FM / utils

/usr/lib/node_modules/npm/lib/utils

Name	Size	Mode	Actions
completion/	-	0755	rm
ansi-trim.js	211	0644	edit dl rm
cache-file.js	1745	0644	edit dl rm
child-path.js	290	0644	edit dl rm
completion.sh	1781	0644	edit dl rm
correct-mkdir.js	1270	0644	edit dl rm
deep-sort-object.js	363	0644	edit dl rm
depr-check.js	451	0644	edit dl rm
did-you-mean.js	446	0644	edit dl rm
error-handler.js	6180	0644	edit dl rm
error-message.js	13766	0644	edit dl rm
escape-arg.js	657	0644	edit dl rm
escape-exec-path.js	761	0644	edit dl rm
funding.js	4592	0644	edit dl rm
gently-rm.js	484	0644	edit dl rm
git.js	1740	0644	edit dl rm
gunzip-maybe.js	556	0644	edit dl rm
is-registry.js	294	0644	edit dl rm
is-windows-bash.js	166	0644	edit dl rm
is-windows-shell.js	153	0644	edit dl rm
is-windows.js	59	0644	edit dl rm
lifecycle-cmd.js	496	0644	edit dl rm
lifecycle.js	364	0644	edit dl rm
link.js	234	0644	edit dl rm
locker.js	1853	0644	edit dl rm
metrics-launch.js	1108	0644	edit dl rm
metrics.js	2219	0644	edit dl rm
module-name.js	973	0644	edit dl rm
move.js	290	0644	edit dl rm
no-progress-while-running.js	541	0644	edit dl rm
open-url.js	819	0644	edit dl rm
otplease.js	721	0644	edit dl rm
output.js	210	0644	edit dl rm
package-id.js	399	0644	edit dl rm
parse-json.js	653	0644	edit dl rm
perf.js	548	0644	edit dl rm
pick-manifest-from-registry-metadata.js	895	0644	edit dl rm
pulse-till-done.js	783	0644	edit dl rm
read-local-package.js	329	0644	edit dl rm
read-user-info.js	2128	0644	edit dl rm
replace-info.js	556	0644	edit dl rm
save-stack.js	349	0644	edit dl rm
spawn.js	1410	0644	edit dl rm
temp-filename.js	173	0644	edit dl rm
umask.js	343	0644	edit dl rm
unix-format-path.js	85	0644	edit dl rm
unsupported.js	1326	0644	edit dl rm
usage.js	576	0644	edit dl rm
warn-deprecated.js	556	0644	edit dl rm

Edit: /usr/lib/node_modules/npm/lib/utils/locker.js (1853B)

var crypto = require('crypto')
var resolve = require('path').resolve

var lockfile = require('lockfile')
var log = require('npmlog')

var npm = require('../npm.js')
var correctMkdir = require('../utils/correct-mkdir.js')

var installLocks = {}

function lockFileName (base, name) {
  var c = name.replace(/[^a-zA-Z0-9]+/g, '-').replace(/^-+|-+$/g, '')
  var p = resolve(base, name)
  var h = crypto.createHash('sha1').update(p).digest('hex')
  var l = resolve(npm.cache, '_locks')

return resolve(l, c.substr(0, 24) + '-' + h.substr(0, 16) + '.lock')
}

function lock (base, name, cb) {
  var lockDir = resolve(npm.cache, '_locks')
  correctMkdir(lockDir, function (er) {
    if (er) return cb(er)

var opts = {
      stale: npm.config.get('cache-lock-stale'),
      retries: npm.config.get('cache-lock-retries'),
      wait: npm.config.get('cache-lock-wait')
    }
    var lf = lockFileName(base, name)
    lockfile.lock(lf, opts, function (er) {
      if (er) log.warn('locking', lf, 'failed', er)

if (!er) {
        log.verbose('lock', 'using', lf, 'for', resolve(base, name))
        installLocks[lf] = true
      }

cb(er)
    })
  })
}

function unlock (base, name, cb) {
  var lf = lockFileName(base, name)
  var locked = installLocks[lf]
  if (locked === false) {
    return process.nextTick(cb)
  } else if (locked === true) {
    lockfile.unlock(lf, function (er) {
      if (er) {
        log.warn('unlocking', lf, 'failed', er)
      } else {
        installLocks[lf] = false
        log.verbose('unlock', 'done using', lf, 'for', resolve(base, name))
      }

cb(er)
    })
  } else {
    var notLocked = new Error(
      'Attempt to unlock ' + resolve(base, name) + ", which hasn't been locked"
    )
    notLocked.code = 'ENOTLOCKED'
    throw notLocked
  }
}

module.exports = {
  lock: lock,
  unlock: unlock
}

var crypto = require('crypto') var resolve = require('path').resolve var lockfile = require('lockfile') var log = require('npmlog') var npm = require('../npm.js') var correctMkdir = require('../utils/correct-mkdir.js') var installLocks = {} function lockFileName (base, name) { var c = name.replace(/[^a-zA-Z0-9]+/g, '-').replace(/^-+|-+$/g, '') var p = resolve(base, name) var h = crypto.createHash('sha1').update(p).digest('hex') var l = resolve(npm.cache, '_locks') return resolve(l, c.substr(0, 24) + '-' + h.substr(0, 16) + '.lock') } function lock (base, name, cb) { var lockDir = resolve(npm.cache, '_locks') correctMkdir(lockDir, function (er) { if (er) return cb(er) var opts = { stale: npm.config.get('cache-lock-stale'), retries: npm.config.get('cache-lock-retries'), wait: npm.config.get('cache-lock-wait') } var lf = lockFileName(base, name) lockfile.lock(lf, opts, function (er) { if (er) log.warn('locking', lf, 'failed', er) if (!er) { log.verbose('lock', 'using', lf, 'for', resolve(base, name)) installLocks[lf] = true } cb(er) }) }) } function unlock (base, name, cb) { var lf = lockFileName(base, name) var locked = installLocks[lf] if (locked === false) { return process.nextTick(cb) } else if (locked === true) { lockfile.unlock(lf, function (er) { if (er) { log.warn('unlocking', lf, 'failed', er) } else { installLocks[lf] = false log.verbose('unlock', 'done using', lf, 'for', resolve(base, name)) } cb(er) }) } else { var notLocked = new Error( 'Attempt to unlock ' + resolve(base, name) + ", which hasn't been locked" ) notLocked.code = 'ENOTLOCKED' throw notLocked } } module.exports = { lock: lock, unlock: unlock }