xrootd
Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
XrdOucStream Class Reference

#include <XrdOucStream.hh>

Collaboration diagram for XrdOucStream:
Collaboration graph
[legend]

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(), llBuff, myInst, and varVal.

Member Function Documentation

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

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

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

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 FD, FE, and fsync().

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

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

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

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 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().

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[] 
)

References ecode, Erp, FE, flags, Put(), write(), and XrdOucStream_BUSY.

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 XrdOucEnv::Get(), maxVLen, myEnv, varVal, and xMsg().

Referenced by GetWord().

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

References FD.

Referenced by XrdOssSys::MSS_Xeq().

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

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

Referenced by isSet(), and vSubs().

Member Data Documentation

int XrdOucStream::bleft
private

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

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

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

char* XrdOucStream::buff
private
pid_t XrdOucStream::child
private

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

int XrdOucStream::ecode
private
XrdSysError* XrdOucStream::Eroute
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
staticprivate

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

char* XrdOucStream::llBuff
private
const char* XrdOucStream::llPrefix
private
const int XrdOucStream::maxVLen = 512
staticprivate

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

XrdOucEnv* XrdOucStream::myEnv
private
char* XrdOucStream::myExec
private

Referenced by doif(), and XrdOucStream().

char* XrdOucStream::myHost
private

Referenced by doif(), and XrdOucStream().

char* XrdOucStream::myInst
private
char* XrdOucStream::myName
private

Referenced by doif(), and XrdOucStream().

int XrdOucStream::notabs
private

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

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

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

char XrdOucStream::Verbose
private
int XrdOucStream::xcont
private

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

int XrdOucStream::xline
private

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