/*
* libslack - https://libslack.org
*
* Copyright (C) 1999-2004, 2010, 2020-2023 raf <raf@raf.org>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program 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.  See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, see <https://www.gnu.org/licenses/>.
*
* 20230824 raf <raf@raf.org>
*/

/*

=head1 NAME

I<libslack(coproc)> - coprocess module

=head1 SYNOPSIS

    #include <slack/std.h>
    #include <slack/coproc.h>

    pid_t coproc_open(int *to, int *from, int *err, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data);
    int coproc_close(pid_t pid, int *to, int *from, int *err);
    pid_t coproc_pty_open(int *pty_user_fd, char *pty_device_name, size_t pty_device_name_size, const struct termios *pty_device_termios, const struct winsize *pty_device_winsize, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data);
    int coproc_pty_close(pid_t pid, int *pty_user_fd, const char *pty_device_name);

=head1 DESCRIPTION

This module contains functions for creating coprocesses that use either
pipes or pseudo terminals for communication.

=over 4

=cut

*/

#ifndef _BSD_SOURCE
#define _BSD_SOURCE /* For snprintf() on OpenBSD-4.7 */
#endif

#ifndef _DEFAULT_SOURCE
#define _DEFAULT_SOURCE /* New name for _BSD_SOURCE */
#endif

#include "config.h"
#include "std.h"

#include <sys/wait.h>

#include "coproc.h"
#include "daemon.h"
#include "pseudo.h"
#include "err.h"

#ifndef HAVE_SNPRINTF
#include "snprintf.h"
#endif

#ifndef TEST

extern char **environ;

#ifndef SHELL_META_CHARACTERS
#define SHELL_META_CHARACTERS "|&;()<>[]{}$`'~\"\\*? \t\r\n"
#endif

#ifndef DEFAULT_ROOT_PATH
#define DEFAULT_ROOT_PATH "/bin:/usr/bin"
#endif

#ifndef DEFAULT_USER_PATH
#define DEFAULT_USER_PATH ":/bin:/usr/bin"
#endif

#define RD 0
#define WR 1

/*

=item C<pid_t coproc_open(int *to, int *from, int *err, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data)>

Starts a coprocess. C<cmd> is the name of the process or a shell command.
C<argv> is the command line argument vector to be passed to I<execve(2)>.
C<envv> is the environment variable vector to be passed to I<execve(2)>. If
C<envv> is C<null>, the current environment is used. If C<cmd> is the name
of a program, C<argv> must not be C<null>. If C<cmd> contains shell
metacharacters, it will executed by C<sh -c> and C<argv> must be C<null>.
This provides protection from unintentionally invoking C<sh -c>. If C<cmd>
does not contain any shell metacharacters, but does contain a slash
character (C</>), it is passed directly to I<execve(2)>. If it doesn't
contain a slash character, we search for the executable in the directories
specified by the C<PATH> environment variable. If the C<PATH> environment
variable is not set, a default path is used: C</bin:/usr/bin> for I<root>;
C<:/bin:/usr/bin> for other users. If permission is denied for a file
(I<execve(2)> returns C<EACCES>), then searching continues. If the header of
a file isn't recognised (I<execve(2)> returns C<ENOEXEC>), then C</bin/sh>
will be executed with C<cmd> as its first argument. This is done so that
shell scripts without a C<#!> line can be used. If this attempt fails, no
further searching is done. Communication with the coprocess occurs over
pipes. Data written to C<*to> can be read from the standard input of the
coprocess. Data written to the standard output or standard error of the
coprocess may be read from C<*from> and C<*err>, respectively. If the
function pointer C<action> is not C<null>, it is invoked in the child
process between the calls to I<fork(2)> and I<execve(2)>. Specifically, it
is invoked before the pipes are duplicated onto C<stdin>, C<stdout> and
C<stderr>. I<data> is passed as the argument to I<action>. This is useful
when you need to prevent the coprocess from inheriting certain process
attributes. It can be used to ignore signals, set default signal handlers,
modify the signal mask and close files. On success, returns the process id
of the coprocess. On error, returns C<-1> with C<errno> set appropriately.

Note: That this can only be used with coprocesses that do not buffer I/O or
that explicitly set line buffering (or no buffering) with I<setbuf(3)> or
I<setvbuf(3)>. If a potential coprocess uses standard I/O, and you don't
have access to the source code, you will need to use I<coproc_pty_open(3)>
instead.

B<Note: If I<cmd> does contain shell metacharacters, make sure that the
application provides the command to execute. If the command comes from
outside the application, do not trust it. Verify that it is safe to
execute.>

=cut

*/

static char * const *new_shargv(const char *cmd, char * const *argv)
{
	char **shargv;
	int nargs = 0;

	while (argv[nargs])
		++nargs;

	if (!(shargv = malloc((nargs + 2) * sizeof(char **))))
		return NULL;

	shargv[0] = "/bin/sh";
	shargv[1] = (char *)cmd;

	for (nargs = 1; argv[nargs]; ++nargs)
		shargv[nargs + 1] = argv[nargs];

	shargv[nargs + 1] = NULL;

	return (char * const *)shargv;
}

static void do_exec(int has_meta, const char *cmd, char * const *argv, char * const *envv)
{
	if (has_meta)
	{
		char const *shargv[4];

		shargv[0] = "sh";
		shargv[1] = "-c";
		shargv[2] = cmd;
		shargv[3] = NULL;

		execve("/bin/sh", (char * const *)shargv, (envv) ? envv : environ);
	}
	else if (strchr(cmd, PATH_SEP))
	{
		execve(cmd, argv, (envv) ? envv : environ);

		if (errno == ENOEXEC)
		{
			char * const *shargv = new_shargv(cmd, argv);
			execve("/bin/sh", shargv, (envv) ? envv : environ);
			free((void *)shargv);
		}
	}
	else
	{
		char *path, *s, *f;
		char cmdbuf[512];

		if (!(path = getenv("PATH")))
			path = geteuid() ? DEFAULT_USER_PATH : DEFAULT_ROOT_PATH;

		for (s = path; s; s = (*f) ? f + 1 : NULL)
		{
			if (!(f = strchr(s, PATH_LIST_SEP)))
				f = s + strlen(s);

			if (snprintf(cmdbuf, 512, "%.*s%s%s", (int)(f - s), s, (f - s) ? PATH_SEP_STR : "", cmd) >= 512)
				continue;

			if (execve(cmdbuf, argv, (envv) ? envv : environ) == -1)
			{
				if (errno == EACCES)
					continue;

				if (errno == ENOEXEC)
				{
					char * const *shargv = new_shargv(cmdbuf, argv);
					execve("/bin/sh", shargv, (envv) ? envv : environ);
					free((void *)shargv);
					break;
				}
			}
		}
	}
}

