7 #include <gio/gunixinputstream.h>
8 #include <gio/gfiledescriptorbased.h>
12 #define LINEEND "\r\n"
20 get_test_subprocess_args (const char *mode,
21 ...) G_GNUC_NULL_TERMINATED;
24 get_test_subprocess_args (const char *mode,
33 ret = g_ptr_array_new_with_free_func (g_free);
36 binname = "gsubprocess-testprog.exe";
38 binname = "gsubprocess-testprog";
41 path = g_test_build_filename (G_TEST_BUILT, binname, NULL);
42 g_ptr_array_add (ret, path);
43 g_ptr_array_add (ret, g_strdup (mode));
45 va_start (args, mode);
46 while ((arg = va_arg (args, gpointer)) != NULL)
47 g_ptr_array_add (ret, g_strdup (arg));
50 g_ptr_array_add (ret, NULL);
57 GError *local_error = NULL;
58 GError **error = &local_error;
62 args = get_test_subprocess_args ("noop", NULL);
63 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_NONE, error);
64 g_ptr_array_free (args, TRUE);
65 g_assert_no_error (local_error);
67 g_subprocess_wait_check (proc, NULL, error);
68 g_assert_no_error (local_error);
70 g_object_unref (proc);
74 test_noop_all_to_null (void)
76 GError *local_error = NULL;
77 GError **error = &local_error;
81 args = get_test_subprocess_args ("noop", NULL);
82 proc = g_subprocess_newv ((const gchar * const *) args->pdata,
83 G_SUBPROCESS_FLAGS_STDOUT_SILENCE | G_SUBPROCESS_FLAGS_STDERR_SILENCE,
85 g_ptr_array_free (args, TRUE);
86 g_assert_no_error (local_error);
88 g_subprocess_wait_check (proc, NULL, error);
89 g_assert_no_error (local_error);
91 g_object_unref (proc);
95 test_noop_no_wait (void)
97 GError *local_error = NULL;
98 GError **error = &local_error;
102 args = get_test_subprocess_args ("noop", NULL);
103 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_NONE, error);
104 g_ptr_array_free (args, TRUE);
105 g_assert_no_error (local_error);
107 g_object_unref (proc);
111 test_noop_stdin_inherit (void)
113 GError *local_error = NULL;
114 GError **error = &local_error;
118 args = get_test_subprocess_args ("noop", NULL);
119 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_STDIN_INHERIT, error);
120 g_ptr_array_free (args, TRUE);
121 g_assert_no_error (local_error);
123 g_subprocess_wait_check (proc, NULL, error);
124 g_assert_no_error (local_error);
126 g_object_unref (proc);
131 test_search_path (void)
133 GError *local_error = NULL;
134 GError **error = &local_error;
137 proc = g_subprocess_new (G_SUBPROCESS_FLAGS_NONE, error, "true", NULL);
138 g_assert_no_error (local_error);
140 g_subprocess_wait_check (proc, NULL, error);
141 g_assert_no_error (local_error);
143 g_object_unref (proc);
150 GError *local_error = NULL;
151 GError **error = &local_error;
155 args = get_test_subprocess_args ("exit1", NULL);
156 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_NONE, error);
157 g_ptr_array_free (args, TRUE);
158 g_assert_no_error (local_error);
160 g_subprocess_wait_check (proc, NULL, error);
161 g_assert_error (local_error, G_SPAWN_EXIT_ERROR, 1);
162 g_clear_error (error);
164 g_object_unref (proc);
168 splice_to_string (GInputStream *stream,
171 GMemoryOutputStream *buffer = NULL;
174 buffer = (GMemoryOutputStream*)g_memory_output_stream_new (NULL, 0, g_realloc, g_free);
175 if (g_output_stream_splice ((GOutputStream*)buffer, stream, 0, NULL, error) < 0)
178 if (!g_output_stream_write ((GOutputStream*)buffer, "\0", 1, NULL, error))
181 if (!g_output_stream_close ((GOutputStream*)buffer, NULL, error))
184 ret = g_memory_output_stream_steal_data (buffer);
186 g_clear_object (&buffer);
193 GError *local_error = NULL;
194 GError **error = &local_error;
197 GInputStream *stdout;
200 args = get_test_subprocess_args ("echo", "hello", "world!", NULL);
201 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_STDOUT_PIPE, error);
202 g_ptr_array_free (args, TRUE);
203 g_assert_no_error (local_error);
205 stdout = g_subprocess_get_stdout_pipe (proc);
207 result = splice_to_string (stdout, error);
208 g_assert_no_error (local_error);
210 g_assert_cmpstr (result, ==, "hello" LINEEND "world!" LINEEND);
213 g_object_unref (proc);
218 test_echo_merged (void)
220 GError *local_error = NULL;
221 GError **error = &local_error;
224 GInputStream *stdout;
227 args = get_test_subprocess_args ("echo-stdout-and-stderr", "merge", "this", NULL);
228 proc = g_subprocess_newv ((const gchar * const *) args->pdata,
229 G_SUBPROCESS_FLAGS_STDOUT_PIPE | G_SUBPROCESS_FLAGS_STDERR_MERGE,
231 g_ptr_array_free (args, TRUE);
232 g_assert_no_error (local_error);
234 stdout = g_subprocess_get_stdout_pipe (proc);
235 result = splice_to_string (stdout, error);
236 g_assert_no_error (local_error);
238 g_assert_cmpstr (result, ==, "merge\nmerge\nthis\nthis\n");
241 g_object_unref (proc);
246 guint events_pending;
251 test_cat_on_input_splice_complete (GObject *object,
252 GAsyncResult *result,
255 TestCatData *data = user_data;
256 GError *error = NULL;
258 (void)g_output_stream_splice_finish ((GOutputStream*)object, result, &error);
259 g_assert_no_error (error);
261 data->events_pending--;
262 if (data->events_pending == 0)
263 g_main_loop_quit (data->loop);
269 GError *local_error = NULL;
270 GError **error = &local_error;
275 GInputStream *input_buf_stream = NULL;
276 GOutputStream *output_buf_stream = NULL;
277 GOutputStream *stdin_stream = NULL;
278 GInputStream *stdout_stream = NULL;
281 memset (&data, 0, sizeof (data));
282 data.loop = g_main_loop_new (NULL, TRUE);
284 args = get_test_subprocess_args ("cat", NULL);
285 proc = g_subprocess_newv ((const gchar * const *) args->pdata,
286 G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE,
288 g_ptr_array_free (args, TRUE);
289 g_assert_no_error (local_error);
291 stdin_stream = g_subprocess_get_stdin_pipe (proc);
292 stdout_stream = g_subprocess_get_stdout_pipe (proc);
294 input_buf = g_bytes_new_static ("hello, world!", strlen ("hello, world!"));
295 input_buf_stream = g_memory_input_stream_new_from_bytes (input_buf);
296 g_bytes_unref (input_buf);
298 output_buf_stream = g_memory_output_stream_new (NULL, 0, g_realloc, g_free);
300 g_output_stream_splice_async (stdin_stream, input_buf_stream, G_OUTPUT_STREAM_SPLICE_CLOSE_SOURCE | G_OUTPUT_STREAM_SPLICE_CLOSE_TARGET,
301 G_PRIORITY_DEFAULT, NULL, test_cat_on_input_splice_complete,
303 data.events_pending++;
304 g_output_stream_splice_async (output_buf_stream, stdout_stream, G_OUTPUT_STREAM_SPLICE_CLOSE_SOURCE | G_OUTPUT_STREAM_SPLICE_CLOSE_TARGET,
305 G_PRIORITY_DEFAULT, NULL, test_cat_on_input_splice_complete,
307 data.events_pending++;
309 g_main_loop_run (data.loop);
311 g_subprocess_wait_check (proc, NULL, error);
312 g_assert_no_error (local_error);
314 output_buf = g_memory_output_stream_steal_as_bytes ((GMemoryOutputStream*)output_buf_stream);
316 g_assert_cmpint (g_bytes_get_size (output_buf), ==, 13);
317 g_assert_cmpint (memcmp (g_bytes_get_data (output_buf, NULL), "hello, world!", 13), ==, 0);
319 g_bytes_unref (output_buf);
320 g_main_loop_unref (data.loop);
321 g_object_unref (input_buf_stream);
322 g_object_unref (output_buf_stream);
323 g_object_unref (proc);
327 cancel_soon (gpointer user_data)
329 GCancellable *cancellable = user_data;
331 g_usleep (G_TIME_SPAN_SECOND);
332 g_cancellable_cancel (cancellable);
333 g_object_unref (cancellable);
341 GCancellable *cancellable;
342 GError *error = NULL;
349 g_test_skip ("This test has not been ported to Win32");
354 cat = g_subprocess_new (G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE, &error, "cat", NULL);
355 g_assert_no_error (error);
358 /* Make sure that reading stdout blocks (until we cancel) */
359 cancellable = g_cancellable_new ();
360 g_thread_unref (g_thread_new ("cancel thread", cancel_soon, g_object_ref (cancellable)));
361 s = g_input_stream_read (g_subprocess_get_stdout_pipe (cat), &buffer, sizeof buffer, cancellable, &error);
362 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_CANCELLED);
363 g_assert_cmpint (s, ==, -1);
364 g_object_unref (cancellable);
365 g_clear_error (&error);
367 /* Close the stream (EOF on cat's stdin) */
368 result = g_output_stream_close (g_subprocess_get_stdin_pipe (cat), NULL, &error);
369 g_assert_no_error (error);
372 /* Now check that reading cat's stdout gets us an EOF (since it quit) */
373 s = g_input_stream_read (g_subprocess_get_stdout_pipe (cat), &buffer, sizeof buffer, NULL, &error);
374 g_assert_no_error (error);
377 /* Check that the process has exited as a result of the EOF */
378 result = g_subprocess_wait (cat, NULL, &error);
379 g_assert_no_error (error);
380 g_assert (g_subprocess_get_if_exited (cat));
381 g_assert_cmpint (g_subprocess_get_exit_status (cat), ==, 0);
384 g_object_unref (cat);
388 guint events_pending;
389 gboolean caught_error;
394 GOutputStream *first_stdin;
395 } TestMultiSpliceData;
398 on_one_multi_splice_done (GObject *obj,
402 TestMultiSpliceData *data = user_data;
404 if (!data->caught_error)
406 if (g_output_stream_splice_finish ((GOutputStream*)obj, res, &data->error) < 0)
407 data->caught_error = TRUE;
410 data->events_pending--;
411 if (data->events_pending == 0)
412 g_main_loop_quit (data->loop);
416 on_idle_multisplice (gpointer user_data)
418 TestMultiSpliceData *data = user_data;
420 /* We write 2^1 + 2^2 ... + 2^10 or 2047 copies of "Hello World!\n"
423 if (data->counter >= 2047 || data->caught_error)
425 if (!g_output_stream_close (data->first_stdin, NULL, &data->error))
426 data->caught_error = TRUE;
427 data->events_pending--;
428 if (data->events_pending == 0)
430 g_main_loop_quit (data->loop);
437 for (i = 0; i < data->counter; i++)
440 if (!g_output_stream_write_all (data->first_stdin, "hello world!\n",
441 strlen ("hello world!\n"), &bytes_written,
444 data->caught_error = TRUE;
454 on_subprocess_exited (GObject *object,
455 GAsyncResult *result,
458 GSubprocess *subprocess = G_SUBPROCESS (object);
459 TestMultiSpliceData *data = user_data;
460 GError *error = NULL;
462 if (!g_subprocess_wait_finish (subprocess, result, &error))
464 if (!data->caught_error)
466 data->caught_error = TRUE;
467 g_propagate_error (&data->error, error);
470 g_spawn_check_exit_status (g_subprocess_get_exit_status (subprocess), &error);
471 g_assert_no_error (error);
472 data->events_pending--;
473 if (data->events_pending == 0)
474 g_main_loop_quit (data->loop);
480 GError *local_error = NULL;
481 GError **error = &local_error;
483 GSubprocessLauncher *launcher;
487 GOutputStream *first_stdin;
488 GInputStream *first_stdout;
489 GOutputStream *second_stdin;
490 GInputStream *second_stdout;
491 GOutputStream *third_stdin;
492 GInputStream *third_stdout;
493 GOutputStream *membuf;
494 TestMultiSpliceData data;
495 int splice_flags = G_OUTPUT_STREAM_SPLICE_CLOSE_SOURCE | G_OUTPUT_STREAM_SPLICE_CLOSE_TARGET;
497 args = get_test_subprocess_args ("cat", NULL);
498 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE);
499 first = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
500 g_assert_no_error (local_error);
501 second = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
502 g_assert_no_error (local_error);
503 third = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
504 g_assert_no_error (local_error);
506 g_ptr_array_free (args, TRUE);
508 membuf = g_memory_output_stream_new (NULL, 0, g_realloc, g_free);
510 first_stdin = g_subprocess_get_stdin_pipe (first);
511 first_stdout = g_subprocess_get_stdout_pipe (first);
512 second_stdin = g_subprocess_get_stdin_pipe (second);
513 second_stdout = g_subprocess_get_stdout_pipe (second);
514 third_stdin = g_subprocess_get_stdin_pipe (third);
515 third_stdout = g_subprocess_get_stdout_pipe (third);
517 memset (&data, 0, sizeof (data));
518 data.loop = g_main_loop_new (NULL, TRUE);
520 data.first_stdin = first_stdin;
522 data.events_pending++;
523 g_output_stream_splice_async (second_stdin, first_stdout, splice_flags, G_PRIORITY_DEFAULT,
524 NULL, on_one_multi_splice_done, &data);
525 data.events_pending++;
526 g_output_stream_splice_async (third_stdin, second_stdout, splice_flags, G_PRIORITY_DEFAULT,
527 NULL, on_one_multi_splice_done, &data);
528 data.events_pending++;
529 g_output_stream_splice_async (membuf, third_stdout, splice_flags, G_PRIORITY_DEFAULT,
530 NULL, on_one_multi_splice_done, &data);
532 data.events_pending++;
533 g_timeout_add (250, on_idle_multisplice, &data);
535 data.events_pending++;
536 g_subprocess_wait_async (first, NULL, on_subprocess_exited, &data);
537 data.events_pending++;
538 g_subprocess_wait_async (second, NULL, on_subprocess_exited, &data);
539 data.events_pending++;
540 g_subprocess_wait_async (third, NULL, on_subprocess_exited, &data);
542 g_main_loop_run (data.loop);
544 g_assert (!data.caught_error);
545 g_assert_no_error (data.error);
547 g_assert_cmpint (g_memory_output_stream_get_data_size ((GMemoryOutputStream*)membuf), ==, 26611);
549 g_main_loop_unref (data.loop);
550 g_object_unref (membuf);
551 g_object_unref (launcher);
552 g_object_unref (first);
553 g_object_unref (second);
554 g_object_unref (third);
561 } TestAsyncCommunicateData;
564 on_communicate_complete (GObject *proc,
565 GAsyncResult *result,
568 TestAsyncCommunicateData *data = user_data;
569 GBytes *stdout = NULL;
570 char *stdout_str = NULL;
571 const guint8 *stdout_data;
574 data->running = FALSE;
576 (void) g_subprocess_communicate_utf8_finish ((GSubprocess*)proc, result,
577 &stdout_str, NULL, &data->error);
579 (void) g_subprocess_communicate_finish ((GSubprocess*)proc, result,
580 &stdout, NULL, &data->error);
586 g_assert (stdout != NULL);
587 stdout_data = g_bytes_get_data (stdout, &stdout_len);
591 g_assert (stdout_str != NULL);
592 stdout_data = (guint8*)stdout_str;
593 stdout_len = strlen (stdout_str);
596 g_assert_cmpint (stdout_len, ==, 11);
597 g_assert (memcmp (stdout_data, "hello world", 11) == 0);
599 g_bytes_unref (stdout);
604 test_communicate (void)
606 GError *error = NULL;
608 TestAsyncCommunicateData data = { 0, };
610 GCancellable *cancellable = NULL;
612 const char *hellostring;
614 args = get_test_subprocess_args ("cat", NULL);
615 proc = g_subprocess_newv ((const gchar* const*)args->pdata,
616 G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE,
618 g_assert_no_error (error);
619 g_ptr_array_free (args, TRUE);
621 hellostring = "hello world";
622 input = g_bytes_new_static (hellostring, strlen (hellostring));
624 g_subprocess_communicate_async (proc, input,
626 on_communicate_complete,
631 g_main_context_iteration (NULL, TRUE);
633 g_assert_no_error (data.error);
635 g_bytes_unref (input);
636 g_object_unref (proc);
640 test_communicate_utf8 (void)
642 GError *error = NULL;
644 TestAsyncCommunicateData data = { 0, };
646 GCancellable *cancellable = NULL;
648 args = get_test_subprocess_args ("cat", NULL);
649 proc = g_subprocess_newv ((const gchar* const*)args->pdata,
650 G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE,
652 g_assert_no_error (error);
653 g_ptr_array_free (args, TRUE);
656 g_subprocess_communicate_utf8_async (proc, "hello world",
658 on_communicate_complete,
663 g_main_context_iteration (NULL, TRUE);
665 g_assert_no_error (data.error);
667 g_object_unref (proc);
671 test_communicate_utf8_invalid (void)
673 GError *error = NULL;
675 TestAsyncCommunicateData data = { 0, };
677 GCancellable *cancellable = NULL;
679 args = get_test_subprocess_args ("cat", NULL);
680 proc = g_subprocess_newv ((const gchar* const*)args->pdata,
681 G_SUBPROCESS_FLAGS_STDIN_PIPE | G_SUBPROCESS_FLAGS_STDOUT_PIPE,
683 g_assert_no_error (error);
684 g_ptr_array_free (args, TRUE);
687 g_subprocess_communicate_utf8_async (proc, "\xFF\xFF",
689 on_communicate_complete,
694 g_main_context_iteration (NULL, TRUE);
696 g_assert_error (data.error, G_IO_ERROR, G_IO_ERROR_FAILED);
697 g_error_free (data.error);
699 g_object_unref (proc);
703 send_terminate (gpointer user_data)
705 GSubprocess *proc = user_data;
707 g_subprocess_force_exit (proc);
713 on_request_quit_exited (GObject *object,
714 GAsyncResult *result,
717 GSubprocess *subprocess = G_SUBPROCESS (object);
718 GError *error = NULL;
720 g_subprocess_wait_finish (subprocess, result, &error);
721 g_assert_no_error (error);
723 g_assert (g_subprocess_get_if_signaled (subprocess));
724 g_assert (g_subprocess_get_term_sig (subprocess) == 9);
726 g_spawn_check_exit_status (g_subprocess_get_status (subprocess), &error);
727 g_assert (error != NULL);
728 g_clear_error (&error);
730 g_main_loop_quit ((GMainLoop*)user_data);
734 test_terminate (void)
736 GError *local_error = NULL;
737 GError **error = &local_error;
742 args = get_test_subprocess_args ("sleep-forever", NULL);
743 proc = g_subprocess_newv ((const gchar * const *) args->pdata, G_SUBPROCESS_FLAGS_NONE, error);
744 g_ptr_array_free (args, TRUE);
745 g_assert_no_error (local_error);
747 loop = g_main_loop_new (NULL, TRUE);
749 g_subprocess_wait_async (proc, NULL, on_request_quit_exited, loop);
751 g_timeout_add_seconds (3, send_terminate, proc);
753 g_main_loop_run (loop);
755 g_main_loop_unref (loop);
756 g_object_unref (proc);
762 GError *local_error = NULL;
763 GError **error = &local_error;
764 GSubprocessLauncher *launcher;
767 GInputStream *stdout;
769 gchar *envp[] = { "ONE=1", "TWO=1", "THREE=3", "FOUR=1", NULL };
772 args = get_test_subprocess_args ("env", NULL);
773 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_NONE);
774 g_subprocess_launcher_set_flags (launcher, G_SUBPROCESS_FLAGS_STDOUT_PIPE);
775 g_subprocess_launcher_set_environ (launcher, envp);
776 g_subprocess_launcher_setenv (launcher, "TWO", "2", TRUE);
777 g_subprocess_launcher_setenv (launcher, "THREE", "1", FALSE);
778 g_subprocess_launcher_unsetenv (launcher, "FOUR");
780 g_assert_null (g_subprocess_launcher_getenv (launcher, "FOUR"));
782 proc = g_subprocess_launcher_spawn (launcher, error, args->pdata[0], "env", NULL);
783 g_ptr_array_free (args, TRUE);
784 g_assert_no_error (local_error);
786 stdout = g_subprocess_get_stdout_pipe (proc);
788 result = splice_to_string (stdout, error);
789 split = g_strsplit (result, "\n", -1);
790 g_assert_cmpstr (g_environ_getenv (split, "ONE"), ==, "1");
791 g_assert_cmpstr (g_environ_getenv (split, "TWO"), ==, "2");
792 g_assert_cmpstr (g_environ_getenv (split, "THREE"), ==, "3");
793 g_assert_null (g_environ_getenv (split, "FOUR"));
797 g_object_unref (proc);
802 test_stdout_file (void)
804 GError *local_error = NULL;
805 GError **error = &local_error;
806 GSubprocessLauncher *launcher;
810 GFileIOStream *iostream;
811 GOutputStream *stdin;
812 const char *test_data = "this is some test data\n";
816 tmpfile = g_file_new_tmp ("gsubprocessXXXXXX", &iostream, error);
817 g_assert_no_error (local_error);
818 g_clear_object (&iostream);
820 tmp_file_path = g_file_get_path (tmpfile);
822 args = get_test_subprocess_args ("cat", NULL);
823 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_STDIN_PIPE);
824 g_subprocess_launcher_set_stdout_file_path (launcher, tmp_file_path);
825 proc = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
826 g_ptr_array_free (args, TRUE);
827 g_assert_no_error (local_error);
829 stdin = g_subprocess_get_stdin_pipe (proc);
831 g_output_stream_write_all (stdin, test_data, strlen (test_data), NULL, NULL, error);
832 g_assert_no_error (local_error);
834 g_output_stream_close (stdin, NULL, error);
835 g_assert_no_error (local_error);
837 g_subprocess_wait_check (proc, NULL, error);
839 g_object_unref (launcher);
840 g_object_unref (proc);
842 g_file_load_contents (tmpfile, NULL, &tmp_contents, NULL, NULL, error);
843 g_assert_no_error (local_error);
845 g_assert_cmpstr (test_data, ==, tmp_contents);
846 g_free (tmp_contents);
848 (void) g_file_delete (tmpfile, NULL, NULL);
849 g_object_unref (tmpfile);
850 g_free (tmp_file_path);
854 test_stdout_fd (void)
856 GError *local_error = NULL;
857 GError **error = &local_error;
858 GSubprocessLauncher *launcher;
862 GFileIOStream *iostream;
863 GFileDescriptorBased *descriptor_stream;
864 GOutputStream *stdin;
865 const char *test_data = "this is some test data\n";
868 tmpfile = g_file_new_tmp ("gsubprocessXXXXXX", &iostream, error);
869 g_assert_no_error (local_error);
871 args = get_test_subprocess_args ("cat", NULL);
872 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_STDIN_PIPE);
873 descriptor_stream = G_FILE_DESCRIPTOR_BASED (g_io_stream_get_output_stream (G_IO_STREAM (iostream)));
874 g_subprocess_launcher_take_stdout_fd (launcher, dup (g_file_descriptor_based_get_fd (descriptor_stream)));
875 proc = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
876 g_ptr_array_free (args, TRUE);
877 g_assert_no_error (local_error);
879 g_clear_object (&iostream);
881 stdin = g_subprocess_get_stdin_pipe (proc);
883 g_output_stream_write_all (stdin, test_data, strlen (test_data), NULL, NULL, error);
884 g_assert_no_error (local_error);
886 g_output_stream_close (stdin, NULL, error);
887 g_assert_no_error (local_error);
889 g_subprocess_wait_check (proc, NULL, error);
891 g_object_unref (launcher);
892 g_object_unref (proc);
894 g_file_load_contents (tmpfile, NULL, &tmp_contents, NULL, NULL, error);
895 g_assert_no_error (local_error);
897 g_assert_cmpstr (test_data, ==, tmp_contents);
898 g_free (tmp_contents);
900 (void) g_file_delete (tmpfile, NULL, NULL);
901 g_object_unref (tmpfile);
905 child_setup (gpointer user_data)
907 dup2 (GPOINTER_TO_INT (user_data), 1);
911 test_child_setup (void)
913 GError *local_error = NULL;
914 GError **error = &local_error;
915 GSubprocessLauncher *launcher;
919 GFileIOStream *iostream;
920 GOutputStream *stdin;
921 const char *test_data = "this is some test data\n";
925 tmpfile = g_file_new_tmp ("gsubprocessXXXXXX", &iostream, error);
926 g_assert_no_error (local_error);
928 fd = g_file_descriptor_based_get_fd (G_FILE_DESCRIPTOR_BASED (g_io_stream_get_output_stream (G_IO_STREAM (iostream))));
930 args = get_test_subprocess_args ("cat", NULL);
931 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_STDIN_PIPE);
932 g_subprocess_launcher_set_child_setup (launcher, child_setup, GINT_TO_POINTER (fd), NULL);
933 proc = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
934 g_ptr_array_free (args, TRUE);
935 g_assert_no_error (local_error);
937 g_clear_object (&iostream);
939 stdin = g_subprocess_get_stdin_pipe (proc);
941 g_output_stream_write_all (stdin, test_data, strlen (test_data), NULL, NULL, error);
942 g_assert_no_error (local_error);
944 g_output_stream_close (stdin, NULL, error);
945 g_assert_no_error (local_error);
947 g_subprocess_wait_check (proc, NULL, error);
949 g_object_unref (launcher);
950 g_object_unref (proc);
952 g_file_load_contents (tmpfile, NULL, &tmp_contents, NULL, NULL, error);
953 g_assert_no_error (local_error);
955 g_assert_cmpstr (test_data, ==, tmp_contents);
956 g_free (tmp_contents);
958 (void) g_file_delete (tmpfile, NULL, NULL);
959 g_object_unref (tmpfile);
965 GError *local_error = NULL;
966 GError **error = &local_error;
967 GInputStream *child_input;
968 GDataInputStream *child_datainput;
969 GSubprocessLauncher *launcher;
972 int basic_pipefds[2];
973 int needdup_pipefds[2];
977 char *needdup_fd_str;
979 g_unix_open_pipe (basic_pipefds, FD_CLOEXEC, error);
980 g_assert_no_error (local_error);
981 g_unix_open_pipe (needdup_pipefds, FD_CLOEXEC, error);
982 g_assert_no_error (local_error);
984 basic_fd_str = g_strdup_printf ("%d", basic_pipefds[1]);
985 needdup_fd_str = g_strdup_printf ("%d", needdup_pipefds[1] + 1);
987 args = get_test_subprocess_args ("write-to-fds", basic_fd_str, needdup_fd_str, NULL);
988 launcher = g_subprocess_launcher_new (G_SUBPROCESS_FLAGS_NONE);
989 g_subprocess_launcher_take_fd (launcher, basic_pipefds[1], basic_pipefds[1]);
990 g_subprocess_launcher_take_fd (launcher, needdup_pipefds[1], needdup_pipefds[1] + 1);
991 proc = g_subprocess_launcher_spawnv (launcher, (const gchar * const *) args->pdata, error);
992 g_ptr_array_free (args, TRUE);
993 g_assert_no_error (local_error);
995 g_free (basic_fd_str);
996 g_free (needdup_fd_str);
998 child_input = g_unix_input_stream_new (basic_pipefds[0], TRUE);
999 child_datainput = g_data_input_stream_new (child_input);
1000 buf = g_data_input_stream_read_line_utf8 (child_datainput, &len, NULL, error);
1001 g_assert_no_error (local_error);
1002 g_assert_cmpstr (buf, ==, "hello world");
1003 g_object_unref (child_datainput);
1004 g_object_unref (child_input);
1007 child_input = g_unix_input_stream_new (needdup_pipefds[0], TRUE);
1008 child_datainput = g_data_input_stream_new (child_input);
1009 buf = g_data_input_stream_read_line_utf8 (child_datainput, &len, NULL, error);
1010 g_assert_no_error (local_error);
1011 g_assert_cmpstr (buf, ==, "hello world");
1013 g_object_unref (child_datainput);
1014 g_object_unref (child_input);
1016 g_object_unref (launcher);
1017 g_object_unref (proc);
1023 main (int argc, char **argv)
1025 g_test_init (&argc, &argv, NULL);
1027 g_test_add_func ("/gsubprocess/noop", test_noop);
1028 g_test_add_func ("/gsubprocess/noop-all-to-null", test_noop_all_to_null);
1029 g_test_add_func ("/gsubprocess/noop-no-wait", test_noop_no_wait);
1030 g_test_add_func ("/gsubprocess/noop-stdin-inherit", test_noop_stdin_inherit);
1032 g_test_add_func ("/gsubprocess/search-path", test_search_path);
1034 g_test_add_func ("/gsubprocess/exit1", test_exit1);
1035 g_test_add_func ("/gsubprocess/echo1", test_echo1);
1037 g_test_add_func ("/gsubprocess/echo-merged", test_echo_merged);
1039 g_test_add_func ("/gsubprocess/cat-utf8", test_cat_utf8);
1040 g_test_add_func ("/gsubprocess/cat-eof", test_cat_eof);
1041 g_test_add_func ("/gsubprocess/multi1", test_multi_1);
1042 g_test_add_func ("/gsubprocess/communicate", test_communicate);
1043 g_test_add_func ("/gsubprocess/communicate-utf8", test_communicate_utf8);
1044 g_test_add_func ("/gsubprocess/communicate-utf8-invalid", test_communicate_utf8_invalid);
1045 g_test_add_func ("/gsubprocess/terminate", test_terminate);
1046 g_test_add_func ("/gsubprocess/env", test_env);
1048 g_test_add_func ("/gsubprocess/stdout-file", test_stdout_file);
1049 g_test_add_func ("/gsubprocess/stdout-fd", test_stdout_fd);
1050 g_test_add_func ("/gsubprocess/child-setup", test_child_setup);
1051 g_test_add_func ("/gsubprocess/pass-fd", test_pass_fd);
1054 return g_test_run ();