TXSocket Class Reference

#include <TXSocket.h>

Inheritance diagram for TXSocket:

TSocket XrdClientAbsUnsolMsgHandler TNamed TNamed TObject TObject TObject TObject TXUnixSocket List of all members.

Public Types

enum  EUrgentMsgType

Public Member Functions

 TXSocket (const char *url, Char_t mode= 'M', Int_t psid=-1, Char_t ver=-1, const char *logbuf=0, Int_t loglevel=-1, TXHandler *handler=0)
 TXSocket (const TXSocket &xs)
TXSocket & operator= (const TXSocket &xs)
virtual ~TXSocket ()
virtual void Close (Option_t *opt="")
Bool_t Create (Bool_t attach=kFALSE)
void DisconnectSession (Int_t id, Option_t *opt="")
void DoError (int level, const char *location, const char *fmt, va_list va) const
virtual UnsolRespProcResult ProcessUnsolicitedMsg (XrdClientUnsolMsgSender *s, XrdClientMessage *msg)
virtual Int_t GetClientID () const
virtual Int_t GetClientIDSize () const
Int_t GetLogConnID () const
Int_t GetOpenError () const
Int_t GetServType () const
Int_t GetSessionID () const
Int_t GetXrdProofdVersion () const
Bool_t IsValid () const
Bool_t IsServProofd ()
virtual void RemoveClientID ()
virtual void SetClientID (Int_t)
void SetSendOpt (ESendRecvOptions o)
void SetSessionID (Int_t id)
Int_t Send (const TMessage &mess)
Int_t Send (Int_t kind)
Int_t Send (Int_t status, Int_t kind)
Int_t Send (const char *mess, Int_t kind=kMESS_STRING)
Int_t SendRaw (const void *buf, Int_t len, ESendRecvOptions opt=kDontBlock)
TObjString * SendCoordinator (Int_t kind, const char *msg=0, Int_t int2=0, Long64_t l64=0, Int_t int3=0, const char *opt=0)
Int_t Recv (TMessage *&mess)
Int_t Recv (Int_t &status, Int_t &kind)
Int_t Recv (char *mess, Int_t max)
Int_t Recv (char *mess, Int_t max, Int_t &kind)
Int_t RecvRaw (void *buf, Int_t len, ESendRecvOptions opt=kDefault)
Int_t SendInterrupt (Int_t type)
Int_t GetInterrupt (Bool_t &forward)
void SendUrgent (Int_t type, Int_t int1, Int_t int2)
void SetInterrupt ()
Int_t Flush ()
Bool_t Ping (const char *ord=0)
void RemoteTouch ()
void CtrlC ()
Int_t SetOption (ESockOptions, Int_t)
void DisableTimeout ()
void EnableTimeout ()
virtual Int_t Reconnect ()

Private Member Functions

Int_t PickUpReady ()
TXSockBuf * PopUpSpare (Int_t sz)
void PushBackSpare ()
void PostMsg (Int_t type, const char *msg=0)
Int_t GetLowSocket () const

Static Private Member Functions

static void SetLocation (const char *loc="")
static void InitEnvs ()

Private Attributes

char fMode
kXR_int32 fSendOpt
Short_t fSessionID
TString fUser
TString fHost
Int_t fPort
Int_t fLogLevel
TString fBuffer
TObject * fReference
TXHandler * fHandler
XrdProofConn * fConn
TSemaphore fASem
TMutex * fAMtx
std::list< TXSockBuf * > fAQue
Int_t fByteLeft
Int_t fByteCur
TXSockBuf * fBufCur
TSemaphore fAsynProc
TMutex * fIMtx
kXR_int32 fILev
Bool_t fIForward
Int_t fPid
Bool_t fDontTimeout
Bool_t fRDInterrupt
Int_t fXrdProofdVersion

Static Private Attributes

static TXSockPipe fgPipe
static TString fgLoc
static Bool_t fgInitDone
static TMutex fgSMtx
static std::list< TXSockBuf * > fgSQue

Friends

class TXProofMgr
class TXProofServ
class TXSlave
class TXSocketHandler
class TXSockPipe
class TXUnixSocket

Detailed Description