pid_t coproc_open(int *to, int *from, int *err, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data)
{
	int to_pipe[2];   /* pipe for writing to the coprocess */
	int from_pipe[2]; /* pipe for reading from the coprocess */
	int err_pipe[2];  /* pipe for reading errors from the coprocess */
	pid_t pid;        /* process id of the coprocess */
	int has_meta;     /* does cmd contain shell meta characters? */

	/* Check arguments */

	if (!to || !from || !err || !cmd)
		return set_errno(EINVAL);

	has_meta = (cmd[strcspn(cmd, SHELL_META_CHARACTERS)] != '\0');

	if ((has_meta && argv) || (!has_meta && !argv))
		return set_errno(EINVAL);

	/* Create pipes */

	if (pipe(to_pipe) == -1)
		return -1;

	if (pipe(from_pipe) == -1)
	{
		close(to_pipe[RD]);
		close(to_pipe[WR]);
		return -1;
	}

	if (pipe(err_pipe) == -1)
	{
		close(to_pipe[RD]);
		close(to_pipe[WR]);
		close(from_pipe[RD]);
		close(from_pipe[WR]);
		return -1;
	}

	/* Create child process */

	switch (pid = fork())
	{
		case -1:
		{
			close(to_pipe[RD]);
			close(to_pipe[WR]);
			close(from_pipe[RD]);
			close(from_pipe[WR]);
			close(err_pipe[RD]);
			close(err_pipe[WR]);
			return -1;
		}

		case 0:
		{
			/* Adjust process attributes */

			if (action)
				action(data);

			/* Attach pipes to stdin, stdout and stderr */

			close(to_pipe[WR]);
			close(from_pipe[RD]);
			close(err_pipe[RD]);

			if (to_pipe[RD] != STDIN_FILENO)
			{
				if (dup2(to_pipe[RD], STDIN_FILENO) == -1)
					_exit(1);

				close(to_pipe[RD]);
			}

			if (from_pipe[WR] != STDOUT_FILENO)
			{
				if (dup2(from_pipe[WR], STDOUT_FILENO) == -1)
					_exit(1);

				close(from_pipe[WR]);
			}

			if (err_pipe[WR] != STDERR_FILENO)
			{
				if (dup2(err_pipe[WR], STDERR_FILENO) == -1)
					_exit(1);

				close(err_pipe[WR]);
			}

			/* Execute co-process */

			do_exec(has_meta, cmd, argv, envv);
			_exit(EXIT_FAILURE);
		}

		default:
		{
			/* Return the pipe descriptors and the coprocess id to the caller */

			close(to_pipe[RD]);
			close(from_pipe[WR]);
			close(err_pipe[WR]);

			*to = to_pipe[WR];
			*from = from_pipe[RD];
			*err = err_pipe[RD];

			return pid;
		}
	}
}

/*

=item C<int coproc_close(pid_t pid, int *to, int *from, int *err)>

Closes the coprocess referred to by C<pid> which must have been obtained
from I<coproc_open(3)>. C<*to>, C<*from> and C<*err> will be closed and set
to C<-1> if they are not already C<-1>. The current process will then wait
for the coprocess to terminate by calling I<waitpid(2)>. On success, returns
the status of the child process as determined by I<waitpid(2)>. On error,
returns C<-1> with C<errno> set appropriately. B<Note:> If I<waitpid(2)> is
interrupted by a signal, I<coproc_close(3)> will return C<-1> with C<errno>
set to C<EINTR>. The caller has to call I<coproc_close(3)> (or just
I<waitpid(2)>) again until it succeeds (or a real error occurs).

=cut

*/

int coproc_close(pid_t pid, int *to, int *from, int *err)
{
	int status = 0;

	if (pid <= 0)
		return set_errno(EINVAL);

	if (to && *to != -1)
	{
		close(*to);
		*to = -1;
	}

	if (from && *from != -1)
	{
		close(*from);
		*from = -1;
	}

	if (err && *err != -1)
	{
		close(*err);
		*err = -1;
	}

	if (waitpid(pid, &status, 0) == -1)
		return -1;

	return status;
}

/*

=item C<pid_t coproc_pty_open(int *pty_user_fd, char *pty_device_name, size_t pty_device_name_size, const struct termios *pty_device_termios, const struct winsize *pty_device_winsize, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data)>

Equivalent to I<coproc_open(3)> except that communication with the coprocess
occurs over a pseudo terminal. This is useful when the coprocess uses
standard I/O, and you don't have the source code. Standard I/O is fully
buffered unless connected to a terminal. C<*pty_user_fd> is set to the user
(or controlling process) side of a pseudo terminal. Data written to
C<*pty_user_fd> can be read from the standard input of the coprocess. Data
written to the standard output or standard error of the coprocess can be
read from C<*pty_user_fd>. The device name of the coprocess side of the
pseudo terminal is stored in the buffer pointed to by C<pty_device_name>
which must be able to store at least 64 bytes. C<pty_device_name_size> is
the size of the buffer pointed to by C<pty_device_name>. No more than
C<pty_device_name_size> bytes will be written into the buffer pointed to by
C<pty_device_name> including the terminating C<nul> byte. If
C<pty_device_termios> is not null, it is passed to I<tcsetattr(3)> with the
command C<TCSANOW> to set the terminal attributes of the device on the
coprocess side of the pseudo terminal. If C<pty_device_winsize> is not null,
it is passed to I<ioctl(2)> with the command C<TIOCSWINSZ> to set the window
size of the device on the coprocess side of the pseudo terminal. On success,
returns C<0>. On error, returns C<-1> with C<errno> set appropriately.

=cut

*/

