Index: common/MessageProcessor.cpp
===================================================================
--- common/MessageProcessor.cpp	(revision 855f1534e611e9a242abd6232b54a224305e3178)
+++ common/MessageProcessor.cpp	(revision 3794f6d6f359025d4bb6f4aaa99a8ab1849eaf63)
@@ -63,6 +63,8 @@
 
          sendto(sock, (char*)&ack, sizeof(NETWORK_MSG), 0, (struct sockaddr *)source, sizeof(struct sockaddr_in));
-      }else
+      }else {
          cout << "Got duplicate ack" << endl;
+         return -1;
+      }
    }
 
@@ -100,5 +102,5 @@
 
    while (it2 != ackedMessages.end()) {
-      if ((getCurrentMillis() - it2->second) > 5000) {
+      if ((getCurrentMillis() - it2->second) > 500) {
          ackedMessages.erase(it2++);
          cout << "Deleting ack record" << endl;