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

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

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

s_InitTests(

);

(

= 1;

< argc; ++

) {

.GetVersion();

(

!= &another) {

+ blob_subkey.

() + 2);

* key_str = cache_str + cache_size + 1;

key_size =

.find(

, cache_size + 1)

* subkey_str = key_str + key_size + 1;

subkey_size =

.size() - cache_size - key_size - 2;

.append(

);

(blob_key.

() && cache_name.

()) {

rawKey = blob_key;

}

(cache_name.

()) {

(

,

<< blob_key);

m_TaskName =

;

time_t modified = 0;

(

== modified) {

+=

;

(left.size() != right.size())

(left.size()) -

(right.size());

left.compare(right);

& section,

one_month = 2592000;

(pass_policy ==

) {

(pass_policy ==

) {

(pass_policy !=

) {

<<

<< pass_policy

<<

);

best_index,

params_set->

.insert(params_set->

.begin() + best_index, entry);

& best_index)

low = 1;

mid = (low + high) / 2;

(comp_res > 0)

(cur_set->

.size() == 0) {

(

= 0;

< cur_set->

.size(); ++

) {

cur_set,

- 1, this_deflt);

main_params->

=

;

main_params->

= 2592000;

keys.push_back(

);

params_set = next_set;

list<string> conf_sections;

(list<string>, sec_it, conf_sections) {

& section = *sec_it;

& key_name = *prty_it;

keys.push_back(key_name);

& key_value = reg.

(section, key_name);

next_ind = 0;

(cur_set->

.size() == 0) {

(cur_set->

.size() == 0) {

(cur_set->

.size() != 0) {

(

,

<< section <<

);

list<string> split_ports;

ncbi_NStr_Split(ports_str,

, split_ports);

(list<string>, it, split_ports) {

<< *it <<

<< ex);

<<

(

<< forget);

(

<< port);

port = *it;

ports_str.append(

, 2);

ports_str.resize(ports_str.size() - 2);

(

<< ports_str);

(

);

(it != client_params.

()) {

&

= it->second;

best_index = 0;

(it != client_params.

()) {

&

= it->second;

best_index = 0;

(!cur_set->

.empty()) {

(!

&& it != client_params.

()) {

&

= it->second;

best_index = 0;

cur_set_2 = next_set;

(!cur_set_2->

.empty()) {

vector<string>& keys)

(

= 0;

< cur_set->

.size(); ++

) {

keys.push_back(cur_set->

[

].key);

cur_set,

- 1, this_deflt, keys);

caches.push_back(

.at(

));

(vector<string>, k, keys) {

(k->empty() || all_ports.

(*k) != all_ports.

()) {

caches.push_back(*k);

caches.push_front(

);

is(

), iss(

), eol(

), eos(

);

is_first =

;

(list<string>, c, caches) {

eol(

), is(

), isv(

),

iss(

), eos(

),

isk(

), eok(

);

is(

),iss(

), eol(

), eos(

);

(

);

(

);

(cur_time.

());

(!ofs.is_open()) {

(

argc,

* argv[])

(

= 1;

< argc; ++

) {

param(argv[

]);

(param ==

) {

}

(param ==

) {

cout <<

<< endl;

cout <<

<< endl;

cout <<

<< endl;

cout <<

<< endl;

cout <<

<< endl;

cout <<

<< endl;

cout <<

<< endl;

(getrlimit(RLIMIT_CORE, &rlim) == 0) {

rlim.rlim_cur = RLIM_INFINITY;

setrlimit(RLIMIT_CORE, &rlim);

is_daemon =

;

is_reinit =

;

(

= 1;

< argc; ++

) {

param(argv[

]);

(param ==

) {

}

(param ==

) {

}

(param ==

) {

(

+ 1 < argc) {

pid_file = argv[++

];

= !pid_file.empty() && pid_file[0] !=

&&

(pid_file);

cerr <<

<< pid_file << endl;

cerr <<

<< endl;

cerr <<

<< param << endl;

cout <<

<< endl;

(

);

cerr <<

<< endl;

(!pid_file.empty()) {

MAKE_TEST_TASKS = 100;

MAKE_TEST_MAXSIZE = 1000000;

MAKE_TEST_DELAY = 1;

MAKE_TEST_INTERVAL = 10;

CTest_BlobStorage :

<CTest_BlobStorage>

CTest_BlobStorage(

);

~CTest_BlobStorage(

);

State x_Start(

);

State x_WaitForBlobAccess(

);

State x_PutBegin(

);

State x_PutBlobChunk(

);

State x_PutEnd(

);

State x_Remove(

);

State x_Next(

);

State x_Stop(

);

PutData(

*

,

);

IsTaskPaused(

);

PrintStat(

);

vector<string> m_Keys;

* ms_Commands[];

s_InitTests(

);

CTest_BlobStorage::ms_Rnd;

* CTest_BlobStorage::ms_Commands[] = {

,

,

};

s_Noop = 0;

s_Put3 = 1;

s_Remove = 2;

s_CounterPut = 0;

s_CounterRem = 0;

s_SizePut = 0;

s_SizeRem = 0;

s_ftxCounter;

s_InitTests(

)

(

<<

);

(

=0;

< MAKE_TEST_TASKS; ++

) {

CTest_BlobStorage(

);

CTest_BlobStorage::CTest_BlobStorage(

)

SetState(&Me::x_Start);

CTest_BlobStorage::~CTest_BlobStorage(

)

CTest_BlobStorage::Reset(

)

m_BlobAccess =

;

rand1 = ms_Rnd.GetRand(0, MAKE_TEST_MAXSIZE);

rand2 =

( ms_Rnd.GetRand(1, (rand1+3)/4 + 1), rand1/100);

(m_Keys.size() > 10) {

(ms_Rnd.GetRand(1, 2) == 2) {

shuffle(m_Keys.begin(), m_Keys.end(), default_random_engine());

m_BlobKey.Assign( *m_Keys.begin());

m_Keys.erase(m_Keys.begin());

(m_Counter == 2) {

m_BlobKey = *m_Keys.begin();

m_Keys.erase(m_Keys.begin());

ms_RndLock.Unlock();

(!m_BlobKey.IsValid()) {

m_Command = s_Remove;

(m_Counter > 2) {

CTest_BlobStorage::PutData(

*

,

)

CTest_BlobStorage::IsTaskPaused(

)

((m_Counter % MAKE_TEST_INTERVAL) == 0) {

(

== MAKE_TEST_TASKS) {

CTest_BlobStorage::PrintStat(

)

cout <<

<< endl;

cout <<

<< s_CounterPut << endl;

cout <<

<< s_CounterRem << endl;

cout <<

<< (s_CounterPut - s_CounterRem) << endl;

cout <<

<< s_SizePut << endl;

cout <<

<< s_SizeRem << endl;

cout <<

<< (s_SizePut - s_SizeRem) << endl;

cout <<

<< endl;

cout <<

<<

.db_files << endl;

cout <<

<<

.cnt_blobs << endl;

cout <<

<<

.cnt_keys << endl;

cout <<

<<

.min_dead_time << endl;

cout <<

<<

.db_size << endl;

cout <<

<<

.db_garb << endl;

cout <<

<<

.db_size -

.db_garb << endl;

cout <<

<<

.wb_size << endl;

cout <<

<<

.wb_releasable << endl;

cout <<

<<

.wb_releasing << endl;

cout <<

<< endl;

CTest_BlobStorage::State

CTest_BlobStorage::x_Start(

)

(m_Command == s_Put3) {

m_BlobKey.Assign(m_RawKey);

m_Keys.push_back(m_RawKey);

m_BlobAccess->RequestMetaInfo(

);

&CTest_BlobStorage::x_WaitForBlobAccess;

CTest_BlobStorage::State

CTest_BlobStorage::x_WaitForBlobAccess(

)

(!m_BlobAccess->IsMetaInfoReady()) {

(m_Command == s_Put3) {

&CTest_BlobStorage::x_PutBegin;

&CTest_BlobStorage::x_Remove;

CTest_BlobStorage::State

CTest_BlobStorage::x_PutBegin(

)

m_BlobAccess->SetBlobTTL(m_AppSetup->blob_ttl);

m_BlobAccess->SetVersionTTL(0);

m_BlobAccess->SetBlobVersion(0);

&CTest_BlobStorage::x_PutBlobChunk;

CTest_BlobStorage::State

CTest_BlobStorage::x_PutBlobChunk(

)

read_len =

(m_BlobAccess->GetWriteMemSize());

(m_BlobAccess->HasError()) {

(read_len > m_ChunkLen) {

read_len = m_ChunkLen;

(read_len > m_DataSize) {

read_len = (

)m_DataSize;

n_read =

(PutData(m_BlobAccess->GetWriteMemPtr(), read_len));

m_BlobAccess->MoveWritePos(n_read);

m_DataSize -= n_read;

m_BlobSize += n_read;

(m_DataSize != 0) {

&CTest_BlobStorage::x_PutEnd;

CTest_BlobStorage::State

CTest_BlobStorage::x_PutEnd(

)

cur_secs =

(cur_srv_time.

());

m_BlobAccess->SetBlobCreateTime(cur_time);

(m_BlobAccess->GetNewBlobExpire() == 0)

m_BlobAccess->SetNewBlobExpire(cur_secs + m_BlobAccess->GetNewBlobTTL());

m_BlobAccess->SetNewVerExpire(cur_secs + m_BlobAccess->GetNewVersionTTL());

m_BlobAccess->SetCreateServer(

(m_BlobAccess->HasError()) {

CTest_BlobStorage::State

CTest_BlobStorage::x_Remove(

)

(m_BlobAccess->IsBlobExists() && !m_BlobAccess->IsCurBlobExpired())

m_BlobSize = m_BlobAccess->GetCurBlobSize();

m_BlobAccess->SetBlobTTL(m_AppSetup->blob_ttl);

mirrored_ttl = is_good ?

(

(300), m_AppSetup->blob_ttl) : m_AppSetup->blob_ttl;

local_ttl = 5;

m_BlobAccess->SetBlobTTL( is_mirrored ? mirrored_ttl : local_ttl);

m_BlobAccess->SetBlobVersion(0);

ttl = m_BlobAccess->GetNewBlobTTL();

(m_BlobAccess->IsBlobExists() && m_BlobAccess->GetCurBlobTTL() > ttl)

ttl = m_BlobAccess->GetCurBlobTTL();

m_BlobAccess->SetNewBlobExpire(expire, expire + ttl + 1);

cur_secs =

(cur_srv_time.

());

m_BlobAccess->SetBlobCreateTime(cur_time);

(m_BlobAccess->GetNewBlobExpire() == 0)

m_BlobAccess->SetNewBlobExpire(cur_secs + m_BlobAccess->GetNewBlobTTL());

m_BlobAccess->SetNewVerExpire(cur_secs + m_BlobAccess->GetNewVersionTTL());

CTest_BlobStorage::State

(m_Command == s_Put3) {

m_BlobAccess->Finalize();

m_BlobAccess->Release();

m_BlobAccess =

;

cmd_len -= m_CmdStartTime;

&CTest_BlobStorage::x_Next;

CTest_BlobStorage::State

CTest_BlobStorage::x_Next(

)

&CTest_BlobStorage::x_Stop;

(IsTaskPaused()) {

(m_Command != s_Noop) {

SetState(&Me::x_Start);

(MAKE_TEST_DELAY != 0) {

RunAfter(MAKE_TEST_DELAY);

CTest_BlobStorage::State

CTest_BlobStorage::x_Stop(

)

Wrapper around Linux's futex.

EWaitResult WaitValueChange(int old_value)

Wait for futex's value to change (with and without timeout).

int GetValue(void)

Read value of the futex.

@ eTimedOut

Method returned because total waiting time exceeded given timeout.

bool ChangeValue(int old_value, int new_value)

Atomically change value of the futex.

int WakeUpWaiters(int cnt_to_wake)

Wake up some threads waiting on this futex.

int AddValue(int cnt_to_add)

Atomically add some amount to futex's value.

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

static void Initialize(void)

static void Register(EAlertType alert_type, const string &message)

@ ePidFileFailed

Reporting Pid failed.

@ eStartupConfigChanged

Configuration file changed.

static bool UpdatePurgeData(const string &data, char separator='\n')

unsigned int m_KeyVersion

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

CNCBlobKeyLight & operator=(const CNCBlobKeyLight &another)

string KeyForLogs(void) const

unsigned int KeyVersion(void) const

CNCBlobKeyLight & Copy(const CNCBlobKeyLight &another)

void SetKeyVersion(unsigned int v)

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

static void SaveMaxSyncLogRecNo(void)

static Uint8 GetMaxSyncLogRecNo(void)

static void MeasureDB(SNCStateStat &state)

static string GetPurgeData(void)

static CNCBlobAccessor * GetBlobAccess(ENCAccessType access, const string &key, const string &password, Uint2 time_bucket)

Acquire access to the blob identified by key, subkey and version.

static void Finalize(void)

static bool Initialize(bool do_reinit)

static Uint8 GetMaxBlobSizeStore(void)

static bool IsCleanStart(void)

static void CheckDiskSpace(void)

static Uint4 GetNewBlobId(void)

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

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

static void Finalize(void)

static size_t CountServersForSlot(Uint2 slot)

static Uint8 GetMaxBlobSizeSync(void)

static Uint8 GetSelfID(void)

static bool Initialize(Uint2 control_port)

virtual void ExecuteSlice(TSrvThreadNum thr_num)

This is the main method to do all work this task should do.

static void CheckConfFile(void)

virtual ~CNCHeartBeat(void)

static void Finalize(void)

static bool HasPeerInThrottle(void)

static bool Initialize(void)

static void ReadCurState(SNCStateStat &state)

static void Finalize(void)

static bool Initialize(void)

static const SNCSpecificParams * GetAppSetup(const TStringMap &client_params)

static void ReadCurState(SNCStateStat &state)

static const string & GetAdminClient(void)

Get name of client that should be used for administrative commands.

static bool IsDebugMode(void)

static bool IsCachingComplete(void)

static void WriteAppSetup(TNCBufferType &task, const TStringMap &client)

static int GetDefBlobTTL(void)

Get inactivity timeout for each connection.

static string GetHostLocation(void)

static int GetUpTime(void)

Get total number of seconds the server is running.

static void WriteEnvInfo(CSrvSocketTask &task)

static bool IsInitiallySynced(void)

static void InitialSyncRequired(void)

static string GetHostRole(void)

static void CachingCompleted(void)

static void InitialSyncComplete(void)

static void CmdFinished(const char *cmd, Uint8 len_usec, int status)

static void SaveCurStateStat(const SNCStateStat &state)

static void CmdStarted(const char *cmd)

static void DumpAllStats(void)

static void ClientBlobWrite(Uint8 blob_size, Uint8 len_usec)

static void ClientDataWrite(size_t data_size)

static void Initialize(void)

static void Initialize(bool need_read_saved, Uint8 start_log_rec_no)

static bool Finalize(void)

static Uint8 GetLogSize(void)

static void Initialize(void)

Initialization of SQLite and tuning some default parameters.

static void Finalize(void)

Finish all SQLite operations.

Task controlling a socket.

CSrvSocketTask & WriteText(CTempString message)

Write text into socket.

CSrvSocketTask & WriteNumber(NumType num)

Write number into socket as string, i.e.

Special task which executes as finite state machine.

void RunAfter(Uint4 delay_sec)

This call is basically equivalent to SetRunnable() but with guarantee that task will be scheduled for...

void SetRunnable(bool boost=false)

Set this task "runnable", i.e.

Class incorporating convenient methods to work with struct timespec.

static int CurSecs(void)

Current time in seconds since epoch (time_t).

time_t & Sec(void)

Read/set number of seconds since epoch stored in the object.

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 const string & GetHostName(void)

Returns name of server this application is executing on.

static void RequestShutdown(ESrvShutdownType shutdown_type)

Asks server to start shutdown procedures.

static bool AddListeningPort(Uint2 port, CSrvSocketFactory *factory)

Adds port for TaskServer to listen to.

static CSrvTime GetStartTime(void)

Returns time when this server application was started (when Initialize() method was called).

static void Finalize(void)

Finalizes TaskServer infrastructure.

static bool IsInShutdown(void)

Checks if TaskServer received request to shutdown.

static bool Initialize(int &argc, const char **argv)

Initializes TaskServer infrastructure from given command line arguments.

static void Run(void)

Run all TaskServer machinery.

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

static void Initialize(void)

static void ReadState(SNCStateStat &state)

TNCBufferType & WriteNumber(NumType num)

TNCBufferType & WriteText(const char *buf)

container_type::const_iterator const_iterator

const_iterator end() const

const_iterator find(const key_type &key) const

iterator_bool insert(const value_type &val)

const_iterator find(const key_type &key) const

const_iterator end() const

The NCBI C++ standard methods for dealing with std::string.

static unsigned char depth[2 *(256+1+29)+1]

std::ofstream out("events_result.xml")

main entry point for tests

static DLIST_TYPE *DLIST_NAME() first(DLIST_LIST_TYPE *list)

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

#define ERR_POST(message)

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

void Critical(CExceptionArgs_Base &args)

void Error(CExceptionArgs_Base &args)

void Warning(CExceptionArgs_Base &args)

static string NormalizePath(const string &path, EFollowLinks follow_links=eIgnoreLinks)

Normalize a path.

static bool IsAbsolutePath(const string &path)

Check if a "path" is absolute for the current OS.

Int8 GetLength(void) const

Get size of file.

bool GetTimeT(time_t *modification, time_t *last_access=0, time_t *creation=0) const

Get time stamp(s) of a directory entry (time_t version).

static string ConcatPath(const string &first, const string &second)

Concatenate two parts of the path for the current OS.

static string GetCwd(void)

Get the current working directory.

bool GetTime(CTime *modification, CTime *last_access=0, CTime *creation=0) const

Get time stamp(s) of a directory entry.

virtual bool Exists(void) const

Check existence of file.

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.

bool HasExtensions() const

unsigned GetVersion() const

string StripKeyExtensions() const

If the blob key has been parsed successfully, this method returns a trimmed "base" version of the key...

TObjectType * GetNCPointer(void) const THROWS_NONE

Get pointer,.

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

int64_t Int8

8-byte (64-bit) signed integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

static TPid Daemonize(const char *logfile=0, TDaemonFlags flags=0)

Go daemon.

static TPid GetPid(void)

Get process identifier (pid) for the current process.

Uint4 TValue

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

void SetSeed(TValue seed)

Seed the random number generator with "seed".

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 void EnumerateSections(list< string > *sections, TFlags flags=fAllLayers) const

Enumerate section names.

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

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

Get the parameter string value.

@ fCountCleared

Let explicitly cleared entries stand.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

IO_PREFIX::ofstream CNcbiOfstream

Portable alias for ofstream.

IO_PREFIX::ifstream CNcbiIfstream

Portable alias for ifstream.

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

Convert string to int.

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.

CTempString & assign(const char *src_str, size_type len)

Assign new values to the content of the a string.

static const string BoolToString(bool value)

Convert bool to string.

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

Convert int to string.

static string Join(const TContainer &arr, const CTempString &delim)

Join strings using the specified delimiter.

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.

bool empty(void) const

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

static bool StartsWith(const CTempString str, const CTempString start, ECase use_case=eCase)

Check if a string starts with a specified prefix value.

void clear(void)

Clears the string.

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.

const char *const kEmptyCStr

Empty "C" string (points to a '\0').

size_type size(void) const

Return the length of the represented array.

@ eNocase

Case insensitive compare.

string AsString(const CTimeFormat &format=kEmptyStr, TSeconds out_tz=eCurrentTimeZone) const

Transform time to string.

unsigned int

A callback function used to compare two keys in a database.

string GetLogFileName(void)

const struct ncbi::grid::netcache::search::fields::SIZE size

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

const GenericPointer< typename T::ValueType > T2 value

const CharType(& source)[N]

void SetWBInitialSyncComplete(void)

void InitClientMessages(void)

Initializes maps between status codes and error texts sent to client to explain these codes.

map< string, string > TStringMap

@ eStatus_OK

Command is ok and execution is good.

@ eNCCreate

Create blob or re-write its contents.

static void x_Finalize(SERV_ITER iter)

Defines process management classes.

Defines classes: CDirEntry, CFile, CDir, CSymLink, CMemoryFile, CFileUtil, CFileLock,...

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

#define NETCACHED_FULL_VERSION

#define NETCACHED_VERSION

static const char * kNCReg_Quorum

static const char * kNCReg_SearchOnRead

static const char * kNCReg_FastOnMain

static const char * kNCReg_VerTTL

static const char * kNCReg_SpecPriority

static const char * kNCReg_ServerSection

static const char * kNCReg_AppSetupValue

static void s_StoreStartupParams(int argc, const char *argv[])

set< unsigned int > TPortsList

static const char * kNCReg_TTLUnit

static void s_Finalize(void)

static const char * kNCReg_LifespanTTL

static const char * kNCReg_ProlongOnRead

static int s_CompareStrings(const string &left, const string &right)

static const char * kNCReg_BlobTTL

static bool s_ReadServerParams(void)

static const char * kNCReg_DefAdminClient

static CNCMsgHandler_Factory s_MsgHandlerFactory

static void s_ReadPerClientConfig(const CNcbiRegistry &reg)

static const char * kNCReg_MaxTTL

static void s_ReadSpecificParams(const IRegistry &reg, const string &section, SNCSpecificParams *params, vector< string > &keys)

static const char * kNCReg_DefSpecPriority

static void s_CollectClientConfigKeys(SSpecParamsSet *cur_set, SSpecParamsSet *prev_set, Uint1 depth, SSpecParamsSet *deflt, vector< string > &keys)

static const char * kNCReg_DisableClient

bool s_ReportPid(const string &pid_file)

static const char * kNCReg_PassPolicy

static CSrvRef< SSpecParamsSet > s_SpecParams

static TPortsList s_Ports

Port where server runs.

static bool s_CachingComplete

static CNCHeartBeat * s_HeartBeat

static string s_AdminClient

Name of client that should be used for administrative commands.

static SSpecParamsSet * s_FindNextParamsSet(const SSpecParamsSet *cur_set, const string &key, unsigned int &best_index)

vector< string > TSpecKeysList

static string s_CmdLineArgs

static const char * kNCReg_AppSetupPrefix

static TSpecKeysList s_SpecPriority

static void s_CheckDefClientConfig(SSpecParamsSet *cur_set, SSpecParamsSet *prev_set, Uint1 depth, SSpecParamsSet *deflt)

static const char * kNCReg_CtrlPort

int main(int argc, const char *argv[])

static void s_PutNewParams(SSpecParamsSet *params_set, unsigned int best_index, const SSpecParamsEntry &entry)

static string s_HostLocation

static bool s_Initialize(bool do_reinit)

static bool s_InitiallySynced

static const char * kNCReg_Ports

static const char * kNCReg_AdminClient

@ eNCBlobPassAny

Both blobs with password and without are accepted.

@ eNCOnlyWithoutPass

Only blobs without password are accepted.

@ eNCOnlyWithPass

Only blobs with password are accepted.

std::istream & in(std::istream &in_, double &x_)

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

static CNamedPipeClient * client

#define INFO(msg)

Macro to be used for printing informational messages.

#define SRV_LOG(sev, msg)

Macro to be used for printing log messages.

T AtomicAdd(T volatile &var, T add_value)

Meaningful information encoded in the NetCache key.

map< string, string > keys

ENCBlobPassPolicy pass_policy

map< string, string > source

virtual ~SNCSpecificParams(void)

SSpecParamsEntry(const string &key, CObject *value)

vector< SSpecParamsEntry > entries

virtual ~SSpecParamsSet(void)

Uint2 TSrvThreadNum

Type for thread number in TaskServer.

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