/* 

 * Copyright (C) 2011 Red Hat, Inc.

 *

 * This work is provided "as is"; redistribution and modification

 * in whole or in part, in any medium, physical or electronic is

 * permitted without restriction.

 *

 * This work 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.

 *

 * In no event shall the authors or contributors be liable for any

 * direct, indirect, incidental, special, exemplary, or consequential

 * damages (including, but not limited to, procurement of substitute

 * goods or services; loss of use, data, or profits; or business

 * interruption) however caused and on any theory of liability, whether

 * in contract, strict liability, or tort (including negligence or

 * otherwise) arising in any way out of the use of this software, even

 * if advised of the possibility of such damage.

 *

 * Author: Colin Walters <walters@verbum.org> 

 */

#include "config.h"

#include <glib.h>

#include <string.h>

#ifdef G_OS_WIN32

#define LINEEND "\r\n"

#else

#define LINEEND "\n"

#endif

/* MinGW builds are likely done using a BASH-style shell, so run the

 * normal script there, as on non-Windows builds, as it is more likely

 * that one will run 'make check' in such shells to test the code

 */

#if defined (G_OS_WIN32) && defined (_MSC_VER)

#define SCRIPT_EXT ".bat"

#else

#define SCRIPT_EXT

#endif

static char *echo_prog_path;

static char *echo_script_path;

typedef struct {

  GMainLoop *loop;

  gboolean child_exited;

  gboolean stdout_done;

  GString *stdout_buf;

} SpawnAsyncMultithreadedData;

static gboolean

on_child_exited (GPid     pid,

		 gint     status,

		 gpointer datap)

{

  SpawnAsyncMultithreadedData *data = datap;

  data->child_exited = TRUE;

  if (data->child_exited && data->stdout_done)

    g_main_loop_quit (data->loop);

  return G_SOURCE_REMOVE;

}

static gboolean

on_child_stdout (GIOChannel   *channel,

		 GIOCondition  condition,

		 gpointer      datap)

{

  char buf[1024];

  GError *error = NULL;

  gsize bytes_read;

  SpawnAsyncMultithreadedData *data = datap;

  if (condition & G_IO_IN)

    {

      GIOStatus status;

      status = g_io_channel_read_chars (channel, buf, sizeof (buf), &bytes_read, &error);

      g_assert_no_error (error);

      g_string_append_len (data->stdout_buf, buf, (gssize) bytes_read);

      if (status == G_IO_STATUS_EOF)

	data->stdout_done = TRUE;

    }

  if (condition & G_IO_HUP)

    data->stdout_done = TRUE;

  if (condition & G_IO_ERR)

    g_error ("Error reading from child stdin");

  if (data->child_exited && data->stdout_done)

    g_main_loop_quit (data->loop);

  return !data->stdout_done;

}

static void

test_spawn_async (void)

{

  int tnum = 1;

  GError *error = NULL;

  GPtrArray *argv;

  char *arg;

  GPid pid;

  GMainContext *context;

  GMainLoop *loop;

  GIOChannel *channel;

  GSource *source;

  int child_stdout_fd;

  SpawnAsyncMultithreadedData data;

  context = g_main_context_new ();

  loop = g_main_loop_new (context, TRUE);

  arg = g_strdup_printf ("thread %d", tnum);

  argv = g_ptr_array_new ();

  g_ptr_array_add (argv, echo_prog_path);

  g_ptr_array_add (argv, arg);

  g_ptr_array_add (argv, NULL);

  g_spawn_async_with_pipes (NULL, (char**)argv->pdata, NULL, G_SPAWN_DO_NOT_REAP_CHILD, NULL, NULL, &pid, NULL,

			    &child_stdout_fd, NULL, &error);

  g_assert_no_error (error);

  g_ptr_array_free (argv, TRUE);

  data.loop = loop;

  data.stdout_done = FALSE;

  data.child_exited = FALSE;

  data.stdout_buf = g_string_new (0);

  source = g_child_watch_source_new (pid);

  g_source_set_callback (source, (GSourceFunc)on_child_exited, &data, NULL);

  g_source_attach (source, context);

  g_source_unref (source);

  channel = g_io_channel_unix_new (child_stdout_fd);

  source = g_io_create_watch (channel, G_IO_IN | G_IO_HUP | G_IO_ERR);

  g_source_set_callback (source, (GSourceFunc)on_child_stdout, &data, NULL);

  g_source_attach (source, context);

  g_source_unref (source);

  g_main_loop_run (loop);

  g_assert (data.child_exited);

  g_assert (data.stdout_done);

  g_assert_cmpstr (data.stdout_buf->str, ==, arg);

  g_string_free (data.stdout_buf, TRUE);

  g_io_channel_unref (channel);

  g_main_context_unref (context);

  g_main_loop_unref (loop);

  g_free (arg);

}

static void

test_spawn_sync (void)

{

  int tnum = 1;

  GError *error = NULL;

  GPtrArray *argv;

  char *arg;

  char *stdout_str;

  int estatus;

  arg = g_strdup_printf ("thread %d", tnum);

  argv = g_ptr_array_new ();

  g_ptr_array_add (argv, echo_prog_path);

  g_ptr_array_add (argv, arg);

  g_ptr_array_add (argv, NULL);

  g_spawn_sync (NULL, (char**)argv->pdata, NULL, 0, NULL, NULL, &stdout_str, NULL, &estatus, &error);

  g_assert_no_error (error);

  g_assert_cmpstr (arg, ==, stdout_str);

  g_free (arg);

  g_free (stdout_str);

  g_ptr_array_free (argv, TRUE);

}

static void

test_spawn_script (void)

{

  GError *error = NULL;

  GPtrArray *argv;

  char *stdout_str;

  int estatus;

  argv = g_ptr_array_new ();

  g_ptr_array_add (argv, echo_script_path);

  g_ptr_array_add (argv, NULL);

  g_spawn_sync (NULL, (char**)argv->pdata, NULL, 0, NULL, NULL, &stdout_str, NULL, &estatus, &error);

  g_assert_no_error (error);

  g_assert_cmpstr ("echo" LINEEND, ==, stdout_str);

  g_free (stdout_str);

  g_ptr_array_free (argv, TRUE);

}

int

main (int   argc,

      char *argv[])

{

  char *dirname;

  int ret;

  g_test_init (&argc, &argv, NULL);

  dirname = g_path_get_dirname (argv[0]);

  echo_prog_path = g_build_filename (dirname, "test-spawn-echo" EXEEXT, NULL);

  if (!g_file_test (echo_prog_path, G_FILE_TEST_EXISTS))

    {

      g_free (echo_prog_path);

      echo_prog_path = g_build_filename (dirname, "lt-test-spawn-echo" EXEEXT, NULL);

    }

  echo_script_path = g_build_filename (dirname, "echo-script" SCRIPT_EXT, NULL);

  if (!g_file_test (echo_script_path, G_FILE_TEST_EXISTS))

    {

      g_free (echo_script_path);

      echo_script_path = g_test_build_filename (G_TEST_DIST, "echo-script" SCRIPT_EXT, NULL);

    }

  g_free (dirname);

  g_assert (g_file_test (echo_prog_path, G_FILE_TEST_EXISTS));

  g_assert (g_file_test (echo_script_path, G_FILE_TEST_EXISTS));

  g_test_add_func ("/gthread/spawn-single-sync", test_spawn_sync);

  g_test_add_func ("/gthread/spawn-single-async", test_spawn_async);

  g_test_add_func ("/gthread/spawn-script", test_spawn_script);

  ret = g_test_run();

  g_free (echo_script_path);

  g_free (echo_prog_path);

  return ret;

}