silva
/
pingpong
mirror of https://github.com/viniciusfdasilva/pingpong.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Init commit

This commit is contained in:
Vinicius Silva 2023-09-04 21:20:42 -03:00
parent df11283d5b
commit 7383e95a8e
6 changed files with 336 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
.vscode/settings.json vendored Normal file
View File

@ -0,0 +1,6 @@
{
"files.associations": {
"unistd.h": "c",
"stdio.h": "c"
}
}

7
README.md
View File

@ -1 +1,6 @@
# pingpong # pingpong
* Establish a simple socket connection between a client and a server using the TCP protocol.

BIN
client Executable file
View File

Binary file not shown.

170
client.c Normal file
View File

@ -0,0 +1,170 @@
#include <time.h>
#include <stdio.h>
#include <signal.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#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;
}

BIN
server Executable file
View File

Binary file not shown.

154
server.c Normal file
View File

@ -0,0 +1,154 @@
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#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);
}