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 <basis/contracts.h>
#include <basis/mutex.h>
#include <processes/ethread.h>

namespace application {


class stdio_redirecter : public virtual basis::root_object
{
public:
  stdio_redirecter(const basis::astring &command, const basis::astring &parameters);

  stdio_redirecter();

  ~stdio_redirecter();

  basis::outcome reset(const basis::astring &command, const basis::astring &parameters);

  DEFINE_CLASS_NAME("stdio_redirecter");

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

  basis::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();

  basis::outcome read(basis::byte_array &received);

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

  basis::outcome write(const basis::astring &to_write, int &written);

  basis::outcome read_stderr(basis::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
  basis::astring *_command;  
  basis::astring *_parms;  
  basis::outcome _persistent_result;  
  processes::ethread *_stdout_reader;  
  processes::ethread *_stderr_reader;  
  basis::byte_array *_stdout_queue;  
  basis::byte_array *_stderr_queue;  
  basis::mutex *_lock;  
  int _process_id;  
  int _exit_value;  

  basis::outcome create_pipes();

  basis::outcome launch_program(int &new_process_id);
};

} //namespace.

#endif