Function pp_buffer_stdin

run-command.c:1691–1727

}

static void pp_buffer_stdin(struct parallel_processes *pp,
			    const struct run_process_parallel_opts *opts)
{
	/* Buffer stdin for each pipe. */
	for (size_t i = 0; i < opts->processes; i++) {
		struct child_process *proc = &pp->children[i].process;
		int ret;

		if (!child_is_receiving_input(&pp->children[i]))
			continue;

		/*
		 * child input is provided via path_to_stdin when the feed_pipe cb is
		 * missing, so we just signal an EOF.
		 */
		if (!opts->feed_pipe) {
			close(proc->in);
			proc->in = 0;
			continue;
		}

		/**
		 * Feed the pipe:
		 *   ret < 0 means error
		 *   ret == 0 means there is more data to be fed
		 *   ret > 0 means feeding finished
		 */
		ret = opts->feed_pipe(proc->in, opts->data, pp->children[i].data);
		if (ret < 0)
			die_errno("feed_pipe");

		if (ret) {
			close(proc->in);
			proc->in = 0;
		}
	}
}

static void pp_buffer_io(struct parallel_processes *pp,
			 const struct run_process_parallel_opts *opts,