console.h

Go to the documentation of this file.

#ifndef __LIB_BASE_CONSOLE_H__
#define __LIB_BASE_CONSOLE_H__
 
#include <string>
#include <lib/base/ebase.h>
#include <lib/python/connections.h>
#include <queue>
#include <vector>
#include <utility>
 
struct queue_data
{
  queue_data( char *data, int len )
    :data(data), len(len), dataSent(0)
  {
  }
  char *data;
  int len;
  int dataSent;
};
 
class eConsoleAppContainer: public sigc::trackable, public iObject
{
  DECLARE_REF(eConsoleAppContainer);
  int fd[3];
  int filefd[3];
  int pid;
  int killstate;
  std::string m_cwd;
  std::queue<struct queue_data> outbuf;
  ePtr<eSocketNotifier> in, out, err;
  std::vector<char> buffer;
  int m_nice = -1;
  int m_ionice = -1;
  void readyRead(int what);
  void readyErrRead(int what);
  void readyWrite(int what);
  void closePipes();
public:
  eConsoleAppContainer();
  ~eConsoleAppContainer();
  int setCWD( const char *path );
  void setBufferSize(int size);
  void setNice(int nice) { m_nice = nice;}
  void setIONice(int ionice) { m_ionice = ionice;}
  int execute( const char *str );
  int execute( const char *cmdline, const char *const argv[] );
  int getPID() { return pid; }
  void kill();
  void sendCtrlC();
  void sendEOF();
  void write( const char *data, int len );
  void setFileFD(int num, int fd) { if (num >= 0 && num <= 2) filefd[num] = fd; }
  bool running() { return (fd[0]!=-1) && (fd[1]!=-1) && (fd[2]!=-1); }
  PSignal1<void, std::pair<const char*, int> > dataAvail;
  PSignal1<void, std::pair<const char*, int> > stdoutAvail;
  PSignal1<void, std::pair<const char*, int> > stderrAvail;
  PSignal1<void,int> dataSent;
  PSignal1<void,int> appClosed;
};
 
#endif // __LIB_BASE_CONSOLE_H__