Function dmLogDispatch

engine/dlib/src/dlib/log.cpp:350–419

}

static void dmLogDispatch(dmMessage::Message *message, void* user_ptr)
{
    dmLogServer* server = g_dmLogServer;

    bool* run = (bool*) user_ptr;
    LogMessage* log_message = (LogMessage*) &message->m_Data[0];
    if (log_message->m_Type == LogMessage::SHUTDOWN)
    {
        *run = false;
        return;
    }

    int msg_len = (int) strlen(log_message->m_Message);
    DoLogSynchronized((LogSeverity)log_message->m_Severity, log_message->m_Domain, log_message->m_Message, msg_len);

    // NOTE: Keep i as signed! See --i below after EraseSwap
    int n = 0;
    {
        DM_SPINLOCK_SCOPED_LOCK(dmLog::g_LogServerLock);
        if (!dmLog::IsServerInitialized())
            return; // The log system may have been shut down in between
        n = (int) server->m_Connections.Size();
    }

    for (int i = 0; i < n; ++i)
    {
        dmLogConnection* c = 0;
        dmSocket::Socket socket = dmSocket::INVALID_SOCKET_HANDLE;
        {
            DM_SPINLOCK_SCOPED_LOCK(dmLog::g_LogServerLock);
            if (!dmLog::IsServerInitialized())
                return; // The log system may have been shut down in between
            c = &server->m_Connections[i];
            socket = c->m_Socket;
        }

        dmSocket::Result r;
        int sent_bytes;
        int total_sent = 0;
        do
        {
            r = dmSocket::Send(socket, log_message->m_Message + total_sent, msg_len - total_sent, &sent_bytes);
            if (r == dmSocket::RESULT_OK)
            {
                total_sent += sent_bytes;
            }
            else if (r == dmSocket::RESULT_TRY_AGAIN)
            {
                // Ok
            }
            else
            {
                dmSocket::Shutdown(socket, dmSocket::SHUTDOWNTYPE_READWRITE);
                dmSocket::Delete(socket);

                {
                    DM_SPINLOCK_SCOPED_LOCK(dmLog::g_LogServerLock);
                    if (!dmLog::IsServerInitialized())