[Box Backup-commit] COMMIT r3370 - box/trunk/test/basicserver

subversion at boxbackup.org subversion at boxbackup.org
Fri Aug 15 23:48:07 BST 2014


Author: chris
Date: 2014-08-15 23:48:07 +0100 (Fri, 15 Aug 2014)
New Revision: 3370

Modified:
   box/trunk/test/basicserver/testbasicserver.cpp
Log:
Add missing network operation timeouts to test/basicserver.

Modified: box/trunk/test/basicserver/testbasicserver.cpp
===================================================================
--- box/trunk/test/basicserver/testbasicserver.cpp	2014-08-15 22:48:05 UTC (rev 3369)
+++ box/trunk/test/basicserver/testbasicserver.cpp	2014-08-15 22:48:07 UTC (rev 3370)
@@ -36,6 +36,7 @@
 // in ms
 #define COMMS_READ_TIMEOUT					4
 #define COMMS_SERVER_WAIT_BEFORE_REPLYING	40
+#define SHORT_TIMEOUT 5000
 
 class basicdaemon : public Daemon
 {
@@ -112,7 +113,7 @@
 				}
 				for(int s = 0; s < (LARGE_DATA_SIZE / LARGE_DATA_BLOCK_SIZE); ++s)
 				{
-					rStream.Write(data, sizeof(data));
+					rStream.Write(data, sizeof(data), SHORT_TIMEOUT);
 				}
 			}
 			{
@@ -120,7 +121,8 @@
 				char buf[1024];
 				int total = 0;
 				int r = 0;
-				while(total < LARGE_DATA_SIZE && (r = rStream.Read(buf, sizeof(buf))) != 0)
+				while(total < LARGE_DATA_SIZE &&
+					(r = rStream.Read(buf, sizeof(buf), SHORT_TIMEOUT)) != 0)
 				{
 					total += r;
 				}
@@ -142,7 +144,7 @@
 				}
 				for(int s = 0; s < (LARGE_DATA_SIZE / LARGE_DATA_BLOCK_SIZE); ++s)
 				{
-					rStream.Write(data, sizeof(data));
+					rStream.Write(data, sizeof(data), SHORT_TIMEOUT);
 				}
 			}
 			
@@ -336,7 +338,7 @@
 	}
 	for(unsigned int c = 0; c < conns.size(); ++c)
 	{
-		conns[c]->Write("LARGEDATA\n", 10);
+		conns[c]->Write("LARGEDATA\n", 10, SHORT_TIMEOUT);
 	}
 	for(unsigned int c = 0; c < conns.size(); ++c)
 	{
@@ -344,7 +346,8 @@
 		char buf[1024];
 		int total = 0;
 		int r = 0;
-		while(total < LARGE_DATA_SIZE && (r = conns[c]->Read(buf, sizeof(buf))) != 0)
+		while(total < LARGE_DATA_SIZE &&
+			(r = conns[c]->Read(buf, sizeof(buf), SHORT_TIMEOUT)) != 0)
 		{
 			total += r;
 		}
@@ -360,7 +363,7 @@
 		}
 		for(int s = 0; s < (LARGE_DATA_SIZE / LARGE_DATA_BLOCK_SIZE); ++s)
 		{
-			conns[c]->Write(data, sizeof(data));
+			conns[c]->Write(data, sizeof(data), SHORT_TIMEOUT);
 		}
 	}
 	for(unsigned int c = 0; c < conns.size(); ++c)
@@ -369,7 +372,8 @@
 		char buf[1024];
 		int total = 0;
 		int r = 0;
-		while(total < LARGE_DATA_SIZE && (r = conns[c]->Read(buf, sizeof(buf))) != 0)
+		while(total < LARGE_DATA_SIZE &&
+			(r = conns[c]->Read(buf, sizeof(buf), SHORT_TIMEOUT)) != 0)
 		{
 			total += r;
 		}
@@ -412,7 +416,8 @@
 	while(stream->StreamDataLeft())
 	{
 		// Read some data
-		int bytes = stream->Read(((char*)values) + bytesleft, sizeof(values) - bytesleft);
+		int bytes = stream->Read(((char*)values) + bytesleft,
+			sizeof(values) - bytesleft, SHORT_TIMEOUT);
 		bytessofar += bytes;
 		bytes += bytesleft;
 		int n = bytes / 4;




More information about the Boxbackup-commit mailing list