Socket write speed

lib/net_uv.js

@@ -57,7 +57,8 @@ exports.connect = exports.createConnection = function(port /* [host], [cb] */) {
 
 /* called when creating new Socket, or when re-using a closed Socket */
 function initSocketHandle(self) {
-  self._writeRequests = [];
+  self._writeRequestsHead = null;
+  self._writeRequestsTail = null;
 
   self._flags = 0;
   self._connectQueueSize = 0;
@@ -235,7 +236,7 @@ Socket.prototype.destroySoon = function() {
   this.writable = false;
   this._flags |= FLAG_DESTROY_SOON;
 
-  if (this._writeRequests.length == 0) {
+  if (!this._writeRequestsHead) {
     this.destroy();
   }
 };
@@ -392,7 +393,14 @@ Socket.prototype.write = function(data /* [encoding], [fd], [cb] */) {
 
   writeReq.oncomplete = afterWrite;
   writeReq.cb = cb;
-  this._writeRequests.push(writeReq);
+  writeReq.next = null;
+
+  if (this._writeRequestsTail) {
+    this._writeRequestsTail.next = writeReq;
+    this._writeRequestsTail = writeReq;
+  } else {
+    this._writeRequestsHead = this._writeRequestsTail = writeReq;
+  }
 
   return this._handle.writeQueueSize == 0;
 };
@@ -407,18 +415,23 @@ function afterWrite(status, handle, req, buffer) {
   }
   // TODO check status.
 
-  var req_ = self._writeRequests.shift();
+  var req_ = self._writeRequestsHead;
+  if (req_.next) {
+    self._writeRequestsHead = req_.next;
+  } else {
+    self._writeRequestsHead = self._writeRequestsTail = null;
+  }
   assert.equal(req, req_);
 
-  if (self._writeRequests.length == 0) {
+  if (!self._writeRequestsHead) {
     // TODO remove all uses of ondrain - this is not a good hack.
     if (self.ondrain) self.ondrain();
     self.emit('drain');
   }
 
   if (req.cb) req.cb();
 
-  if (self._writeRequests.length == 0 && self._flags & FLAG_DESTROY_SOON) {
+  if (!self._writeRequestsHead && self._flags & FLAG_DESTROY_SOON) {
     self.destroy();
   }
 }