/* See LICENSE file for copyright and license details. */
#include "common.h"
#ifndef TEST
int
libexec_spawn(pid_t *out, struct libexec_command *cmd,
int (*after_fork)(struct libexec_command *cmd, int new_fd, void *user),
void *user, struct libexec_document **docsp, size_t *ndocsp, int doc_fd_flags)
{
int fds[2], error, new_fd;
size_t i;
ssize_t r;
if (!docsp || !ndocsp || !out || !cmd) {
errno = EINVAL;
return -1;
}
*out = -1;
if (pipe2(fds, O_CLOEXEC))
return -1;
new_fd = fds[1];
for (i = 0; i < cmd->nplumings; i++)
if (cmd->plumings[i].fd >= new_fd)
new_fd = cmd->plumings[i].fd + 1;
if (new_fd != fds[1]) {
new_fd = fcntl(fds[1], F_DUPFD_CLOEXEC, new_fd);
if (new_fd == -1)
goto fail;
fds[1] = new_fd;
}
if (libexec_get_documents(cmd, docsp, ndocsp, doc_fd_flags))
goto fail;
*out = fork();
switch (*out) {
case -1:
goto fail;
case 0:
close(fds[0]);
if (after_fork)
if ((*after_fork)(cmd, fds[1], user))
goto child_fail;
libexec_exec(cmd);
child_fail:
error = errno;
write_again:
r = write(fds[1], &error, sizeof(error));
if (r <= 0) {
if (errno == EINTR)
goto write_again;
abort();
}
_exit(1);
default:
close(fds[1]);
read_again:
r = read(fds[0], &error, sizeof(error));
if (r < 0) {
if (errno == EINTR)
goto read_again;
} else if (r == 0) {
return 0;
} else if ((size_t)r >= sizeof(error)) {
errno = error;
}
return -1;
}
fail:
error = errno;
close(fds[0]);
close(fds[1]);
errno = error;
return -1;
}
#else
LIBEXEC_CONST__ int main(void) {return 0;} /* TODO test */
#endif
