Re: [RFC][PATCH][cryo] Read/print contents of fifo

["Serge E. Hallyn" <serue-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org>]

Quoting sukadev-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org (sukadev-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org):
> 
> >From 0f5b3ea20238e0704a71252a3d495ca0db61e1dc Mon Sep 17 00:00:00 2001
> From: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org>
> Date: Sat, 14 Jun 2008 11:45:00 -0700
> Subject: [RFC][PATCH] Read/print contents of fifo.
> 
> To test that checkpoint/restart of pipes is working, read
> one byte at a time from the pipe and write to stdout.
> 
> After checkpoint, both the checkpointed application and the
> restarted application should continue reading from the checkpoint.
> 
> The '-e' option to the program, tests with an empty pipe.
> 
> Signed-off-by: Sukadev Bhattiprolu <sukadev-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org>

Thanks, will apply to the git tree tonight.

-serge

> ---
>  tests/pipe.c |   32 ++++++++++++++++++++++++++++----
>  1 files changed, 28 insertions(+), 4 deletions(-)
> 
> diff --git a/tests/pipe.c b/tests/pipe.c
> index cc3cdfd..0812cb3 100644
> --- a/tests/pipe.c
> +++ b/tests/pipe.c
> @@ -3,25 +3,49 @@
>  #include <unistd.h>
>  #include <stdlib.h>
>  #include <string.h>
> +#include <errno.h>
> +#include <sys/fcntl.h>
> 
> -int main()
> +int main(int argc, char *argv[])
>  {
>  	int i = 0;
> +	int rc;
>  	int fds[2];
> +	int c;
> +	int empty;
>  	char *buf = "abcdefghijklmnopqrstuvwxyz";
> 
> +	/*
> +	 * -e: test with an empty pipe
> +	 */
> +	empty = 0;
> +	if (argc > 1 && strcmp(argv[1], "-e") == 0)
> +		empty = 1;
> +
>  	if (pipe(fds) < 0) {
>  		perror("pipe()");
>  		exit(1);
>  	}
> 
> -	write(fds[1], buf, strlen(buf));
> +	if (!empty)
> +		write(fds[1], buf, strlen(buf));
> 
> +	if (fcntl(fds[0], F_SETFL, O_NONBLOCK) < 0) {
> +		perror("fcntl()");
> +		exit(1);
> +	}
>  	printf("Running as %d\n", getpid());
>  	while (i<100) {
>  		sleep(1);
> -		if (i%5 == 0)
> -			printf("i is %d (pid %d)\n", i, getpid());
> +		if (i%5 == 0) {
> +			c = errno = 0;
> +			rc = read(fds[0], &c, 1);
> +			if (rc != 1) {
> +				perror("read() failed");
> +			}
> +			printf("i is %d (pid %d), c is %c\n", i, getpid(), c);
> +
> +		}
>  		i++;
>  	}
>  }
> -- 
> 1.5.2.5