Function NewSocket

engine/dlib/src/dlib/message.cpp:172–217

    } g_ContextDestroyer;

    Result NewSocket(const char* name, HSocket* socket)
    {
        if (dmAtomicGet32(&g_ContextDestroyer.m_Deleted))
        {
            return RESULT_SOCKET_OUT_OF_RESOURCES;
        }

        if (name == 0x0 || *name == 0 || strchr(name, '#') != 0x0 || strchr(name, ':') != 0x0)
        {
            return RESULT_INVALID_SOCKET_NAME;
        }

        dmhash_t name_hash = dmHashString64(name);

        DM_SPINLOCK_SCOPED_LOCK(g_MessageSpinlock);

        if (g_MessageContext == 0)
        {
            g_MessageContext = Create(MAX_SOCKETS);
        }

        if (g_MessageContext->m_Sockets.Full())
        {
            return RESULT_SOCKET_OUT_OF_RESOURCES;
        }

        HSocket tmp;
        if (GetSocketNoLock(name_hash, &tmp) == RESULT_OK)
        {
            return RESULT_SOCKET_EXISTS;
        }

        MessageSocket s;
        s.m_RefCount = 1;
        s.m_Header = 0;
        s.m_Tail = 0;
        s.m_NameHash = name_hash;
        s.m_Name = strdup(name);
        s.m_Mutex = dmMutex::New();
        s.m_Condition = dmConditionVariable::New();

        g_MessageContext->m_Sockets.Put(name_hash, s);
        *socket = name_hash;

        return RESULT_OK;
    }

    static void DisposeSocket(MessageSocket* s)
    {