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

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

NCBI C++ ToolKit: src/connect/services/netschedule_api_admin.cpp Source File

:

);

m_Impl->m_API->m_Service.ExecOnAllServers(

);

die = level ==

;

(die ?

:

level == eShutdownImmediate ?

:

level ==

?

:

);

retry_guard = m_Impl->m_API->m_Service->CreateRetryGuard(retry_mode);

m_Impl->m_API->m_Service.ExecOnAllServers(

);

(

);

m_Impl->m_API->m_Service.ExecOnAllServers(

);

& description)

limits::Check<limits::SQueueName>(qname);

=

+ qname;

(!description.empty()) {

m_Impl->m_API->m_Service.ExecOnAllServers(

);

limits::Check<limits::SQueueName>(qname);

(

+ qname);

m_Impl->m_API->m_Service.ExecOnAllServers(

);

(

.ReadLine(line))

<< line <<

;

(

+ job_key);

m_Impl->m_API->GetServer(job_key).ExecWithRetry(

,

);

(job_statuses.empty()) {

.assign(

);

.assign(

);

.append(job_statuses);

m_Impl->m_API->m_Service.ExecOnAllServers(

);

(

);

m_Impl->m_API->m_Service.PrintCmdOutput(

,

& start_after_job,

& job_statuses,

& job_group)

(

);

(!job_statuses.empty()) {

.append(

);

.append(job_statuses);

(!start_after_job.empty()) {

.append(

);

.append(start_after_job);

.append(

);

(!job_group.empty()) {

limits::Check<limits::SJobGroup>(job_group);

.append(

);

.append(job_group);

m_Impl->m_API->m_Service.PrintCmdOutput(

,

& start_after_job,

& job_group)

job_statuses.clear();

DumpQueue(output_stream, start_after_job, job_count, job_statuses, job_group);

qinf_cmd(

+ queue_name);

queue_info[field->name] = field->value;

GetQueueInfo(m_Impl->m_API->m_Service.Iterate().GetServer(),

queue_name, queue_info);

GetQueueInfo(server, m_Impl->m_API->m_Queue, queue_info);

GetQueueInfo(m_Impl->m_API->m_Queue, queue_info);

print_headers = m_Impl->m_API->m_Service.IsLoadBalanced();

output_stream <<

<< (*it).GetServerAddress() <<

<<

;

GetQueueInfo(*it, queue_name, queue_info);

output_stream << qi->first <<

<< qi->second <<

;

list<SWorkerNodeInfo>& worker_nodes)

(

);

m_Impl->m_API->m_Service.PrintCmdOutput(

,

(opt == eStatisticsBrief ?

:

opt == eStatisticsClients ?

:

);

m_Impl->m_API->m_Service.PrintCmdOutput(

,

(

);

m_Impl->m_API->m_Service.PrintCmdOutput(

,

(

);

(cmd_output.

(output_line))

output_line.length() >

(

))

qlist.back().queues.push_back(output_line.substr(

(

) - 1,

output_line.length() -

(

)));

& affinity_token,

& job_group)

=

;

(!affinity_token.empty()) {

limits::Check<limits::SAffinity>(affinity_token);

.append(

);

.append(affinity_token);

(!job_group.empty()) {

limits::Check<limits::SJobGroup>(job_group);

.append(

);

.append(job_group);

(*it).ExecWithRetry(

,

));

(cmd_output.

(output_line))

status_map[st_str] +=

);

Client API for NCBI NetSchedule server.

void ReloadServerConfig()

void GetQueueInfo(CNetServer server, const string &queue_name, TQueueInfo &queue_info)

void PrintServerStatistics(CNcbiOstream &output_stream, EStatisticsOptions opt=eStatisticsBrief)

void PrintServerVersion(CNcbiOstream &output_stream)

Print version string.

void DeleteQueue(const string &qname)

Delete queue Applicable only to queues, created through CreateQueue method.

void GetQueueList(TQueueList &result)

void SwitchToDrainMode(ESwitch on_off)

Enable server drain mode.

void CreateQueue(const string &qname, const string &qclass, const string &description=kEmptyStr)

Create an instance of the given queue class.

void PrintConf(CNcbiOstream &output_stream)

EShutdownLevel

Shutdown level.

void DumpJob(CNcbiOstream &out, const string &job_key)

void ShutdownServer(EShutdownLevel level=eNormalShutdown)

Shutdown the server daemon.

void StatusSnapshot(TStatusMap &status_map, const string &affinity_token=kEmptyStr, const string &job_group=kEmptyStr)

Returns statuses for a given affinity token.

void CancelAllJobs(const string &job_statuses=kEmptyStr)

Cancel all jobs in the queue (optionally with particular statuses).

void DumpQueue(CNcbiOstream &output_stream, const string &start_after_job=kEmptyStr, size_t job_count=0, const string &job_statuses=kEmptyStr, const string &job_group=kEmptyStr)

void PrintHealth(CNcbiOstream &output_stream)

void GetWorkerNodes(list< SWorkerNodeInfo > &worker_nodes)

void PrintQueueInfo(const string &queue_name, CNcbiOstream &output_stream)

list< SServerQueueList > TQueueList

NetSchedule internal exception.

bool ReadLine(string &output)

@ eMultilineOutput_NetCacheStyle

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

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

main entry point for tests

static SQLCHAR output[256]

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

TErrCode GetErrCode(void) const

Get error code.

#define NCBI_RETHROW(prev_exception, exception_class, err_code, message)

Generic macro to re-throw an exception.

EJobStatus

Job status codes.

static string StatusToString(EJobStatus status)

Printable status type.

@ eJobNotFound

No such job.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

static CTempString TruncateSpaces_Unsafe(const CTempString str, ETrunc where=eTrunc_Both)

Truncate whitespace in a string.

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

Check if a string starts with a specified prefix value.

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

Split a string into two pieces using the specified delimiters.

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.

@ eTrunc_Begin

Truncate leading whitespace only.

const TArgs & GetArgs(void) const

Get the const list of arguments.

enum ENcbiSwitch ESwitch

Aux.

NetSchedule client specs.

static string s_MkQINFCmd(const string &queue_name)

void g_GetWorkerNodes(CNetScheduleAPI api, list< CNetScheduleAdmin::SWorkerNodeInfo > &worker_nodes)

static void s_ParseQueueInfo(const string &server_output, CNetScheduleAdmin::TQueueInfo &queue_info)

void g_AppendClientIPSessionIDHitID(string &cmd)

CNetServer::SExecResult ConnectAndExec(const string &cmd, bool multiline_output, bool retry_on_exception=false)

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