src/server/server.c


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

#include <signal.h>
#include <stdio.h>

#include "../parameters/parameters.h"

#include "server.h"

volatile char ZoO_SERVER_IS_RUNNING = (char) 1;

static void request_termination (int const signo)
{
   if ((signo == SIGINT) || (signo == SIGTERM))
   {
      ZoO_SERVER_IS_RUNNING = (char) 0;
   }
}

int ZoO_server_main (const struct ZoO_parameters params)
{
   struct ZoO_server server;
   struct ZoO_server_message msg_buffer;
   struct ZoO_server_worker_parameters worker_params;

   if
   (
      ZoO_server_initialize
      (
         &server,
         ZoO_parameters_get_session_name(&params)
      ) < 0
   )
   {
      return -1;
   }

   ZoO_server_worker_initialize_parameters
   (
      &worker_params,
      &server,
      &msg_buffer,
      &params
   );

   while ((ZoO_SERVER_IS_RUNNING == (char) 1) || (server.running_threads > 0))
   {
      if (ZoO_server_receive_message(&server, &msg_buffer) < 0)
      {
         ZoO_server_no_mq_termination(&server);

         break;
      }

      switch (msg_buffer.type)
      {
         case 'C': /* Client request */
            ZoO_server_add_worker(&server, &worker_params);
            break;

         case 'J': /* Join request */
            ZoO_server_finalize_worker(&server, &msg_buffer);
            break;

         default:
            fprintf
            (
               stderr,
               "[W] Received message with unknown type '%c'.\n",
               msg_buffer.type
            );
            break;
      }
   }

   ZoO_server_finalize(&server);

   return 0;
}