Even more logging.

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();
+		}
 	}
 }
 

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);
 

src/net/senderthread.h

@@ -28,6 +28,7 @@
 
 #include <list>
 #include <boost/shared_ptr.hpp>
+#include <core/boost/timers.hpp>
 
 #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