Changeset b35b2b2 in network-game

Timestamp:

Jul 29, 2013, 10:32:59 PM (11 years ago)

Author:

dportnoy <dmp1488@…>

Branches:

master

Children:

d05086b

Parents:

297682c

Message:

Added a basic ingame debug console

Files:

• client/Client/main.cpp (modified) (13 diffs)
• common/MessageContainer.cpp (modified) (1 diff)
• common/MessageContainer.h (modified) (3 diffs)
• common/MessageProcessor.cpp (modified) (5 diffs)
• common/MessageProcessor.h (modified) (2 diffs)

client/Client/main.cpp

@@ -28 +28 @@
 
 #include "../../common/Common.h"
+#include "../../common/MessageContainer.h"
 #include "../../common/MessageProcessor.h"
 #include "../../common/WorldMap.h"
@@ -63 +64 @@
 void quit();
 void sendChatMessage();
+void toggleDebugging();
+void drawMessageStatus(ALLEGRO_FONT* font);
 
 void error(const char *);
@@ -82 +85 @@
 Window* wndRegister;
 Window* wndMain;
+Window* wndMainDebug;
 Window* wndCurrent;
 
@@ -103 +107 @@
 NETWORK_MSG msgTo, msgFrom;
 string username;
-chat chatConsole;
+chat chatConsole, debugConsole;
+bool debugging;
 
 MessageProcessor msgProcessor;
@@ -120 +125 @@
    int scoreBlue, scoreRed;
    bool fullscreen = false;
+   debugging = false;
 
    scoreBlue = 0;
@@ -183 +189 @@
 
    cout << "Loaded map" << endl;
+
+   debugConsole.addLine("Debug console:");
+   debugConsole.addLine("");
 
    wndLogin = new Window(0, 0, SCREEN_W, SCREEN_H);
@@ -193 +202 @@
    wndLogin->addComponent(new Button(SCREEN_W/2+10, 130, 90, 20, font, "Login", login));
    wndLogin->addComponent(new Button(920, 10, 80, 20, font, "Quit", quit));
+   wndLogin->addComponent(new Button(20, 10, 160, 20, font, "Toggle Debugging", toggleDebugging));
 
    txtUsername = (Textbox*)wndLogin->getComponent(0);
@@ -210 +220 @@
    wndRegister->addComponent(new Button(SCREEN_W/2+10, 220, 90, 20, font, "Submit", registerAccount));
    wndRegister->addComponent(new Button(920, 10, 80, 20, font, "Quit", quit));
+   wndRegister->addComponent(new Button(20, 10, 160, 20, font, "Toggle Debugging", toggleDebugging));
 
    txtUsernameRegister = (Textbox*)wndRegister->getComponent(0);
@@ -225 +236 @@
    wndMain->addComponent(new Textbox(95, 40, 300, 20, font));
    wndMain->addComponent(new Button(95, 70, 60, 20, font, "Send", sendChatMessage));
+   wndMain->addComponent(new Button(20, 10, 160, 20, font, "Toggle Debugging", toggleDebugging));
    wndMain->addComponent(new Button(920, 10, 80, 20, font, "Logout", logout));
 
    txtChat = (Textbox*)wndMain->getComponent(0);
+
+   wndMainDebug = new Window(0, 0, SCREEN_W, SCREEN_H);
+   wndMainDebug->addComponent(new Button(20, 10, 160, 20, font, "Toggle Debugging", toggleDebugging));
+   wndMainDebug->addComponent(new Button(920, 10, 80, 20, font, "Logout", logout));
 
    cout << "Created main screen" << endl;
@@ -391 +407 @@
 
          msgProcessor.resendUnackedMessages(sock);
-         msgProcessor.cleanAckedMessages();
-
-         wndCurrent->draw(display);
+         //msgProcessor.cleanAckedMessages();
+
+         if (debugging && wndCurrent == wndMain)
+            wndMainDebug->draw(display);
+         else
+            wndCurrent->draw(display);
 
          if(wndCurrent == wndMain) {
-            chatConsole.draw(font, al_map_rgb(255,255,255));
+            if (!debugging)
+               chatConsole.draw(font, al_map_rgb(255,255,255));
 
             al_draw_text(font, al_map_rgb(0, 255, 0), 4, 43, ALLEGRO_ALIGN_LEFT, "Message:");
@@ -449 +469 @@
                al_draw_line(start.x, start.y, end.x, end.y, al_map_rgb(0, 0, 0), 4);
             }
+         }
+
+         if (debugging) {
+            //debugConsole.draw(font, al_map_rgb(255,255,255));
+            drawMessageStatus(font);
          }
 
@@ -977 +1002 @@
 }
 
