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

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

NCBI C++ ToolKit: src/app/netcache/distribution_conf.cpp Source File

log_pfx(

);

isReconf = prevMirrorCfg !=

;

vector<Uint2> self_slots;

found_self =

;

(

srv_idx = 0; ; ++srv_idx) {

(reg_value.empty())

srv_name = reg_value;

list<CTempString> srv_fields;

ncbi_NStr_Split(reg_value,

, srv_fields);

(srv_fields.size() != 3) {

err_message = srv_name +

;

list<CTempString>::const_iterator it_fields = srv_fields.begin();

grp_name = *it_fields;

host_str = *it_fields;

port_str = *it_fields;

(host == 0 || port == 0) {

err_message = srv_name +

;

trustlevel = 0;

(!reg_value.empty()) {

peer_str = host_str +

+ port_str;

err_message = srv_name +

;

err_message = srv_name +

;

err_message = srv_name + +

;

mirrorCfg->

[srv_id] = peer_str;

(reg_value.empty()) {

err_message = srv_name +

;

ncbi_NStr_Split(reg_value,

, values);

(list<string>, it, values) {

err_message = srv_name +

+

(*it);

(find(srvs.begin(), srvs.end(), srv_id) != srvs.end()) {

err_message = srv_name +

+

(*it);

vector<Uint2>& slots = isReconf ? self_slots :

;

(find(slots.begin(), slots.end(), slot) != slots.end()) {

err_message = srv_name +

+

(*it);

slots.push_back(slot);

srvs.push_back(srv_id);

(isReconf && !self_slots.empty()) {

err_message =

+

;

srv_id = it_peer->first;

vector<Uint2>& common_slots = mirrorCfg->

[srv_id];

slot = it_slot->first;

(find(srvs.begin(), srvs.end(), srv_id) != srvs.end()) {

common_slots.push_back(it_slot->first);

value_name,

;

(srv_idx = 0; ; ++srv_idx) {

(

.empty()) {

(srv_idx = 0; ; ++srv_idx) {

(pn = new_peers.

(); pn != new_peers.

(); ++pn) {

po = old_peers.

(pn->first);

(po != old_peers.

()) {

(pn->second.

() != po->second.

() ||

!std::equal(pn->second.

(), pn->second.

(), po->second.

())) {

err_message = pn->first +

;

(po = old_peers.

(); po != old_peers.

(); ++po) {

pn = new_peers.

(po->first);

(pn != new_peers.

()) {

(po->second.

() != pn->second.

() ||

!std::equal(po->second.

(), po->second.

(), pn->second.

())) {

err_message = po->first +

;

(pn = new_peers.

(); pn != new_peers.

(); ++pn) {

po = old_peers.

(pn->first);

(po != old_peers.

()) {

(po = old_peers.

(); po != old_peers.

(); ++po) {

pn = new_peers.

(po->first);

(pn != new_peers.

()) {

is(

),iss(

), eol(

),

(

), eos(

);

srv_id = p->first;

slot = it_slot->first;

(find(srvs.begin(), srvs.end(), srv_id) != srvs.end()) {

slots.push_back(slot);

( vector<Uint2>, s, slots) {

(s != slots.begin()) {

is(

),iss(

), eol(

),

(

), eos(

);

shuffle(srvs.begin(), srvs.end(), mt);

(

= 0;

< srvs.size(); ++

) {

lst.push_back(srvs[

].srv_id);

(

= 0;

< srvs.size(); ++

) {

lst.push_back(srvs[

].srv_id);

vector<Uint2>& srv_slots(

(

s : srv_slots) {

(peers.

(srv_id) != peers.

()) {

name = peers.

(srv_id)->second;

name =

;

lst.push_back(it_peer->first);

index = rnd_num / piece_share;

rnd_num -= index * piece_share;

(

[0] ==

)

key_rnd = 0;

SKIP_UNDERSCORE(

, ind);

SKIP_UNDERSCORE(

, ind);

SKIP_UNDERSCORE(

, ind);

SKIP_UNDERSCORE(

, ind);

SKIP_UNDERSCORE(

, ind);

SKIP_UNDERSCORE(

, ind);

ind =

.rfind(

);

(ind == string::npos) {

(key_rnd == 0 && errno != 0) {

.AddChars(

.RawKey().data(),

.RawKey().size());

.AddChars(

.PackedKey().data(),

.PackedKey().size());

(

.IsICacheKey()) {

(

.KeyVersion() == 3) ?

(

.KeyVersion() == 3) {

alias =

.GetHostPortCRC32();

& host_str(

.GetHost());

cur_time, create_server, write_server, cur_time - create_time);

Uint4 GetDefaultTaskPriority(void)

Checksum and hash calculation classes.

CChecksum – Checksum calculator.

Mutex created to have minimum possible size (its size is 4 bytes) and to sleep using kernel capabilit...

void Unlock(void)

Unlock the mutex.

void Lock(void)

Lock the mutex.

const CTempString & RawKey(void) const

const CTempString & SubKey(void) const

const CTempString & Cache(void) const

void Assign(const CTempString &cache_name, const CTempString &blob_key, const CTempString &blob_subkey)

static void GenerateBlobKey(Uint2 local_port, string &key, Uint2 &slot, Uint2 &time_bucket, unsigned int ver=1)

static Uint2 GetMaxPeerBGConns(void)

static const TNCPeerList & GetPeers(void)

static bool IsThisServerKey(const string &packed_key)

static bool IsServedLocally(Uint2 slot)

static Uint2 GetMaxMirrorQueueSize(void)

static Uint8 GetPeriodicSyncInterval(void)

static bool GetSlotByNetCacheKey(const string &key, Uint2 &slot, Uint2 &time_bucket)

static Uint8 GetPeriodicSyncTailTime(void)

static Uint1 GetMaxSyncsOneServer(void)

static void GetSlotByRnd(Uint4 key_rnd, Uint2 &slot, Uint2 &time_bucket)

static void Finalize(void)

static Uint4 GetSyncPriority(void)

static const vector< Uint2 > & GetSelfSlots(void)

static Uint8 GetSmallBlobBoundary(void)

static bool ReConfig(const CNcbiRegistry &new_reg, string &err_message)

static string GetPeerNameOrEmpty(Uint8 srv_id)

static Uint2 GetMaxPeerTotalConns(void)

static string GetPeerName(Uint8 srv_id)

static size_t CountServersForSlot(Uint2 slot)

static string GetFullPeerName(Uint8 srv_id)

static const vector< Uint2 > & GetSlotsForServer(Uint8 srv_id)

static Uint4 GetMainSrvIP(const CNCBlobKey &key)

static Uint8 GetNetworkErrorTimeout(void)

static Uint2 GetCntErrorsToThrottle(void)

static Uint1 GetBlobListTimeout(void)

static void AddServerSlots(set< Uint2 > &slots, Uint8 srv_id)

static Uint8 GetPeriodicSyncTimeout(void)

static Uint4 GetMaxCleanLogBatch(void)

static Uint8 GetMainSrvId(const CNCBlobKey &key)

static Uint8 GetSelfTrustLevel(void)

static Uint2 GetMaxSlotNumber(void)

static void GetPeerServers(TServersList &lst)

static bool GetBlobUpdateHotline(void)

static Uint8 GetPeerThrottlePeriod(void)

static bool GetSlotByKey(const string &key, Uint2 &slot, Uint2 &time_bucket)

static Uint2 GetCntSlotBuckets(void)

static const string & GetSyncLogFileName(void)

static bool GetWarnBlobSizeSync(void)

static const TServersList & GetRawServersForSlot(Uint2 slot)

static void GetSlotByICacheKey(const CNCBlobKeyLight &key, Uint2 &slot, Uint2 &time_bucket)

static Uint8 GetFailedSyncRetryDelay(void)

static bool InitMirrorConfig(const CNcbiRegistry &reg, string &err_message)

static const string & GetPeriodicLogFile(void)

static void PrintBlobCopyStat(Uint8 create_time, Uint8 create_server, Uint8 write_server)

static Uint4 CreateHostAlias(Uint4 ip, Uint4 port)

static Uint8 GetMaxBlobSizeSync(void)

static bool HasCommonSlots(Uint8 server)

static Uint1 GetCntActiveSyncs(void)

static Uint2 GetCntThrottlesToIpchange(void)

static bool HasPeers(void)

static const string & GetMirroringSizeFile(void)

static Uint2 GetCntTimeBuckets(void)

static const vector< Uint2 > & GetCommonSlots(Uint8 server)

static Uint8 GetSelfID(void)

static void WriteEnvInfo(CSrvSocketTask &task)

static Uint8 GetSrvIdByIP(Uint4 ip)

static Uint4 GetMaxSlotLogEvents(void)

static void GetServersForSlot(Uint2 slot, TServersList &lst)

static Uint4 GetCleanAttemptInterval(void)

static bool Initialize(Uint2 control_port)

static Uint8 GetMinForcedCleanPeriod(void)

static Uint8 GetPeriodicSyncHeadTime(void)

static Uint1 GetPeerTimeout(void)

static void WriteSetup(CSrvSocketTask &task)

static Uint4 GetCleanLogReserve(void)

static Uint4 FindIPbyName(const string &alias)

Uint8 GetRawTrustLevel(void) const

void SetHostProtocol(Uint8 ver)

static string GetPeerNameOrEmpty(Uint8 srv_id)

static CNCPeerControl * Peer(Uint8 srv_id)

static Uint4 FindIPbyAlias(Uint4 alias)

void SetTrustLevel(Uint8 trust)

static bool IsInitiallySynced(void)

Task controlling a socket.

CSrvSocketTask & WriteText(CTempString message)

Write text into socket.

CSrvSocketTask & WriteNumber(NumType num)

Write number into socket as string, i.e.

CSrvSocketTask & WriteBool(bool b)

static CSrvTime Current(void)

Exact current time with precision up to nanoseconds.

Uint8 AsUSec(void) const

Converts object's value to microseconds since epoch.

static const CNcbiRegistry & GetConfRegistry(void)

Obtains reference to registry read from application's ini-file.

static CNcbiRegistry & SetConfRegistry(void)

Used to modify original registry (to reflect RECONF modifications)

static const string & GetHostName(void)

Returns name of server this application is executing on.

static string IPToString(Uint4 ip)

Converts 4-byte encoded IP address into its string representation.

static Uint4 GetIPByHost(const string &host)

Converts server name (or IP address written as string) to encoded 4-byte IP address.

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

const_iterator begin() const

const_iterator end() const

const_iterator find(const key_type &key) const

iterator_bool insert(const value_type &val)

static const char * kNCReg_NCPoolSection

static Uint2 s_MaxPeerBGConns

static string s_SyncLogFileName

static string kNCReg_NCServerTrustPrefix

static CRandom s_KeyRnd(CRandom::TValue(time(NULL)))

static Uint8 s_PeriodicSyncTimeout

static string s_PeriodicLogFile

static string s_SelfGroup

static bool s_BlobUpdateHotline

static Uint8 s_PeriodicSyncInterval

static string kNCReg_NCServerPrefix

static Uint2 s_MaxSlotNumber

static Uint4 s_MaxCleanLogBatch

static string s_MirroringSizeFile

static Uint4 s_SlotRndShare

map< Uint8, vector< Uint2 > > TSrv2SlotMap

static string s_SelfHostIP

static CMiniMutex s_KeyRndLock

static CAtomicCounter s_BlobId

static string s_CopyDelayLogFile

static Uint1 s_MaxSyncsOneServer

static SSrvMirrorInfo * s_MirrorConf

static bool s_WarnBlobSizeSync

static Uint4 s_TimeRndShare

static Uint2 s_MaxPeerTotalConns

static Uint8 s_FailedSyncRetryDelay

static Uint4 s_CleanAttemptInterval

static string kNCReg_NCServerSlotsPrefix

static Uint2 s_CntTimeBuckets

static Uint2 s_CntThrottlesToIpchange

static FILE * s_CopyDelayLog

static Uint2 s_CntSlotBuckets

static Uint1 s_BlobListTimeout

static Uint8 s_SmallBlobBoundary

static Uint2 s_CntErrorsToThrottle

map< Uint2, TSrvGroupsList > TSrvGroupsMap

static Uint1 s_CntActiveSyncs

static Uint8 s_NetworkErrorTimeout

static Uint8 s_MaxBlobSizeSync

static Uint4 s_MaxSlotLogEvents

vector< SSrvGroupInfo > TSrvGroupsList

static bool s_SlotByRawkey

static Uint4 s_CleanLogReserve

static Uint8 s_PeerThrottlePeriod

static Uint1 s_PeerTimeout

static vector< Uint2 > s_SelfSlots

map< Uint2, TServersList > TSlot2SrvMap

static Uint2 s_MaxMirrorQueueSize

static Uint4 s_TaskPrioritySync

static Uint8 s_MinForcedCleanPeriod

static const char * str(char *buf, int n)

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

TValue Add(int delta) THROWS_NONE

Atomically add value (=delta), and return new counter value.

void Critical(CExceptionArgs_Base &args)

void Error(CExceptionArgs_Base &args)

static Uint4 CalculateChecksum(const string &host, unsigned short port)

Calculate and return the CRC32 checksum generated from the string "host:port".

static void GenerateBlobKey(string *key, unsigned int id, const string &host, unsigned short port, unsigned int ver, unsigned int rnd_num, time_t creation_time=0)

Generate blob key string.

static bool ParseBlobKey(const char *key_str, size_t key_len, CNetCacheKey *key_obj, CCompoundIDPool::TInstance id_pool=NULL)

Parse blob key string into a CNetCacheKey structure.

uint8_t Uint1

1-byte (8-bit) unsigned integer

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define NCBI_UINT8_FORMAT_SPEC

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)

static TValue GetMax(void)

The max. value GetRand() returns.

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

Get boolean value of specified parameter name.

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 string GetString(const string &section, const string &name, const string &default_value, TFlags flags=0) const

Get the parameter string value.

bool Set(const string &section, const string &name, const string &value, TFlags flags=0, const string &comment=kEmptyStr)

Set the configuration parameter value.

@ fPersistent

Persistent – saved when file is written.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static Uint8 StringToUInt8_DataSize(const CTempString str, TStringToNumFlags flags=0)

Convert string that can contain "software" qualifiers to Uint8.

const char * data(void) const

Return a pointer to the array represented.

static string UInt8ToString_DataSize(Uint8 value, TNumToStringFlags flags=0, unsigned int max_digits=3)

Convert UInt8 to string using "software" qualifiers.

static Uint8 StringToUInt8(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to Uint8.

static unsigned int StringToUInt(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to unsigned int.

static enable_if< is_arithmetic< TNumeric >::value||is_convertible< TNumeric, Int8 >::value, string >::type NumericToString(TNumeric value, TNumToStringFlags flags=0, int base=10)

Convert numeric value to string.

size_type size(void) const

Return the length of the represented array.

static string UInt8ToString(Uint8 value, TNumToStringFlags flags=0, int base=10)

Convert UInt8 to string.

@ fAllowTrailingSpaces

Ignore trailing whitespace characters.

@ fConvErr_NoThrow

Do not throw an exception on error.

@ fAllowTrailingSymbols

Ignore trailing non-numerics characters.

@ fAllowLeadingSpaces

Ignore leading whitespace characters in converted string.

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

const GenericPointer< typename T::ValueType > T2 value

vector< Uint8 > TServersList

Process information in the NCBI Registry, including working with configuration files.

#define SRV_LOG(sev, msg)

Macro to be used for printing log messages.

#define ACCESS_ONCE(x)

Purpose of this macro is to force compiler to access variable exactly at the place it's written (no m...

bool AtomicCAS(T volatile &var, T old_value, T new_value)

constexpr Uint8 kUSecsPerSecond

Meaningful information encoded in the NetCache key.

SSrvGroupInfo(Uint8 srv, const string &group)

TSlot2SrvMap s_RawSlot2Servers

TSrv2SlotMap s_CommonSlots

map< Uint4, Uint8 > s_IpToId

TSrv2SlotMap s_Servers2Slots

TSrvGroupsMap s_Slot2Servers

map< Uint8, Uint8 > s_SrvTrust

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