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

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

NCBI C++ ToolKit: src/connect/ext/ncbi_dblb_svcmapper.cpp Source File

pref_section =

;

list<string> pref_keys;

(

& service : pref_keys) {

& preference_info =

->

(pref_section, service);

endpoint, preference, host_str, port_str;

( !port_str.

() ) {

((*it)->GetExpireTime() <= now) {

(

<< service <<

<< (*it)->GetName() <<

<< (*it)->GetHost()

<<

<< (*it)->GetPort());

exclude_list.

(it);

(it->second.second >= now

&& (promiscuity & ~it->second.first) == 0) {

(

<< service <<

);

time_t cur_time = time(

);

vector<const char*> skip_names;

std::for_each(exclude_list.

(),

exclude_list.

(),

skip_names.push_back(

);

(!preferred_svr.

()) {

preferred_svr.

()

}

(cp.

) {

(

<< service <<

);

(sinfo->

!= 0) {

server_name.append(1,

);

serv_list->push_back(server_name);

time_t cur_time = time(

);

&& preferred_svr->second.first >= 100.0

&& preferred_svr->second.second.NotEmpty()) {

requested = preferred_svr->second.second;

&& (requested->GetHost() == server->

()

|| requested->GetHost() == 0)

&& (requested->GetPort() == server->

()

|| requested->GetPort() == 0)) {

(service <<

<< server->

() <<

options->emplace_back

TOptions::iterator most_preferred = options->end();

missing_hinfo = 0;

list<CRef<SRawOption>> raw_options;

(

& it : exclusions->second) {

(it->GetHost() == sinfo->

&& (it->GetPort() == sinfo->

|| it->GetPort() == 0)) {

(hinfo ==

) {

missing_hinfo =

;

(missing_hinfo > 0) {

(missing_hinfo ==

) {

scale = 1.0 / (

- missing_hinfo);

(

& it : raw_options) {

default_load.

+= it->load.status * scale;

default_load.

+= it->load.statusBLAST * scale;

(

& it : raw_options) {

(it->load.status == 0.0) {

it->load = default_load;

(

& it : raw_options) {

update_most_preferred =

;

&& preferred_svr->second.first > 0.0

&& preferred_svr->second.second.NotEmpty()

&& (preferred_svr->second.second->GetHost() == sinfo->

|| preferred_svr->second.second->GetHost() == 0)

&& (preferred_svr->second.second->GetPort() == sinfo->

|| preferred_svr->second.second->GetPort() == 0)) {

(most_preferred == options->end()

|| (*most_preferred)->GetRanking() < ranking) {

update_most_preferred =

;

(service <<

<< name <<

<<

<< ranking <<

<<

<<

<<

(sinfo->

));

options->emplace_back

(update_most_preferred) {

TOptions::reverse_iterator ri = options->rbegin();

most_preferred = (++ri).base();

(

>= 2 && most_preferred != options->end()) {

pref = preferred_svr->second.first * 0.01,

access = (*most_preferred)->GetRanking(),

gap = access / total,

spread = 14.0 / (double(

) + 12.0);

(gap >= spread /

(

)) {

p0 = 2.0 / spread * gap * pref;

new_ranking = (total - access) * p0 / (1.0 - p0);

& name = (*most_preferred)->GetName();

host = (*most_preferred)->GetHost();

port = (*most_preferred)->GetPort();

(service <<

<< name <<

<<

<< new_ranking);

most_preferred->Reset

(*most_preferred)->GetState(),

(

) (*most_preferred)->GetExpireTime()));

(options->empty()) {

(

<< service <<

);

& preferred_server,

}

(exception&) {

;

void operator()(const TSvrRef &server)

vector< const char * > * m_Names

CCharInserter(vector< const char * > &names)

TSvrRef x_GetServer(const string &service)

virtual void GetServerOptions(const string &service, TOptions *options)

Get an annotated list of all servers for the given service.

CDBLB_ServiceMapper(const IRegistry *registry=NULL)

static IDBServiceMapper * Factory(const IRegistry *registry)

TPreferenceMap m_PreferenceMap

virtual void GetServersList(const string &service, list< string > *serv_list) const

Get list of all servers for the given service disregarding any exclusions.

bool x_IsEmpty(const string &service, TSERV_Type promiscuity, time_t now)

virtual TSvrRef GetServer(const string &service)

Map a service to a server.

void ConfigureFromRegistry(const IRegistry *registry=NULL)

virtual ~CDBLB_ServiceMapper(void)

virtual void SetPreference(const string &service, const TSvrRef &preferred_server, double preference=100.0)

Set up mapping preferences for a service preference - value between 0 and 100 (0 means *no particular...

virtual void Configure(const IRegistry *registry=NULL)

virtual bool RecordServer(I_ConnectionExtra &extra) const

Given a connection that succeeded even though this service mapper was unable to identify a good serve...

virtual string GetName(void) const

CDBServerOption – CDBServer extended with additional information that helps maintain a balanced pool ...

@ fState_Normal

Fully available.

@ fState_Penalized

Penalized by the load balancer.

@ fState_Excluded

Excluded by DBAPI.

time_t GetExpireTime(void) const

Uint2 GetPort(void) const

const string & GetName(void) const

Uint4 GetHost(void) const

static string GetName(void)

CTempString implements a light-weight string on top of a storage buffer whose lifetime management is ...

static void x_RecordServer(I_ConnectionExtra &extra, CDBServer &server)

list< CRef< CDBServerOption > > TOptions

container_type::const_iterator const_iterator

container_type::iterator iterator

const_iterator end() const

const_iterator find(const key_type &key) const

const_iterator begin() const

const_iterator end() const

static const char si[8][64]

static const struct name_t names[]

static CNcbiApplicationGuard InstanceGuard(void)

Singleton method.

const CNcbiRegistry & GetConfig(void) const

Get the application's cached configuration parameters (read-only).

#define ERASE_ITERATE(Type, Var, Cont)

Non-constant version with ability to erase current element, if container permits.

bool NotEmpty(void) const THROWS_NONE

Check if CRef is not empty – pointing to an object and has a non-null value.

bool Empty(void) const THROWS_NONE

Check if CRef is empty – not pointing to any object, which means having a null value.

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

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

Get the parameter value.

virtual int GetInt(const string &section, const string &name, int default_value, TFlags flags=0, EErrAction err_action=eThrow) const

Get integer value of specified parameter name.

virtual void EnumerateEntries(const string &section, list< string > *entries, TFlags flags=fAllLayers) const

Enumerate parameter names for a specified section.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

#define SERV_MINIMAL_RATE

SSERV_InfoCPtr SERV_GetNextInfo(SERV_ITER iter)

Same as "SERV_GetNextInfoEx(., 0)" – i.e.

void SERV_Close(SERV_ITER iter)

Deallocate the iterator.

int HINFO_Status(const HOST_INFO host_info, double status[2])

Obtain LB host availability status.

SERV_ITER SERV_Open(const char *service, TSERV_Type types, unsigned int preferred_host, const SConnNetInfo *net_info)

Same as "SERV_OpenEx(., ., ., ., 0, 0)" – i.e.

unsigned int TSERV_Type

Bitwise OR of ESERV_Type[Special].

SSERV_InfoCPtr SERV_GetNextInfoEx(SERV_ITER iter, HOST_INFO *host_info)

Get the next server meta-address, optionally accompanied by the host parameters made available by the...

@ fSERV_ReverseDns

LB-DNS translation.

@ fSERV_Promiscuous

Evrthng and the kitchen sink.

void SOCK_GetPeerAddress(SOCK sock, unsigned int *host, unsigned short *port, ENH_ByteOrder byte_order)

Get host and port of the socket's peer (remote end).

unsigned short SOCK_GetRemotePort(SOCK sock, ENH_ByteOrder byte_order)

Get remote port of the socket (the port it is connected to).

EIO_Status SOCK_Close(SOCK sock)

Close the SOCK handle, and destroy all relevant internal data.

static CNCBI_IPAddr gethostbyname(const string &host, ESwitch log=eOff)

Return 0 or empty address on error.

static string HostPortToString(const CNCBI_IPAddr &addr, unsigned short port)

See SOCK_HostPortToString[6], return empty when failed.

EIO_Status SOCK_CreateOnTopEx(const void *handle, size_t handle_size, SOCK *sock, const void *data, size_t size, TSOCK_Flags flags)

[SERVER-side] Create a SOCKet on top of either an OS-dependent "handle" (file descriptor on Unix,...

static string ntoa(const CNCBI_IPAddr &addr)

BSD-like API.

@ fSOCK_KeepOnClose

retain OS handle in SOCK_Close[Ex]()

static double StringToDouble(const CTempStringEx str, TStringToNumFlags flags=0)

Convert string to double.

static TNumeric StringToNumeric(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to a numeric value.

bool empty(void) const

Return true if the represented string is empty (i.e., the length is zero)

static string UIntToString(unsigned int value, TNumToStringFlags flags=0, int base=10)

Convert UInt to string.

static bool SplitInTwo(const CTempString str, const CTempString delim, string &str1, string &str2, TSplitFlags flags=0)

Split a string into two pieces using the specified delimiters.

@ fSplit_MergeDelimiters

Merge adjacent delimiters.

#define NCBI_TIME_INFINITE

SConnNetInfo * ConnNetInfo_Create(const char *service)

void ConnNetInfo_Destroy(SConnNetInfo *net_info)

SNetStorageObjectState< SNetStorageObjectDirectState< TBase > > TState

@ fDBLB_AllowFallbackToStandby

const char * DBLB_GetServer(const char *lb_name, TDBLB_Flags flags, const SDBLB_Preference *preference, const char *const skip_servers[], SDBLB_ConnPoint *conn_point, char *server_name_buf, size_t server_name_buflen, EDBLB_Status *result)

CRef< CDBServer > TSvrRef

double LBSM_CalculateStatus(double rate, double fine, ESERV_Algo algo, const SLBSM_HostLoad *load)

SSERV_Info * SERV_CopyInfoEx(const SSERV_Info *orig, const char *name)

const char * SERV_NameOfInfo(const SSERV_Info *info)

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

static SLJIT_INLINE sljit_ins st(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

static SLJIT_INLINE sljit_ins l(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

CDBServerOption::TState TState

SRawOption(const SSERV_Info &si, TState st, const SLBSM_HostLoad &l)

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