| summaryrefslogtreecommitdiff |
diff options
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/communication_thread.c | 3 | ||||
| -rw-r--r-- | src/server/handle_client.c | 87 |
2 files changed, 88 insertions, 2 deletions
diff --git a/src/server/communication_thread.c b/src/server/communication_thread.c index 0f367da..cc91065 100644 --- a/src/server/communication_thread.c +++ b/src/server/communication_thread.c @@ -9,7 +9,6 @@ /******************************************************************************/ /**** LOCAL FUNCTIONS *********************************************************/ /******************************************************************************/ - static void main_loop (struct relabsd_server server [const static 1]) { int communication_socket, current_client_socket; @@ -87,7 +86,7 @@ static void main_loop (struct relabsd_server server [const static 1]) return -1; } - (void) handle_client(current_client_socket, server); + (void) relabsd_server_handle_client(current_client_socket, server); } } diff --git a/src/server/handle_client.c b/src/server/handle_client.c new file mode 100644 index 0000000..696725b --- /dev/null +++ b/src/server/handle_client.c @@ -0,0 +1,87 @@ +/**** POSIX *******************************************************************/ +/* + * To get the POSIX 'getline' function. + * We don't know what POSIX version is set by default. + */ +#define _POSIX_C_SOURCE 200809L + +#include <errno.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> + +/**** RELABSD *****************************************************************/ +#include <relabsd/debug.h> +#include <relabsd/server.h> + +/******************************************************************************/ +/**** LOCAL FUNCTIONS *********************************************************/ +/******************************************************************************/ +static void handle_input +( + const ssize_t input_size, + const char input [const static 1], + struct relabsd_server server [const static 1] +) +{ +} + +/******************************************************************************/ +/**** EXPORTED FUNCTIONS ******************************************************/ +/******************************************************************************/ +int relabsd_server_handle_client +( + const int socket, + struct relabsd_server server [const static 1] +) +{ + FILE * socket_as_file; + /* FIXME: reallocating at every new connection is kind of wasteful. */ + char * input; + ssize_t input_size; + + errno = 0; + socket_as_file = fdopen(socket, "r"); + + if (socket_as_file == ((FILE *) NULL)) + { + RELABSD_ERROR + ( + "Unable to open client socket as a FILE: %s.", + strerror(errno) + ); + + (void) close(socket); + + return -1; + } + + errno = 0; + + input_size = getline(&input, (size_t *) NULL, socket_as_file); + + if (input_size < 1) + { + RELABSD_ERROR + ( + "Unable to read line from client socket: %s.", + strerror(errno) + ); + + (void) free((void *) input); + + /* This also closes 'socket' */ + (void) fclose(socket_as_file); + + return -1; + } + + handle_input(input_size, input, server); + + (void) free((void *) input); + + /* This also closes 'socket' */ + (void) fclose(socket_as_file); + + return 0; +} |


