//bench/bw_pxmsg.c
void
writer(int contfd, mqd_t mqsend)
{
	int		ntowrite;

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

		while (ntowrite > 0) {
			Mq_send(mqsend, buf, xfersize, 0);
			ntowrite -= xfersize;
		}
	}
}

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

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

	while ((nbytes > 0) &&
		   ( (n = Mq_receive(mqrecv, buf, xfersize, NULL)) > 0)) {
		nbytes -= n;
	}
}
