Pipe и все иже с ним

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <wait.h>
#include <sys/stat.h>
 
int main(int argc, char* argv[])
{
  int n, total=0, result=0, finish,temp;
  char filename[256];
  char str[2], strpos[6], strstart[6];
  int position, start=0;
  FILE *in;
  if (argc<4)
    {
      printf("Введите количество дочерних процессов и имя файла\n");
      exit (0);
    }
  n=atoi(argv[2]);
  pid_t pid[n];
  printf("Количество дочерних процессов = %d\n",n );
  strcpy(filename,argv[1]);
  strcat(filename,".txt");
  if ((in=fopen (filename, "r"))==NULL)
    {
      printf("Нельзя открыть исходный файл.\n");
      exit(1);
    }
  fseek (in, 0, SEEK_END);
  int size = ftell(in);
  printf("Размер текстового файла %d байт\n",size );
  int diap=size/n;
  printf ("Размер читаемой области для каждого процесса %d байт\n", diap);
  fclose(in);
 
  for (int i=1; i<=n; i++)
    {
      sprintf (str, "%d", i);
      position=diap*i;
      sprintf (strpos, "%d", position);
      sprintf (strstart, "%d", start);
      pid[i]=fork();
      if (pid[i] == 0)
        {
          if (execl ("./laba3-2", "laba3-2",argv[1],argv[3],str,strpos,strstart, NULL)<0)
            {
              printf( "Создание процесса провалено.\n" );
              exit(0);
            }
        }
      start=atoi(strstart);
      start=start+diap;
    }
 
  sleep (2);
  for (int i=1; i<=n; i++)
    {
      finish=waitpid(pid[i], &result, WNOHANG);
      if (pid[i]==finish)
        {
          printf("Область файла %s.txt проверена процессом %d количество совпадений %d\n",argv[1],pid[i],WEXITSTATUS(result));
          total+=result;
        }
    }
  return 0;
}

#include <stdio.h>
#include   <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
 
int main(int argc, char* argv[])
{
  char filename[256], str[256];
  FILE *in;
  int   count = 0, nomer = 0;
  strcpy(filename,argv[1]);
  strcat(filename,".txt");
  if ((in=fopen (filename, "r"))==NULL)
  {
     printf("Нельзя открыть исходный файл.\n");
     exit(1);
  }
  int nomerproc=atoi(argv[3]);
  int strpos=atoi(argv[4]);
  int strstart=atoi(argv[5]);
  int size=1;
  fseek (in, strstart, SEEK_SET);  
  char line[20];
  strcpy(line,argv[2]);
  while ((size <= strpos) && (!feof(in)))
    {
      fscanf (in, "%s\n", str);
      nomer++;
      if (strcmp(str, line) == 0)
        {
          count++;
          printf("(Процессом с ID : %d) - в файле %s.txt найдено искомое слово в тексте: %s\n",getpid(), argv[1], line);                 
        }
        size = ftell(in);
      }
  fclose(in);
  return count;
}

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <wait.h>
#include <sys/stat.h>
 
int main(int argc, char* argv[])
{
  int n, total=0, result=0, finish;
  char filename[256],line[20];char str[256];
  int position, start=0, count=0;
  FILE *in;
  if (argc<4)
    {
      printf("Введите количество дочерних процессов и имя файла\n");
      exit (0);
    }
  n=atoi(argv[2]);
  pid_t pid[n];
  printf("Количество дочерних процессов = %d\n",n );
  strcpy(filename,argv[1]);
  strcat(filename,".txt");
  if ((in=fopen (filename, "r"))==NULL)
    {
      printf("Нельзя открыть исходный файл.\n");
      exit(1);
    }
  fseek (in, 0, SEEK_END);
  int size = ftell(in);
  printf("Размер текстового файла %d байт\n",size );
  int diap=size/n;
  printf ("Размер читаемой области для каждого процесса %d байт\n", diap);
  strcpy(line,argv[3]);
  for (int i=1; i<=n; i++)
    {    
      pid[i]=fork();
      if (i==1) start=0;
      else start+=diap;
      if (pid[i] == 0)
        {             
          size=1;
          fseek (in, start, SEEK_SET);
          position=diap*i;          
          while ((size <= position) && (!feof(in)))
          {            
            fscanf (in, "%s\n", str);
            if (strcmp(str, line) == 0)
                {
                  count++;
                  printf("(Процессом с ID : %d) - в файле %s.txt найдено искомое слово в тексте: %s\n",getpid(), argv[1], line);
                }
            size = ftell(in);
          }                       
          return count;  
        }       
    }    
  sleep (1);
  for (int i=1; i<=n; i++)
    {
      finish=waitpid(pid[i], &result, WNOHANG);
      if (pid[i]==finish)
        {
          printf("Область файла %s.txt проверена процессом %d количество совпадений %d\n",argv[1],pid[i],WEXITSTATUS(result));
          total+=result;
        }
    }   
    fclose(in); 
  return 0;
}

