|
|
@ -369,15 +369,19 @@ var getDeletedPads = function (Env, channels, cb) {
|
|
|
|
|
|
|
|
|
|
|
|
var sem = Saferphore.create(10);
|
|
|
|
var sem = Saferphore.create(10);
|
|
|
|
var absentees = [];
|
|
|
|
var absentees = [];
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var job = function (channel, wait) {
|
|
|
|
|
|
|
|
return function (give) {
|
|
|
|
|
|
|
|
getFileSize(Env, channel, wait(give(function (e, size) {
|
|
|
|
|
|
|
|
if (e) { return; }
|
|
|
|
|
|
|
|
if (size === 0) { absentees.push(channel); }
|
|
|
|
|
|
|
|
})));
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
nThen(function (w) {
|
|
|
|
nThen(function (w) {
|
|
|
|
for (var i = 0; i < L; i++) {
|
|
|
|
for (var i = 0; i < L; i++) {
|
|
|
|
let channel = channels[i];
|
|
|
|
sem.take(job(channels[i], w));
|
|
|
|
sem.take(function (give) {
|
|
|
|
|
|
|
|
getFileSize(Env, channel, w(give(function (e, size) {
|
|
|
|
|
|
|
|
if (e) { return; }
|
|
|
|
|
|
|
|
if (size === 0) { absentees.push(channel); }
|
|
|
|
|
|
|
|
})));
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}).nThen(function () {
|
|
|
|
}).nThen(function () {
|
|
|
|
cb(void 0, absentees);
|
|
|
|
cb(void 0, absentees);
|
|
|
|