PIPE PROBLEM AGAIN>>> MORE COMPLEX

Hi all!  Here's the problem... I want to open a file -> write its contents to a pipe -> pass the contents of the pipe to gzip or bzip2 -> give the output of gzip (or bzip2) to another pipe -> write the contents of the last pipe to a new file... This is my code... When I run it it hangs like its waiting for something... I guess there is a problem with a call to read() or something...


int zip(char* sourceFile,char* targetFile, int zipProgram)
{
     char* arg[3];
     
     pid_t fChildPid;
     pid_t sChildPid;

     int pipe1[2];
     int pipe2[2];
     
     pipe(pipe1);
     pipe(pipe2);
     
     if(zipProgram == 1)
          arg[0] = "/bin/gzip";
     else
          arg[0] = "/usr/bin/bzip2";

     arg[1] = "-c";
     arg[2] = NULL;
     
     fChildPid = fork();
     
     if(fChildPid == 0)
     {
         
          dup2(pipe1[R], STD_IN);
          dup2(pipe2[W], STD_OUT);
         
          close(pipe1[W]);
          close(pipe2[R]);

          execv(arg[0], arg);
     }
     else
     {
          sChildPid = fork();
          if(sChildPid == 0)
          {
               close(pipe2[W]);
               close(pipe1[R]);
               close(pipe1[W]);
               
               char buf[BUFFERSIZE] = {0};
               int target = open(targetFile, O_WRONLY | O_APPEND | O_CREAT |
                         S_IRWXU |
                         S_IRWXO |
                         S_IRWXG );    
               int count1;
               
               while((count1 = read(pipe2[R], buf, sizeof(buf))) > 0)
               {
                    write(target, buf, count1);
               }
               
               close(target);
               exit(1);
          }
                else
                {
                    int source = open(sourceFile, O_RDONLY);
                  char buf2[BUFFERSIZE] = {0};
                     int count2;
         
                        close(pipe1[R]);
                  close(pipe2[R]);
                  close(pipe2[W]);
               
                    while((count2 = read(source, buf2, sizeof(buf2))) > 0)
                 {
                     write(pipe1[W], buf2, count2);
                  }
     
                 close(source);
                 wait(&status);
                  }
     }
     return 0;
}

Can anyone see the problem?Start Free Trial