Spaces:
Sleeping
Sleeping
File size: 1,556 Bytes
6491ad4 | 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 | 'use strict'
const MAX_TIMEOUT = 1000
function wait (state, index, expected, timeout, done) {
const max = Date.now() + timeout
let current = Atomics.load(state, index)
if (current === expected) {
done(null, 'ok')
return
}
let prior = current
const check = (backoff) => {
if (Date.now() > max) {
done(null, 'timed-out')
} else {
setTimeout(() => {
prior = current
current = Atomics.load(state, index)
if (current === prior) {
check(backoff >= MAX_TIMEOUT ? MAX_TIMEOUT : backoff * 2)
} else {
if (current === expected) done(null, 'ok')
else done(null, 'not-equal')
}
}, backoff)
}
}
check(1)
}
// let waitDiffCount = 0
function waitDiff (state, index, expected, timeout, done) {
// const id = waitDiffCount++
// process._rawDebug(`>>> waitDiff ${id}`)
const max = Date.now() + timeout
let current = Atomics.load(state, index)
if (current !== expected) {
done(null, 'ok')
return
}
const check = (backoff) => {
// process._rawDebug(`${id} ${index} current ${current} expected ${expected}`)
// process._rawDebug('' + backoff)
if (Date.now() > max) {
done(null, 'timed-out')
} else {
setTimeout(() => {
current = Atomics.load(state, index)
if (current !== expected) {
done(null, 'ok')
} else {
check(backoff >= MAX_TIMEOUT ? MAX_TIMEOUT : backoff * 2)
}
}, backoff)
}
}
check(1)
}
module.exports = { wait, waitDiff }
|