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 <sys/socket.h>
   7 #include <errno.h>
   8
   9 GMainLoop *loop;
  10
  11 void accept_callback (GSocket *socket, GAsyncResult *result, gpointer data);
  12
  13 /*
  14 gboolean
  15 accept_source (gpointer data)
  16 {
  17         GSocket *socket = G_SOCKET (data);
  18
  19         g_print ("in source\n");
  20
  21         g_socket_accept_async (socket, NULL, (GAsyncReadyCallback) accept_callback, NULL);
  22
  23         return FALSE;
  24 }
  25
  26 void
  27 accept_callback (GSocket *socket, GAsyncResult *result, gpointer data)
  28 {
  29         GSocket *new_socket;
  30         GSocketAddress *address;
  31         GError *error = NULL;
  32
  33         g_print ("in callback\n");
  34
  35         new_socket = g_socket_accept_finish (socket, result, &error);
  36
  37         if (!new_socket)
  38                 g_error (error->message);
  39
  40         address = g_socket_get_remote_address (new_socket, &error);
  41
  42         if (!address)
  43                 g_error (error->message);
  44
  45         g_print ("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)));
  46
  47         g_idle_add (accept_source, (gpointer) socket);
  48 }
  49 */
  50
  51 int main (int argc, char *argv[])
  52 {
  53         GSocket *socket, *new_socket;
  54         GSocketAddress *address;
  55         GError *error = NULL;
  56
  57         g_thread_init (NULL);
  58
  59         g_type_init ();
  60
  61         loop = g_main_loop_new (NULL, FALSE);
  62
  63         socket = g_socket_new (G_SOCKET_DOMAIN_INET, G_SOCKET_TYPE_STREAM, NULL);
  64
  65         g_socket_set_reuse_address (socket, TRUE);
  66
  67         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)) {
  68                 g_error (error->message);
  69                 return 0;
  70         }
  71
  72         if (!g_socket_listen (socket, &error)) {
  73                 g_error (error->message);
  74                 return 0;
  75         }
  76
  77         g_print ("listening on port 31882...\n");
  78
  79         new_socket = g_socket_accept (socket, &error);
  80
  81         if (!new_socket) {
  82                 g_error (error->message);
  83                 return 0;
  84         }
  85
  86         address = g_socket_get_remote_address (new_socket, &error);
  87
  88         if (!address) {
  89                 g_error (error->message);
  90                 return 0;
  91         }
  92
  93         g_print ("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)));
  94
  95         while (TRUE) {
  96                 gchar buffer[128] = { };
  97                 gssize size;
  98
  99                 if ((size = g_socket_receive (new_socket, buffer, 128, &error)) < 0) {
 100                         g_error (error->message);
 101                         return 0;
 102                 }
 103
 104                 if (size == 0)
 105                         break;
 106
 107                 g_print ("received %" G_GSSIZE_FORMAT " bytes of data: %s\n", size, buffer);
 108
 109                 if ((size = g_socket_send (new_socket, buffer, size, &error)) < 0) {
 110                         g_error (error->message);
 111                         return 0;
 112                 }
 113
 114                 if (size == 0)
 115                         break;
 116         }
 117
 118         g_print ("connection closed\n");
 119
 120         g_object_unref (G_OBJECT (new_socket));
 121
 122         g_socket_close (socket);
 123
 124         g_object_unref (G_OBJECT (socket));
 125
 126         return 0;
 127 }