Definition at line 74 of file TXSocket.h.

Member Enumeration Documentation

enum TXSocket::EUrgentMsgType

Definition at line 150 of file TXSocket.h.

Constructor & Destructor Documentation

TXSocket::TXSocket ( const char *  url,
Char_t  mode = 'M',
Int_t  psid = -1,
Char_t  ver = -1,
const char *  logbuf = 0,
Int_t  loglevel = -1,
TXHandler *  handler = 0 
)

Definition at line 114 of file TXSocket.cxx.

References XrdOucString::c_str(), Close(), Create(), TString::Data(), eDest, eLogger, TObject::Error(), TSocket::fAddress, fAMtx, fAQue, fBufCur, fBuffer, fByteCur, fByteLeft, fConn, fgInitDone, fgPipe, fHandler, fHost, XrdProofConn::fHost, fIForward, fILev, fIMtx, XrdProofConn::fLastErrMsg, fMode, fPid, TInetAddress::fPort, XrdProofConn::fPort, fPort, fReference, TSocket::fRemoteProtocol, XrdProofConn::fRemoteProtocol, fSendOpt, TSocket::fServType, fSessionID, TSocket::fSocket, TSocket::fTcpWindowSize, XrdProofConn::fUrl, TSocket::fUrl, XrdProofConn::fUser, fUser, fXrdProofdVersion, gDebug, TSystem::GetHostByName(), XrdProofConn::GetLastErr(), TSystem::GetPid(), XrdProofConn::GetServType(), XrdClientUrlInfo::GetUrl(), gSystem, handler, XrdClientUrlInfo::Host, InitEnvs(), XrdProofConn::IsValid(), TXSockPipe::IsValid(), kFALSE, TSocket::kPROOFD, XrdProofConn::kSTProofd, kTRUE, kXPD_async, kXPD_internal, XrdOucString::length(), XrdSysError::logger(), u, and XrdProofdTrace.

TXSocket::TXSocket ( const TXSocket &  xs  ) 

Definition at line 237 of file TXSocket.cxx.

TXSocket::~TXSocket (  )  [virtual]

Definition at line 250 of file TXSocket.cxx.

References Close(), fAMtx, fIMtx, and SafeDelete.

Member Function Documentation

Int_t TXSocket::PickUpReady (  )  [private]

Definition at line 1372 of file TXSocket.cxx.

References TXSockPipe::Clean(), TObject::Error(), fAMtx, fAQue, fASem, fBufCur, fByteCur, fByteLeft, TSocket::fBytesRecv, fDontTimeout, fgPipe, TXSockBuf::fLen, fRDInterrupt, gDebug, gEnv, GetClientID(), TNamed::GetTitle(), TEnv::GetValue(), TObject::Info(), kFALSE, R__LOCKGUARD, SetClientID(), and TSemaphore::Wait().

Referenced by RecvRaw().

TXSockBuf * TXSocket::PopUpSpare ( Int_t  sz  )  [private]

Definition at line 1450 of file TXSocket.cxx.

References b, buf, fgSMtx, fgSQue, gDebug, i, TObject::Info(), malloc(), and R__LOCKGUARD.

Referenced by PostMsg(), and ProcessUnsolicitedMsg().

void TXSocket::PushBackSpare (  )  [private]

Definition at line 1502 of file TXSocket.cxx.

References TXSockBuf::BuffMem(), fBufCur, fByteCur, fByteLeft, fgSMtx, fgSQue, TXSockBuf::fSiz, gDebug, TXSockBuf::GetMemMax(), TObject::Info(), and R__LOCKGUARD.

Referenced by RecvRaw().

void TXSocket::PostMsg ( Int_t  type,
const char *  msg = 0 
) [private]

Definition at line 870 of file TXSocket.cxx.

References b, TObject::Error(), fAMtx, fAQue, fASem, TSocket::fBytesRecv, fgPipe, gDebug, TObject::Info(), m, PopUpSpare(), TSemaphore::Post(), TXSockPipe::Post(), and R__LOCKGUARD.

Referenced by ProcessUnsolicitedMsg().

Int_t TXSocket::GetLowSocket (  )  const [inline, private]

