Go to the documentation of this file.
49 #define ConnectionManager XrdClientConn::GetConnectionMgr()
108 long long begin_offs,
112 long &outstandingblks );
115 long long begin_offs,
119 long long begin_offs,
123 long long end_offs) {
135 long long end_offs,
bool remove_overlapped =
false) {
156 long long &bytessubmitted,
163 long long &misscount,
169 long long &readreqcnt,
172 float &bytesusefulness
241 const void *reqMoreData,
242 void **answMoreDataAllocated,
243 void *answMoreData,
bool HasToAlloc,
244 char *CmdName,
int substreamid = 0);
308 const void* reqMoreData,
309 int substreamid = 0);
410 const void *reqMoreData,
411 void **answMoreDataAllocated,
414 int substreamid = 0);
441 const void* reqMoreData,
443 int substreamid = 0);
int fLogConnID
Definition: XrdClientConn.hh:360
struct ServerResponseHeader LastServerResp
Definition: XrdClientConn.hh:227
kXR_unt16 GetStreamID() const
Definition: XrdClientConn.hh:214
void SetOpenError(XErrorCode err)
Definition: XrdClientConn.hh:251
int kXR_int32
Definition: XPtypes.hh:89
bool fLBSIsMeta
Definition: XrdClientConn.hh:448
XReqErrorType WriteToServer(ClientRequest *req, const void *reqMoreData, short LogConnID, int substreamid=0)
Definition: XProtocol.hh:814
static void DelSessionIDRepo()
Definition: XrdClientConn.hh:314
Definition: XrdClientReadCache.hh:161
time_t fREQWaitTimeLimit
Definition: XrdClientConn.hh:382
void GetInfo(int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness)
bool GetCacheInfo(int &size, long long &bytessubmitted, long long &byteshit, long long &misscount, float &missrate, long long &readreqcnt, float &bytesusefulness)
Definition: XrdClientConn.hh:151
XrdOucString fRedirCGI
Definition: XrdClientConn.hh:451
short Connect(XrdClientUrlInfo Host2Conn, XrdClientAbsUnsolMsgHandler *unsolhandler)
ServerResponseBody_Attn_asynresp * fREQWaitRespData
Definition: XrdClientConn.hh:380
UnsolRespProcResult
Definition: XrdClientUnsolMsg.hh:43
Definition: XrdSysPthread.hh:166
XrdOucString ParseDomainFromHostname(XrdOucString hostname)
bool fConnected
Definition: XrdClientConn.hh:356
int fLastDataBytesRecv
Definition: XrdClientConn.hh:76
XrdClientMessage * ClientServerCmd(ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, int substreamid=0)
#define FALSE
Definition: XrdClientConst.hh:187
bool CacheWillFit(long long bytes)
Definition: XrdClientConn.hh:86
@ kTSRHContinue
Definition: XrdClientConn.hh:68
void SetRedirHandler(XrdClientAbs *rh)
Definition: XrdClientConn.hh:257
void CheckPort(int &port)
Definition: XrdClientConn.hh:54
XrdOucString GetDomainToMatch(XrdOucString hostname)
void SetMaxRedirCnt(short mx)
Definition: XrdClientConn.hh:324
bool IsOpTimeLimitElapsed(time_t timenow)
EThreeStateReadHandler
Definition: XrdClientConn.hh:65
unsigned char kXR_char
Definition: XPtypes.hh:65
Definition: XrdOucHash.hh:128
XErrorCode
Definition: XProtocol.hh:330
void Disconnect(bool ForcePhysicalDisc)
XrdClientUrlInfo * fLBSUrl
Definition: XrdClientConn.hh:348
void SetStreamID(kXR_unt16 sid)
Definition: XrdClientConn.hh:340
XrdClientReadCache * fMainReadCache
Definition: XrdClientConn.hh:366
static XrdOucHash< SessionIDInfo > fSessionIDRepo
Definition: XrdClientConn.hh:394
void CheckREQConnectWaitState()
void SetCacheSize(int CacheSize)
Definition: XrdClientConn.hh:187
int GetParallelStreamCount()
XrdClientUrlInfo fREQUrl
Definition: XrdClientConn.hh:349
XReqErrorType GoBackToRedirector()
bool DoWriteHardCheckPoint()
void RemovePlaceholdersFromCache()
Definition: XrdClientConn.hh:140
void SetClientHostDomain(const char *src)
Definition: XrdClientConn.hh:248
XErrorCode fOpenError
Definition: XrdClientConn.hh:78
UnsolRespProcResult ProcessAsynResp(XrdClientMessage *unsolmsg)
void SetRequestedDestHost(char *newh, kXR_int32 port)
Definition: XrdClientConn.hh:259
XrdOucString fRedirOpaque
Definition: XrdClientConn.hh:80
kXR_int32 errnum
Definition: XProtocol.hh:790
bool DomainMatcher(XrdOucString dom, XrdOucString domlist)
XrdClientAbsUnsolMsgHandler * fUnsolMsgHandler
Definition: XrdClientConn.hh:345
void RemoveAllDataFromCache(bool keepwriteblocks=true)
Definition: XrdClientConn.hh:129
ERemoteServerType GetServerType() const
Definition: XrdClientConn.hh:212
void UnPinCacheBlk(long long begin_offs, long long end_offs)
Definition: XrdClientConn.hh:200
void Broadcast()
Definition: XrdSysPthread.hh:89
XReqErrorType WriteToServer_Async(ClientRequest *req, const void *reqMoreData, int substreamid=0)
@ kSEHRBreakLoop
Definition: XrdClientConn.hh:60
XrdOucString GetClientHostDomain()
Definition: XrdClientConn.hh:99
bool SubmitRawDataToCache(const void *buffer, long long begin_offs, long long end_offs)
unsigned short kXR_unt16
Definition: XPtypes.hh:67
XrdOucString fRedirInternalToken
Definition: XrdClientConn.hh:375
ERemoteServerType
Definition: XrdClientPhyConnection.hh:56
@ kTSRHReturnMex
Definition: XrdClientConn.hh:66
void SetREQDelayedConnectState(kXR_int32 wsec)
Definition: XrdClientConn.hh:286
struct ServerResponseBody_Error LastServerError
Definition: XrdClientConn.hh:230
virtual bool SendGenCommand(ClientRequest *req, const void *reqMoreData, void **answMoreDataAllocated, void *answMoreData, bool HasToAlloc, char *CmdName, int substreamid=0)
Definition: XrdSysPthread.hh:79
virtual XReqErrorType GoToMetaManager()
@ kSEHRRedirLimitReached
Definition: XrdClientConn.hh:63
Definition: XrdClientAbs.hh:49
int GetOpenSockFD() const
Definition: XrdClientConn.hh:246
@ kSEHRReturnNoMsgToCaller
Definition: XrdClientConn.hh:62
@ kTSRHReturnNullMex
Definition: XrdClientConn.hh:67
int Port
Definition: XrdClientUrlInfo.hh:56
Definition: XrdClientConnMgr.hh:61
Definition: XrdClientMessage.hh:49
bool CheckErrorStatus(XrdClientMessage *, short &, char *)
time_t fREQConnectWaitTimeLimit
Definition: XrdClientConn.hh:384
void SetLogConnID(int cid)
Definition: XrdClientConn.hh:339
@ kSEHRReturnMsgToCaller
Definition: XrdClientConn.hh:59
Definition: XrdClientVector.hh:49
XrdSysCondVar * fWriteWaitAck
Definition: XrdClientConn.hh:401
Definition: XProtocol.hh:789
@ kXR_noErrorYet
Definition: XProtocol.hh:362
ERemoteServerType DoHandShake(short log)
void UnPinCacheBlk(long long begin_offs, long long end_offs)
XrdClientUrlInfo * GetLBSUrl()
Definition: XrdClientConn.hh:216
void UnLock()
Definition: XrdSysPthread.hh:94
Definition: XProtocol.hh:630
static XrdOucString fgClientHostDomain
Definition: XrdClientConn.hh:355
XReqErrorType
Definition: XProtocol.hh:97
short GetRedirCnt() const
Definition: XrdClientConn.hh:325
void RemoveDataFromCache(long long begin_offs, long long end_offs, bool remove_overlapped=false)
Definition: XrdClientConn.hh:134
bool WaitResp(int secsmax)
bool IsConnected() const
Definition: XrdClientConn.hh:224
short fMaxGlobalRedirCnt
Definition: XrdClientConn.hh:365
Definition: XProtocol.hh:841
bool DoWriteSoftCheckPoint()
XrdSysCondVar * fREQWaitResp
Definition: XrdClientConn.hh:378
XrdSecProtocol * DoAuthentication(char *plist, int plsiz)
bool CheckHostDomain(XrdOucString hostToCheck)
@ kSEHRContinue
Definition: XrdClientConn.hh:61
bool WillFit(long long bc)
Definition: XrdClientReadCache.hh:279
bool fGettingAccessToSrv
Definition: XrdClientConn.hh:357
XrdClientUrlInfo * GetMetaUrl()
Definition: XrdClientConn.hh:217
long GetServerProtocol()
Definition: XrdClientConn.hh:321
kXR_unt16 fPrimaryStreamid
Definition: XrdClientConn.hh:361
XrdClientUrlInfo * fMetaUrl
Definition: XrdClientConn.hh:447
bool IsPhyConnConnected()
void SetBlkRemovalPolicy(int p)
Definition: XrdClientReadCache.hh:271
int fOpenSockFD
Definition: XrdClientConn.hh:398
XrdClientMessage * ReadPartialAnswer(XReqErrorType &, size_t &, ClientRequest *, bool, void **, EThreeStateReadHandler &)
void SetREQPauseState(kXR_int32 wsec)
Definition: XrdClientConn.hh:268
Definition: XrdClientConn.hh:72
Definition: XrdClientUnsolMsg.hh:51
ERemoteServerType fServerType
Definition: XrdClientConn.hh:388
void SetUrl(XrdClientUrlInfo thisUrl)
Definition: XrdClientConn.hh:302
Definition: XrdSecInterface.hh:131
void PrintCache()
Definition: XrdClientConn.hh:145
static XrdClientConnectionMgr * fgConnectionMgr
Definition: XrdClientConn.hh:399
void SetOpTimeLimit(int delta_secs)
XrdOucString Host
Definition: XrdClientUrlInfo.hh:55
static XrdClientPhyConnection * GetPhyConn(int LogConnID)
void SetSID(kXR_char *sid)
Definition: XrdClientUrlInfo.hh:50
static XrdClientConnectionMgr * GetConnectionMgr()
Definition: XrdClientConn.hh:311
XrdSysCondVar * fREQWait
Definition: XrdClientConn.hh:383
void UnLock()
Definition: XrdSysPthread.hh:222
short GetMaxRedirCnt() const
Definition: XrdClientConn.hh:323
long fServerProto
Definition: XrdClientConn.hh:387
int fLastDataBytesSent
Definition: XrdClientConn.hh:77
XErrorCode GetOpenError() const
Definition: XrdClientConn.hh:221
void CheckREQPauseState()
bool CheckResp(struct ServerResponseHeader *resp, const char *method)
void Lock()
Definition: XrdSysPthread.hh:220
void RemovePlaceholders()
short fGlobalRedirCnt
Definition: XrdClientConn.hh:351
bool SubmitDataToCache(XrdClientMessage *xmsg, long long begin_offs, long long end_offs)
time_t fOpTimeLimit
Definition: XrdClientConn.hh:369
XrdClientUrlInfo fUrl
Definition: XrdClientConn.hh:347
void PutPlaceholder(long long begin_offs, long long end_offs)
Definition: XrdClientPhyConnection.hh:69
void Lock()
Definition: XrdSysPthread.hh:82
ESrvErrorHandlerRetval
Definition: XrdClientConn.hh:58
void SetConnected(bool conn)
Definition: XrdClientConn.hh:249
ESrvErrorHandlerRetval HandleServerError(XReqErrorType &, XrdClientMessage *, ClientRequest *)
XrdClientVector< ClientRequest > fWriteReqsToRetry
Definition: XrdClientConn.hh:402
XrdSysCondVar * fREQConnectWait
Definition: XrdClientConn.hh:385
void SetSize(int sz)
Definition: XrdClientReadCache.hh:267
bool MatchStreamid(struct ServerResponseHeader *ServerResponse)
SessionIDInfo mySessionID
Definition: XrdClientConn.hh:389
int GetParallelStreamToUse(int reqsperstream)
virtual bool GetAccessToSrv()
int GetLogConnID() const
Definition: XrdClientConn.hh:210
void ClearLastServerError()
Definition: XrdClientConn.hh:233
long GetDataFromCache(const void *buffer, long long begin_offs, long long end_offs, bool PerfCalc, XrdClientIntvList &missingblks, long &outstandingblks)
void RemoveItems(bool leavepinned=true)
Definition: XrdOucString.hh:254
virtual XReqErrorType GoToAnotherServer(XrdClientUrlInfo &newdest)
void GetSessionID(SessionIDInfo &sess)
Definition: XrdClientConn.hh:319
XrdClientAbs * fRedirHandler
Definition: XrdClientConn.hh:371
void SetCacheRmPolicy(int RmPolicy)
Definition: XrdClientConn.hh:195
XrdClientUrlInfo GetCurrentUrl()
Definition: XrdClientConn.hh:218
time_t fGlobalRedirLastUpdateTimestamp
Definition: XrdClientConn.hh:358
static XrdSysMutex fSessionIDRMutex
Definition: XrdClientConn.hh:392
XrdClientUrlInfo GetRedirUrl()
Definition: XrdClientConn.hh:219
void SubmitPlaceholderToCache(long long begin_offs, long long end_offs)
Definition: XrdClientConn.hh:122