socket.c

   1 /*-*- Mode: C; c-basic-offset: 8 -*-*/
   2
   3 #include "name.h"
   4 #include "socket.h"
   5
   6 static int socket_load(Name *n) {
   7         Socket *s = SOCKET(n);
   8
   9         exec_context_defaults(&s->exec_context);
  10         s->backlog = SOMAXCONN;
  11
  12         return name_load_fragment_and_dropin(n);
  13 }
  14
  15 static const char* listen_lookup(int type) {
  16
  17         if (type == SOCK_STREAM)
  18                 return "ListenStream";
  19         else if (type == SOCK_DGRAM)
  20                 return "ListenDatagram";
  21         else if (type == SOCK_SEQPACKET)
  22                 return "ListenSequentialPacket";
  23
  24         assert_not_reached("Unkown socket type");
  25         return NULL;
  26 }
  27
  28 static void socket_dump(Name *n, FILE *f, const char *prefix) {
  29
  30         static const char* const state_table[_SOCKET_STATE_MAX] = {
  31                 [SOCKET_DEAD] = "dead",
  32                 [SOCKET_START_PRE] = "start-pre",
  33                 [SOCKET_START_POST] = "start-post",
  34                 [SOCKET_LISTENING] = "listening",
  35                 [SOCKET_RUNNING] = "running",
  36                 [SOCKET_STOP_PRE] = "stop-pre",
  37                 [SOCKET_STOP_POST] = "stop-post",
  38                 [SOCKET_MAINTAINANCE] = "maintainance"
  39         };
  40
  41         static const char* const command_table[_SOCKET_EXEC_MAX] = {
  42                 [SOCKET_EXEC_START_PRE] = "StartPre",
  43                 [SOCKET_EXEC_START_POST] = "StartPost",
  44                 [SOCKET_EXEC_STOP_PRE] = "StopPre",
  45                 [SOCKET_EXEC_STOP_POST] = "StopPost"
  46         };
  47
  48         SocketExecCommand c;
  49         Socket *s = SOCKET(n);
  50         SocketPort *p;
  51
  52         assert(s);
  53
  54         fprintf(f,
  55                 "%sSocket State: %s\n"
  56                 "%sBindIPv6Only: %s\n"
  57                 "%sBacklog: %u\n",
  58                 prefix, state_table[s->state],
  59                 prefix, yes_no(s->bind_ipv6_only),
  60                 prefix, s->backlog);
  61
  62         LIST_FOREACH(p, s->ports) {
  63
  64                 if (p->type == SOCKET_SOCKET) {
  65                         const char *t;
  66                         int r;
  67                         char *k;
  68
  69                         if ((r = socket_address_print(&p->address, &k)) < 0)
  70                                 t = strerror(-r);
  71                         else
  72                                 t = k;
  73
  74                         fprintf(f, "%s%s: %s\n", prefix, listen_lookup(p->address.type), k);
  75                         free(k);
  76                 } else
  77                         fprintf(f, "%sListenFIFO: %s\n", prefix, p->path);
  78         }
  79
  80         exec_context_dump(&s->exec_context, f, prefix);
  81
  82         for (c = 0; c < _SOCKET_EXEC_MAX; c++) {
  83                 ExecCommand *i;
  84
  85                 LIST_FOREACH(i, s->exec_command[c])
  86                         fprintf(f, "%s%s: %s\n", prefix, command_table[c], i->path);
  87         }
  88 }
  89
  90 static int socket_start(Name *n) {
  91         return 0;
  92 }
  93
  94 static int socket_stop(Name *n) {
  95         return 0;
  96 }
  97
  98 static NameActiveState socket_active_state(Name *n) {
  99
 100         static const NameActiveState table[_SOCKET_STATE_MAX] = {
 101                 [SOCKET_DEAD] = NAME_INACTIVE,
 102                 [SOCKET_START_PRE] = NAME_ACTIVATING,
 103                 [SOCKET_START_POST] = NAME_ACTIVATING,
 104                 [SOCKET_LISTENING] = NAME_ACTIVE,
 105                 [SOCKET_RUNNING] = NAME_ACTIVE,
 106                 [SOCKET_STOP_PRE] = NAME_DEACTIVATING,
 107                 [SOCKET_STOP_POST] = NAME_DEACTIVATING,
 108                 [SOCKET_MAINTAINANCE] = NAME_INACTIVE,
 109         };
 110
 111         return table[SOCKET(n)->state];
 112 }
 113
 114 static void socket_free_hook(Name *n) {
 115         SocketExecCommand c;
 116         Socket *s = SOCKET(n);
 117         SocketPort *p;
 118
 119         assert(s);
 120
 121         while ((p = s->ports)) {
 122                 LIST_REMOVE(SocketPort, s->ports, p);
 123
 124                 if (p->fd >= 0)
 125                         close_nointr(p->fd);
 126                 free(p->path);
 127                 free(p);
 128         }
 129
 130         exec_context_free(&s->exec_context);
 131
 132         for (c = 0; c < _SOCKET_EXEC_MAX; c++)
 133                 exec_command_free_list(s->exec_command[c]);
 134
 135         if (s->service)
 136                 s->service->socket = NULL;
 137 }
 138
 139 const NameVTable socket_vtable = {
 140         .suffix = ".socket",
 141
 142         .load = socket_load,
 143         .dump = socket_dump,
 144
 145         .start = socket_start,
 146         .stop = socket_stop,
 147         .reload = NULL,
 148
 149         .active_state = socket_active_state,
 150
 151         .free_hook = socket_free_hook
 152 };