Join_network.cpp

Go to the documentation of this file.

#include "Join.h"

void Join::networkLoop() {
        unsigned int i;

        GE_PlayerJoined *ge_playerJoined = NULL;
        GE_State *ge_state = NULL;
        GE_PlayerScore *ge_playerScore = NULL;
        GE_PlayerDisconnected *ge_playerDisconnected = NULL;
        GE_PlayerExtras *ge_playerExtras = NULL;
        GE_Info *ge_info = NULL;

        Player *p;
        int playerID;
        int type;

        //-----------------------------------------------------------------##
        // Network event handler
        //-----------------------------------------------------------------##
        while (i = gne->nextEventPending()) {
                //console.addEx(Vec3(1.0f, 1.0f, 1.0f), "Event pending [%d]", i);

                switch(i) {
                        //-----------------------------------------------------------------#
                        // Player joined
                        //-----------------------------------------------------------------#
                        case E_PLAYER_JOINED:
                                ge_playerJoined = (GE_PlayerJoined *)gne->getNextEvent();
                                playerID = ge_playerJoined->getId();
                                p = gne->getPlayerById(playerID);
                                strcpy(g_players[playerID].name, p->getName());

                                // set defaults for player
                                g_players[playerID].life = 100.0f;
                                g_players[playerID].frags = 0;
                                g_players[playerID].kills = 0;
                                g_players[playerID].deaths = 0;
                                //if (playerID < g_myPlayerID)
                                //      g_players[playerID].state = PLAYER_STATE_LOADING;
                                //else
                                g_players[playerID].state = PLAYER_STATE_INVISIBLE;
                                g_players[playerID].ownsParticleSystem = -1;
                                g_players[playerID].chatClr = getPlayerChatColor(playerID);

                                if (playerID > g_myPlayerID) {
                                        m_sounds[JOIN_SOUND_ONLINE].play();
                                }

                                // I'm server, notify new player about level list
                                console.addEx(Vec3(1.0f, 1.0f, 1.0f), "Player %d joined", playerID);

                                if (ge_playerJoined) delete ge_playerJoined;
                                break;

                        //-----------------------------------------------------------------#
                        // Player disconnected!
                        //-----------------------------------------------------------------#
                        case E_PLAYER_DISCONNECTED:
                                ge_playerDisconnected = (GE_PlayerDisconnected *)gne->getNextEvent();
                                playerID = ge_playerDisconnected->getId();
                                console.addEx(Vec3(1.0f, 0.0f, 0.0f), "'%s' disconnected!", g_players[playerID].name);
                                g_players[playerID].state = PLAYER_STATE_OFFLINE;

                                if (ge_playerDisconnected) delete ge_playerDisconnected;
                                break;

                        //-----------------------------------------------------------------#
                        // Player state
                        //-----------------------------------------------------------------#
                        case E_PLAYER_STATE:
                                ge_state = (GE_State *)gne->getNextEvent();
                                playerID = ge_state->getId();
                                g_players[playerID].state = ge_state->getState();

                                // the new player has loaded, send levels to him
                                if (gne->isServer() && g_players[playerID].state == PLAYER_STATE_INVISIBLE) {
                                        for (i=0; i<g_gameInfo.nLvls; i++) {
                                                if (g_gameInfo.lvlList[i][0] == 1) {
                                                        //LOG_MISC(("Skickar lvl: %d",i));
                                                        gne->sendInfo(playerID, JOIN_NET_ADD, g_gameInfo.lvlList[i][1], g_gameInfo.lvlList[i][2]);
                                                        Sleep(25);
                                                }
                                        }

                                        // and player models
                                        for (i=0; i<SPLAYER_MAX_PLAYERS; i++) {
                                                if (i != playerID && g_players[i].state != PLAYER_STATE_OFFLINE) {
                                                        gne->sendInfo(playerID, JOIN_NET_PLAYER_MODEL, i, g_players[i].model);
                                                        //LOG_MISC(("Drar iväg spelar-model för %d",i));
                                                        Sleep(25);
                                                }
                                        }
                                }

                                if (ge_state) delete ge_state;
                                break;

                        //-----------------------------------------------------------------#
                        // Player score
                        //-----------------------------------------------------------------#
                        case E_PLAYER_SCORE:
                                ge_playerScore = (GE_PlayerScore *)gne->getNextEvent();
                                playerID = ge_playerScore->getId();
                                g_players[playerID].frags = ge_playerScore->getFrags();
                                g_players[playerID].kills = ge_playerScore->getKills();
                                g_players[playerID].deaths = ge_playerScore->getDeaths();

                                if (ge_playerScore) delete ge_playerScore;
                                break;

                        //-----------------------------------------------------------------#
                        // Select galaxy (yes, same as Extras in game ;))
                        //-----------------------------------------------------------------#
                        case E_PLAYER_EXTRAS:
                                ge_playerExtras = (GE_PlayerExtras *)gne->getNextEvent();
                                playerID = ge_playerExtras->getId();

                                //LOG_MISC(("EXTRAS EVENT"));
                                //applyExtras(playerID, ge_playerExtras->getExtras(), ((ge_playerExtras->getValue() == 0) ? false : true));

                                // galaxy / level selct
                                if (playerID == JOIN_NET_SELECT && !gne->isServer()) {
                                        m_selectedGalaxy = ge_playerExtras->getExtras();
                                        m_selectedLevel = ge_playerExtras->getValue();
                                }
                                // add level
                                else if (playerID == JOIN_NET_ADD && !gne->isServer()) {
                                        addLevel(ge_playerExtras->getExtras(), ge_playerExtras->getValue());
                                }
                                // remove level
                                else if (playerID == JOIN_NET_REMOVE && !gne->isServer()) {
                                        removeLevel();
                                }
                                // start game :D
                                else if (playerID == JOIN_NET_START) {
                                        gne->setPlayerState(g_myPlayerID,PLAYER_STATE_LOADING);

                                        g_gameInfo.currLvl[0] = ge_playerExtras->getExtras();
                                        g_gameInfo.currLvl[1] = ge_playerExtras->getValue();
                                        //console.addEx(Vec3(1.0f, 1.0f, 1.0f), "Galaxy: %d, Level: %d", g_gameInfo.currLvl[0], g_gameInfo.currLvl[1]);
                                        g_music.stop();
                                        g_selectedScene = SCENE_PLAY;
                                }
                                // Set model
                                else if (playerID >= 0) {
                                        g_players[playerID].model = ge_playerExtras->getExtras();
                                        //LOG_MISC(("PlayerID: %d, Model: %d",playerID, ge_playerExtras->getExtras()));
                                }

                                //console.addEx(Vec3(1.0f, 1.0f, 1.0f), "Got some!");

                                if (ge_playerExtras) delete ge_playerExtras;
                                break;

                        //-----------------------------------------------------------------#
                        // Info
                        //-----------------------------------------------------------------#
                        case E_INFO:
                                ge_info = (GE_Info *)gne->getNextEvent();
                                type = ge_info->getValA();

                                //LOG_MISC(("INFO EVENT"));

                                if (type == JOIN_NET_ADD) {
                                        addLevel(ge_info->getValB(), ge_info->getValC());
                                }
                                else if (type == JOIN_NET_PLAYER_MODEL) {
                                        g_players[ge_info->getValB()].model = ge_info->getValC();
                                        //LOG_MISC(("2. PlayerID: %d, Model: %d",ge_info->getValB(), ge_info->getValC()));
                                }

                        //-----------------------------------------------------------------#
                        // No valid event
                        //-----------------------------------------------------------------#
                        default:
                                gne->getNextEvent();
                                break;
                }
        }
}

---