|
xrootd
|
#include <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) |
| 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 * | GetMetaUrl () |
| XrdClientUrlInfo | GetCurrentUrl () |
| XrdClientUrlInfo | GetRedirUrl () |
| XErrorCode | GetOpenError () const |
| virtual XReqErrorType | GoToAnotherServer (XrdClientUrlInfo &newdest) |
| virtual XReqErrorType | GoToMetaManager () |
| 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 | |
| static XrdClientPhyConnection * | GetPhyConn (int LogConnID) |
| static XrdClientConnectionMgr * | GetConnectionMgr () |
| static void | DelSessionIDRepo () |
Public Attributes | |
| int | fLastDataBytesRecv |
| int | fLastDataBytesSent |
| XErrorCode | fOpenError |
| XrdOucString | fRedirOpaque |
| struct ServerResponseHeader | LastServerResp |
| struct ServerResponseBody_Error | LastServerError |
| XrdOucString | fRedirCGI |
Protected Member Functions | |
| void | SetLogConnID (int cid) |
| void | SetStreamID (kXR_unt16 sid) |
Protected Attributes | |
| XrdClientAbsUnsolMsgHandler * | fUnsolMsgHandler |
| XrdClientUrlInfo | fUrl |
| XrdClientUrlInfo * | fLBSUrl |
| XrdClientUrlInfo | fREQUrl |
| short | fGlobalRedirCnt |
Static Private Attributes | |
| static XrdOucString | fgClientHostDomain |
| static XrdSysMutex | fSessionIDRMutex |
| static XrdOucHash< SessionIDInfo > | fSessionIDRepo |
| static XrdClientConnectionMgr * | fgConnectionMgr |
| XrdClientConn::XrdClientConn | ( | ) |
|
virtual |
|
inline |
References FALSE, fMainReadCache, and XrdClientReadCache::WillFit().
|
private |
| bool XrdClientConn::CheckHostDomain | ( | XrdOucString | hostToCheck | ) |
|
private |
|
private |
|
private |
|
private |
|
inline |
References ServerResponseBody_Error::errnum, kXR_noErrorYet, and LastServerError.
|
private |
| short XrdClientConn::Connect | ( | XrdClientUrlInfo | Host2Conn, |
| XrdClientAbsUnsolMsgHandler * | unsolhandler | ||
| ) |
|
inlinestatic |
References fSessionIDRepo, fSessionIDRMutex, XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
| void XrdClientConn::Disconnect | ( | bool | ForcePhysicalDisc | ) |
|
private |
|
private |
|
private |
|
private |
| bool XrdClientConn::DoWriteHardCheckPoint | ( | ) |
| bool XrdClientConn::DoWriteSoftCheckPoint | ( | ) |
|
virtual |
|
inline |
References fMainReadCache, and XrdClientReadCache::GetInfo().
|
inline |
References fgClientHostDomain.
|
inlinestatic |
References fgConnectionMgr.
|
inline |
References fUrl.
| long XrdClientConn::GetDataFromCache | ( | const void * | buffer, |
| long long | begin_offs, | ||
| long long | end_offs, | ||
| bool | PerfCalc, | ||
| XrdClientIntvList & | missingblks, | ||
| long & | outstandingblks | ||
| ) |
|
private |
|
inline |
References fLBSUrl.
|
inline |
References fLogConnID.
|
inline |
References fMaxGlobalRedirCnt.
|
inline |
References fMetaUrl.
|
inline |
References fOpenError.
|
inline |
References fOpenSockFD.
| int XrdClientConn::GetParallelStreamCount | ( | ) |
| int XrdClientConn::GetParallelStreamToUse | ( | int | reqsperstream | ) |
|
static |
|
inline |
References fGlobalRedirCnt.
|
inline |
References fREQUrl.
|
inline |
References fServerProto.
|
inline |
References fServerType.
|
inline |
References mySessionID.
|
inline |
References fPrimaryStreamid.
| XReqErrorType XrdClientConn::GoBackToRedirector | ( | ) |
|
virtual |
|
virtual |
|
private |
|
inline |
References fConnected.
| bool XrdClientConn::IsOpTimeLimitElapsed | ( | time_t | timenow | ) |
| bool XrdClientConn::IsPhyConnConnected | ( | ) |
|
private |
|
private |
|
private |
|
inline |
References fMainReadCache, and XrdClientReadCache::PrintCache().
| UnsolRespProcResult XrdClientConn::ProcessAsynResp | ( | XrdClientMessage * | unsolmsg | ) |
|
private |
|
inline |
References fMainReadCache, and XrdClientReadCache::RemoveItems().
|
inline |
References fMainReadCache, and XrdClientReadCache::RemoveItems().
|
inline |
References fMainReadCache, and XrdClientReadCache::RemovePlaceholders().
|
virtual |
|
inline |
References fMainReadCache, and XrdClientReadCache::SetBlkRemovalPolicy().
|
inline |
References fMainReadCache, and XrdClientReadCache::SetSize().
|
inline |
References fgClientHostDomain.
|
inline |
References fConnected.
|
inlineprotected |
References fLogConnID.
|
inline |
References fMaxGlobalRedirCnt.
|
inline |
References fOpenError.
| void XrdClientConn::SetOpTimeLimit | ( | int | delta_secs | ) |
|
inline |
References fRedirHandler.
|
inline |
|
inline |
References XrdSysCondVar::Broadcast(), fREQWait, fREQWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
|
inline |
References fREQUrl, fUrl, XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, and XrdClientUrlInfo::SetAddrFromHost().
| void XrdClientConn::SetSID | ( | kXR_char * | sid | ) |
|
inlineprotected |
References fPrimaryStreamid.
|
inline |
References fUrl.
| bool XrdClientConn::SubmitDataToCache | ( | XrdClientMessage * | xmsg, |
| long long | begin_offs, | ||
| long long | end_offs | ||
| ) |
|
inline |
References fMainReadCache, and XrdClientReadCache::PutPlaceholder().
| bool XrdClientConn::SubmitRawDataToCache | ( | const void * | buffer, |
| long long | begin_offs, | ||
| long long | end_offs | ||
| ) |
| void XrdClientConn::UnPinCacheBlk | ( | ) |
|
inline |
References XrdSysCondVar::Broadcast(), fMainReadCache, fWriteWaitAck, and XrdClientReadCache::UnPinCacheBlk().
|
private |
|
private |
| XReqErrorType XrdClientConn::WriteToServer_Async | ( | ClientRequest * | req, |
| const void * | reqMoreData, | ||
| int | substreamid = 0 |
||
| ) |
|
private |
Referenced by IsConnected(), and SetConnected().
|
staticprivate |
Referenced by GetClientHostDomain(), and SetClientHostDomain().
|
staticprivate |
Referenced by GetConnectionMgr().
|
private |
|
protected |
Referenced by GetRedirCnt().
|
private |
| int XrdClientConn::fLastDataBytesRecv |
| int XrdClientConn::fLastDataBytesSent |
|
private |
|
protected |
Referenced by GetLBSUrl().
|
private |
Referenced by GetLogConnID(), and SetLogConnID().
|
private |
|
private |
Referenced by GetMaxRedirCnt(), and SetMaxRedirCnt().
|
private |
Referenced by GetMetaUrl().
| XErrorCode XrdClientConn::fOpenError |
Referenced by GetOpenError(), and SetOpenError().
|
private |
Referenced by GetOpenSockFD().
|
private |
|
private |
Referenced by GetStreamID(), and SetStreamID().
| XrdOucString XrdClientConn::fRedirCGI |
|
private |
Referenced by SetRedirHandler().
|
private |
| XrdOucString XrdClientConn::fRedirOpaque |
|
private |
Referenced by SetREQDelayedConnectState().
|
private |
Referenced by SetREQDelayedConnectState().
|
protected |
Referenced by GetRedirUrl(), and SetRequestedDestHost().
|
private |
Referenced by SetREQPauseState().
|
private |
|
private |
|
private |
Referenced by SetREQPauseState().
|
private |
Referenced by GetServerProtocol().
|
private |
Referenced by GetServerType().
|
staticprivate |
Referenced by DelSessionIDRepo().
|
staticprivate |
Referenced by DelSessionIDRepo().
|
protected |
|
protected |
Referenced by GetCurrentUrl(), SetRequestedDestHost(), and SetUrl().
|
private |
|
private |
Referenced by UnPinCacheBlk().
| struct ServerResponseBody_Error XrdClientConn::LastServerError |
Referenced by ClearLastServerError().
| struct ServerResponseHeader XrdClientConn::LastServerResp |
|
private |
Referenced by GetSessionID().