CppSandbox/utilityNetwork/Serveur.cpp

#include "Serveur.h"

Serveur::Serveur(int port): m_port(port)
{
    #ifdef WIN32
        m_erreur = WSAStartup(MAKEWORD(2,2), &m_WSAData);
    #else
        m_erreur = 0;
    #endif // WIN32
    m_sock.recsize = sizeof(m_sock.sin);
    for(int i = 0;i<NBR_CLIENT;i++)
        m_csock[i].recsize = sizeof(m_csock[i].sin);

}

Serveur::~Serveur()
{
    #ifdef WIN32
        WSACleanup();
    #endif // WIN32
    std::cout << "Fermeture des sockets clientes" << std::endl;
    for(int i = 0;i<NBR_CLIENT;i++)
        closesocket(m_csock[i].sock);
    std::cout << "Fermeture de la socket serveur" << std::endl;
    closesocket(m_sock.sock);
    std::cout << "Fermeture du serveur termine" << std::endl;
}


bool Serveur::rendreUtilisable()
{
    if(!m_erreur)
    {
        m_sock.sock = socket(AF_INET, SOCK_STREAM, 0);// SOCK_STREAM pour TCP/IP, SOCK_DGRAM pour UDP/IP
        if(m_sock.sock != INVALID_SOCKET)
        {
            std::cout << "La socket " << m_sock.sock << " est maintenant ouverte en mode TCP/IP" << std::endl;
            m_sock.sin.sin_addr.s_addr = htonl(INADDR_ANY);
            m_sock.sin.sin_family = AF_INET;
            m_sock.sin.sin_port = htons(m_port);
            if(bind(m_sock.sock, (SOCKADDR*)&m_sock.sin, m_sock.recsize) != SOCKET_ERROR)
            {
                std::cout << "Listage du port " << m_port << "..." << std::endl;
                if(listen(m_sock.sock, 5) != SOCKET_ERROR)
                {
                    std::cout << "Patientez pendant que les " << NBR_CLIENT << " clients se connectent sur le port " << m_port << "..." << std::endl;
                    for(int i = 0;i<NBR_CLIENT;i++)
                    {
                        m_csock[i].sock = accept(m_sock.sock, (SOCKADDR*)&m_csock[i].sin, &m_csock[0].recsize);// renvoi INVALID_SOCKET si il y a un probleme
                        if(m_csock[i].sock != INVALID_SOCKET)
                        {
                            std::cout << "Un clien se connect avec la socket " << m_csock[i].sock << " de " << inet_ntoa(m_csock[i].sin.sin_addr) << " : " << htons(m_csock[i].sin.sin_port) << std::endl;
                        }
                        else
                            return false;
                    }
                }
                else
                    return false;
            }
            else
                return false;
        }
        else
            return false;
    }
    else
        return false;
    return true;
}

void Serveur::envoyer(int *donnee, int indice, int tailleByte)
{
    if(tailleByte != 0)
        send(m_csock[indice].sock, (char*)donnee, tailleByte, 0);
    else
        send(m_csock[indice].sock, (char*)donnee, sizeof(*donnee), 0);
}

void Serveur::recevoir(int *donnee, int indice, int tailleByte)
{
    if(tailleByte != 0)
        send(m_csock[indice].sock, (char*)donnee, tailleByte, 0);
    else
        send(m_csock[indice].sock, (char*)donnee, sizeof(*donnee), 0);
}