lib/base/console.h

   1 #ifndef __LIB_BASE_CONSOLE_H__
   2 #define __LIB_BASE_CONSOLE_H__
   3
   4 #include <string>
   5 #include <lib/base/ebase.h>
   6 #include <lib/python/connections.h>
   7 #include <queue>
   8
   9 struct queue_data
  10 {
  11         queue_data( char *data, int len )
  12                 :data(data), len(len), dataSent(0)
  13         {
  14         }
  15         char *data;
  16         int len;
  17         int dataSent;
  18 };
  19
  20 class eConsoleAppContainer: public Object, public iObject
  21 {
  22         DECLARE_REF(eConsoleAppContainer);
  23         int fd[3];
  24         int filefd[3];
  25         int pid;
  26         int killstate;
  27         std::string m_cwd;
  28         std::queue<struct queue_data> outbuf;
  29         ePtr<eSocketNotifier> in, out, err;
  30         void readyRead(int what);
  31         void readyErrRead(int what);
  32         void readyWrite(int what);
  33         void closePipes();
  34 public:
  35         eConsoleAppContainer();
  36         ~eConsoleAppContainer();
  37         int setCWD( const char *path );
  38         int execute( const char *str );
  39         int execute( const char *cmdline, const char *const argv[] );
  40         int getPID() { return pid; }
  41         void kill();
  42         void sendCtrlC();
  43         void sendEOF();
  44         void write( const char *data, int len );
  45         void setFileFD(int num, int fd) { if (num >= 0 && num <= 2) filefd[num] = fd; }
  46         bool running() { return (fd[0]!=-1) && (fd[1]!=-1) && (fd[2]!=-1); }
  47         PSignal1<void, const char*> dataAvail;
  48         PSignal1<void, const char*> stdoutAvail;
  49         PSignal1<void, const char*> stderrAvail;
  50         PSignal1<void,int> dataSent;
  51         PSignal1<void,int> appClosed;
  52 };
  53
  54 #endif // __LIB_BASE_CONSOLE_H__