test/test-server.c

   1 #include <gio/gio.h>
   2 #include <gnio/gsocket.h>
   3 #include <gnio/ginetsocketaddress.h>
   4 #include <gnio/ginet4address.h>
   5 #include <glib.h>
   6 #include <glib/gprintf.h>
   7 #include <sys/socket.h>
   8
   9 GMainLoop *loop;
  10
  11 void accept_callback (GSocket *socket, GAsyncResult *result, gpointer data);
  12
  13 gboolean
  14 accept_source (gpointer data)
  15 {
  16         GSocket *socket = G_SOCKET (data);
  17
  18         g_print ("in source\n");
  19
  20         g_socket_accept_async (socket, NULL, (GAsyncReadyCallback) accept_callback, NULL);
  21
  22         return FALSE;
  23 }
  24
  25 void
  26 accept_callback (GSocket *socket, GAsyncResult *result, gpointer data)
  27 {
  28         GSocket *new_socket;
  29         GSocketAddress *address;
  30         GError *error = NULL;
  31
  32         g_print ("in callback\n");
  33
  34         new_socket = g_socket_accept_finish (socket, result, &error);
  35
  36         if (!new_socket)
  37                 g_error (error->message);
  38
  39         address = g_socket_get_peer_address (new_socket, &error);
  40
  41         if (!address)
  42                 g_error (error->message);
  43
  44         g_printf ("got a new connection from %s:%d\n", g_inet_address_to_string (g_inet_socket_address_get_address (G_INET_SOCKET_ADDRESS (address))), g_inet_socket_address_get_port (G_INET_SOCKET_ADDRESS (address)));
  45
  46         g_idle_add (accept_source, (gpointer) socket);
  47 }
  48
  49 int main (int argc, char *argv[])
  50 {
  51         GSocket *socket;
  52         GError *error = NULL;
  53
  54         g_thread_init (NULL);
  55
  56         g_type_init ();
  57
  58         loop = g_main_loop_new (NULL, FALSE);
  59
  60         socket = g_socket_new (G_SOCKET_DOMAIN_INET, G_SOCKET_TYPE_STREAM, NULL, NULL);
  61
  62         if (!g_socket_bind (socket, G_SOCKET_ADDRESS (g_inet_socket_address_new (G_INET_ADDRESS (g_inet4_address_from_string ("127.0.0.1")), 31882)), &error))
  63                 g_error (error->message);
  64
  65         g_socket_listen (socket, 10);
  66
  67         g_printf ("listening on port 31882...\n");
  68
  69         g_idle_add (accept_source, (gpointer) socket);
  70
  71         g_main_loop_run (loop);
  72
  73         return 0;
  74 }