TcpClient.cpp

Go to the documentation of this file.

// -*- mode: c++; indent-tabs-mode: nil; c-basic-offset: 4; coding: iso-8859-1; -*-

/*
ACT-CV - Machine Vision for Cognitive Modeling
Copyright (c) 2008 Marc Halbruegge

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., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
*/


#include <iostream>
#include "TcpClient.h"

using namespace std;

void ActCvClient::ConnectTo(const char* name, int port) {
    struct hostent *hp; /* ptr to host info for remote */
    struct sockaddr_in srv; /* used by connect() */
    srv.sin_family = AF_INET;

    hp = gethostbyname(name);
    srv.sin_addr.s_addr = ((struct in_addr*)(hp->h_addr))->s_addr;

    /* connect: use the Internet address family */
    srv.sin_family = AF_INET;
    /* connect: socket fd to user specified port */
    srv.sin_port = htons(port);
    if((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        cerr << "socket";
        throw ClientError("socket");
    }
#if 1
    int flag = 1;
    int result = setsockopt(sock,
                     IPPROTO_TCP,
                     TCP_NODELAY,
                     (char *) &flag,
                     sizeof(int));
    if (result < 0) {
        cerr << "setsockopt";
        throw ClientError("setsockopt");
    }
#endif

    if(connect(sock, (struct sockaddr*) &srv, sizeof(srv)) < 0) {
        cerr << "connect"; 
        throw ClientError("connect");
    }
    
    isConnected=true;
}

void ActCvClient::SendKey(int keyCode) {
    if (!isConnected) {
        throw ClientError("not connected");
    }
    
    if (send(sock, "K", 1, 0) < 0) {
        cerr << "write";
        throw ClientError("write");
    }
    // B -> 0x42
    // M -> 0x4d
    // N -> 0x4e
    // left arrow -> 37
    // right arrow -> 39
    if (send(sock, (char*)&keyCode, sizeof(int), 0) < 0) {
        cerr << "write";
        throw ClientError("write");
    }
}

void ActCvClient::ReadData() {
    if (!isConnected) {
        throw ClientError("not connected");
    }

    if (send(sock, "X", 1, 0) < 0) {
        cerr << "write";
        throw ClientError("write");
    }
    int numBytes;
    if(recv(sock, (char*)&numBytes, sizeof(numBytes), 0) < 0) {
        cerr << "read";
        throw ClientError("read");
    }
    if (numBytes>0) {
        char *data= new char[numBytes+1];
        if(recv(sock, data, numBytes, 0) < 0) {
            cerr << "read";
            throw ClientError("write");
        }
        data[numBytes]=0;
        
        cout << data << endl;
        delete[] data;
    }
}