|
|
@ -110,6 +110,7 @@ Workers.initialize = function (Env, config, _cb) {
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const txid = guid();
|
|
|
|
var cb = Util.once(Util.mkAsync(Util.both(_cb, function (err /*, value */) {
|
|
|
|
var cb = Util.once(Util.mkAsync(Util.both(_cb, function (err /*, value */) {
|
|
|
|
if (err !== 'TIMEOUT') { return; }
|
|
|
|
if (err !== 'TIMEOUT') { return; }
|
|
|
|
// in the event of a timeout the user will receive an error
|
|
|
|
// in the event of a timeout the user will receive an error
|
|
|
@ -124,7 +125,6 @@ Workers.initialize = function (Env, config, _cb) {
|
|
|
|
return void cb('ESERVERERR');
|
|
|
|
return void cb('ESERVERERR');
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const txid = guid();
|
|
|
|
|
|
|
|
msg.txid = txid;
|
|
|
|
msg.txid = txid;
|
|
|
|
msg.pid = PID;
|
|
|
|
msg.pid = PID;
|
|
|
|
|
|
|
|
|
|
|
|