pid_t coproc_pty_open(int *pty_user_fd, char *pty_device_name, size_t pty_device_name_size, const struct termios *pty_device_termios, const struct winsize *pty_device_winsize, const char *cmd, char * const *argv, char * const *envv, void (*action)(void *data), void *data)
{
	pid_t pid;        /* process id of the coprocess */
	int has_meta;     /* does cmd contain shell meta characters? */

	/* Check arguments */

	if (!pty_user_fd || !pty_device_name || pty_device_name_size < 64 || !cmd)
		return set_errno(EINVAL);

	has_meta = (cmd[strcspn(cmd, SHELL_META_CHARACTERS)] != '\0');

	if ((has_meta && argv) || (!has_meta && !argv))
		return set_errno(EINVAL);

	/* Create pty and child process */

	switch (pid = pty_fork(pty_user_fd, pty_device_name, pty_device_name_size, pty_device_termios, pty_device_winsize))
	{
		case -1:
			return -1;

		case 0:
		{
			/* Adjust process attributes */

			if (action)
				action(data);

			/* Execute co-process */

			do_exec(has_meta, cmd, argv, envv);
			_exit(EXIT_FAILURE);
		}

		default:
			return pid;
	}
}

/*

=item C<int coproc_pty_close(pid_t pid, int *pty_user_fd, const char *pty_device_name)>

Closes the coprocess referred to by C<pid> which must have been obtained
from I<coproc_pty_open(3)>. The coprocess side of the pseudo terminal is
released with I<pty_release(3)> and C<*pty_user_fd> is closed and set to
C<-1> if it is not already C<-1>. The current process will then wait for the
coprocess to terminate by calling I<waitpid(2)>. On success, returns the
status of the child process as determined by I<waitpid(2)>. On error,
returns C<-1> with C<errno> set appropriately. B<Note:> If I<waitpid(2)> is
interrupted by a signal, I<coproc_close(3)> will return C<-1> with C<errno>
set to C<EINTR>. The caller has to call I<coproc_close(3)> (or just
I<waitpid(2)>) again until it succeeds (or until a real error occurs).

=cut

*/

int coproc_pty_close(pid_t pid, int *pty_user_fd, const char *pty_device_name)
{
	int status = 0;

	if (pid <= 0)
		return set_errno(EINVAL);

	if (pty_user_fd && *pty_user_fd != -1)
	{
		pty_release(pty_device_name);
		close(*pty_user_fd);
		*pty_user_fd = -1;
	}

	if (waitpid(pid, &status, 0) == -1)
		return -1;

	return status;
}

