Changeset 9522 in orxonox.OLD for branches/proxy/src/lib/network/message_manager.cc

Timestamp:

Jul 27, 2006, 8:29:32 PM (19 years ago)

Author:

patrick

Message:

new the message handler is checking, if this message is also for the local host. if not the system tries to relay the message

File:

• branches/proxy/src/lib/network/message_manager.cc (modified) (2 diffs)

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

@@ -227 +227 @@
          outgoingMessageQueue[userId].recievedMessages.end() )
     {
+
+//       RT_ALL_BUT_ME = 1,   //!< message is sent to all users but myself
+//       RT_ALL_ME,           //!< message is sent to all users
+//       RT_USER,             //!< message is only sent to reciever
+//       RT_NOT_USER,         //!< message is sent to all but reciever
+//       RT_SERVER
+
+      // find out if this message is addressed for this client too
+      if( messageType == RT_ALL_BUT_ME ||
+          messageType == RT_ALL_ME ||
+          messageType == RT_USER  && SharedNetworkData::getInstance()->getHostID() == destinationId ||
+          messageType == RT_SERVER && SharedNetworkData::getInstance()->isMasterServer())
+      {
+
       // call the handler function and handle errors
-      if ( !(*(messageHandlerMap[(MessageType)messageType].cb))( (MessageType)messageType, data + i, messageLength,
-                                                                 messageHandlerMap[(MessageType)messageType].someData, senderId, destinationId ) )
+        if ( !(*(messageHandlerMap[(MessageType)messageType].cb))( (MessageType)messageType, data + i, messageLength,
+                 messageHandlerMap[(MessageType)messageType].someData, senderId, destinationId ) )
+        {
+        // if the message is not handled correctly, bush it back to the incoming packets
+          NetworkMessage msg;
+
+          msg.data = new byte[messageLength];
+          memcpy( msg.data, data + i, messageLength );
+          msg.length = messageLength;
+          msg.messageType = (MessageType)messageType;
+          msg.number = userId;
+          msg.senderId = senderId;
+          msg.destinationId = destinationId;
+
+          incomingMessageQueue.push_back( msg );
+        }
+      // save the serial number for ack signaling
+        outgoingMessageQueue[userId].recievedMessages.push_back( number );
+        PRINTF(0)("<<< MessageManager: got msg with type: %i, from sender %i, to rec: %i\n", messageType, senderId, destinationId);
+      }
+      // or else forward the message to the other servers
+      else
       {
-        // if the message is not handled correctly, bush it back to the incoming packets
+        PRINTF(0)("===========>> Forwarding Message\n");
         NetworkMessage msg;
 
@@ -244 +278 @@
         incomingMessageQueue.push_back( msg );
       }
-      // save the serial number for ack signaling
-      outgoingMessageQueue[userId].recievedMessages.push_back( number );
-      PRINTF(0)("<<< MessageManager: got msg with type: %i\n", messageType);
-    }
+    }
+
     i += messageLength;
   }