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__handler_8cpp_source.html below:

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

{

,

{

,

((

*)

)->append((

*) ptr,

);

m_ProcessMessage(

),

m_WithinBatchSubmit(

),

m_SingleCmdParser(sm_CommandMap),

m_BatchHeaderParser(sm_BatchHeaderMap),

m_BatchEndParser(sm_BatchEndMap),

m_ClientIdentificationPrinted(

),

m_RollbackAction(

)

(read_count > 0 || write_count > 0)) {

(

<< status <<

<<

(status));

(

);

(

);

(

);

(

);

(

);

+

error_client_message;

(

exception & ex) {

error_client_message =

+

+

(ex.

()));

(

);

error_client_message =

;

setsockopt(fd, IPPROTO_TCP, TCP_QUICKACK, &

,

(

));

required_size)

nanosleep(&delay,

);

msg_size =

.size();

(msg_size >= 1 &&

[msg_size-1] ==

)

required_size = msg_size + 1;

msg_size =

.size();

has_eom =

;

(msg_size >= 1 &&

[msg_size-1] ==

) {

required_size = msg_size + 1;

* msg_buf =

;

msg_buf =

.data();

written_bytes,

+

(write_result) +

+ to_string(written_bytes) +

+ to_string(

(timing)) +

;

(

.size() > 32)

report +=

.substr(0, 32) +

;

peer_addr;

=

;

(

& param : params) {

(param.first ==

) {

diag_extra.

(

, param.second);

diag_extra.

(param.first, param.second);

restore_client =

;

orig_client_id = 0;

restore_client =

;

);

client_was_found =

;

session_was_reset =

;

had_wn_pref_affs =

;

had_reader_pref_affs =

;

session_was_reset, old_session,

had_wn_pref_affs, had_reader_pref_affs);

(client_was_found && session_was_reset) {

wn_val =

;

(!had_wn_pref_affs)

wn_val =

;

reader_val =

;

(!had_reader_pref_affs)

reader_val =

;

.

(

, old_session)

.

(

, wn_val)

.

(

, reader_val);

(restore_client) {

(!size_str.

())

(

<< ex);

(

<< ex);

(

);

(

<< ex);

+

(

);

+

(

<< ex);

+

(

);

+

->SetRequestID();

.Print(

,

)

.Print(

,

)

.

(

, job_id)

.

(

,

.

(

,

SetRequestStatus(ex.ErrCodeToHTTPStatusCode());

<<

reply.reserve(1024);

reply.append(

)

.append(

)

.append(to_string(lifetime.

()));

reply.append(

);

reply.append(

);

reply.append(

)

progress_msg;

client_ip, client_sid,

client_phid, progress_msg,

<<

reply.reserve(1024);

reply.append(

)

.append(

)

.append(to_string(lifetime.

()));

reply.append(

);

reply.append(

);

reply.append(

)

<<

);

list<string> aff_to_add_list;

list<string> aff_to_del_list;

, aff_to_add_list);

, aff_to_del_list);

(list<string>::const_iterator k = aff_to_add_list.begin();

k != aff_to_add_list.end(); ++k) {

(find(aff_to_del_list.begin(), aff_to_del_list.end(), *k) !=

aff_to_del_list.end()) {

+

(list<string>::const_iterator k = msgs.begin();

k != msgs.end(); ++k)

+=

+ *k +

;

list<string> aff_to_set;

, aff_to_set);

);

);

(

vector<string> warnings;

vector<TJobStatus> statuses;

reported =

;

vector<TJobStatus>::iterator k =

warnings.push_back(

);

);

k = statuses.begin();

(k != statuses.end()) {

warnings.push_back(

);

);

(warnings.empty())

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

k != warnings.end(); ++k) {

+=

+ *k +

;

<<

<<

reply.reserve(2048);

pause_status_msg;

pause_status_msg =

;

pause_status_msg =

;

progress_msg_part;

progress_msg_part.append(

)

reply.append(

)

.append(

)

.append(

)

.append(

)

.append(

)

.append(

)

.append(to_string(lifetime.

()))

.append(

)

.append(

)

.append(

)

.append(

)

.append(pause_status_msg)

.append(progress_msg_part)

reply.append(

)

.append(to_string((

) job.

()))

pause_status_str;

pause_status_str =

;

pause_status_str =

;

.

(

,

+ pause_status_str);

list<string> aff_list;

list<string> group_list;

, group_list);

added_pref_aff;

added_pref_aff) ==

) {

(!added_pref_aff.empty()) {

.

(

, added_pref_aff);

.

(

, added_pref_aff);

(

<<

);

<<

);

<<

);

<<

+

<<

);

(

<<

);

<<

);

pause_status_str;

pause_status_str =

;

pause_status_str =

;

.

(

,

+ pause_status_str);

list<string> aff_list;

added_pref_aff;

