Move test/gio-test.c to glib/test/io-channel-basic.c

Helps issue #1434

2 files changed, 0 insertions, 426 deletions

diff --git a/tests/gio-test.c b/tests/gio-test.c
deleted file mode 100644
index e26ebdb3d..000000000
--- a/tests/gio-test.c
+++ /dev/null
@@ -1,425 +0,0 @@
-/* GLIB - Library of useful routines for C programming
- * Copyright (C) 2000  Tor Lillqvist
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2.1 of the License, or (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, see <http://www.gnu.org/licenses/>.
- */
-
-/* A test program for the main loop and IO channel code.
- * Just run it. Optional parameter is number of sub-processes.
- */
-
-#include "config.h"
-
-#include <glib.h>
-
-#include <stdio.h>
-
-#ifdef G_OS_WIN32
-  #include <io.h>
-  #include <fcntl.h>
-  #include <process.h>
-  #define STRICT
-  #include <windows.h>
-  #define pipe(fds) _pipe(fds, 4096, _O_BINARY)
-#endif
-
-#ifdef G_OS_UNIX
-  #include <unistd.h>
-#endif
-
-static int nrunning;
-static GMainLoop *main_loop;
-
-/* Larger than the circular buffer in giowin32.c on purpose */
-#define BUFSIZE 5000
-
-static int nkiddies;
-static char *exec_name;
-
-static struct {
-  int fd;
-  int seq;
-} *seqtab;
-
-static GIOError
-read_all (int         fd,
-          GIOChannel *channel,
-          char       *buffer,
-          guint       nbytes,
-          guint      *bytes_read)
-{
-  guint left = nbytes;
-  gsize nb;
-  GIOError error = G_IO_ERROR_NONE;
-  char *bufp = buffer;
-
-  /* g_io_channel_read() doesn't necessarily return all the
-   * data we want at once.
-   */
-  *bytes_read = 0;
-  while (left)
-    {
-      error = g_io_channel_read (channel, bufp, left, &nb);
-
-      if (error != G_IO_ERROR_NONE)
-        {
-          g_print ("gio-test: ...from %d: %d\n", fd, error);
-          if (error == G_IO_ERROR_AGAIN)
-            continue;
-          break;
-        }
-      if (nb == 0)
-        return error;
-      left -= nb;
-      bufp += nb;
-      *bytes_read += nb;
-    }
-  return error;
-}
-
-static void
-shutdown_source (gpointer data)
-{
-  if (g_source_remove (*(guint *) data))
-    {
-      nrunning--;
-      if (nrunning == 0)
-        g_main_loop_quit (main_loop);
-    }
-}
-
-static gboolean
-recv_message (GIOChannel  *channel,
-              GIOCondition cond,
-              gpointer    data)
-{
-  gint fd = g_io_channel_unix_get_fd (channel);
-  gboolean retval = TRUE;
-
-  g_debug ("gio-test: ...from %d:%s%s%s%s", fd,
-           (cond & G_IO_ERR) ? " ERR" : "",
-           (cond & G_IO_HUP) ? " HUP" : "",
-           (cond & G_IO_IN)  ? " IN"  : "",
-           (cond & G_IO_PRI) ? " PRI" : "");
-
-  if (cond & (G_IO_ERR | G_IO_HUP))
-    {
-      shutdown_source (data);
-      retval = FALSE;
-    }
-
-  if (cond & G_IO_IN)
-    {
-      char buf[BUFSIZE];
-      guint nbytes = 0;
-      guint nb;
-      guint j;
-      int i, seq;
-      GIOError error;
-
-      error = read_all (fd, channel, (gchar *) &seq, sizeof (seq), &nb);
-      if (error == G_IO_ERROR_NONE)
-        {
-          if (nb == 0)
-            {
-              g_debug ("gio-test: ...from %d: EOF", fd);
-              shutdown_source (data);
-              return FALSE;
-            }
-          g_assert_cmpuint (nb, ==, sizeof (nbytes));
-
-          for (i = 0; i < nkiddies; i++)
-            if (seqtab[i].fd == fd)
-              {
-                g_assert_cmpint (seq, ==, seqtab[i].seq);
-                seqtab[i].seq++;
-                break;
-              }
-
-          error =
-            read_all (fd, channel, (gchar *) &nbytes, sizeof (nbytes), &nb);
-        }
-
-      if (error != G_IO_ERROR_NONE)
-        return FALSE;
-
-      if (nb == 0)
-        {
-          g_debug ("gio-test: ...from %d: EOF", fd);
-          shutdown_source (data);
-          return FALSE;
-        }
-      g_assert_cmpuint (nb, ==, sizeof (nbytes));
-
-      g_assert_cmpuint (nbytes, <, BUFSIZE);
-      g_debug ("gio-test: ...from %d: %d bytes", fd, nbytes);
-      if (nbytes > 0)
-        {
-          error = read_all (fd, channel, buf, nbytes, &nb);
-
-          if (error != G_IO_ERROR_NONE)
-            return FALSE;
-
-          if (nb == 0)
-            {
-              g_debug ("gio-test: ...from %d: EOF", fd);
-              shutdown_source (data);
-              return FALSE;
-            }
-
-          for (j = 0; j < nbytes; j++)
-            g_assert_cmpint (buf[j], ==, ' ' + (char) ((nbytes + j) % 95));
-          g_debug ("gio-test: ...from %d: OK", fd);
-        }
-    }
-  return retval;
-}
-
-#ifdef G_OS_WIN32
-static gboolean
-recv_windows_message (GIOChannel  *channel,
-                      GIOCondition cond,
-                      gpointer    data)
-{
-  GIOError error;
-  MSG msg;
-  gsize nb;
-
-  while (1)
-    {
-      error = g_io_channel_read (channel, (gchar *) &msg, sizeof (MSG), &nb);
-
-      if (error != G_IO_ERROR_NONE)
-        {
-          g_print ("gio-test: ...reading Windows message: G_IO_ERROR_%s\n",
-                   (error == G_IO_ERROR_AGAIN ? "AGAIN" :
-                    (error == G_IO_ERROR_INVAL ? "INVAL" :
-                     (error == G_IO_ERROR_UNKNOWN ? "UNKNOWN" : "???"))));
-          if (error == G_IO_ERROR_AGAIN)
-            continue;
-        }
-      break;
-    }
-
-  g_print ("gio-test: ...Windows message for 0x%p: %d,%" G_GUINTPTR_FORMAT ",%" G_GINTPTR_FORMAT "\n",
-           msg.hwnd, msg.message, msg.wParam, (gintptr) msg.lParam);
-
-  return TRUE;
-}
-
-LRESULT CALLBACK window_procedure (HWND   hwnd,
-                                   UINT   message,
-                                   WPARAM wparam,
-                                   LPARAM lparam);
-
-LRESULT CALLBACK
-window_procedure (HWND hwnd,
-                  UINT message,
-                  WPARAM wparam,
-                  LPARAM lparam)
-{
-  g_print ("gio-test: window_procedure for 0x%p: %d,%" G_GUINTPTR_FORMAT ",%" G_GINTPTR_FORMAT "\n",
-           hwnd, message, wparam, (gintptr) lparam);
-  return DefWindowProc (hwnd, message, wparam, lparam);
-}
-#endif
-
-static void
-spawn_process (int children_nb)
-{
-  GIOChannel *my_read_channel;
-  gchar *cmdline;
-  int i;
-
-#ifdef G_OS_WIN32
-  gint64 start, end;
-  GPollFD pollfd;
-  int pollresult;
-  ATOM klass;
-  static WNDCLASS wcl;
-  HWND hwnd;
-  GIOChannel *windows_messages_channel;
-
-  wcl.style = 0;
-  wcl.lpfnWndProc = window_procedure;
-  wcl.cbClsExtra = 0;
-  wcl.cbWndExtra = 0;
-  wcl.hInstance = GetModuleHandle (NULL);
-  wcl.hIcon = NULL;
-  wcl.hCursor = NULL;
-  wcl.hbrBackground = NULL;
-  wcl.lpszMenuName = NULL;
-  wcl.lpszClassName = "gio-test";
-
-  klass = RegisterClass (&wcl);
-
-  if (!klass)
-    {
-      g_print ("gio-test: RegisterClass failed\n");
-      exit (1);
-    }
-
-  hwnd = CreateWindow (MAKEINTATOM(klass), "gio-test", 0, 0, 0, 10, 10,
-                       NULL, NULL, wcl.hInstance, NULL);
-  if (!hwnd)
-    {
-      g_print ("gio-test: CreateWindow failed\n");
-      exit (1);
-    }
-
-  windows_messages_channel =
-    g_io_channel_win32_new_messages ((guint) (guintptr) hwnd);
-  g_io_add_watch (windows_messages_channel, G_IO_IN, recv_windows_message, 0);
-#endif
-
-  nkiddies = (children_nb > 0 ? children_nb : 1);
-  seqtab = g_malloc (nkiddies * 2 * sizeof (int));
-
-  for (i = 0; i < nkiddies; i++)
-    {
-      guint *id;
-      int pipe_to_sub[2], pipe_from_sub[2];
-
-      if (pipe (pipe_to_sub) == -1 || pipe (pipe_from_sub) == -1)
-        {
-          perror ("pipe");
-          exit (1);
-        }
-
-      seqtab[i].fd = pipe_from_sub[0];
-      seqtab[i].seq = 0;
-
-      my_read_channel = g_io_channel_unix_new (pipe_from_sub[0]);
-
-      id = g_new (guint, 1);
-      *id = g_io_add_watch_full (my_read_channel,
-                                 G_PRIORITY_DEFAULT,
-                                 G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP,
-                                 recv_message,
-                                 id, g_free);
-      nrunning++;
-
-#ifdef G_OS_WIN32
-      /* Spawn new Win32 process */
-      cmdline =
-        g_strdup_printf ("%d:%d:0x%p", pipe_to_sub[0], pipe_from_sub[1], hwnd);
-      _spawnl (_P_NOWAIT, exec_name, exec_name, "--child", cmdline, NULL);
-#else
-      /* Spawn new Unix process */
-      cmdline = g_strdup_printf ("%s --child %d:%d &",
-                                 exec_name, pipe_to_sub[0], pipe_from_sub[1]);
-      system (cmdline);
-#endif
-      g_free (cmdline);
-
-      /* Closing pipes */
-      close (pipe_to_sub[0]);
-      close (pipe_from_sub[1]);
-
-#ifdef G_OS_WIN32
-      start = g_get_monotonic_time();
-      g_io_channel_win32_make_pollfd (my_read_channel, G_IO_IN, &pollfd);
-      pollresult = g_io_channel_win32_poll (&pollfd, 1, 100);
-      end = g_get_monotonic_time();
-
-      g_print ("gio-test: had to wait %" G_GINT64_FORMAT "s, result:%d\n",
-               (end - start) / 1000000, pollresult);
-#endif
-      g_io_channel_unref (my_read_channel);
-    }
-
-  main_loop = g_main_loop_new (NULL, FALSE);
-  g_main_loop_run (main_loop);
-
-  g_main_loop_unref (main_loop);
-  g_free (seqtab);
-}
-
-static void
-run_process (int argc, char *argv[])
-{
-  int readfd, writefd;
-  gint64 dt;
-  char buf[BUFSIZE];
-  int buflen, i, j, n;
-#ifdef G_OS_WIN32
-  HWND hwnd;
-#endif
-
-  /* Extract parameters */
-  sscanf (argv[2], "%d:%d%n", &readfd, &writefd, &n);
-#ifdef G_OS_WIN32
-  sscanf (argv[2] + n, ":0x%p", &hwnd);
-#endif
-
-  dt = g_get_monotonic_time();
-  srand (dt ^ (dt / 1000) ^ readfd ^ (writefd << 4));
-
-  for (i = 0; i < 20 + rand () % 10; i++)
-    {
-      g_usleep ((100 + rand () % 10) * 2500);
-      buflen = rand () % BUFSIZE;
-      for (j = 0; j < buflen; j++)
-        buf[j] = ' ' + ((buflen + j) % 95);
-      g_debug ("gio-test: child writing %d+%d bytes to %d",
-               (int) (sizeof (i) + sizeof (buflen)), buflen, writefd);
-      write (writefd, &i, sizeof (i));
-      write (writefd, &buflen, sizeof (buflen));
-      write (writefd, buf, buflen);
-
-#ifdef G_OS_WIN32
-      if (i % 10 == 0)
-        {
-          int msg = WM_USER + (rand () % 100);
-          WPARAM wparam = rand ();
-          LPARAM lparam = rand ();
-          g_print ("gio-test: child posting message %d,%" G_GUINTPTR_FORMAT ",%" G_GINTPTR_FORMAT " to 0x%p\n",
-                   msg, wparam, (gintptr) lparam, hwnd);
-          PostMessage (hwnd, msg, wparam, lparam);
-        }
-#endif
-    }
-  g_debug ("gio-test: child exiting, closing %d", writefd);
-  close (writefd);
-}
-
-static void
-test_io_basics (void)
-{
-  spawn_process (1);
-#ifndef G_OS_WIN32
-  spawn_process (5);
-#endif
-}
-
-int
-main (int argc, char *argv[])
-{
-  /* Get executable name */
-  exec_name = argv[0];
-
-  /* Run the tests */
-  g_test_init (&argc, &argv, NULL);
-
-  /* Run subprocess, if it is the case */
-  if (argc > 2)
-    {
-      run_process (argc, argv);
-      return 0;
-    }
-
-  g_test_add_func ("/gio/io-basics", test_io_basics);
-
-  return g_test_run ();
-}
diff --git a/tests/meson.build b/tests/meson.build
index 9c8821132..a74453d6d 100644
--- a/tests/meson.build
+++ b/tests/meson.build
@@ -16,7 +16,6 @@ subdir('gobject')
 subdir('refcount')
 
 tests = {
-  'gio-test' : {},
   'slice-threadinit' : {
     'dependencies' : [libgthread_dep],
   },