1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
var crypto = require("crypto")
var resolve = require("path").resolve
var lockfile = require("lockfile")
var log = require("npmlog")
var mkdirp = require("mkdirp")
var npm = require("../npm.js")
var getStat = require("../cache/get-stat.js")
var installLocks = {}
function lockFileName (base, name) {
var c = name.replace(/[^a-zA-Z0-9]+/g, "-").replace(/^-+|-+$/g, "")
, p = resolve(base, name)
, h = crypto.createHash("sha1").update(p).digest("hex")
, l = resolve(npm.cache, "_locks")
return resolve(l, c.substr(0, 24)+"-"+h.substr(0, 16)+".lock")
}
function lock (base, name, cb) {
getStat(function (er) {
var lockDir = resolve(npm.cache, "_locks")
mkdirp(lockDir, function () {
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)
, 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 {
throw new Error(
"Attempt to unlock " + resolve(base, name) + ", which hasn't been locked"
)
}
}
module.exports = {
lock : lock,
unlock : unlock
}
|
