|
|
|
@ -1545,7 +1545,7 @@ Connection.prototype._doKeepaliveTimer = function(immediate) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
self._doKeepaliveTimer();
|
|
|
|
|
self._tmrKeepalive = setTimeout(timerfn, KEEPALIVE_INTERVAL);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
@ -1689,11 +1689,10 @@ Connection.prototype._processQueue = function() {
|
|
|
|
|
this.debug && this.debug('=> ' + inspect(out));
|
|
|
|
|
this._sock.write(out + CRLF, 'utf8');
|
|
|
|
|
|
|
|
|
|
if (! this._curReq.literalAppendData)
|
|
|
|
|
return;
|
|
|
|
|
|
|
|
|
|
// LITERAL+: we are appending a mesage, and not waiting for a reply
|
|
|
|
|
this._sockWriteAppendData(this._curReq.literalAppendData);
|
|
|
|
|
if (this._curReq.literalAppendData) {
|
|
|
|
|
// LITERAL+: we are appending a mesage, and not waiting for a reply
|
|
|
|
|
this._sockWriteAppendData(this._curReq.literalAppendData);
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Connection.prototype._sockWriteAppendData = function(appendData)
|
|
|
|
@ -1714,11 +1713,12 @@ Connection.prototype._enqueue = function(fullcmd, promote, cb) {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var info = {
|
|
|
|
|
type: fullcmd.match(RE_CMD)[1],
|
|
|
|
|
fullcmd: fullcmd,
|
|
|
|
|
cb: cb,
|
|
|
|
|
cbargs: []
|
|
|
|
|
}, self = this;
|
|
|
|
|
type: fullcmd.match(RE_CMD)[1],
|
|
|
|
|
fullcmd: fullcmd,
|
|
|
|
|
cb: cb,
|
|
|
|
|
cbargs: []
|
|
|
|
|
},
|
|
|
|
|
self = this;
|
|
|
|
|
|
|
|
|
|
if (promote)
|
|
|
|
|
this._queue.unshift(info);
|
|
|
|
|