Changeset 7681 in orxonox.OLD for branches

Timestamp:

May 18, 2006, 2:32:47 PM (19 years ago)

Author:

rennerc

Message:

finished and tested MessageManager

Location:

branches/network/src

Files:

• lib/network/handshake.cc (modified) (2 diffs)
• lib/network/handshake.h (modified) (2 diffs)
• lib/network/message_manager.cc (modified) (3 diffs)
• lib/network/message_manager.h (modified) (5 diffs)
• lib/network/network_stream.cc (modified) (5 diffs)
• subprojects/network/network_unit_test.cc (modified) (5 diffs)

branches/network/src/lib/network/handshake.cc

@@ -24 +24 @@
 #include <cassert>
 
-Handshake::Handshake( bool server, int clientId, int networkGameManagerId )
+Handshake::Handshake( bool server, int clientId, int networkGameManagerId, int messageManagerId )
   : Synchronizeable()
 {
@@ -33 +33 @@
   this->localState.hostId = clientId;
   this->localState.networkManagerId = networkGameManagerId;
+  this->localState.messageManagerId = messageManagerId;
  
   orxId_handler = registerVarId( new SynchronizeableInt( &localState.orxId, &remoteState.orxId, "orxonoxId", PERMISSION_ALL ) );
   version_handler = registerVarId( new SynchronizeableInt( &localState.version, &remoteState.version, "version", PERMISSION_ALL ) );
   netManId_handler = registerVarId( new SynchronizeableInt( &localState.networkManagerId, &remoteState.networkManagerId, "networkManagerId", PERMISSION_ALL ) );
+  netManId_handler = registerVarId( new SynchronizeableInt( &localState.messageManagerId, &remoteState.messageManagerId, "networkManagerId", PERMISSION_ALL ) );
   hostId_handler = registerVarId( new SynchronizeableInt( &localState.hostId, &remoteState.hostId, "hostId", PERMISSION_ALL ) );
   completed_handler = registerVarId( new SynchronizeableInt( &localState.completed, &remoteState.completed, "completed", PERMISSION_ALL ) );

branches/network/src/lib/network/handshake.h

@@ -19 +19 @@
   
   int networkManagerId;
+  int messageManagerId;
   int hostId;
   
@@ -31 +32 @@
 {
   public:
-    Handshake( bool server, int clientId = 0, int networkGameManagerId = 0 );
+    Handshake( bool server, int clientId = 0, int networkGameManagerId = 0, int messageManagerId = 0 );
     inline bool       completed(){ return localState.completed != 0 && remoteState.completed != 0; }
     inline bool       ok(){ return localState.error == 0 && remoteState.error == 0; }
     inline int        getHostId(){ return remoteState.hostId; }
     inline int        getNetworkGameManagerId(){ return remoteState.networkManagerId; }
+    inline int        getMessageManagerId(){ return remoteState.messageManagerId; }
     inline void       doReject( std::string reason ){ localState.error = 1; localState.errorString = "the server rejected your connection ["+ reason +"]"; }
     

branches/network/src/lib/network/message_manager.cc

@@ -29 +29 @@
 {
   this->setClassID( CL_MESSAGE_MANAGER, "MessageManager" );
+  newNumber = 1;
+  setSynchronized( true );
 }
 
@@ -180 +182 @@
     assert( i + messageLength <= length );
     assert( messageHandlerMap.find( (MessageId)messageId ) != messageHandlerMap.end() );
-    (*(messageHandlerMap[(MessageId)messageId].cb))( (MessageId)messageId, data + i, messageLength, messageHandlerMap[(MessageId)messageId].someData, userId );
+    if ( std::find( messageQueue[userId].recievedMessages.begin(), messageQueue[userId].recievedMessages.end(), number )== messageQueue[userId].recievedMessages.end() )
+    {
+      (*(messageHandlerMap[(MessageId)messageId].cb))( (MessageId)messageId, data + i, messageLength, messageHandlerMap[(MessageId)messageId].someData, userId );
+      messageQueue[userId].recievedMessages.push_back( number );
+    }
     i += messageLength;
+  }
+  
+  
+  //walk throu message queue and remove acked messages
+  for ( std::list<NetworkMessage>::iterator it = messageQueue[userId].messages.begin(); it != messageQueue[userId].messages.end();  )
+  {
+    if ( std::find( acks.begin(), acks.end(), it->number) != acks.end() )
+    {
+      std::list<NetworkMessage>::iterator delIt = it;
+      it++;
+      messageQueue[userId].messages.erase( delIt );
+      continue;
+    }
+    it++;
+  }
+  
+  //TODO find bether way. maybe with timestamp
+  if ( messageQueue[userId].recievedMessages.size() > 1000 )
+  {
+    for ( int j = 0; j < messageQueue[userId].recievedMessages.size() - 1000; j++ )
+      messageQueue[userId].recievedMessages.erase( messageQueue[userId].recievedMessages.begin() );
   }
 
@@ -238 +265 @@
   assert( messageQueue[userId].messages.size() == 0 );
 }
