orcasim::gdbrsp::UdpAsyncServer Class Reference

This class implements an asynchonous udp server. More...

#include <UdpAsyncServer.hpp>

Public Member Functions
	UdpAsyncServer (int port)
	Default ctor. More...
	~UdpAsyncServer ()
int	Send (char *data, int length)
	Send a reply to the GDB client. More...
int	Receive (char *data)
	Receives data from the GDB client. More...
void	Error (UdpAsyncError err)

Private Attributes
fd_set	original_socket
fd_set	original_stdin
fd_set	readfds
fd_set	writefds
struct timeval	tv
int	numfd
int	socket_fd
int	bytes_read
unsigned int	address_length
char *	recieve_data [MAX_LENGTH]
char	send_data [MAX_LENGTH]
struct sockaddr_in server_address	client_address

Detailed Description

This class implements an asynchonous udp server.

We use select() to interrupt the simulation only when there is some packet for the gdb server.

Definition at line 58 of file UdpAsyncServer.hpp.

Constructor & Destructor Documentation

UdpAsyncServer()

UdpAsyncServer::UdpAsyncServer ( int  port )

explicit

Default ctor.

Parameters

port	UDP port number to run the server.

Definition at line 51 of file UdpAsyncServer.cpp.

                                       {
    if ((socket_fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
        this->Error(UdpAsyncError::SOCKET_OPEN);
    }

    int flags = fcntl(socket_fd, F_GETFL);
    flags |= O_NONBLOCK;
    fcntl(socket_fd, F_SETFL, flags);

    // file descriptor set to monitoring for reading
    FD_ZERO(&original_socket);
    FD_ZERO(&readfds);

    // file descriptor set to monitoring for writing
    FD_ZERO(&writefds);

    // add the receiving socket to the receiving set
    FD_SET(socket_fd, &original_socket);
    FD_SET(socket_fd, &readfds);

    // add the empty set to the writing monitoring list
    FD_SET(0, &writefds);

    // since we got s2 second, it's the "greater", so we use that for
    // // the n param in select()
    numfd = socket_fd + 1;

    // wait until either socket has data ready to be recv()d (timeout 10.5 secs)
    tv.tv_sec = 1;
    tv.tv_usec = 500000;

    server_address.sin_family = AF_INET;
    server_address.sin_port = htons(port);
    server_address.sin_addr.s_addr = INADDR_ANY;
    bzero(&(server_address.sin_zero), 8);

    address_length = sizeof(struct sockaddr);

    if (bind(socket_fd, (struct sockaddr *)&server_address,
        sizeof(struct sockaddr)) == -1) {
            this->Error(UdpAsyncError::SOCKET_BIND);
    }
}

~UdpAsyncServer()

UdpAsyncServer::~UdpAsyncServer

(

)

Definition at line 127 of file UdpAsyncServer.cpp.

                                {
    close(socket_fd);
}

Member Function Documentation

Error()

void UdpAsyncServer::Error

(

UdpAsyncError

err

)

Definition at line 32 of file UdpAsyncServer.cpp.

                                            {
    std::string message = "UdpAsyncErro: ";

    switch (err) {
        case UdpAsyncError::SOCKET_OPEN:
            message = message +
                "Could not create socket" +
                "(tips: +exceeded_socket_limit +system_permission).";
            break;
        case UdpAsyncError::SOCKET_BIND:
            message = message +
                "Could not bind socket (tips: +address_in_use).";
            break;
        default: break;
    }

    std::cout << message << std::endl;
}

Receive()

int UdpAsyncServer::Receive

(

char *

data

)

Receives data from the GDB client.

Parameters

data	Location to store data in.

Returns

Returns the number of received bytes or -1

Definition at line 101 of file UdpAsyncServer.cpp.

                                      {
    // copy the receiving set to the working variable
    readfds = original_socket;

    // chech whether the receving set has data
    int res = select(numfd, &readfds, &writefds, NULL, &tv);

    switch (res) {
        case -1:
            this->Error(UdpAsyncError::SELECT_ERR);
            break;
        case 0:
            this->Error(UdpAsyncError::TIMEOUT_EXCEEDED);
            break;
        default:
            if (FD_ISSET(socket_fd, &readfds)) {
                FD_CLR(socket_fd, &readfds);
                bytes_read = recvfrom(socket_fd, data, MAX_LENGTH, 0,
                    (struct sockaddr *)&client_address, &address_length);
                return bytes_read;
            }
    }

    return 0;
}

Send()

int UdpAsyncServer::Send	(	char *	data,
		int	length
	)

Send a reply to the GDB client.

Parameters

data	Data to be send
length	The number of bytes to send

Returns

Returns 0 when sucefful, otherwise error num.

Definition at line 96 of file UdpAsyncServer.cpp.

                                               {
    return sendto(socket_fd, data, length, 0,
        (struct sockaddr*)&client_address, sizeof(struct sockaddr));
}

Member Data Documentation

address_length

unsigned int orcasim::gdbrsp::UdpAsyncServer::address_length

private

Definition at line 68 of file UdpAsyncServer.hpp.

bytes_read

int orcasim::gdbrsp::UdpAsyncServer::bytes_read

private

Definition at line 67 of file UdpAsyncServer.hpp.

client_address

struct sockaddr_in server_address orcasim::gdbrsp::UdpAsyncServer::client_address

private

Definition at line 70 of file UdpAsyncServer.hpp.

numfd

int orcasim::gdbrsp::UdpAsyncServer::numfd

private

Definition at line 66 of file UdpAsyncServer.hpp.

original_socket

fd_set orcasim::gdbrsp::UdpAsyncServer::original_socket

private

Definition at line 60 of file UdpAsyncServer.hpp.

original_stdin

fd_set orcasim::gdbrsp::UdpAsyncServer::original_stdin

private

Definition at line 61 of file UdpAsyncServer.hpp.

readfds

fd_set orcasim::gdbrsp::UdpAsyncServer::readfds

private

Definition at line 62 of file UdpAsyncServer.hpp.

recieve_data

char* orcasim::gdbrsp::UdpAsyncServer::recieve_data[MAX_LENGTH]

private

Definition at line 69 of file UdpAsyncServer.hpp.

send_data

char orcasim::gdbrsp::UdpAsyncServer::send_data[MAX_LENGTH]

private

Definition at line 69 of file UdpAsyncServer.hpp.

socket_fd

int orcasim::gdbrsp::UdpAsyncServer::socket_fd

private

Definition at line 67 of file UdpAsyncServer.hpp.

tv

struct timeval orcasim::gdbrsp::UdpAsyncServer::tv

private

Definition at line 65 of file UdpAsyncServer.hpp.

writefds

fd_set orcasim::gdbrsp::UdpAsyncServer::writefds

private

Definition at line 63 of file UdpAsyncServer.hpp.

---

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

• orcasim-gdbrsp/include/UdpAsyncServer.hpp
• orcasim-gdbrsp/src/UdpAsyncServer.cpp