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