Function enumReceive

engine/Poseidon/Network/NetTransportNet.cpp:692–804

Control (broadcast) data received by the enumerator and client...

                    {
                        out->setDistant(distant);
                    }
                    out->setFlags(MSG_ALL_FLAGS, MSG_MAGIC_FLAG | (ch ? MSG_VIM_FLAG : MSG_FROM_BCAST_FLAG));
                    out->setData((unsigned8*)&app, sizeof(app));
                    out->send(true); // urgent message
                }
                if (ch)
                { // initial hand-shake (to initialize band-width..).
                    ch->checkConnectivity(0);
                }
            }
            break;

        case MAGIC_RECONNECT_PLAYER: // reconnect player
            if (msg->getLength() == sizeof(ReconnectPlayerPacket))
            {
                ReconnectPlayerPacket* rpp = (ReconnectPlayerPacket*)msg->getData();
                _server->enterUsr();
                RefD<NetChannel> ch;
                ConnectResult result = CRError;
                if (_server->users.get(rpp->playerNo, ch) && // player with this ID exists => reconnect it
                    ch->reconnect(distant) == nsOK)
                {
                    result = CROK;
                }
                _server->leaveUsr();
                // .. send either acknowledgement back to the user
                AckPlayerPacket app;
                app.magic = MAGIC_ACK_PLAYER;
                app.result = result;
                app.playerNo = rpp->playerNo;
                Ref<NetMessage> out = NetMessagePool::pool()->newMessage(
                    sizeof(AckPlayerPacket), (result == CROK) ? (NetChannel*)ch : msg->getChannel());
                if (out)
                {
                    if (result != CROK)
                    {
                        out->setDistant(distant);
                    }
                    out->setFlags(MSG_ALL_FLAGS,
                                  MSG_MAGIC_FLAG | ((result == CROK) ? MSG_VIM_FLAG : MSG_FROM_BCAST_FLAG));
                    out->setData((unsigned8*)&app, sizeof(app));
                    out->send(true); // urgent message
                }
                if (result == CROK)
                { // initial hand-shake (to re-initialize band-width..).
                    ch->checkConnectivity(0);
                }
            }
            break;
    }

    return nsNoMoreCallbacks;
}

// Control (broadcast) data received by the enumerator and client...
NetStatus enumReceive(NetMessage* msg, NetStatus event, void* data)
{
    // thread-critical: sprintf(), AutoArray::Add(), strncpy()