(
unsigneddiscovery_iteration)
103 voidResetServerConnections();
140 m_Position(server_group_impl->m_Servers.begin())
144 virtual bool Next();
145 virtual bool Prev();
157TNetServerList::const_iterator position) :
170 virtual bool Next();
176TNetServerList::const_iterator pivot) :
183 virtual bool Next();
184 virtual bool Prev();
195TNetServerList::const_iterator pivot) :
201 virtual bool Next();
202 virtual bool Prev();
212 virtual bool Next();
213 virtual bool Prev();
237 Uint4rank = (1103515245 *
238(server->first->m_RankBase ^
m_KeyCRC32) + 12345) & 0x7FFFFFFF;
263 #ifdef NCBI_GRID_XSITE_CONN_SUPPORT 264 static boolIsUsingXSiteProxy();
265 static voidAllowXSiteConnections();
268 static boolIsForeignAddr(
unsigned int ip);
269 static intGetDomain(
unsigned int ip);
271 staticatomic<int> m_LocalDomain;
272 staticatomic<bool> m_AllowXSiteConnections;
296 static SNetServiceImpl* Create(
const string& api_name,
const string& service_name,
const string& client_name,
305 SNetServiceImpl(
const string& api_name,
const string& service_name,
const string& client_name,
318 stringMakeAuthString();
321 boolmultiline_output);
322 voidDiscoverServersIfNeeded();
333 voidIterateUntilExecOK(
const string&
cmd,
334 boolmultiline_output,
337EServerErrorHandling error_handling);
349shared_ptr<void> CreateRetryGuard(SRetry::EType
type);
365 unsignedm_LatestDiscoveryIteration = 0;
395 bool IsAllowed(
const string& service_name)
const;
409 cmd+=
" ncbi_phid=\"";
CTimeout â Timeout interval.
virtual CNetServer BeginIteration()=0
virtual CNetServer NextServer()=0
virtual ~IServiceTraversal()
void swap(NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair1, NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair2)
string GetSessionID(void) const
Session ID.
const string & GetNextSubHitID(CTempString prefix=CTempString())
Get current hit id appended with auto-incremented sub-hit id.
string GetClientIP(void) const
Client IP/hostname.
bool IsSetClientIP(void) const
uint32_t Uint4
4-byte (32-bit) unsigned integer
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
#define NCBI_XCONNECT_EXPORT
const CharType(& source)[N]
void g_AppendClientIPAndSessionID(string &cmd, const CRequestContext &req)
map< string, CNetService > TNetServiceByName
pair< SNetServerInPool *, double > TServerRate
map< SSocketAddress, SNetServerInPool * > TNetServerByAddress
vector< TServerRate > TNetServerList
void g_AppendHitID(string &cmd, CRequestContext &req)
Defines CRequestContext class for NCBI C++ diagnostic API.
function< INetServerProperties *()> TPropCreator
SDiscoveredServers(unsigned discovery_iteration)
virtual void DeleteThis()
Virtual method "deleting" this object.
TNetServerList::const_iterator m_SuppressedBegin
SDiscoveredServers * m_NextGroupInPool
unsigned m_DiscoveryIteration
void Reset(unsigned discovery_iteration)
STimeout m_FirstServerTimeout
pair< string, const char * > TLBSMAffinity
TLBSMAffinity m_LBSMAffinity
SSocketAddress m_EnforcedServer
SThrottleParams m_ThrottleParams
INetServerConnectionListener::TPropCreator m_PropCreator
TNetServerByAddress m_Servers
const SThrottleParams & GetThrottleParams() const
void Swap(SNetServiceImpl &impl, unsigned &n)
bool IsLoadBalanced() const
CRef< INetServerConnectionListener > m_Listener
CNetServerPool m_ServerPool
@ eRethrowAllServerErrors
shared_ptr< void > m_NetInfo
CSimpleRebalanceStrategy m_RebalanceStrategy
unsigned GetConnectionMaxRetries() const
const string & GetClientName() const
unsigned long m_ConnectionRetryDelay
CFastMutex m_DiscoveryMutex
atomic< size_t > m_RoundRobin
unsigned long GetConnectionRetryDelay() const
unsigned m_ConnectionMaxRetries
SNetServiceIteratorImpl(SDiscoveredServers *server_group_impl)
TNetServerList::const_iterator m_Position
CRef< SDiscoveredServers > m_ServerGroup
SNetServiceIteratorImpl(SDiscoveredServers *server_group_impl, TNetServerList::const_iterator position)
TNetServerList::const_iterator m_Pivot
SNetServiceIterator_Circular(SDiscoveredServers *server_group_impl, TNetServerList::const_iterator pivot)
SNetServiceIterator_OmitPenalized(SDiscoveredServers *server_group_impl)
SNetServiceIterator_RandomPivot(SDiscoveredServers *server_group_impl, TNetServerList::const_iterator pivot)
vector< TNetServerList::const_iterator > TRandomIterators
TRandomIterators m_RandomIterators
TRandomIterators::const_iterator m_RandomIterator
SServerRank(TNetServerList::const_iterator server_list_iter, Uint4 server_rank)
bool operator<(const SServerRank &that) const
TNetServerList::const_iterator m_ServerListIter
SNetServiceIterator_Weighted(SDiscoveredServers *server_group_impl, Uint4 key_crc32)
vector< SServerRank >::const_iterator m_CurrentServerRank
SServerRank x_GetServerRank(TNetServerList::const_iterator server) const
vector< SServerRank > m_ServerRanks
bool IsAllowed(const string &service_name) const
void AddToAllowed(const string &service_name)
set< string, PNocase > m_Allowed
TNetServiceByName m_ServiceByName
SNetServiceMap(const SNetServiceMap &source)
CNetService GetServiceByNameImpl(const string &, SNetServiceImpl *)
CFastMutex m_ServiceMapMutex
CNetService GetServiceByName(const string &service_name, SNetServiceImpl *prototype)
static void ConnectXSite(CSocket &, SNetServerImpl::SConnectDeadline &, const SSocketAddress &, const string &)
static void InitXSite(CSynRegistry ®istry, const SRegSynonyms §ions)
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4