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().