#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#define MAXSTRS 5

int main()
{
  int cntr;
  FILE *pipe_fp;
  char *strings[MAXSTRS] = { "echo", "bravo", "alpha", "charlie", "delta"};
  int i;
  int fds[2];
  pid_t pid;
  int data_processed;
  const char some_data[]="pewnego razu byl sobie jeden ....\n";
  if(pipe(fds)==0)
  {
    pid=fork();
    if(pid==(pid_t)0)
    {
      close(fds[1]);
      dup2(fds[0],0);//STDIN_FILENO
      execlp("sort","sort", 0);
    }
    

    
    else
    {
      FILE *stream;
      close(fds[0]);
      stream=fdopen(fds[1],"w");
      
      for(i=0; i<MAXSTRS;i++) fprintf(stream,"%s\n", strings[i]);

      
      fprintf(stream,"darek\n");
      fprintf(stream,"adam\n");
      fflush(stream);
      
      char b[40];
      sprintf(b,"ls –l /proc/%d/fd", getpid());
      system(b);

      
      close(fds[1]);
    }
  }
  return 0;
}


#include <stdio.h>
#define MAXSTRS 5
int main(void)
{
  int cntr;
  FILE *pipe_fp;
  char *strings[MAXSTRS] = { "echo", "bravo", "alpha", "charlie", "delta"};

  if (( pipe_fp = popen("sort", "w")) == NULL) 
  { 
    perror("popen");
    exit(1); 
  }

  for(cntr=0; cntr<MAXSTRS; cntr++)
  {
    fputs(strings[cntr], pipe_fp);
    fputc('\n', pipe_fp);
  }
  system("ps f");
  pclose(pipe_fp); /* Zamknięcie potoku */
  return(0);
}


#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <errno.h>
#include <string.h>
#define MAXSTRS 5
#define MAX 512

#define 10MEG (1024*1024*10)
#define ROZMIAR_BUF PIPE_BUF

int main(int argc, char *argv[])
{
  
  extern int errno;
  char path[20];
  char komunikat[MAX];
  int infkolejka;
  int open_mode=O_WRONLY;
  int pipe_fd;
  char bufor[ROZMIAR_BUF+1];
  
  if(argc==2) 
    strcpy(path,argv[1]);
  else
    strcpy(path,"/tmp/kolejka");
  
  
    infkolejka=mkfifo(path,0777);
    
  
  if(infkolejka==-1)
    {
      printf("Utworzenie kolejki %s\n",path);
    }
      fprintf(stderr,"Bład mkfifo %s numer %d\n",path,errno);
  
      pipe_fd = open(path, open_mode);
    
      if(pipe_fd!=-1)
      {
	while(wyslane<10MEG)
	  infkolejka = write(pipe_fd, bufor, ROZMIAR_BUF);
	
	  if(infkolejka==-1)
	  {
	    
	    
	  }
	  wyslane+=infkolejka
      }
	

  else{
    exit(1);
  return 0;
}