performance improvements

lib/connection.js

@@ -242,6 +242,9 @@ Connection.prototype.accept = function (socket) {
 
 Connection.prototype.init = function (socket) {
     this.socket = socket;
+    if (this.get_option('tcp_no_delay', false) && this.socket.setNoDelay) {
+        this.socket.setNoDelay(true);
+    }
     this.socket.on('data', this.input.bind(this));
     this.socket.on('error', this.on_error.bind(this));
     this.socket.on('end', this.eof.bind(this));
@@ -297,6 +300,9 @@ Connection.prototype.attach_sender = function (options) {
 Connection.prototype.open_sender = Connection.prototype.attach_sender;//alias
 
 Connection.prototype.attach_receiver = function (options) {
+    if (this.get_option('tcp_no_delay', true) && this.socket.setNoDelay) {
+        this.socket.setNoDelay(true);
+    }
     return this.session_policy.get_session().attach_receiver(options);
 };
 Connection.prototype.open_receiver = Connection.prototype.attach_receiver;//alias

lib/link.js

@@ -305,7 +305,7 @@ Sender.prototype.send = function (msg, tag) {
 var Receiver = function (session, name, local_handle, opts) {
     this.init(session, name, local_handle, opts, true);
     this.drain = false;
-    this.set_credit_window(this.get_option('credit_window', 1000));
+    this.set_credit_window(this.get_option('credit_window', 100));
     if (this.get_option('autoaccept', true)) {
         this.observers.on('message', auto_accept);
     }

lib/message.js

@@ -328,11 +328,6 @@ message.decode = function(buffer) {
             console.warn('WARNING: expected described message section got ' + JSON.stringify(s));
         }
     }
-    if (msg.application_properties) {
-        for (var key in msg.application_properties) {
-            add_property_shortcut(msg, 'application_properties', key);
-        }
-    }
     return msg;
 };
 

lib/transport.js

@@ -77,7 +77,7 @@ Transport.prototype.read = function (buffer) {
             offset = 8;
         }
     }
-    while (offset < buffer.length && !this.read_complete) {
+    while (offset < (buffer.length - 4) && !this.read_complete) {
         var frame_size = buffer.readUInt32BE(offset);
         log.io('[%s] got frame of size %d', this.identifier, frame_size);
         if (buffer.length < offset + frame_size) {