Definition at line 142 of file TXSocket.h.

References fConn, and XrdProofConn::GetLowSocket().

void TXSocket::SetLocation ( const char *  loc = ""  )  [static, private]

Definition at line 265 of file TXSocket.cxx.

References fgLoc, fgPipe, and TXSockPipe::SetLoc().

Referenced by TXProofServ::CreateServer(), and TXSlave::TXSlave().

void TXSocket::InitEnvs (  )  [static, private]

Definition at line 1908 of file TXSocket.cxx.

References TString::Data(), DFLT_RECONNECTWAIT, EnvPutInt, EnvPutString, fgInitDone, TString::Form(), gEnv, TSystem::Getenv(), TEnv::GetValue(), TROOT::GetVersion(), gROOT, gSystem, TSystem::HomeDirectory(), TObject::Info(), TString::IsNull(), kTRUE, TString::Length(), NAME_CONNECTDOMAINALLOW_RE, NAME_CONNECTDOMAINDENY_RE, NAME_CONNECTTIMEOUT, NAME_DEBUG, NAME_FIRSTCONNECTMAXCNT, NAME_KEEPSOCKOPENIFNOTXRD, NAME_RECONNECTWAIT, NAME_REQUESTTIMEOUT, NAME_SOCKS4HOST, NAME_SOCKS4PORT, TSystem::Setenv(), XrdProofConn::SetRetryParam(), TRACE_ALL, TRACE_DBG, TRACE_REQ, XrdOucTrace::What, and XrdProofdTrace.

Referenced by TXSocket().

TXSocket & TXSocket::operator= ( const TXSocket &  xs  ) 

Definition at line 243 of file TXSocket.cxx.

void TXSocket::Close ( Option_t *  opt = ""  )  [virtual]

Reimplemented from TSocket.

Definition at line 330 of file TXSocket.cxx.

References XrdProofConn::Close(), DisconnectSession(), fAsynProc, fConn, fgPipe, TXSockPipe::Flush(), fSessionID, gDebug, gEnv, TEnv::GetValue(), TObject::Info(), IsValid(), kNPOS, o, TSemaphore::Post(), SafeDelete, XrdProofConn::SetAsync(), TSemaphore::Wait(), and TObject::Warning().

Referenced by Reconnect(), TXProofMgr::SetInvalid(), TXSocket(), and ~TXSocket().

Bool_t TXSocket::Create ( Bool_t  attach = kFALSE  ) 

Definition at line 1021 of file TXSocket.cxx.

