Definition at line 54 of file XrdClientConn.hh.
Classes | |
| struct | SessionIDInfo |
Public Types | |
| enum | ESrvErrorHandlerRetval { kSEHRReturnMsgToCaller = 0 , kSEHRBreakLoop = 1 , kSEHRContinue = 2 , kSEHRReturnNoMsgToCaller = 3 , kSEHRRedirLimitReached = 4 } |
| enum | EThreeStateReadHandler { kTSRHReturnMex = 0 , kTSRHReturnNullMex = 1 , kTSRHContinue = 2 } |
Public Member Functions | |
| 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) |
Static Public Member Functions | |
| static void | DelSessionIDRepo () |
| static XrdClientConnectionMgr * | GetConnectionMgr () |
| static XrdClientPhyConnection * | GetPhyConn (int LogConnID) |
Public Attributes | |
| int | fLastDataBytesRecv |
| int | fLastDataBytesSent |
| XErrorCode | fOpenError |
| XrdOucString | fRedirCGI |
| XrdOucString | fRedirOpaque |
| struct ServerResponseBody_Error | LastServerError |
| struct ServerResponseHeader | LastServerResp |
Protected Member Functions | |
| void | SetLogConnID (int cid) |
| void | SetStreamID (kXR_unt16 sid) |
Protected Attributes | |
| short | fGlobalRedirCnt |
| XrdClientUrlInfo * | fLBSUrl |
| XrdClientUrlInfo | fREQUrl |
| XrdClientAbsUnsolMsgHandler * | fUnsolMsgHandler |
| XrdClientUrlInfo | fUrl |
Private Member Functions | |
| 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) |
Private Attributes | |
| bool | fConnected |
| bool | fGettingAccessToSrv |
| time_t | fGlobalRedirLastUpdateTimestamp |
| bool | fLBSIsMeta |
| int | fLogConnID |
| XrdClientReadCache * | fMainReadCache |
| short | fMaxGlobalRedirCnt |
| XrdClientUrlInfo * | fMetaUrl |
| int | fOpenSockFD |
| time_t | fOpTimeLimit |
| kXR_unt16 | fPrimaryStreamid |
| XrdClientAbs * | fRedirHandler |
| XrdOucString | fRedirInternalToken |
| XrdSysCondVar * | fREQConnectWait |
| time_t | fREQConnectWaitTimeLimit |
| XrdSysCondVar * | fREQWait |
| XrdSysCondVar * | fREQWaitResp |
| ServerResponseBody_Attn_asynresp * | fREQWaitRespData |
| time_t | fREQWaitTimeLimit |
| long | fServerProto |
| ERemoteServerType | fServerType |
| XrdClientVector< ClientRequest > | fWriteReqsToRetry |
| XrdSysCondVar * | fWriteWaitAck |
| SessionIDInfo | mySessionID |
Static Private Attributes | |
| static XrdOucString | fgClientHostDomain |
| static XrdClientConnectionMgr * | fgConnectionMgr |
| static XrdOucHash< SessionIDInfo > | fSessionIDRepo |
| static XrdSysMutex | fSessionIDRMutex |
| Enumerator | |
|---|---|
| kSEHRReturnMsgToCaller | |
| kSEHRBreakLoop | |
| kSEHRContinue | |
| kSEHRReturnNoMsgToCaller | |
| kSEHRRedirLimitReached | |
Definition at line 58 of file XrdClientConn.hh.
| Enumerator | |
|---|---|
| kTSRHReturnMex | |
| kTSRHReturnNullMex | |
| kTSRHContinue | |
Definition at line 65 of file XrdClientConn.hh.
| XrdClientConn::XrdClientConn | ( | ) |
|
virtual |
|
inline |
Definition at line 86 of file XrdClientConn.hh.
|
private |
| bool XrdClientConn::CheckHostDomain | ( | XrdOucString | hostToCheck | ) |
|
private |
|
private |
|
private |
|
private |
|
inline |
Definition at line 233 of file XrdClientConn.hh.
|
private |
| short XrdClientConn::Connect | ( | XrdClientUrlInfo | Host2Conn, |
| XrdClientAbsUnsolMsgHandler * | unsolhandler | ||
| ) |
|
inlinestatic |
Definition at line 314 of file XrdClientConn.hh.
| void XrdClientConn::Disconnect | ( | bool | ForcePhysicalDisc | ) |
|
private |
|
private |
|
private |
|
private |
| bool XrdClientConn::DoWriteHardCheckPoint | ( | ) |
| bool XrdClientConn::DoWriteSoftCheckPoint | ( | ) |
|
virtual |
|
inline |
Definition at line 151 of file XrdClientConn.hh.
|
inline |
Definition at line 99 of file XrdClientConn.hh.
|
inlinestatic |
Definition at line 311 of file XrdClientConn.hh.
|
inline |
Definition at line 218 of file XrdClientConn.hh.
| long XrdClientConn::GetDataFromCache | ( | const void * | buffer, |
| long long | begin_offs, | ||
| long long | end_offs, | ||
| bool | PerfCalc, | ||
| XrdClientIntvList & | missingblks, | ||
| long & | outstandingblks | ||
| ) |
|
private |
|
inline |
Definition at line 216 of file XrdClientConn.hh.
|
inline |
Definition at line 210 of file XrdClientConn.hh.
|
inline |
Definition at line 323 of file XrdClientConn.hh.
|
inline |
Definition at line 217 of file XrdClientConn.hh.
|
inline |
Definition at line 221 of file XrdClientConn.hh.
|
inline |
Definition at line 246 of file XrdClientConn.hh.
| int XrdClientConn::GetParallelStreamCount | ( | ) |
| int XrdClientConn::GetParallelStreamToUse | ( | int | reqsperstream | ) |
|
static |
|
inline |
Definition at line 325 of file XrdClientConn.hh.
|
inline |
Definition at line 219 of file XrdClientConn.hh.
|
inline |
Definition at line 321 of file XrdClientConn.hh.
|
inline |
Definition at line 212 of file XrdClientConn.hh.
|
inline |
Definition at line 319 of file XrdClientConn.hh.
|
inline |
Definition at line 214 of file XrdClientConn.hh.
| XReqErrorType XrdClientConn::GoBackToRedirector | ( | ) |
|
virtual |
|
virtual |
|
private |
|
inline |
Definition at line 224 of file XrdClientConn.hh.
| bool XrdClientConn::IsOpTimeLimitElapsed | ( | time_t | timenow | ) |
| bool XrdClientConn::IsPhyConnConnected | ( | ) |
|
private |
|
private |
|
private |
|
inline |
Definition at line 145 of file XrdClientConn.hh.
| UnsolRespProcResult XrdClientConn::ProcessAsynResp | ( | XrdClientMessage * | unsolmsg | ) |
|
private |
|
inline |
Definition at line 129 of file XrdClientConn.hh.
|
inline |
Definition at line 134 of file XrdClientConn.hh.
|
inline |
Definition at line 140 of file XrdClientConn.hh.
|
virtual |
|
inline |
Definition at line 195 of file XrdClientConn.hh.
|
inline |
Definition at line 187 of file XrdClientConn.hh.
|
inline |
Definition at line 248 of file XrdClientConn.hh.
|
inline |
Definition at line 249 of file XrdClientConn.hh.
|
inlineprotected |
Definition at line 339 of file XrdClientConn.hh.
|
inline |
Definition at line 324 of file XrdClientConn.hh.
|
inline |
Definition at line 251 of file XrdClientConn.hh.
| void XrdClientConn::SetOpTimeLimit | ( | int | delta_secs | ) |
|
inline |
Definition at line 257 of file XrdClientConn.hh.
|
inline |
Definition at line 286 of file XrdClientConn.hh.
|
inline |
Definition at line 268 of file XrdClientConn.hh.
|
inline |
Definition at line 259 of file XrdClientConn.hh.
| void XrdClientConn::SetSID | ( | kXR_char * | sid | ) |
|
inlineprotected |
Definition at line 340 of file XrdClientConn.hh.
|
inline |
Definition at line 302 of file XrdClientConn.hh.
| bool XrdClientConn::SubmitDataToCache | ( | XrdClientMessage * | xmsg, |
| long long | begin_offs, | ||
| long long | end_offs | ||
| ) |
|
inline |
Definition at line 122 of file XrdClientConn.hh.
| bool XrdClientConn::SubmitRawDataToCache | ( | const void * | buffer, |
| long long | begin_offs, | ||
| long long | end_offs | ||
| ) |
| void XrdClientConn::UnPinCacheBlk | ( | ) |
|
inline |
Definition at line 200 of file XrdClientConn.hh.
|
private |
|
private |
| XReqErrorType XrdClientConn::WriteToServer_Async | ( | ClientRequest * | req, |
| const void * | reqMoreData, | ||
| int | substreamid = 0 |
||
| ) |
|
private |
Definition at line 356 of file XrdClientConn.hh.
|
staticprivate |
Definition at line 355 of file XrdClientConn.hh.
|
staticprivate |
Definition at line 399 of file XrdClientConn.hh.
|
private |
Definition at line 357 of file XrdClientConn.hh.
|
protected |
Definition at line 351 of file XrdClientConn.hh.
|
private |
Definition at line 358 of file XrdClientConn.hh.
| int XrdClientConn::fLastDataBytesRecv |
Definition at line 76 of file XrdClientConn.hh.
| int XrdClientConn::fLastDataBytesSent |
Definition at line 77 of file XrdClientConn.hh.
|
private |
Definition at line 448 of file XrdClientConn.hh.
|
protected |
Definition at line 348 of file XrdClientConn.hh.
|
private |
Definition at line 360 of file XrdClientConn.hh.
|
private |
Definition at line 366 of file XrdClientConn.hh.
|
private |
Definition at line 365 of file XrdClientConn.hh.
|
private |
Definition at line 447 of file XrdClientConn.hh.
| XErrorCode XrdClientConn::fOpenError |
Definition at line 78 of file XrdClientConn.hh.
|
private |
Definition at line 398 of file XrdClientConn.hh.
|
private |
Definition at line 369 of file XrdClientConn.hh.
|
private |
Definition at line 361 of file XrdClientConn.hh.
| XrdOucString XrdClientConn::fRedirCGI |
Definition at line 451 of file XrdClientConn.hh.
|
private |
Definition at line 371 of file XrdClientConn.hh.
|
private |
Definition at line 375 of file XrdClientConn.hh.
| XrdOucString XrdClientConn::fRedirOpaque |
Definition at line 80 of file XrdClientConn.hh.
|
private |
Definition at line 385 of file XrdClientConn.hh.
|
private |
Definition at line 384 of file XrdClientConn.hh.
|
protected |
Definition at line 349 of file XrdClientConn.hh.
|
private |
Definition at line 383 of file XrdClientConn.hh.
|
private |
Definition at line 378 of file XrdClientConn.hh.
|
private |
Definition at line 380 of file XrdClientConn.hh.
|
private |
Definition at line 382 of file XrdClientConn.hh.
|
private |
Definition at line 387 of file XrdClientConn.hh.
|
private |
Definition at line 388 of file XrdClientConn.hh.
|
staticprivate |
Definition at line 394 of file XrdClientConn.hh.
|
staticprivate |
Definition at line 392 of file XrdClientConn.hh.
|
protected |
Definition at line 345 of file XrdClientConn.hh.
|
protected |
Definition at line 347 of file XrdClientConn.hh.
|
private |
Definition at line 402 of file XrdClientConn.hh.
|
private |
Definition at line 401 of file XrdClientConn.hh.
| struct ServerResponseBody_Error XrdClientConn::LastServerError |
Definition at line 231 of file XrdClientConn.hh.
| struct ServerResponseHeader XrdClientConn::LastServerResp |
Definition at line 228 of file XrdClientConn.hh.
|
private |
Definition at line 389 of file XrdClientConn.hh.