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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

/**** RELABSD *****************************************************************/
#include <relabsd/config.h>
#include <relabsd/debug.h>
#include <relabsd/server.h>

#include <relabsd/config/parameters.h>

#include <relabsd/device/physical_device.h>
#include <relabsd/device/virtual_device.h>

/******************************************************************************/
/**** LOCAL FUNCTIONS *********************************************************/
/******************************************************************************/
static int initialize
(
   struct relabsd_server server [const restrict static 1]
)
{
   if
   (
      relabsd_physical_device_open
      (
         relabsd_parameters_get_physical_device_file_name
         (
            &(server->parameters)
         ),
         &(server->physical_device)
      )
      < 0
   )
   {
      return -1;
   }

   if
   (
      relabsd_virtual_device_create_from
      (
         &(server->parameters),
         &(server->virtual_device)
      )
      < 0
   )
   {
      relabsd_physical_device_close(&(server->physical_device));

      return -2;
   }

   if
   (
      (
         relabsd_parameters_get_communication_node_name(&(server->parameters))
         != ((char *) NULL)
      )
      && (relabsd_server_create_communication_thread(server) < 0)
   )
   {
      relabsd_virtual_device_destroy(&(server->virtual_device));
      relabsd_physical_device_close(&(server->physical_device));

      return -3;
   }

   return 0;
}

static void finalize (struct relabsd_server server [const static 1])
{
   if
   (
      relabsd_parameters_get_communication_node_name(&(server->parameters))
      != ((char *) NULL)
   )
   {
      relabsd_server_join_communication_thread(server);
   }

   relabsd_virtual_device_destroy(&(server->virtual_device));
   relabsd_physical_device_close(&(server->physical_device));
}

/******************************************************************************/
/**** EXPORTED FUNCTIONS ******************************************************/
/******************************************************************************/
int relabsd_server_main
(
   const int argc,
   const char * const argv [const static argc],
   struct relabsd_parameters parameters [const restrict static 1]
)
{
   struct relabsd_server server;

   server.parameters = *parameters;

   RELABSD_S_DEBUG(RELABSD_DEBUG_PROGRAM_FLOW, "Started server mode.");

   if (relabsd_parameters_parse_options(argc, argv, &(server.parameters)) < 0)
   {
      return -1;
   }

   if
   (
      relabsd_parameters_get_run_as_daemon(&(server.parameters))
      && (relabsd_server_create_daemon() < 0)
   )
   {
      return -2;
   }

   (void) initialize(&server);

   (void) relabsd_server_conversion_loop(&server);

   finalize(&server);

   RELABSD_S_DEBUG(RELABSD_DEBUG_PROGRAM_FLOW, "Completed server mode.");

   return 0;
}