YUKI Hiroshi
null+****@clear*****
Wed Apr 29 15:03:32 JST 2015
YUKI Hiroshi 2015-04-29 15:03:32 +0900 (Wed, 29 Apr 2015) New Revision: da567b0ac0a83c525772dc15dc21dd92ac20978b https://github.com/droonga/express-droonga/commit/da567b0ac0a83c525772dc15dc21dd92ac20978b Message: Reduce duplicated information Modified files: lib/droonga-protocol/connection.js Modified: lib/droonga-protocol/connection.js (+7 -7) =================================================================== --- lib/droonga-protocol/connection.js 2015-04-29 14:44:31 +0900 (d43c161) +++ lib/droonga-protocol/connection.js 2015-04-29 15:03:32 +0900 (61e47de) @@ -133,7 +133,7 @@ Connection.prototype._initReceiver = function() { }).bind(this)); var tag = this.tag + '.message'; - this._logger.trace(LOG_PREFIX + 'Connection._initReceiver %d (%s): %d %d:', + this._logger.trace(LOG_PREFIX + '_initReceiver %d (%s): %d %d:', this._id, this.hostAndPort, receiver._id, this.receivePort, tag); this._receiver = receiver; @@ -149,14 +149,14 @@ Connection.prototype._handleMessage = function(envelope) { var inReplyTo = envelope.inReplyTo; if (inReplyTo) { delete this._sendingMessages[inReplyTo]; - this._logger.trace(LOG_PREFIX + 'Connection._handleMessage.reply %d (%s):', + this._logger.trace(LOG_PREFIX + '_handleMessage.reply %d (%s):', this._id, this.hostAndPort, envelope); var errorCode = envelope.statusCode; if (!errorCode || isSuccess(errorCode)) errorCode = null; this.emit('reply:' + inReplyTo, errorCode, envelope); } else { - this._logger.trace(LOG_PREFIX + 'Connection._handleMessage.message %d (%s):', + this._logger.trace(LOG_PREFIX + '_handleMessage.message %d (%s):', this._id, this.hostAndPort, envelope); this.emit(envelope.type, envelope); } @@ -220,7 +220,7 @@ Connection.prototype.emitMessage = function(type, body, callback, options) { } if (!this.receivePort) { - this._logger.trace(LOG_PREFIX + 'Connection.emitMessage %d (%s): ' + + this._logger.trace(LOG_PREFIX + 'emitMessage %d (%s): ' + 'Receiver is not initialized yet. ' + 'Given message will be sent later.', this._id, this.hostAndPort); @@ -229,7 +229,7 @@ Connection.prototype.emitMessage = function(type, body, callback, options) { } var id = createId(); - this._logger.trace(LOG_PREFIX + 'Connection.emitMessage %d (%s):', + this._logger.trace(LOG_PREFIX + 'emitMessage %d (%s):', this._id, this.hostAndPort); var from = this.getRouteToSelf(options); var envelope = { @@ -261,7 +261,7 @@ Connection.prototype.emitMessage = function(type, body, callback, options) { var event = 'reply:' + id; var timeoutId; this.once(event, (function(errorCode, response) { - this._logger.trace(LOG_PREFIX + 'Connection.emitMessage.reply %d (%s):', + this._logger.trace(LOG_PREFIX + 'emitMessage.reply %d (%s):', this._id, this.hostAndPort, errorCode); if (timeoutId) clearTimeout(timeoutId); @@ -311,7 +311,7 @@ Connection.prototype.thenableEmitMessage = function(type, body, options) { }; Connection.prototype._sendPendingMessages = function() { - this._logger.trace(LOG_PREFIX + 'Connection._sendPendingMessages %d (%s): ' + + this._logger.trace(LOG_PREFIX + '_sendPendingMessages %d (%s): ' + 'Send %d pending message(s).', this._id, this.hostAndPort, this._pendingMessages.length); -------------- next part -------------- HTML����������������������������... 다운로드