+
+/**
+ * send a message to one or more clients
+ * recieverType:
+ *               RT_ALL send to all users. reciever is ignored
+ *               RT_USER send only to reciever
+ *               RT_NOT_USER send to all but reciever
+ *
+ * @param messageId message id
+ * @param data pointer to data
+ * @param dataLength length of data
+ * @param recieverType 
+ * @param reciever 
+ */
+void MessageManager::sendMessage( MessageId messageId, byte * data, int dataLength, RecieverType recieverType, int reciever, MessagePriority messagePriority )
+{
+  for ( MessageQueue::iterator it = messageQueue.begin(); it != messageQueue.end(); it++ )
+  {
+    if ( 
+         recieverType == RT_ALL ||
+         recieverType == RT_USER && it->first == reciever ||
+         recieverType == RT_NOT_USER && it->first != reciever
+       )
+    {
+      NetworkMessage msg;
+      
+      msg.data = new byte[dataLength];
+      memcpy( msg.data, data, dataLength );
+      msg.length = dataLength;
+      msg.messageId = messageId;
+      msg.number = newNumber++;
+      msg.priority = messagePriority;
+      
+      it->second.messages.push_back( msg );
+    }
+  }
+}
+
+

branches/network/src/lib/network/message_manager.h

@@ -28 +28 @@
 enum MessageId 
 {
+  TESTMESSAGEID = 1
 };
 
@@ -39 +40 @@
 };
 
+//TODO implement priority handling
+enum MessagePriority
+{
+  MP_HIGHBANDWIDTH = 1,  //!< fast and reliable but uses a lot of bandwidth
+  MP_LOWBANDWIDTH,       //!< may take a long time to arrive. reliable
+  MP_UNRELIABLE          //!< unreliable. low bandwidth 
+};
+
 struct NetworkMessage
 {
-  MessageId messageId;
-  byte *    data;
-  int       length;
-  int       number;
+  MessageId        messageId;
+  byte *           data;
+  int              length;
+  int              number;
+  MessagePriority  priority;
 };
 
@@ -51 +61 @@
   std::list<NetworkMessage> messages;
   std::list<int>            toAck;
+  std::list<int>            recievedMessages;
 };
 
@@ -75 +86 @@
    bool registerMessageHandler( MessageId messageId, MessageCallback cb, void * someData );
    
-   void sendMessage( MessageId messageId, byte * data, int dataLength, RecieverType recieverType, int reciever );
+   void sendMessage( MessageId messageId, byte * data, int dataLength, RecieverType recieverType, int reciever, MessagePriority messagePriority );
 
    virtual int getStateDiff( int userId, byte* data, int maxLength, int stateId, int fromStateId, int priorityTH );
@@ -89 +100 @@
    MessageHandlerMap       messageHandlerMap;   //!< contains handlers for messages
 
+   int                     newNumber;           //!< used to create unique message numbers
+
 };
 

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

@@ -134 +134 @@
   // and one for handshake to reject client maxCon+1
   this->networkGameManager->setUniqueID( MAX_CONNECTIONS + 2 );
-
+  MessageManager::getInstance()->setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
 }
 
@@ -219 +219 @@
       freeSocketSlots.pop_back();
       peers[clientId].socket = tempNetworkSocket;
-      peers[clientId].handshake = new Handshake(true, clientId, this->networkGameManager->getUniqueID());
+      peers[clientId].handshake = new Handshake(true, clientId, this->networkGameManager->getUniqueID(), MessageManager::getInstance()->getUniqueID() );
       peers[clientId].handshake->setUniqueID(clientId);
       peers[clientId].userId = clientId;
@@ -232 +232 @@
       
       peers[clientId].socket = tempNetworkSocket;
-      peers[clientId].handshake = new Handshake(true, clientId, this->networkGameManager->getUniqueID());
+      peers[clientId].handshake = new Handshake(true, clientId, this->networkGameManager->getUniqueID(), MessageManager::getInstance()->getUniqueID());
       peers[clientId].handshake->setUniqueID(clientId);
       peers[clientId].userId = clientId;
@@ -333 +333 @@
             this->networkGameManager = NetworkGameManager::getInstance();
             this->networkGameManager->setUniqueID( it->second.handshake->getNetworkGameManagerId() );
+            MessageManager::getInstance()->setUniqueID( it->second.handshake->getMessageManagerId() );
           }
 
@@ -446 +447 @@
       continue;
 
-    while ( packetLength = peer->second.socket->readPacket( buf, UDP_PACKET_SIZE ) > 0 )
+    while ( 0 < (packetLength = peer->second.socket->readPacket( buf, UDP_PACKET_SIZE )) )
     {
 

branches/network/src/subprojects/network/network_unit_test.cc

@@ -16 +16 @@
 #include "state.h"
 #include "shared_network_data.h"
+#include "message_manager.h"
 
 #include "simple_sync.h"
@@ -236 +237 @@
 }
 
-
+void testCB( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
+{
+  printf("GOT MESSAGE: %s\n", data);
+}
 
 /**
@@ -261 +265 @@
   ss->setSynchronized( true );
 
+  //MessageManager::getInstance()->initUser( 1 );
+  MessageManager::getInstance()->registerMessageHandler( TESTMESSAGEID, testCB, NULL );
   
   SDL_Delay(20);
@@ -266 +272 @@
   for(;;)
   {
+    MessageManager::getInstance()->sendMessage( TESTMESSAGEID, (byte*)"server to client", 18, RT_ALL, 0, MP_HIGHBANDWIDTH );
     netMan->synchronize();
     SDL_Delay(1000);
@@ -299 +306 @@
   SimpleSync * ss = NULL;
   
+  //MessageManager::getInstance()->initUser( 0 );
+  MessageManager::getInstance()->registerMessageHandler( TESTMESSAGEID, testCB, NULL );
+  
   for(;;)
   {
     netMan->synchronize();
+    MessageManager::getInstance()->sendMessage( TESTMESSAGEID, (byte*)"client to server", 18, RT_ALL, 0, MP_HIGHBANDWIDTH );
     ss = dynamic_cast<SimpleSync*>(ClassList::getObject( "Server", CL_SIMPLE_SYNC ) );
     SDL_Delay(1000);