Function Post

engine/dlib/src/dlib/message.cpp:448–510

    }

    Result Post(const URL* sender, const URL* receiver, dmhash_t message_id, uintptr_t user_data1, uintptr_t user_data2,
                    uintptr_t descriptor, const void* message_data, uint32_t message_data_size, MessageDestroyCallback destroy_callback)
    {
        DM_PROFILE("Post");
        //Currently called out by the Thread Sanitizer: DM_PROPERTY_ADD_U32(rmtp_Messages, 1);

        if (receiver == 0x0)
        {
            return RESULT_SOCKET_NOT_FOUND;
        }

        MessageSocket* s = AcquireSocket(receiver->m_Socket);
        if (s == 0x0)
        {
            return RESULT_SOCKET_NOT_FOUND;
        }

        dmMutex::Lock(s->m_Mutex);

        MemoryAllocator* allocator = &s->m_Allocator;
        uint32_t data_size = sizeof(Message) + message_data_size;
        Message *new_message = (Message *) AllocateMessage(allocator, data_size);
        if (sender != 0x0)
        {
            new_message->m_Sender = *sender;
        }
        else
        {
            ResetURL(&new_message->m_Sender);
        }
        new_message->m_Receiver = *receiver;
        new_message->m_Id = message_id;
        new_message->m_UserData1 = user_data1;
        new_message->m_UserData2 = user_data2;
        new_message->m_Descriptor = descriptor;
        new_message->m_DataSize = message_data_size;
        new_message->m_Next = 0;
        new_message->m_DestroyCallback = destroy_callback;
        memcpy(&new_message->m_Data[0], message_data, message_data_size);

        bool is_first_message = !s->m_Header;

        if (!s->m_Header)
        {
            s->m_Header = new_message;
            s->m_Tail = new_message;
        }
        else
        {
            s->m_Tail->m_Next = new_message;
            s->m_Tail = new_message;
        }

        if (is_first_message)
        {
            dmConditionVariable::Signal(s->m_Condition);
        }
        dmMutex::Unlock(s->m_Mutex);