ServerProgram.cpp

См. документацию.

/*
 * ServerProgram.cpp
 *
 *  Created on: 18.04.2011
 *      Author: nick
 */

#include "ServerProgram.h"
#include "LibFileOperations/main.h"

int ServerProgram::waiteSocketConnection(int i32SocketFD) {
    int i32ConnectFD = accept(i32SocketFD, 0, 0);
    if (i32ConnectFD < 0) {
        perror("ошибка принятия");
        close(i32ConnectFD); /* нужно ли закрывать сокет после ошибки? */
        exit(EXIT_FAILURE);
    }
    return i32ConnectFD;
}

int ServerProgram::createSocket(uint16_t port) {
    struct sockaddr_in stSockAddr;
    int i32SocketFD = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (i32SocketFD == -1) {
        cerr << "ошибка при создании сокета" << endl;
        exit(EXIT_FAILURE);
    }
    memset(&stSockAddr, 0, sizeof ( stSockAddr));
    stSockAddr.sin_family = PF_INET;
    stSockAddr.sin_port = htons(port);
    stSockAddr.sin_addr.s_addr = INADDR_ANY;

    if (
            bind(i32SocketFD, (const sockaddr*) & stSockAddr, /* зачем приведение типа? */sizeof ( stSockAddr)) == -1
            ) {
        cerr << "ошибка связывания" << endl;
        close(i32SocketFD);
        exit(EXIT_FAILURE);
    }

    if (listen(i32SocketFD, 10) == -1) {
        cerr << "ошибка прослушивания" << endl;
        close(i32SocketFD);
        exit(EXIT_FAILURE);
    }
    return i32SocketFD;
}

void* client_thread_func(void* data ){
        clientData* cld= static_cast<clientData*> (data);
        ServerProgram* self=cld->self;
        unsigned int i32ConnectFD=cld->i32ConnectFD;
        unsigned int i32ConnectFDb=cld->i32ConnectFDb;
        delete cld;
        BinaryProtocolServer bs(self->sc);
        Server serv;
        unsigned int modid=registerModule(&serv, self->sc, &bs);
        serv.setClientId(modid);
//============================================================
        cout<<"Клиент подключился"<<endl;
        bs.startTread(i32ConnectFDb);
        serv.parserCreate(i32ConnectFD);
        //serv.skt_id=i32ConnectFD;
        serv.startParsing(/*i32ConnectFD*/);
        cout<<"Клиент отключился"<<endl;
    //
        shutdown(i32ConnectFD, SHUT_RDWR);
        close(i32ConnectFD);

        shutdown(i32ConnectFDb, SHUT_RDWR);
        close(i32ConnectFDb);
        unregisterModule(modid);
        return NULL;
}

ServerProgram::ServerProgram() {
    // TODO Auto-generated constructor stub
    //ServerConfig* sc=ServerConfig::getInstance();
    //ServerConfig sc;
    pthread_t clntthrd;
    pthread_attr_t clntthrd_attr;
    pthread_attr_init(&clntthrd_attr);
    pthread_attr_setdetachstate(&clntthrd_attr,PTHREAD_CREATE_DETACHED);
    sc=new ServerConfig();
    //====
    int i32SocketFD = createSocket(sc->getServerPort());
    int i32SocketFDb = createSocket(sc->getServerBinPort());
    while(true){
    
        int i32ConnectFD = waiteSocketConnection(i32SocketFD);
        int i32ConnectFDb = waiteSocketConnection(i32SocketFDb);
        clientData* cld=new clientData;
        cld->i32ConnectFD=i32ConnectFD;
        cld->i32ConnectFDb=i32ConnectFDb;
        cld->self=this;
        
        pthread_create(&clntthrd, &clntthrd_attr, client_thread_func, cld);
    }
    pthread_attr_destroy(&clntthrd_attr);
    delete sc;
}

ServerProgram::~ServerProgram() {
    // TODO Auto-generated destructor stub
}