From 1aed2f793800c8a8f2f50547cc8d3ae1cfde5b33 Mon Sep 17 00:00:00 2001 From: Brian White Date: Sun, 27 Jul 2014 21:27:20 -0400 Subject: [PATCH] Connection: fix style --- lib/Connection.js | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/lib/Connection.js b/lib/Connection.js index 86ee924..9c3872c 100644 --- a/lib/Connection.js +++ b/lib/Connection.js @@ -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);