|
xrootd
|
#include <XrdOucStream.hh>

Public Member Functions | |
| XrdOucStream (XrdSysError *erobj=0, const char *ifname=0, XrdOucEnv *anEnv=0, const char *Pfx=0) | |
| ~XrdOucStream () | |
| int | Attach (int FileDescriptor, int bsz=2047) |
| int | AttachIO (int infd, int outfd, int bsz=2047) |
| void | Close (int hold=0) |
| int | Detach () |
| int | Drain () |
| void | Echo () |
| int | Exec (const char *, int inrd=0, int efd=0) |
| int | Exec (char **, int inrd=0, int efd=0) |
| int | FDNum () |
| int | FENum () |
| void | Flush () |
| char * | GetLine () |
| char * | GetToken (int lowcase=0) |
| char * | GetToken (char **rest, int lowcase=0) |
| void | RetToken () |
| char * | GetFirstWord (int lowcase=0) |
| char * | GetMyFirstWord (int lowcase=0) |
| int | GetRest (char *theBuf, int Blen, int lowcase=0) |
| char * | GetWord (int lowcase=0) |
| int | isAlive () |
| int | LastError () |
| char * | LastLine () |
| int | noEcho () |
| int | Put (const char *data, const int dlen) |
| int | Put (const char *data) |
| int | Put (const char *data[], const int dlen[]) |
| int | PutLine (const char *data, int dlen=0) |
| XrdOucEnv * | SetEnv (XrdOucEnv *newEnv) |
| void | SetEroute (XrdSysError *eroute) |
| void | Tabs (int x=1) |
| int | Wait4Data (int msMax=-1) |
Private Member Functions | |
| char * | add2llB (char *tok, int reset=0) |
| char * | doelse () |
| char * | doif () |
| int | isSet (char *var) |
| char * | vSubs (char *Var) |
| int | xMsg (const char *txt1, const char *txt2=0, const char *txt3=0) |
Private Attributes | |
| int | FD |
| int | FE |
| int | bsize |
| int | bleft |
| char * | buff |
| char * | bnext |
| char * | recp |
| char * | token |
| int | flags |
| pid_t | child |
| int | ecode |
| int | notabs |
| int | xcont |
| int | xline |
| char * | myInst |
| char * | myHost |
| char * | myName |
| char * | myExec |
| XrdSysError * | Eroute |
| XrdOucEnv * | myEnv |
| char * | varVal |
| const char * | llPrefix |
| char * | llBuff |
| char * | llBcur |
| int | llBleft |
| char | Verbose |
| char | sawif |
| char | skpel |
| char | llBok |
Static Private Attributes | |
| static const int | maxVLen = 512 |
| static const int | llBsz = 1024 |
| XrdOucStream::XrdOucStream | ( | XrdSysError * | erobj = 0, |
| const char * | ifname = 0, |
||
| XrdOucEnv * | anEnv = 0, |
||
| const char * | Pfx = 0 |
||
| ) |
|
private |
| int XrdOucStream::Attach | ( | int | FileDescriptor, |
| int | bsz = 2047 |
||
| ) |
References bleft, bnext, bsize, buff, Close(), ecode, Erq, FD, FE, flags, llBcur, llBleft, llBok, llBsz, llBuff, recp, sawif, skpel, token, xcont, and xline.
Referenced by XrdNetLink::Alloc(), XrdCnsSsi::ApplyLog(), AttachIO(), XrdCns::CnsEvents(), XrdCpConfig::Config(), XrdXrootdProtocol::Config(), XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), XrdConfig::ConfigProc(), XrdCmsClientConfig::ConfigProc(), XrdCmsConfig::ConfigProc(), XrdFrmConfig::ConfigProc(), XrdPssSys::ConfigProc(), XrdOssSys::ConfigProc(), XrdBwm::Configure(), XrdOfs::Configure(), Exec(), XrdSecsssKT::getKeyTab(), XrdCmsFinderTRG::Hookup(), XrdFrcCID::Init(), XrdFrcProxy::Init2(), XrdCnsSsi::List(), main(), XrdAccAuthFile::Open(), XrdFrmXfrDaemon::Pong(), PutLine(), XrdOssSpace::Quotas(), XrdOfsEvr::recvEvents(), XrdFrmXfrAgent::Start(), and XrdCnsSsi::Updt().
| int XrdOucStream::AttachIO | ( | int | infd, |
| int | outfd, | ||
| int | bsz = 2047 |
||
| ) |
Referenced by XrdXrootdAdmin::Login().
| void XrdOucStream::Close | ( | int | hold = 0 | ) |
References buff, child, close(), Drain(), Eroute, FD, FE, llBok, llBuff, llPrefix, XrdSysError::Say(), and Verbose.
Referenced by XrdCmsFinderTRG::Added(), Attach(), XrdAccAuthFile::Close(), XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), XrdConfig::ConfigProc(), XrdCmsClientConfig::ConfigProc(), XrdCmsConfig::ConfigProc(), XrdPssSys::ConfigProc(), XrdFrmConfig::ConfigProc(), XrdOssSys::ConfigProc(), XrdBwm::Configure(), XrdOfs::Configure(), XrdSecsssKT::getKeyTab(), XrdFrcCID::Init(), XrdFrcProxy::Init2(), main(), XrdCmsFinderTRG::Removed(), XrdOucProg::Restart(), XrdCmsFinderTRG::Start(), XrdCnsSsi::Updt(), XrdOfsEvr::~XrdOfsEvr(), and ~XrdOucStream().
|
inline |
Referenced by XrdNetLink::Close().
|
private |
References doif(), ecode, XrdSysError::Emsg(), Eroute, GetFirstWord(), GetWord(), sawif, and skpel.
Referenced by GetMyFirstWord().
|
private |
References XrdOucUtils::doIf(), ecode, XrdSysError::Emsg(), Eroute, GetFirstWord(), myExec, myHost, myName, sawif, and skpel.
Referenced by doelse(), and GetMyFirstWord().
| int XrdOucStream::Drain | ( | ) |
References child.
Referenced by XrdOfsTPCProg::Cancel(), XrdXrootdJob::CleanUp(), Close(), XrdCmsMeter::Report(), XrdCmsPrepare::Reset(), and XrdOucProg::RunDone().
| void XrdOucStream::Echo | ( | ) |
References Eroute, llBok, llBuff, llPrefix, XrdSysError::Say(), and Verbose.
Referenced by XrdXrootdProtocol::Config(), XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), XrdConfig::ConfigProc(), XrdCmsClientConfig::ConfigProc(), XrdCmsConfig::ConfigProc(), XrdPssSys::ConfigProc(), XrdFrmConfig::ConfigProc(), XrdOssSys::ConfigProc(), XrdBwm::Configure(), XrdOfs::Configure(), XrdConfig::ConfigXeq(), XrdCmsConfig::ConfigXeq(), XrdSecServer::ConfigXeq(), XrdAccConfig::ConfigXeq(), XrdPssSys::ConfigXeq(), XrdFrmConfig::ConfigXeq(), XrdBwm::ConfigXeq(), XrdOssSys::ConfigXeq(), XrdOfs::ConfigXeq(), XrdFrcProxy::Init2(), and main().
| int XrdOucStream::Exec | ( | const char * | theCmd, |
| int | inrd = 0, |
||
| int | efd = 0 |
||
| ) |
References MaxARGC.
Referenced by Exec(), XrdCmsMeter::Run(), XrdOucProg::Run(), and XrdCmsPrepare::startIF().
| int XrdOucStream::Exec | ( | char ** | parm, |
| int | inrd = 0, |
||
| int | efd = 0 |
||
| ) |
|
inline |
References FD.
Referenced by XrdCmsFinderTRG::Start().
|
inline |
References FE.
| char * XrdOucStream::GetFirstWord | ( | int | lowcase = 0 | ) |
| char * XrdOucStream::GetLine | ( | ) |
References bleft, bnext, bsize, buff, Erp, FD, flags, notabs, read(), recp, token, and XrdOucStream_EOM.
Referenced by XrdCnsSsi::ApplyLog(), XrdCpConfig::Config(), XrdXrootdJob2Do::DoIt(), XrdCnsDaemon::getEvents(), XrdSecsssKT::getKeyTab(), XrdNetLink::GetLine(), GetWord(), XrdFrcCID::Init(), XrdCnsSsi::List(), XrdXrootdAdmin::Login(), main(), XrdOssSys::MSS_Readdir(), XrdOssSys::MSS_Xeq(), XrdFrmXfrDaemon::Pong(), XrdOfsEvr::recvEvents(), XrdCmsPrepare::Reset(), XrdCmsMeter::Run(), XrdOucProg::Run(), XrdFrmXfrAgent::Start(), XrdCnsSsi::Updt(), XrdOfsTPCProg::Xeq(), XrdXrootdAdmin::Xeq(), and XrdFrmPurge::XPolOK().
| char * XrdOucStream::GetMyFirstWord | ( | int | lowcase = 0 | ) |
References add2llB(), doelse(), doif(), ecode, XrdSysError::Emsg(), Eroute, GetFirstWord(), isSet(), llBok, llBuff, llPrefix, myEnv, myInst, sawif, XrdSysError::Say(), skpel, and Verbose.
Referenced by XrdXrootdProtocol::Config(), XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), XrdConfig::ConfigProc(), XrdCmsClientConfig::ConfigProc(), XrdCmsConfig::ConfigProc(), XrdFrmConfig::ConfigProc(), XrdPssSys::ConfigProc(), XrdOssSys::ConfigProc(), XrdBwm::Configure(), XrdOfs::Configure(), XrdFrcProxy::Init2(), main(), and XrdOssSpace::Quotas().
| int XrdOucStream::GetRest | ( | char * | theBuf, |
| int | Blen, | ||
| int | lowcase = 0 |
||
| ) |
References add2llB(), and GetWord().
Referenced by XrdOssSys::ConfigXeq(), XrdFrmConfig::Grab(), main(), XrdCksConfig::ParseLib(), XrdBwm::xalib(), XrdOfs::xalib(), XrdPssSys::xcacl(), XrdXrootdProtocol::xcksum(), XrdOfs::xcmsl(), XrdBwm::xlog(), XrdPssSys::xnml(), XrdCmsConfig::xnml(), XrdFrmConfig::xnml(), XrdOssSys::xnml(), XrdOfs::xnmsg(), XrdOfs::xnot(), XrdCmsConfig::xolib(), XrdOfs::xolib(), XrdFrmConfig::xoss(), XrdCmsConfig::xperf(), XrdBwm::xpol(), XrdFrmConfig::xpolprog(), XrdCmsConfig::xprep(), XrdCmsConfig::xprepm(), XrdOfs::xtpc(), and XrdCmsConfig::xxmi().
| char * XrdOucStream::GetToken | ( | int | lowcase = 0 | ) |
References token.
Referenced by XrdFrmXfrAgent::Add(), XrdFrmXfrAgent::Del(), XrdXrootdAdmin::do_Cj(), XrdXrootdAdmin::do_Disc(), XrdXrootdAdmin::do_Login(), XrdXrootdAdmin::do_Lsj(), XrdXrootdAdmin::do_Pause(), XrdXrootdAdmin::do_Red(), XrdOfsEvr::eventStage(), XrdCnsDaemon::getEvents(), XrdSecsssKT::getKeyTab(), XrdCnsDaemon::getLFN(), XrdXrootdAdmin::getreqID(), XrdXrootdAdmin::getTarget(), XrdNetLink::GetToken(), GetToken(), GetWord(), XrdFrcCID::Init(), isSet(), XrdSecsssKT::ktDecode0(), XrdFrmXfrAgent::List(), XrdXrootdAdmin::Login(), main(), XrdFrmXfrDaemon::Pong(), XrdFrmXfrAgent::Process(), XrdOfsEvr::recvEvents(), and XrdXrootdAdmin::Xeq().
| char * XrdOucStream::GetToken | ( | char ** | rest, |
| int | lowcase = 0 |
||
| ) |
References GetToken(), and token.
| char * XrdOucStream::GetWord | ( | int | lowcase = 0 | ) |
References add2llB(), bnext, buff, GetLine(), GetToken(), myEnv, vSubs(), xcont, and xline.
Referenced by XrdPssSys::ConfigXeq(), XrdOfs::ConfigXeq(), doelse(), XrdOucUtils::doIf(), GetFirstWord(), XrdAccAuthFile::getPP(), XrdAccAuthFile::getRec(), GetRest(), XrdFrmConfig::Grab(), main(), XrdOucExport::ParseDefs(), XrdCksConfig::ParseLib(), XrdOucExport::ParsePath(), XrdFrcProxy::qChk(), XrdOssSpace::Quotas(), XrdBwm::xalib(), XrdOfs::xalib(), XrdOssSys::xalloc(), XrdConfig::xallow(), XrdCmsConfig::xallow(), XrdCmsConfig::xaltds(), XrdConfig::xapath(), XrdCmsClientConfig::xapath(), XrdCmsConfig::xapath(), XrdFrmConfig::xapath(), XrdAccConfig::xart(), XrdXrootdProtocol::xasync(), XrdAccConfig::xaud(), XrdConfig::xbuf(), XrdPssSys::xcach(), XrdOssSys::xcachescan(), XrdPssSys::xcacl(), XrdPssSys::xcapr(), XrdFrmConfig::xcks(), XrdXrootdProtocol::xcksum(), XrdFrmConfig::xcmax(), XrdOfs::xcmsl(), XrdFrmConfig::xcnsd(), XrdPssSys::xconf(), XrdCmsClientConfig::xconw(), XrdFrmConfig::xcopy(), XrdOfs::xcrds(), XrdAccConfig::xdbp(), XrdCmsConfig::xdelay(), XrdCmsConfig::xdfs(), XrdFrmConfig::xdpol(), XrdXrootdProtocol::xexp(), XrdOssSys::xfdlimit(), XrdOfs::xforward(), XrdXrootdProtocol::xfsl(), XrdCmsConfig::xfsxq(), XrdCmsConfig::xfxhld(), XrdAccConfig::xglt(), XrdAccConfig::xgrt(), XrdFrmConfig::xitm(), XrdCmsConfig::xlclrt(), XrdXrootdProtocol::xlog(), XrdBwm::xlog(), XrdCmsClientConfig::xmang(), XrdCmsConfig::xmang(), XrdOfs::xmaxd(), XrdOssSys::xmaxsz(), XrdOssSys::xmemf(), XrdXrootdProtocol::xmon(), XrdFrmConfig::xmon(), XrdConfig::xnet(), XrdAccConfig::xnis(), XrdPssSys::xnml(), XrdFrmConfig::xnml(), XrdCmsConfig::xnml(), XrdOssSys::xnml(), XrdOfs::xnmsg(), XrdOfs::xnot(), XrdCmsConfig::xolib(), XrdOfs::xolib(), XrdPssSys::xorig(), XrdFrmConfig::xoss(), XrdSecServer::xpbind(), XrdCmsConfig::xperf(), XrdOfs::xpers(), XrdXrootdProtocol::xpidf(), XrdCmsConfig::xpidf(), XrdCmsConfig::xping(), XrdFrmConfig::xpol(), XrdBwm::xpol(), XrdFrmConfig::xpolprog(), XrdConfig::xport(), XrdSecServer::xpparm(), XrdXrootdProtocol::xprep(), XrdCmsConfig::xprep(), XrdCmsConfig::xprepm(), XrdConfig::xprot(), XrdSecServer::xprot(), XrdFrmConfig::xqchk(), XrdXrootdProtocol::xred(), XrdConfig::xrep(), XrdCmsConfig::xreps(), XrdCmsClientConfig::xreqs(), XrdCmsConfig::xrmtrt(), XrdCmsConfig::xrole(), XrdOfs::xrole(), XrdConfig::xsched(), XrdCmsConfig::xsched(), XrdXrootdProtocol::xsecl(), XrdCmsConfig::xsecl(), XrdConfig::xsit(), XrdFrmConfig::xsit(), XrdPssSys::xsopt(), XrdFrmConfig::xspace(), XrdCmsConfig::xspace(), XrdOssSys::xspace(), XrdOssSys::xstg(), XrdConfig::xtmo(), XrdOfs::xtpc(), XrdOfs::xtpcal(), XrdCmsClientConfig::xtrac(), XrdPssSys::xtrac(), XrdConfig::xtrace(), XrdSecServer::xtrace(), XrdXrootdProtocol::xtrace(), XrdCmsConfig::xtrace(), XrdBwm::xtrace(), XrdOssSys::xtrace(), XrdOfs::xtrace(), XrdOssSys::xusage(), XrdFrmConfig::xxfr(), XrdOssSys::xxfr(), and XrdCmsConfig::xxmi().
|
inline |
References child.
Referenced by XrdCmsPrepare::Add(), XrdCmsPrepare::Del(), XrdOucProg::Feed(), XrdCmsPrepare::Reset(), and XrdCmsPrepare::Scrub().
|
private |
References Eroute, XrdOucEnv::Export(), XrdOucEnv::Get(), GetToken(), llBcur, llBleft, llBok, llBsz, llBuff, maxVLen, myEnv, XrdOucEnv::Put(), XrdSysError::Say(), strlcpy(), Verbose, and xMsg().
Referenced by GetMyFirstWord().
|
inline |
References ecode.
Referenced by XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), XrdConfig::ConfigProc(), XrdCmsClientConfig::ConfigProc(), XrdCmsConfig::ConfigProc(), XrdPssSys::ConfigProc(), XrdFrmConfig::ConfigProc(), XrdOssSys::ConfigProc(), XrdBwm::Configure(), XrdOfs::Configure(), XrdOucProg::Feed(), XrdSecsssKT::getKeyTab(), XrdFrcCID::Init(), XrdFrcProxy::Init2(), XrdNetLink::LastError(), main(), XrdOssSys::MSS_Readdir(), XrdAccAuthFile::Open(), XrdCmsPrepare::Reset(), XrdOucProg::Run(), and XrdCmsPrepare::startIF().
|
inline |
References recp.
|
inline |
References llBok.
Referenced by XrdFrmConfig::ConfigXeq(), main(), XrdCmsConfig::xallow(), XrdCmsConfig::xaltds(), XrdCmsConfig::xdelay(), XrdCmsConfig::xdfs(), XrdCmsConfig::xfsxq(), XrdCmsConfig::xfxhld(), XrdCmsConfig::xlclrt(), XrdCmsClientConfig::xmang(), XrdCmsConfig::xmang(), XrdCmsConfig::xperf(), XrdConfig::xport(), XrdCmsConfig::xprep(), XrdCmsConfig::xrmtrt(), XrdCmsConfig::xrole(), XrdOfs::xrole(), and XrdCmsConfig::xsecl().
| int XrdOucStream::Put | ( | const char * | data, |
| const int | dlen | ||
| ) |
References ecode, Erp, FE, flags, write(), and XrdOucStream_BUSY.
Referenced by XrdCmsPrepare::Add(), XrdCmsFinderTRG::Added(), XrdCmsPrepare::Del(), XrdXrootdAdmin::do_Cj(), XrdXrootdAdmin::do_Login(), XrdXrootdAdmin::do_Lsc(), XrdXrootdAdmin::do_Lsd(), XrdXrootdAdmin::do_Lsj(), XrdXrootdAdmin::do_Lsj_Xeq(), XrdOucProg::Feed(), Put(), XrdCmsFinderTRG::Removed(), XrdCmsPrepare::Reset(), XrdOucERoute::Route(), XrdXrootdAdmin::sendErr(), XrdXrootdAdmin::sendOK(), and XrdCmsFinderTRG::Start().
| int XrdOucStream::Put | ( | const char * | data[], |
| const int | dlen[] | ||
| ) |
| int XrdOucStream::PutLine | ( | const char * | data, |
| int | dlen = 0 |
||
| ) |
| void XrdOucStream::RetToken | ( | void | ) |
References bnext, llBcur, llBleft, llBuff, recp, and token.
Referenced by XrdNetLink::RetToken(), XrdXrootdProtocol::xexp(), XrdCmsConfig::xfsxq(), XrdBwm::xlog(), XrdOfs::xnot(), XrdCmsConfig::xprepm(), XrdOfs::xtpc(), and XrdOfs::xtpcal().
References myEnv.
Referenced by XrdOssSys::ConfigXeq(), GetFirstWord(), XrdFrmConfig::Grab(), main(), XrdOfs::xnmsg(), and XrdCmsConfig::xprepm().
|
inline |
References Eroute.
Referenced by XrdCmsConfig::ConfigProc(), XrdXrootdAdmin::Login(), and XrdAccAuthFile::Open().
|
inline |
References notabs.
Referenced by XrdSecServer::ConfigFile(), XrdAccConfig::ConfigFile(), and XrdAccAuthFile::Open().
|
private |
| int XrdOucStream::Wait4Data | ( | int | msMax = -1 | ) |
References FD.
Referenced by XrdOssSys::MSS_Xeq().
|
private |
References ecode, XrdSysError::Emsg(), and Eroute.
|
private |
Referenced by Attach(), GetLine(), PutLine(), and XrdOucStream().
|
private |
Referenced by Attach(), GetLine(), GetWord(), PutLine(), RetToken(), and XrdOucStream().
|
private |
Referenced by Attach(), GetLine(), PutLine(), and XrdOucStream().
|
private |
|
private |
Referenced by Close(), Drain(), Exec(), isAlive(), and XrdOucStream().
|
private |
Referenced by Attach(), doelse(), doif(), GetMyFirstWord(), LastError(), Put(), xMsg(), and XrdOucStream().
|
private |
Referenced by Close(), doelse(), doif(), Echo(), Exec(), GetMyFirstWord(), isSet(), SetEroute(), xMsg(), and XrdOucStream().
|
private |
Referenced by Attach(), Close(), Detach(), Exec(), FDNum(), Flush(), GetLine(), Wait4Data(), and XrdOucStream().
|
private |
Referenced by Attach(), AttachIO(), Close(), Detach(), Exec(), FENum(), Flush(), Put(), and XrdOucStream().
|
private |
Referenced by Attach(), GetLine(), Put(), PutLine(), and XrdOucStream().
|
private |
Referenced by add2llB(), Attach(), isSet(), RetToken(), and XrdOucStream().
|
private |
Referenced by add2llB(), Attach(), isSet(), RetToken(), and XrdOucStream().
|
private |
Referenced by add2llB(), Attach(), Close(), Echo(), GetMyFirstWord(), isSet(), noEcho(), and XrdOucStream().
|
staticprivate |
Referenced by add2llB(), Attach(), isSet(), and XrdOucStream().
|
private |
Referenced by add2llB(), Attach(), Close(), Echo(), GetMyFirstWord(), isSet(), RetToken(), XrdOucStream(), and ~XrdOucStream().
|
private |
Referenced by Close(), Echo(), GetMyFirstWord(), and XrdOucStream().
|
staticprivate |
Referenced by isSet(), vSubs(), and XrdOucStream().
|
private |
Referenced by GetMyFirstWord(), GetWord(), isSet(), SetEnv(), vSubs(), and XrdOucStream().
|
private |
Referenced by doif(), and XrdOucStream().
|
private |
Referenced by doif(), and XrdOucStream().
|
private |
Referenced by GetMyFirstWord(), XrdOucStream(), and ~XrdOucStream().
|
private |
Referenced by doif(), and XrdOucStream().
|
private |
Referenced by GetLine(), Tabs(), and XrdOucStream().
|
private |
Referenced by Attach(), GetLine(), LastLine(), PutLine(), RetToken(), and XrdOucStream().
|
private |
Referenced by Attach(), doelse(), doif(), GetMyFirstWord(), and XrdOucStream().
|
private |
Referenced by Attach(), doelse(), doif(), GetMyFirstWord(), and XrdOucStream().
|
private |
Referenced by Attach(), GetLine(), GetToken(), PutLine(), RetToken(), and XrdOucStream().
|
private |
Referenced by vSubs(), XrdOucStream(), and ~XrdOucStream().
|
private |
Referenced by Close(), Echo(), GetMyFirstWord(), isSet(), and XrdOucStream().
|
private |
Referenced by Attach(), GetWord(), and XrdOucStream().
|
private |
Referenced by Attach(), GetFirstWord(), GetWord(), and XrdOucStream().
1.8.3.1