diff --git a/src/net/chatcleanermanager.h b/src/net/chatcleanermanager.h index 1e46ea2f..a382ff59 100644 --- a/src/net/chatcleanermanager.h +++ b/src/net/chatcleanermanager.h @@ -27,7 +27,7 @@ #include #include -class SendDataManager; +class SendBuffer; class ChatCleanerManager : public boost::enable_shared_from_this { @@ -57,7 +57,7 @@ private: boost::shared_ptr m_ioService; boost::shared_ptr m_resolver; boost::shared_ptr m_socket; - boost::shared_ptr m_sendManager; + boost::shared_ptr m_sendManager; bool m_connected; unsigned m_curRequestId; diff --git a/src/net/common/chatcleanermanager.cpp b/src/net/common/chatcleanermanager.cpp index 7bc9f6a4..bbf28675 100644 --- a/src/net/common/chatcleanermanager.cpp +++ b/src/net/common/chatcleanermanager.cpp @@ -37,7 +37,7 @@ ChatCleanerManager::ChatCleanerManager(ChatCleanerCallback &cb, boost::shared_pt m_resolver.reset( new boost::asio::ip::tcp::resolver(*m_ioService)); m_sendManager.reset( - new SendDataManager); + new SendBuffer); } ChatCleanerManager::~ChatCleanerManager() @@ -248,7 +248,7 @@ ChatCleanerManager::HandleMessage(InternalChatCleanerPacket &msg) void ChatCleanerManager::SendMessageToServer(InternalChatCleanerPacket &msg) { - asn_enc_rval_t e = der_encode(&asn_DEF_ChatCleanerMessage, msg.GetMsg(), &SendDataManager::EncodeToBuf, &m_sendManager); + asn_enc_rval_t e = der_encode(&asn_DEF_ChatCleanerMessage, msg.GetMsg(), &SendBuffer::EncodeToBuf, &m_sendManager); if (e.encoded == -1) LOG_ERROR("Failed to encode chat cleaner packet: " << msg.GetMsg()->present); diff --git a/src/net/common/senddatamanager.cpp b/src/net/common/senddatamanager.cpp index 4ceace04..24d2faf4 100644 --- a/src/net/common/senddatamanager.cpp +++ b/src/net/common/senddatamanager.cpp @@ -27,20 +27,20 @@ using namespace std; using boost::asio::ip::tcp; -SendDataManager::SendDataManager() +SendBuffer::SendBuffer() : sendBuf(NULL), curWriteBuf(NULL), sendBufAllocated(0), sendBufUsed(0), curWriteBufAllocated(0), curWriteBufUsed(0) { } -SendDataManager::~SendDataManager() +SendBuffer::~SendBuffer() { free(sendBuf); free(curWriteBuf); } void -SendDataManager::HandleWrite(boost::shared_ptr socket, const boost::system::error_code &error) +SendBuffer::HandleWrite(boost::shared_ptr socket, const boost::system::error_code &error) { if (!error) { // Successfully sent the data. @@ -52,7 +52,7 @@ SendDataManager::HandleWrite(boost::shared_ptr soc } void -SendDataManager::AsyncSendNextPacket(boost::shared_ptr socket) +SendBuffer::AsyncSendNextPacket(boost::shared_ptr socket) { if (!curWriteBufUsed) { // Swap buffers and send data. @@ -63,7 +63,7 @@ SendDataManager::AsyncSendNextPacket(boost::shared_ptrGetSendBufLeft() < size) { diff --git a/src/net/common/senderhelper.cpp b/src/net/common/senderhelper.cpp index f4617ac7..a87b5ede 100644 --- a/src/net/common/senderhelper.cpp +++ b/src/net/common/senderhelper.cpp @@ -41,12 +41,12 @@ void SenderHelper::Send(boost::shared_ptr session, boost::shared_ptr packet) { if (packet && session) { - SendDataManager &tmpManager = session->GetSendDataManager(); + SendBuffer &tmpBuffer = session->GetSendBuffer(); // Add packet to specific queue. - boost::mutex::scoped_lock lock(tmpManager.dataMutex); - InternalStorePacket(tmpManager, packet); + boost::mutex::scoped_lock lock(tmpBuffer.dataMutex); + InternalStorePacket(tmpBuffer, packet); // Activate async send, if needed. - tmpManager.AsyncSendNextPacket(session->GetAsioSocket()); + tmpBuffer.AsyncSendNextPacket(session->GetAsioSocket()); } } @@ -54,25 +54,25 @@ void SenderHelper::Send(boost::shared_ptr session, const NetPacketList &packetList) { if (!packetList.empty() && session) { - SendDataManager &tmpManager = session->GetSendDataManager(); + SendBuffer &tmpBuffer = session->GetSendBuffer(); // Add packets to specific queue. - boost::mutex::scoped_lock lock(tmpManager.dataMutex); + boost::mutex::scoped_lock lock(tmpBuffer.dataMutex); NetPacketList::const_iterator i = packetList.begin(); NetPacketList::const_iterator end = packetList.end(); while (i != end) { if (*i) - InternalStorePacket(tmpManager, *i); + InternalStorePacket(tmpBuffer, *i); ++i; } // Activate async send, if needed. - tmpManager.AsyncSendNextPacket(session->GetAsioSocket()); + tmpBuffer.AsyncSendNextPacket(session->GetAsioSocket()); } } void -SenderHelper::InternalStorePacket(SendDataManager &tmpManager, boost::shared_ptr packet) +SenderHelper::InternalStorePacket(SendBuffer &tmpBuffer, boost::shared_ptr packet) { - asn_enc_rval_t e = der_encode(&asn_DEF_PokerTHMessage, packet->GetMsg(), &SendDataManager::EncodeToBuf, &tmpManager); + asn_enc_rval_t e = der_encode(&asn_DEF_PokerTHMessage, packet->GetMsg(), &SendBuffer::EncodeToBuf, &tmpBuffer); //cerr << "OUT:" << endl << packet->ToString() << endl; if (e.encoded == -1) LOG_ERROR("Failed to encode NetPacket: " << packet->GetMsg()->present); diff --git a/src/net/common/sessiondata.cpp b/src/net/common/sessiondata.cpp index 7c01bd48..1d93bc1d 100644 --- a/src/net/common/sessiondata.cpp +++ b/src/net/common/sessiondata.cpp @@ -30,7 +30,7 @@ SessionData::SessionData(boost::shared_ptr sock, S m_autoDisconnectTimer(boost::posix_time::time_duration(0, 0, 0), boost::timers::portable::microsec_timer::auto_start), m_callback(cb), m_authSession(NULL), m_curAuthStep(0) { - m_sendDataManager.reset(new SendDataManager); + m_sendBuffer.reset(new SendBuffer); } SessionData::~SessionData() diff --git a/src/net/senddatamanager.h b/src/net/senddatamanager.h index ecf73ed2..90fea047 100644 --- a/src/net/senddatamanager.h +++ b/src/net/senddatamanager.h @@ -31,11 +31,11 @@ #define MAX_SEND_BUF_SIZE SEND_BUF_FIRST_ALLOC_CHUNKSIZE * 256 -class SendDataManager : public boost::enable_shared_from_this +class SendBuffer : public boost::enable_shared_from_this { public: - SendDataManager(); - ~SendDataManager(); + SendBuffer(); + ~SendBuffer(); inline size_t GetSendBufLeft() const { int bytesLeft = sendBufAllocated - sendBufUsed; diff --git a/src/net/senderhelper.h b/src/net/senderhelper.h index 0fd9e1fd..97a49bb9 100644 --- a/src/net/senderhelper.h +++ b/src/net/senderhelper.h @@ -25,7 +25,7 @@ #include class SessionData; -class SendDataManager; +class SendBuffer; class SenderHelper { @@ -37,7 +37,7 @@ public: void Send(boost::shared_ptr session, const NetPacketList &packetList); protected: - void InternalStorePacket(SendDataManager &tmpManager, boost::shared_ptr packet); + void InternalStorePacket(SendBuffer &tmpManager, boost::shared_ptr packet); private: diff --git a/src/net/sessiondata.h b/src/net/sessiondata.h index ffbd42fd..2045a3fa 100644 --- a/src/net/sessiondata.h +++ b/src/net/sessiondata.h @@ -38,7 +38,7 @@ typedef unsigned SessionId; struct Gsasl; struct Gsasl_session; -class SendDataManager; +class SendBuffer; class SessionData { @@ -80,8 +80,8 @@ public: ReceiveBuffer &GetReceiveBuffer() { return m_receiveBuffer; } - SendDataManager &GetSendDataManager() { - return *m_sendDataManager; + SendBuffer &GetSendBuffer() { + return *m_sendBuffer; } void ResetActivityTimer(); @@ -102,7 +102,7 @@ private: State m_state; std::string m_clientAddr; ReceiveBuffer m_receiveBuffer; - boost::shared_ptr m_sendDataManager; + boost::shared_ptr m_sendBuffer; bool m_readyFlag; bool m_wantsLobbyMsg; boost::timers::portable::microsec_timer m_activityTimer;