#include "config.h"
#include <sys/types.h>
+#ifdef HAVE_UNISTD_H
#include <unistd.h>
+#endif
#include <stdlib.h>
#include <glib.h>
+#ifdef G_OS_WIN32
+#include <windows.h>
+#endif
+
+#ifdef G_OS_WIN32
+#define GPID_FORMAT "%p"
+#else
+#define GPID_FORMAT "%d"
+#endif
+
GMainLoop *main_loop;
gint alive;
-gint
+#ifdef G_OS_WIN32
+char *argv0;
+#endif
+
+GPid
get_a_child (gint ttl)
{
GPid pid;
+#ifdef G_OS_WIN32
+ STARTUPINFO si;
+ PROCESS_INFORMATION pi;
+ gchar *cmdline;
+
+ memset (&si, 0, sizeof (si));
+ si.cb = sizeof (&si);
+ memset (&pi, 0, sizeof (pi));
+
+ cmdline = g_strdup_printf( "child-test -c%d", ttl);
+
+ if (!CreateProcess (argv0, cmdline, NULL, NULL, FALSE, 0, NULL, NULL, &si, &pi))
+ g_error ("CreateProcess failed: %s\n", g_win32_error_message (GetLastError ()));
+
+ g_free(cmdline);
+
+ CloseHandle (pi.hThread);
+ pid = pi.hProcess;
+
+ return pid;
+#else
pid = fork ();
if (pid < 0)
exit (1);
sleep (ttl);
_exit (0);
+#endif /* G_OS_WIN32 */
}
gboolean
child_watch_callback (GPid pid, gint status, gpointer data)
{
- g_print ("child %d exited, status %d\n", pid, status);
+#ifdef VERBOSE
+ gint ttl = GPOINTER_TO_INT (data);
+
+ g_print ("child " GPID_FORMAT " (ttl %d) exited, status %d\n", pid, ttl, status);
+#endif
+
+ g_spawn_close_pid (pid);
if (--alive == 0)
g_main_loop_quit (main_loop);
return TRUE;
}
+static gboolean
+quit_loop (gpointer data)
+{
+ GMainLoop *main_loop = data;
+
+ g_main_loop_quit (main_loop);
+
+ return TRUE;
+}
+
+#ifdef TEST_THREAD
static gpointer
test_thread (gpointer data)
{
pid = get_a_child (ttl);
source = g_child_watch_source_new (pid);
- g_source_set_callback (source, (GSourceFunc) child_watch_callback, NULL, NULL);
+ g_source_set_callback (source, (GSourceFunc) child_watch_callback, data, NULL);
g_source_attach (source, g_main_loop_get_context (new_main_loop));
g_source_unref (source);
- g_print ("whee! created pid: %d\n", pid);
+#ifdef VERBOSE
+ g_print ("whee! created pid: " GPID_FORMAT " (ttl %d)\n", pid, ttl);
+#endif
+
g_main_loop_run (new_main_loop);
+ return NULL;
}
+#endif
int
main (int argc, char *argv[])
{
+#ifndef TEST_THREAD
+ GPid pid;
+#endif
+#ifdef G_OS_WIN32
+ argv0 = argv[0];
+ if (argc > 1 && argv[1][0] == '-' && argv[1][1] == 'c')
+ {
+ int ttl = atoi (argv[1] + 2);
+ Sleep (ttl * 1000);
+ /* Exit on purpose with STILL_ACTIVE (which isn't a very common
+ * exit status) to verify that g_child_watch_check() in gmain.c
+ * doesn't believe a child still to be active if it happens to
+ * exit with that status.
+ */
+ exit (STILL_ACTIVE);
+ }
+#endif
/* Only run the test, if threads are enabled and a default thread
- implementation is available */
+ * implementation is available.
+ */
#if defined(G_THREADS_ENABLED) && ! defined(G_THREADS_IMPL_NONE)
- g_thread_init (NULL);
+#ifdef TEST_THREAD
+ g_thread_init (NULL);
+#endif
main_loop = g_main_loop_new (NULL, FALSE);
+#ifdef G_OS_WIN32
+ system ("ipconfig /all");
+#else
system ("/bin/true");
+#endif
alive = 2;
+ g_timeout_add (30000, quit_loop, main_loop);
+
+#ifdef TEST_THREAD
g_thread_create (test_thread, GINT_TO_POINTER (10), FALSE, NULL);
g_thread_create (test_thread, GINT_TO_POINTER (20), FALSE, NULL);
+#else
+ pid = get_a_child (10);
+ g_child_watch_add (pid, (GChildWatchFunc) child_watch_callback,
+ GINT_TO_POINTER (10));
+ pid = get_a_child (20);
+ g_child_watch_add (pid, (GChildWatchFunc) child_watch_callback,
+ GINT_TO_POINTER (20));
+#endif
g_main_loop_run (main_loop);
+ if (alive > 0)
+ {
+ g_warning ("%d children still alive\n", alive);
+ return 1;
+ }
+
#endif
return 0;
}