- Timestamp:
- Jul 29, 2013, 10:32:59 PM (11 years ago)
- Branches:
- master
- Children:
- d05086b
- Parents:
- 297682c
- Location:
- common
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
common/MessageContainer.cpp
r297682c rb35b2b2 48 48 this->timeAcked = time; 49 49 } 50 51 /* 52 string getMsgTypeString(int msgType) { 53 switch(msgType) { 54 case MSG_TYPE_ACK: return "MSG_TYPE_ACK"; 55 case MSG_TYPE_REGISTER: return "MSG_TYPE_REGISTER"; 56 case MSG_TYPE_LOGIN: return "MSG_TYPE_LOGIN"; 57 case MSG_TYPE_LOGOUT: return "MSG_TYPE_LOGOUT"; 58 case MSG_TYPE_CHAT: return "MSG_TYPE_CHAT"; 59 case MSG_TYPE_PLAYER: return "MSG_TYPE_PLAYER"; 60 case MSG_TYPE_PLAYER_MOVE: return "MSG_TYPE_PLAYER_MOVE"; 61 case MSG_TYPE_OBJECT: return "MSG_TYPE_OBJECT"; 62 case MSG_TYPE_REMOVE_OBJECT: return "MSG_TYPE_REMOVE_OBJECT"; 63 case MSG_TYPE_PICKUP_FLAG: return "MSG_TYPE_PICKUP_FLAG"; 64 caseMSG_TYPE_DROP_FLAG: return "MSG_TYPE_DROP_FLAG"; 65 case MSG_TYPE_SCORE: return "MSG_TYPE_SCORE"; 66 case MSG_TYPE_START_ATTACK: return "MSG_TYPE_START_ATACK"; 67 case MSG_TYPE_ATTACK: return "MSG_TYPE_ATTACK"; 68 case MSG_TYPE_PROJECTILE: return "MSG_TYPE_PROJECTILE"; 69 case MSG_TYPE_REMOVE_PROJECTILE: return "MSG_TYPE_REMOVE_PROJECTILE"; 70 default: return "Unknown"; 71 } 72 } 73 */ -
common/MessageContainer.h
r297682c rb35b2b2 3 3 4 4 #include "Compiler.h" 5 6 #include <string> 5 7 6 8 #if defined WINDOWS … … 10 12 #include <netinet/in.h> 11 13 #endif 14 15 using namespace std; 12 16 13 17 #define MSG_TYPE_ACK 1 … … 54 58 void setAcked(bool acked); 55 59 void setTimeAcked(unsigned long long time); 60 61 static string getMsgTypeString(int msgType) { 62 switch(msgType) { 63 case MSG_TYPE_ACK: return "MSG_TYPE_ACK"; 64 case MSG_TYPE_REGISTER: return "MSG_TYPE_REGISTER"; 65 case MSG_TYPE_LOGIN: return "MSG_TYPE_LOGIN"; 66 case MSG_TYPE_LOGOUT: return "MSG_TYPE_LOGOUT"; 67 case MSG_TYPE_CHAT: return "MSG_TYPE_CHAT"; 68 case MSG_TYPE_PLAYER: return "MSG_TYPE_PLAYER"; 69 case MSG_TYPE_PLAYER_MOVE: return "MSG_TYPE_PLAYER_MOVE"; 70 case MSG_TYPE_OBJECT: return "MSG_TYPE_OBJECT"; 71 case MSG_TYPE_REMOVE_OBJECT: return "MSG_TYPE_REMOVE_OBJECT"; 72 case MSG_TYPE_PICKUP_FLAG: return "MSG_TYPE_PICKUP_FLAG"; 73 case MSG_TYPE_DROP_FLAG: return "MSG_TYPE_DROP_FLAG"; 74 case MSG_TYPE_SCORE: return "MSG_TYPE_SCORE"; 75 case MSG_TYPE_START_ATTACK: return "MSG_TYPE_START_ATACK"; 76 case MSG_TYPE_ATTACK: return "MSG_TYPE_ATTACK"; 77 case MSG_TYPE_PROJECTILE: return "MSG_TYPE_PROJECTILE"; 78 case MSG_TYPE_REMOVE_PROJECTILE: return "MSG_TYPE_REMOVE_PROJECTILE"; 79 default: return "Unknown"; 80 } 81 } 56 82 }; 57 83 -
common/MessageProcessor.cpp
r297682c rb35b2b2 52 52 cout << "Got message of type " << msg->type << endl; 53 53 54 ackedMessages[msg->id] = getCurrentMillis(); 54 ackedMessages[msg->id] = MessageContainer(*msg, *source); 55 ackedMessages[msg->id].setAcked(true); 56 ackedMessages[msg->id].setTimeAcked(getCurrentMillis()); 55 57 56 58 NETWORK_MSG ack; … … 68 70 69 71 void MessageProcessor::resendUnackedMessages(int sock) { 70 map< int, map<unsigned long, MessageContainer> >::iterator it;72 map<unsigned int, map<unsigned long, MessageContainer> >::iterator it; 71 73 map<unsigned long, MessageContainer>::iterator it2; 72 74 map<unsigned long, MessageContainer> sentMsg; … … 83 85 84 86 void MessageProcessor::cleanAckedMessages() { 85 map< int, map<unsigned long, MessageContainer> >::iterator it = sentMessages.begin();87 map<unsigned int, map<unsigned long, MessageContainer> >::iterator it = sentMessages.begin(); 86 88 map<unsigned long, MessageContainer>::iterator it2; 87 89 … … 104 106 } 105 107 108 /* 106 109 map<unsigned int, unsigned long long>::iterator it3 = ackedMessages.begin(); 107 110 … … 112 115 it3++; 113 116 } 117 */ 114 118 } 119 120 map<unsigned int, map<unsigned long, MessageContainer> >& MessageProcessor::getSentMessages() { 121 return this->sentMessages; 122 } 123 124 map<unsigned int, MessageContainer>& MessageProcessor::getAckedMessages() { 125 return this->ackedMessages; 126 } -
common/MessageProcessor.h
r297682c rb35b2b2 13 13 14 14 // map from message ids to maps from player addresses to message info 15 map< int, map<unsigned long, MessageContainer> > sentMessages;15 map<unsigned int, map<unsigned long, MessageContainer> > sentMessages; 16 16 17 17 // map from message ids to the time each mesage was acked 18 map<unsigned int, unsigned long long> ackedMessages;18 map<unsigned int, MessageContainer> ackedMessages; 19 19 20 20 unsigned long pid; … … 28 28 void resendUnackedMessages(int sock); 29 29 void cleanAckedMessages(); 30 31 map<unsigned int, map<unsigned long, MessageContainer> >& getSentMessages(); 32 map<unsigned int, MessageContainer>& getAckedMessages(); 30 33 }; 31 34
Note:
See TracChangeset
for help on using the changeset viewer.