|
|
@ -113,7 +113,7 @@ function Socket (peerInfo) { |
|
|
|
if (!recvMsg.fd && bytesRead == 0) { |
|
|
|
self.readable = false; |
|
|
|
self._readWatcher.stop(); |
|
|
|
self.emit('eof'); |
|
|
|
self.emit('end'); |
|
|
|
if (!self.writable) self.forceClose(); |
|
|
|
} else if (bytesRead > 0) { |
|
|
|
var start = recvBuffer.used; |
|
|
@ -266,10 +266,10 @@ Socket.prototype.send = function (data, encoding) { |
|
|
|
} else { |
|
|
|
// data is a process.Buffer
|
|
|
|
// walk through the sendQueue, find the first empty buffer
|
|
|
|
var inserted = false; |
|
|
|
//var inserted = false;
|
|
|
|
data.sent = 0; |
|
|
|
data.used = data.length; |
|
|
|
if (!inserted) self.sendQueue.push(data); |
|
|
|
self.sendQueue.push(data); |
|
|
|
self.sendQueueSize += data.used; |
|
|
|
} |
|
|
|
return this.flush(); |
|
|
|