xrootd
|
#include <XrdClientConn.hh>
XrdClientConn::XrdClientConn | ( | ) |
References 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, NAME_REDIRDOMAINDENY_RE, and ServerResponseHeader::status.
XrdClientConn::~XrdClientConn | ( | ) | [virtual] |
bool XrdClientConn::CacheWillFit | ( | long long | bytes | ) | [inline] |
References FALSE, fMainReadCache, and XrdClientReadCache::WillFit().
Referenced by XrdClient::Read(), and XrdClient::ReadV().
bool XrdClientConn::CheckErrorStatus | ( | XrdClientMessage * | mex, |
short & | Retry, | ||
char * | CmdName | ||
) | [private] |
References XrdClientMessage::DataLen(), ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, FALSE, fOpenError, fUrl, GetCurrentUrl(), XrdClientMessage::GetData(), XrdClientMessage::HeaderStatus(), XrdClientUrlInfo::Host, Info, ServerResponseBody_Wait::infomsg, XrdClientDebug::kNODEBUG, XrdClientDebug::kUSERDEBUG, kXR_error, kXR_maxReqRetry, kXR_redirect, kXR_wait, LastServerError, XrdClientUrlInfo::Port, ServerResponseBody_Wait::seconds, sleep, and TRUE.
Referenced by SendGenCommand().
bool XrdClientConn::CheckHostDomain | ( | XrdOucString | hostToCheck | ) |
References XrdOucHash< T >::Add(), XrdOucString::c_str(), DomainMatcher(), EnvGetString, Error, FALSE, XrdOucHash< T >::Find(), GetDomainToMatch(), Info, XrdClientDebug::kHIDEBUG, XrdOucString::length(), NAME_REDIRDOMAINALLOW_RE, NAME_REDIRDOMAINDENY_RE, and TRUE.
Referenced by XrdClientAdmin::Connect(), HandleServerError(), and XrdClient::Open().
void XrdClientConn::CheckPort | ( | int & | port | ) | [private] |
References Info, XrdClientDebug::kHIDEBUG, and XrdClientDebug::kNODEBUG.
Referenced by HandleServerError().
void XrdClientConn::CheckREQConnectWaitState | ( | ) | [private] |
References fREQConnectWait, fREQConnectWaitTimeLimit, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by Connect().
void XrdClientConn::CheckREQPauseState | ( | ) | [private] |
References fREQWait, fREQWaitTimeLimit, IsOpTimeLimitElapsed(), XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by SendGenCommand().
bool XrdClientConn::CheckResp | ( | struct ServerResponseHeader * | resp, |
const char * | method | ||
) | [private] |
References Error, FALSE, kXR_authmore, kXR_ok, kXR_redirect, MatchStreamid(), ServerResponseHeader::status, and TRUE.
Referenced by SendGenCommand().
void XrdClientConn::ClearLastServerError | ( | ) | [inline] |
References ServerResponseBody_Error::errnum, kXR_noErrorYet, and LastServerError.
Referenced by XrdClientAdmin::DirList(), and XrdClientConn().
void XrdClientConn::ClearSessionID | ( | ) | [private] |
XrdClientMessage * XrdClientConn::ClientServerCmd | ( | ClientRequest * | req, |
const void * | reqMoreData, | ||
void ** | answMoreDataAllocated, | ||
void * | answMoreData, | ||
bool | HasToAlloc, | ||
int | substreamid = 0 |
||
) | [private] |
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, ClientReadRequest::offset, ClientRequest::read, ReadPartialAnswer(), ClientRequestHdr::requestid, SetSID(), ClientRequestHdr::streamid, XrdClientReadCache::SubmitXMessage(), and WriteToServer().
Referenced by SendGenCommand().
short XrdClientConn::Connect | ( | XrdClientUrlInfo | Host2Conn, |
XrdClientAbsUnsolMsgHandler * | unsolhandler | ||
) |
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 | ) |
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().
XrdSecProtocol * XrdClientConn::DoAuthentication | ( | char * | plist, |
int | plsiz | ||
) | [private] |
References ClientRequest::auth, XrdSecBuffer::buffer, XrdOucString::c_str(), ClientAuthRequest::credtype, XrdSecProtocol::Delete(), ServerResponseHeader::dlen, ClientRequestHdr::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(), XrdClientUrlInfo::Port, XrdSecEntity::prot, ClientRequestHdr::requestid, ClientAuthRequest::reserved, RTLD_NOW, SafeDelete, SendGenCommand(), SetSID(), XrdSecBuffer::size, ServerResponseHeader::status, ClientRequestHdr::streamid, and TRUE.
Referenced by DoLogin().
ERemoteServerType XrdClientConn::DoHandShake | ( | short | log | ) | [private] |
Referenced by GetAccessToSrv().
bool XrdClientConn::DoLogin | ( | ) | [private] |
References XrdOucString::c_str(), ClientLoginRequest::capver, ConnectionManager, DebugLevel, Disconnect(), ServerResponseHeader::dlen, ClientRequestHdr::dlen, DoAuthentication(), emsg(), ClientRequest::endsess, EnvGetLong, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, Error, FALSE, XrdOucHash< T >::Find(), fLogConnID, fOpenError, fRedirInternalToken, fServerProto, fSessionIDRepo, fUrl, XrdClientLogConnection::GetPhyConnection(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientUrlInfo::HostAddr, XrdClientConn::SessionIDInfo::id, Info, XrdClientDebug::kHIDEBUG, kNo, kXR_endsess, kXR_login, kXR_NotAuthorized, kYes, LastServerError, LastServerResp, XrdOucString::length(), ClientRequest::login, NAME_DEBUG, ClientLoginRequest::pid, XrdClientUrlInfo::Port, XrdOucHash< T >::Rep(), ClientRequestHdr::requestid, SendGenCommand(), ClientEndsessRequest::sessid, XrdClientPhyConnection::SetLogged(), XrdClientPhyConnection::SetSecProtocol(), SetSID(), snprintf, ClientRequestHdr::streamid, TRUE, XrdClientUrlInfo::User, ClientLoginRequest::username, and XRD_CLIENT_CAPVER.
Referenced by GetAccessToSrv().
bool XrdClientConn::DomainMatcher | ( | XrdOucString | dom, |
XrdOucString | domlist | ||
) | [private] |
References XrdOucString::c_str(), FALSE, Info, XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kHIDEBUG, XrdOucString::length(), XrdOucString::matches(), STR_NPOS, XrdOucString::tokenize(), and TRUE.
Referenced by CheckHostDomain().
bool XrdClientConn::DoWriteHardCheckPoint | ( | ) |
References ConnectionManager, DoWriteSoftCheckPoint(), fPrimaryStreamid, fWriteWaitAck, and XrdSysCondVar::Wait().
Referenced by XrdClient::Close(), XrdClient::Sync(), and XrdClient::Write().
bool XrdClientConn::DoWriteSoftCheckPoint | ( | ) |
References XrdClientVector< T >::Clear(), ConnectionManager, ClientWriteRequest::dlen, Error, XrdClientReadCache::FindBlk(), fMainReadCache, fPrimaryStreamid, fWriteReqsToRetry, XrdClientVector< T >::GetSize(), ClientWriteRequest::offset, ClientWriteRequest::pathid, SendGenCommand(), UnPinCacheBlk(), and ClientRequest::write.
Referenced by DoWriteHardCheckPoint(), and XrdClient::Write().
bool XrdClientConn::GetAccessToSrv | ( | ) | [virtual] |
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, XrdClientPhyConnection::SaveSocket(), XrdClientPhyConnection::SetTTL(), XrdClientPhyConnection::StartReader(), and TRUE.
Referenced by XrdClientAdmin::Connect(), GoToAnotherServer(), and XrdClient::Open().
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().
Referenced by XrdClient::GetCacheInfo(), XrdClient::Read(), and XrdClient::UseCache().
XrdOucString XrdClientConn::GetClientHostDomain | ( | ) | [inline] |
References fgClientHostDomain.
static XrdClientConnectionMgr* XrdClientConn::GetConnectionMgr | ( | ) | [inline, static] |
References fgConnectionMgr.
XrdClientUrlInfo XrdClientConn::GetCurrentUrl | ( | ) | [inline] |
References fUrl.
Referenced by CheckErrorStatus(), XrdClientAbs::GetCurrentUrl(), XrdClientAdmin::Locate(), XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::TryOpen().
long XrdClientConn::GetDataFromCache | ( | const void * | buffer, |
long long | begin_offs, | ||
long long | end_offs, | ||
bool | PerfCalc, | ||
XrdClientIntvList & | missingblks, | ||
long & | outstandingblks | ||
) |
References FALSE, fMainReadCache, and XrdClientReadCache::GetDataIfPresent().
Referenced by XrdClient::Read().
XrdOucString XrdClientConn::GetDomainToMatch | ( | XrdOucString | hostname | ) | [private] |
References XrdOucString::c_str(), XrdNetDNS::getHostName(), Info, XrdClientDebug::kHIDEBUG, XrdOucString::length(), and ParseDomainFromHostname().
Referenced by CheckHostDomain(), and XrdClientConn().
XrdClientUrlInfo* XrdClientConn::GetLBSUrl | ( | ) | [inline] |
References fLBSUrl.
Referenced by XrdClient::TryOpen().
int XrdClientConn::GetLogConnID | ( | ) | const [inline] |
short XrdClientConn::GetMaxRedirCnt | ( | ) | const [inline] |
References fMaxGlobalRedirCnt.
Referenced by XrdClient::Open().
XErrorCode XrdClientConn::GetOpenError | ( | ) | const [inline] |
References fOpenError.
int XrdClientConn::GetOpenSockFD | ( | ) | const [inline] |
References fOpenSockFD.
int XrdClientConn::GetParallelStreamCount | ( | ) |
References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::GetSockIdCount().
Referenced by XrdClientMStream::GetGoodSplitParameters().
int XrdClientConn::GetParallelStreamToUse | ( | int | reqsperstream | ) |
References ConnectionManager, Error, fLogConnID, XrdClientLogConnection::GetPhyConnection(), XrdClientPhyConnection::GetSockIdHint(), and kWRITE.
Referenced by XrdClient::ReadV(), and XrdClientMStream::SplitReadRequest().
XrdClientPhyConnection * XrdClientConn::GetPhyConn | ( | int | LogConnID | ) | [static] |
References ConnectionManager, and XrdClientLogConnection::GetPhyConnection().
Referenced by XrdClientMStream::AddParallelStream(), and XrdClientMStream::EstablishParallelStreams().
short XrdClientConn::GetRedirCnt | ( | ) | const [inline] |
References fGlobalRedirCnt.
Referenced by XrdClient::Open().
XrdClientUrlInfo XrdClientConn::GetRedirUrl | ( | ) | [inline] |
References fREQUrl.
long XrdClientConn::GetServerProtocol | ( | ) | [inline] |
References fServerProto.
Referenced by XrdClientAdmin::DirList(), XrdClientAdmin::GetSpaceInfo(), XrdClientAdmin::Locate(), XrdClient::Read(), XrdClient::ReadV(), and SendGenCommand().
ERemoteServerType XrdClientConn::GetServerType | ( | ) | const [inline] |
References fServerType.
Referenced by XrdClientAdmin::Connect(), XrdClientMStream::EstablishParallelStreams(), and XrdClient::Open().
void XrdClientConn::GetSessionID | ( | SessionIDInfo & | sess | ) | [inline] |
kXR_unt16 XrdClientConn::GetStreamID | ( | ) | const [inline] |
References fPrimaryStreamid.
Referenced by XrdClient::ProcessUnsolicitedMsg().
XReqErrorType XrdClientConn::GoBackToRedirector | ( | ) |
References Disconnect(), fGlobalRedirCnt, fLBSUrl, GoToAnotherServer(), and kOK.
Referenced by XrdClientAdmin::GoBackToRedirector().
XReqErrorType XrdClientConn::GoToAnotherServer | ( | XrdClientUrlInfo & | newdest | ) | [virtual] |
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(), GoBackToRedirector(), XrdClientAdmin::GoBackToRedirector(), HandleServerError(), XrdClientAdmin::Locate(), and XrdClient::TryOpen().
XrdClientConn::ESrvErrorHandlerRetval XrdClientConn::HandleServerError | ( | XReqErrorType & | errorType, |
XrdClientMessage * | xmsg, | ||
ClientRequest * | req | ||
) | [private] |
References XrdClientAbs::CanRedirOnError(), CheckHostDomain(), CheckPort(), XrdClientUrlInfo::Clear(), DebugLevel, Disconnect(), EnvGetLong, ServerResponseBody_Error::errnum, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fLBSUrl, 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::IsConnected | ( | ) | const [inline] |
bool XrdClientConn::IsOpTimeLimitElapsed | ( | time_t | timenow | ) |
References fOpTimeLimit.
Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), ClientServerCmd(), XrdClientAdmin::Connect(), HandleServerError(), XrdClient::Open(), SendGenCommand(), and WaitResp().
bool XrdClientConn::IsPhyConnConnected | ( | ) |
References ConnectionManager, fLogConnID, XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::IsValid().
Referenced by XrdClient::Read().
bool XrdClientConn::MatchStreamid | ( | struct ServerResponseHeader * | ServerResponse | ) | [private] |
References fPrimaryStreamid, and ServerResponseHeader::streamid.
Referenced by CheckResp(), and ProcessAsynResp().
bool XrdClientConn::PanicClose | ( | ) | [private] |
XrdOucString XrdClientConn::ParseDomainFromHostname | ( | XrdOucString | hostname | ) | [private] |
References XrdOucString::assign(), XrdOucString::find(), and STR_NPOS.
Referenced by GetDomainToMatch().
void XrdClientConn::PrintCache | ( | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::PrintCache().
Referenced by XrdClient::Read().
UnsolRespProcResult XrdClientConn::ProcessAsynResp | ( | XrdClientMessage * | unsolmsg | ) |
References clientUnmarshall(), DebugLevel, Disconnect(), ServerResponseHeader::dlen, XrdClientMessage::DonateData(), ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, FALSE, fREQWaitResp, fREQWaitRespData, XrdClientMessage::GetData(), XrdClientMessage::GetStatusCode(), ServerResponseBody_Redirect::host, 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(), MatchStreamid(), ServerResponseBody_Redirect::port, ServerResponseBody_Attn_asynresp::respdata, ServerResponseBody_Attn_asynresp::resphdr, SetRequestedDestHost(), XrdSysCondVar::Signal(), smartPrintServerHeader(), ServerResponseHeader::status, XrdSysCondVar::UnLock(), and xrdmin.
Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().
XrdClientMessage * XrdClientConn::ReadPartialAnswer | ( | XReqErrorType & | errorType, |
size_t & | TotalBlkSize, | ||
ClientRequest * | req, | ||
bool | HasToAlloc, | ||
void ** | tmpMoreData, | ||
EThreeStateReadHandler & | what_to_do | ||
) | [private] |
References ConnectionManager, convertRespStatusToChar(), XrdClientMessage::DataLen(), DebugLevel, Error, XrdClientMessage::fHdr, fLastDataBytesRecv, fLogConnID, 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, XrdClientUrlInfo::Port, smartPrintServerHeader(), ServerResponseHeader::status, and XrdClientMessage::Unmarshall().
Referenced by ClientServerCmd().
void XrdClientConn::RemoveAllDataFromCache | ( | bool | keepwriteblocks = true | ) | [inline] |
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] |
References fMainReadCache, and XrdClientReadCache::RemoveItems().
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), XrdClient::RemoveDataFromCache(), and XrdClient::Write().
void XrdClientConn::RemovePlaceholdersFromCache | ( | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::RemovePlaceholders().
bool XrdClientConn::SendGenCommand | ( | ClientRequest * | req, |
const void * | reqMoreData, | ||
void ** | answMoreDataAllocated, | ||
void * | answMoreData, | ||
bool | HasToAlloc, | ||
char * | CmdName, | ||
int | substreamid = 0 |
||
) | [virtual] |
References XrdOucString::c_str(), CheckErrorStatus(), CheckREQPauseState(), CheckResp(), ClientServerCmd(), convertRequestIdToChar(), ServerResponseHeader::dlen, ClientOpenRequest::dlen, Error, FALSE, fGlobalRedirCnt, XrdClientMessage::fHdr, fMaxGlobalRedirCnt, fOpenError, fRedirOpaque, 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(), 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().
void XrdClientConn::SetCacheRmPolicy | ( | int | RmPolicy | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::SetBlkRemovalPolicy().
Referenced by XrdClient::SetCacheParameters().
void XrdClientConn::SetCacheSize | ( | int | CacheSize | ) | [inline] |
References fMainReadCache, and XrdClientReadCache::SetSize().
Referenced by XrdClient::SetCacheParameters().
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 | ) |
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().
void XrdClientConn::SetRedirHandler | ( | XrdClientAbs * | rh | ) | [inline] |
References fRedirHandler.
Referenced by XrdClient::XrdClient(), and XrdClientAdmin::XrdClientAdmin().
void XrdClientConn::SetREQDelayedConnectState | ( | kXR_int32 | wsec | ) | [inline] |
References XrdSysCondVar::Broadcast(), fREQConnectWait, fREQConnectWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().
void XrdClientConn::SetREQPauseState | ( | kXR_int32 | wsec | ) | [inline] |
References XrdSysCondVar::Broadcast(), fREQWait, fREQWaitTimeLimit, XrdSysCondVar::Lock(), and XrdSysCondVar::UnLock().
Referenced by XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().
void XrdClientConn::SetRequestedDestHost | ( | char * | newh, |
kXR_int32 | port | ||
) | [inline] |
void XrdClientConn::SetSID | ( | kXR_char * | sid | ) |
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::SetStreamID | ( | kXR_unt16 | sid | ) | [inline, protected] |
References fPrimaryStreamid.
void XrdClientConn::SetUrl | ( | XrdClientUrlInfo | thisUrl | ) | [inline] |
References fUrl.
Referenced by XrdClientAdmin::Connect(), and XrdClient::Open().
bool XrdClientConn::SubmitDataToCache | ( | XrdClientMessage * | xmsg, |
long long | begin_offs, | ||
long long | end_offs | ||
) |
References fMainReadCache, XrdClientMessage::HeaderStatus(), kXR_ok, kXR_oksofar, and XrdClientReadCache::SubmitXMessage().
Referenced by XrdClient::ProcessUnsolicitedMsg().
void XrdClientConn::SubmitPlaceholderToCache | ( | long long | begin_offs, |
long long | end_offs | ||
) | [inline] |
References fMainReadCache, and XrdClientReadCache::PutPlaceholder().
Referenced by XrdClient::Read_Async(), and XrdClientReadV::ReqReadV().
bool XrdClientConn::SubmitRawDataToCache | ( | const void * | buffer, |
long long | begin_offs, | ||
long long | end_offs | ||
) |
References fMainReadCache, and XrdClientReadCache::SubmitRawData().
Referenced by XrdClientReadV::SubmitToCacheReadVResp().
void XrdClientConn::UnPinCacheBlk | ( | long long | begin_offs, |
long long | end_offs | ||
) | [inline] |
References XrdSysCondVar::Broadcast(), fMainReadCache, fWriteWaitAck, and XrdClientReadCache::UnPinCacheBlk().
Referenced by XrdClient::ProcessUnsolicitedMsg().
void XrdClientConn::UnPinCacheBlk | ( | ) |
Referenced by DoWriteSoftCheckPoint().
bool XrdClientConn::WaitResp | ( | int | secsmax | ) | [private] |
References fREQWaitResp, fREQWaitRespData, Info, IsOpTimeLimitElapsed(), XrdClientDebug::kHIDEBUG, XrdSysCondVar::Lock(), XrdSysCondVar::UnLock(), XrdSysCondVar::Wait(), and xrdmin.
Referenced by SendGenCommand().
XReqErrorType XrdClientConn::WriteToServer | ( | ClientRequest * | req, |
const void * | reqMoreData, | ||
short | LogConnID, | ||
int | substreamid = 0 |
||
) | [private] |
References clientMarshall(), ConnectionManager, DebugLevel, ClientRequestHdr::dlen, Error, fLastDataBytesSent, fUrl, XrdClientLogConnection::GetPhyConnection(), ClientRequest::header, XrdClientUrlInfo::Host, XrdClientDebug::kDUMPDEBUG, kOK, kWRITE, kXR_bind, XrdClientUrlInfo::Port, ClientRequestHdr::requestid, and smartPrintClientHeader().
Referenced by ClientServerCmd(), PanicClose(), and WriteToServer_Async().
XReqErrorType XrdClientConn::WriteToServer_Async | ( | ClientRequest * | req, |
const void * | reqMoreData, | ||
int | substreamid = 0 |
||
) |
References ConnectionManager, ClientRequestHdr::dlen, Error, fLogConnID, fMainReadCache, fPrimaryStreamid, ClientRequest::header, kGENERICERR, kNOMORESTREAMS, kXR_write, ClientWriteRequest::offset, ClientRequestHdr::requestid, XrdClientReadCache::SubmitRawData(), ClientRequest::write, and WriteToServer().
Referenced by XrdClient::Read_Async(), XrdClientReadV::ReqReadV(), and XrdClient::Write().
bool XrdClientConn::fConnected [private] |
Referenced by Connect(), Disconnect(), IsConnected(), and SetConnected().
XrdOucString XrdClientConn::fgClientHostDomain [static, private] |
Referenced by GetClientHostDomain(), SetClientHostDomain(), and XrdClientConn().
XrdClientConnectionMgr * XrdClientConn::fgConnectionMgr = 0 [static, private] |
Referenced by GetConnectionMgr(), and XrdClientConn().
bool XrdClientConn::fGettingAccessToSrv [private] |
Referenced by GetAccessToSrv(), and GoToAnotherServer().
short XrdClientConn::fGlobalRedirCnt [protected] |
Referenced by ClientServerCmd(), GetRedirCnt(), GoBackToRedirector(), HandleServerError(), SendGenCommand(), and XrdClientConn().
time_t XrdClientConn::fGlobalRedirLastUpdateTimestamp [private] |
Referenced by XrdClientConn().
Referenced by ReadPartialAnswer().
Referenced by WriteToServer().
XrdClientUrlInfo* XrdClientConn::fLBSUrl [protected] |
Referenced by XrdClientPhyConnection::DoHandShake(), GetLBSUrl(), GoBackToRedirector(), HandleServerError(), and ~XrdClientConn().
int XrdClientConn::fLogConnID [private] |
XrdClientReadCache* XrdClientConn::fMainReadCache [private] |
Referenced by CacheWillFit(), ClientServerCmd(), Disconnect(), DoWriteSoftCheckPoint(), GetCacheInfo(), GetDataFromCache(), HandleServerError(), PrintCache(), RemoveAllDataFromCache(), RemoveDataFromCache(), RemovePlaceholdersFromCache(), SetCacheRmPolicy(), SetCacheSize(), SubmitDataToCache(), SubmitPlaceholderToCache(), SubmitRawDataToCache(), UnPinCacheBlk(), WriteToServer_Async(), and ~XrdClientConn().
short XrdClientConn::fMaxGlobalRedirCnt [private] |
Referenced by ClientServerCmd(), GetMaxRedirCnt(), HandleServerError(), SendGenCommand(), SetMaxRedirCnt(), and XrdClientConn().
Referenced by CheckErrorStatus(), DoAuthentication(), DoLogin(), GetOpenError(), SendGenCommand(), and SetOpenError().
int XrdClientConn::fOpenSockFD [private] |
Referenced by GetAccessToSrv(), GetOpenSockFD(), and XrdClientConn().
time_t XrdClientConn::fOpTimeLimit [private] |
Referenced by IsOpTimeLimitElapsed(), and SetOpTimeLimit().
kXR_unt16 XrdClientConn::fPrimaryStreamid [private] |
XrdClientAbs* XrdClientConn::fRedirHandler [private] |
Referenced by HandleServerError(), SetRedirHandler(), and XrdClientConn().
Referenced by DoLogin(), and HandleServerError().
Referenced by HandleServerError(), XrdClient::LowOpen(), and SendGenCommand().
XrdSysCondVar* XrdClientConn::fREQConnectWait [private] |
Referenced by CheckREQConnectWaitState(), SetREQDelayedConnectState(), XrdClientConn(), and ~XrdClientConn().
time_t XrdClientConn::fREQConnectWaitTimeLimit [private] |
Referenced by CheckREQConnectWaitState(), and SetREQDelayedConnectState().
XrdClientUrlInfo XrdClientConn::fREQUrl [protected] |
Referenced by GetRedirUrl(), HandleServerError(), SetRequestedDestHost(), and XrdClientConn().
XrdSysCondVar* XrdClientConn::fREQWait [private] |
Referenced by CheckREQPauseState(), SetREQPauseState(), XrdClientConn(), and ~XrdClientConn().
XrdSysCondVar* XrdClientConn::fREQWaitResp [private] |
Referenced by ProcessAsynResp(), WaitResp(), XrdClientConn(), and ~XrdClientConn().
Referenced by ProcessAsynResp(), SendGenCommand(), and WaitResp().
time_t XrdClientConn::fREQWaitTimeLimit [private] |
Referenced by CheckREQConnectWaitState(), CheckREQPauseState(), and SetREQPauseState().
long XrdClientConn::fServerProto [private] |
Referenced by XrdClientPhyConnection::DoHandShake(), DoLogin(), and GetServerProtocol().
ERemoteServerType XrdClientConn::fServerType [private] |
Referenced by GetAccessToSrv(), GetServerType(), and XrdClientConn().
XrdOucHash< XrdClientConn::SessionIDInfo > XrdClientConn::fSessionIDRepo [static, private] |
Referenced by DoLogin(), and GetSessionID().
Referenced by Connect(), GoToAnotherServer(), and XrdClientConn().
XrdClientUrlInfo XrdClientConn::fUrl [protected] |
Referenced by Disconnect(), and DoWriteSoftCheckPoint().
XrdSysCondVar* XrdClientConn::fWriteWaitAck [private] |
Referenced by DoWriteHardCheckPoint(), UnPinCacheBlk(), XrdClientConn(), and ~XrdClientConn().
Referenced by CheckErrorStatus(), ClearLastServerError(), XrdClientAdmin::Connect(), XrdClientAdmin::DirList(), DoAuthentication(), DoLogin(), HandleServerError(), XrdClientAbs::LastServerError(), XrdClient::Open(), ProcessAsynResp(), XrdClient::ProcessUnsolicitedMsg(), XrdClient::Read(), and XrdClient::TryOpen().
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().