fixed the problems

change new Buffer() to Buffer.alloc

Author: amiiigh

lib/LinkedList.js

@@ -102,6 +102,9 @@ LinkedList.prototype._insert = function (parentNode, object) {
 
   if (order <= -1) {
     var node = new Node(object);
+    if (this._currentNode.value > node.value) {
+      this._currentNode = node
+    }
     node._childNode = parentNode._childNode;
     parentNode._childNode = node;
     return InsertionResult.INSERTED;

lib/Packet.js

@@ -20,7 +20,7 @@ function Packet(sequenceNumber, payload, synchronize, reset) {
     this._reset           = !!(bools & 0x10);
 
     this._sequenceNumber = segment.readUInt8(offset); offset++;
-    this._payload = new Buffer(segment.length - offset);
+    this._payload = Buffer.alloc(segment.length - offset);
     segment.copy(this._payload, 0, offset);
   } else {
     this._acknowledgement = false;
@@ -33,13 +33,13 @@ function Packet(sequenceNumber, payload, synchronize, reset) {
 };
 
 Packet.createAcknowledgementPacket = function (sequenceNumber) {
-  var packet = new Packet(sequenceNumber, new Buffer(0), false);
+  var packet = new Packet(sequenceNumber, Buffer.alloc(0), false);
   packet._acknowledgement = true;
   return packet;
 };
 
 Packet.createFinishPacket = function () {
-  var packet = new Packet(0, new Buffer(0), false, false);
+  var packet = new Packet(0, Buffer.alloc(0), false, false);
   packet._finish = true;
   return packet;
 };
@@ -75,7 +75,7 @@ Packet.prototype.getIsReset = function () {
  */
 Packet.prototype.toBuffer = function () {
   var offset = 0;
-  var retval = new Buffer(2 + this._payload.length);
+  var retval = Buffer.alloc(2 + this._payload.length);
 
   var bools = 0 + (
     (this._acknowledgement && 0x80) |
@@ -116,4 +116,4 @@ Packet.prototype.equals = function (packet) {
     this.getSequenceNumber() === packet.getSequenceNumber() &&
     bufferEqual(this.getPayload(), packet.getPayload())
   )
-};
+};

lib/Receiver.js

@@ -27,19 +27,15 @@ Receiver.prototype.receive = function (packet) {
   }
 
   // Ignores packets that have a sequence number less than the next sequence
-  // number
-  if (!packet.getIsSynchronize() && packet.getSequenceNumber() < this._syncSequenceNumber) {
+  // number. sending the ack again
+  if (!packet.getIsSynchronize() && packet.getSequenceNumber() < this._nextSequenceNumber) {
+    this._packetSender.send(Packet.createAcknowledgementPacket(packet.getSequenceNumber()));
     return;
   }
 
   if (packet.getIsSynchronize() && !this._synced) {
     // This is the beginning of the stream.
 
-    if (packet.getSequenceNumber() === this._syncSequenceNumber) {
-      this._packetSender.send(Packet.createAcknowledgementPacket(packet.getSequenceNumber()));
-      return;
-    }
-
     // Send the packet upstream, send acknowledgement packet to end host, and
     // increment the next expected packet.
     this._packets.clear();
@@ -59,6 +55,11 @@ Receiver.prototype.receive = function (packet) {
     // We're done.
     return;
 
+  } else if (packet.getIsSynchronize() && this._synced && this._syncSequenceNumber === packet.getSequenceNumber()) {
+    // this will happen if the ack for sync message get lost so we will send it again
+    this._packetSender.send(Packet.createAcknowledgementPacket(packet.getSequenceNumber()));
+    // and we are done!
+    return;
   } else if (packet.getIsReset()) {
     this.emit('_reset');
     this._synced = false;
@@ -90,7 +91,6 @@ Receiver.prototype.receive = function (packet) {
   // after the current packet. If there are, then check to see if the next
   // packet is the expected packet number. If it is, then start the
   // acknowledgement process anew.
-
   var result = this._packets.insert(packet);
   if (result === LinkedList.InsertionResult.INSERTED) {
     this._pushIfExpectedSequence(packet);

lib/Sender.js

@@ -69,6 +69,7 @@ Window.prototype.send = function () {
       }
     }
 
+
     pkts.forEach(function (packet) {
       packet.on('acknowledge', onAcknowledge);
       packet.send();

lib/Server.js

@@ -15,7 +15,6 @@ function Server(socket) {
   this._connections = {};
 
   var self = this;
-
   socket.on('message', function (message, rinfo) {
     var addressKey = rinfo.address + rinfo.port;
     var connection;
@@ -29,7 +28,6 @@ function Server(socket) {
       self.emit('connection', connection);
     } else {
       // Just get the existing connection.
-
       connection = self._connections[addressKey];
     }
 
@@ -38,7 +36,6 @@ function Server(socket) {
 
     if (packet.getIsFinish()) {
       // The client requested that the connection be closed.
-
       delete self._connections[addressKey];
     } else {
       // Capture the packet, and place it into the window of packets.

lib/bufferEqual.js

@@ -1,5 +1,3 @@
-
-var buffertools = require('buffertools')
 module.exports = function bufferEqual(a, b) {
-  return buffertools.compare(a, b) === 0
+  return Buffer.compare(a, b) === 0
 }