Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/netservice__api_8cpp_source.html below:

NCBI C++ ToolKit: src/connect/services/netservice_api.cpp Source File

->m_Listener->SetErrorHandler(error_handler);

->GetServer();

->GetRate();

server_group_impl->m_Servers.begin() +

(

::TValue((server_group_impl->m_SuppressedBegin -

server_group_impl->m_Servers.begin()) - 1)))

(number_of_servers <= 1)

}

(number_of_servers > 0);

m_KeyCRC32(key_crc32)

TNetServerList::const_iterator server_list_iter(

);

(highest_rank < server_rank)

highest_rank = server_rank;

TNetServerList::const_iterator server_list_iter(

m_PropCreator(listener->GetPropCreator()),

m_EnforcedServer(0, 0),

m_MaxTotalTime(

::eInfinite),

m_UseOldStyleAuth(

)

m_Listener(listener),

m_ServiceName(service_name),

m_RebalanceStrategy(

, sections),

m_ClientName(client_name)

m_Listener(prototype->m_Listener->Clone()),

m_ServerPool(prototype->m_ServerPool),

m_ServiceName(server->m_Address.AsString()),

m_RebalanceStrategy(prototype->m_RebalanceStrategy),

m_RoundRobin(prototype->m_RoundRobin.load()),

m_APIName(prototype->m_APIName),

m_ClientName(prototype->m_ClientName),

m_UseSmartRetries(prototype->m_UseSmartRetries),

m_ConnectionMaxRetries(prototype->m_ConnectionMaxRetries),

m_ConnectionRetryDelay(prototype->m_ConnectionRetryDelay),

m_NetInfo(prototype->m_NetInfo)

m_Listener(prototype->m_Listener->Clone()),

m_ServerPool(prototype->m_ServerPool),

m_ServiceName(service_name),

m_RebalanceStrategy(prototype->m_RebalanceStrategy),

m_RoundRobin(prototype->m_RoundRobin.load()),

m_APIName(prototype->m_APIName),

m_ClientName(prototype->m_ClientName),

m_UseSmartRetries(prototype->m_UseSmartRetries),

m_ConnectionMaxRetries(prototype->m_ConnectionMaxRetries),

m_ConnectionRetryDelay(prototype->m_ConnectionRetryDelay),

m_NetInfo(prototype->m_NetInfo)

& api_name,

& service_name,

& client_name,

rv->Init(

, sections, ns_client_name);

SNetServiceXSiteAPI::AllowXSiteConnections();

SNetServiceXSiteAPI::IsUsingXSiteProxy();

kXSiteFwd[] =

;

SNetServiceXSiteAPI::AllowXSiteConnections()

local_domain = GetDomain(local_ip);

m_LocalDomain.store(local_domain);

m_AllowXSiteConnections.store(

);

SNetServiceXSiteAPI::IsUsingXSiteProxy()

m_AllowXSiteConnections.load();

(

.

({

, sections },

,

)) {

AllowXSiteConnections();

(IsForeignAddr(actual.host)) {

memset(&rr, 0,

(rr));

rr.host = actual.host;

text_len = service.size() ?

(service.size() + 1, text_max) : 0;

memcpy(rr.text, service.c_str(), text_len);

svc.rdbuf()->PUBSETBUF(0, 0);

(svc.write((

*) &rr.ticket

,

(rr.ticket)) &&

svc.read(

,

(

)-1);

= (size_t) svc.gcount();

err =

;

err =

;

?

:

;

(memcmp(

,

, 4) != 0)

err = rr.text[0] ? rr.text :

;

<< kXSiteFwd <<

<< err);

actual.host = rr.host;

text_len = strlen(rr.text) + 1

;

(text_len > text_max)

<< kXSiteFwd <<

<< err);

);

SNetServiceXSiteAPI::GetDomain(

)

SNetServiceXSiteAPI::IsForeignAddr(

)

(!IsUsingXSiteProxy())

;

d = GetDomain(

);

d && (d != m_LocalDomain);

atomic<int> SNetServiceXSiteAPI::m_LocalDomain{0};

atomic<bool> SNetServiceXSiteAPI::m_AllowXSiteConnections{

};

host =

.

(sections, {

,

},

);

port =

.

(sections,

,

);

(!host.empty() && !port.empty())

= host +

+ port;

<<

);

kConnTimeoutDefault = 2.0;

kCommTimeoutDefault = 12.0;

kFirstServerTimeoutDefault = 0.0;

conn_timeout =

