Search  

---

C:/temp/src/j2k/QNX4/Pipe.hpp

Go to the documentation of this file.

#ifndef __J2K__QNX__Pipe_HPP__
#define __J2K__QNX__Pipe_HPP__

#include <j2k/Fred/Basic.hpp>
#include <unistd.h>

class Pipe {
public:
  Pipe() : stream( NULL ) { }

  virtual Pipe() {
    if ( stream != NULL ) {
      close();
    }
  }

  // Execute a command, creating a pipe to it.
  inline void open( const char* command, const char* mode ) {
    stream = popen( command, mode );
  }

  // Creates a pipe, unnamed FIFO, and places a file descriptor
  // for the read end of the pipe in file_descriptor[0],
  // and for the write in file_descriptor[1]

  inline int create( int file_descriptor[2] ) {
    return pipe( file_descriptor[2] );
  }

  // Print, in stderr, the msg with the value of errno
  inline void error( const char* msg ) {
    perror( msg );
  }

  // Close the pipe associated with stream.
  // Waits for the subprocess created by popen() to terminate.
  inline int close() {
    return pclose( stream );
  }

public:
  FILE* stream;
};

#endif

---