-int getRefreshRate(int width, int height) {
+void toggleDebugging()
+{
+   debugging = !debugging;
+}
+
+int getRefreshRate(int width, int height)
+{
    int numRefreshRates = al_get_num_display_modes();
    ALLEGRO_DISPLAY_MODE displayMode;
@@ -990 +1021 @@
    return 0;
 }
+
+void drawMessageStatus(ALLEGRO_FONT* font)
+{
+   int clientMsgOffset = 0;
+   int serverMsgOffset = 650;
+
+   al_draw_text(font, al_map_rgb(0, 255, 255), 5, 43, ALLEGRO_ALIGN_LEFT, "ID");
+   al_draw_text(font, al_map_rgb(0, 255, 255), 25, 43, ALLEGRO_ALIGN_LEFT, "Type");
+   al_draw_text(font, al_map_rgb(0, 255, 255), 245, 43, ALLEGRO_ALIGN_LEFT, "Acked?");
+
+   al_draw_text(font, al_map_rgb(0, 255, 255), 5+serverMsgOffset, 43, ALLEGRO_ALIGN_LEFT, "ID");
+   al_draw_text(font, al_map_rgb(0, 255, 255), 25+serverMsgOffset, 43, ALLEGRO_ALIGN_LEFT, "Type");
+
+   map<unsigned int, map<unsigned long, MessageContainer> >& sentMessages = msgProcessor.getSentMessages();
+   int id, type;
+   bool acked;
+   ostringstream ossId, ossAcked;
+
+   map<unsigned int, map<unsigned long, MessageContainer> >::iterator it;
+
+   int msgCount = 0;
+   for (it = sentMessages.begin(); it != sentMessages.end(); it++) {
+      map<unsigned long, MessageContainer> playerMessage = it->second;
+      map<unsigned long, MessageContainer>::iterator it2;
+      for (it2 = playerMessage.begin(); it2 !=  playerMessage.end(); it2++) {
+
+         id = it->first;
+         ossId.str("");;
+         ossId << id;
+
+         type = it2->second.getMessage()->type;
+         string typeStr = MessageContainer::getMsgTypeString(type);
+
+         acked = it2->second.getAcked();
+         ossAcked.str("");;
+         ossAcked << boolalpha << acked;
+
+         al_draw_text(font, al_map_rgb(0, 255, 0), 5, 60+15*msgCount, ALLEGRO_ALIGN_LEFT, ossId.str().c_str());
+         al_draw_text(font, al_map_rgb(0, 255, 0), 25, 60+15*msgCount, ALLEGRO_ALIGN_LEFT, typeStr.c_str());
+         al_draw_text(font, al_map_rgb(0, 255, 0), 245, 60+15*msgCount, ALLEGRO_ALIGN_LEFT, ossAcked.str().c_str());
+
+         msgCount++;
+      }
+   }
+
+   map<unsigned int, MessageContainer>& ackedMessages = msgProcessor.getAckedMessages();
+   map<unsigned int, MessageContainer>::iterator it3;
+
+   msgCount = 0;
+   for (it3 = ackedMessages.begin(); it3 != ackedMessages.end(); it3++) {
+      ossId.str("");;
+      ossId << it3->first;
+
+      string typeStr = MessageContainer::getMsgTypeString(it3->second.getMessage()->type);
+
+      al_draw_text(font, al_map_rgb(255, 0, 0), 5+serverMsgOffset, 60+15*msgCount, ALLEGRO_ALIGN_LEFT, ossId.str().c_str());
+      al_draw_text(font, al_map_rgb(255, 0, 0), 25+serverMsgOffset, 60+15*msgCount, ALLEGRO_ALIGN_LEFT, typeStr.c_str());
+
+      msgCount++;
+   }
+}

common/MessageContainer.cpp

@@ -48 +48 @@
    this->timeAcked = time;
 }
+
+/*
+string getMsgTypeString(int msgType) {
+   switch(msgType) {
+      case MSG_TYPE_ACK: return "MSG_TYPE_ACK";
+      case MSG_TYPE_REGISTER: return "MSG_TYPE_REGISTER";
+      case MSG_TYPE_LOGIN: return "MSG_TYPE_LOGIN";
+      case MSG_TYPE_LOGOUT: return "MSG_TYPE_LOGOUT";
+      case MSG_TYPE_CHAT: return "MSG_TYPE_CHAT";
+      case MSG_TYPE_PLAYER: return "MSG_TYPE_PLAYER";
+      case MSG_TYPE_PLAYER_MOVE: return "MSG_TYPE_PLAYER_MOVE";
+      case MSG_TYPE_OBJECT: return "MSG_TYPE_OBJECT";
+      case MSG_TYPE_REMOVE_OBJECT: return "MSG_TYPE_REMOVE_OBJECT";
+      case MSG_TYPE_PICKUP_FLAG: return "MSG_TYPE_PICKUP_FLAG";
+      caseMSG_TYPE_DROP_FLAG: return "MSG_TYPE_DROP_FLAG";
+      case MSG_TYPE_SCORE: return "MSG_TYPE_SCORE";
+      case MSG_TYPE_START_ATTACK: return "MSG_TYPE_START_ATACK";
+      case MSG_TYPE_ATTACK: return "MSG_TYPE_ATTACK";
+      case MSG_TYPE_PROJECTILE: return "MSG_TYPE_PROJECTILE";
+      case MSG_TYPE_REMOVE_PROJECTILE: return "MSG_TYPE_REMOVE_PROJECTILE";
+      default: return "Unknown";
+   }
+}
+*/