/*

=back

=head1 ERRORS

Additional errors may be generated and returned from the underlying system
calls. See their manual pages.

=over 4

=item C<EINVAL>

Invalid arguments were passed to I<coproc_open(3)>, I<coproc_close(3)>,
I<coproc_pty_open(3)> or I<coproc_pty_close(3)>.

=back

=head1 MT-Level

I<MT-Safe> (I<coproc_pty_open(3)> is I<MT-Safe> iff the I<pseudo(3)> module
is I<MT-Safe>).

=head1 EXAMPLES

The following examples add two numbers from the command line using dc as a coprocess
in four different ways.

This version uses pipes and does not use C<sh -c>.

    #include <slack/std.h>
    #include <slack/coproc.h>

    int main(int ac, char **av)
    {
        if (ac == 3)
        {
            char *argv[2] = { "dc", NULL };
            int to, from, err, status;
            char buf[BUFSIZ];
            ssize_t bytes;
            pid_t pid;

            // Start the coprocess (without using sh -c)

            if ((pid = coproc_open(&to, &from, &err, "dc", argv, NULL, NULL, NULL)) == (pid_t)-1)
            {
                fprintf(stderr, "coproc_open(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Send it input and read its output

            snprintf(buf, BUFSIZ, "%s %s + p\n", av[1], av[2]);
            write(to, buf, strlen(buf));
            bytes = read(from, buf, BUFSIZ);
            printf("%*.*s", bytes, bytes, buf);

            // Stop the coprocess (it's ok if you close to, from and/or err beforehand)

            while ((status = coproc_close(pid, &to, &from, &err)) == -1 && errno == EINTR)
            {}

            if (status == -1)
            {
                fprintf(stderr, "coproc_close(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Evaluate its exit status

            if (WIFSIGNALED(status))
            {
                fprintf(stderr, "dc was killed by signal %d\n", WTERMSIG(status));
                return EXIT_FAILURE;
            }

            if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
            {
                fprintf(stderr, "dc was killed by signal %d\n", WEXITSTATUS(status));
                return EXIT_FAILURE;
            }
        }

        return EXIT_SUCCESS;
    }

This version uses pipes and C<sh -c>.

    #include <slack/std.h>
    #include <slack/coproc.h>

    int main(int ac, char **av)
    {
        if (ac == 3)
        {
            int to, from, err, status;
            char buf[BUFSIZ];
            ssize_t bytes;
            pid_t pid;

            // Start the coprocess (using sh -c)

            if ((pid = coproc_open(&to, &from, &err, "dc 2>&1", NULL, NULL, NULL, NULL)) == (pid_t)-1)
            {
                fprintf(stderr, "coproc_open(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Send it input and read its output

            snprintf(buf, BUFSIZ, "%s %s + p\n", av[1], av[2]);
            write(to, buf, strlen(buf));
            bytes = read(from, buf, BUFSIZ);
            printf("%*.*s", bytes, bytes, buf);

            // Stop the coprocess (it's ok if you close to, from and/or err beforehand)

            while ((status = coproc_close(pid, &to, &from, &err)) == -1 && errno == EINTR)
            {}

            if (status == -1)
            {
                fprintf(stderr, "coproc_close(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Evaluate its exit status

            if (WIFSIGNALED(status))
            {
                fprintf(stderr, "dc was killed by signal %d\n", WTERMSIG(status));
                return EXIT_FAILURE;
            }

            if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
            {
                fprintf(stderr, "dc was killed by signal %d\n", WEXITSTATUS(status));
                return EXIT_FAILURE;
            }
        }

        return EXIT_SUCCESS;
    }

This version uses a pseudo terminal and does not use C<sh -c>.

    #include <slack/std.h>
    #include <slack/coproc.h>

    int tty_noecho(int fd)
    {
        struct termios attr[1];

        if (tcgetattr(fd, attr) == -1)
            return -1;

        attr->c_lflag &= ~(ECHO | ECHOE | ECHOK | ECHONL);
	#ifdef ONLCR
        attr->c_oflag &= ~ONLCR;
	#endif

        return tcsetattr(fd, TCSANOW, attr);
    }

    int main(int ac, char **av)
    {
        if (ac == 3)
        {
            char *argv[2] = { "dc", NULL };
            struct termios attr[1];
            char eof = CEOF;
            int pty_user_fd, status;
            char pty_device_name[64];
            char buf[BUFSIZ];
            ssize_t bytes;
            pid_t pid;

            // Start the coprocess (without using sh -c)

            if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "dc", argv, NULL, NULL, NULL)) == (pid_t)-1)
            {
                fprintf(stderr, "coproc_pty_open(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Turn off echo so we don't read back what we are about to write

            if (tty_noecho(pty_user_fd) == -1)
                fprintf(stderr, "tty_noecho(pty_user_fd) failed: %s\n", strerror(errno));

            // Send it input and eof and read its output

            snprintf(buf, BUFSIZ, "%s %s + p\n", av[1], av[2]);
            write(pty_user_fd, buf, strlen(buf));
            if (tcgetattr(pty_user_fd, attr) != -1)
                eof = attr->c_cc[VEOF];
            write(pty_user_fd, &eof, 1);
            while ((bytes = read(pty_user_fd, buf, BUFSIZ)) > 0)
                printf("%*.*s", bytes, bytes, buf);

            if (bytes == -1 && errno != EIO)
                fprintf(stderr, "read(pty_user_fd) failed: %s\n", strerror(errno));

            // Stop the coprocess (pty_user_fd must not be closed beforehand)

            while ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1 && errno == EINTR)
            {}

            if (status == -1)
            {
                fprintf(stderr, "coproc_pty_close(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Evaluate its exit status

            if (WIFSIGNALED(status))
            {
                fprintf(stderr, "dc was killed by signal %d\n", WTERMSIG(status));
                return EXIT_FAILURE;
            }

            if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
            {
                fprintf(stderr, "dc was killed by signal %d\n", WEXITSTATUS(status));
                return EXIT_FAILURE;
            }
        }

        return EXIT_SUCCESS;
    }

This version uses a pseudo terminal and C<sh -c>.

    #include <slack/std.h>
    #include <slack/coproc.h>

    int tty_noecho(int fd)
    {
        struct termios attr[1];

        if (tcgetattr(fd, attr) == -1)
            return -1;

        attr->c_lflag &= ~(ECHO | ECHOE | ECHOK | ECHONL);
	#ifdef ONLCR
        attr->c_oflag &= ~ONLCR;
	#endif

        return tcsetattr(fd, TCSANOW, attr);
    }

    int main(int ac, char **av)
    {
        if (ac == 3)
        {
            int pty_user_fd, status;
            char pty_device_name[64];
            char buf[BUFSIZ];
            struct termios attr[1];
            char eof = CEOF;
            ssize_t bytes;
            pid_t pid;

            // Start the coprocess (without using sh -c)

            if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "dc 2>&1", NULL, NULL, NULL, NULL)) == (pid_t)-1)
            {
                fprintf(stderr, "coproc_pty_open(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Turn off echo so we don't read back what we are about to write

            if (tty_noecho(pty_user_fd) == -1)
                fprintf(stderr, "tty_noecho(pty_user_fd) failed: %s\n", strerror(errno));

            // Send it input and eof and read its output

            snprintf(buf, BUFSIZ, "%s %s + p\n", av[1], av[2]);
            write(pty_user_fd, buf, strlen(buf));
            if (tcgetattr(pty_user_fd, attr) != -1)
                eof = attr->c_cc[VEOF];
            write(pty_user_fd, &eof, 1);
            while ((bytes = read(pty_user_fd, buf, BUFSIZ)) > 0)
                printf("%*.*s", bytes, bytes, buf);

            if (bytes == -1 && errno != EIO)
                fprintf(stderr, "read(pty_user_fd) failed: %s\n", strerror(errno));

            // Stop the coprocess (pty_user_fd must not be closed beforehand)

            while ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1 && errno == EINTR)
            {}

            if (status == -1)
            {
                fprintf(stderr, "coproc_pty_close(dc) failed: %s\n", strerror(errno));
                return EXIT_FAILURE;
            }

            // Evaluate its exit status

            if (WIFSIGNALED(status))
            {
                fprintf(stderr, "dc was killed by signal %d\n", WTERMSIG(status));
                return EXIT_FAILURE;
            }

            if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
            {
                fprintf(stderr, "dc was killed by signal %d\n", WEXITSTATUS(status));
                return EXIT_FAILURE;
            }
        }

        return EXIT_SUCCESS;
    }

=head1 SEE ALSO

I<libslack(3)>,
I<execve(2)>,
I<system(3)>,
I<popen(3)>,
I<waitpid(2)>,
I<sh(1)>,
I<pseudo(3>>

=head1 AUTHOR

20230824 raf <raf@raf.org>

=cut

*/

#endif

#ifdef TEST

#include <fcntl.h>

#include "fio.h"
#include "str.h"

static int cwd_in_path()
{
	const char *path = getenv("PATH");
	const char *s, *r;

	if (!path)
		return 1;

	for (r = path, s = strchr(path, PATH_LIST_SEP); s; r = s, s = strchr(s + 1, PATH_LIST_SEP))
		if ((r == s) || (s - r == 1 && r[0] == '.') || (s - r == 2 && r[0] == ':' && r[1] == '.'))
			return 1;

	if (r[0] == '\0' || (r[0] == ':' && r[1] == '\0') || (r[0] == ':' && r[1] == '.' && r[2] == '\0'))
		return 1;

	return 0;
}

