TestReseauServer.cpp

Aller à la documentation de ce fichier.

/*! \file TestReseauServer.cpp
    \brief Serveur pour test réseau.

    Serveur pour tester le système réseau.

    \author     aerith (contact@aerith.biz - www.aerith.biz)
    \version    1.0
    \date       16/02/2006
*/

#include    "../Portage/Error.h"
#include    "../Portage/Tools.h"
#include    "../Ini/Ini.h"
#include    "NetServer.h"
#include    "NetParser.h"


MUTEX       MutexEcran;
NetServer   Server;

int     ThreadGestionClient(NetConnect *pConnect);          /*!< Thread de gestion des clients. */

int     RequestServerData(NetRequestParameter *pParameter); /*!< Requette de raw NET_DATA.      */

int     main(void)
{
    char        Buffer[NET_BUFFER];
    char        Key;
    int         Size;
    int         i;
    Ini         Fichier("Net.conf");
    BEGIN
    LOC("main")
    LOG("serveur.log")

    if(Fichier.GetSection("langage"))
    {
        if(Fichier.GetSection("langage")->GetItem("error"))
        {
            LANG(Fichier.GetSection("langage")->GetItem("error")->GetData())
        }
        else
            printf("Pas d'info de langage d'erreur\n");
    }
    else
        printf("Pas de section langage\n");

    sprintf(Buffer, "%s ", NET_DATA);
    for(i = strlen(Buffer); i <= (NET_BUFFER - 1); i++)
        Buffer[i] = 'a';

    MutexInit(&MutexEcran);

    TRY if(Fichier.GetSection("client"))
    {
        if(Fichier.GetSection("serveur")->GetItem("port") && Fichier.GetSection("serveur")->GetItem("limit") && Fichier.GetSection("serveur")->GetItem("pass"))
            TRY CERROR = Server.Start(
                AtoD(Fichier.GetSection("serveur")->GetItem("port")->GetData()),
                AtoD(Fichier.GetSection("serveur")->GetItem("limit")->GetData()),
                Fichier.GetSection("serveur")->GetItem("pass")->GetData(),
                (ROUTINE)ThreadGestionClient
            );
        else
        {
            printf("Pas d'info de port, limit ou pass\n");
            CERROR = 2;
        }
    }
    else
    {
        printf("Pas de section serveur\n");
        CERROR = 2;
    }

    TRY do
    {
        MutexLock(&MutexEcran);
        printf("Clients : %i/%i\n\n", Server.GetNbClient(), Server.GetLimit());
        printf("--- Menu d'administration serveur ---\n");
        printf("\tl : Liste les clients\n");
        printf("\te : Envoie un packet aux clients\n");
        printf("\tq : Quitte l'application\n\n");
        printf("  Choix : ");
        MutexUnLock(&MutexEcran);
    
        Key = KeyGet();

        switch(Key)
        {
            case    'l' :
                MutexLock(&MutexEcran);
                printf("Serveur en ecoute sur : %i\n\n", Server.Connect->Port);
                printf("Nombre de client : %i\n\n", Server.GetNbClient());
                for(i = 0; i < Server.GetNbClient(); i++)
                    printf("IP : %s\tID : %i\n", Server.GetClientNo(i)->Ip, Server.GetClientNo(i)->GetId());

                MutexUnLock(&MutexEcran);
                break;
            case    'e' :
                MutexLock(&MutexEcran);
                printf("\n\n  Entrez la taille des packets : ");
                MutexUnLock(&MutexEcran);

                scanf("%i", &Size);

                for(i = 0; i < Server.GetNbClient(); i++)
                {
                    TRYIF(Server.GetClientNo(i)->SetBufferSize(Size + strlen(NET_DATA) + 1), 14)
                    TRYIF(Server.GetClientNo(i)->SetBufferManu(Buffer), 14)

                    TRY CERROR = Server.GetClientNo(i)->Send();
                }
                break;
        }

        if(Key != 'q')
        {
            MutexLock(&MutexEcran);
            printf("\nPressez entree pour le menu\n");
            MutexUnLock(&MutexEcran);

            Key = KeyGet();
        }
    }
    while((Key != 'q') && !CERROR);
    
    Server.Stop();
    printf("\nServeur stoper\n");

    MutexStop(&MutexEcran);

    PERROR

    ENDBEGIN
}

int     ThreadGestionClient(NetConnect *pConnect)
{
    NetParser   Parser(pConnect);
    BEGIN
    LOC("ThreadGestionClient")

    TRY Parser.AddRequest(NET_DATA, 0, (ROUTINE)RequestServerData, "%s %i");

    do
    {
        TRY CERROR = pConnect->Receive();

        TRY CERROR = Parser.Parse(pConnect->GetBuffer());
    }
    while(!CERROR && pConnect);

    if(pConnect)
        Server.KillClient(pConnect->GetId());

    ThreadExit(CERROR);

    return 0;
}

int     RequestServerData(NetRequestParameter *pParameter)
{
    MutexLock(&MutexEcran);
    printf("Client %i : %i chars\n", pParameter->Connect->GetId(), pParameter->GetInt(1));
    MutexUnLock(&MutexEcran);

    return 0;
}

---