xrootd
Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes
XrdOucStream Class Reference

#include <XrdOucStream.hh>

Collaboration diagram for XrdOucStream:
Collaboration graph
[legend]

List of all members.

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)
XrdOucEnvSetEnv (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
XrdSysErrorEroute
XrdOucEnvmyEnv
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

Constructor & Destructor Documentation

XrdOucStream::XrdOucStream ( XrdSysError erobj = 0,
const char *  ifname = 0,
XrdOucEnv anEnv = 0,
const char *  Pfx = 0 
)
XrdOucStream::~XrdOucStream ( ) [inline]

References Close(), myInst, varVal, and llBuff.


Member Function Documentation

char * XrdOucStream::add2llB ( char *  tok,
int  reset = 0 
) [private]

References llBuff, llBok, llBcur, llBleft, and llBsz.

Referenced by GetMyFirstWord(), GetWord(), and GetRest().

int XrdOucStream::Attach ( int  FileDescriptor,
int  bsz = 2047 
)
int XrdOucStream::AttachIO ( int  infd,
int  outfd,
int  bsz = 2047 
)

References Attach(), and FE.

Referenced by XrdXrootdAdmin::Login().

void XrdOucStream::Close ( int  hold = 0)
int XrdOucStream::Detach ( ) [inline]

References FD, and FE.

Referenced by XrdNetLink::Close().

char * XrdOucStream::doelse ( ) [private]
char * XrdOucStream::doif ( ) [private]
int XrdOucStream::Drain ( )
void XrdOucStream::Echo ( )
int XrdOucStream::Exec ( const char *  theCmd,
int  inrd = 0,
int  efd = 0 
)
int XrdOucStream::Exec ( char **  parm,
int  inrd = 0,
int  efd = 0 
)
int XrdOucStream::FDNum ( ) [inline]

References FD.

Referenced by XrdCmsFinderTRG::Start().

int XrdOucStream::FENum ( ) [inline]

References FE.

void XrdOucStream::Flush ( ) [inline]

References fsync(), FD, and FE.

char * XrdOucStream::GetFirstWord ( int  lowcase = 0)

References xline, SetEnv(), and GetWord().

Referenced by GetMyFirstWord(), doelse(), and doif().

char * XrdOucStream::GetLine ( )
char * XrdOucStream::GetMyFirstWord ( int  lowcase = 0)
int XrdOucStream::GetRest ( char *  theBuf,
int  Blen,
int  lowcase = 0 
)
char * XrdOucStream::GetToken ( int  lowcase = 0)
char * XrdOucStream::GetToken ( char **  rest,
int  lowcase = 0 
)

References GetToken(), and token.

char * XrdOucStream::GetWord ( int  lowcase = 0)

References xline, GetToken(), myEnv, add2llB(), vSubs(), xcont, GetLine(), bnext, and buff.

Referenced by XrdAccAuthFile::getPP(), XrdAccAuthFile::getRec(), XrdAccConfig::xaud(), XrdAccConfig::xart(), XrdAccConfig::xdbp(), XrdAccConfig::xglt(), XrdAccConfig::xgrt(), XrdAccConfig::xnis(), main(), XrdBwm::xalib(), XrdBwm::xlog(), XrdBwm::xpol(), XrdBwm::xtrace(), XrdCksConfig::ParseLib(), XrdCmsClientConfig::xapath(), XrdCmsClientConfig::xconw(), XrdCmsClientConfig::xmang(), XrdCmsClientConfig::xreqs(), XrdCmsClientConfig::xtrac(), XrdCmsConfig::xallow(), XrdCmsConfig::xapath(), XrdCmsConfig::xdelay(), XrdCmsConfig::xdfs(), XrdCmsConfig::xfsxq(), XrdCmsConfig::xfxhld(), XrdCmsConfig::xlclrt(), XrdCmsConfig::xmang(), XrdCmsConfig::xnml(), XrdCmsConfig::xolib(), XrdCmsConfig::xperf(), XrdCmsConfig::xpidf(), XrdCmsConfig::xping(), XrdCmsConfig::xprep(), XrdCmsConfig::xprepm(), XrdCmsConfig::xreps(), XrdCmsConfig::xrmtrt(), XrdCmsConfig::xrole(), XrdCmsConfig::xsched(), XrdCmsConfig::xsecl(), XrdCmsConfig::xspace(), XrdCmsConfig::xtrace(), XrdCmsConfig::xxmi(), XrdConfig::xapath(), XrdConfig::xallow(), XrdConfig::xbuf(), XrdConfig::xnet(), XrdConfig::xport(), XrdConfig::xprot(), XrdConfig::xrep(), XrdConfig::xsched(), XrdConfig::xtmo(), XrdConfig::xtrace(), XrdFrcProxy::qChk(), XrdFrmConfig::Grab(), XrdFrmConfig::xapath(), XrdFrmConfig::xcks(), XrdFrmConfig::xcnsd(), XrdFrmConfig::xcopy(), XrdFrmConfig::xcmax(), XrdFrmConfig::xdpol(), XrdFrmConfig::xitm(), XrdFrmConfig::xmon(), XrdFrmConfig::xnml(), XrdFrmConfig::xpol(), XrdFrmConfig::xpolprog(), XrdFrmConfig::xqchk(), XrdFrmConfig::xspace(), XrdFrmConfig::xxfr(), XrdOfs::ConfigXeq(), XrdOfs::xalib(), XrdOfs::xcrds(), XrdOfs::xforward(), XrdOfs::xmaxd(), XrdOfs::xnmsg(), XrdOfs::xnot(), XrdOfs::xolib(), XrdOfs::xpers(), XrdOfs::xrole(), XrdOfs::xtrace(), XrdOssSys::xalloc(), XrdOssSys::xcachescan(), XrdOssSys::xfdlimit(), XrdOssSys::xmaxsz(), XrdOssSys::xmemf(), XrdOssSys::xnml(), XrdOssSys::xspace(), XrdOssSys::xstg(), XrdOssSys::xtrace(), XrdOssSys::xusage(), XrdOssSys::xxfr(), XrdOssSpace::Quotas(), XrdOucExport::ParseDefs(), XrdOucExport::ParsePath(), GetFirstWord(), GetRest(), doelse(), XrdOucUtils::doIf(), XrdPssSys::ConfigXeq(), XrdPssSys::xcach(), XrdPssSys::xcapr(), XrdPssSys::xconf(), XrdPssSys::xnml(), XrdPssSys::xorig(), XrdPssSys::xsopt(), XrdPssSys::xtrac(), XrdSecServer::xpbind(), XrdSecServer::xprot(), XrdSecServer::xpparm(), XrdSecServer::xtrace(), XrdXrootdProtocol::xasync(), XrdXrootdProtocol::xcksum(), XrdXrootdProtocol::xexp(), XrdXrootdProtocol::xfsl(), XrdXrootdProtocol::xlog(), XrdXrootdProtocol::xmon(), XrdXrootdProtocol::xpidf(), XrdXrootdProtocol::xprep(), XrdXrootdProtocol::xred(), XrdXrootdProtocol::xsecl(), and XrdXrootdProtocol::xtrace().

int XrdOucStream::isAlive ( ) [inline]
int XrdOucStream::isSet ( char *  var) [private]
int XrdOucStream::LastError ( ) [inline]
char* XrdOucStream::LastLine ( ) [inline]

References recp.

int XrdOucStream::noEcho ( ) [inline]
int XrdOucStream::Put ( const char *  data,
const int  dlen 
)
int XrdOucStream::Put ( const char *  data) [inline]

References Put().

Referenced by Put().

int XrdOucStream::Put ( const char *  data[],
const int  dlen[] 
)
int XrdOucStream::PutLine ( const char *  data,
int  dlen = 0 
)
void XrdOucStream::RetToken ( void  )
XrdOucEnv* XrdOucStream::SetEnv ( XrdOucEnv newEnv) [inline]
void XrdOucStream::SetEroute ( XrdSysError eroute) [inline]
void XrdOucStream::Tabs ( int  x = 1) [inline]
char * XrdOucStream::vSubs ( char *  Var) [private]

References maxVLen, varVal, index(), xMsg(), myEnv, and XrdOucEnv::Get().

Referenced by GetWord().

int XrdOucStream::Wait4Data ( int  msMax = -1)

References FD, POLLIN, POLLRDNORM, poll(), and pollfd::revents.

Referenced by XrdOssSys::MSS_Xeq().

int XrdOucStream::xMsg ( const char *  txt1,
const char *  txt2 = 0,
const char *  txt3 = 0 
) [private]

References Eroute, XrdSysError::Emsg(), and ecode.

Referenced by isSet(), and vSubs().


Member Data Documentation

int XrdOucStream::bleft [private]

Referenced by XrdOucStream(), Attach(), GetLine(), and PutLine().

char* XrdOucStream::bnext [private]
int XrdOucStream::bsize [private]

Referenced by XrdOucStream(), Attach(), GetLine(), and PutLine().

char* XrdOucStream::buff [private]

Referenced by XrdOucStream(), Close(), Drain(), Exec(), and isAlive().

int XrdOucStream::ecode [private]
int XrdOucStream::FD [private]
int XrdOucStream::FE [private]
int XrdOucStream::flags [private]
char* XrdOucStream::llBcur [private]
int XrdOucStream::llBleft [private]
char XrdOucStream::llBok [private]
const int XrdOucStream::llBsz = 1024 [static, private]

Referenced by XrdOucStream(), Attach(), add2llB(), and isSet().

char* XrdOucStream::llBuff [private]
const char* XrdOucStream::llPrefix [private]
const int XrdOucStream::maxVLen = 512 [static, private]

Referenced by XrdOucStream(), isSet(), and vSubs().

char* XrdOucStream::myExec [private]

Referenced by XrdOucStream(), and doif().

char* XrdOucStream::myHost [private]

Referenced by XrdOucStream(), and doif().

char* XrdOucStream::myInst [private]
char* XrdOucStream::myName [private]

Referenced by XrdOucStream(), and doif().

int XrdOucStream::notabs [private]

Referenced by XrdOucStream(), GetLine(), and Tabs().

char* XrdOucStream::recp [private]
char XrdOucStream::sawif [private]
char XrdOucStream::skpel [private]
char* XrdOucStream::token [private]
char* XrdOucStream::varVal [private]

Referenced by XrdOucStream(), vSubs(), and ~XrdOucStream().

char XrdOucStream::Verbose [private]
int XrdOucStream::xcont [private]

Referenced by XrdOucStream(), Attach(), and GetWord().

int XrdOucStream::xline [private]

The documentation for this class was generated from the following files: