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