[CONJS-132] Adding 'fast path' implementation: mysql packet usually never split header into multiple TCP packet

Author: rusher

lib/io/compression-input-stream.js

@@ -70,6 +70,20 @@ class CompressionInputStream {
     do {
       if (this.remainingLen) {
         length = this.remainingLen;
+      } else if (this.headerLen === 0 && chunkLen - pos >= 7) {
+        this.header[0] = chunk[pos];
+        this.header[1] = chunk[pos + 1];
+        this.header[2] = chunk[pos + 2];
+        this.header[3] = chunk[pos + 3];
+        this.header[4] = chunk[pos + 4];
+        this.header[5] = chunk[pos + 5];
+        this.header[6] = chunk[pos + 6];
+        this.headerLen = 7;
+        pos += 7;
+        this.compressPacketLen = this.header[0] + (this.header[1] << 8) + (this.header[2] << 16);
+        this.packetLen = this.header[4] | (this.header[5] << 8) | (this.header[6] << 16);
+        if (this.packetLen === 0) this.packetLen = this.compressPacketLen;
+        length = this.compressPacketLen;
       } else {
         length = null;
         while (chunkLen - pos > 0) {

lib/io/packet-input-stream.js

@@ -128,6 +128,15 @@ class PacketInputStream {
       //read header
       if (this.remainingLen) {
         length = this.remainingLen;
+      } else if (this.headerLen === 0 && chunkLen - pos >= 4) {
+        this.header[0] = chunk[pos];
+        this.header[1] = chunk[pos + 1];
+        this.header[2] = chunk[pos + 2];
+        this.header[3] = chunk[pos + 3];
+        pos += 4;
+        this.headerLen = 4;
+        this.packetLen = this.header[0] + (this.header[1] << 8) + (this.header[2] << 16);
+        length = this.packetLen;
       } else {
         length = null;
         while (chunkLen - pos > 0) {

test/conf.js

@@ -5,7 +5,7 @@ let baseConfig = {
   database: 'testn',
   host: 'localhost',
   connectTimeout: 1000,
-  port: 3308
+  port: 3306
 };
 
 if (process.env.TEST_HOST) baseConfig['host'] = process.env.TEST_HOST;