common/MessageContainer.h

@@ -3 +3 @@
 
 #include "Compiler.h"
+
+#include <string>
 
 #if defined WINDOWS
@@ -10 +12 @@
    #include <netinet/in.h>
 #endif
+
+using namespace std;
 
 #define MSG_TYPE_ACK               1
@@ -54 +58 @@
    void setAcked(bool acked);
    void setTimeAcked(unsigned long long time);
+
+   static string getMsgTypeString(int msgType) {
+      switch(msgType) {
+         case MSG_TYPE_ACK: return "MSG_TYPE_ACK";
+         case MSG_TYPE_REGISTER: return "MSG_TYPE_REGISTER";
+         case MSG_TYPE_LOGIN: return "MSG_TYPE_LOGIN";
+         case MSG_TYPE_LOGOUT: return "MSG_TYPE_LOGOUT";
+         case MSG_TYPE_CHAT: return "MSG_TYPE_CHAT";
+         case MSG_TYPE_PLAYER: return "MSG_TYPE_PLAYER";
+         case MSG_TYPE_PLAYER_MOVE: return "MSG_TYPE_PLAYER_MOVE";
+         case MSG_TYPE_OBJECT: return "MSG_TYPE_OBJECT";
+         case MSG_TYPE_REMOVE_OBJECT: return "MSG_TYPE_REMOVE_OBJECT";
+         case MSG_TYPE_PICKUP_FLAG: return "MSG_TYPE_PICKUP_FLAG";
+         case MSG_TYPE_DROP_FLAG: return "MSG_TYPE_DROP_FLAG";
+         case MSG_TYPE_SCORE: return "MSG_TYPE_SCORE";
+         case MSG_TYPE_START_ATTACK: return "MSG_TYPE_START_ATACK";
+         case MSG_TYPE_ATTACK: return "MSG_TYPE_ATTACK";
+         case MSG_TYPE_PROJECTILE: return "MSG_TYPE_PROJECTILE";
+         case MSG_TYPE_REMOVE_PROJECTILE: return "MSG_TYPE_REMOVE_PROJECTILE";
+         default: return "Unknown";
+      }
+   }
 };
 

common/MessageProcessor.cpp

@@ -52 +52 @@
          cout << "Got message of type " << msg->type << endl;
 
-      ackedMessages[msg->id] = getCurrentMillis();
+      ackedMessages[msg->id] = MessageContainer(*msg, *source);
+      ackedMessages[msg->id].setAcked(true);
+      ackedMessages[msg->id].setTimeAcked(getCurrentMillis());
 
       NETWORK_MSG ack;
@@ -68 +70 @@
 
 void MessageProcessor::resendUnackedMessages(int sock) {
-   map<int, map<unsigned long, MessageContainer> >::iterator it;
+   map<unsigned int, map<unsigned long, MessageContainer> >::iterator it;
    map<unsigned long, MessageContainer>::iterator it2;
    map<unsigned long, MessageContainer> sentMsg;
@@ -83 +85 @@
 
 void MessageProcessor::cleanAckedMessages() {
-   map<int, map<unsigned long, MessageContainer> >::iterator it = sentMessages.begin();
+   map<unsigned int, map<unsigned long, MessageContainer> >::iterator it = sentMessages.begin();
    map<unsigned long, MessageContainer>::iterator it2;
 
@@ -104 +106 @@
    }
 
+   /*
    map<unsigned int, unsigned long long>::iterator it3 = ackedMessages.begin();
 
@@ -112 +115 @@
          it3++;
    }
+   */
 }
+
+map<unsigned int, map<unsigned long, MessageContainer> >& MessageProcessor::getSentMessages() {
+   return this->sentMessages;
+}
+
+map<unsigned int, MessageContainer>& MessageProcessor::getAckedMessages() {
+   return this->ackedMessages;
+}

common/MessageProcessor.h

@@ -13 +13 @@
 
    // map from message ids to maps from player addresses to message info
-   map<int, map<unsigned long, MessageContainer> > sentMessages;
+   map<unsigned int, map<unsigned long, MessageContainer> > sentMessages;
 
    // map from message ids to the time each mesage was acked
-   map<unsigned int, unsigned long long> ackedMessages;
+   map<unsigned int, MessageContainer> ackedMessages;
 
    unsigned long pid;
@@ -28 +28 @@
    void resendUnackedMessages(int sock);
    void cleanAckedMessages();
+
+   map<unsigned int, map<unsigned long, MessageContainer> >& getSentMessages();
+   map<unsigned int, MessageContainer>& getAckedMessages();
 };