Synchronisation de deux processus

#include <unistd.h> 
#include <stdio.h> 
#include <signal.h>
#include <stdlib.h>
#include <string.h>

#define FALSE 0
#define TRUE !FALSE
#define SIZE 80

int main() 
{
	int fd1_a[2]; /* Pipe fils 1 aller */
	int fd1_r[2]; /* Pipe fils 1 retour */
	int fd2_a[2]; /* Pipe fils 2 aller */
	int fd2_r[2]; /* Pipe fils 2 retour */

	int i = 0;
	int n;
	char buffer[SIZE];
	int pid;
	
	strcpy(buffer, "msg");
	
	/* Création des pipes du fils 1 */
	pipe(fd1_a);
	pipe(fd1_r);

	/* Père */
	if(fork()) 
	{
		/* Pipe fils 1 : 1er pour écrire, 2e pour lire */
		close(fd1_a[0]);
		close(fd1_r[1]);
	}
	/* Fils 1 */
	else
	{
		i = 1;
		fd_set rfds1;

		/* 1er pipe pour lire et 2e pour écrire */
		close(fd1_a[1]);
		close(fd1_r[0]);

		while(TRUE) 
		{
			if(i > 20)
			{
				exit(EXIT_SUCCESS);
			}
			
			FD_ZERO(&rfds1);
			FD_SET(fd1_a[0], &rfds1);

			select(fd1_a[0] + 1, &rfds1, NULL, NULL, NULL);
			n = read(fd1_a[0], buffer, SIZE);
			printf("Fils 1 (pid %d) : %d\n", getpid(), i); 
			i += 2;
			write(fd1_r[1], buffer, n);
		} 
	}
	
	/* Création des pipes du fils 2 */
	pipe(fd2_a);
	pipe(fd2_r);
	
	/* Fils 2 */
	if(fork()) 
	{
		/* Pipe fils 2 : 1er pour écrire, 2e pour lire */
		close(fd2_a[0]);
		close(fd2_r[1]);
	}
	else
	{
		i = 2;
		fd_set rfds2;

		/* 1er pipe pour lire et 2e pour écrire */
		close(fd2_a[1]);
		close(fd2_r[0]);

		while(TRUE) 
		{
			if(i > 20)
			{
				exit(EXIT_SUCCESS);
			}
			
			FD_ZERO(&rfds2);
			FD_SET(fd2_a[0], &rfds2);
			
			select(fd2_a[0] + 1, &rfds2, NULL, NULL, NULL);
			n = read(fd2_a[0], buffer, SIZE);
			printf("Fils 2 (pid %d) : %d\n", getpid(), i); 
			i += 2;
			write(fd2_r[1], buffer, n);
		}
	}

	/* Père */
	
	/* Pour amorcer on lance un premier message chez le fils 1 */
	write(fd1_a[1], buffer, SIZE);
	
	while(TRUE)
	{
		int max;
		fd_set rfds;
		FD_ZERO(&rfds);
		
		FD_SET(fd1_r[0], &rfds);
		FD_SET(fd2_r[0], &rfds);
		
		max = fd1_r[0] > fd2_r[0] ? fd1_r[0] : fd2_r[0];
	
		select(max + 1, &rfds, NULL, NULL, NULL);
		
		if(FD_ISSET(fd1_r[0], &rfds))
		{
			/* Si on reçoit un message du fils 1, on envoie au fils 2 */
			n = read(fd1_r[0], buffer, SIZE);
			if(!n) exit(EXIT_SUCCESS);
			write(fd2_a[1], buffer, n);
		}
		else
		{
			/* Si on reçoit un message du fils 2, on envoie au fils 1 */
			n = read(fd2_r[0], buffer, SIZE);
			if(!n) exit(EXIT_SUCCESS);
			write(fd1_a[1], buffer, n);
		}
	}	
}