aboutsummaryrefslogtreecommitdiff
path: root/src/server/bnetserver/Server/Session.h
diff options
context:
space:
mode:
authorShauren <shauren.trinity@gmail.com>2016-02-19 19:23:04 +0100
committerShauren <shauren.trinity@gmail.com>2016-02-19 19:23:04 +0100
commit97a79af4701621ec04b88c8b548dbc35d120e99e (patch)
treec3e7f3f2f7f5ee41565bf16ea884cf55aa75c911 /src/server/bnetserver/Server/Session.h
parent06ec1b8fe8dfe9bb8a225ed57a053eb546d386ad (diff)
Core/Networking: Rewrite networking threading model
Each network thread has its own io_service - this means that all operations on a given socket except queueing packets run from a single thread, removing the need for locking Sending packets now writes to a lockfree intermediate queue directly, encryption is applied in network thread if it was required at the time of sending the packet
Diffstat (limited to 'src/server/bnetserver/Server/Session.h')
-rw-r--r--src/server/bnetserver/Server/Session.h8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/server/bnetserver/Server/Session.h b/src/server/bnetserver/Server/Session.h
index 75c30096417..2443d694a80 100644
--- a/src/server/bnetserver/Server/Session.h
+++ b/src/server/bnetserver/Server/Session.h
@@ -23,6 +23,7 @@
#include "Socket.h"
#include "BigNumber.h"
#include "Callback.h"
+#include "MPSCQueue.h"
#include <memory>
#include <boost/asio/ip/tcp.hpp>
@@ -174,6 +175,13 @@ namespace Battlenet
std::queue<ModuleType> _modulesWaitingForData;
+ struct EncryptableBuffer
+ {
+ MessageBuffer Buffer;
+ bool Encrypt;
+ };
+
+ MPSCQueue<EncryptableBuffer> _bufferQueue;
PacketCrypt _crypt;
bool _authed;
bool _subscribedToRealmListUpdates;