BinaryProtocolClient.cpp

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

/*
 * BinaryProtocolClient.cpp
 *
 *  Created on: 25.05.2011
 *      Author: nick
 */

#include "BinaryProtocolClient.h"

void* bin_client_threadFunc(void* clnt){
        BinaryProtocol* cl= static_cast<BinaryProtocol*> (clnt);
        cl->parse();
        return NULL;
}

void BinaryProtocolClient::connect_server(string address, unsigned short port){
    struct sockaddr_in stSockAddr;
    int i32Res;
    skt_id = socket( PF_INET, SOCK_STREAM, IPPROTO_TCP );
    if ( skt_id == -1 ){
        cout<< "Ошибка: невозможно создать сокет"<<endl;
        exit( EXIT_FAILURE );
    }

    memset( &stSockAddr, 0, sizeof( stSockAddr ) );

    stSockAddr.sin_family = PF_INET;
    stSockAddr.sin_port = htons(port);
    i32Res = inet_pton( PF_INET, address.data(), &stSockAddr.sin_addr );

    if ( i32Res < 0 ){
        cout<< "Ошибка: первый параметр не относится к категории корректных адресов"<<endl;
        close( skt_id );
        exit( EXIT_FAILURE );
    }else
      if ( !i32Res ){
          cout<< ( "Ошибка: второй параметр не содержит корректного IP-адреса" );
          close( skt_id );
          exit( EXIT_FAILURE );
      }

    if (connect(skt_id,( const sockaddr* )&stSockAddr, sizeof( stSockAddr )) == -1){
        cout<<"Ошибка соединения"<<endl;
        close( skt_id );
        exit( EXIT_FAILURE );
    }
    //parserCreate(skt_id);
    //curNodeSend=new Node("stream:stream",NULL);
    pthread_create(&clientThread,NULL,bin_client_threadFunc,this);
    //Создаем и отправляем начальную ноду
    //createNodeSend();
    /* выполнение операций чтения и записи ... */
    //shutdown( i32SocketFD, SHUT_RDWR );
    //close( i32SocketFD );
}

BinaryProtocolClient::BinaryProtocolClient(ClientConfigFile* cf):BinaryProtocol(cf) {
        // TODO Auto-generated constructor stub

}

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