Fix #40: Hangs when receiving a value > 250 bytes.

mysql-d · May 30, 2014 · 1dd2996 · 1dd2996
1 parent 2e97d24
commit 1dd2996
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/source/mysql/connection.d b/source/mysql/connection.d
@@ -1373,7 +1373,17 @@ body
     if(lcb.isNull || lcb.isIncomplete)
         return lcb;
     assert(packet.length >= lcb.totalBytes);
-    lcb.value = packet.decode!ulong(lcb.numBytes);
+
+    if(lcb.numBytes == 0)
+        lcb.value = 0;
+    else if(lcb.numBytes == 1)
+        lcb.value = packet.decode!ulong(lcb.numBytes);
+    else
+    {
+        // Skip the throwaway byte that indicated "at least 2 more bytes coming"
+        lcb.value = packet[1..$].decode!ulong(lcb.numBytes);
+    }
+
     return lcb;
 }