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