diff --git a/.vscode/settings.json b/.vscode/settings.json new file mode 100644 index 0000000..a0aef3b --- /dev/null +++ b/.vscode/settings.json @@ -0,0 +1,6 @@ +{ + "files.associations": { + "unistd.h": "c", + "stdio.h": "c" + } +} \ No newline at end of file diff --git a/README.md b/README.md index dfd3afd..496c079 100644 --- a/README.md +++ b/README.md @@ -1 +1,6 @@ -# pingpong \ No newline at end of file +# pingpong + + +* Establish a simple socket connection between a client and a server using the TCP protocol. + + \ No newline at end of file diff --git a/client b/client new file mode 100755 index 0000000..fa20f62 Binary files /dev/null and b/client differ diff --git a/client.c b/client.c new file mode 100644 index 0000000..21eea59 --- /dev/null +++ b/client.c @@ -0,0 +1,170 @@ +#include +#include +#include +#include +#include +#include +#include +#include + + +#define TRUE 1 +#define FALSE 0 +#define HOST_IP "127.0.0.1" // IPV4 loopback address +#define SERVER_PORT 8077 // Server port +#define BUFFER_SIZE 8192 // Default size +#define PORT_USED_CODE 256 +#define SOCKET_ERROR_CODE -1 // Socket create, Connection server, Receive buffer to server code error +#define SYSTEM_EXIT_FAILED 1 // Operating System program error response +#define SYSTEM_EXIT_SUCCESS 0 // Operating System program success response + + +char sended_buffer[BUFFER_SIZE]; + +typedef struct sockaddr_in socket_address; + +int init_socket() +{ + // AF_INET -> IPV4 Family + // SOCK_STREAM -> TCP Socket initialization + // IPPROTO_TCP -> TCP Explicit protocol + int client_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); + + if(client_socket == SOCKET_ERROR_CODE) + { + perror("Socket create failed!\n"); + exit(SYSTEM_EXIT_FAILED); + } +} + +socket_address config_server_address() +{ + socket_address server_address; + + server_address.sin_family = AF_INET; // IPV4 ips family + server_address.sin_port = htons(SERVER_PORT); + server_address.sin_addr.s_addr = inet_addr(HOST_IP); + + return server_address; +} + + +void connect_to_server(int client_socket, socket_address server_address) +{ + struct sockaddr* address = (struct sockaddr*)&server_address; + + int connection_response = connect(client_socket, + address, + sizeof(server_address) + ); + + if(connection_response == SOCKET_ERROR_CODE) + { + perror("Server connection error\n"); + close(client_socket); + exit(SYSTEM_EXIT_FAILED); + }{ + printf("Server connection successfully\n\n"); + } +} + +void init_buffer() +{ + memset(&sended_buffer, '0', BUFFER_SIZE); +} + +int is_server_down() +{ + char* full_command = (char*)malloc(1000*sizeof(char)); + + char* base_command = "lsof -i 4@"; + char str[5]; + sprintf(str, "%d", SERVER_PORT); + + strcat(full_command, base_command); + strcat(full_command,HOST_IP); + strcat(full_command, " -i:"); + strcat(full_command, str); + strcat(full_command, " >/dev/null 2>&1"); + + system(full_command) == PORT_USED_CODE ? FALSE : TRUE; +} + +int receive_buffer(int client_socket) +{ + if(!is_server_down()) + { + char received_buffer[BUFFER_SIZE]; // Buffer will be send by server to client + int bytes_read = recv(client_socket, received_buffer, sizeof(received_buffer), 0); + + if(bytes_read == SOCKET_ERROR_CODE) + { + perror("Receive server message error!"); + + }else + { + received_buffer[bytes_read] = '\0'; // Buffer string finalized with '\0', + printf("Receiving [PONG] %f KB\n", ((float)BUFFER_SIZE/(float)1024)); + printf("\nServer message received successfully!\n"); + } + }else{ + printf("Server is down!"); + exit(SYSTEM_EXIT_SUCCESS); + } +} + +void send_buffer(int client_socket) +{ + clock_t init_time, end_time, total_time; + init_buffer(sended_buffer); + + + printf("Sending [PING] %f KB\n", ((float)BUFFER_SIZE/(float)1024)); + + + + send(client_socket, sended_buffer, strlen(sended_buffer), 0); + receive_buffer(client_socket); + +} + +void controlc_handler() +{ + printf("\nProgram finished!\n"); + exit(SYSTEM_EXIT_SUCCESS); +} + +void socket_listen(int client_socket) +{ + + if(signal(SIGINT, controlc_handler) == SIG_ERR) + { + perror("Signal create error!"); + exit(SYSTEM_EXIT_FAILED); + } + + send_buffer(client_socket); + +} + +int main(void) +{ + + int client_socket = init_socket(); + + socket_address server_address; + server_address = config_server_address(); + + connect_to_server(client_socket, server_address); + + clock_t start = clock(); + socket_listen(client_socket); + clock_t end = clock(); + + double elapsed_time_ms = (double)(end - start) * 1000.0 / CLOCKS_PER_SEC; + + printf("Time: %.2f ms\n", elapsed_time_ms); + + + return SYSTEM_EXIT_SUCCESS; +} \ No newline at end of file diff --git a/server b/server new file mode 100755 index 0000000..c12b2d3 Binary files /dev/null and b/server differ diff --git a/server.c b/server.c new file mode 100644 index 0000000..920d7de --- /dev/null +++ b/server.c @@ -0,0 +1,154 @@ +#include +#include +#include +#include +#include +#include +#include + +#define TRUE 1 +#define HOST_IP "127.0.0.1" // IPV4 loopback address +#define SERVER_PORT 8077 // Server port +#define BUFFER_SIZE 8192 // Default size (64bytes) to (8Kbytes) +#define MAX_CONNECTIONS 2 // Num max client connected simultaneously +#define SOCKET_ERROR_CODE -1 // Socket create, Connection server, Receive buffer to server code error +#define SYSTEM_EXIT_FAILED 1 // Operating System program error response +#define SYSTEM_EXIT_SUCCESS 0 // Operating System program success response + +typedef struct sockaddr_in socket_address; + +char buffer[BUFFER_SIZE]; + +int create_socket() +{ + int server_socket; + + server_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); + + if(server_socket == SOCKET_ERROR_CODE) + { + perror("Socket create failed!"); + exit(SYSTEM_EXIT_FAILED); + } + + return server_socket; +} + +socket_address config_server_address() +{ + socket_address server_address; + + server_address.sin_family = AF_INET; // IPV4 ips family + server_address.sin_port = htons(SERVER_PORT); + server_address.sin_addr.s_addr = inet_addr(HOST_IP); + + return server_address; +} + +void bind_server(int server_socket, socket_address server_address) +{ + + struct sockaddr *address = (struct sockaddr*)&server_address; + + int server_bind_response = bind(server_socket, address, sizeof(server_address)); + + if(server_bind_response == SOCKET_ERROR_CODE) + { + perror("Bind server error"); + close(server_socket); + exit(SYSTEM_EXIT_FAILED); + } +} + +int accept_connection(int client_socket, int server_socket, socket_address client_address, socklen_t client_addr_len) +{ + struct sockaddr *address = (struct sockaddr*)&client_address; + + client_socket = accept(server_socket, address, &client_addr_len); + + if(client_socket == SYSTEM_EXIT_FAILED) + { + perror("Accept connection error!"); + exit(SYSTEM_EXIT_FAILED); + + }else{ + printf("Client connected: %s:%d\n", inet_ntoa(client_address.sin_addr), ntohs(client_address.sin_port)); + return client_socket; + } + +} + +void send_buffer(int client_socket) +{ + + printf("Sending [PONG]\n"); + send(client_socket, buffer, strlen(buffer), 0); +} + + +void receive_buffer(int client_socket) +{ + int bytes_read; + + printf("Receiving [PING]\n"); + + while((bytes_read = recv(client_socket, buffer, sizeof(buffer), 0)) > 0) + { + buffer[bytes_read] = '\0'; + printf("Client message received successfully!\n"); + + send_buffer(client_socket); + } + + +} + +void controlc_handler() +{ + printf("\nProgram finished!\n"); + exit(SYSTEM_EXIT_SUCCESS); +} + + +void server_listen(int client_socket, int server_socket, socket_address client_address, socklen_t client_addr_len) +{ + + if (listen(server_socket, MAX_CONNECTIONS) == SOCKET_ERROR_CODE) + { + perror("Listening mode error"); + close(server_socket); + exit(SYSTEM_EXIT_FAILED); + } + + printf("Server TCP listening on port %d...\n", SERVER_PORT); + + if(signal(SIGINT, controlc_handler) == SIG_ERR) + { + perror("Signal create error!"); + exit(SYSTEM_EXIT_FAILED); + } + + while(TRUE) + { + client_socket = accept_connection(client_socket, server_socket, client_address, client_addr_len); + + receive_buffer(client_socket); + } + +} + +int main(void) +{ + int server_socket, client_socket; + + server_socket = create_socket(); + + socket_address server_address, client_address; + socklen_t client_addr_len = sizeof(client_address); + + server_address = config_server_address(); + + bind_server(server_socket, server_address); + + server_listen(client_socket, server_socket, client_address, client_addr_len); +}