|
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) |
short | Connect (XrdClientUrlInfo Host2Conn, XrdClientAbsUnsolMsgHandler *unsolhandler) |
void | Disconnect (bool ForcePhysicalDisc) |
virtual bool | GetAccessToSrv () |
XReqErrorType | GoBackToRedirector () |
XrdOucString | GetClientHostDomain () |
long | GetDataFromCache (const void *buffer, long long begin_offs, long long end_offs, bool PerfCalc, XrdClientIntvList &missingblks, long &outstandingblks) |
bool | SubmitDataToCache (XrdClientMessage *xmsg, long long begin_offs, long long end_offs) |
bool | SubmitRawDataToCache (const void *buffer, long long begin_offs, long long end_offs) |
void | SubmitPlaceholderToCache (long long begin_offs, long long end_offs) |
void | RemoveAllDataFromCache (bool keepwriteblocks=true) |
void | RemoveDataFromCache (long long begin_offs, long long end_offs, bool remove_overlapped=false) |
void | RemovePlaceholdersFromCache () |
void | PrintCache () |
bool | GetCacheInfo (int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness) |
void | SetCacheSize (int CacheSize) |
void | SetCacheRmPolicy (int RmPolicy) |
void | UnPinCacheBlk (long long begin_offs, long long end_offs) |
int | GetLogConnID () const |
ERemoteServerType | GetServerType () const |
kXR_unt16 | GetStreamID () const |
XrdClientUrlInfo * | GetLBSUrl () |
XrdClientUrlInfo | GetCurrentUrl () |
XrdClientUrlInfo | GetRedirUrl () |
XErrorCode | GetOpenError () const |
virtual XReqErrorType | GoToAnotherServer (XrdClientUrlInfo &newdest) |
bool | IsConnected () const |
bool | IsPhyConnConnected () |
void | ClearLastServerError () |
UnsolRespProcResult | ProcessAsynResp (XrdClientMessage *unsolmsg) |
virtual bool | SendGenCommand (ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, char *CmdName, int substreamid=0) |
int | GetOpenSockFD () const |
void | SetClientHostDomain (const char *src) |
void | SetConnected (bool conn) |
void | SetOpenError (XErrorCode err) |
int | GetParallelStreamToUse (int reqsperstream) |
int | GetParallelStreamCount () |
void | SetRedirHandler (XrdClientAbs *rh) |
void | SetRequestedDestHost (char *newh, kXR_int32 port) |
void | SetREQPauseState (kXR_int32 wsec) |
void | SetREQDelayedConnectState (kXR_int32 wsec) |
void | SetSID (kXR_char *sid) |
void | SetUrl (XrdClientUrlInfo thisUrl) |
XReqErrorType | WriteToServer_Async (ClientRequest *req, const void *reqMoreData, int substreamid=0) |
void | GetSessionID (SessionIDInfo &sess) |
long | GetServerProtocol () |
short | GetMaxRedirCnt () const |
void | SetMaxRedirCnt (short mx) |
short | GetRedirCnt () const |
bool | DoWriteSoftCheckPoint () |
bool | DoWriteHardCheckPoint () |
void | UnPinCacheBlk () |
void | SetOpTimeLimit (int delta_secs) |
bool | IsOpTimeLimitElapsed (time_t timenow) |
Static Public Member Functions |
XrdClientPhyConnection * | GetPhyConn (int LogConnID) |
XrdClientConnectionMgr * | GetConnectionMgr () |
XrdOucHash< SessionIDInfo > & | GetSessionIDRepo () |
Public Attributes |
int | fLastDataBytesRecv |
int | fLastDataBytesSent |
XErrorCode | fOpenError |
XrdOucString | fRedirOpaque |
ServerResponseHeader | LastServerResp |
ServerResponseBody_Error | LastServerError |
Protected Member Functions |
void | SetLogConnID (int cid) |
void | SetStreamID (kXR_unt16 sid) |
Protected Attributes |
XrdClientAbsUnsolMsgHandler * | fUnsolMsgHandler |
XrdClientUrlInfo | fUrl |
XrdClientUrlInfo * | fLBSUrl |
XrdClientUrlInfo | fREQUrl |
short | fGlobalRedirCnt |
Private Member Functions |
bool | CheckErrorStatus (XrdClientMessage *, short &, char *) |
void | CheckPort (int &port) |
void | CheckREQPauseState () |
void | CheckREQConnectWaitState () |
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 &) |
void | ClearSessionID () |
XReqErrorType | WriteToServer (ClientRequest *req, const void *reqMoreData, short LogConnID, int substreamid=0) |
bool | WaitResp (int secsmax) |
Private Attributes |
bool | fConnected |
bool | fGettingAccessToSrv |
time_t | fGlobalRedirLastUpdateTimestamp |
int | fLogConnID |
kXR_unt16 | fPrimaryStreamid |
short | fMaxGlobalRedirCnt |
XrdClientReadCache * | fMainReadCache |
time_t | fOpTimeLimit |
XrdClientAbs * | fRedirHandler |
XrdOucString | fRedirInternalToken |
XrdSysCondVar * | fREQWaitResp |
ServerResponseBody_Attn_asynresp * | fREQWaitRespData |
time_t | fREQWaitTimeLimit |
XrdSysCondVar * | fREQWait |
time_t | fREQConnectWaitTimeLimit |
XrdSysCondVar * | fREQConnectWait |
long | fServerProto |
ERemoteServerType | fServerType |
int | fOpenSockFD |
XrdSysCondVar * | fWriteWaitAck |
XrdClientVector< ClientRequest > | fWriteReqsToRetry |
Static Private Attributes |
XrdOucString | fgClientHostDomain |
XrdOucHash< SessionIDInfo > | fSessionIDRepo |
XrdClientConnectionMgr * | fgConnectionMgr = 0 |