Merge lp:~oxan/gearman.net/bugfix into lp:gearman.net

[Oxan van Leeuwen]

Use incremental receiving. Socket.Receive doesn't guarant that it reads all bytes you specify, it just reads at least 1 byte. If the payload is big, we need to call Receive multiple times to read the whole payload.

Unmerged revisions

24. By Oxan van Leeuwen on 2010-09-01

Use incremental receiving. Socket.Receive doesn't guarant that it reads all bytes you specify, it just reads at least 1 byte. If the payload is big, we need to call Receive multiple times to read the whole payload.

=== modified file 'src/Connection.cs'
--- src/Connection.cs	2009-12-18 16:00:24 +0000
+++ src/Connection.cs	2010-09-01 20:31:48 +0000
@@ -113,6 +113,7 @@
 		{
 			int messagesize = -1; 
 			int messagetype = -1; 
+			int read = 0;
 			
 			// Initialize to 12 bytes (header only), and resize later as needed
 			byte[] header = new byte[12];
@@ -144,7 +145,9 @@
 					Array.Copy(header, packet, header.Length);
 					
 					// Receive the remainder of the message 
-					conn.Receive(packet, 12, messagesize, 0); 
+					do {
+						read += conn.Receive(packet, 12 + read, messagesize - read, 0); 
+					} while(read < messagesize);
 				} else {
 					packet = header; 
 				}