References buf, XrdOucString::c_str(), TString::Data(), XrdClientMessage::DataLen(), TObject::Error(), fBuffer, fConn, fHost, XrdProofConn::fLastErrMsg, fLogLevel, fMode, free(), TSocket::fRemoteProtocol, fSessionID, TSocket::fUrl, fXrdProofdVersion, gDebug, gEnv, XrdClientMessage::GetData(), XrdProofConn::GetLastErr(), XrdProofConn::GetOpenError(), TEnv::GetValue(), TObject::Info(), IsValid(), kFALSE, kTRUE, kXP_attach, kXP_create, kXP_TooManySess, len, TString::Length(), XrdOucString::length(), net2host(), Printf(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TObject::Warning().

Referenced by Reconnect(), and TXSocket().

void TXSocket::DisconnectSession ( Int_t  id,
Option_t *  opt = "" 
)

Definition at line 289 of file TXSocket.cxx.

References TString::Data(), fConn, fHost, gDebug, XrdProofConn::GetLastErr(), TObject::Info(), IsValid(), kXP_destroy, kXP_detach, Printf(), SafeDelete, XrdProofConn::SendReq(), and XrdProofConn::SetSID().

Referenced by Close(), and TXProofMgr::DetachSession().

void TXSocket::DoError ( int  level,
const char *  location,
const char *  fmt,
va_list  va 
) const [virtual]

Reimplemented from TObject.

Definition at line 73 of file TXSocket.cxx.

References ErrorHandler(), and Form().

UnsolRespProcResult TXSocket::ProcessUnsolicitedMsg ( XrdClientUnsolMsgSender *  s,
XrdClientMessage *  msg 
) [virtual]

Implements XrdClientAbsUnsolMsgHandler.

Definition at line 387 of file TXSocket.cxx.

References b, TXSockPipe::DumpReadySock(), TObject::Error(), fAMtx, fAQue, fASem, fAsynProc, TSocket::fBytesRecv, fConn, fgPipe, fHandler, fIForward, fILev, fIMtx, TString::Format(), fprintf(), fSessionID, XrdProofConn::fStreamid, gDebug, TNamed::GetTitle(), TXHandler::HandleError(), TXHandler::HandleInput(), inflate(), TObject::Info(), TXSemaphoreGuard::IsValid(), kFALSE, TProof::kPing, kPROOF_FATAL, kPROOF_STARTPROCESS, kPROOF_STOP, kPROOF_TOUCH, kPROOF_WorkerIdleTO, kTRUE, kUNSOL_CONTINUE, kUNSOL_KEEP, kXPD_clusterinfo, kXPD_errmsg, kXPD_feedback, kXPD_flush, kXPD_inflate, kXPD_interrupt, kXPD_msg, kXPD_msgsid, kXPD_ping, kXPD_priority, kXPD_resume, kXPD_srvmsg, kXPD_timer, kXPD_touch, kXPD_urgent, kXPD_wrkmortem, XrdClientMessage::kXrdMSC_timeout, len, m, net2host(), PopUpSpare(), TSemaphore::Post(), TXSockPipe::Post(), PostMsg(), Printf(), R__LOCKGUARD, TSocket::Touch(), type, and what.

virtual Int_t TXSocket::GetClientID (  )  const [inline, virtual]

Definition at line 168 of file TXSocket.h.

Referenced by PickUpReady(), and SendRaw().

virtual Int_t TXSocket::GetClientIDSize (  )  const [inline, virtual]

Definition at line 169 of file TXSocket.h.

Referenced by Send().

Int_t TXSocket::GetLogConnID (  )  const [inline]

Definition at line 170 of file TXSocket.h.

References fConn, and XrdProofConn::GetLogConnID().

Int_t TXSocket::GetOpenError (  )  const [inline]

Definition at line 171 of file TXSocket.h.

References fConn, and XrdProofConn::GetOpenError().

Referenced by TXProofMgr::Init().

Int_t TXSocket::GetServType (  )  const [inline]

Reimplemented from TSocket.

Definition at line 172 of file TXSocket.h.

References fConn, and XrdProofConn::GetServType().

Int_t TXSocket::GetSessionID (  )  const [inline]

Definition at line 173 of file TXSocket.h.

References fConn, and XrdProofConn::GetSessionID().

Int_t TXSocket::GetXrdProofdVersion (  )  const [inline]

Definition at line 174 of file TXSocket.h.

References fXrdProofdVersion.

Referenced by TXProofMgr::Cp(), TXProofMgr::Exec(), TXProofMgr::Find(), TXProofMgr::GetFile(), TXProofMgr::Grep(), TXProofMgr::Ls(), TXProofMgr::Md5sum(), TXProofMgr::More(), TXProofMgr::PutFile(), TXProofMgr::Rm(), TXProofMgr::Stat(), and TXProofMgr::Tail().

Bool_t TXSocket::IsValid (  )  const [inline, virtual]

Reimplemented from TSocket.

Definition at line 176 of file TXSocket.h.

References fConn, XrdProofConn::IsValid(), and kFALSE.

Referenced by Close(), Create(), CtrlC(), DisconnectSession(), TXProofMgr::HandleError(), TXProofMgr::HandleInput(), TXProofMgr::Init(), Ping(), Recv(), and RemoteTouch().

Bool_t TXSocket::IsServProofd (  ) 

Definition at line 931 of file TXSocket.cxx.

References fConn, XrdProofConn::GetServType(), kFALSE, XrdProofConn::kSTProofd, and kTRUE.

Referenced by TXProofMgr::Init().

virtual void TXSocket::RemoveClientID (  )  [inline, virtual]

Definition at line 178 of file TXSocket.h.

virtual void TXSocket::SetClientID ( Int_t   )  [inline, virtual]

Definition at line 179 of file TXSocket.h.

Referenced by PickUpReady().

void TXSocket::SetSendOpt ( ESendRecvOptions  o  )  [inline]

Definition at line 180 of file TXSocket.h.

References fSendOpt.

void TXSocket::SetSessionID ( Int_t  id  ) 

Definition at line 279 of file TXSocket.cxx.

References fConn, fSessionID, and XrdProofConn::SetAsync().

Int_t TXSocket::Send ( const TMessage &  mess  )  [virtual]

Reimplemented from TSocket.

Definition at line 1620 of file TXSocket.cxx.

References TObject::Error(), TSocket::fBytesSent, TSocket::fCompress, TSocket::fgBytesSent, fSendOpt, gDebug, GetClientIDSize(), TMessage::GetCompressionLevel(), TNamed::GetTitle(), TObject::Info(), TBuffer::IsReading(), kPROOF_FEEDBACK, kPROOF_LOGDONE, kPROOF_LOGFILE, kPROOF_PROCESS, kPROOF_PROGRESS, kPROOF_QUERYSUBMITTED, kPROOF_SETIDLE, kPROOF_STARTPROCESS, kPROOF_STOPPROCESS, kXPD_fb_prog, kXPD_logmsg, kXPD_process, kXPD_querynum, kXPD_setidle, kXPD_startprocess, TSystem::ResetErrno(), TSocket::SendProcessIDs(), SendRaw(), TSocket::SendStreamerInfos(), and TMessage::SetLength().

Int_t TXSocket::Send ( Int_t  kind  )  [inline, virtual]

Reimplemented from TSocket.

Definition at line 185 of file TXSocket.h.

References TSocket::Send().

Int_t TXSocket::Send ( Int_t  status,
Int_t  kind 
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 186 of file TXSocket.h.

References TSocket::Send().

Int_t TXSocket::Send ( const char *  mess,
Int_t  kind = kMESS_STRING 
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 188 of file TXSocket.h.

References TSocket::Send().

Int_t TXSocket::SendRaw ( const void *  buf,
Int_t  len,
ESendRecvOptions  opt = kDontBlock 
) [virtual]

Reimplemented from TSocket.

Definition at line 1167 of file TXSocket.cxx.

References TString::Data(), TObject::Error(), TSocket::fBytesSent, fConn, fHost, fSendOpt, fSessionID, gDebug, GetClientID(), XrdProofConn::GetLastErr(), TObject::Info(), kDontBlock, kXP_sendmsg, kXPD_async, Printf(), TSystem::ResetErrno(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TSocket::Touch().

Referenced by Send().

TObjString * TXSocket::SendCoordinator ( Int_t  kind,
const char *  msg = 0,
Int_t  int2 = 0,
Long64_t  l64 = 0,
Int_t  int3 = 0,
const char *  opt = 0 
)

Definition at line 1755 of file TXSocket.cxx.

References buf, TString::Data(), XrdClientMessage::DataLen(), fConn, fHost, free(), fSessionID, fXrdProofdVersion, gDebug, XrdProofConn::GetLastErr(), TObject::Info(), kCleanupSessions, kCpFile, kExec, kFALSE, kGetFile, kGetWorkers, kGroupProperties, kPutFile, kQueryLogPaths, kQueryROOTVersions, kQuerySessions, kQueryWorkers, kReadBuffer, kReleaseWorker, kROOTVersion, kSendMsgToUser, kSessionAlias, kSessionTag, kTRUE, kXP_admin, kXP_readbuf, kXPD_AnyServer, kXPD_TopMaster, Printf(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TSocket::Touch().

Referenced by TXProofMgr::Cp(), TXProofMgr::Exec(), TXProofMgr::GetFile(), TXProofMgr::GetSessionLogs(), TXProofMgr::PutFile(), TXProofMgr::QuerySessions(), TXProofMgr::ReadBuffer(), TXProofMgr::Reset(), TXProofMgr::SendMsgToUsers(), TXProofMgr::SetROOTVersion(), TXProofMgr::ShowROOTVersions(), and TXProofMgr::ShowWorkers().

Int_t TXSocket::Recv ( TMessage *&  mess  )  [virtual]

Reimplemented from TSocket.

Definition at line 1703 of file TXSocket.cxx.

References buf, TSocket::fBytesRecv, TSocket::fgBytesRecv, IsValid(), kMESS_ACK, len, n, net2host(), TSocket::RecvProcessIDs(), RecvRaw(), TSocket::RecvStreamerInfos(), and TSystem::ResetErrno().

Referenced by TXProofMgr::HandleInput().

Int_t TXSocket::Recv ( Int_t &  status,
Int_t &  kind 
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 198 of file TXSocket.h.

References TSocket::Recv().

Int_t TXSocket::Recv ( char *  mess,
Int_t  max 
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 200 of file TXSocket.h.

References TSocket::Recv().

Int_t TXSocket::Recv ( char *  mess,
Int_t  max,
Int_t &  kind 
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 202 of file TXSocket.h.

References TSocket::Recv().

Int_t TXSocket::RecvRaw ( void *  buf,
Int_t  len,
ESendRecvOptions  opt = kDefault 
) [virtual]

Reimplemented from TSocket.

Definition at line 1523 of file TXSocket.cxx.

References TXSockBuf::fBuf, fBufCur, fByteCur, fByteLeft, TSocket::fBytesRecv, TSocket::fgBytesRecv, PickUpReady(), PushBackSpare(), and TSocket::Touch().

Referenced by TXProofMgr::GetFile(), and Recv().

Int_t TXSocket::SendInterrupt ( Int_t  type  ) 

Definition at line 1579 of file TXSocket.cxx.

References TString::Data(), TObject::Error(), fConn, fHost, fSessionID, XrdProofConn::GetLastErr(), TProof::kShutdownInterrupt, kXP_destroy, kXP_interrupt, Printf(), TSystem::ResetErrno(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TSocket::Touch().

Int_t TXSocket::GetInterrupt ( Bool_t &  forward  ) 

Definition at line 943 of file TXSocket.cxx.

References TObject::Error(), fIForward, fILev, fIMtx, gDebug, TObject::Info(), kFALSE, and R__LOCKGUARD.

void TXSocket::SendUrgent ( Int_t  type,
Int_t  int1,
Int_t  int2 
)

Definition at line 1870 of file TXSocket.cxx.

References TString::Data(), fConn, fHost, fSessionID, XrdProofConn::GetLastErr(), kXP_urgent, Printf(), TSystem::ResetErrno(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TSocket::Touch().

void TXSocket::SetInterrupt (  )  [inline]

Definition at line 215 of file TXSocket.h.

References fConn, fRDInterrupt, kTRUE, and XrdProofConn::SetInterrupt().

Referenced by TXSlaveInterruptHandler::Notify().

Int_t TXSocket::Flush (  ) 

Definition at line 974 of file TXSocket.cxx.

References fAMtx, fAQue, fASem, fgSMtx, fgSQue, i, nf, R__LOCKGUARD, and TSemaphore::TryWait().

Bool_t TXSocket::Ping ( const char *  ord = 0  ) 

Definition at line 1225 of file TXSocket.cxx.

References XPD::clientMarshall(), TString::Data(), TObject::Error(), fConn, fHost, fMode, fSessionID, gDebug, XrdProofConn::GetLastErr(), XrdClientMessage::HeaderStatus(), TObject::Info(), IsValid(), kFALSE, kOK, kTRUE, kXP_ping, kXPD_internal, kXR_ok, XrdProofConn::LowWrite(), net2host(), Printf(), TSystem::ResetErrno(), SafeDelete, XrdProofConn::SendReq(), XrdProofConn::SetSID(), and TSocket::Touch().

Referenced by TXSocketPingHandler::Notify().

void TXSocket::RemoteTouch (  ) 

Definition at line 1297 of file TXSocket.cxx.

References XPD::clientMarshall(), TObject::Error(), fConn, fSessionID, gDebug, TNamed::GetName(), TObject::Info(), IsValid(), kOK, kXP_touch, XrdProofConn::LowWrite(), TSystem::ResetErrno(), and XrdProofConn::SetSID().

Referenced by TXProofMgr::HandleInput().

void TXSocket::CtrlC (  ) 

Definition at line 1335 of file TXSocket.cxx.

References XPD::clientMarshall(), TObject::Error(), fConn, gDebug, TNamed::GetName(), TObject::Info(), IsValid(), kOK, kXP_ctrlc, XrdProofConn::LowWrite(), TSystem::ResetErrno(), and XrdProofConn::SetSID().

Int_t TXSocket::SetOption ( ESockOptions  ,
Int_t   
) [inline, virtual]

Reimplemented from TSocket.

Definition at line 230 of file TXSocket.h.

void TXSocket::DisableTimeout (  )  [inline]

Definition at line 233 of file TXSocket.h.

References fDontTimeout, and kTRUE.

void TXSocket::EnableTimeout (  )  [inline]

Definition at line 234 of file TXSocket.h.

References fDontTimeout, and kFALSE.

Int_t TXSocket::Reconnect (  )  [virtual]

Reimplemented from TSocket.

Definition at line 2057 of file TXSocket.cxx.

References XrdOucString::c_str(), Close(), Create(), TString::Data(), TObject::Error(), fConn, XrdProofConn::fLastErrMsg, fMode, XrdProofConn::fPhyConn, TSocket::fUrl, fXrdProofdVersion, gDebug, XrdProofConn::GetLogConnID(), TObject::Info(), XrdProofConn::IsValid(), kTRUE, XrdOucString::length(), and XrdProofConn::ReConnect().

Referenced by TXProofMgr::HandleError().

Friends And Related Function Documentation

friend class TXProofMgr [friend]

Definition at line 76 of file TXSocket.h.

friend class TXProofServ [friend]

Definition at line 77 of file TXSocket.h.

friend class TXSlave [friend]

Definition at line 78 of file TXSocket.h.

friend class TXSocketHandler [friend]

Definition at line 79 of file TXSocket.h.

friend class TXSockPipe [friend]

Definition at line 80 of file TXSocket.h.

friend class TXUnixSocket [friend]

Definition at line 81 of file TXSocket.h.

Member Data Documentation

char TXSocket::fMode [private]

Definition at line 84 of file TXSocket.h.

Referenced by Create(), Ping(), Reconnect(), and TXSocket().

kXR_int32 TXSocket::fSendOpt [private]

Definition at line 85 of file TXSocket.h.

Referenced by Send(), SendRaw(), SetSendOpt(), and TXSocket().

Short_t TXSocket::fSessionID [private]

Definition at line 86 of file TXSocket.h.

Referenced by Close(), Create(), Ping(), ProcessUnsolicitedMsg(), RemoteTouch(), SendCoordinator(), SendInterrupt(), SendRaw(), SendUrgent(), SetSessionID(), TXSocket(), and TXUnixSocket::~TXUnixSocket().

TString TXSocket::fUser [private]

Definition at line 87 of file TXSocket.h.

Referenced by TXSocket().

TString TXSocket::fHost [private]

Definition at line 88 of file TXSocket.h.

Referenced by Create(), DisconnectSession(), Ping(), SendCoordinator(), SendInterrupt(), SendRaw(), SendUrgent(), and TXSocket().

Int_t TXSocket::fPort [private]

Definition at line 89 of file TXSocket.h.

Referenced by TXSocket().

Int_t TXSocket::fLogLevel [private]

Definition at line 91 of file TXSocket.h.

Referenced by Create().

TString TXSocket::fBuffer [private]

Definition at line 93 of file TXSocket.h.

Referenced by Create(), and TXSocket().

TObject* TXSocket::fReference [private]

Definition at line 94 of file TXSocket.h.

Referenced by TXSocket().

TXHandler* TXSocket::fHandler [private]

Definition at line 95 of file TXSocket.h.

Referenced by ProcessUnsolicitedMsg(), and TXSocket().

XrdProofConn* TXSocket::fConn [private]

Definition at line 97 of file TXSocket.h.

Referenced by Close(), Create(), CtrlC(), DisconnectSession(), GetLogConnID(), GetLowSocket(), GetOpenError(), GetServType(), GetSessionID(), IsServProofd(), IsValid(), Ping(), ProcessUnsolicitedMsg(), TXProofMgr::PutFile(), Reconnect(), TXUnixSocket::Reconnect(), RemoteTouch(), SendCoordinator(), SendInterrupt(), SendRaw(), SendUrgent(), SetInterrupt(), SetSessionID(), and TXSocket().

TSemaphore TXSocket::fASem [private]

Definition at line 100 of file TXSocket.h.

Referenced by Flush(), PickUpReady(), PostMsg(), and ProcessUnsolicitedMsg().

TMutex* TXSocket::fAMtx [private]

Definition at line 101 of file TXSocket.h.

Referenced by Flush(), PickUpReady(), PostMsg(), ProcessUnsolicitedMsg(), TXSocket(), and ~TXSocket().

std::list<TXSockBuf *> TXSocket::fAQue [private]

Definition at line 102 of file TXSocket.h.

Referenced by Flush(), PickUpReady(), PostMsg(), ProcessUnsolicitedMsg(), and TXSocket().

Int_t TXSocket::fByteLeft [private]

Definition at line 103 of file TXSocket.h.

Referenced by PickUpReady(), PushBackSpare(), RecvRaw(), and TXSocket().

Int_t TXSocket::fByteCur [private]

Definition at line 104 of file TXSocket.h.

Referenced by PickUpReady(), PushBackSpare(), RecvRaw(), and TXSocket().

TXSockBuf* TXSocket::fBufCur [private]

Definition at line 105 of file TXSocket.h.

Referenced by PickUpReady(), PushBackSpare(), RecvRaw(), and TXSocket().

TSemaphore TXSocket::fAsynProc [private]

Definition at line 107 of file TXSocket.h.

Referenced by Close(), and ProcessUnsolicitedMsg().

TMutex* TXSocket::fIMtx [private]

Definition at line 110 of file TXSocket.h.

Referenced by GetInterrupt(), ProcessUnsolicitedMsg(), TXSocket(), and ~TXSocket().

kXR_int32 TXSocket::fILev [private]

Definition at line 111 of file TXSocket.h.

Referenced by GetInterrupt(), ProcessUnsolicitedMsg(), and TXSocket().

Bool_t TXSocket::fIForward [private]

Definition at line 112 of file TXSocket.h.

Referenced by GetInterrupt(), ProcessUnsolicitedMsg(), and TXSocket().

Int_t TXSocket::fPid [private]

Definition at line 115 of file TXSocket.h.

Referenced by TXSocket().

Bool_t TXSocket::fDontTimeout [private]

Definition at line 118 of file TXSocket.h.

Referenced by DisableTimeout(), EnableTimeout(), and PickUpReady().

Bool_t TXSocket::fRDInterrupt [private]

Definition at line 119 of file TXSocket.h.

Referenced by PickUpReady(), and SetInterrupt().

Int_t TXSocket::fXrdProofdVersion [private]

Definition at line 122 of file TXSocket.h.

Referenced by Create(), GetXrdProofdVersion(), Reconnect(), TXUnixSocket::Reconnect(), SendCoordinator(), and TXSocket().

TXSockPipe TXSocket::fgPipe [static, private]

Definition at line 125 of file TXSocket.h.

Referenced by Close(), TXSlave::FlushSocket(), PickUpReady(), PostMsg(), ProcessUnsolicitedMsg(), SetLocation(), TXProofServ::Terminate(), and TXSocket().

TString TXSocket::fgLoc [static, private]

Definition at line 126 of file TXSocket.h.

Referenced by SetLocation().

Bool_t TXSocket::fgInitDone [static, private]

Definition at line 127 of file TXSocket.h.

Referenced by InitEnvs(), and TXSocket().

TMutex TXSocket::fgSMtx [static, private]

Definition at line 130 of file TXSocket.h.

Referenced by Flush(), PopUpSpare(), and PushBackSpare().

std::list< TXSockBuf * > TXSocket::fgSQue [static, private]

Definition at line 131 of file TXSocket.h.

Referenced by Flush(), PopUpSpare(), and PushBackSpare().

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:49:56 2011 for ROOT_528-00b_version by  doxygen 1.5.1