static void print_error_details(char *buf, int bytes, char *expected)
{
	String *qbuf;

	if (bytes == -1)
		printf("(%s)\n", strerror(errno));
	else
	{
		buf[bytes] = '\0';
		qbuf = encode(buf, "\a\b\t\n\v\f\r", "abtnvfr", '\\', 1);
		printf("read <%s> expected <%s>\n", cstr(qbuf), expected);
		str_destroy(&qbuf);
	}
}

int main()
{
	int errors = 0;
	int to, from, err, pty_user_fd;
	int status;
	pid_t pid;
	int fd;
	char *argv[2] = { "cat", NULL };
	char *argv2[5] = { "arkleseizure", "a", "b", "c", NULL };
	char buf[BUFSIZ];
	char pty_device_name[64];
	ssize_t bytes;

	printf("Testing: %s\n", "coproc");

	/* Test coproc_open("cat") - searches path, locating binary executable */

	if ((pid = coproc_open(&to, &from, &err, "cat", argv, NULL, NULL, NULL)) == -1)
		++errors, printf("Test1: coproc_open(\"cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(to, 5, 0) == -1 || write(to, "abc\n", 4) != 4)
			++errors, printf("Test2: write_timeout(to) or write(to, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "def\n", 4) != 4)
			++errors, printf("Test3: write_timeout(to) or write(to, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "ghi\n", 4) != 4)
			++errors, printf("Test4: write_timeout(to) or write(to, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else
		{
			close(to);
			to = -1;

			if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test5: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test6: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "abc\\n");
			}
			else if (memcmp(buf, "abc\n", 4))
				++errors, printf("Test7: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "abc\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test8: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test9: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "def\\n");
			}
			else if (memcmp(buf, "def\n", 4))
				++errors, printf("Test10: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "def\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test11: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test12: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "ghi\\n");
			}
			else if (memcmp(buf, "ghi\n", 4))
				++errors, printf("Test13: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "ghi\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test14: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 0)
			{
				++errors, printf("Test15: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}

			if ((status = coproc_close(pid, &to, &from, &err)) == -1)
				++errors, printf("Test16: coproc_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status))
				++errors, printf("Test17: coproc(\"cat\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
				++errors, printf("Test18: coproc(\"cat\") exited %d\n", WEXITSTATUS(status));
		}
	}

	/* Test coproc_open("cat") - searches path, locating binary executable */

	if ((pid = coproc_open(&to, &from, &err, "cat", argv, NULL, NULL, NULL)) == -1)
		++errors, printf("Test19: coproc_open(\"cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(to, 5, 0) == -1 || write(to, "abc\n", 4) != 4)
			++errors, printf("Test20: write_timeout(to) or write(to, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "def\n", 4) != 4)
			++errors, printf("Test21: write_timeout(to) or write(to, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "ghi\n", 4) != 4)
			++errors, printf("Test22: write_timeout(to) or write(to, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else
		{
			close(to);
			to = -1;

			if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test23: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test24: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "abc\\n");
			}
			else if (memcmp(buf, "abc\n", 4))
				++errors, printf("Test25: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "abc\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test26: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test27: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "def\\n");
			}
			else if (memcmp(buf, "def\n", 4))
				++errors, printf("Test28: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "def\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test29: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test30: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "ghi\\n");
			}
			else if (memcmp(buf, "ghi\n", 4))
				++errors, printf("Test31: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "ghi\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test32: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 0)
			{
				++errors, printf("Test33: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}

			if ((status = coproc_close(pid, &to, &from, &err)) == -1)
				++errors, printf("Test34: coproc_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status))
				++errors, printf("Test35: coproc(\"cat\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
				++errors, printf("Test36: coproc(\"cat\") exited %d\n", WEXITSTATUS(status));
		}
	}

	/* Test coproc_open("/bin/cat") - does not search path */

	if ((pid = coproc_open(&to, &from, &err, "/bin/cat", argv, NULL, NULL, NULL)) == -1)
		++errors, printf("Test37: coproc_open(\"/bin/cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(to, 5, 0) == -1 || write(to, "abc\n", 4) != 4)
			++errors, printf("Test38: write_timeout(to) or write(to, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "def\n", 4) != 4)
			++errors, printf("Test39: write_timeout(to) or write(to, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "ghi\n", 4) != 4)
			++errors, printf("Test40: write_timeout(to) or write(to, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else
		{
			close(to);
			to = -1;

			if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test41: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test42: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "abc\\n");
			}
			else if (memcmp(buf, "abc\n", 4))
				++errors, printf("Test43: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "abc\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test44: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test45: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "def\\n");
			}
			else if (memcmp(buf, "def\n", 4))
				++errors, printf("Test46: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "def\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test47: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test48: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "ghi\\n");
			}
			else if (memcmp(buf, "ghi\n", 4))
				++errors, printf("Test49: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "ghi\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test50: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 0)
			{
				++errors, printf("Test51: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}

			if ((status = coproc_close(pid, &to, &from, &err)) == -1)
				++errors, printf("Test52: coproc_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status))
				++errors, printf("Test53: coproc(\"/bin/cat\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
				++errors, printf("Test54: coproc(\"/bin/cat\") exited %d\n", WEXITSTATUS(status));
		}
	}

	/* Test coproc_open("cat | sort") - uses "sh -c cmd" to handle meta characters */

	if ((pid = coproc_open(&to, &from, &err, "cat | sort", NULL, NULL, NULL, NULL)) == -1)
		++errors, printf("Test55: coproc_open(\"cat | sort\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(to, 5, 0) == -1 || write(to, "ghi\n", 4) != 4)
			++errors, printf("Test56: write_timeout(to) or write(to, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "def\n", 4) != 4)
			++errors, printf("Test57: write_timeout(to) or write(to, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (write_timeout(to, 5, 0) == -1 || write(to, "abc\n", 4) != 4)
			++errors, printf("Test58: write_timeout(to) or write(to, \"abc\\n\") failed (%s)\n", strerror(errno));
		else
		{
			close(to);
			to = -1;

			if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test59: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test60: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "abc\\n");
			}
			else if (memcmp(buf, "abc\n", 4))
				++errors, printf("Test61: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "abc\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test62: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test63: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "def\\n");
			}
			else if (memcmp(buf, "def\n", 4))
				++errors, printf("Test64: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "def\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test65: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 4)
			{
				++errors, printf("Test66: read(from) failed (returned %d, not %d) ", (int)bytes, 4);
				print_error_details(buf, (int)bytes, "ghi\\n");
			}
			else if (memcmp(buf, "ghi\n", 4))
				++errors, printf("Test67: read(from) failed (read \"%.4s\", not \"%.4s\")\n", buf, "ghi\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test68: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, 4)) != 0)
			{
				++errors, printf("Test69: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}

			if ((status = coproc_close(pid, &to, &from, &err)) == -1)
				++errors, printf("Test70: coproc_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status))
				++errors, printf("Test71: coproc(\"cat | sort\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
				++errors, printf("Test72: coproc(\"cat | sort\") exited %d\n", WEXITSTATUS(status));
		}
	}

	/* Test coproc_open() - path search of sh script without #! line (cwd must be in $PATH) */

	if (cwd_in_path())
	{
		if ((fd = open("arkleseizure", O_WRONLY | O_CREAT, 0700)) == -1 || write(fd, "echo $*\n", 8) != 8 || close(fd) == -1)
			++errors, printf("Test73: failed to perform test: open(arkleseizure) failed\n");
		else if ((pid = coproc_open(&to, &from, &err, "arkleseizure", argv2, NULL, NULL, NULL)) == -1)
			++errors, printf("Test74: coproc_open(\"arkleseizure a b c\") failed (%s)\nIs the current directory in $PATH?\n", strerror(errno));
		else
		{
			close(to);
			to = -1;

			if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test75: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, BUFSIZ)) != 6)
			{
				++errors, printf("Test76: read(from) failed (returned %d, not %d) ", (int)bytes, 6);
				print_error_details(buf, (int)bytes, "a b c\\n");
			}
			else if (memcmp(buf, "a b c\n", 6))
				++errors, printf("Test77: read(from) failed (read \"%.6s\", not \"%.6s\")\n", buf, "a b c\n");
			else if (read_timeout(from, 5, 0) == -1)
				++errors, printf("Test78: read_timeout(from) failed (%s)\n", strerror(errno));
			else if ((bytes = read(from, buf, BUFSIZ)) != 0)
			{
				++errors, printf("Test79: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}

			if ((status = coproc_close(pid, &to, &from, &err)) == -1)
				++errors, printf("Test80: coproc_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status))
				++errors, printf("Test81: coproc(\"arkleseizure a b c\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
				++errors, printf("Test82: coproc(\"arkleseizure a b c\") exited %d\n", WEXITSTATUS(status));
		}

		unlink("arkleseizure");
	}

	/* Test coproc_open() - sh script without #! line without path search */

	if ((fd = open("arkleseizure", O_WRONLY | O_CREAT, 0700)) == -1 || write(fd, "echo $*\n", 8) != 8 || close(fd) == -1)
		++errors, printf("Test83: failed to perform test: open(arkleseizure) failed\n");
	else if ((pid = coproc_open(&to, &from, &err, "./arkleseizure", argv2, NULL, NULL, NULL)) == -1)
		++errors, printf("Test84: coproc_open(\"arkleseizure a b c\") failed (%s)\n", strerror(errno));
	else
	{
		close(to);
		to = -1;

		if (read_timeout(from, 5, 0) == -1)
			++errors, printf("Test85: read_timeout(from) failed (%s)\n", strerror(errno));
		else if ((bytes = read(from, buf, BUFSIZ)) != 6)
		{
			++errors, printf("Test86: read(from) failed (returned %d, not %d) ", (int)bytes, 6);
			print_error_details(buf, (int)bytes, "a b c\\n");
		}
		else if (memcmp(buf, "a b c\n", 6))
			++errors, printf("Test87: read(from) failed (read \"%.6s\", not \"%.6s\")\n", buf, "a b c\n");
		else if (read_timeout(from, 5, 0) == -1)
			++errors, printf("Test88: read_timeout(from) failed (%s)\n", strerror(errno));
		else if ((bytes = read(from, buf, BUFSIZ)) != 0)
		{
			++errors, printf("Test89: read(from) failed (returned %d, not %d) ", (int)bytes, 0);
			print_error_details(buf, (int)bytes, "");
		}

		if ((status = coproc_close(pid, &to, &from, &err)) == -1)
			++errors, printf("Test90: coproc_close() failed (%s)\n", strerror(errno));
		else if (WIFSIGNALED(status))
			++errors, printf("Test91: coproc(\"./arkleseizure a b c\") received signal %d\n", WTERMSIG(status));
		else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
			++errors, printf("Test92: coproc(\"./arkleseizure a b c\") exited %d\n", WEXITSTATUS(status));
	}

	unlink("arkleseizure");

	/* Test coproc_open() error reporting */

	if (coproc_open(NULL, &from, &err, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test93: coproc_open(to == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test94: coproc_open(to == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_open(&to, NULL, &err, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test95: coproc_open(from == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test96: coproc_open(from == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_open(&to, &from, NULL, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test97: coproc_open(err == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test98: coproc_open(err == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_open(&to, &from, &err, NULL, argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test99: coproc_open(cmd == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test100: coproc_open(cmd == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_open(&to, &from, &err, "cmd", NULL, NULL, NULL, NULL) != -1)
		++errors, printf("Test101: coproc_open(cmd has no meta but argv is null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test102: coproc_open(cmd has no meta but argv is null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_open(&to, &from, &err, "cmd || cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test103: coproc_open(cmd has meta and argv is not null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test104: coproc_open(cmd has meta but argv is not null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_close(-1, NULL, NULL, NULL) != -1)
		++errors, printf("Test104: coproc_close(pid = -1) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test105: coproc_close(pid = -1) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	/* Test coproc_pty_open("cat") - searches path, locating binary executable */

	if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "cat", argv, NULL, NULL, NULL)) == -1)
		++errors, printf("Test107: coproc_pty_open(\"cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "abc\n", 4) != 4)
			++errors, printf("Test108: write_timeout(pty_user_fd) or write(pty_user_fd, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test109: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5 && bytes != 3) /* CRLF might be missing - why? */
		{
			++errors, printf("Test110: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "abc\\r\\n");
		}
		else if (memcmp(buf, "abc", 4))
			printf("    Warning: Test111: read(pty_user_fd) missing crlf but otherwise ok\n");
		else if (memcmp(buf, "abc\r\n", 5))
			++errors, printf("Test111: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "abc");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "def\n", 4) != 4)
			++errors, printf("Test112: write_timeout(pty_user_fd) or write(pty_user_fd, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test113: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test114: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "def\\r\\n");
		}
		else if (memcmp(buf, "def\r\n", 5))
			++errors, printf("Test115: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "def");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "ghi\n", 4) != 4)
			++errors, printf("Test116: write_timeout(pty_user_fd) or write(pty_user_fd, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test117: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test118: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "ghi\\r\\n");
		}
		else if (memcmp(buf, "ghi\r\n", 5))
			++errors, printf("Test119: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "ghi");

		if ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1)
			++errors, printf("Test120: coproc_pty_close() failed (%s)\n", strerror(errno));
		else if (WIFSIGNALED(status) && WTERMSIG(status) != SIGHUP)
			++errors, printf("Test121: pty coproc(\"cat\") received signal %d\n", WTERMSIG(status));
		else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
			++errors, printf("Test122: pty coproc(\"cat\") exited %d\n", WEXITSTATUS(status));
	}

	/* Test coproc_pty_open("/bin/cat") - does not search path */

	if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "/bin/cat", argv, NULL, NULL, NULL)) == -1)
		++errors, printf("Test123: coproc_pty_open(\"/bin/cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "abc\n", 4) != 4)
			++errors, printf("Test124: write_timeout(pty_user_fd) or write(pty_user_fd, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test125: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5 && bytes != 3) /* CRLF might be missing - why? */
		{
			++errors, printf("Test126: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "abc\\r\\n");
		}
		else if (memcmp(buf, "abc", 4))
			printf("    Warning: Test127: read(pty_user_fd) missing crlf but otherwise ok\n");
		else if (memcmp(buf, "abc\r\n", 5))
			++errors, printf("Test127: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "abc");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "def\n", 4) != 4)
			++errors, printf("Test128: write_timeout(pty_user_fd) or write(pty_user_fd, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test129: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test130: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "def\\r\\n");
		}
		else if (memcmp(buf, "def\r\n", 5))
			++errors, printf("Test131: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "def");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "ghi\n", 4) != 4)
			++errors, printf("Test132: write_timeout(pty_user_fd) or write(pty_user_fd, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test133: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test134: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "ghi\\r\\n");
		}
		else if (memcmp(buf, "ghi\r\n", 5))
			++errors, printf("Test135: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "ghi");

		if ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1)
			++errors, printf("Test136: coproc_pty_close() failed (%s)\n", strerror(errno));
		else if (WIFSIGNALED(status) && WTERMSIG(status) != SIGHUP)
			++errors, printf("Test137: pty coproc(\"/bin/cat\") received signal %d\n", WTERMSIG(status));
		else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
			++errors, printf("Test138: pty coproc(\"/bin/cat\") exited %d\n", WEXITSTATUS(status));
	}

	/* Test coproc_pty_open("cat | cat") - uses "sh -c cmd" to handle meta characters */

	if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "cat | cat", NULL, NULL, NULL, NULL)) == -1)
		++errors, printf("Test139: coproc_pty_open(\"cat | cat\") failed (%s)\n", strerror(errno));
	else
	{
		if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "abc\n", 4) != 4)
			++errors, printf("Test140: write_timeout(pty_user_fd) or write(pty_user_fd, \"abc\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test141: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5 && bytes != 3) /* CRLF might be missing - why? */
		{
			++errors, printf("Test142: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "abc\\r\\n");
		}
		else if (memcmp(buf, "abc", 4))
			printf("    Warning: Test143: read(pty_user_fd) missing crlf but otherwise ok\n");
		else if (memcmp(buf, "abc\r\n", 5))
			++errors, printf("Test143: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "abc");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "def\n", 4) != 4)
			++errors, printf("Test144: write_timeout(pty_user_fd) or write(pty_user_fd, \"def\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test145: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test146: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "def\\r\\n");
		}
		else if (memcmp(buf, "def\r\n", 5))
			++errors, printf("Test147: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "def");
		else if (write_timeout(pty_user_fd, 5, 0) == -1 || write(pty_user_fd, "ghi\n", 4) != 4)
			++errors, printf("Test148: write_timeout(pty_user_fd) or write(pty_user_fd, \"ghi\\n\") failed (%s)\n", strerror(errno));
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test149: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 5)
		{
			++errors, printf("Test150: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 5);
			print_error_details(buf, (int)bytes, "ghi\\r\\n");
		}
		else if (memcmp(buf, "ghi\r\n", 5))
			++errors, printf("Test151: read(pty_user_fd) failed (read \"%.3s\", not \"%.3s\")\n", buf, "ghi");

		if ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1)
			++errors, printf("Test152: coproc_pty_close() failed (%s)\n", strerror(errno));
		else if (WIFSIGNALED(status) && WTERMSIG(status) != SIGHUP)
			++errors, printf("Test153: pty coproc(\"cat | cat\") received signal %d\n", WTERMSIG(status));
		else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS)
			++errors, printf("Test154: pty coproc(\"cat | cat\") exited %d\n", WEXITSTATUS(status));
	}

	/* Test coproc_pty_open() - path search of sh script without #! line (cwd must be in $PATH) */

	if (cwd_in_path())
	{
		if ((fd = open("arkleseizure", O_WRONLY | O_CREAT, 0700)) == -1 || write(fd, "echo $*\n", 8) != 8 || close(fd) == -1)
			++errors, printf("Test155: failed to perform test: open(arkleseizure) failed\n");
		else if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "arkleseizure", argv2, NULL, NULL, NULL)) == -1)
			++errors, printf("Test156: coproc_pty_open(\"arkleseizure a b c\") failed (%s)\nIs the current directory in $PATH?\n", strerror(errno));
		else
		{
			if (read_timeout(pty_user_fd, 5, 0) == -1)
				++errors, printf("Test157: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
			else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 7 && bytes != 5)
			{
				++errors, printf("Test158: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 7);
				print_error_details(buf, (int)bytes, "a b c\\r\\n");
			}
			else if (memcmp(buf, "a b c", 5))
				++errors, printf("Test159: read(pty_user_fd) failed (read \"%.5s\", not \"%.5s\")\n", buf, "a b c");
#ifndef linux
			else if (read_timeout(pty_user_fd, 5, 0) == -1)
				++errors, printf("Test160: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
			else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 0)
			{
				++errors, printf("Test161: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 0);
				print_error_details(buf, (int)bytes, "");
			}
#endif

			if ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1)
				++errors, printf("Test162: coproc_pty_close() failed (%s)\n", strerror(errno));
			else if (WIFSIGNALED(status) && WTERMSIG(status) != SIGHUP)
				++errors, printf("Test163: pty coproc(\"arkleseizure a b c\") received signal %d\n", WTERMSIG(status));
			else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS && WEXITSTATUS(status) != 128 + SIGHUP)
				++errors, printf("Test164: pty coproc(\"arkleseizure a b c\") exited %d\n", WEXITSTATUS(status));
		}

		unlink("arkleseizure");
	}

	/* Test coproc_pty_open() - sh script without #! line without path search */

	if ((fd = open("arkleseizure", O_WRONLY | O_CREAT, 0700)) == -1 || write(fd, "echo $*\n", 8) != 8 || close(fd) == -1)
		++errors, printf("Test165: failed to perform test: open(arkleseizure) failed\n");
	else if ((pid = coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "./arkleseizure", argv2, NULL, NULL, NULL)) == -1)
		++errors, printf("Test166: coproc_pty_open(\"arkleseizure a b c\") failed (%s)\n", strerror(errno));
	else
	{
		if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test167: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 7 && bytes != 5)
		{
			++errors, printf("Test168: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 7);
			print_error_details(buf, (int)bytes, "a b c\\r\\n");
		}
		else if (memcmp(buf, "a b c", 5))
			++errors, printf("Test169: read(pty_user_fd) failed (read \"%.5s\", not \"%.5s\")\n", buf, "a b c");
#ifndef linux
		else if (read_timeout(pty_user_fd, 5, 0) == -1)
			++errors, printf("Test170: read_timeout(pty_user_fd) failed (%s)\n", strerror(errno));
		else if ((bytes = read(pty_user_fd, buf, BUFSIZ)) != 0)
		{
			++errors, printf("Test171: read(pty_user_fd) failed (returned %d, not %d) ", (int)bytes, 0);
			print_error_details(buf, (int)bytes, "");
		}
#endif

		if ((status = coproc_pty_close(pid, &pty_user_fd, pty_device_name)) == -1)
			++errors, printf("Test172: coproc_pty_close() failed (%s)\n", strerror(errno));
		else if (WIFSIGNALED(status) && WTERMSIG(status) != SIGHUP)
			++errors, printf("Test173: pty coproc(\"arkleseizure a b c\") received signal %d\n", WTERMSIG(status));
		else if (WIFEXITED(status) && WEXITSTATUS(status) != EXIT_SUCCESS && WEXITSTATUS(status) != 128 + SIGHUP)
			++errors, printf("Test174: pty coproc(\"arkleseizure a b c\") exited %d\n", WEXITSTATUS(status));
	}

	unlink("arkleseizure");

	/* Test coproc_pty_open() error reporting */

	if (coproc_pty_open(NULL, pty_device_name, 64, NULL, NULL, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test175: coproc_pty_open(pty_user_fd == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test176: coproc_pty_open(pty_user_fd == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_open(&pty_user_fd, NULL, 64, NULL, NULL, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test177: coproc_pty_open(pty_device_name == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test178: coproc_pty_open(pty_device_name == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_open(&pty_user_fd, pty_device_name, 63, NULL, NULL, "cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test179: coproc_pty_open(pty_device_name_size < 64) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test180: coproc_pty_open(pty_device_name_size < 64) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, NULL, argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test181: coproc_pty_open(cmd == null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test182: coproc_pty_open(cmd == null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "cmd", NULL, NULL, NULL, NULL) != -1)
		++errors, printf("Test183: coproc_pty_open(cmd has no meta but argv is null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test184: coproc_pty_open(cmd has no meta but argv is null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_open(&pty_user_fd, pty_device_name, 64, NULL, NULL, "cmd || cmd", argv, NULL, NULL, NULL) != -1)
		++errors, printf("Test185: coproc_pty_open(cmd has meta and argv is not null) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test186: coproc_pty_open(cmd has meta but argv is not null) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (coproc_pty_close(-1, NULL, NULL) != -1)
		++errors, printf("Test187: coproc_pty_close(pid = -1) failed\n");
	else if (errno != EINVAL)
		++errors, printf("Test188: coproc_pty_close(pid = -1) failed (errno == %s, not %s)\n", strerror(errno), strerror(EINVAL));

	if (errors)
		printf("%d/%d tests failed\n", errors, 188);
	else
		printf("All tests passed\n");

	if (!cwd_in_path())
	{
		printf("\n");
		printf("    Note: Can't perform the path search tests.\n");
		printf("    Rerun the test with \".\" in $PATH.\n");
	}

	return EXIT_SUCCESS;
}

#endif

/* vi:set ts=4 sw=4: */