redirecter.h

Go to the documentation of this file.

#ifndef STDIO_REDIRECTER_CLASS
#define STDIO_REDIRECTER_CLASS

/*****************************************************************************\
*                                                                             *
*  Name   : stdio_redirecter                                                  *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 2005-$now By Author.  This program 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.  This is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include "opsysdll.h"

#include <basis/object_base.h>

// forward.
class ithread;


class OPSYSTEM_CLASS_STYLE stdio_redirecter
: public virtual object_base
{
public:
  stdio_redirecter(const istring &command, const istring &parameters);

  stdio_redirecter();

  ~stdio_redirecter();

  outcome reset(const istring &command, const istring &parameters);

  IMPLEMENT_CLASS_NAME("stdio_redirecter");

  enum outcomes {
    OKAY = common::OKAY,
    NOT_FOUND = common::NOT_FOUND,  
    NONE_READY = common::NONE_READY,  
    PARTIAL = common::PARTIAL,  
    ACCESS_DENIED = common::ACCESS_DENIED  
  };

  outcome health() const { return _persistent_result; }

  bool running();

  int exit_value() const { return _exit_value; }

  int process_id() const { return _process_id; }

  void zap_program();

  outcome read(byte_array &received);

  outcome write(const byte_array &to_write, int &written);

  outcome write(const istring &to_write, int &written);

  outcome read_stderr(byte_array &received);

  void close_input();

  // internal use only...

  void std_thread_action(bool is_stdout);

private:
#ifdef __UNIX__
  int _output_fds[2];  
  int _input_fds[2];  
  int _stderr_fds[2];  
#endif
#ifdef __WIN32__
  void *_child_in, *_child_out, *_child_err;  
  void *_parent_in, *_parent_out, *_parent_err;  
  void *_app_handle;  
#endif
  istring *_command;  
  istring *_parms;  
  outcome _persistent_result;  
  ithread *_stdout_reader;  
  ithread *_stderr_reader;  
  byte_array *_stdout_queue;  
  byte_array *_stderr_queue;  
  mutex *_lock;  
  int _process_id;  
  int _exit_value;  

  outcome create_pipes();

  outcome launch_program(int &new_process_id);
};

#endif

---