diff --git a/src/net/common/senderthread.cpp b/src/net/common/senderthread.cpp index c27b9b9d..f8d94843 100644 --- a/src/net/common/senderthread.cpp +++ b/src/net/common/senderthread.cpp @@ -33,6 +33,7 @@ using namespace std; #define SEND_ERROR_TIMEOUT_MSEC 20000 #define SEND_TIMEOUT_MSEC 10 #define SEND_QUEUE_SIZE 10000000 +#define SEND_LOG_INTERVAL_SEC 60 SenderThread::SenderThread(SenderCallback &cb) : m_callback(cb) @@ -260,6 +261,23 @@ SenderThread::Main() } else Msleep(SEND_TIMEOUT_MSEC); + + if (m_logTimer.elapsed().total_seconds() >= SEND_LOG_INTERVAL_SEC) + { + unsigned sendQueueSize = 0; + unsigned stalledQueueSize = 0; + { + boost::mutex::scoped_lock lock(m_sendQueueMutex); + sendQueueSize = m_sendQueue.size(); + } + { + boost::mutex::scoped_lock lock(m_stalledQueueMutex); + stalledQueueSize = m_stalledQueue.size(); + } + LOG_VERBOSE("Sender TICK - send queue " << sendQueueSize << ", stalled " << stalledQueueSize << "."); + m_logTimer.reset(); + m_logTimer.start(); + } } } diff --git a/src/net/common/serverlobbythread.cpp b/src/net/common/serverlobbythread.cpp index 06457e47..520c989d 100644 --- a/src/net/common/serverlobbythread.cpp +++ b/src/net/common/serverlobbythread.cpp @@ -414,6 +414,8 @@ ServerLobbyThread::ProcessLoop() void ServerLobbyThread::HandleNetPacketInit(SessionWrapper session, const NetPacketInit &tmpPacket) { + LOG_VERBOSE("Received init for session #" << session.sessionData->GetId() << "."); + NetPacketInit::Data initData; tmpPacket.GetData(initData); diff --git a/src/net/senderthread.h b/src/net/senderthread.h index 6a6c5c8f..6d9c92f7 100644 --- a/src/net/senderthread.h +++ b/src/net/senderthread.h @@ -28,6 +28,7 @@ #include #include +#include #define SENDER_THREAD_TERMINATE_TIMEOUT THREAD_WAIT_INFINITE @@ -71,6 +72,8 @@ private: mutable boost::mutex m_stalledQueueMutex; SenderCallback &m_callback; + + boost::timers::portable::microsec_timer m_logTimer; }; #endif