| 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; +} | 


