TraitementComServeurPrincipal.cpp

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2007 by Pierre Schmitt, Ludovic Giacomello, Nhi Ly      *
 *                                                                         *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#include "TraitementComServeurPrincipal.h"


TraitementComServeurPrincipal::TraitementComServeurPrincipal(unsigned int port){
        mJeu=Jeu::GetInstance();
        //On établit une connexion vers le serveur principal 
        cout<<endl<<"    SJ TraitementComServeurPrincipal::Création d'un thread de communication UDP avec le serveur principal sur le port "<<port<<endl;
        //On établit une connexion avec le serveur principal
        try{
                mSocket=new SocketUDP("localhost",(unsigned int)port);
        } catch(SocketException s){ s.Afficher(); }
}

TraitementComServeurPrincipal::~TraitementComServeurPrincipal(){
        cout<<"      SJ TraitementComServeurPrincipal::Destruction du thread de communication avec le serveur principal"<<endl;
        if(mSocket!=NULL) delete mSocket;
}

void *TraitementComServeurPrincipal::Traitement(){
        HandShake();
        IndiquerAttenteJoueurs();
        IndiquerConnexions();
        IndiquerDebutPartie();
        IndiquerStatusPartie();
        IndiquerFinPartie();
}

void TraitementComServeurPrincipal::HandShake(){
        mSocket->Envoyer("HELLO");
        if(mSocket->Ecouter()=="HELLO"){
                cout<<"    SJ TraitementComServeurPrincipal::Le serveur principal a répondu à la poignée de main UDP"<<endl;
        }
}

void TraitementComServeurPrincipal::IndiquerAttenteJoueurs(){
        //On indique au serveur principal que l'on est en attente des joueurs 
        string cmd;
        cmd="WAITING ";
        ostringstream oss;
        oss<<mJeu->GetNbFantomeAuto();
        cmd+=oss.str();
        cout<<"    SJ TraitementComServeurPrincipal::On indique au serveur de jeu que le jeu n'est pas pret "<<endl;
        mSocket->Envoyer(cmd);
        mSocket->Ecouter();
}

void TraitementComServeurPrincipal::IndiquerConnexions(){
        //On attend que tout les joueurs soient prets
        string cmd;
        bool pacman=false, f[3];
        for(unsigned int i=0; i<3; i++) f[i]=false;
        while(1){
                //On cherche si des nouvelles places ont été choisies et on l'en informe le serveur de jeu
                if(!pacman) if(mJeu->GetPacmanConnecte()){
                        cout<<"    SJ TraitementComServeurPrincipal::On indique au serveur de jeu que pacman vient de se connecter"<<endl;
                        cmd="SET PACMAN "; cmd+=mJeu->GetLoginPacman();
                        mSocket->Envoyer(cmd);
                        pacman=true;
                }
                for(unsigned int i=0; i<3; i++){
                        if(!f[i]) if(mJeu->GetFConnecte(i)){
                                cout<<"    SJ TraitementComServeurPrincipal::On indique au serveur de jeu que le fantome "<<i<<" vient de se connecter"<<endl;  
                                ostringstream oss;
                                oss<<i;
                                string no=oss.str();
                                cmd="SET F "; cmd+=mJeu->GetLoginF(i);  cmd+=" ";  cmd+=no;
                                mSocket->Envoyer(cmd);
                                f[i]=true;
                        }
                }
                if(pacman){
                        bool tousConnecte=true;
                        for(unsigned int i=0; i<3; i++){
                                if(!f[i]) tousConnecte=false;
                        }
                        if(tousConnecte){
                                //Tous les joueurs sont connectés ET on l'a bien annoncé au serveur principal 
                                break;
                        }
                }
                sleep(1);
        }
}

void TraitementComServeurPrincipal::IndiquerDebutPartie(){
        cout<<"    SJ TraitementComServeurPrincipal::On indique au serveur de jeu que tous les joueurs sont connectés"<<endl;
        mSocket->Envoyer("READY");
        mSocket->Ecouter();     
}

void TraitementComServeurPrincipal::IndiquerStatusPartie(){
        while(!mJeu->GameOver()){
                string envoi="STATUS "; envoi+=mJeu->EtatPartie();
                mSocket->Envoyer(envoi);
                sleep(1);
        }
}

void TraitementComServeurPrincipal::IndiquerFinPartie(){
        //La partie est terminée, on le signifie au serveur principal 
        //On envoi le status du jeu final 
        string envoi="STATUS "; envoi+=mJeu->EtatPartie();
        mSocket->Envoyer(envoi);
        cout<<"    SJ TraitementComServeurPrincipal::On indique au serveur principal que la partie est terminée"<<endl;
        mSocket->Envoyer("GAME OVER");
}

---