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