SocketConnector Class Reference

#include <SocketConnector.h>

Public Member Functions
int	read_data (char *buffer, int data_size)
void	flush_socket ()
void	connect_socket ()
void	close_socket ()
	SocketConnector ()

Public Attributes
SOCKET	rc_socket
bool	b_connected
std::string	ip
int	port
std::string	connection_information

Detailed Description

Definition at line 36 of file SocketConnector.h.

Constructor & Destructor Documentation

SocketConnector()

SocketConnector::SocketConnector ( )

inline

Definition at line 50 of file SocketConnector.h.

                      : rc_socket(INVALID_SOCKET),
                        b_connected(false),
                        ip("127.0.0.1"),
                        port(6342){};

Member Function Documentation

close_socket()

void SocketConnector::close_socket

(

)

Definition at line 137 of file SocketConnector.cpp.

{
    close(rc_socket);
}

connect_socket()

void SocketConnector::connect_socket

(

)

Definition at line 63 of file SocketConnector.cpp.

{
#ifdef WIN32
    int error = WSAStartup(0x0202, &w);
    if (error)
    {
        exit(EXIT_FAILURE);
    }
#endif
 
    // Creating socket file descriptor
    rc_socket = socket(AF_INET, SOCK_STREAM, 0);
    if (rc_socket == INVALID_SOCKET)
    {
        handle_socket_errors("intitializing Socket");
    }
 
    if (setsockopt(rc_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) == SOCKET_ERROR)
    {
        handle_socket_errors("setting socket options");
    }
 
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = inet_addr(ip.c_str());
    address.sin_port = htons(port);
 
    std::cout << "Waiting for incoming connection..." << std::endl;
 
    // Connecting socket to the port
    int error_counter = 0;
    while (true)
    {
        if (connect(rc_socket, (struct sockaddr *)&address, sizeof(address)) == SOCKET_ERROR)
        {
            if (error_counter < 1)
            {
                handle_socket_errors("connecting to Socket");
            }
            error_counter++;
        }
        else
        {
            std::cout << "Connected by " << inet_ntoa(address.sin_addr) << "\n";
            b_connected = true;
            break;
        }
    }
}

flush_socket()

void SocketConnector::flush_socket

(

)

Definition at line 42 of file SocketConnector.cpp.

{
    close_socket();
    connect_socket();
    char *buffer = {0};
    int bytes_total = 0;
 
    while (true)
    {
        int bytes_count = recv(rc_socket, &buffer[0], 1, 0);
 
        if (bytes_count <= 0)
        {
            std::cout << "Socket flushed (" << bytes_total / 1024 << " kB)" << std::endl;
            break;
        }
        bytes_total += bytes_count;
    }
    close_socket();
}

read_data()

int SocketConnector::read_data	(	char *	buffer,
		int	data_size
	)

Definition at line 16 of file SocketConnector.cpp.

{
    int bytes_payload_total = 0;
 
    while (bytes_payload_total < data_size)
    {
        int bytes_payload_count = recv(rc_socket,
                                   &buffer[bytes_payload_total],
                                   data_size - bytes_payload_total,
                                   0);
 
        if (bytes_payload_count == -1)
        {
            perror("Error reading Data!");
            return -1;
        }
        else if (bytes_payload_count == 0)
        {
            std::cout << "Unexpected end of transmission" << std::endl;
            return -1;
        }
        bytes_payload_total += bytes_payload_count;
    }
    return 0;
}

Member Data Documentation

b_connected

bool SocketConnector::b_connected

Definition at line 41 of file SocketConnector.h.

connection_information

std::string SocketConnector::connection_information

Definition at line 45 of file SocketConnector.h.

ip

std::string SocketConnector::ip

Definition at line 42 of file SocketConnector.h.

port

int SocketConnector::port

Definition at line 43 of file SocketConnector.h.

rc_socket

SOCKET SocketConnector::rc_socket

Definition at line 39 of file SocketConnector.h.

---

The documentation for this class was generated from the following files:

• src/SocketConnector.h
• src/SocketConnector.cpp