Definition at line 54 of file XrdClientConn.hh.
|
| | XrdClientConn () |
| |
| virtual | ~XrdClientConn () |
| |
| bool | CacheWillFit (long long bytes) |
| |
| bool | CheckHostDomain (XrdOucString hostToCheck) |
| |
| void | ClearLastServerError () |
| |
| short | Connect (XrdClientUrlInfo Host2Conn, XrdClientAbsUnsolMsgHandler *unsolhandler) |
| |
| void | Disconnect (bool ForcePhysicalDisc) |
| |
| bool | DoWriteHardCheckPoint () |
| |
| bool | DoWriteSoftCheckPoint () |
| |
| virtual bool | GetAccessToSrv () |
| |
| bool | GetCacheInfo (int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness) |
| |
| XrdOucString | GetClientHostDomain () |
| |
| XrdClientUrlInfo | GetCurrentUrl () |
| |
| long | GetDataFromCache (const void *buffer, long long begin_offs, long long end_offs, bool PerfCalc, XrdClientIntvList &missingblks, long &outstandingblks) |
| |
| XrdClientUrlInfo * | GetLBSUrl () |
| |
| int | GetLogConnID () const |
| |
| short | GetMaxRedirCnt () const |
| |
| XrdClientUrlInfo * | GetMetaUrl () |
| |
| XErrorCode | GetOpenError () const |
| |
| int | GetOpenSockFD () const |
| |
| int | GetParallelStreamCount () |
| |
| int | GetParallelStreamToUse (int reqsperstream) |
| |
| short | GetRedirCnt () const |
| |
| XrdClientUrlInfo | GetRedirUrl () |
| |
| long | GetServerProtocol () |
| |
| ERemoteServerType | GetServerType () const |
| |
| void | GetSessionID (SessionIDInfo &sess) |
| |
| kXR_unt16 | GetStreamID () const |
| |
| XReqErrorType | GoBackToRedirector () |
| |
| virtual XReqErrorType | GoToAnotherServer (XrdClientUrlInfo &newdest) |
| |
| virtual XReqErrorType | GoToMetaManager () |
| |
| bool | IsConnected () const |
| |
| bool | IsOpTimeLimitElapsed (time_t timenow) |
| |
| bool | IsPhyConnConnected () |
| |
| void | PrintCache () |
| |
| UnsolRespProcResult | ProcessAsynResp (XrdClientMessage *unsolmsg) |
| |
| void | RemoveAllDataFromCache (bool keepwriteblocks=true) |
| |
| void | RemoveDataFromCache (long long begin_offs, long long end_offs, bool remove_overlapped=false) |
| |
| void | RemovePlaceholdersFromCache () |
| |
| virtual bool | SendGenCommand (ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, char *CmdName, int substreamid=0) |
| |
| void | SetCacheRmPolicy (int RmPolicy) |
| |
| void | SetCacheSize (int CacheSize) |
| |
| void | SetClientHostDomain (const char *src) |
| |
| void | SetConnected (bool conn) |
| |
| void | SetMaxRedirCnt (short mx) |
| |
| void | SetOpenError (XErrorCode err) |
| |
| void | SetOpTimeLimit (int delta_secs) |
| |
| void | SetRedirHandler (XrdClientAbs *rh) |
| |
| void | SetREQDelayedConnectState (kXR_int32 wsec) |
| |
| void | SetREQPauseState (kXR_int32 wsec) |
| |
| void | SetRequestedDestHost (char *newh, kXR_int32 port) |
| |
| void | SetSID (kXR_char *sid) |
| |
| void | SetUrl (XrdClientUrlInfo thisUrl) |
| |
| bool | SubmitDataToCache (XrdClientMessage *xmsg, long long begin_offs, long long end_offs) |
| |
| void | SubmitPlaceholderToCache (long long begin_offs, long long end_offs) |
| |
| bool | SubmitRawDataToCache (const void *buffer, long long begin_offs, long long end_offs) |
| |
| void | UnPinCacheBlk () |
| |
| void | UnPinCacheBlk (long long begin_offs, long long end_offs) |
| |
| XReqErrorType | WriteToServer_Async (ClientRequest *req, const void *reqMoreData, int substreamid=0) |
| |
|
| bool | CheckErrorStatus (XrdClientMessage *, short &, char *) |
| |
| void | CheckPort (int &port) |
| |
| void | CheckREQConnectWaitState () |
| |
| void | CheckREQPauseState () |
| |
| bool | CheckResp (struct ServerResponseHeader *resp, const char *method) |
| |
| XrdClientMessage * | ClientServerCmd (ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, int substreamid=0) |
| |
| XrdSecProtocol * | DoAuthentication (char *plist, int plsiz) |
| |
| ERemoteServerType | DoHandShake (short log) |
| |
| bool | DoLogin () |
| |
| bool | DomainMatcher (XrdOucString dom, XrdOucString domlist) |
| |
| XrdOucString | GetDomainToMatch (XrdOucString hostname) |
| |
| ESrvErrorHandlerRetval | HandleServerError (XReqErrorType &, XrdClientMessage *, ClientRequest *) |
| |
| bool | MatchStreamid (struct ServerResponseHeader *ServerResponse) |
| |
| bool | PanicClose () |
| |
| XrdOucString | ParseDomainFromHostname (XrdOucString hostname) |
| |
| XrdClientMessage * | ReadPartialAnswer (XReqErrorType &, size_t &, ClientRequest *, bool, void **, EThreeStateReadHandler &) |
| |
| bool | WaitResp (int secsmax) |
| |
| XReqErrorType | WriteToServer (ClientRequest *req, const void *reqMoreData, short LogConnID, int substreamid=0) |
| |
#include </github/home/ROOT-CI/src/proof/xrdinc/XrdClient/XrdClientConn.hh>
◆ ESrvErrorHandlerRetval
| Enumerator |
|---|
| kSEHRReturnMsgToCaller | |
| kSEHRBreakLoop | |
| kSEHRContinue | |
| kSEHRReturnNoMsgToCaller | |
| kSEHRRedirLimitReached | |
Definition at line 58 of file XrdClientConn.hh.
◆ EThreeStateReadHandler
| Enumerator |
|---|
| kTSRHReturnMex | |
| kTSRHReturnNullMex | |
| kTSRHContinue | |
Definition at line 65 of file XrdClientConn.hh.
◆ XrdClientConn()
| XrdClientConn::XrdClientConn |
( |
| ) |
|
◆ ~XrdClientConn()
| virtual XrdClientConn::~XrdClientConn |
( |
| ) |
|
|
virtual |
◆ CacheWillFit()
| bool XrdClientConn::CacheWillFit |
( |
long long | bytes | ) |
|
|
inline |
◆ CheckErrorStatus()
◆ CheckHostDomain()
| bool XrdClientConn::CheckHostDomain |
( |
XrdOucString | hostToCheck | ) |
|
◆ CheckPort()
| void XrdClientConn::CheckPort |
( |
int & | port | ) |
|
|
private |
◆ CheckREQConnectWaitState()
| void XrdClientConn::CheckREQConnectWaitState |
( |
| ) |
|
|
private |
◆ CheckREQPauseState()
| void XrdClientConn::CheckREQPauseState |
( |
| ) |
|
|
private |
◆ CheckResp()
| bool XrdClientConn::CheckResp |
( |
struct ServerResponseHeader * | resp, |
|
|
const char * | method ) |
|
private |
◆ ClearLastServerError()
| void XrdClientConn::ClearLastServerError |
( |
| ) |
|
|
inline |
◆ ClientServerCmd()
◆ Connect()
◆ DelSessionIDRepo()
| static void XrdClientConn::DelSessionIDRepo |
( |
| ) |
|
|
inlinestatic |
◆ Disconnect()
| void XrdClientConn::Disconnect |
( |
bool | ForcePhysicalDisc | ) |
|
◆ DoAuthentication()
◆ DoHandShake()
◆ DoLogin()
| bool XrdClientConn::DoLogin |
( |
| ) |
|
|
private |
◆ DomainMatcher()
| bool XrdClientConn::DomainMatcher |
( |
XrdOucString | dom, |
|
|
XrdOucString | domlist ) |
|
private |
◆ DoWriteHardCheckPoint()
| bool XrdClientConn::DoWriteHardCheckPoint |
( |
| ) |
|
◆ DoWriteSoftCheckPoint()
| bool XrdClientConn::DoWriteSoftCheckPoint |
( |
| ) |
|
◆ GetAccessToSrv()
◆ GetCacheInfo()
| bool XrdClientConn::GetCacheInfo |
( |
int & | size, |
|
|
long long & | bytessubmitted, |
|
|
long long & | byteshit, |
|
|
long long & | misscount, |
|
|
float & | missrate, |
|
|
long long & | readreqcnt, |
|
|
float & | bytesusefulness ) |
|
inline |
◆ GetClientHostDomain()
| XrdOucString XrdClientConn::GetClientHostDomain |
( |
| ) |
|
|
inline |
◆ GetConnectionMgr()
◆ GetCurrentUrl()
◆ GetDataFromCache()
| long XrdClientConn::GetDataFromCache |
( |
const void * | buffer, |
|
|
long long | begin_offs, |
|
|
long long | end_offs, |
|
|
bool | PerfCalc, |
|
|
XrdClientIntvList & | missingblks, |
|
|
long & | outstandingblks ) |
◆ GetDomainToMatch()
| XrdOucString XrdClientConn::GetDomainToMatch |
( |
XrdOucString | hostname | ) |
|
|
private |
◆ GetLBSUrl()
◆ GetLogConnID()
| int XrdClientConn::GetLogConnID |
( |
| ) |
const |
|
inline |
◆ GetMaxRedirCnt()
| short XrdClientConn::GetMaxRedirCnt |
( |
| ) |
const |
|
inline |
◆ GetMetaUrl()
◆ GetOpenError()
| XErrorCode XrdClientConn::GetOpenError |
( |
| ) |
const |
|
inline |
◆ GetOpenSockFD()
| int XrdClientConn::GetOpenSockFD |
( |
| ) |
const |
|
inline |
◆ GetParallelStreamCount()
| int XrdClientConn::GetParallelStreamCount |
( |
| ) |
|
◆ GetParallelStreamToUse()
| int XrdClientConn::GetParallelStreamToUse |
( |
int | reqsperstream | ) |
|
◆ GetPhyConn()
◆ GetRedirCnt()
| short XrdClientConn::GetRedirCnt |
( |
| ) |
const |
|
inline |
◆ GetRedirUrl()
◆ GetServerProtocol()
| long XrdClientConn::GetServerProtocol |
( |
| ) |
|
|
inline |
◆ GetServerType()
◆ GetSessionID()
◆ GetStreamID()
| kXR_unt16 XrdClientConn::GetStreamID |
( |
| ) |
const |
|
inline |
◆ GoBackToRedirector()
◆ GoToAnotherServer()
◆ GoToMetaManager()
◆ HandleServerError()
◆ IsConnected()
| bool XrdClientConn::IsConnected |
( |
| ) |
const |
|
inline |
◆ IsOpTimeLimitElapsed()
| bool XrdClientConn::IsOpTimeLimitElapsed |
( |
time_t | timenow | ) |
|
◆ IsPhyConnConnected()
| bool XrdClientConn::IsPhyConnConnected |
( |
| ) |
|
◆ MatchStreamid()
| bool XrdClientConn::MatchStreamid |
( |
struct ServerResponseHeader * | ServerResponse | ) |
|
|
private |
◆ PanicClose()
| bool XrdClientConn::PanicClose |
( |
| ) |
|
|
private |
◆ ParseDomainFromHostname()
| XrdOucString XrdClientConn::ParseDomainFromHostname |
( |
XrdOucString | hostname | ) |
|
|
private |
◆ PrintCache()
| void XrdClientConn::PrintCache |
( |
| ) |
|
|
inline |
◆ ProcessAsynResp()
◆ ReadPartialAnswer()
◆ RemoveAllDataFromCache()
| void XrdClientConn::RemoveAllDataFromCache |
( |
bool | keepwriteblocks = true | ) |
|
|
inline |
◆ RemoveDataFromCache()
| void XrdClientConn::RemoveDataFromCache |
( |
long long | begin_offs, |
|
|
long long | end_offs, |
|
|
bool | remove_overlapped = false ) |
|
inline |
◆ RemovePlaceholdersFromCache()
| void XrdClientConn::RemovePlaceholdersFromCache |
( |
| ) |
|
|
inline |
◆ SendGenCommand()
| virtual bool XrdClientConn::SendGenCommand |
( |
ClientRequest * | req, |
|
|
const void * | reqMoreData, |
|
|
void ** | answMoreDataAllocated, |
|
|
void * | answMoreData, |
|
|
bool | HasToAlloc, |
|
|
char * | CmdName, |
|
|
int | substreamid = 0 ) |
|
virtual |
◆ SetCacheRmPolicy()
| void XrdClientConn::SetCacheRmPolicy |
( |
int | RmPolicy | ) |
|
|
inline |
◆ SetCacheSize()
| void XrdClientConn::SetCacheSize |
( |
int | CacheSize | ) |
|
|
inline |
◆ SetClientHostDomain()
| void XrdClientConn::SetClientHostDomain |
( |
const char * | src | ) |
|
|
inline |
◆ SetConnected()
| void XrdClientConn::SetConnected |
( |
bool | conn | ) |
|
|
inline |
◆ SetLogConnID()
| void XrdClientConn::SetLogConnID |
( |
int | cid | ) |
|
|
inlineprotected |
◆ SetMaxRedirCnt()
| void XrdClientConn::SetMaxRedirCnt |
( |
short | mx | ) |
|
|
inline |
◆ SetOpenError()
| void XrdClientConn::SetOpenError |
( |
XErrorCode | err | ) |
|
|
inline |
◆ SetOpTimeLimit()
| void XrdClientConn::SetOpTimeLimit |
( |
int | delta_secs | ) |
|
◆ SetRedirHandler()
◆ SetREQDelayedConnectState()
| void XrdClientConn::SetREQDelayedConnectState |
( |
kXR_int32 | wsec | ) |
|
|
inline |
◆ SetREQPauseState()
| void XrdClientConn::SetREQPauseState |
( |
kXR_int32 | wsec | ) |
|
|
inline |
◆ SetRequestedDestHost()
| void XrdClientConn::SetRequestedDestHost |
( |
char * | newh, |
|
|
kXR_int32 | port ) |
|
inline |
◆ SetSID()
| void XrdClientConn::SetSID |
( |
kXR_char * | sid | ) |
|
◆ SetStreamID()
| void XrdClientConn::SetStreamID |
( |
kXR_unt16 | sid | ) |
|
|
inlineprotected |
◆ SetUrl()
◆ SubmitDataToCache()
| bool XrdClientConn::SubmitDataToCache |
( |
XrdClientMessage * | xmsg, |
|
|
long long | begin_offs, |
|
|
long long | end_offs ) |
◆ SubmitPlaceholderToCache()
| void XrdClientConn::SubmitPlaceholderToCache |
( |
long long | begin_offs, |
|
|
long long | end_offs ) |
|
inline |
◆ SubmitRawDataToCache()
| bool XrdClientConn::SubmitRawDataToCache |
( |
const void * | buffer, |
|
|
long long | begin_offs, |
|
|
long long | end_offs ) |
◆ UnPinCacheBlk() [1/2]
| void XrdClientConn::UnPinCacheBlk |
( |
| ) |
|
◆ UnPinCacheBlk() [2/2]
| void XrdClientConn::UnPinCacheBlk |
( |
long long | begin_offs, |
|
|
long long | end_offs ) |
|
inline |
◆ WaitResp()
| bool XrdClientConn::WaitResp |
( |
int | secsmax | ) |
|
|
private |
◆ WriteToServer()
◆ WriteToServer_Async()
◆ fConnected
| bool XrdClientConn::fConnected |
|
private |
◆ fgClientHostDomain
| XrdOucString XrdClientConn::fgClientHostDomain |
|
staticprivate |
◆ fgConnectionMgr
◆ fGettingAccessToSrv
| bool XrdClientConn::fGettingAccessToSrv |
|
private |
◆ fGlobalRedirCnt
| short XrdClientConn::fGlobalRedirCnt |
|
protected |
◆ fGlobalRedirLastUpdateTimestamp
| time_t XrdClientConn::fGlobalRedirLastUpdateTimestamp |
|
private |
◆ fLastDataBytesRecv
| int XrdClientConn::fLastDataBytesRecv |
◆ fLastDataBytesSent
| int XrdClientConn::fLastDataBytesSent |
◆ fLBSIsMeta
| bool XrdClientConn::fLBSIsMeta |
|
private |
◆ fLBSUrl
◆ fLogConnID
| int XrdClientConn::fLogConnID |
|
private |
◆ fMainReadCache
◆ fMaxGlobalRedirCnt
| short XrdClientConn::fMaxGlobalRedirCnt |
|
private |
◆ fMetaUrl
◆ fOpenError
| XErrorCode XrdClientConn::fOpenError |
◆ fOpenSockFD
| int XrdClientConn::fOpenSockFD |
|
private |
◆ fOpTimeLimit
| time_t XrdClientConn::fOpTimeLimit |
|
private |
◆ fPrimaryStreamid
| kXR_unt16 XrdClientConn::fPrimaryStreamid |
|
private |
◆ fRedirCGI
| XrdOucString XrdClientConn::fRedirCGI |
◆ fRedirHandler
◆ fRedirInternalToken
| XrdOucString XrdClientConn::fRedirInternalToken |
|
private |
◆ fRedirOpaque
| XrdOucString XrdClientConn::fRedirOpaque |
◆ fREQConnectWait
| XrdSysCondVar* XrdClientConn::fREQConnectWait |
|
private |
◆ fREQConnectWaitTimeLimit
| time_t XrdClientConn::fREQConnectWaitTimeLimit |
|
private |
◆ fREQUrl
◆ fREQWait
| XrdSysCondVar* XrdClientConn::fREQWait |
|
private |
◆ fREQWaitResp
| XrdSysCondVar* XrdClientConn::fREQWaitResp |
|
private |
◆ fREQWaitRespData
◆ fREQWaitTimeLimit
| time_t XrdClientConn::fREQWaitTimeLimit |
|
private |
◆ fServerProto
| long XrdClientConn::fServerProto |
|
private |
◆ fServerType
◆ fSessionIDRepo
◆ fSessionIDRMutex
◆ fUnsolMsgHandler
◆ fUrl
◆ fWriteReqsToRetry
◆ fWriteWaitAck
| XrdSysCondVar* XrdClientConn::fWriteWaitAck |
|
private |
◆ LastServerError
◆ LastServerResp
| struct ServerResponseHeader XrdClientConn::LastServerResp |
◆ mySessionID
proof/xrdinc/XrdClient/XrdClientConn.hh