//bench/bw_pipe.cvoid
void
writer(int contfd, int datafd)
{
	int		ntowrite;

	for ( ; ; ) {
		Read(contfd, &ntowrite, sizeof(ntowrite));

		while (ntowrite > 0) {
			Write(datafd, buf, xfersize);
			ntowrite -= xfersize;
		}
	}
}

void
reader(int contfd, int datafd, int nbytes)
{
	ssize_t	n;

	Write(contfd, &nbytes, sizeof(nbytes));

	while ((nbytes > 0) &&
		   ( (n = Read(datafd, buf, xfersize)) > 0)) {
		nbytes -= n;
	}
}
