pipe.h

Go to the documentation of this file.

//
// Copyright (c) 2000-2004 California Institute of Technology
// Copyright (c) 2004-2007 University of Southern California
// Rob Peters <rjpeters at usc dot edu>
//
// created: Fri Jan 14 17:33:24 2000
// commit: $Id: pipe.h 10065 2007-04-12 05:54:56Z rjpeters $
// $HeadURL: file:///lab/rjpeters/svnrepo/code/trunk/groovx/src/rutz/pipe.h $
//
// --------------------------------------------------------------------
//
// This file is part of GroovX.
//   [http://ilab.usc.edu/rjpeters/groovx/]
//
// GroovX is free software; you can redistribute it and/or modify it
// under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// GroovX is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with GroovX; if not, write to the Free Software Foundation,
// Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
//

#ifndef GROOVX_RUTZ_PIPE_H_UTC20050626084019_DEFINED
#define GROOVX_RUTZ_PIPE_H_UTC20050626084019_DEFINED

#include "rutz/stdiobuf.h"

#include <cstdio>
#include <istream>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>

namespace rutz
{
  class shell_pipe;
  class pipe_fds;
  class child_process;
  class exec_pipe;
  class bidir_pipe;
}

class rutz::shell_pipe
{
public:
  shell_pipe(const char* command, const char* mode);

  ~shell_pipe();

  std::iostream& stream() { return m_stream; }

  int close();

  bool is_closed() const { return (m_file == 0) || !m_stream.is_open(); }

  int exit_status() const { return m_exit_status; }

private:
  shell_pipe(const shell_pipe&);
  shell_pipe& operator=(const shell_pipe&);

  FILE*             m_file;
  rutz::stdiostream m_stream;
  int               m_exit_status;
};

class rutz::pipe_fds
{
public:

  pipe_fds();

  ~pipe_fds() throw();

  int reader() const throw() { return m_fds[0]; }
  int writer() const throw() { return m_fds[1]; }

  void close_reader() throw() { if (m_fds[0] >= 0) close(m_fds[0]); m_fds[0] = -1; }
  void close_writer() throw() { if (m_fds[1] >= 0) close(m_fds[1]); m_fds[1] = -1; }

private:
  pipe_fds(const pipe_fds&);
  pipe_fds& operator=(const pipe_fds&);

  int m_fds[2]; // reading == m_fds[0], writing == m_fds[1]
};

class rutz::child_process
{
public:

  child_process();

  ~child_process() throw();

  bool in_parent() const throw() { return m_pid != 0; }

  int wait() throw();

private:
  child_process(const child_process&);
  child_process& operator=(const child_process&);

  int m_child_status;
  pid_t m_pid;
};


class rutz::exec_pipe
{
private:
  void init(char* const* argv);

public:

  exec_pipe(const char* m, char* const* argv);


  exec_pipe(const char* m, const char* argv0, ...);

  ~exec_pipe() throw();

  std::iostream& stream() throw();

  void close();

  int exit_status() throw();

private:
  bool               m_parent_is_reader;
  pipe_fds           m_fds;
  child_process      m_child;
  rutz::stdiostream* m_stream;
};


class rutz::bidir_pipe
{
public:
  bidir_pipe();


  bidir_pipe(char* const* argv);


  bidir_pipe(const char* argv0, ...);

  ~bidir_pipe() throw();


  void block_child_sigint();


  void init(char* const* argv);


  void init(const char* argv0, ...);

  std::iostream& in_stream() throw();

  std::iostream& out_stream() throw();

  void close_in();

  void close_out();

  int exit_status() throw();

private:
  bidir_pipe(const bidir_pipe&); // not implemented
  bidir_pipe& operator=(const bidir_pipe&); // not implemented

  pipe_fds           m_in_pipe;
  pipe_fds           m_out_pipe;
  child_process      m_child;
  rutz::stdiostream* m_in_stream;
  rutz::stdiostream* m_out_stream;
  bool               m_block_child_sigint;
};

static const char __attribute__((used)) vcid_groovx_rutz_pipe_h_utc20050626084019[] = "$Id: pipe.h 10065 2007-04-12 05:54:56Z rjpeters $ $HeadURL: file:
#endif // !GROOVX_RUTZ_PIPE_H_UTC20050626084019_DEFINED

---

The software described here is Copyright (c) 1998-2005, Rob Peters.
This page was generated Wed Dec 3 06:49:40 2008 by Doxygen version 1.5.5.