gio/tests/socket-server.c

   1 #include <gio/gio.h>
   2 #include <gio/gunixsocketaddress.h>
   3 #include <glib.h>
   4 #include <stdlib.h>
   5 #include <string.h>
   6
   7 GMainLoop *loop;
   8
   9 int port = 7777;
  10 gboolean verbose = FALSE;
  11 gboolean dont_reuse_address = FALSE;
  12 gboolean non_blocking = FALSE;
  13 gboolean use_udp = FALSE;
  14 int cancel_timeout = 0;
  15 int read_timeout = 0;
  16 int delay = 0;
  17 gboolean unix_socket = FALSE;
  18 const char *tls_cert_file = NULL;
  19
  20 static GOptionEntry cmd_entries[] = {
  21   {"port", 'p', 0, G_OPTION_ARG_INT, &port,
  22    "Local port to bind to", NULL},
  23   {"cancel", 'c', 0, G_OPTION_ARG_INT, &cancel_timeout,
  24    "Cancel any op after the specified amount of seconds", NULL},
  25   {"udp", 'u', 0, G_OPTION_ARG_NONE, &use_udp,
  26    "Use udp instead of tcp", NULL},
  27   {"verbose", 'v', 0, G_OPTION_ARG_NONE, &verbose,
  28    "Be verbose", NULL},
  29   {"no-reuse", 0, 0, G_OPTION_ARG_NONE, &dont_reuse_address,
  30    "Don't SOADDRREUSE", NULL},
  31   {"non-blocking", 'n', 0, G_OPTION_ARG_NONE, &non_blocking,
  32    "Enable non-blocking i/o", NULL},
  33 #ifdef G_OS_UNIX
  34   {"unix", 'U', 0, G_OPTION_ARG_NONE, &unix_socket,
  35    "Use a unix socket instead of IP", NULL},
  36 #endif
  37   {"delay", 'd', 0, G_OPTION_ARG_INT, &delay,
  38    "Delay responses by the specified number of seconds", NULL},
  39   {"timeout", 't', 0, G_OPTION_ARG_INT, &read_timeout,
  40    "Time out reads after the specified number of seconds", NULL},
  41   {"tls", 'T', 0, G_OPTION_ARG_STRING, &tls_cert_file,
  42    "Use TLS (SSL) with indicated server certificate", "CERTFILE"},
  43   {NULL}
  44 };
  45
  46 #include "socket-common.c"
  47
  48 int
  49 main (int argc,
  50       char *argv[])
  51 {
  52   GSocket *socket, *new_socket, *recv_socket;
  53   GSocketAddress *src_address;
  54   GSocketAddress *address;
  55   GSocketType socket_type;
  56   GSocketFamily socket_family;
  57   GError *error = NULL;
  58   GOptionContext *context;
  59   GCancellable *cancellable;
  60   char *display_addr;
  61   GTlsCertificate *tlscert = NULL;
  62   GIOStream *connection;
  63   GInputStream *istream;
  64   GOutputStream *ostream;
  65
  66   context = g_option_context_new (" - Test GSocket server stuff");
  67   g_option_context_add_main_entries (context, cmd_entries, NULL);
  68   if (!g_option_context_parse (context, &argc, &argv, &error))
  69     {
  70       g_printerr ("%s: %s\n", argv[0], error->message);
  71       return 1;
  72     }
  73
  74   if (unix_socket && argc != 2)
  75     {
  76       g_printerr ("%s: %s\n", argv[0], "Need to specify unix socket name");
  77       return 1;
  78     }
  79
  80   if (cancel_timeout)
  81     {
  82       GThread *thread;
  83       cancellable = g_cancellable_new ();
  84       thread = g_thread_new ("cancel", cancel_thread, cancellable);
  85       g_thread_unref (thread);
  86     }
  87   else
  88     {
  89       cancellable = NULL;
  90     }
  91
  92   if (tls_cert_file)
  93     {
  94       if (use_udp)
  95         {
  96           g_printerr ("DTLS (TLS over UDP) is not supported");
  97           return 1;
  98         }
  99
 100       tlscert = g_tls_certificate_new_from_file (tls_cert_file, &error);
 101       if (!tlscert)
 102         {
 103           g_printerr ("Could not read server certificate '%s': %s\n",
 104                       tls_cert_file, error->message);
 105           return 1;
 106         }
 107     }
 108
 109   loop = g_main_loop_new (NULL, FALSE);
 110
 111   if (use_udp)
 112     socket_type = G_SOCKET_TYPE_DATAGRAM;
 113   else
 114     socket_type = G_SOCKET_TYPE_STREAM;
 115
 116   if (unix_socket)
 117     socket_family = G_SOCKET_FAMILY_UNIX;
 118   else
 119     socket_family = G_SOCKET_FAMILY_IPV4;
 120
 121   socket = g_socket_new (socket_family, socket_type, 0, &error);
 122
 123   if (socket == NULL)
 124     {
 125       g_printerr ("%s: %s\n", argv[0], error->message);
 126       return 1;
 127     }
 128
 129   if (non_blocking)
 130     g_socket_set_blocking (socket, FALSE);
 131
 132   if (unix_socket)
 133     {
 134       src_address = socket_address_from_string (argv[1]);
 135       if (src_address == NULL)
 136         {
 137           g_printerr ("%s: Could not parse '%s' as unix socket name\n", argv[0], argv[1]);
 138           return 1;
 139         }
 140     }
 141   else
 142     {
 143       src_address = g_inet_socket_address_new (g_inet_address_new_any (G_SOCKET_FAMILY_IPV4), port);
 144     }
 145
 146   if (!g_socket_bind (socket, src_address, !dont_reuse_address, &error))
 147     {
 148       g_printerr ("Can't bind socket: %s\n", error->message);
 149       return 1;
 150     }
 151   g_object_unref (src_address);
 152
 153   if (!use_udp)
 154     {
 155       if (!g_socket_listen (socket, &error))
 156         {
 157           g_printerr ("Can't listen on socket: %s\n", error->message);
 158           return 1;
 159         }
 160
 161       address = g_socket_get_local_address (socket, &error);
 162       if (!address)
 163         {
 164           g_printerr ("Error getting local address: %s\n",
 165                       error->message);
 166           return 1;
 167         }
 168       display_addr = socket_address_to_string (address);
 169       g_print ("listening on %s...\n", display_addr);
 170       g_free (display_addr);
 171
 172       ensure_socket_condition (socket, G_IO_IN, cancellable);
 173       new_socket = g_socket_accept (socket, cancellable, &error);
 174       if (!new_socket)
 175         {
 176           g_printerr ("Error accepting socket: %s\n",
 177                       error->message);
 178           return 1;
 179         }
 180
 181       if (non_blocking)
 182         g_socket_set_blocking (new_socket, FALSE);
 183       if (read_timeout)
 184         g_socket_set_timeout (new_socket, read_timeout);
 185
 186       address = g_socket_get_remote_address (new_socket, &error);
 187       if (!address)
 188         {
 189           g_printerr ("Error getting remote address: %s\n",
 190                       error->message);
 191           return 1;
 192         }
 193
 194       display_addr = socket_address_to_string (address);
 195       g_print ("got a new connection from %s\n", display_addr);
 196       g_free(display_addr);
 197       g_object_unref (address);
 198
 199       recv_socket = new_socket;
 200
 201       connection = G_IO_STREAM (g_socket_connection_factory_create_connection (recv_socket));
 202       g_object_unref (new_socket);
 203     }
 204   else
 205     {
 206       recv_socket = socket;
 207       connection = NULL;
 208     }
 209
 210   if (tlscert)
 211     {
 212       GIOStream *tls_conn;
 213
 214       tls_conn = g_tls_server_connection_new (connection, tlscert, &error);
 215       if (!tls_conn)
 216         {
 217           g_printerr ("Could not create TLS connection: %s\n",
 218                       error->message);
 219           return 1;
 220         }
 221
 222       if (!g_tls_connection_handshake (G_TLS_CONNECTION (tls_conn),
 223                                        cancellable, &error))
 224         {
 225           g_printerr ("Error during TLS handshake: %s\n",
 226                       error->message);
 227           return 1;
 228        }
 229
 230       g_object_unref (connection);
 231       connection = tls_conn;
 232     }
 233
 234   if (connection)
 235     {
 236       istream = g_io_stream_get_input_stream (connection);
 237       ostream = g_io_stream_get_output_stream (connection);
 238     }
 239   else
 240     {
 241       g_assert (use_udp);
 242       istream = NULL;
 243       ostream = NULL;
 244     }
 245
 246   while (TRUE)
 247     {
 248       gchar buffer[4096];
 249       gssize size;
 250       gsize to_send;
 251
 252       if (use_udp)
 253         {
 254           ensure_socket_condition (recv_socket, G_IO_IN, cancellable);
 255           size = g_socket_receive_from (recv_socket, &address,
 256                                         buffer, sizeof buffer,
 257                                         cancellable, &error);
 258         }
 259       else
 260         {
 261           ensure_connection_condition (connection, G_IO_IN, cancellable);
 262           size = g_input_stream_read (istream,
 263                                       buffer, sizeof buffer,
 264                                       cancellable, &error);
 265         }
 266
 267       if (size < 0)
 268         {
 269           g_printerr ("Error receiving from socket: %s\n",
 270                       error->message);
 271           return 1;
 272         }
 273
 274       if (size == 0)
 275         break;
 276
 277       g_print ("received %" G_GSSIZE_FORMAT " bytes of data", size);
 278       if (use_udp)
 279         g_print (" from %s", socket_address_to_string (address));
 280       g_print ("\n");
 281
 282       if (verbose)
 283         g_print ("-------------------------\n"
 284                  "%.*s\n"
 285                  "-------------------------\n",
 286                  (int)size, buffer);
 287
 288       to_send = size;
 289
 290       if (delay)
 291         {
 292           if (verbose)
 293             g_print ("delaying %d seconds before response\n", delay);
 294           g_usleep (1000 * 1000 * delay);
 295         }
 296
 297       while (to_send > 0)
 298         {
 299           if (use_udp)
 300             {
 301               ensure_socket_condition (recv_socket, G_IO_OUT, cancellable);
 302               size = g_socket_send_to (recv_socket, address,
 303                                        buffer, to_send, cancellable, &error);
 304             }
 305           else
 306             {
 307               ensure_connection_condition (connection, G_IO_OUT, cancellable);
 308               size = g_output_stream_write (ostream,
 309                                             buffer, to_send,
 310                                             cancellable, &error);
 311             }
 312
 313           if (size < 0)
 314             {
 315               if (g_error_matches (error,
 316                                    G_IO_ERROR,
 317                                    G_IO_ERROR_WOULD_BLOCK))
 318                 {
 319                   g_print ("socket send would block, handling\n");
 320                   g_error_free (error);
 321                   error = NULL;
 322                   continue;
 323                 }
 324               else
 325                 {
 326                   g_printerr ("Error sending to socket: %s\n",
 327                               error->message);
 328                   return 1;
 329                 }
 330             }
 331
 332           g_print ("sent %" G_GSSIZE_FORMAT " bytes of data\n", size);
 333
 334           if (size == 0)
 335             {
 336               g_printerr ("Unexpected short write\n");
 337               return 1;
 338             }
 339
 340           to_send -= size;
 341         }
 342     }
 343
 344   g_print ("connection closed\n");
 345
 346   if (connection)
 347     {
 348       if (!g_io_stream_close (connection, NULL, &error))
 349         {
 350           g_printerr ("Error closing connection stream: %s\n",
 351                       error->message);
 352           return 1;
 353         }
 354       g_object_unref (connection);
 355     }
 356
 357   if (!g_socket_close (socket, &error))
 358     {
 359       g_printerr ("Error closing master socket: %s\n",
 360                   error->message);
 361       return 1;
 362     }
 363   g_object_unref (socket);
 364
 365   return 0;
 366 }