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