.

(sections,

, kConnTimeoutDefault);

comm_timeout =

.

({ sections,

},

, kCommTimeoutDefault);

first_srv_timeout =

.

(sections,

, kFirstServerTimeoutDefault);

max_total_time =

.

(sections,

, 0.0);

discovery_iteration)

server_group->

(discovery_iteration);

auth +=

;

auth +=

;

->m_ServiceName;

->m_ServerPool;

->IsLoadBalanced();

->m_EnforcedServer = std::move(address);

output_stream <<

<< (*it).GetServerAddress() <<

<< endl;

(output_style) {

output_stream << (*it).ExecWithRetry(

,

).response << endl;

url_parser((*it).ExecWithRetry(

,

).response);

output_stream << field->name <<

<< field->value << endl;

(*it).ExecWithRetry(

,

));

->SetNetCacheCompatMode();

(

.ReadLine(line))

output_stream << line << endl;

output_stream << endl;

loc.first->second;

loc.first->second = server;

server->m_ServerPool =

;

multiline_output)

<<

);

exec_result, &random_traversal,

multiline_output)

->FindServerAndExec(

, multiline_output);

(*it).ExecWithRetry(

,

);

<<

);

TNetServerList::size_type number_of_regular_servers = 0;

TNetServerList::size_type number_of_standby_servers = 0;

