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

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

NCBI C++ ToolKit: src/app/netschedule/ns_server.cpp Source File

: m_BackgroundHost(this),

m_RefuseSubmits(

),

m_NodeID(

),

m_SessionID(

+ x_GenerateGUID()),

m_StartIDs(dbpath, diskless),

m_AnybodyCanReconfigure(

),

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

(accepted_hosts.

() > 0)

changes.

(

, accepted_hosts);

(admin_diff.

() > 0)

changes.

(

, admin_diff);

state_transition_perf_log_queues_diff =

(state_transition_perf_log_queues_diff.

() > 0)

changes.

(

,

state_transition_perf_log_queues_diff);

state_transition_perf_log_classes_diff =

(state_transition_perf_log_classes_diff.

() > 0)

changes.

(

,

state_transition_perf_log_classes_diff);

changes.

(

, values);

changes.

(

, values);

changes.

(

, values);

what_changed.

(

, changes);

section =

;

(list<string>::const_iterator k =

.begin();

service_name = *k;

qname = reg.

(

, service_name);

new_services[service_name] = qname;

k != new_services.

(); ++k) {

(found->second != k->second) {

changed_items.

(k->first, vals);

(found = new_services.

(); found != new_services.

(); ++found)

(found == new_services.

())

diff.

(

, new_items);

(deleted_items.

() > 0)

diff.

(

, deleted_items);

(changed_items.

() > 0)

diff.

(

, changed_items);

& qname,

& qclass,

& description)

=

;

+= k->first +

+ k->second +

;

(vector<string>::const_iterator

(vector<string>::const_iterator

& class_name)

(vector<string>::const_iterator

(!class_name.empty()) {

(vector<string>::const_iterator

& message)

(node_id_file.

()) {

->SetRequestID();

extra.

(

,

)

.

(

,

)

.

(

,

)

->SetRequestStatus(200);

current_time = time(0);

to_string((pid << 32) | current_time);

vector<string> old = to;

(to.begin(), to.end());

(vector<string>::const_iterator k = old.begin();

(vector<string>::const_iterator k = to.begin();

Class for support low level input/output for files.

void AppendBoolean(bool value)

For an array node, add a boolean node at the end of the array.

size_t GetSize() const

For a container node (that is, either an array or an object), return the number of elements in the co...

static CJsonNode NewArrayNode()

Create a new JSON array node.

void AppendInteger(Int8 value)

For an array node, add a integer node at the end of the array.

void AppendString(const string &value)

For an array node, add a string node at the end of the array.

void SetByKey(const string &key, CJsonNode::TInstance value)

For a JSON object node, insert a new element or update an existing element.

static CJsonNode NewObjectNode()

Create a new JSON object node.

void Append(CJsonNode::TInstance value)

For an array node, add a new element at the end of the array.

string GetURLEncoded(void) const

string Serialize(void) const

enum EAlertAckResult Acknowledge(const string &alert_id, const string &user)

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

bool IsAllowed(unsigned int ha) const

CJsonNode SetHosts(const string &host_names)

NetScheduler threaded server.

unsigned int m_MaxClientData

string ResolveService(const string &service) const

string GetQueueNames(const string &sep) const

CFastMutex m_ServicesLock

unsigned int m_ReserveDumpSpace

void GetServices(map< string, string > &services) const

map< string, string > m_Services

string GetAdminClientNames(void) const

CJsonNode x_SetFromList(const string &from, vector< string > &to, CRWLock &lock)

unsigned int m_JobCountersInterval

static CNetScheduleServer * GetInstance(void)

string SerializeAlerts(void) const

unsigned int m_ScanBatchSize

string GetStateTransitionPerfLogClasses(void) const

bool AdminHostValid(unsigned host) const

unsigned int m_StatInterval

static CNetScheduleServer * sm_netschedule_server

void RegisterAlert(EAlertType alert_type, const string &message)

bool m_LogCleaningThreadFlag

SErrorEmulatorParameter debug_write_delay

SNSRegistryParameters m_ScopeRegistrySettings

string GetStateTransitionPerfLogQueues(void) const

vector< string > m_AdminClientNames

unsigned int m_DeleteBatchSize

vector< string > GetRefuseSubmitQueues(void) const

string m_DiskConfigFileChecksum

enum EAlertAckResult AcknowledgeAlert(const string &id, const string &user)

string PrintTransitionCounters(void)

CNetScheduleServer(const string &dbpath, bool diskless)

NetScheduler threaded server implementation.

void CreateDynamicQueue(const CNSClientId &client, const string &qname, const string &qclass, const string &description)

SNSRegistryParameters m_AffRegistrySettings

bool m_LogBatchEachJobFlag

unsigned int m_InactivityTimeout

CJsonNode SetNSParameters(const SNS_Parameters &new_params, bool limited)

CNetScheduleAccessList m_AdminHosts

string GetAlerts(void) const

string GetQueueClassesInfo(void) const

void SetShutdownFlag(int signum=0, bool db_was_drained=false)

SErrorEmulatorParameter debug_fd_count

string GetQueueInfo(void) const

void SetQueueDB(CQueueDataBase *qdb)

virtual bool ShutdownRequested(void)

Runs synchronously between iterations.

CQueueDataBase * m_QueueDB

SQueueParameters QueueInfo(const string &qname) const

bool m_LogStatisticsThreadFlag

void SetDiskConfigFileChecksum(const string &checksum)

string GetServiceToQueueSectionConfig(void) const

void AddDefaultListener(IServer_ConnectionFactory *factory)

unsigned CountActiveJobs() const

SErrorEmulatorParameter debug_mem_count

virtual void Exit()

Cleanup the server.

map< string, int > GetPauseQueues(void) const

CRWLock m_STPerfLogQCLock

string x_GenerateGUID(void) const

unsigned int Configure(const IRegistry &reg, CJsonNode &diff)

virtual ~CNetScheduleServer()

bool IsAdminClientName(const string &name) const

CAtomicCounter m_CurrentSubmitsCounter

bool ShouldPerfLogTransitions(const string &queue_name, const string &class_name) const

SErrorEmulatorParameter debug_reply_with_garbage

SNSRegistryParameters m_GroupRegistrySettings

void DeleteDynamicQueue(const CNSClientId &client, const string &qname)

bool m_LogExecutionWatcherThreadFlag

string GetLinkedSectionConfig(void) const

void InitNodeID(const string &db_path)

string m_RAMConfigFileChecksum

string GetDataPath(void) const

CJsonNode ReadServicesConfig(const CNcbiRegistry &reg)

string PrintJobsStat(const CNSClientId &client)

SErrorEmulatorParameter debug_conn_drop_before_write

SErrorEmulatorParameter debug_conn_drop_after_write

void SetRAMConfigFileChecksum(const string &checksum)

const bool & IsLog() const

unsigned int m_MarkdelBatchSize

bool m_LogNotificationThreadFlag

string GetQueueConfig(void) const

string GetQueueClassesConfig(void) const

CRWLock m_AdminClientsLock

vector< string > m_StateTransitionPerfLogClasses

CRef< CQueue > OpenQueue(const string &name)

vector< string > m_StateTransitionPerfLogQueues

string PrintJobsStat(const CNSClientId &client)

SQueueParameters QueueInfo(const string &qname) const

string GetQueueConfig(void) const

time_t Configure(const IRegistry &reg, CJsonNode &diff)

void CreateDynamicQueue(const CNSClientId &client, const string &qname, const string &qclass, const string &description="")

string GetDataPath(void) const

string GetQueueInfo(void) const

void DeleteDynamicQueue(const CNSClientId &client, const string &qname)

map< string, int > GetPauseQueues(void) const

string GetQueueClassesConfig(void) const

bool QueueExists(const string &qname) const

vector< string > GetRefuseSubmitQueues(void) const

string GetQueueNames(const string &sep) const

string PrintTransitionCounters(void)

string GetLinkedSectionConfig(void) const

unsigned int CountActiveJobs(void) const

CRef< CQueue > OpenQueue(const string &name)

string GetQueueClassesInfo(void) const

IServer_ConnectionFactory::

container_type::const_iterator const_iterator

const_iterator begin() const

const_iterator end() const

static SQLCHAR output[256]

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

void PrintRequestStop(void)

Print request stop message (for request-driven applications)

CDiagContext_Extra & Print(const string &name, const string &value)

The method does not print the argument, but adds it to the string.

CDiagContext & GetDiagContext(void)

Get diag context instance.

static void SetRequestContext(CRequestContext *ctx)

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

void PrintRequestStart(const string &message)

Print request start message (for request-driven applications)

void Flush(void)

Print the message and reset object.

static string MakePath(const string &dir=kEmptyStr, const string &base=kEmptyStr, const string &ext=kEmptyStr)

Assemble a path from basic components.

static string AddTrailingPathSeparator(const string &path)

Add trailing path separator, if needed.

const string & GetPath(void) const

Get entry path.

virtual bool Exists(void) const

Check existence of file.

@ eRead

File can be read.

@ eReadWrite

File can be read and written.

@ eOpen

Open an existing file, or create a new one.

@ eCreate

Create a new file, or truncate an existing one.

int64_t Int8

8-byte (64-bit) signed integer

static TPid GetPid(void)

Get process identifier (pid) for the current process.

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

Get the parameter value.

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

Enumerate parameter names for a specified section.

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

Return 0 or empty address on error.

static string gethostname(ESwitch log=eOff)

Return empty string on error.

static string ntoa(const CNCBI_IPAddr &addr)

BSD-like API.

static int CompareNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive compare of a substring with another string.

static list< string > & Split(const CTempString str, const CTempString delim, list< string > &arr, TSplitFlags flags=0, vector< SIZE_TYPE > *token_pos=NULL)

Split a string using specified delimiters.

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

Truncate whitespace in a string (in-place)

@ fSplit_MergeDelimiters

Merge adjacent delimiters.

@ eTrunc_End

Truncate trailing whitespace only.

void GetParameters(SServer_Parameters *params)

void AddListener(IServer_ConnectionFactory *factory, unsigned short port)

Register a listener.

unsigned short m_Port

TCP port to listen on.

void SetParameters(const SServer_Parameters &new_params)

unsigned int max_connections

Maximum # of open connections.

CTime GetFastLocalTime(void)

Quick and dirty getter of local time.

constexpr auto sort(_Init &&init)

const bool default_log_batch_each_job

const double default_purge_timeout

const unsigned int default_stat_interval

const bool default_log_cleaning_thread

const bool default_log_execution_watcher_thread

const unsigned int default_max_client_data

const bool default_log_notification_thread

const unsigned int default_markdel_batch_size

const bool default_is_log

const unsigned int default_reserve_dump_space

const unsigned int default_del_batch_size

const unsigned int default_job_counters_interval

const bool default_log_statistics_thread

const bool default_use_hostname

const unsigned int default_scan_batch_size

const unsigned int default_network_timeout

const unsigned int kSubmitCounterInitialValue

const string kNodeIDFileName("NODE_ID")

Defines CRequestContext class for NCBI C++ diagnostic API.

static CNamedPipeClient * client

SNSRegistryParameters group_reg

string state_transition_perf_log_classes

unsigned int del_batch_size

SErrorEmulatorParameter debug_mem_count

string state_transition_perf_log_queues

SErrorEmulatorParameter debug_fd_count

unsigned int stat_interval

unsigned int markdel_batch_size

SErrorEmulatorParameter debug_write_delay

bool log_notification_thread

unsigned int reserve_dump_space

SNSRegistryParameters affinity_reg

SErrorEmulatorParameter debug_conn_drop_after_write

SErrorEmulatorParameter debug_conn_drop_before_write

unsigned int scan_batch_size

string admin_client_names

SErrorEmulatorParameter debug_reply_with_garbage

unsigned int job_counters_interval

SNSRegistryParameters scope_reg

unsigned int max_client_data

bool log_statistics_thread

bool log_execution_watcher_thread

static wxAcceleratorEntry entries[3]

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