Changeset 6b641af in network-game for common/MessageProcessor.cpp

Timestamp:

Jul 16, 2013, 1:06:57 AM (11 years ago)

Author:

dportnoy <dmp1488@…>

Branches:

master

Children:

4dbac87

Parents:

5755e68

Message:

Debugging

File:

• common/MessageProcessor.cpp (modified) (3 diffs)

common/MessageProcessor.cpp

@@ -35 +35 @@
    int ret =  recvfrom(sock, (char*)msg, sizeof(NETWORK_MSG), 0, (struct sockaddr *)source, &socklen);
 
+   if (ret == -1)
+      return ret;
+
    // add id to the NETWORK_MSG struct
    if (msg->type == MSG_TYPE_ACK) {
@@ -41 +44 @@
          sentMessages[msg->id].isAcked = true;
          sentMessages[msg->id].timeAcked = getCurrentMillis();
-      }else
-         cout << "Received old ack" << endl;
+      }
 
       return -1; // don't do any further processing
@@ -75 +77 @@
 
    while (it != sentMessages.end()) {
-      if (it->second.isAcked && (getCurrentMillis() - it->second.timeAcked) > 1000)
-         sentMessages.erase(it++);
-      else
+      if (it->second.isAcked) {
+//         cout << "Found acked message" << endl;
+//         cout << "time acked" << it->second.timeAcked << endl;
+//         cout << "cur time" << getCurrentMillis() << endl;
+         if ((getCurrentMillis() - it->second.timeAcked) > 1000) {
+            cout << "Message was acked. time to delete it" << endl;
+            cout << "old map size" << sentMessages.size() << endl;
+            sentMessages.erase(it++);
+            cout << "new map size" << sentMessages.size() << endl;
+         }else
+            it++;
+      }else
          it++;
    }