#define _GNU_SOURCE
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <malloc.h>
#include <sys/wait.h>
 
int main (int ac, char *av[]) {
  if (ac != 4) {
    printf ("Фомтат вызова: %s кол-во_процессов файл подстрока\n", av[0]);
    return 0;
  }
  FILE *f= fopen (av[2], "r");
  if (!f) return -1;
  int p_count= atoi (av[1]);
  int (*pd)[2]= malloc (p_count * sizeof(int[2])); // пайпы по кол-ву дочерних процессов
  int np;
  for ( np= 0; np < p_count; np++) {
    if (pipe (pd[np])) return -1;
    if (!fork()) break;
    close (pd[np][0]);
  }
  if (np == p_count) {
    char *lp= 0;
    size_t n= 0;
    int sz;
    for (np= 0; (sz= getline (&lp, &n, f)) > 0; np++) {
      if (np == p_count) np= 0;
      if (write (pd[np][1], lp, sz) != sz) return -1;
    }
    for (np= 0; np < p_count; np++) close (pd[np][1]);
    for (np= 0; np < p_count; np++)  wait(0);
  }
  else {
    close (pd[np][1]);
    char *buf= malloc (1000);
    int count= 0;
    for (int n= 0; read (pd[np][0], buf+n, 1) == 1 && n < 1000; n++) {
      if (*(buf+n) && *(buf+n) != '\n') continue;
      *(buf+n)= 0; n= -1;
      if (strstr (buf, av[3])) ++count;
    }
    free (buf);
    close (pd[np][0]);
    printf ( "Процесс %d: Кол-во совпадений - %d\n", getpid(), count);
  }
  return 0;
}

(sz= getline (&lp, &n, f)) > 0;

if (isalnum(*(buf+n))) continue;

for (int n= 0; read (pd[np][0], buf+n, 1) == 1 && n < 1000; n++) { 
                                               // чтение из пайпа  в буфер по одному символу
  if (*(buf+n) && *(buf+n) != '\n') continue;  // если это не 0 и не '\n' читаем слудующий
  (buf+n)= 0; n= -1;                           // иначе заканчиваем строку в буфере
  if (strstr (buf, av[3])) ++count;            // не является ли заданное слово подстрокой строки в буфере
}

    for (int n= 0; read (pd[np][0], buf+n, 1) == 1; n++) {
      if (isalnum(buf[n])) continue;
      buf[n]= 0; n= -1;
      if (!strcmp (buf, av[3])) ++count;
    }

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <wait.h>
#include <sys/stat.h>
 
int main(int argc, char* argv[])
{
  FILE *in;
  if (argc<3)
    {
      printf("Введите количество дочерних процессов и имя файла\n");
      exit (0);
    }
    char filename[256];
  int n=atoi(argv[2]);
  pid_t pid[n];
  int fd[2];
  printf("Количество дочерних процессов = %d\n",n );
  strcpy(filename,argv[1]);
  strcat(filename,".txt");
  if ((in=fopen (filename, "r"))==NULL)
    {
      printf("Нельзя открыть исходный файл.\n");
      exit(1);
    }
  if(pipe (fd)<0) {printf("Не могу создать канал\n");exit (0);}
printf("Родитель  %d\n", getpid() );
  char mas[256];
  for (int i=1; i<=n; i++)
    {    
      
     close (fd[0]);
      fgets (mas,256,in);
      //printf("Родитель %s\n %d\n",mas, getpid() );
      int size;
      size=write (fd[1], mas,10);
      printf("%d\n",size );
      close (fd[1]);
      pid[i]=fork();
      if (pid[i]==0)
        { 
          //printf("Дочка %s\n, %d\n",mas, getpid() );
          char remas[256];
          close (fd[1]);
          read (fd[0], remas, 10);
          printf("Дочка %s\n, %d\n",remas, getpid() );
          exit (-1);
          close(fd[0]);
        }
      else {printf("не могу создать дочерний процесс вернулосб %d\n", pid[i]); exit (0);}       
    }    
  sleep (3);
  //wait (0);
  for (int i=1; i<=1; i++)
    {
      waitpid(pid[i], NULL, WNOHANG);
    }  
    fclose(in); 
  return 0;
}