CoProc.h

Go to the documentation of this file.

// $Id: CoProc.h,v 1.2 2013/08/20 21:56:51 eml Exp $

#ifndef SZA_UTIL_COPROC_H
#define SZA_UTIL_COPROC_H

#include <iostream>
#include <vector>

namespace sza {
  namespace util {

    class CoProc;

    // Define a class for managing a spawned process whose stdout and
    // stderr are captured by the parent

    class CoProc {
    public:

      class Pipe {

      public:

        ~Pipe();

        FILE* readFp();
        FILE* writeFp();

        int readFd();
        int writeFd();

        void closeForWrite();
        void closeForRead();

        void close();

      private:

        friend class CoProc;

        int fd_[2];     // pair of file descriptors

        Pipe();
      };

      CoProc(std::string exe);

      CoProc(char *exe);

      CoProc(char *exe, FILE** stdInFp, FILE** stdOutFp, FILE** stdErrFp);

      CoProc(char *exe, char** argv, 
             FILE** stdInFp, FILE** stdOutFp, FILE** stdErrFp);

      void fork(char *exe, char** argv, 
                FILE** stdInFp, FILE** stdOutFp, FILE** stdErrFp);

      CoProc::Pipe* getPipe();

      CoProc::Pipe* stdIn();
      CoProc::Pipe* stdOut();
      CoProc::Pipe* stdErr();

      virtual ~CoProc();
      
      // Split a command string into separate tokens

      static std::vector<std::string> split(std::string command);

      int readFd();
      int writeFd();

    private:

      int pid_;
      CoProc::Pipe* stdIn_;
      CoProc::Pipe* stdOut_;
      CoProc::Pipe* stdErr_;

    }; // End class CoProc
    
  } // End namespace util
} // End namespace sza



#endif // End #ifndef SZA_UTIL_COPROC_H