#include <XrdClientConn.hh>
Definition at line 34 of file XrdClientConn.hh.
Definition at line 38 of file XrdClientConn.hh.
Definition at line 45 of file XrdClientConn.hh.
XrdClientConn::XrdClientConn | ( | ) |
Definition at line 131 of file XrdClientConn.cc.
References buf, XrdOucString::c_str(), XrdClientUrlInfo::Clear(), ClearLastServerError(), EnvGetLong, EnvGetString, EnvPutString, Error, fgClientHostDomain, fgConnectionMgr, fGlobalRedirCnt, fGlobalRedirLastUpdateTimestamp, fMaxGlobalRedirCnt, fOpenSockFD, fRedirHandler, fREQConnectWait, fREQUrl, fREQWait, fREQWaitResp, fServerType, fUnsolMsgHandler, fWriteWaitAck, GetDomainToMatch(), kSTNone, kXR_noResponsesYet, LastServerResp, NAME_CONNECTDOMAINALLOW_RE, NAME_CONNECTDOMAINDENY_RE, NAME_MAXREDIRECTCOUNT, NAME_REDIRDOMAINALLOW_RE, and NAME_REDIRDOMAINDENY_RE.
XrdClientConn::~XrdClientConn | ( | ) | [virtual] |
Definition at line 192 of file XrdClientConn.cc.
References DebugLevel, Disconnect(), FALSE, fLBSUrl, fMainReadCache, fREQConnectWait, fREQWait, fREQWaitResp, fWriteWaitAck, XrdClientDebug::kUSERDEBUG, and XrdClientReadCache::PrintPerfCounters().
Definition at line 66 of file XrdClientConn.hh.
References FALSE, fMainReadCache, and XrdClientReadCache::WillFit().
Referenced by XrdClient::Read(), and XrdClient::ReadV().
bool XrdClientConn::CheckHostDomain | ( | XrdOucString | hostToCheck | ) |
Definition at line 658 of file XrdClientConn.cc.
References XrdOucHash< T >::Add(), XrdOucString::c_str(), DomainMatcher(), EnvGetString, Error, FALSE, XrdOucHash< T >::Find(), GetDomainToMatch(), Info, int, XrdClientDebug::kHIDEBUG, XrdOucString::length(), NAME_REDIRDOMAINALLOW_RE, NAME_REDIRDOMAINDENY_RE, and TRUE.
Referenced by XrdClientAdmin::Connect(), HandleServerError(), and XrdClient::Open().
short XrdClientConn::Connect | ( | XrdClientUrlInfo | Host2Conn, | |
XrdClientAbsUnsolMsgHandler * | unsolhandler | |||
) |
Definition at line 223 of file XrdClientConn.cc.
References CheckREQConnectWaitState(), ConnectionManager, Error, FALSE, fConnected, fLogConnID, fPrimaryStreamid, fUnsolMsgHandler, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, XrdClientDebug::kHIDEBUG, XrdClientUrlInfo::Port, and TRUE.
Referenced by XrdClientAdmin::Connect(), GoToAnotherServer(), and XrdClient::Open().
void XrdClientConn::Disconnect | ( | bool | ForcePhysicalDisc | ) |
Definition at line 274 of file XrdClientConn.cc.
References ConnectionManager, DebugLevel, FALSE, fConnected, fLogConnID, fMainReadCache, fPrimaryStreamid, fWriteReqsToRetry, XrdClientDebug::kDUMPDEBUG, and XrdClientReadCache::PrintCache().
Referenced by XrdClientAdmin::Connect(), XrdClientAdmin::DirList(), DoLogin(), GetAccessToSrv(), XrdClientAdmin::GetSpaceInfo(), GoBackToRedirector(), HandleServerError(), XrdClientAdmin::Locate(), XrdClient::Open(), ProcessAsynResp(), XrdClient::TryOpen(), and ~XrdClientConn().
bool XrdClientConn::GetAccessToSrv | ( | ) | [virtual] |
Definition at line 1162 of file XrdClientConn.cc.
References ConnectionManager, Disconnect(), DoHandShake(), DoLogin(), EnvGetLong, Error, FALSE, fGettingAccessToSrv, fLogConnID, fOpenSockFD, fServerType, fUrl, XrdClientLogConnection::GetPhyConnection(), XrdClientUrlInfo::Host, Info, XrdClientPhyConnection::IsLogged(), XrdClientPhyConnection::IsValid(), XrdClientDebug::kHIDEBUG, kNo, XrdClientDebug::kNODEBUG, kSTBaseXrootd, kSTDataXrootd, kSTError, kSTNone, kSTRootd, NAME_DATASERVERCONN_TTL, NAME_KEEPSOCKOPENIFNOTXRD, NAME_LBSERVERCONN_TTL, XrdClientUrlInfo::Port, retval, XrdClientPhyConnection::SaveSocket(), XrdClientPhyConnection::SetTTL(), XrdClientPhyConnection::StartReader(), and TRUE.
Referenced by XrdClientAdmin::Connect(), GoToAnotherServer(), and XrdClient::Open().
XReqErrorType XrdClientConn::GoBackToRedirector | ( | ) |
Definition at line 2110 of file XrdClientConn.cc.
References Disconnect(), fGlobalRedirCnt, GoToAnotherServer(), and kOK.
Referenced by XrdClientAdmin::GoBackToRedirector().
XrdOucString XrdClientConn::GetClientHostDomain | ( | ) | [inline] |
XrdClientPhyConnection * XrdClientConn::GetPhyConn | ( | int | LogConnID | ) | [static] |
Definition at line 2644 of file XrdClientConn.cc.
References ConnectionManager, and log().
Referenced by XrdClientMStream::AddParallelStream(), and XrdClientMStream::EstablishParallelStreams().
long XrdClientConn::GetDataFromCache | ( | const void * | buffer, | |
long long | begin_offs, | |||
long long | end_offs, | |||
bool | PerfCalc, | |||
XrdClientIntvList & | missingblks, | |||
long & | outstandingblks | |||
) |
Definition at line 2220 of file XrdClientConn.cc.
References FALSE, fMainReadCache, and XrdClientReadCache::GetDataIfPresent().
Referenced by XrdClient::Read().
bool XrdClientConn::SubmitDataToCache | ( | XrdClientMessage * | xmsg, | |
long long | begin_offs, | |||
long long | end_offs | |||
) |
Definition at line 2238 of file XrdClientConn.cc.
References fMainReadCache, XrdClientMessage::HeaderStatus(), kXR_ok, kXR_oksofar, and XrdClientReadCache::SubmitXMessage().
Referenced by XrdClient::ProcessUnsolicitedMsg().
bool XrdClientConn::SubmitRawDataToCache | ( | const void * | buffer, | |
long long | begin_offs, | |||
long long | end_offs | |||
) |
Definition at line 2251 of file XrdClientConn.cc.
References fMainReadCache, free(), and XrdClientReadCache::SubmitRawData().
Referenced by XrdClientReadV::SubmitToCacheReadVResp().
Definition at line 102 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::PutPlaceholder().
Referenced by XrdClient::Read_Async(), and XrdClientReadV::ReqReadV().
void XrdClientConn::RemoveAllDataFromCache | ( | bool | keepwriteblocks = true |
) | [inline] |
Definition at line 109 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::RemoveItems().
Referenced by XrdClient::RemoveAllDataFromCache().
void XrdClientConn::RemoveDataFromCache | ( | long long | begin_offs, | |
long long | end_offs, | |||
bool | remove_overlapped = false | |||
) | [inline] |
Definition at line 114 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::RemoveItems().
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), XrdClient::RemoveDataFromCache(), and XrdClient::Write().
void XrdClientConn::RemovePlaceholdersFromCache | ( | ) | [inline] |
Definition at line 120 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::RemovePlaceholders().
void XrdClientConn::PrintCache | ( | ) | [inline] |
Definition at line 125 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::PrintCache().
Referenced by XrdClient::Read().
bool XrdClientConn::GetCacheInfo | ( | int & | size, | |
long long & | bytessubmitted, | |||
long long & | byteshit, | |||
long long & | misscount, | |||
float & | missrate, | |||
long long & | readreqcnt, | |||
float & | bytesusefulness | |||
) | [inline] |
Definition at line 131 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::GetInfo().
Referenced by XrdClient::GetCacheInfo(), XrdClient::Read(), and XrdClient::UseCache().
void XrdClientConn::SetCacheSize | ( | int | CacheSize | ) | [inline] |
Definition at line 167 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::SetSize().
Referenced by XrdClient::SetCacheParameters().
void XrdClientConn::SetCacheRmPolicy | ( | int | RmPolicy | ) | [inline] |
Definition at line 175 of file XrdClientConn.hh.
References fMainReadCache, and XrdClientReadCache::SetBlkRemovalPolicy().
Referenced by XrdClient::SetCacheParameters().
Definition at line 180 of file XrdClientConn.hh.
References XrdSysCondVar::Broadcast(), fMainReadCache, fWriteWaitAck, and XrdClientReadCache::UnPinCacheBlk().
Referenced by XrdClient::ProcessUnsolicitedMsg().
int XrdClientConn::GetLogConnID | ( | ) | const [inline] |
Definition at line 190 of file XrdClientConn.hh.
References fLogConnID.
Referenced by XrdClientMStream::AddParallelStream(), XrdClientMStream::BindPendingStream(), XrdClientAdmin::Connect(), XrdClientMStream::EstablishParallelStreams(), XrdClient::Open(), and XrdClientMStream::RemoveParallelStream().
ERemoteServerType XrdClientConn::GetServerType | ( | ) | const [inline] |
Definition at line 192 of file XrdClientConn.hh.
References fServerType.
Referenced by TXNetSystem::Connect(), XrdClientAdmin::Connect(), TXNetFile::CreateXClient(), XrdClientMStream::EstablishParallelStreams(), TXNetSystem::IsPathLocal(), and XrdClient::Open().
kXR_unt16 XrdClientConn::GetStreamID | ( | ) | const [inline] |
Definition at line 194 of file XrdClientConn.hh.
References fPrimaryStreamid.
Referenced by XrdClient::ProcessUnsolicitedMsg().
XrdClientUrlInfo* XrdClientConn::GetLBSUrl | ( | ) | [inline] |
Definition at line 196 of file XrdClientConn.hh.
References fLBSUrl.
Referenced by XrdClient::TryOpen().
XrdClientUrlInfo XrdClientConn::GetCurrentUrl | ( | ) | [inline] |
Definition at line 197 of file XrdClientConn.hh.
References fUrl.
Referenced by CheckErrorStatus(), TXNetSystem::Connect(), TXNetFile::CreateXClient(), XrdClientAbs::GetCurrentUrl(), TXNetFile::Init(), XrdClientAdmin::Locate(), XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::TryOpen().
XrdClientUrlInfo XrdClientConn::GetRedirUrl | ( | ) | [inline] |
XErrorCode XrdClientConn::GetOpenError | ( | ) | const [inline] |
XReqErrorType XrdClientConn::GoToAnotherServer | ( | XrdClientUrlInfo & | newdest | ) | [virtual] |
Definition at line 2072 of file XrdClientConn.cc.
References XrdOucString::c_str(), Connect(), ConnectionManager, Error, fGettingAccessToSrv, fLogConnID, fPrimaryStreamid, fUnsolMsgHandler, fUrl, GetAccessToSrv(), XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, IsConnected(), kOK, kREDIRCONNECT, and XrdClientUrlInfo::Port.
Referenced by XrdClientAdmin::DirList(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::GoBackToRedirector(), GoBackToRedirector(), HandleServerError(), XrdClientAdmin::Locate(), and XrdClient::TryOpen().
bool XrdClientConn::IsConnected | ( | ) | const [inline] |
Definition at line 202 of file XrdClientConn.hh.
References fConnected.
Referenced by XrdClientAdmin::Connect(), XrdClientAdmin::GoBackToRedirector(), GoToAnotherServer(), HandleServerError(), XrdClientAdmin::Locate(), XrdClient::Open(), and XrdClientAbs::Query().
bool XrdClientConn::IsPhyConnConnected | ( | ) |
Definition at line 2602 of file XrdClientConn.cc.
References ConnectionManager, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::IsValid().
Referenced by XrdClient::Read().
void XrdClientConn::ClearLastServerError | ( | ) | [inline] |
Definition at line 211 of file XrdClientConn.hh.
References kXR_noErrorYet, and LastServerError.
Referenced by XrdClientAdmin::DirList(), and XrdClientConn().
UnsolRespProcResult XrdClientConn::ProcessAsynResp | ( | XrdClientMessage * | unsolmsg | ) |
Definition at line 2442 of file XrdClientConn.cc.
References clientUnmarshall(), DebugLevel, Disconnect(), ServerResponseHeader::dlen, XrdClientMessage::DonateData(), ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, FALSE, free(), fREQWaitResp, fREQWaitRespData, XrdClientMessage::GetData(), XrdClientMessage::GetStatusCode(), ServerResponseBody_Redirect::host, i, if(), Info, XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdClientDebug::kNODEBUG, kUNSOL_CONTINUE, kUNSOL_DISPOSE, XrdClientDebug::kUSERDEBUG, kXR_error, kXR_redirect, kXR_wait, XrdClientMessage::kXrdMSC_ok, LastServerError, LastServerResp, XrdSysCondVar::Lock(), malloc(), MatchStreamid(), ServerResponseBody_Redirect::port, ServerResponseBody_Attn_asynresp::respdata, ServerResponseBody_Attn_asynresp::resphdr, SetRequestedDestHost(), XrdSysCondVar::Signal(), smartPrintServerHeader(), ServerResponseHeader::status, XrdSysCondVar::UnLock(), and xrdmin.
Referenced by XrdClient::ProcessUnsolicitedMsg(), and XrdClientAdmin::ProcessUnsolicitedMsg().
bool XrdClientConn::SendGenCommand | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
void ** | answMoreDataAllocated, | |||
void * | answMoreData, | |||
bool | HasToAlloc, | |||
char * | CmdName, | |||
int | substreamid = 0 | |||
) | [virtual] |
Definition at line 411 of file XrdClientConn.cc.
References XrdOucString::c_str(), CheckErrorStatus(), CheckREQPauseState(), CheckResp(), ClientServerCmd(), convertRequestIdToChar(), ClientOpenRequest::dlen, ServerResponseHeader::dlen, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fMaxGlobalRedirCnt, fOpenError, fRedirOpaque, free(), fREQWaitRespData, fUrl, XrdClientMessage::GetData(), GetServerProtocol(), ClientRequest::header, XrdClientUrlInfo::Host, Info, XrdClientMessage::IsError(), IsOpTimeLimitElapsed(), XrdClientDebug::kHIDEBUG, kXR_bind, kXR_close, kXR_maxReqRetry, kXR_ok, kXR_open, kXR_read, kXR_refresh, kXR_retstat, kXR_sync, kXR_wait, kXR_waitresp, kXR_write, LastServerResp, XrdOucString::length(), malloc(), ClientRequest::open, ClientOpenRequest::options, XrdClientUrlInfo::Port, ClientRequestHdr::requestid, ServerResponseBody_Attn_asynresp::respdata, ServerResponseBody_Attn_asynresp::resphdr, ServerResponseHeader::status, TRUE, and WaitResp().
Referenced by XrdClientAdmin::Chmod(), XrdClient::Close(), XrdClientAdmin::DirList_low(), DoAuthentication(), DoLogin(), DoWriteSoftCheckPoint(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::LocalLocate(), XrdClient::LowOpen(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClientAbs::Query(), XrdClient::Read(), XrdClientReadV::ReqReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), XrdClient::Truncate(), and XrdClient::Write().
int XrdClientConn::GetOpenSockFD | ( | ) | const [inline] |
Definition at line 224 of file XrdClientConn.hh.
References fOpenSockFD.
Referenced by TXNetSystem::Connect(), and TXNetFile::CreateXClient().
void XrdClientConn::SetClientHostDomain | ( | const char * | src | ) | [inline] |
void XrdClientConn::SetConnected | ( | bool | conn | ) | [inline] |
void XrdClientConn::SetOpenError | ( | XErrorCode | err | ) | [inline] |
int XrdClientConn::GetParallelStreamToUse | ( | int | reqsperstream | ) |
Definition at line 2577 of file XrdClientConn.cc.
References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), XrdClientPhyConnection::GetSockIdHint(), and kWRITE.
Referenced by XrdClient::ReadV(), and XrdClientMStream::SplitReadRequest().
int XrdClientConn::GetParallelStreamCount | ( | ) |
Definition at line 2617 of file XrdClientConn.cc.
References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::GetSockIdCount().
Referenced by XrdClientMStream::GetGoodSplitParameters().
void XrdClientConn::SetRedirHandler | ( | XrdClientAbs * | rh | ) | [inline] |
Definition at line 235 of file XrdClientConn.hh.
References fRedirHandler.
Referenced by XrdClient::XrdClient(), and XrdClientAdmin::XrdClientAdmin().
void XrdClientConn::SetRequestedDestHost | ( | char * | newh, | |
kXR_int32 | port | |||
) | [inline] |
Definition at line 237 of file XrdClientConn.hh.
References fREQUrl, fUrl, XrdClientUrlInfo::Host, XrdClientUrlInfo::Port, and XrdClientUrlInfo::SetAddrFromHost().
Referenced by ProcessAsynResp(), XrdClient::ProcessUnsolicitedMsg(), and XrdClientAdmin::ProcessUnsolicitedMsg().
void XrdClientConn::SetREQPauseState | ( | kXR_int32 | wsec | ) | [inline] |
Definition at line 246 of file XrdClientConn.hh.
References XrdSysCondVar::Broadcast(), fREQWait, fREQWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
Referenced by XrdClient::ProcessUnsolicitedMsg(), and XrdClientAdmin::ProcessUnsolicitedMsg().
void XrdClientConn::SetREQDelayedConnectState | ( | kXR_int32 | wsec | ) | [inline] |
Definition at line 264 of file XrdClientConn.hh.
References XrdSysCondVar::Broadcast(), fREQConnectWait, fREQConnectWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
Referenced by XrdClient::ProcessUnsolicitedMsg(), and XrdClientAdmin::ProcessUnsolicitedMsg().
void XrdClientConn::SetSID | ( | kXR_char * | sid | ) |
Definition at line 787 of file XrdClientConn.cc.
References fPrimaryStreamid.
Referenced by XrdClientMStream::BindPendingStream(), XrdClientAdmin::Chmod(), ClientServerCmd(), XrdClient::Close(), XrdClientAdmin::DirList_low(), DoAuthentication(), DoLogin(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::LocalLocate(), XrdClient::LowOpen(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), PanicClose(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClientAbs::Query(), XrdClient::Read(), XrdClientReadV::ReqReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), XrdClient::Truncate(), and XrdClient::Write().
void XrdClientConn::SetUrl | ( | XrdClientUrlInfo | thisUrl | ) | [inline] |
Definition at line 280 of file XrdClientConn.hh.
References fUrl.
Referenced by XrdClientAdmin::Connect(), and XrdClient::Open().
XReqErrorType XrdClientConn::WriteToServer_Async | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
int | substreamid = 0 | |||
) |
Definition at line 2267 of file XrdClientConn.cc.
References ConnectionManager, ClientRequestHdr::dlen, Error, fLogConnID, fMainReadCache, fPrimaryStreamid, free(), ClientRequest::header, kGENERICERR, kNOMORESTREAMS, kXR_write, malloc(), ClientWriteRequest::offset, ClientRequestHdr::requestid, XrdClientReadCache::SubmitRawData(), ClientRequest::write, and WriteToServer().
Referenced by XrdClientReadV::ReqReadV(), and XrdClient::Write().
static XrdClientConnectionMgr* XrdClientConn::GetConnectionMgr | ( | ) | [inline, static] |
void XrdClientConn::GetSessionID | ( | SessionIDInfo & | sess | ) | [inline] |
Definition at line 292 of file XrdClientConn.hh.
References buf, XrdOucString::c_str(), fSessionIDRepo, fUrl, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, XrdOucString::length(), XrdClientUrlInfo::Port, and snprintf.
Referenced by XrdClientMStream::BindPendingStream().
long XrdClientConn::GetServerProtocol | ( | ) | [inline] |
Definition at line 308 of file XrdClientConn.hh.
References fServerProto.
Referenced by XrdClientAdmin::DirList(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::Locate(), XrdClient::Read(), XrdClient::ReadV(), and SendGenCommand().
short XrdClientConn::GetMaxRedirCnt | ( | ) | const [inline] |
Definition at line 310 of file XrdClientConn.hh.
References fMaxGlobalRedirCnt.
Referenced by XrdClient::Open().
void XrdClientConn::SetMaxRedirCnt | ( | short | mx | ) | [inline] |
Definition at line 311 of file XrdClientConn.hh.
References fMaxGlobalRedirCnt.
Referenced by TXNetFile::CreateXClient().
short XrdClientConn::GetRedirCnt | ( | ) | const [inline] |
Definition at line 312 of file XrdClientConn.hh.
References fGlobalRedirCnt.
Referenced by XrdClient::Open().
bool XrdClientConn::DoWriteSoftCheckPoint | ( | ) |
Definition at line 2656 of file XrdClientConn.cc.
References XrdClientVector< T >::Clear(), ConnectionManager, data, Error, XrdClientReadCache::FindBlk(), fMainReadCache, fPrimaryStreamid, fWriteReqsToRetry, XrdClientVector< T >::GetSize(), ok, SendGenCommand(), and UnPinCacheBlk().
Referenced by DoWriteHardCheckPoint(), and XrdClient::Write().
bool XrdClientConn::DoWriteHardCheckPoint | ( | ) |
Definition at line 2704 of file XrdClientConn.cc.
References ConnectionManager, DoWriteSoftCheckPoint(), fPrimaryStreamid, fWriteWaitAck, and XrdSysCondVar::Wait().
Referenced by XrdClient::Close(), XrdClient::Sync(), and XrdClient::Write().
void XrdClientConn::UnPinCacheBlk | ( | ) |
Referenced by DoWriteSoftCheckPoint().
void XrdClientConn::SetOpTimeLimit | ( | int | delta_secs | ) |
Definition at line 2724 of file XrdClientConn.cc.
References fOpTimeLimit.
Referenced by XrdClientAdmin::Chmod(), XrdClient::Close(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList_low(), XrdClientAdmin::GetChecksum(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::Locate(), XrdClientAdmin::Mkdir(), XrdClientAdmin::Mv(), XrdClient::Open(), XrdClientAdmin::Prepare(), XrdClientAdmin::Protocol(), XrdClient::Read(), XrdClient::ReadV(), XrdClientAdmin::Rm(), XrdClientAdmin::Rmdir(), XrdClientAdmin::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::Sync(), XrdClientAdmin::SysStatX(), XrdClientAdmin::Truncate(), and XrdClient::Write().
bool XrdClientConn::IsOpTimeLimitElapsed | ( | time_t | timenow | ) |
Definition at line 2728 of file XrdClientConn.cc.
References fOpTimeLimit.
Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), ClientServerCmd(), XrdClientAdmin::Connect(), HandleServerError(), XrdClient::Open(), SendGenCommand(), and WaitResp().
void XrdClientConn::SetLogConnID | ( | int | cid | ) | [inline, protected] |
void XrdClientConn::SetStreamID | ( | kXR_unt16 | sid | ) | [inline, protected] |
bool XrdClientConn::CheckErrorStatus | ( | XrdClientMessage * | , | |
short & | , | |||
char * | ||||
) | [private] |
Definition at line 883 of file XrdClientConn.cc.
References XrdClientMessage::DataLen(), Error, FALSE, fOpenError, fUrl, GetCurrentUrl(), XrdClientMessage::GetData(), getenv(), XrdClientMessage::HeaderStatus(), XrdClientUrlInfo::Host, Info, int, XrdClientDebug::kNODEBUG, XrdClientDebug::kUSERDEBUG, kXR_error, kXR_maxReqRetry, kXR_redirect, kXR_wait, LastServerError, XrdClientUrlInfo::Port, sleep, and TRUE.
Referenced by SendGenCommand().
void XrdClientConn::CheckPort | ( | int & | port | ) | [private] |
Definition at line 2192 of file XrdClientConn.cc.
References Info, int, XrdClientDebug::kHIDEBUG, XrdClientDebug::kNODEBUG, and RooFitShortHand::S().
Referenced by HandleServerError().
void XrdClientConn::CheckREQPauseState | ( | ) | [private] |
Definition at line 2328 of file XrdClientConn.cc.
References fREQWait, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by SendGenCommand().
void XrdClientConn::CheckREQConnectWaitState | ( | ) | [private] |
Definition at line 2357 of file XrdClientConn.cc.
References fREQConnectWait, fREQConnectWaitTimeLimit, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by Connect().
bool XrdClientConn::CheckResp | ( | struct ServerResponseHeader * | resp, | |
const char * | method | |||
) | [private] |
Definition at line 747 of file XrdClientConn.cc.
References Error, FALSE, kXR_authmore, kXR_ok, kXR_redirect, MatchStreamid(), ServerResponseHeader::status, and TRUE.
Referenced by SendGenCommand().
XrdClientMessage * XrdClientConn::ClientServerCmd | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
void ** | answMoreDataAllocated, | |||
void * | answMoreData, | |||
bool | HasToAlloc, | |||
int | substreamid = 0 | |||
) | [private] |
Definition at line 289 of file XrdClientConn.cc.
References XrdClientMessage::DataLen(), ServerResponseHeader::dlen, fGlobalRedirCnt, XrdClientMessage::fHdr, fLogConnID, fMainReadCache, fMaxGlobalRedirCnt, ClientRequest::header, XrdClientMessage::HeaderStatus(), IsOpTimeLimitElapsed(), kOK, kTSRHReturnMex, kTSRHReturnNullMex, kXR_ok, kXR_oksofar, kXR_read, kXR_redirect, len, ClientReadRequest::offset, ClientRequest::read, ReadPartialAnswer(), ClientRequestHdr::requestid, SetSID(), size_t, ClientRequestHdr::streamid, XrdClientReadCache::SubmitXMessage(), and WriteToServer().
Referenced by SendGenCommand().
XrdSecProtocol * XrdClientConn::DoAuthentication | ( | char * | plist, | |
int | plsiz | |||
) | [private] |
Definition at line 1636 of file XrdClientConn.cc.
References ClientRequest::auth, XrdSecBuffer::buffer, XrdOucString::c_str(), ClientAuthRequest::credtype, XrdSecProtocol::Delete(), ClientRequestHdr::dlen, ServerResponseHeader::dlen, dlopen(), dlsym(), XrdSecProtocol::Entity, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, fOpenError, fUrl, XrdSecProtocol::getCredentials(), XrdOucErrInfo::getErrText(), XrdNetDNS::getHostAddr(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, XrdClientDebug::kHIDEBUG, XrdClientDebug::kUSERDEBUG, kXR_auth, kXR_authmore, kXR_error, kXR_NotAuthorized, LastServerError, LastServerResp, XrdOucString::length(), malloc(), XrdClientUrlInfo::Port, XrdSecEntity::prot, ClientRequestHdr::requestid, ClientAuthRequest::reserved, RTLD_NOW, SafeDelete, SendGenCommand(), SetSID(), XrdSecBuffer::size, ServerResponseHeader::status, strcat(), strcpy(), ClientRequestHdr::streamid, and TRUE.
Referenced by DoLogin().
ERemoteServerType XrdClientConn::DoHandShake | ( | short | log | ) | [private] |
Referenced by GetAccessToSrv().
bool XrdClientConn::DoLogin | ( | ) | [private] |
Definition at line 1392 of file XrdClientConn.cc.
References b, buf, XrdOucString::c_str(), ConnectionManager, DebugLevel, Disconnect(), ServerResponseHeader::dlen, DoAuthentication(), DWORD, emsg(), EnvGetLong, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, FALSE, fLogConnID, fOpenError, fRedirInternalToken, free(), fServerProto, fSessionIDRepo, fUrl, getenv(), XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, i, XrdClientConn::SessionIDInfo::id, Info, int, XrdClientDebug::kHIDEBUG, kNo, kXR_endsess, kXR_login, kXR_NotAuthorized, kYes, l, LastServerError, LastServerResp, length, XrdOucString::length(), name, NAME_DEBUG, p, XrdClientUrlInfo::Port, putenv, realloc(), SendGenCommand(), SetSID(), snprintf, sprintf(), strcpy(), TRUE, u, XrdClientUrlInfo::User, and XRD_CLIENT_CAPVER.
Referenced by GetAccessToSrv().
bool XrdClientConn::DomainMatcher | ( | XrdOucString | dom, | |
XrdOucString | domlist | |||
) | [private] |
Definition at line 708 of file XrdClientConn.cc.
References FALSE, Info, XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdOucString::length(), XrdOucString::matches(), STR_NPOS, XrdOucString::tokenize(), and TRUE.
Referenced by CheckHostDomain().
XrdOucString XrdClientConn::GetDomainToMatch | ( | XrdOucString | hostname | ) | [private] |
Definition at line 2120 of file XrdClientConn.cc.
References XrdOucString::c_str(), free(), XrdNetDNS::getHostName(), Info, XrdClientDebug::kHIDEBUG, and ParseDomainFromHostname().
Referenced by CheckHostDomain(), and XrdClientConn().
XrdClientConn::ESrvErrorHandlerRetval XrdClientConn::HandleServerError | ( | XReqErrorType & | , | |
XrdClientMessage * | , | |||
ClientRequest * | ||||
) | [private] |
Definition at line 1825 of file XrdClientConn.cc.
References XrdClientAbs::CanRedirOnError(), CheckHostDomain(), CheckPort(), XrdClientUrlInfo::Clear(), DebugLevel, Disconnect(), EnvGetLong, ServerResponseBody_Error::errnum, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fMainReadCache, fMaxGlobalRedirCnt, fRedirHandler, fRedirInternalToken, fRedirOpaque, fREQUrl, fUrl, XrdClientUrlInfo::GetUrl(), GoToAnotherServer(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, Info, IsConnected(), XrdClientMessage::IsError(), IsOpTimeLimitElapsed(), isRedir(), XrdClientDebug::kHIDEBUG, kOK, kREAD, kREDIRCONNECT, kSEHRContinue, kSEHRReturnMsgToCaller, kSEHRReturnNoMsgToCaller, XrdClientDebug::kUSERDEBUG, kWRITE, kXR_login, kXR_NotAuthorized, kXR_open, LastServerError, XrdOucString::length(), NAME_RECONNECTWAIT, XrdClientAbs::OpenFileWhenRedirected(), ParseRedir(), ParseRedirHost(), XrdClientUrlInfo::Port, PutFilehandleInRequest(), XrdClientReadCache::RemovePlaceholders(), ClientRequestHdr::requestid, sleep, and TRUE.
Referenced by ReadPartialAnswer().
bool XrdClientConn::MatchStreamid | ( | struct ServerResponseHeader * | ServerResponse | ) | [private] |
Definition at line 775 of file XrdClientConn.cc.
References fPrimaryStreamid, and ServerResponseHeader::streamid.
Referenced by CheckResp(), and ProcessAsynResp().
bool XrdClientConn::PanicClose | ( | ) | [private] |
Definition at line 2308 of file XrdClientConn.cc.
References fLogConnID, kXR_close, SetSID(), TRUE, and WriteToServer().
XrdOucString XrdClientConn::ParseDomainFromHostname | ( | XrdOucString | hostname | ) | [private] |
Definition at line 2179 of file XrdClientConn.cc.
References XrdOucString::find(), and STR_NPOS.
Referenced by GetDomainToMatch().
XrdClientMessage * XrdClientConn::ReadPartialAnswer | ( | XReqErrorType & | , | |
size_t & | , | |||
ClientRequest * | , | |||
bool | , | |||
void ** | , | |||
EThreeStateReadHandler & | ||||
) | [private] |
Definition at line 978 of file XrdClientConn.cc.
References ConnectionManager, convertRespStatusToChar(), XrdClientMessage::DataLen(), DebugLevel, Error, XrdClientMessage::fHdr, fLastDataBytesRecv, fLogConnID, free(), fUrl, XrdClientMessage::GetData(), HandleServerError(), XrdClientMessage::HeaderStatus(), XrdClientUrlInfo::Host, Info, XrdClientMessage::IsError(), isRedir(), XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdClientDebug::kNODEBUG, kOK, kREAD, kSEHRReturnMsgToCaller, kSEHRReturnNoMsgToCaller, kTSRHContinue, kTSRHReturnMex, kTSRHReturnNullMex, kWRITE, kXR_authmore, kXR_ok, kXR_oksofar, len, XrdClientUrlInfo::Port, realloc(), smartPrintServerHeader(), ServerResponseHeader::status, and XrdClientMessage::Unmarshall().
Referenced by ClientServerCmd().
void XrdClientConn::ClearSessionID | ( | ) | [private] |
XReqErrorType XrdClientConn::WriteToServer | ( | ClientRequest * | req, | |
const void * | reqMoreData, | |||
short | LogConnID, | |||
int | substreamid = 0 | |||
) | [private] |
Definition at line 795 of file XrdClientConn.cc.
References clientMarshall(), ConnectionManager, DebugLevel, Error, fLastDataBytesSent, fUrl, XrdClientLogConnection::GetPhyConnection(), XrdClientUrlInfo::Host, XrdClientDebug::kDUMPDEBUG, kOK, kWRITE, kXR_bind, len, XrdClientUrlInfo::Port, and smartPrintClientHeader().
Referenced by ClientServerCmd(), PanicClose(), and WriteToServer_Async().
bool XrdClientConn::WaitResp | ( | int | secsmax | ) | [private] |
Definition at line 2386 of file XrdClientConn.cc.
References fREQWaitResp, fREQWaitRespData, Info, IsOpTimeLimitElapsed(), XrdClientDebug::kHIDEBUG, XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by SendGenCommand().
Definition at line 58 of file XrdClientConn.hh.
Referenced by CheckErrorStatus(), DoAuthentication(), DoLogin(), GetOpenError(), SendGenCommand(), and SetOpenError().
Definition at line 60 of file XrdClientConn.hh.
Referenced by HandleServerError(), TXNetFile::Init(), XrdClient::LowOpen(), and SendGenCommand().
Definition at line 205 of file XrdClientConn.hh.
Referenced by DoAuthentication(), DoLogin(), XrdClientMStream::EstablishParallelStreams(), XrdClientAdmin::GetChecksum(), XrdClientAbs::LastServerResp(), XrdClientAdmin::Locate(), XrdClient::LowOpen(), ProcessAsynResp(), XrdClient::Read(), XrdClientReadV::ReqReadV(), SendGenCommand(), XrdClientAdmin::Stat(), XrdClient::Stat(), XrdClientAdmin::Stat_vfs(), XrdClient::TryOpen(), and XrdClientConn().
Definition at line 208 of file XrdClientConn.hh.
Referenced by CheckErrorStatus(), ClearLastServerError(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList(), DoAuthentication(), DoLogin(), HandleServerError(), XrdClientAbs::LastServerError(), TXNetSystemConnectGuard::NotifyLastError(), XrdClient::Open(), ProcessAsynResp(), XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), and XrdClient::TryOpen().
Definition at line 332 of file XrdClientConn.hh.
Referenced by Connect(), GoToAnotherServer(), and XrdClientConn().
XrdClientUrlInfo XrdClientConn::fUrl [protected] |
Definition at line 334 of file XrdClientConn.hh.
Referenced by CheckErrorStatus(), DoAuthentication(), DoLogin(), GetAccessToSrv(), GetCurrentUrl(), GetSessionID(), GoToAnotherServer(), HandleServerError(), ReadPartialAnswer(), SendGenCommand(), SetRequestedDestHost(), SetUrl(), and WriteToServer().
XrdClientUrlInfo* XrdClientConn::fLBSUrl [protected] |
XrdClientUrlInfo XrdClientConn::fREQUrl [protected] |
Definition at line 336 of file XrdClientConn.hh.
Referenced by GetRedirUrl(), HandleServerError(), SetRequestedDestHost(), and XrdClientConn().
short XrdClientConn::fGlobalRedirCnt [protected] |
Definition at line 338 of file XrdClientConn.hh.
Referenced by ClientServerCmd(), GetRedirCnt(), GoBackToRedirector(), HandleServerError(), SendGenCommand(), and XrdClientConn().
XrdOucString XrdClientConn::fgClientHostDomain [static, private] |
Definition at line 342 of file XrdClientConn.hh.
Referenced by GetClientHostDomain(), SetClientHostDomain(), and XrdClientConn().
bool XrdClientConn::fConnected [private] |
Definition at line 343 of file XrdClientConn.hh.
Referenced by Connect(), Disconnect(), IsConnected(), and SetConnected().
bool XrdClientConn::fGettingAccessToSrv [private] |
Definition at line 344 of file XrdClientConn.hh.
Referenced by GetAccessToSrv(), and GoToAnotherServer().
time_t XrdClientConn::fGlobalRedirLastUpdateTimestamp [private] |
int XrdClientConn::fLogConnID [private] |
Definition at line 347 of file XrdClientConn.hh.
Referenced by ClientServerCmd(), Connect(), Disconnect(), DoLogin(), GetAccessToSrv(), GetLogConnID(), GetParallelStreamCount(), GetParallelStreamToUse(), GoToAnotherServer(), IsPhyConnConnected(), PanicClose(), ReadPartialAnswer(), SetLogConnID(), and WriteToServer_Async().
kXR_unt16 XrdClientConn::fPrimaryStreamid [private] |
Definition at line 348 of file XrdClientConn.hh.
Referenced by Connect(), Disconnect(), DoWriteHardCheckPoint(), DoWriteSoftCheckPoint(), GetStreamID(), GoToAnotherServer(), MatchStreamid(), SetSID(), SetStreamID(), and WriteToServer_Async().
short XrdClientConn::fMaxGlobalRedirCnt [private] |
Definition at line 352 of file XrdClientConn.hh.
Referenced by ClientServerCmd(), GetMaxRedirCnt(), HandleServerError(), SendGenCommand(), SetMaxRedirCnt(), and XrdClientConn().
XrdClientReadCache* XrdClientConn::fMainReadCache [private] |
Definition at line 353 of file XrdClientConn.hh.
Referenced by CacheWillFit(), ClientServerCmd(), Disconnect(), DoWriteSoftCheckPoint(), GetCacheInfo(), GetDataFromCache(), HandleServerError(), PrintCache(), RemoveAllDataFromCache(), RemoveDataFromCache(), RemovePlaceholdersFromCache(), SetCacheRmPolicy(), SetCacheSize(), SubmitDataToCache(), SubmitPlaceholderToCache(), SubmitRawDataToCache(), UnPinCacheBlk(), WriteToServer_Async(), and ~XrdClientConn().
time_t XrdClientConn::fOpTimeLimit [private] |
Definition at line 356 of file XrdClientConn.hh.
Referenced by IsOpTimeLimitElapsed(), and SetOpTimeLimit().
XrdClientAbs* XrdClientConn::fRedirHandler [private] |
Definition at line 358 of file XrdClientConn.hh.
Referenced by HandleServerError(), SetRedirHandler(), and XrdClientConn().
XrdSysCondVar* XrdClientConn::fREQWaitResp [private] |
Definition at line 365 of file XrdClientConn.hh.
Referenced by ProcessAsynResp(), WaitResp(), XrdClientConn(), and ~XrdClientConn().
Definition at line 367 of file XrdClientConn.hh.
Referenced by ProcessAsynResp(), SendGenCommand(), and WaitResp().
time_t XrdClientConn::fREQWaitTimeLimit [private] |
Definition at line 369 of file XrdClientConn.hh.
Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), and SetREQPauseState().
XrdSysCondVar* XrdClientConn::fREQWait [private] |
Definition at line 370 of file XrdClientConn.hh.
Referenced by CheckREQPauseState(), SetREQPauseState(), XrdClientConn(), and ~XrdClientConn().
time_t XrdClientConn::fREQConnectWaitTimeLimit [private] |
Definition at line 371 of file XrdClientConn.hh.
Referenced by CheckREQConnectWaitState(), and SetREQDelayedConnectState().
XrdSysCondVar* XrdClientConn::fREQConnectWait [private] |
Definition at line 372 of file XrdClientConn.hh.
Referenced by CheckREQConnectWaitState(), SetREQDelayedConnectState(), XrdClientConn(), and ~XrdClientConn().
long XrdClientConn::fServerProto [private] |
ERemoteServerType XrdClientConn::fServerType [private] |
Definition at line 375 of file XrdClientConn.hh.
Referenced by GetAccessToSrv(), GetServerType(), and XrdClientConn().
XrdOucHash< XrdClientConn::SessionIDInfo > XrdClientConn::fSessionIDRepo [static, private] |
int XrdClientConn::fOpenSockFD [private] |
Definition at line 382 of file XrdClientConn.hh.
Referenced by GetAccessToSrv(), GetOpenSockFD(), and XrdClientConn().
XrdClientConnectionMgr * XrdClientConn::fgConnectionMgr [static, private] |
Definition at line 383 of file XrdClientConn.hh.
Referenced by GetConnectionMgr(), and XrdClientConn().
XrdSysCondVar* XrdClientConn::fWriteWaitAck [private] |
Definition at line 385 of file XrdClientConn.hh.
Referenced by DoWriteHardCheckPoint(), UnPinCacheBlk(), XrdClientConn(), and ~XrdClientConn().
Definition at line 386 of file XrdClientConn.hh.
Referenced by Disconnect(), and DoWriteSoftCheckPoint().