added_pref_aff) ==

) {

(added_pref_aff.empty() ==

) {

.

(

, added_pref_aff);

.

(

, added_pref_aff);

<<

(

+

(

+

(warning.empty())

warning, return_option);

(warning.empty())

(

+

auth_token_ok =

;

(!auth_token_ok) {

(

+

(

+

<<

<<

last_event_index = 0;

progress_msg_part;

progress_msg_part =

+

+

to_string(last_event_index) +

(!what.empty() && what !=

&& what !=

&&

what !=

&& what !=

&& what !=

&&

what !=

&& what !=

&&

what !=

&& what !=

&& what !=

&&

what !=

&& what !=

) {

+ what +

);

(q ==

&& (what ==

|| what ==

||

what ==

|| what ==

||

what ==

|| what ==

)) {

+ what +

);

(what ==

) {

(!

.empty())

(what ==

) {

(!

.empty())

(what ==

) {

k != services.

(); ++k) {

+= k->first +

+ k->second;

(what ==

) {

(what ==

)

+=

;

+=

;

(!what.empty() && what !=

) {

=

+

+=

;

+=

;

(what ==

) {

+ to_string(bv_stat.

) +

+ to_string(bv_stat.

) +

+ to_string(bv_stat.

) +

);

);

vector<string> config_warnings;

admin_decrypt_error(

);

(!config_warnings.empty()) {

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

k != config_warnings.end(); ++k) {

(!

.empty()) {

=

+

;

(

.size() > 1024) {

+=

;

vector<string> config_checksum_warnings;

(config_checksum_warnings.empty()) {

(vector<string>::const_iterator

k = config_checksum_warnings.begin();

k != config_checksum_warnings.end(); ++k)

(what_changed.

() == 0 &&

services_changed.

() == 0) {

(

diff.

(k.GetKey(), k.GetNode());

diff.

(k.GetKey(), k.GetNode());

diff_as_string = diff.

();

(

+

);

(

reported =

;

vector<TJobStatus>::iterator k =

);

vector<string> warnings;

statuses.size() == 0)

(job_info.empty()) {

(

+

configuration;

configuration =

(converter);

reply =

mem_used_result =

proc_fd_soft_limit;

proc_fd_hard_limit;

&proc_fd_soft_limit,

&proc_fd_hard_limit);

(err_emul.

>= 0)

proc_fd_used = err_emul.

;

(err_emul.

>= 0)

(process_time_result)

reply +=

+ to_string(user_time) +

+ to_string(system_time) +

+ to_string(real_time);

reply +=

;

(physical_memory > 0)

reply +=

+ to_string(physical_memory);

reply +=

;

(mem_used_result)

reply +=

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

) +

+ to_string(mem_used.

);

reply +=

;

(proc_fd_soft_limit >= 0)

reply +=

+ to_string(proc_fd_soft_limit);

reply +=

;

(proc_fd_hard_limit >= 0)

reply +=

+ to_string(proc_fd_hard_limit);

reply +=

;

(proc_fd_used >= 0)

reply +=

+ to_string(proc_fd_used);

reply +=

;

(proc_thread_count >= 1)

reply +=

+ to_string(proc_thread_count);

reply +=

;

(!alerts.empty())

reply +=

+ alerts;

args_size = arguments.

();

cmdline_args;

(

index = 0; index < args_size; ++index) {

cmdline_args +=

;

cmdline_args += arguments[index];

(

(qname.empty()) {

linked_sections_part;

vector<string> warnings;

jobs_per_state, warnings);

jobs_part.append(1,

)

.append(to_string(jobs_per_state[index]));

total += jobs_per_state[index];

jobs_part.append(

)

.append(to_string(total));

k = linked_sections.

(); k != linked_sections.end(); ++k) {

prefix((k->first).c_str() + strlen(

));

j != k->second.end(); ++j) {

linked_sections_part.append(1,

)

qname_part.append(

)

params.

+

+

client_was_found =

;

session_was_reset =

;

had_wn_pref_affs =

;

had_reader_pref_affs =

;

session_was_reset, old_session,

had_reader_pref_affs);

(client_was_found && session_was_reset) {

wn_val =

;

(!had_wn_pref_affs)

wn_val =

;

reader_val =

;

(!had_reader_pref_affs)

reader_val =

;

.

(

, old_session)

.

(

, wn_val)

.

(

, reader_val);

(used_slots >= max_slots) {

(

);

(

+

max_input_size;

max_output_size;

(

+

to_string(max_input_size) +

+

+

to_string(max_output_size));

k = linked_sections.

(); k != linked_sections.end(); ++k) {

prefix((k->first).c_str() + strlen(

));

j != k->second.end(); ++j) {

+=

+ prefix +

+

(

+ to_string(max_input_size) +

+ to_string(max_output_size) +

+

configuration;

configuration +=

+ it->first +

+ it->second +

;

no_more_jobs =

;

added_pref_aff;

list<string> aff_list;

list<string> group_list;

added_pref_aff) ==

) {

job_id = job.

();

(!added_pref_aff.empty()) {

.

(

, added_pref_aff);

.

(

, added_pref_aff);

.

(

, no_more_jobs);

no_op =

;

(

+

<<

);

(

+

<<

(data_size > limit) {

<<

(

+ to_string(limit) +

+ to_string(data_size) +

(

+ to_string(current_data_version) +

client_found =

;

had_wn_pref_affs =

;

had_reader_pref_affs =

;

old_session, had_wn_pref_affs, had_reader_pref_affs);

wn_val =

;

(!had_wn_pref_affs)

wn_val =

;

reader_val =

;

(!had_reader_pref_affs)

reader_val =

;

.

(

, old_session)

.

(

, wn_val)

.

(

, reader_val);

+

(

reply =

;

reply +=

;

reply +=

;

reply +=

;

+

+ message);

);

);

);

);

);

);

);

(

<<

);

);

);

);

);

);

);

(!is_worker_node_command) {

(it->first ==

)

(it->first ==

)

.Print(

,

)

.Print(

,

.command->cmd)

(

& param :

.params) {

(param.first ==

)

(param.first ==

)

(param.first ==

)

(param.first ==

)

ctxt_extra.

(

, param.second);

ctxt_extra.

(param.first, param.second);

ctxt_extra.

();

.Print(

,

)

.Print(

,

)

(!job.

()) {

submitter_notif_info;

(host ==

) {

(host ==

) {

);

submitter_notif_info.append(

)

.append(

)

reply.reserve(1024);

reply.append(

)

.append(

)

.append(

)

.append(

)

.append(

)

.append(

)

.append(to_string(job.

()))

.append(

)

.append(submitter_notif_info)

+ to_string(job.

()) +

& client_sid,

& phid)

.Print(

,

)

&

,

& suffix)

(need_request_start) {

(

<<

+ suffix);

(

<<

+ suffix);

client_error =

;

client_error +=

+ suffix;

+ suffix;

& what,

vector<string> warnings;

(what ==

) {

(what ==

) {

(what ==

) {

(what ==

) {

(what ==

) {

(what ==

) {

(what ==

) {

warnings.push_back(

);

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

k != warnings.end(); ++k) {

+=

+ *k +

;

+

+

+

+

+

+

+

+

+

+

+

+

+

+

+

+

+

+

& section_name,

(values.

())

ret =

+ section_name +

;

k != values.

(); ++k)

ret += k->first +

+ k->second +

;

vector<string> & warnings)

vector<TJobStatus> no_duplicates;

(vector<TJobStatus>::const_iterator k = src.begin();

k != src.end(); ++k) {

(find(no_duplicates.begin(), no_duplicates.end(), *k) !=

no_duplicates.end()) {

warnings.push_back(

+

);

);

no_duplicates.push_back(*k);

no_duplicates;

message.resize(message.size() - 1);

(!message.empty())

TJobStatus GetStatusBeforeReading(void) const

const string & GetClientSID() const

void SetNCBIPHID(const string &ncbi_phid)

void SetSubmNotifTimeout(const CNSPreciseTime &t)

unsigned GetSubmAddr() const

void SetClientIP(const string &client_ip)

unsigned short GetSubmNotifPort() const

const string & GetInput() const

const string & GetOutput() const

TJobStatus GetStatus() const

string GetAuthToken() const

void SetMask(unsigned mask)

void SetInput(const string &input)

string GetErrorMsg() const

const string & GetClientIP() const

unsigned GetAffinityId() const

const string & GetNCBIPHID() const

const string & GetProgressMsg() const

void SetClientSID(const string &client_sid)

void SetSubmNotifPort(unsigned short port)

Iterator for JSON arrays and objects.

size_t GetSize() const

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

string Repr(TReprFlags flags=0) const

Return a string representation of this node.

SJsonIteratorImpl * Iterate(EIterationMode mode=eNatural) const

For a container node (that is, either an array or an object), begin iteration over its elements.

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 SetPassedChecks(TNSCommandChecks check)

void SetScope(const string &scope)

void ResetPassedCheck(void)

const string & GetClientName(void) const

unsigned int GetID(void) const

bool IsComplete(void) const

const string & GetProgramName(void) const

const string & GetSession(void) const

void SetID(unsigned int id)

const string & GetNode(void) const

void CheckAccess(TNSCommandChecks cmd_reqs, CNetScheduleServer *server, const string &cmd)

TNSCommandChecks GetPassedChecks(void) const

void Update(unsigned int peer_addr, const TNSProtoParams &params)

unsigned int GetAddress(void) const

static CNSPreciseTime Current(void)

virtual const char * GetErrCodeString(void) const override

Get error code interpreted as text.

virtual void Rollback(CQueue *queue)=0

static CNcbiApplication * Instance(void)

Singleton method.

static void Reload(void)

Re-read key file locations and domain paths, reload encryption keys.

CNcbiOstrstreamToString class helps convert CNcbiOstrstream to a string Sample usage:

string GetAsFromConfig(void) const

map< string, string > GetOrigDiagSection(void) const

map< string, string > GetOrigLogSection(void) const

NetSchedule internal exception.

void x_PrintGetJobResponse(const CQueue *q, const CJob &job, bool add_security_token)

void x_ProcessQueueInfo(CQueue *)

void x_ProcessCancelWaitGet(CQueue *)

void x_ProcessGetParam(CQueue *)

virtual void OnOpen(void)

Runs in response to an external event [asynchronous].

CNetScheduleHandler(CNetScheduleServer *server)

void x_ProcessFastStatusW(CQueue *)

void x_ProcessCancelWaitRead(CQueue *)

void x_ProcessReloadConfig(CQueue *)

void x_ProcessReadRollback(CQueue *)

CRef< CQueue > GetQueue(void)

void x_ProcessGetMessage(CQueue *)

@ eStatus_OK

Command is ok and execution is good.

@ eStatus_SubmitRefused

In refuse submits mode and received SUBMIT.

@ eStatus_SocketIOError

Error writing to socket.

@ eStatus_NotImplemented

Command is not implemented.

@ eStatus_HTTPProbe

Routine test from systems.

@ eStatus_Inactive

Connection was closed due to inactivity timeout.

@ eStatus_BadAuth

Bad authorization token.

@ eStatus_ServerError

Internal server error.

@ eStatus_NotFound

Job is not found.

@ eStatus_ShuttingDown

Server is shutting down.

@ eStatus_BadRequest

Command is incorrect.

@ eStatus_InvalidJobStatus

Invalid job status.

void x_OnCmdParserError(bool need_request_start, const string &msg, const string &suffix)

virtual void OnMessage(BUF buffer)

void x_ProcessPutFailure(CQueue *)

void x_ProcessDropQueue(CQueue *)

string x_GetConnRef(void) const

void x_HandleSocketErrorOnResponse(const string &msg, EIO_Status write_result, size_t written_bytes, const CNSPreciseTime &timing)

void x_ProcessQuitSession(CQueue *)

void x_ProcessMsgAuth(BUF buffer)

bool x_NeedToGeneratePHIDAndSID(FProcessor processor) const

void x_CheckAuthorizationToken(void)

void x_ProcessChangeAffinity(CQueue *)

TProtoParser m_BatchEndParser

void x_ProcessCancel(CQueue *)

void x_ProcessSetClientData(CQueue *)

void x_ProcessDump(CQueue *)

void x_ProcessReading(CQueue *)

void x_ProcessQList(CQueue *)

EIO_Status x_PrepareWriteBuffer(const string &msg, size_t msg_size, size_t required_size)

void x_FinalizeReadCommand(const string &command, TJobStatus status, const CJob &job)

CNSRollbackInterface * m_RollbackAction

bool x_CanBeWithoutQueue(FProcessor processor) const

static void x_MakeSureSingleEOR(string &message)

void x_ProcessMsgBatchSubmit(BUF buffer)

void x_ProcessRefuseSubmits(CQueue *)

TProtoParser m_BatchHeaderParser

static SCommandMap sm_BatchHeaderMap[]

void x_ProcessMsgBatchHeader(BUF buffer)

CStopWatch m_BatchStopWatch

void x_PrintCmdRequestStop(void)

string x_GetServerSection(void) const

void x_ProcessSubmitBatch(CQueue *)

void x_ProcessReadFailed(CQueue *)

void x_SetConnRequestStatus(unsigned int status)

void x_ProcessCancelQueue(CQueue *)

void x_CmdObsolete(CQueue *)

void x_ProcessGetConfiguration(CQueue *)

bool x_NeedCmdLogging(void) const

virtual void OnWrite(void)

The client is ready to receive data.

void x_ProcessJobDelayExpiration(CQueue *)

void x_ProcessGetConf(CQueue *)

CWeakRef< CQueue > m_QueueRef

void x_ClearRollbackAction(void)

void x_ProcessRedo(CQueue *)

unsigned int x_GetPeerAddress(void)

void x_ProcessConfirm(CQueue *)

void x_SetCmdRequestStatus(unsigned int status)

void x_ProcessDeleteDynamicQueue(CQueue *)

EIO_Status x_WriteMessage(const string &msg)

void x_UpdateClientPassedChecks(CQueue *q)

virtual void OnClose(IServer_ConnectionHandler::EClosePeer peer)

The connection has closed (with information on type of closing)

void x_ProcessAckAlert(CQueue *)

TProtoParser m_SingleCmdParser

void x_ProcessPause(CQueue *)

void x_ExecuteRollbackAction(CQueue *q)

void x_ProcessJobExchange(CQueue *)

void x_ProcessClearWorkerNode(CQueue *)

void x_ProcessCreateDynamicQueue(CQueue *)

virtual void OnTimeout(void)

Runs when a client has been idle for too long, prior to closing the connection [synchronous].

void x_CheckReadParameters(void)

string x_GetLogSection(void) const

void x_LogCommandWithJob(const CJob &job) const

void x_CmdNotImplemented(CQueue *)

void x_CreateConnContext(void)

void x_ProcessActiveCount(CQueue *)

void x_ProcessMsgBatchJob(BUF buffer)

string x_GetStoredSectionValues(const string &section_name, const map< string, string > &values) const

void x_SetRequestContext(void)

CRef< CRequestContext > m_CmdContext

void x_ProcessVersion(CQueue *)

void x_ProcessMsgRequest(BUF buffer)

void x_ProcessGetJob(CQueue *)

void x_SetQuickAcknowledge(void)

string x_GetDiagSection(void) const

bool m_ClientIdentificationPrinted

void x_ProcessSetAffinity(CQueue *)

CNSPreciseTime m_BatchSubmTimeout

void(CNetScheduleHandler::* m_ProcessMessage)(BUF buffer)

static SCommandMap sm_BatchEndMap[]

void x_ProcessPut(CQueue *)

CRef< CRequestContext > m_ConnContext

void x_CheckGetParameters(void)

void x_ProcessPutMessage(CQueue *)

void x_StatisticsNew(CQueue *q, const string &what, const CNSPreciseTime &curr)

void x_ProcessResume(CQueue *)

void x_CheckPortAndTimeout(void)

void x_ProcessJobDelayReadExpiration(CQueue *)

vector< TJobStatus > x_RemoveDuplicateStatuses(const vector< TJobStatus > &src, vector< string > &warnings) const

void x_ProcessSetQueue(CQueue *)

void x_ProcessMsgQueue(BUF buffer)

void x_CheckQInf2Parameters(void)

void x_ProcessSetScope(CQueue *)

void x_ProcessReread(CQueue *)

CNetScheduleServer * m_Server

virtual void OnOverflow(EOverflowReason reason)

Runs when there are insufficient resources to queue a connection, prior to closing it.

virtual void OnError(const string &err_message)

Runs when a socket error is detected.

void x_ProcessFastStatusS(CQueue *)

void x_ProcessSubmit(CQueue *)

static SCommandMap sm_CommandMap[]

void x_ProcessReturn(CQueue *)

void x_ProcessBatchSequenceEnd(CQueue *)

void x_CheckNonAnonymousClient(const string &message)

void x_ProcessHealth(CQueue *)

void x_ProcessListenJob(CQueue *)

void x_ProcessShutdown(CQueue *)

bool x_WorkerNodeCommand(void) const

void x_ProcessReschedule(CQueue *)

void x_PrintCmdRequestStart(const SParsedCmd &cmd)

void x_ProcessStatistics(CQueue *)

void x_ProcessBatchStart(CQueue *)

vector< pair< CJob, string > > m_BatchJobs

SNSCommandArguments m_CommandArguments

void x_ProcessStatus(CQueue *)

NetScheduler threaded server.

const CNetScheduleAccessList & GetAdminHosts(void) const

unsigned int GetReserveDumpSpace(void) const

string ResolveService(const string &service) const

string GetSessionID(void) const

string GetQueueNames(const string &sep) const

string GetDebugGarbage(void) const

SErrorEmulatorParameter GetDebugConnDropBeforeWrite(void) const

unsigned GetHostNetAddr() const

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

string GetAdminClientNames(void) const

SErrorEmulatorParameter GetDebugFDCount(void) const

unsigned GetInactivityTimeout(void) const

unsigned GetScanBatchSize(void) const

string SerializeAlerts(void) const

string GetStateTransitionPerfLogClasses(void) const

string GetNodeID(void) const

bool AdminHostValid(unsigned host) const

bool GetRefuseSubmits() const

unsigned int DecrementCurrentSubmitsCounter(void)

void SetAnybodyCanReconfigure(bool val)

SErrorEmulatorParameter GetDebugConnDropAfterWrite(void) const

void RegisterAlert(EAlertType alert_type, const string &message)

const bool & IsLogNotificationThread() const

string GetStateTransitionPerfLogQueues(void) const

void SetDrainShutdown(void)

unsigned int IncrementCurrentSubmitsCounter(void)

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

string PrintTransitionCounters(void)

const bool & IsLogExecutionWatcherThread() const

SNSRegistryParameters GetAffRegistrySettings(void) const

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

const unsigned int & GetJobCountersInterval() const

const unsigned int & GetStatInterval() const

const bool & IsLogBatchEachJob() const

SErrorEmulatorParameter GetDebugWriteDelay(void) const

CJsonNode SetNSParameters(const SNS_Parameters &new_params, bool limited)

unsigned int GetMaxClientData(void) const

string GetAlerts(void) const

string GetQueueClassesInfo(void) const

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

string GetQueueInfo(void) const

virtual bool ShutdownRequested(void)

Runs synchronously between iterations.

const bool & IsLogCleaningThread() const

SQueueParameters QueueInfo(const string &qname) const

unsigned GetMarkdelBatchSize(void) const

void SetDiskConfigFileChecksum(const string &checksum)

unsigned GetDeleteBatchSize(void) const

string GetServiceToQueueSectionConfig(void) const

unsigned CountActiveJobs() const

bool GetUseHostname(void) const

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

SErrorEmulatorParameter GetDebugMemCount(void) const

const CTime & GetStartTime(void) const

bool IsAdminClientName(const string &name) const

bool IsDrainShutdown(void) const

SErrorEmulatorParameter GetDebugReplyWithGarbage(void) const

double GetPurgeTimeout(void) const

void SetRefuseSubmits(bool val)

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

string GetLinkedSectionConfig(void) const

CCompoundIDPool GetCompoundIDPool(void) const

const bool & IsLogStatisticsThread() const

CJsonNode ReadServicesConfig(const CNcbiRegistry &reg)

string PrintJobsStat(const CNSClientId &client)

bool AnybodyCanReconfigure(void) const

void SetRAMConfigFileChecksum(const string &checksum)

const bool & IsLog() const

SNSRegistryParameters GetScopeRegistrySettings(void) const

string GetQueueConfig(void) const

string GetQueueClassesConfig(void) const

CRef< CQueue > OpenQueue(const string &name)

SNSRegistryParameters GetGroupRegistrySettings(void) const

void ParseArguments(CTempString str, const SNSProtoArgument *arg_descr, TNSProtoParams *params)

TParsedCmd ParseCommand(CTempString command)

TPauseStatus GetPauseStatus(void) const

void SetPauseStatus(const CNSClientId &client, TPauseStatus status)

bool IsSubmitAllowed(unsigned host) const

TJobStatus ConfirmReadingJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token)

int SetClientData(const CNSClientId &client, const string &data, int data_version)

unsigned CountStatus(TJobStatus) const

bool IsProgramAllowed(const string &program_name) const

unsigned int CancelAllJobs(const CNSClientId &client, bool logging)

string PrintNotificationsList(bool verbose) const

void SetAffinity(const CNSClientId &client, const list< string > &aff, ECommandGroup cmd_group)

void SetRefuseSubmits(bool val)

void StatusStatistics(TJobStatus status, TNSBitVector::statistics *st) const

string PrintClientsList(bool verbose) const

bool PutProgressMessage(unsigned int job_id, CJob &job, const string &msg)

unsigned int CancelSelectedJobs(const CNSClientId &client, const string &group, const string &aff_token, const vector< TJobStatus > &statuses, bool logging, vector< string > &warnings)

TJobStatus ReadAndTouchJob(unsigned int job_id, CJob &job, CNSPreciseTime *lifetime)

TJobStatus FailReadingJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, const string &err_msg, bool no_retries)

TJobStatus SetJobListener(unsigned int job_id, CJob &job, unsigned int address, unsigned short port, const CNSPreciseTime &timeout, bool need_stolen, bool need_progress_msg, size_t *last_event_index)

void ClearWorkerNode(const CNSClientId &client, bool &client_was_found, string &old_session, bool &had_wn_pref_affs, bool &had_reader_pref_affs)

void RegisterQueueResumeNotification(unsigned int address, unsigned short port, bool new_format)

string GetAffinityTokenByID(unsigned int aff_id) const

bool GetJobForReadingOrWait(const CNSClientId &client, unsigned int port, unsigned int timeout, const list< string > *aff_list, bool reader_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, const list< string > *group_list, bool affinity_may_change, bool group_may_change, CJob *job, bool *no_more_jobs, CNSRollbackInterface *&rollback_action, string &added_pref_aff)

TJobStatus JobDelayExpiration(unsigned int job_id, CJob &job, const CNSPreciseTime &tm)

void SetClientScope(const CNSClientId &client)

string PrintTransitionCounters(void) const

string PrintScopesList(bool verbose) const

void CancelWaitRead(const CNSClientId &client)

TJobStatus FailJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, const string &err_msg, const string &output, int ret_code, bool no_retries, string warning)

TJobStatus ReturnReadingJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, bool is_ns_rollback, bool blacklist, TJobStatus target_status)

TParameterList GetParameters() const

void MarkClientAsAdmin(const CNSClientId &client)

TJobStatus JobDelayReadExpiration(unsigned int job_id, CJob &job, const CNSPreciseTime &tm)

string MakeJobKey(unsigned int job_id) const

string PrintJobDbStat(const CNSClientId &client, unsigned int job_id, TDumpFields dump_fields)

TJobStatus PutResult(const CNSClientId &client, const CNSPreciseTime &curr, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, int ret_code, const string &output)

bool GetRefuseSubmits(void) const

unsigned int Submit(const CNSClientId &client, CJob &job, const string &aff_token, const string &group, bool logging, CNSRollbackInterface *&rollback_action)

TJobStatus GetStatusAndLifetime(unsigned int job_id, string &client_ip, string &client_sid, string &client_phid, string &progress_msg, CNSPreciseTime *lifetime)

void GetJobsPerState(const CNSClientId &client, const string &group_token, const string &aff_token, size_t *jobs, vector< string > &warnings) const

list< pair< string, string > > TParameterList

TJobStatus ReturnJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, string &warning, TJobReturnOption how)

bool IsReaderAllowed(unsigned host) const

string PrintGroupsList(const CNSClientId &client, bool verbose) const

void GetLinkedSections(map< string, map< string, string > > &linked_sections) const

string PrintAllJobDbStat(const CNSClientId &client, const string &group, const string &aff_token, const vector< TJobStatus > &job_statuses, unsigned int start_after_job_id, unsigned int count, bool order_first, TDumpFields dump_fields, bool logging)

TJobStatus RescheduleJob(const CNSClientId &client, unsigned int job_id, const string &job_key, const string &auth_token, const string &aff_token, const string &group, bool &auth_token_ok, CJob &job)

string PrintAffinitiesList(const CNSClientId &client, bool verbose) const

bool GetJobOrWait(const CNSClientId &client, unsigned short port, unsigned int timeout, const list< string > *aff_list, bool wnode_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, bool new_format, const list< string > *group_list, CJob *new_job, CNSRollbackInterface *&rollback_action, string &added_pref_aff)

size_t GetScopeSlotsUsed(void) const

bool IsWorkerAllowed(unsigned host) const

TJobStatus RedoJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job)

TJobStatus RereadJob(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, bool &no_op)

string PrintJobsStat(const CNSClientId &client, const string &group_token, const string &aff_token, vector< string > &warnings) const

void GetMaxIOSizesAndLinkedSections(unsigned int &max_input_size, unsigned int &max_output_size, map< string, map< string, string > > &linked_sections) const

TJobStatus GetStatusAndLifetimeAndTouch(unsigned int job_id, CJob &job, CNSPreciseTime *lifetime)

void TouchClientsRegistry(CNSClientId &client, bool &client_was_found, bool &session_was_reset, string &old_session, bool &had_wn_pref_affs, bool &had_reader_pref_affs)

void CancelWaitGet(const CNSClientId &client)

list< string > ChangeAffinity(const CNSClientId &client, const list< string > &aff_to_add, const list< string > &aff_to_del, ECommandGroup cmd_group)

TJobStatus Cancel(const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, bool is_ns_rollback=false)

~CRequestContextResetter()

CRequestContextResetter()

static unsigned int GetCpuCount(void)

Return number of active CPUs/cores (never less than 1).

static Uint8 GetTotalPhysicalMemorySize(void)

Return the amount of actual/total physical memory, in bytes.

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

container_type::const_iterator const_iterator

const_iterator begin() const

const_iterator end() const

static SQLCHAR output[256]

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

bool ReloadConfig(CMetaRegistry::TFlags flags=CMetaRegistry::fReloadIfChanged, IRegistry::TFlags reg_flags=IRegistry::fWithNcbirc)

Reload the configuration file.

const string & GetProgramExecutablePath(EFollowLinks follow_links=eIgnoreLinks) const

Get the application's executable path.

const CNcbiRegistry & GetConfig(void) const

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

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

const string & GetConfigPath(void) const

Get the full path to the configuration file (if any) we ended up using.

const CNcbiArguments & GetArguments(void) const

Get the application's cached unprocessed command-line arguments.

size_t BUF_Read(BUF buf, void *data, size_t size)

size_t BUF_PeekAtCB(BUF buf, size_t pos, size_t(*callback)(void *cbdata, const void *buf, size_t size), void *cbdata, size_t size)

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.

void SetBytesWr(Int8 bytes)

int GetRequestStatus(void) const

Request exit status.

string GetStringUID(TUID uid=0) const

Return string representation of UID.

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 SetRequestID(TCount rid)

Set request ID.

void SetSessionID(const string &session)

CDiagContext_Extra Extra(void) const

Create a temporary CDiagContext_Extra object.

void SetClientIP(const string &client)

static CRequestContext & GetRequestContext(void)

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

TCount GetRequestID(void) const

Get request ID (or zero if not set).

static TPID GetPID(void)

Get cached PID (read real PID if not cached yet).

void SetRequestStatus(int status)

void Flush(void)

Print the message and reset object.

void SetBytesRd(Int8 bytes)

#define ERR_POST(message)

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

SIZE_TYPE Size(void) const

Get size (number) of arguments.

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)

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

unsigned ErrCodeToHTTPStatusCode() const

EJobStatus

Job status codes.

virtual const char * GetErrCodeString() const override

Get error code interpreted as text.

static string StatusToString(EJobStatus status)

Printable status type.

@ eDone

Job is ready (computed successfully)

@ eReading

Job has its output been reading.

@ eCanceled

Explicitly canceled.

@ eRunning

Running on a worker node.

@ eJobNotFound

No such job.

@ ePending

Waiting for execution.

@ eFailed

Failed to run (execution timeout)

bool NotNull(void) const THROWS_NONE

Check if pointer is not null – same effect as NotEmpty().

TObjectType * GetPointer(void) THROWS_NONE

Get pointer,.

void Reset(void)

Reset reference object.

void Reset(void)

Reset the containing pointer to null.

bool IsNull(void) const THROWS_NONE

Check if pointer is null – same effect as Empty().

uint64_t Uint8

8-byte (64-bit) unsigned integer

size_t resident_peak

Peak resident set size ("high water mark")

static int GetThreadCount(void)

Get the number of threads in the current process.

size_t total_peak

Peak total memory usage.

size_t resident

Resident/working set size (RSS).

static int GetFileDescriptorsCount(int *soft_limit=NULL, int *hard_limit=NULL)

Get the number of file descriptors consumed by the current process, and optional system wide file des...

size_t total

Total memory usage.

size_t shared

Shared memory usage.

size_t text

Text (code) segment size.

static bool GetMemoryUsage(SMemoryUsage &usage)

Get current process memory usage.

size_t swap

Swap space usage.

size_t lib

Shared library code size.

size_t data

Data segment size.

static bool GetTimes(double *real, double *user, double *sys, EWhat what=eProcess)

Get current process execution times.

size_t stack

Stack size of the initial thread in the process.

bool Write(CNcbiOstream &os, TFlags flags=0) const

Write the registry content to output stream.

EIO_Status Shutdown(EIO_Event how)

Shutdown socket I/O in the specified direction.

virtual EIO_Status GetOSHandle(void *handle_buf, size_t handle_size, EOwnership ownership=eNoOwnership) const

Access to the system-specific socket handle.

static CNCBI_IPAddr GetLoopbackAddress(void)

Loopback address is in network byte order (when "unsigned int")

EIO_Status SetTimeout(EIO_Event event, const STimeout *timeout)

Set timeout for I/O in the specified direction.

void DisableOSSendDelay(bool on_off=true)

static CNCBI_IPAddr GetLocalHostAddress(ESwitch reget=eDefault)

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

TNCBI_BigCount GetCount(EIO_Event direction) const

void GetPeerAddress(unsigned int *host, unsigned short *port, ENH_ByteOrder byte_order) const

Get peer address.

static string ntoa(const CNCBI_IPAddr &addr)

BSD-like API.

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

Write to socket.

@ eSAF_IP

only numeric IP if INET socket, empty otherwise

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

Get a printable version of the specified string.

static string DoubleToString(double value, int precision=-1, TNumToStringFlags flags=0)

Convert double to string.

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 int StringToInt(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to int.

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 bool EndsWith(const CTempString str, const CTempString end, ECase use_case=eCase)

Check if a string ends with a specified suffix value.

static const string BoolToString(bool value)

Convert bool to string.

bool empty(void) const

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

static string URLEncode(const CTempString str, EUrlEncode flag=eUrlEnc_SkipMarkChars)

URL-encode string.

@ fDoubleFixed

DoubleToString*(): Use n.nnnn format for double conversions.

void GetParameters(SServer_Parameters *params)

EClosePeer

Type of connection closing.

EOverflowReason

Error codes for OnOverflow method in IServer_ConnectionHandler.

void CloseConnection(CSocket *sock)

Close connection.

unsigned int max_threads

Maximum simultaneous threads.

unsigned int max_connections

Maximum # of open connections.

CSocket & GetSocket(void)

Get underlying socket.

unsigned int init_threads

Number of initial threads.

@ eClientClose

Connection closed by other peer.

@ eOurClose

Connection closed by ourselves.

double Restart(void)

Return time elapsed since first Start() or last Restart() call (in seconds).

double Elapsed(void) const

Return time elapsed since first Start() or last Restart() call (in seconds).

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

Transform time to string.

@ eStart

Start timer immediately after creating.

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

uint64_t TNCBI_BigCount

Big unsigned integer for file size and position.

@ eIO_Success

everything is fine, no error occurred

@ eIO_ReadWrite

eIO_Read | eIO_Write (also, eCONN_OnFlush)

operation

Bit operations.

const size_t g_ValidJobStatusesSize

const CNetScheduleAPI::EJobStatus g_ValidJobStatuses[]

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

const GenericPointer< typename T::ValueType > T2 value

int strncmp(const char *str1, const char *str2, size_t count)

#define NETSCHEDULED_VERSION

#define NETSCHEDULED_FEATURES

#define NETSCHEDULED_STORAGE_VERSION

#define NETSCHEDULED_PROTOCOL_VERSION

#define NETSCHEDULED_BUILD_DATE

unsigned int TNSCommandChecks

const string k_NoAffinityToken

const string k_NoGroupToken

SNSProtoArgument s_BatchArgs[]

const string kEndOfResponse

const string kOKResponsePrefix

static SNSProtoArgument s_AuthArgs[]

static void s_ReadBufToString(BUF buf, string &str)

const string kOKCompleteResponse

static size_t s_BufReadHelper(void *data, const void *ptr, size_t size)

const string kErrNoJobFoundResponse

static const unsigned int kMaxParserErrMsgLength

const size_t kInitialMessageBufferSize

const size_t kMessageBufferIncrement

void SerializeRefuseSubmitState(CNetScheduleServer *server)

const unsigned int kSubmitCounterInitialValue

void NS_ValidateConfigFile(const IRegistry &reg, vector< string > &warnings, bool throw_port_exception, bool &decrypting_error)

string NS_GetConfigFileChecksum(const string &file_name, vector< string > &warnings)

Defines NCBI C++ secure resources API.

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

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

Process memory usage information, in bytes.

bool IsActive(void) const

string job_statuses_string

vector< TJobStatus > job_statuses

void AssignValues(TNSProtoParams &params, const string &command, bool need_to_generate, CSocket &peer_socket, CCompoundIDPool::TInstance id_pool)

unsigned int start_after_job_id

string queue_from_job_key

const SNSProtoCmdDef< Extra > * command

string Serialize(const string &name, const string &prefix, const string &suffix) const

void Read(const IRegistry &reg)

string GetPrintableParameters(bool include_class, bool url_encoded) const

size_t gap_blocks

Number of GAP blocks.

size_t bit_blocks

Number of bit blocks.

size_t memory_used

memory usage for all blocks and service tables

Statistical information about bitset's memory allocation details.

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