This commit is contained in:
isaacs 2013-04-11 11:06:07 -07:00
parent 50be39792a
commit 22c7d134e2
2 changed files with 5 additions and 4 deletions

View File

@ -142,9 +142,9 @@ cluster.setupMaster = function(options) {
var INTERNAL_PREFIX = 'NODE_CLUSTER_'; var INTERNAL_PREFIX = 'NODE_CLUSTER_';
function isInternalMessage(message) { function isInternalMessage(message) {
return isObject(message) && return isObject(message) &&
typeof message.cmd === 'string' && typeof message.cmd === 'string' &&
message.cmd.length > INTERNAL_PREFIX.length && message.cmd.length > INTERNAL_PREFIX.length &&
message.cmd.slice(0, INTERNAL_PREFIX.length) === INTERNAL_PREFIX; message.cmd.slice(0, INTERNAL_PREFIX.length) === INTERNAL_PREFIX;
} }
// Modify message object to be internal // Modify message object to be internal

View File

@ -673,11 +673,12 @@ Socket.prototype.__defineGetter__('bytesWritten', function() {
bytes += Buffer.byteLength(el.chunk, el.encoding); bytes += Buffer.byteLength(el.chunk, el.encoding);
}); });
if (data) if (data) {
if (Buffer.isBuffer(data)) if (Buffer.isBuffer(data))
bytes += data.length; bytes += data.length;
else else
bytes += Buffer.byteLength(data, encoding); bytes += Buffer.byteLength(data, encoding);
}
return bytes; return bytes;
}); });