Function InternalDispatch

engine/dlib/src/dlib/message.cpp:545–610

    }

    uint32_t InternalDispatch(HSocket socket, DispatchCallback dispatch_callback, void* user_ptr, bool blocking)
    {
        MessageSocket* s = AcquireSocket(socket);
        if (s == 0)
        {
            return 0;
        }

        dmMutex::Lock(s->m_Mutex);

        MemoryAllocator* allocator = &s->m_Allocator;

        if (!s->m_Header)
        {
            if (blocking) {
                dmConditionVariable::Wait(s->m_Condition, s->m_Mutex);
            } else {
                dmMutex::Unlock(s->m_Mutex);
                ReleaseSocket(s);
                return 0;
            }
        }


        char buffer[128];
        const char* profiler_string = GetProfilerString(s->m_Name, buffer, sizeof(buffer));
        DM_PROFILE_DYN(profiler_string, 0);

        uint32_t dispatch_count = 0;

        Message *message_object = s->m_Header;
        s->m_Header = 0;
        s->m_Tail = 0;

        // Unlink full pages
        MemoryPage* full_pages = allocator->m_FullPages;
        allocator->m_FullPages = 0;

        dmMutex::Unlock(s->m_Mutex);

        while (message_object)
        {
            dispatch_callback(message_object, user_ptr);
            if (message_object->m_DestroyCallback) {
                message_object->m_DestroyCallback(message_object);
            }
            message_object = message_object->m_Next;
            dispatch_count++;
        }

        // Reclaim all full pages active when dispatch started
        dmMutex::Lock(s->m_Mutex);
        MemoryPage* p = full_pages;
        while (p)
        {
            MemoryPage* next = p->m_NextPage;
            p->m_NextPage = allocator->m_FreePages;
            allocator->m_FreePages = p;