|
xrootd
|
#include <XrdOucProg.hh>

Public Member Functions | |
| XrdOucProg (XrdSysError *errobj=0) | |
| ~XrdOucProg () | |
| int | Feed (const char *data[], const int dlen[]) |
| int | Feed (const char *data, int dlen) |
| int | Feed (const char *data) |
| XrdOucStream * | getStream () |
| int | Run (XrdOucStream *Sp, const char *arg1=0, const char *arg2=0, const char *arg3=0, const char *arg4=0) |
| int | Run (const char *arg1=0, const char *arg2=0, const char *arg3=0, const char *arg4=0) |
| int | Start (void) |
| int | Setup (const char *prog, XrdSysError *errP=0, int(*Proc)(XrdOucStream *, char **, int)=0) |
Private Member Functions | |
| int | Restart () |
Private Attributes | |
| XrdSysError * | eDest |
| XrdOucStream * | myStream |
| int(* | myProc )(XrdOucStream *, char **, int) |
| char * | ArgBuff |
| char * | Arg [64] |
| int | numArgs |
| int | lenArgs |
| int | theEFD |
| XrdOucProg::XrdOucProg | ( | XrdSysError * | errobj = 0 | ) | [inline] |
| int XrdOucProg::Feed | ( | const char * | data[], |
| const int | dlen[] | ||
| ) |
References myStream, XrdSysMutexHelper::Lock(), XrdOucStream::isAlive(), Restart(), eDest, XrdSysError::Emsg(), Arg, XrdOucStream::Put(), and XrdOucStream::LastError().
Referenced by XrdBwmLogger::sendEvents(), XrdFrmPurge::XPolOK(), XrdOfsEvs::sendEvents(), XrdOssSys::Stage_QT(), and Feed().
| int XrdOucProg::Feed | ( | const char * | data, |
| int | dlen | ||
| ) | [inline] |
References Feed().
| XrdOucStream* XrdOucProg::getStream | ( | ) | [inline] |
References myStream.
Referenced by XrdFrmPurge::Init().
| int XrdOucProg::Restart | ( | ) | [private] |
References myStream, XrdOucStream::Close(), and Run().
Referenced by Feed().
| int XrdOucProg::Run | ( | XrdOucStream * | Sp, |
| const char * | arg1 = 0, |
||
| const char * | arg2 = 0, |
||
| const char * | arg3 = 0, |
||
| const char * | arg4 = 0 |
||
| ) |
References Arg, numArgs, ArgBuff, eDest, XrdSysError::Emsg(), lenArgs, myProc, XrdOucStream::Exec(), theEFD, and XrdOucStream::LastError().
Referenced by XrdCmsNode::fsExec(), XrdFrmTransfer::Fetch(), XrdFrmTransfer::Throw(), XrdOssSys::MSS_Xeq(), XrdOssSys::GetFile(), Run(), Start(), Restart(), and XrdXrootdJob2Do::DoIt().
| int XrdOucProg::Run | ( | const char * | arg1 = 0, |
| const char * | arg2 = 0, |
||
| const char * | arg3 = 0, |
||
| const char * | arg4 = 0 |
||
| ) |
References Run(), XrdOucStream::GetLine(), eDest, XrdSysError::Emsg(), XrdOucStream::Drain(), WIFSIGNALED, WTERMSIG, Arg, WIFEXITED, and WEXITSTATUS.
| int XrdOucProg::Setup | ( | const char * | prog, |
| XrdSysError * | errP = 0, |
||
| int(*)(XrdOucStream *, char **, int) | Proc = 0 |
||
| ) |
References Arg, ArgBuff, eDest, XrdSysError::Emsg(), numArgs, lenArgs, myProc, access(), and X_OK.
Referenced by XrdBwmLogger::Start(), XrdFrmConfig::ConfigMss(), XrdFrmPurge::Init(), XrdFrmTransfer::SetupCmd(), XrdOfsEvs::Start(), XrdOssSys::ConfigStage(), XrdOssSys::ConfigStageC(), and XrdXrootdProtocol::xcksum().
| int XrdOucProg::Start | ( | void | ) |
References myStream, eDest, theEFD, and Run().
Referenced by XrdBwmLogger::Start(), XrdFrmPurge::Init(), XrdOfsEvs::Start(), and XrdOssSys::ConfigStageC().
char* XrdOucProg::Arg[64] [private] |
Referenced by Feed(), Run(), Setup(), and XrdOucProg().
char* XrdOucProg::ArgBuff [private] |
Referenced by ~XrdOucProg(), Run(), Setup(), and XrdOucProg().
XrdSysError* XrdOucProg::eDest [private] |
Referenced by Feed(), Run(), Setup(), Start(), and XrdOucProg().
int XrdOucProg::lenArgs [private] |
int(* XrdOucProg::myProc)(XrdOucStream *, char **, int) [private] |
XrdOucStream* XrdOucProg::myStream [private] |
Referenced by ~XrdOucProg(), Feed(), Start(), Restart(), XrdOucProg(), and getStream().
int XrdOucProg::numArgs [private] |
Referenced by Run(), Setup(), and XrdOucProg().
int XrdOucProg::theEFD [private] |
Referenced by Run(), Start(), and XrdOucProg().
1.7.5