| 1874 | } |
| 1875 | |
| 1876 | static void pp_handle_child_IO(struct parallel_processes *pp, |
| 1877 | const struct run_process_parallel_opts *opts, |
| 1878 | int timeout) |
| 1879 | { |
| 1880 | if (opts->ungroup) { |
| 1881 | pp_buffer_stdin(pp, opts); |
| 1882 | for (size_t i = 0; i < opts->processes; i++) |
| 1883 | if (child_is_ready_for_cleanup(&pp->children[i])) |
| 1884 | pp->children[i].state = GIT_CP_WAIT_CLEANUP; |
| 1885 | } else { |
| 1886 | pp_buffer_io(pp, opts, timeout); |
| 1887 | pp_output(pp); |
| 1888 | } |
| 1889 | } |
| 1890 | |
| 1891 | void run_processes_parallel(const struct run_process_parallel_opts *opts) |
| 1892 | { |
no test coverage detected