mirror of
https://github.com/ddnet/ddnet.git
synced 2024-10-19 15:28:19 +00:00
43 lines
870 B
C++
43 lines
870 B
C++
|
#include "server_logger.h"
|
||
|
|
||
|
#include "server.h"
|
||
|
|
||
|
CServerLogger::CServerLogger(CServer *pServer) :
|
||
|
m_pServer(pServer),
|
||
|
m_MainThread(std::this_thread::get_id())
|
||
|
{
|
||
|
dbg_assert(pServer != nullptr, "server pointer must not be null");
|
||
|
}
|
||
|
|
||
|
void CServerLogger::Log(const CLogMessage *pMessage)
|
||
|
{
|
||
|
m_PendingLock.lock();
|
||
|
if(m_MainThread == std::this_thread::get_id())
|
||
|
{
|
||
|
if(!m_vPending.empty())
|
||
|
{
|
||
|
if(m_pServer)
|
||
|
{
|
||
|
for(const auto &Message : m_vPending)
|
||
|
{
|
||
|
m_pServer->SendLogLine(&Message);
|
||
|
}
|
||
|
}
|
||
|
m_vPending.clear();
|
||
|
}
|
||
|
m_PendingLock.unlock();
|
||
|
m_pServer->SendLogLine(pMessage);
|
||
|
}
|
||
|
else
|
||
|
{
|
||
|
m_vPending.push_back(*pMessage);
|
||
|
m_PendingLock.unlock();
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void CServerLogger::OnServerDeletion()
|
||
|
{
|
||
|
dbg_assert(m_MainThread == std::this_thread::get_id(), "CServerLogger::OnServerDeletion not called from the main thread");
|
||
|
m_pServer = nullptr;
|
||
|
}
|