diff options
author | Björn Steinbrink <B.Steinbrink@gmx.de> | 2006-01-22 19:26:32 +0000 |
---|---|---|
committer | Björn Steinbrink <B.Steinbrink@gmx.de> | 2006-01-22 19:26:32 +0000 |
commit | bfedebb8069e4613c96a53151e72785ea7352765 (patch) | |
tree | b0be95e79eb9f1066c2d16c39c16d370eab0b113 /src | |
parent | fafb16bfcbdafa78ca6b587090838cf9752313e5 (diff) | |
download | mana-client-bfedebb8069e4613c96a53151e72785ea7352765.tar.gz mana-client-bfedebb8069e4613c96a53151e72785ea7352765.tar.bz2 mana-client-bfedebb8069e4613c96a53151e72785ea7352765.tar.xz mana-client-bfedebb8069e4613c96a53151e72785ea7352765.zip |
Make dispatchMessages actually handle more than one message per call.
Diffstat (limited to 'src')
-rw-r--r-- | src/game.cpp | 4 | ||||
-rw-r--r-- | src/net/network.cpp | 22 |
2 files changed, 12 insertions, 14 deletions
diff --git a/src/game.cpp b/src/game.cpp index dcd7b9d9..edc1789f 100644 --- a/src/game.cpp +++ b/src/game.cpp @@ -369,10 +369,8 @@ void game(Network *network) } // Handle network stuff - while(network->messageReady()) - network->dispatchMessages(); - network->flush(); + network->dispatchMessages(); } do_exit(network); diff --git a/src/net/network.cpp b/src/net/network.cpp index 3b0652e2..f519a467 100644 --- a/src/net/network.cpp +++ b/src/net/network.cpp @@ -214,20 +214,20 @@ void Network::clearHandlers() void Network::dispatchMessages() { - if (!messageReady()) - return; - - MessageIn msg = getNextMessage(); + while (messageReady()) + { + MessageIn msg = getNextMessage(); - std::map<Uint16, MessageHandler*>::iterator iter; - iter = mMessageHandlers.find(msg.getId()); + std::map<Uint16, MessageHandler*>::iterator iter; + iter = mMessageHandlers.find(msg.getId()); - if (iter != mMessageHandlers.end()) - iter->second->handleMessage(&msg); - else - logger->log("Unhandled packet: %x", msg.getId()); + if (iter != mMessageHandlers.end()) + iter->second->handleMessage(&msg); + else + logger->log("Unhandled packet: %x", msg.getId()); - skip(msg.getLength()); + skip(msg.getLength()); + } } void Network::flush() |