#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <limits.h>
#include <errno.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
#include <stdlib.h>


#define FIFO_NAME "/tmp/moje_fifo5"

#define BUFFER_SIZE PIPE_BUF
int main(int argc , char *argv[])
{
  int res;
  int pipe_fd;
  int open_mode=O_RDONLY;
  char bufor[BUFFER_SIZE+1];
  int zczytane=0;
  char buf[20];
  int a,b;
  short int status = 0;

  memset(bufor,'\0',sizeof(bufor));

  if(access(FIFO_NAME, F_OK)==-1)
  {

    res=mkfifo(FIFO_NAME,0666);

    if(res ==0) printf("Kolejka FIFO utworzona\n");
    else
    {
      printf("B??d %d - %s tworzenia kolejki %s\n",errno,strerror(errno),FIFO_NAME);
      exit(1);
    }
  }
  printf("Proces %d otwiera FIFO \n",getpid());


  pipe_fd=open(FIFO_NAME,open_mode);
  printf("proces %d warto?c %d\n", getpid(),pipe_fd);

  sprintf(buf,"ls -l /proc/%d/fd",getpid());
  system(buf);

  if(pipe_fd!=-1)
  {
    do{
      res=read(pipe_fd,bufor,BUFFER_SIZE);

      zczytane+=res;
      if(status == 0){
    a = atoi(bufor);
    status = 1;
    printf("zawartosc : %s\n",bufor);
      }
      else{
    b = atoi(bufor);
    status = 0;
    printf("zawartosc : %s\n",bufor);
    printf("Suma = %d \n", a+b);
      }

      write(pipe_fd, bufor,1024);

    }while(res>0);

    close(pipe_fd);
  }
  else
    exit(1);

  printf("proces %d zko?czony zczytano %d\n", getpid(),zczytane);


return 0;
}

=====================================================================================
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <limits.h>
#include <errno.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>


#define FIFO_NAME "/tmp/moje_fifo5"
#define BUFFER_SIZE PIPE_BUF
#define TEN_MEG 1024*1024

int main(int argc , char *argv[])
{
  int res;
  int pipe_fd;
  int open_mode=O_WRONLY;
  char bufor[BUFFER_SIZE+1];
  int bytes_send=0;

  memset(bufor,'\0',sizeof(bufor));

 // strcpy(bufor,"ala ma");

  printf("%s\n",bufor);


  if(access(FIFO_NAME, F_OK)==-1)
  {

    res=mkfifo(FIFO_NAME,0666);

    if(res ==0) printf("Kolejka FIFO utworzona\n");
    else
    {
      printf("Blad %d - %s tworzenia kolejki %s\n",errno,strerror(errno),FIFO_NAME);
    }
  }
  printf("Proces %d otwiera FIFO\n",getpid());


  pipe_fd=open(FIFO_NAME,open_mode);
  printf("proces %d wartosc %d\n", getpid(),pipe_fd);


  if(pipe_fd!=-1)
  {
   while(bytes_send<TEN_MEG)
    {
      printf("Podaj a:\n");
      fgets(bufor,BUFFER_SIZE, stdin);

      res=write(pipe_fd,bufor,BUFFER_SIZE);
       printf("nadano %d  - bufor :%s\n",res, bufor);

      printf("Podaj b:\n");
      fgets(bufor,BUFFER_SIZE, stdin);;


      printf("bufor:%s\n",bufor);

      res=write(pipe_fd,bufor,BUFFER_SIZE);
       printf("nadano %d  - bufor :%s\n",res, bufor);

      if(res==-1)
      {
    fprintf(stderr,"Blad zapisu do kolejki FIFO %d %s",errno, strerror(errno));
      }
      bytes_send+=res;

    }
    close(pipe_fd);
  }
  else
    ;




  printf("proces %d zkonczony nadano %d\n", getpid(),bytes_send);


return 0;
}