#include <XrdClientConn.hh>
XrdClientConn::XrdClientConn | ( | ) |
virtual XrdClientConn::~XrdClientConn | ( | ) | [virtual] |
bool XrdClientConn::CacheWillFit | ( | long long | bytes | ) | [inline] |
References FALSE, fMainReadCache, and XrdClientReadCache::WillFit().
bool XrdClientConn::CheckErrorStatus | ( | XrdClientMessage * | , | |
short & | , | |||
char * | ||||
) | [private] |
bool XrdClientConn::CheckHostDomain | ( | XrdOucString | hostToCheck | ) |
void XrdClientConn::CheckPort | ( | int & | port | ) | [private] |
void XrdClientConn::CheckREQConnectWaitState | ( | ) | [private] |
void XrdClientConn::CheckREQPauseState | ( | ) | [private] |
bool XrdClientConn::CheckResp | ( | struct ServerResponseHeader * | resp, | |
const char * | method | |||
) | [private] |
void XrdClientConn::ClearLastServerError | ( | ) | [inline] |
References ServerResponseBody_Error::errnum, kXR_noErrorYet, and LastServerError.
XrdClientMessage* XrdClientConn::ClientServerCmd | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
void ** | answMoreDataAllocated, | |||
void * | answMoreData, | |||
bool | HasToAlloc, | |||
int | substreamid = 0 | |||
) | [private] |
short XrdClientConn::Connect | ( | XrdClientUrlInfo | Host2Conn, | |
XrdClientAbsUnsolMsgHandler * | unsolhandler | |||
) |
static void XrdClientConn::DelSessionIDRepo | ( | ) | [inline, static] |
References fSessionIDRepo, fSessionIDRMutex, XrdSysMutex::Lock(), XrdOucHash< T >::Purge(), and XrdSysMutex::UnLock().
void XrdClientConn::Disconnect | ( | bool | ForcePhysicalDisc | ) |
XrdSecProtocol* XrdClientConn::DoAuthentication | ( | char * | plist, | |
int | plsiz | |||
) | [private] |
ERemoteServerType XrdClientConn::DoHandShake | ( | short | log | ) | [private] |
bool XrdClientConn::DoLogin | ( | ) | [private] |
bool XrdClientConn::DomainMatcher | ( | XrdOucString | dom, | |
XrdOucString | domlist | |||
) | [private] |
bool XrdClientConn::DoWriteHardCheckPoint | ( | ) |
bool XrdClientConn::DoWriteSoftCheckPoint | ( | ) |
virtual bool XrdClientConn::GetAccessToSrv | ( | ) | [virtual] |
bool XrdClientConn::GetCacheInfo | ( | int & | size, | |
long long & | bytessubmitted, | |||
long long & | byteshit, | |||
long long & | misscount, | |||
float & | missrate, | |||
long long & | readreqcnt, | |||
float & | bytesusefulness | |||
) | [inline] |
References fMainReadCache, and XrdClientReadCache::GetInfo().
XrdOucString XrdClientConn::GetClientHostDomain | ( | ) | [inline] |
References fgClientHostDomain.
static XrdClientConnectionMgr* XrdClientConn::GetConnectionMgr | ( | ) | [inline, static] |
References fgConnectionMgr.
XrdClientUrlInfo XrdClientConn::GetCurrentUrl | ( | ) | [inline] |
References fUrl.
long XrdClientConn::GetDataFromCache | ( | const void * | buffer, | |
long long | begin_offs, | |||
long long | end_offs, | |||
bool | PerfCalc, | |||
XrdClientIntvList & | missingblks, | |||
long & | outstandingblks | |||
) |
XrdOucString XrdClientConn::GetDomainToMatch | ( | XrdOucString | hostname | ) | [private] |
XrdClientUrlInfo* XrdClientConn::GetLBSUrl | ( | ) | [inline] |
References fLBSUrl.
int XrdClientConn::GetLogConnID | ( | ) | const [inline] |
References fLogConnID.
short XrdClientConn::GetMaxRedirCnt | ( | ) | const [inline] |
References fMaxGlobalRedirCnt.
XrdClientUrlInfo* XrdClientConn::GetMetaUrl | ( | ) | [inline] |
References fMetaUrl.
XErrorCode XrdClientConn::GetOpenError | ( | ) | const [inline] |
References fOpenError.
int XrdClientConn::GetOpenSockFD | ( | ) | const [inline] |
References fOpenSockFD.
int XrdClientConn::GetParallelStreamCount | ( | ) |
int XrdClientConn::GetParallelStreamToUse | ( | int | reqsperstream | ) |
static XrdClientPhyConnection* XrdClientConn::GetPhyConn | ( | int | LogConnID | ) | [static] |
short XrdClientConn::GetRedirCnt | ( | ) | const [inline] |
References fGlobalRedirCnt.
XrdClientUrlInfo XrdClientConn::GetRedirUrl | ( | ) | [inline] |
References fREQUrl.
long XrdClientConn::GetServerProtocol | ( | ) | [inline] |
References fServerProto.
ERemoteServerType XrdClientConn::GetServerType | ( | ) | const [inline] |
References fServerType.
void XrdClientConn::GetSessionID | ( | SessionIDInfo & | sess | ) | [inline] |
References mySessionID.
kXR_unt16 XrdClientConn::GetStreamID | ( | ) | const [inline] |
References fPrimaryStreamid.
XReqErrorType XrdClientConn::GoBackToRedirector | ( | ) |
virtual XReqErrorType XrdClientConn::GoToAnotherServer | ( | XrdClientUrlInfo & | newdest | ) | [virtual] |
virtual XReqErrorType XrdClientConn::GoToMetaManager | ( | ) | [virtual] |
ESrvErrorHandlerRetval XrdClientConn::HandleServerError | ( | XReqErrorType & | , | |
XrdClientMessage * | , | |||
ClientRequest * | ||||
) | [private] |
bool XrdClientConn::IsConnected | ( | ) | const [inline] |
References fConnected.
bool XrdClientConn::IsOpTimeLimitElapsed | ( | time_t | timenow | ) |
bool XrdClientConn::IsPhyConnConnected | ( | ) |
bool XrdClientConn::MatchStreamid | ( | struct ServerResponseHeader * | ServerResponse | ) | [private] |
bool XrdClientConn::PanicClose | ( | ) | [private] |
XrdOucString XrdClientConn::ParseDomainFromHostname | ( | XrdOucString | hostname | ) | [private] |
void XrdClientConn::PrintCache | ( | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::PrintCache().
UnsolRespProcResult XrdClientConn::ProcessAsynResp | ( | XrdClientMessage * | unsolmsg | ) |
XrdClientMessage* XrdClientConn::ReadPartialAnswer | ( | XReqErrorType & | , | |
size_t & | , | |||
ClientRequest * | , | |||
bool | , | |||
void ** | , | |||
EThreeStateReadHandler & | ||||
) | [private] |
void XrdClientConn::RemoveAllDataFromCache | ( | bool | keepwriteblocks = true |
) | [inline] |
References fMainReadCache, and XrdClientReadCache::RemoveItems().
void XrdClientConn::RemoveDataFromCache | ( | long long | begin_offs, | |
long long | end_offs, | |||
bool | remove_overlapped = false | |||
) | [inline] |
References fMainReadCache, and XrdClientReadCache::RemoveItems().
void XrdClientConn::RemovePlaceholdersFromCache | ( | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::RemovePlaceholders().
virtual bool XrdClientConn::SendGenCommand | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
void ** | answMoreDataAllocated, | |||
void * | answMoreData, | |||
bool | HasToAlloc, | |||
char * | CmdName, | |||
int | substreamid = 0 | |||
) | [virtual] |
void XrdClientConn::SetCacheRmPolicy | ( | int | RmPolicy | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::SetBlkRemovalPolicy().
void XrdClientConn::SetCacheSize | ( | int | CacheSize | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::SetSize().
void XrdClientConn::SetClientHostDomain | ( | const char * | src | ) | [inline] |
References fgClientHostDomain.
void XrdClientConn::SetConnected | ( | bool | conn | ) | [inline] |
References fConnected.
void XrdClientConn::SetLogConnID | ( | int | cid | ) | [inline, protected] |
References fLogConnID.
void XrdClientConn::SetMaxRedirCnt | ( | short | mx | ) | [inline] |
References fMaxGlobalRedirCnt.
void XrdClientConn::SetOpenError | ( | XErrorCode | err | ) | [inline] |
References fOpenError.
void XrdClientConn::SetOpTimeLimit | ( | int | delta_secs | ) |
void XrdClientConn::SetRedirHandler | ( | XrdClientAbs * | rh | ) | [inline] |
References fRedirHandler.
void XrdClientConn::SetREQDelayedConnectState | ( | kXR_int32 | wsec | ) | [inline] |
void XrdClientConn::SetREQPauseState | ( | kXR_int32 | wsec | ) | [inline] |
References XrdSysCondVar::Broadcast(), fREQWait, fREQWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
void XrdClientConn::SetRequestedDestHost | ( | char * | newh, | |
kXR_int32 | port | |||
) | [inline] |
References fREQUrl, fUrl, XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, and XrdClientUrlInfo::SetAddrFromHost().
void XrdClientConn::SetSID | ( | kXR_char * | sid | ) |
void XrdClientConn::SetStreamID | ( | kXR_unt16 | sid | ) | [inline, protected] |
References fPrimaryStreamid.
void XrdClientConn::SetUrl | ( | XrdClientUrlInfo | thisUrl | ) | [inline] |
References fUrl.
bool XrdClientConn::SubmitDataToCache | ( | XrdClientMessage * | xmsg, | |
long long | begin_offs, | |||
long long | end_offs | |||
) |
void XrdClientConn::SubmitPlaceholderToCache | ( | 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 | ( | ) |
void XrdClientConn::UnPinCacheBlk | ( | long long | begin_offs, | |
long long | end_offs | |||
) | [inline] |
References XrdSysCondVar::Broadcast(), fMainReadCache, fWriteWaitAck, and XrdClientReadCache::UnPinCacheBlk().
bool XrdClientConn::WaitResp | ( | int | secsmax | ) | [private] |
XReqErrorType XrdClientConn::WriteToServer | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
short | LogConnID, | |||
int | substreamid = 0 | |||
) | [private] |
XReqErrorType XrdClientConn::WriteToServer_Async | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
int | substreamid = 0 | |||
) |
bool XrdClientConn::fConnected [private] |
Referenced by IsConnected(), and SetConnected().
XrdOucString XrdClientConn::fgClientHostDomain [static, private] |
Referenced by GetClientHostDomain(), and SetClientHostDomain().
XrdClientConnectionMgr* XrdClientConn::fgConnectionMgr [static, private] |
Referenced by GetConnectionMgr().
bool XrdClientConn::fGettingAccessToSrv [private] |
short XrdClientConn::fGlobalRedirCnt [protected] |
Referenced by GetRedirCnt().
time_t XrdClientConn::fGlobalRedirLastUpdateTimestamp [private] |
bool XrdClientConn::fLBSIsMeta [private] |
XrdClientUrlInfo* XrdClientConn::fLBSUrl [protected] |
Referenced by GetLBSUrl().
int XrdClientConn::fLogConnID [private] |
Referenced by GetLogConnID(), and SetLogConnID().
XrdClientReadCache* XrdClientConn::fMainReadCache [private] |
short XrdClientConn::fMaxGlobalRedirCnt [private] |
Referenced by GetMaxRedirCnt(), and SetMaxRedirCnt().
XrdClientUrlInfo* XrdClientConn::fMetaUrl [private] |
Referenced by GetMetaUrl().
Referenced by GetOpenError(), and SetOpenError().
int XrdClientConn::fOpenSockFD [private] |
Referenced by GetOpenSockFD().
time_t XrdClientConn::fOpTimeLimit [private] |
kXR_unt16 XrdClientConn::fPrimaryStreamid [private] |
Referenced by GetStreamID(), and SetStreamID().
XrdClientAbs* XrdClientConn::fRedirHandler [private] |
Referenced by SetRedirHandler().
XrdSysCondVar* XrdClientConn::fREQConnectWait [private] |
Referenced by SetREQDelayedConnectState().
time_t XrdClientConn::fREQConnectWaitTimeLimit [private] |
Referenced by SetREQDelayedConnectState().
XrdClientUrlInfo XrdClientConn::fREQUrl [protected] |
Referenced by GetRedirUrl(), and SetRequestedDestHost().
XrdSysCondVar* XrdClientConn::fREQWait [private] |
Referenced by SetREQPauseState().
XrdSysCondVar* XrdClientConn::fREQWaitResp [private] |
time_t XrdClientConn::fREQWaitTimeLimit [private] |
Referenced by SetREQPauseState().
long XrdClientConn::fServerProto [private] |
Referenced by GetServerProtocol().
ERemoteServerType XrdClientConn::fServerType [private] |
Referenced by GetServerType().
XrdOucHash<SessionIDInfo> XrdClientConn::fSessionIDRepo [static, private] |
Referenced by DelSessionIDRepo().
XrdSysMutex XrdClientConn::fSessionIDRMutex [static, private] |
Referenced by DelSessionIDRepo().
XrdClientUrlInfo XrdClientConn::fUrl [protected] |
Referenced by GetCurrentUrl(), SetRequestedDestHost(), and SetUrl().
XrdSysCondVar* XrdClientConn::fWriteWaitAck [private] |
Referenced by UnPinCacheBlk().
struct ServerResponseBody_Error XrdClientConn::LastServerError [read] |
Referenced by ClearLastServerError().
struct ServerResponseHeader XrdClientConn::LastServerResp [read] |
SessionIDInfo XrdClientConn::mySessionID [private] |
Referenced by GetSessionID().