(

& d : discovered) {

servers.insert(servers.begin() +

number_of_regular_servers++, server_rate);

(d.second < max_standby_rate ||

servers.push_back(server_rate);

servers.insert(servers.begin() +

number_of_regular_servers, server_rate);

(d.second == max_standby_rate)

++number_of_standby_servers;

max_standby_rate = d.second;

number_of_standby_servers = 1;

(number_of_regular_servers > 0 ?

number_of_regular_servers : number_of_standby_servers);

(

& w : *

) {

multiline_output,

EIterationMode {

} iteration_mode = eInitialIteration;

vector<CNetServer> servers_to_retry;

current_server = 0;

number_of_servers = 0;

ns_with_submits_disabled = 0;

servers_throttled = 0;

blob_not_found =

;

use_fst = (fst.sec || fst.usec) && (retry_count > 0 ||

);

* timeout = use_fst ? &fst :

;

skip_server =

;

fail_only_warnings.clear();

blob_not_found =

;

skip_server =

;

++ns_with_submits_disabled;

skip_server =

;

fail_only_warnings.emplace_back(ex.

(), server);

++servers_throttled;

fail_only_warnings.emplace_back(ex.

(), server);

++number_of_servers;

(iteration_mode == eInitialIteration) {

servers_to_retry.push_back(server);

servers_to_retry.erase(servers_to_retry.begin() +

(current_server < servers_to_retry.size())

server = servers_to_retry[current_server];

(!blob_not_found && !deadline.

() &&

(number_of_servers == ns_with_submits_disabled) {

<<

<<

+

+

);

(number_of_servers == servers_throttled) {

<<

<<

+

+

);

(retry_count <= 0 || servers_to_retry.empty()) {

(blob_not_found) {

<<

<<

);

<<

<<

+

+

);

);

number_of_servers = 0;

ns_with_submits_disabled = 0;

servers_throttled = 0;

iteration_mode = eRetry;

server = servers_to_retry[current_server = 0];

:

;

it->second->m_CurrentConnectionGeneration.Add(1);

(server_group !=

) {

server_group;

server_group = next_group;

->m_CommTimeout = to;

->m_CommTimeout;

->GetDiscoveredServers(servers);

+

->m_ServiceName +

);

->Iterate(priority_server);

+

->GetDiscoveredServers(servers);

+

->m_ServiceName +

);

->GetDiscoveredServers(servers);

++circular_iter;

error_messages;

(!error_messages.empty())

error_messages +=

;

error_messages += (*it)->m_ServerInPool->m_Address.AsString();

error_messages +=

;

error_messages += ex.

();

(!error_messages.empty())

error_messages +=

;

error_messages += (*it)->m_ServerInPool->m_Address.AsString();

error_messages +=

;

error_messages += ex.

();

(!error_messages.empty()) {

->m_Listener->SetErrorHandler(error_handler);

->m_Listener->SetWarningHandler(warning_handler);

!loc.second ? loc.first->second :

(loc.first->second =

(

& service_name:

) {

.SetByKey((*it).GetServerAddress(), exec_to_json.

(*it));

OnErrorImpl(

&,

&)

{}

OnWarningImpl(

&,

&)

{}

registry_builder, sections);

Checksum and hash calculation classes.

CChecksum – Checksum calculator.

Helper hook-up class that installs default logging/registry/locking (but only if they have not yet be...

This stream exchanges data with a named service, in a constraint that the service is implemented as o...

void Release()

Manually force the resource to be released.

static CJsonNode NewObjectNode()

Create a new JSON object node.

Exception thrown when the requested blob is older than the requested age.

NetCache internal exception.

NetSchedule internal exception.

void StickToServer(SSocketAddress address)

CNetRef< SNetServerPoolImpl > m_Impl

void SetCommunicationTimeout(const STimeout &to)

const STimeout & GetCommunicationTimeout() const

SExecResult ExecWithRetry(const string &cmd, bool multiline_output=false)

Execute remote command 'cmd', wait for the reply, check if it starts with 'OK:', and return the remai...

CNetRef< SNetServiceIteratorImpl > m_Impl

function< bool(const string &, CNetServer)> TEventHandler

void SetErrorHandler(TEventHandler error_handler)

CNetRef< SNetServiceImpl > m_Impl

CNetServiceIterator FindServer(INetServerFinder *finder, EIterationMode mode=eSortByLoad)

const string & GetServiceName() const

static bool IsUsingXSiteProxy()

CNetServer GetServer(unsigned host, unsigned short port)

void PrintCmdOutput(const string &cmd, CNcbiOstream &output_stream, ECmdOutputStyle output_style, CNetService::EIterationMode=CNetService::eSortByLoad)

CNetServiceIterator ExcludeServer(CNetServer::TInstance server)

Start iteration excluding 'server' (return the next server after 'server' or NULL).

@ eMultilineOutput_NetCacheStyle

@ eMultilineOutput_NoHeaders

void ExecOnAllServers(const string &cmd)

CNetServiceIterator IterateByWeight(const string &key)

static CNetService Create(const string &api_name, const string &service_name, const string &client_name)

CNetServer::SExecResult FindServerAndExec(const string &cmd, bool multiline_output=false)

void SetWarningHandler(TEventHandler warning_handler)

bool IsLoadBalanced() const

CNetServerPool GetServerPool()

CNetServiceIterator Iterate(EIterationMode mode=eSortByLoad)

CNetService Clone(const string &name)

static void AllowXSiteConnections()

static TServers DiscoverImpl(const string &, unsigned, shared_ptr< void > &, pair< string, const char * >, int, unsigned long)

void OnResourceRequested()

CTimeout – Timeout interval.

This class is for use by the grid_cli utility only.

virtual CJsonNode ExecOn(CNetServer server)=0

virtual bool Consider(CNetServer server)=0

virtual CNetServer BeginIteration()=0

virtual CNetServer NextServer()=0

SRandomServiceTraversal(CNetService::TInstance service)

virtual CNetServer NextServer()

CNetServiceIterator m_Iterator

virtual CNetServer BeginIteration()

iterator_bool insert(const value_type &val)

container_type::value_type value_type

iterator_bool insert(const value_type &val)

static SQLCHAR output[256]

static const struct type types[]

const string & GetProgramExecutablePath(EFollowLinks follow_links=eIgnoreLinks) const

Get the application's executable path.

static CNcbiApplicationGuard InstanceGuard(void)

Singleton method.

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

const string & GetProgramDisplayName(void) const

Get the application's "display" name.

#define NON_CONST_ITERATE(Type, Var, Cont)

Non constant version of ITERATE macro.

void swap(NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair1, NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair2)

@ eTakeOwnership

An object can take ownership of another.

Uint4 GetChecksum(void) const

Return calculated checksum.

void AddChars(const char *str, size_t len)

Update current control sum with data provided.

EIO_Status CONN_GetSOCK(CONN conn, SOCK *sock)

Get an underlying SOCK handle for connection that is implemented as a socket.

static CRequestContext & GetRequestContext(void)

Shortcut to CDiagContextThreadData::GetThreadData().GetRequestContext()

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

#define LOG_POST(message)

This macro is deprecated and it's strongly recomended to move in all projects (except tests) to macro...

TErrCode GetErrCode(void) const

Get error code.

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

const string & GetMsg(void) const

Get message string.

void Warning(CExceptionArgs_Base &args)

#define NCBI_THROW_FMT(exception_class, err_code, message)

The same as NCBI_THROW but with message processed as output to ostream.

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

@ eBlobNotFound

Access denied.

bool Referenced(void) const THROWS_NONE

Check if object is referenced.

TObjectType * Release(void)

Release a reference to the object and return a pointer to the object.

uint32_t Uint4

4-byte (32-bit) unsigned integer

Uint4 TValue

Type of the generated integer value and/or the seed value.

TValue GetRand(void)

Get the next random number in the interval [0..GetMax()] (inclusive)

void Randomize(void)

Re-initialize (re-seed) the generator using platform-specific randomization.

virtual const string & Get(const string &section, const string &name, TFlags flags=0) const

Get the parameter value.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

unsigned int TSERV_Type

Bitwise OR of ESERV_Type[Special].

#define SERV_LOCALHOST

Special values for the "preferred_host" parameter.

@ fSERV_IncludeSuppressed

#define SOCK_NetToHostShort

unsigned short SOCK_HostToNetShort(unsigned short value)

See man for the BSDisms, htonl() and htons().

void Reset(SOCK sock, EOwnership if_to_own, ECopyTimeout whence)

Close the current underlying "SOCK" (if any, and if owned), and from now on use "sock" as the underly...

EIO_Status SOCK_Pushback(SOCK sock, const void *data, size_t size)

Push the specified data back to the socket's input queue (in the socket's internal read buffer).

static CNCBI_IPAddr GetLocalHostAddress(ESwitch reget=eDefault)

Local host address in network byte order (cached for faster retrieval)

EIO_Status SOCK_CreateOnTop(const void *handle, size_t handle_size, SOCK *sock)

[SERVER-side] Create a socket on top of a "handle".

EIO_Status Write(const void *buf, size_t size, size_t *n_written=0, EIO_WriteMethod how=eIO_WritePersist)

Write to socket.

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

static string PrintableString(const CTempString str, TPrintableMode mode=fNewLine_Quote|fNonAscii_Passthru)

Get a printable version of the specified string.

static SIZE_TYPE FindNoCase(const CTempString str, const CTempString pattern, SIZE_TYPE start, SIZE_TYPE end, EOccurrence which=eFirst)

Find the pattern in the specified range of a string using a case insensitive search.

static void TruncateSpacesInPlace(string &str, ETrunc where=eTrunc_Both)

Truncate whitespace in a string (in-place)

CNanoTimeout GetRemainingTime(void) const

Get time left to the expiration.

const long kMilliSecondsPerSecond

Number milliseconds in one second.

unsigned long GetAsMilliSeconds(void) const

Get as number of milliseconds.

bool IsInfinite(void) const

Check if the deadline is infinite.

const TArgs & GetArgs(void) const

Get the const list of arguments.

const STimeout * g_CTimeoutToSTimeout(const CTimeout &cto, STimeout &sto)

CTimeout/STimeout adapters.

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

@ eIO_Success

everything is fine, no error occurred

Definition of all error codes used in connect services library (xconnserv.lib and others).

static void text(MDB_val *v)

constexpr auto sort(_Init &&init)

const struct ncbi::grid::netcache::search::fields::KEY key

#define FWD_RR_KEEPALIVE

Try to reuse the connection.

#define FWD_RR_FIREWALL

FWDaemon request / reply.

#define FWD_RR_REJECTMASK

#define FWD_RR_MAX_SIZE

Maximal accepted request/reply size.

Parameters initialization model.

TNCBI_IPv6Addr * NcbiIPv4ToIPv6(TNCBI_IPv6Addr *addr, unsigned int ipv4, size_t pfxlen)

Embed a passed network byte order IPv4 address into an IPv6 address using the specified prefix length...

const char * LBSMD_GetHostParameter(unsigned int addr, const char *name)

IMessage/IMessageListener interfaces and basic implementations.

void SleepMilliSec(unsigned long ml_sec, EInterruptOnSignal onsignal=eRestartOnSignal)

NetCache API exception declarations.

CJsonNode g_ExecToJson(IExecToJson &exec_to_json, CNetService service, CNetService::EIterationMode iteration_mode)

This function is for use by the grid_cli utility only.

void g_AppendClientIPSessionIDHitID(string &cmd)

#define LBSMD_PENALIZED_RATE_BOUNDARY

DEFINE_STATIC_FAST_MUTEX(s_RndLock)

static CRandom::TValue s_GetRand(CRandom::TValue max_value)

void g_AppendClientIPAndSessionID(string &cmd, const CRequestContext &req)

pair< SNetServerInPool *, double > TServerRate

vector< TServerRate > TNetServerList

void g_AppendHitID(string &cmd, CRequestContext &req)

#define RETRY_DELAY_DEFAULT

#define CONNECTION_MAX_RETRIES

static CMiniMutex s_RndLock

void OnWarning(const string &warn_msg, CNetServer &server)

virtual void DeleteThis()

Virtual method "deleting" this object.

TNetServerList::const_iterator m_SuppressedBegin

SDiscoveredServers * m_NextGroupInPool

unsigned m_DiscoveryIteration

void Reset(unsigned discovery_iteration)

CRef< INetServerConnectionListener > m_Listener

SFailOnlyWarnings(CRef< INetServerConnectionListener > listener)

CRef< SNetServerInPool > m_ServerInPool

static void ConnectImpl(CSocket &, SConnectDeadline &, const SSocketAddress &, const SSocketAddress &)

CNetServer::SExecResult ConnectAndExec(const string &cmd, bool multiline_output, bool retry_on_exception=false)

SThrottleStats m_ThrottleStats

CNetServerPool m_ServerPool

CNetServer GetServer(SNetServiceImpl *service, SSocketAddress server_address)

STimeout m_FirstServerTimeout

void ResetServerConnections()

CRef< SNetServerInPool > ReturnServer(SNetServerInPool *server_impl)

virtual ~SNetServerPoolImpl()

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

SNetServerPoolImpl(INetServerConnectionListener *listener)

TLBSMAffinity m_LBSMAffinity

SSocketAddress m_EnforcedServer

SNetServerInPool * FindOrCreateServerImpl(SSocketAddress server_address)

SThrottleParams m_ThrottleParams

INetServerConnectionListener::TPropCreator m_PropCreator

TNetServerByAddress m_Servers

void Swap(SNetServiceImpl &impl, unsigned &n)

EServiceType m_ServiceType

CRef< INetServerConnectionListener > m_Listener

CNetServerPool m_ServerPool

void DiscoverServersIfNeeded()

CNetServer GetServer(SSocketAddress server_address)

@ eRethrowAllServerErrors

static SNetServiceImpl * Create(const string &api_name, const string &service_name, const string &client_name, INetServerConnectionListener *listener, CSynRegistry &registry, SRegSynonyms &sections, const string &ns_client_name=kEmptyStr)

shared_ptr< void > m_NetInfo

void Init(CSynRegistry &registry, SRegSynonyms &sections, const string &ns_client_name)

unsigned m_LatestDiscoveryIteration

CNetServer::SExecResult FindServerAndExec(const string &cmd, bool multiline_output)

CSimpleRebalanceStrategy m_RebalanceStrategy

SNetServiceImpl(const string &api_name, const string &service_name, const string &client_name, INetServerConnectionListener *listener, CSynRegistry &registry, const SRegSynonyms &sections)

SNetServiceIteratorImpl * Iterate(CNetServer::TInstance priority_server)

unsigned long m_ConnectionRetryDelay

CFastMutex m_DiscoveryMutex

void GetDiscoveredServers(CRef< SDiscoveredServers > &discovered_servers)

void IterateUntilExecOK(const string &cmd, bool multiline_output, CNetServer::SExecResult &exec_result, IServiceTraversal *service_traversal, EServerErrorHandling error_handling)

shared_ptr< void > CreateRetryGuard(SRetry::EType type)

SDiscoveredServers * m_DiscoveredServers

SDiscoveredServers * m_ServerGroupPool

static SNetServiceImpl * Clone(SNetServerInPool *server, SNetServiceImpl *prototype)

unsigned m_ConnectionMaxRetries

virtual ~SNetServiceImpl()

bool IsInService(CNetServer::TInstance server)

SDiscoveredServers * AllocServerGroup(unsigned discovery_iteration)

TNetServerList::const_iterator m_Position

CRef< SDiscoveredServers > m_ServerGroup

TNetServerList::const_iterator m_Pivot

SNetServiceIterator_RandomPivot(SDiscoveredServers *server_group_impl, TNetServerList::const_iterator pivot)

TRandomIterators m_RandomIterators

TRandomIterators::const_iterator m_RandomIterator

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

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 &registry, const SRegSynonyms &sections)

SNoRetryNoErrors(SNetServiceImpl *service)

void Set(CNetService::TEventHandler error_handler)

CNetRef< SNetServiceImpl > m_Service

SNoRetry(SNetServiceImpl *service)

static SSocketAddress Parse(const string &address, SHost::EName name=SHost::EName::eResolved)

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

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