Function ctrlReceive

engine/Poseidon/Network/NetTransportNet.cpp:426–689

Control (broadcast) data received by the NetServer...

                msg = mergeMessageList(sup->m_splitUrgent);
                sup->m_splitUrgent = nullptr;
            }
            else
            { // another message-part => remember it!
                if (!sup->m_splitUrgent)
                {
                    sup->m_splitUrgent = msg;
                }
                else
                {
                    sup->m_lastSplitUrgent->next = msg;
                }
                (sup->m_lastSplitUrgent = msg)->next = nullptr;
                _server->leaveRcv();
                return nsNoMoreCallbacks;
            }
        }
        else if (closing)
        { // the last message-part to be merged..
            if (!sup->m_split || !sup->m_lastSplit)
            { // closing fragment with no opener — drop it, don't deref null
                _server->leaveRcv();
                return nsNoMoreCallbacks;
            }
            sup->m_lastSplit->next = msg;
            msg->next = nullptr;
            msg = mergeMessageList(sup->m_split);
            sup->m_split = nullptr;
        }
        else
        { // another message-part => remember it!
            if (!sup->m_split)
            {
                sup->m_split = msg;
            }
            else
            {
                sup->m_lastSplit->next = msg;
            }
            (sup->m_lastSplit = msg)->next = nullptr;
            _server->leaveRcv();
            return nsNoMoreCallbacks;
        }
#ifdef NET_LOG_MERGE
#ifdef NET_LOG_BRIEF
        NetLog("Pe(%u):rMerS(%u,%u,%x,%x)", getServerPeer()->getPeerId(), msg->getLength(), msg->getSerial(),
               (unsigned)msg->getFlags(), msg->id);
#else
        NetLog("Peer(%u)::serverReceive: merging user message (len=%3u, serial=%4u, flags=%04x, ID=%x)",
               getServerPeer()->getPeerId(), msg->getLength(), msg->getSerial(), (unsigned)msg->getFlags(), msg->id);
#endif
#endif
    }

    _server->insertReceived(msg);

    _server->leaveRcv();

    return nsNoMoreCallbacks;