Changeset 5747 in orxonox.OLD for branches/network/src/lib/network/network_stream.cc

Timestamp:

Nov 23, 2005, 11:32:20 PM (19 years ago)

Author:

patrick

Message:

network: some small changes in the NetworkStream and DataStream modules (see mail), printf output in the network_unit_test and short flag

File:

• branches/network/src/lib/network/network_stream.cc (modified) (5 diffs)

branches/network/src/lib/network/network_stream.cc

@@ -19 +19 @@
 */
 #define DEBUG_MODULE_NETWORK
-#define PACKAGE_SIZE  256
+
 
 #include "base_object.h"
@@ -35 +35 @@
 using namespace std;
 
+
+#define PACKAGE_SIZE  256
 
 
@@ -102 +104 @@
   
   /* send the received data to connectionMonitor */
-  this->connectionMonitor->processPacket((byte*)downBuffer, PACKAGE_SIZE);
+  this->connectionMonitor->processPacket((byte*)downBuffer, ret + sizeof(Header));
 
-        this->networkProtocol->createHeader((byte*) downBuffer , PACKAGE_SIZE , 1024,*(this->synchronizeables),12);
+  this->networkProtocol->createHeader((byte*)downBuffer, ret, DATA_STREAM_BUFFER_SIZE,
+                                       *(this->synchronizeables), 12);
         
   /* pass the data to the network socket */
@@ -119 +122 @@
   /* first of all read  data from networkSocket*/
   while(ret == 0)
-  ret = this->networkSocket->readBlock((byte*)upBuffer,PACKAGE_SIZE + sizeof(Header));
+  ret = this->networkSocket->readBlock((byte*)upBuffer, PACKAGE_SIZE + sizeof(Header));
   /* error checking: data read? */
-  if( ret != PACKAGE_SIZE) { PRINTF(0)("Error while reading data from the NetworkSocket\n");}
+  if( ret != PACKAGE_SIZE + sizeof(Header)) { PRINTF(0)("Error while reading data from the NetworkSocket\n");}
 
   /* send the received data to connectionMonitor */
@@ -130 +133 @@
     
   /* now pass the data to the sync object */
-  this->synchronizeables->writeBytes((byte*)upBuffer[sizeof(Header)], PACKAGE_SIZE);
+  this->synchronizeables->writeBytes((byte*)upBuffer, PACKAGE_SIZE);
 
 }