Function serverReceive

engine/Poseidon/Network/NetTransportNet.cpp:278–423

Regular data received by the NetServer...

// Checks _enum, _client and _server. If everything is nullptr, destroys the global NetPool!
static void checkPool()
{
    poolLock.enter();
    if (!_enum && !_client && !_server)
    {
        destroyPool();
    }
    poolLock.leave();
}

Ref<NetMessage> mergeMessageList(NetMessage* msg)
{
    if (!msg)
    {
        return nullptr;
    }
    unsigned size = 0;
    NetMessage* ptr = msg;
    NetMessage* last;
    do
    {
        size += ptr->getLength();
        last = ptr;
    } while ((ptr = ptr->next));
    Ref<NetMessage> composite = NetMessagePool::pool()->newMessage(size, msg->getChannel());
    if (!composite)
    {
        return nullptr;
    }
    composite->setFrom(last);
    unsigned8* data = (unsigned8*)composite->getData();
    for (ptr = msg; ptr; ptr = ptr->next)
    {
        memcpy(data, ptr->getData(), ptr->getLength());
        data += ptr->getLength();
    }
    composite->setLength(size);
    return composite;
}

// Regular data received by the NetServer...
NetStatus serverReceive(NetMessage* msg, NetStatus event, void* data)
{
    // thread-safe
    if (!_server || !msg)
    {
        return nsNoMoreCallbacks; // nothing to do
    }
    unsigned len = msg->getLength();
    if (!len)
    {
        return nsNoMoreCallbacks; // message is too small
    }
    struct sockaddr_in dist;
    msg->getDistant(dist);
    unsigned flags = msg->getFlags();
    bool isMagic = (flags & MSG_MAGIC_FLAG) != 0;
    if (isMagic)
    { // magic-messages: