Changeset 69 for osgVisual/src/cluster/dataIO_clusterENet_implementation.cpp

Timestamp:

Jul 20, 2010, 10:44:13 AM (14 years ago)

Author:

Torben Dannhauer

Message:

Network sync:
now works:

• serialization of transport container
• transport via ENet UDP
• de-serialization of the transport container.
• transport of viewmatrix and framenumber to the slave.

ToDo?: apply viewmatrix on slave still do not work.

File:

• osgVisual/src/cluster/dataIO_clusterENet_implementation.cpp (modified) (4 diffs)

osgVisual/src/cluster/dataIO_clusterENet_implementation.cpp

@@ -21 +21 @@
 int dataIO_clusterENet_implementation::activeENetInstances = 0;
 
-dataIO_clusterENet_implementation::dataIO_clusterENet_implementation()
+dataIO_clusterENet_implementation::dataIO_clusterENet_implementation(std::string& receivedTransportContainer_)
+: receivedTransportContainer(receivedTransportContainer_)
 {
         std::cout << "Instantiated server class# "<< activeENetInstances << std::endl;
@@ -142 +143 @@
         if( peerList.size() == 0 )
         {
-                std::cout << "dataIO_clusterENet_implementation::sendPacket() - ERROR: No connected peer available!" << std::endl;
+                //std::cout << "dataIO_clusterENet_implementation::sendPacket() - ERROR: No connected peer available!" << std::endl;
                 return;
         }
@@ -215 +216 @@
 {
         if(currentRole != dataIO_clusterENet_implementation::CLIENT)
+        {
+                std::cout << "dataIO_clusterENet_implementation::connectTo() : ERROR: ENet does not work as client - ignoring to connect!" << std::endl;
                 return false;
+        }
 
         ENetAddress address;
@@ -257 +261 @@
 void dataIO_clusterENet_implementation::onReceivePacket(ENetEvent* event_)
 {
-                std::string datastring;
-                datastring.assign((char*)(event_->packet->data), event_->packet->dataLength);   
-                std::cout << "A packet of length "<<event_->packet->dataLength<<" containing "<<datastring<<" was received from "<<datastring<<" on channel "<<(int)(event_->channelID)<<std::endl;
-                datastring+=std::string("answer");
-
-                ENetPacket * packet = enet_packet_create (datastring.c_str(), 
-                                                                                                  datastring.size(), 
-                                                                                                  ENET_PACKET_FLAG_RELIABLE);
-                
-                // Send answer
-                sendPacket( packet, 0, 0, true);
+                receivedTransportContainer.assign((char*)(event_->packet->data), event_->packet->dataLength);   
+                //std::cout << "A packet of length "<<event_->packet->dataLength<<" containing "<<receivedTransportContainer<<" was received from "<<receivedTransportContainer<<" on channel "<<(int)(event_->channelID)<<std::endl;
 }