diff options
| author | Mike Buland <eichlan@xagasoft.com> | 2012-03-25 20:00:08 +0000 |
|---|---|---|
| committer | Mike Buland <eichlan@xagasoft.com> | 2012-03-25 20:00:08 +0000 |
| commit | 469bbcf0701e1eb8a6670c23145b0da87357e178 (patch) | |
| tree | b5b062a16e46a6c5d3410b4e574cd0cc09057211 /src/stable/process.h | |
| parent | ee1b79396076edc4e30aefb285fada03bb45e80d (diff) | |
| download | libbu++-469bbcf0701e1eb8a6670c23145b0da87357e178.tar.gz libbu++-469bbcf0701e1eb8a6670c23145b0da87357e178.tar.bz2 libbu++-469bbcf0701e1eb8a6670c23145b0da87357e178.tar.xz libbu++-469bbcf0701e1eb8a6670c23145b0da87357e178.zip | |
Code is all reorganized. We're about ready to release. I should write up a
little explenation of the arrangement.
Diffstat (limited to 'src/stable/process.h')
| -rw-r--r-- | src/stable/process.h | 153 |
1 files changed, 153 insertions, 0 deletions
diff --git a/src/stable/process.h b/src/stable/process.h new file mode 100644 index 0000000..d6282e0 --- /dev/null +++ b/src/stable/process.h | |||
| @@ -0,0 +1,153 @@ | |||
| 1 | /* | ||
| 2 | * Copyright (C) 2007-2011 Xagasoft, All rights reserved. | ||
| 3 | * | ||
| 4 | * This file is part of the libbu++ library and is released under the | ||
| 5 | * terms of the license contained in the file LICENSE. | ||
| 6 | */ | ||
| 7 | |||
| 8 | #ifndef BU_PROCESS_H | ||
| 9 | #define BU_PROCESS_H | ||
| 10 | |||
| 11 | #include <stdint.h> | ||
| 12 | #include <sys/types.h> | ||
| 13 | |||
| 14 | #include "bu/stream.h" | ||
| 15 | #include "bu/string.h" | ||
| 16 | |||
| 17 | namespace Bu | ||
| 18 | { | ||
| 19 | /** | ||
| 20 | * Runs a program and attaches streams to it's stdin, stdout, and stderr. | ||
| 21 | * Reading from a Bu::Process will read from the program's standard output, | ||
| 22 | * writing to a Bu::Process will write to the program's standard input. | ||
| 23 | */ | ||
| 24 | class Process : public Bu::Stream | ||
| 25 | { | ||
| 26 | public: | ||
| 27 | enum Flags | ||
| 28 | { | ||
| 29 | None = 0x00, | ||
| 30 | StdOut = 0x01, | ||
| 31 | StdErr = 0x02, | ||
| 32 | Both = 0x03 | ||
| 33 | }; | ||
| 34 | |||
| 35 | public: | ||
| 36 | class Options | ||
| 37 | { | ||
| 38 | public: | ||
| 39 | enum OptFlags | ||
| 40 | { | ||
| 41 | None = 0x00, | ||
| 42 | SetUid = 0x01, | ||
| 43 | SetGid = 0x02, | ||
| 44 | }; | ||
| 45 | |||
| 46 | Options() : eFlags( None ) {} | ||
| 47 | |||
| 48 | int eFlags; | ||
| 49 | int iUid; | ||
| 50 | int iGid; | ||
| 51 | }; | ||
| 52 | |||
| 53 | Process( Flags eFlags, const char *sName, char *const argv[] ); | ||
| 54 | Process( Flags eFlags, const char *sName, const char *argv, ...); | ||
| 55 | Process( Flags eFlags, const Options &opt, const char *sName, char *const argv[] ); | ||
| 56 | Process( Flags eFlags, const Options &opt, const char *sName, const char *argv, ...); | ||
| 57 | virtual ~Process(); | ||
| 58 | |||
| 59 | /** | ||
| 60 | * Waits until the process exits. This blocks the caller until the | ||
| 61 | * child process terminates. | ||
| 62 | */ | ||
| 63 | void wait(); | ||
| 64 | |||
| 65 | virtual void close(); | ||
| 66 | virtual void closeStdIn(); | ||
| 67 | virtual void closeStdOut(); | ||
| 68 | virtual Bu::size read( void *pBuf, Bu::size nBytes ); | ||
| 69 | virtual Bu::size readErr( void *pBuf, Bu::size nBytes ); | ||
| 70 | virtual Bu::size write( const void *pBuf, Bu::size nBytes ); | ||
| 71 | using Stream::write; | ||
| 72 | |||
| 73 | virtual Bu::size tell(); | ||
| 74 | virtual void seek( Bu::size offset ); | ||
| 75 | virtual void setPos( Bu::size pos ); | ||
| 76 | virtual void setPosEnd( Bu::size pos ); | ||
| 77 | virtual bool isEos(); | ||
| 78 | virtual bool isOpen(); | ||
| 79 | |||
| 80 | virtual void flush(); | ||
| 81 | |||
| 82 | virtual bool canRead(); | ||
| 83 | virtual bool canWrite(); | ||
| 84 | |||
| 85 | virtual bool isReadable(); | ||
| 86 | virtual bool isWritable(); | ||
| 87 | virtual bool isSeekable(); | ||
| 88 | |||
| 89 | virtual bool isBlocking(); | ||
| 90 | virtual void setBlocking( bool bBlocking=true ); | ||
| 91 | |||
| 92 | virtual void setSize( Bu::size iSize ); | ||
| 93 | |||
| 94 | virtual size getBlockSize() const; | ||
| 95 | virtual size getSize() const; | ||
| 96 | virtual Bu::String getLocation() const; | ||
| 97 | |||
| 98 | void select( bool &bStdOut, bool &bStdErr ); | ||
| 99 | |||
| 100 | bool isRunning(); | ||
| 101 | void ignoreStdErr(); | ||
| 102 | |||
| 103 | /** | ||
| 104 | * Returns the pid of the child process, or zero if there is no | ||
| 105 | * currently running child. Note that a read operation must be | ||
| 106 | * performed in order to discover that the child has ended. | ||
| 107 | */ | ||
| 108 | pid_t getPid(); | ||
| 109 | |||
| 110 | /** | ||
| 111 | * Returns true if the child exited normally (by calling exit or | ||
| 112 | * returning from main). | ||
| 113 | */ | ||
| 114 | bool childExited(); | ||
| 115 | |||
| 116 | /** | ||
| 117 | * Returns the 8 bit integer value returned from the child program if | ||
| 118 | * childExited returned true. | ||
| 119 | */ | ||
| 120 | int childExitStatus(); | ||
| 121 | |||
| 122 | /** | ||
| 123 | * Returns true if the child exited because of a signal. | ||
| 124 | */ | ||
| 125 | bool childSignaled(); | ||
| 126 | |||
| 127 | /** | ||
| 128 | * Returns the signal ID if the childSignaled return true. | ||
| 129 | */ | ||
| 130 | int childSignal(); | ||
| 131 | |||
| 132 | /** | ||
| 133 | * Returns true if the child left a core dump behind when it exited. | ||
| 134 | */ | ||
| 135 | bool childCoreDumped(); | ||
| 136 | |||
| 137 | private: | ||
| 138 | int iStdIn; | ||
| 139 | int iStdOut; | ||
| 140 | int iStdErr; | ||
| 141 | pid_t iPid; | ||
| 142 | int iProcStatus; | ||
| 143 | bool bBlocking; | ||
| 144 | bool bStdOutEos; | ||
| 145 | bool bStdErrEos; | ||
| 146 | |||
| 147 | void gexec( Flags eFlags, const char *sName, char *const argv[] ); | ||
| 148 | void checkClose(); | ||
| 149 | Options opt; | ||
| 150 | }; | ||
| 151 | } | ||
| 152 | |||
| 153 | #endif | ||
