AfonsoCMSousa/KeyMaster
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Implemented threads for multiple clients.

Browse Source
This commit is contained in:
Afonso Clerigo Mendes de Sousa 2025-02-28 22:00:43 +00:00
parent d7b8f14bbc
commit 5dc71aaa04
1 changed files with 82 additions and 71 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

153
src/server.c
View File

@ -6,6 +6,7 @@
#include <arpa/inet.h> #include <arpa/inet.h>
#include <unistd.h> #include <unistd.h>
#include <string.h> #include <string.h>
#include <pthread.h>
#include "herror.h" #include "herror.h"
#include "dynmem.h" #include "dynmem.h"
@ -22,85 +23,20 @@ typedef struct Request
int level; int level;
} Request; } Request;
int main(void) void *handle_client(void *arg)
{ {
// Connect and bind to a port (8080) on the server int connfd = *(int *)arg;
int sockfd = socket(AF_INET, SOCK_STREAM, 0); free(arg);
if (sockfd == -1)
{
fprintf(stderr, "Socket creation failed\n");
return 1;
}
struct sockaddr_in servaddr;
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(8080);
servaddr.sin_addr.s_addr = inet_addr(SERVER_IP);
if (bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) != 0)
{
fprintf(stderr, "Socket bind failed\n");
close(sockfd);
return 1;
}
if (listen(sockfd, 5) != 0)
{
fprintf(stderr, "Listen failed\n");
close(sockfd);
return 1;
}
printf("Server listening on %s:8080\n", SERVER_IP);
struct sockaddr_in cli;
u_int32_t len = sizeof(cli);
Request req; Request req;
memset(&req, 0, sizeof(req));
req.ID = 0;
req.level = 0;
req.type = 0;
u_int8_t isConnected = 0;
int connfd;
/*
* WE NEED TO IMPLEMENT A WAY TO HANDLE MULTIPLE CLIENTS
* AND MAKE IT SABLE (RIGHT NOW IT CRASHES EVERY TIME A CLIENT DISCONNECTS)
*
* ALSO MAKE A BETTER WAY OF STOPPING THE SERVER
*
* TODO:
* -1 Fix the chashing issues
* -2 Implement a way to stop the server
* -3 Implement a way to handle multiple clients
*/
// Listen to the client requests
while (1) while (1)
{ {
// Receive the request
if (!isConnected)
{
connfd = accept(sockfd, (struct sockaddr *)&cli, &len);
if (connfd < 0)
{
fprintf(stderr, "Server accept failed\n");
close(sockfd);
}
isConnected = 1;
continue;
}
printf("Client connected\n");
int n = recv(connfd, &req, sizeof(req), 0); int n = recv(connfd, &req, sizeof(req), 0);
if (n <= 0) if (n <= 0)
{ {
fprintf(stderr, "Client disconnected\n"); fprintf(stderr, "Client disconnected\n");
isConnected = 0; close(connfd);
pthread_exit(NULL);
} }
// debug // debug
@ -247,8 +183,83 @@ int main(void)
fprintf(stderr, "Invalid request type\n"); fprintf(stderr, "Invalid request type\n");
break; break;
} }
}
return NULL;
}
// Stop the server as the server int main(void)
{
// Connect and bind to a port (8080) on the server
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd == -1)
{
fprintf(stderr, "Socket creation failed\n");
return 1;
}
struct sockaddr_in servaddr;
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(8080);
servaddr.sin_addr.s_addr = inet_addr(SERVER_IP);
if (bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) != 0)
{
fprintf(stderr, "Socket bind failed\n");
close(sockfd);
return 1;
}
if (listen(sockfd, 5) != 0)
{
fprintf(stderr, "Listen failed\n");
close(sockfd);
return 1;
}
printf("Server listening on %s:8080\n", SERVER_IP);
struct sockaddr_in cli;
u_int32_t len = sizeof(cli);
Request req;
memset(&req, 0, sizeof(req));
req.ID = 0;
req.level = 0;
req.type = 0;
u_int8_t isConnected = 0;
int connfd;
/*
* WE NEED TO IMPLEMENT A WAY TO HANDLE MULTIPLE CLIENTS
* AND MAKE IT SABLE (RIGHT NOW IT CRASHES EVERY TIME A CLIENT DISCONNECTS)
*
* ALSO MAKE A BETTER WAY OF STOPPING THE SERVER
*
* TODO:
* -1 Fix the chashing issues --DONE
* -2 Implement a way to stop the server
* -3 Implement a way to handle multiple clients --TESTING
*/
// Listen to the client requests
while (1)
{
int *connfd = malloc(sizeof(int));
*connfd = accept(sockfd, (struct sockaddr *)&cli, &len);
if (*connfd < 0)
{
fprintf(stderr, "Server accept failed\n");
free(connfd);
continue;
}
printf("Client connected\n");
pthread_t tid;
pthread_create(&tid, NULL, handle_client, connfd);
pthread_detach(tid);
} }
// Close the socket // Close the socket