Changeset 4dbac87 in network-game for common

Timestamp:

Jul 17, 2013, 1:48:16 AM (11 years ago)

Author:

dportnoy <dmp1488@…>

Branches:

master

Children:

855f153

Parents:

6b641af

Message:

MessageProcessor keeps track messages it has acked, so it doesn't send acks to multiple copies of the same message

Location:

common

Files:

• MessageProcessor.cpp (modified) (2 diffs)
• MessageProcessor.h (modified) (1 diff)

common/MessageProcessor.cpp

@@ -48 +48 @@
       return -1; // don't do any further processing
    }else {
-      if (ret > -1) {
-         cout << "Received message" << endl;
-         cout << "id: " << msg->id << endl;
-         cout << "type: " << msg->type << endl;
-         cout << "buffer: " << msg->buffer << endl;
-      }
+      cout << "Received message" << endl;
+      cout << "id: " << msg->id << endl;
+      cout << "type: " << msg->type << endl;
+      cout << "buffer: " << msg->buffer << endl;
 
-      NETWORK_MSG ack;
-      ack.id = msg->id;
-      ack.type = MSG_TYPE_ACK;
+      if (ackedMessages.find(msg->id) != ackedMessages.end()) {
+         ackedMessages[msg->id] = getCurrentMillis();
 
-      sendto(sock, (char*)&ack, sizeof(NETWORK_MSG), 0, (struct sockaddr *)source, sizeof(struct sockaddr_in));
+         NETWORK_MSG ack;
+         ack.id = msg->id;
+         ack.type = MSG_TYPE_ACK;
+
+         sendto(sock, (char*)&ack, sizeof(NETWORK_MSG), 0, (struct sockaddr *)source, sizeof(struct sockaddr_in));
+      }else
+         cout << "Got duplicate ack" << endl;
    }
 
@@ -91 +94 @@
          it++;
    }
+
+   map<unsigned int, unsigned long long>::iterator it2 = ackedMessages.begin();
+
+   while (it2 != ackedMessages.end()) {
+      if ((getCurrentMillis() - it2->second) > 500)
+         ackedMessages.erase(it2++);
+      else
+         it2++;
+   }
 }

common/MessageProcessor.h

@@ -79 +79 @@
    int lastUsedId;
    map<int, MessageContainer> sentMessages;
+   map<unsigned int, unsigned long long> ackedMessages;
 };