(
const string& attr_string,
const char*
const* attr_names,
55 string* attr_values,
size_tattr_count);
60 const string& operator()(
const string& param)
const;
82 boolReceiveNotification(
string* server_host =
NULL);
84 boolWaitForNotification(
const CDeadline& deadline,
85 string* server_host =
NULL);
87 unsigned short GetPort()
const{
returnm_Receiver.port; }
89 const string&
GetMessage()
const{
returnm_Receiver.message; }
91 voidPrintPortNumber();
100 boolCheckJobStatusNotification(
const string& job_id,
102 int* last_event_index =
NULL);
110 using TJobInfo= tuple<CNetScheduleAPI::EJobStatus, TLastEventIndex, TProgressMessage>;
113 const string& job_id,
119 const string& job_id,
122 int* last_event_index);
138 const string& job_key,
143 int*new_event_index =
NULL);
147 static stringMkBaseGETCmd(
149 const string& affinity_list);
150 voidCmdAppendTimeoutGroupAndClientInfo(
string&
cmd,
151 const CDeadline* deadline,
const string& job_group);
154 const string&
cmd);
174 voidAddToClientNode(
const string&
data);
175 voidUpdateAuthString();
176 voidUseOldStyleAuth();
184 voidReSetClientNode(
const string&);
185 voidReSetClientSession(
const string&);
188 static TInstanceCreateWnCompat(
const string&,
const string&);
191 static TInstanceCreateNoCfgLoad(
const string&,
const string&,
const string&);
211 const string& affinity_token =
kEmptyStr,
222 const string& qname,
223 const string& qclass,
224 const string& description =
kEmptyStr);
230 voidDeleteQueue(
const string& qname);
245 voidSwitchToDrainMode(
ESwitchon_off);
249 voidShutdownServer(EShutdownLevel level = eNormalShutdown);
255 voidCancelAllJobs(
const string& job_statuses =
kEmptyStr);
260 voidReloadServerConfig();
275 voidGetWorkerNodes(list<SWorkerNodeInfo>& worker_nodes);
286 voidPrintServerStatistics(
CNcbiOstream& output_stream,
287EStatisticsOptions opt = eStatisticsBrief);
293 const string& start_after_job =
kEmptyStr,
294 size_tjob_count = 0,
295 const string& job_statuses =
kEmptyStr,
298 const string& start_after_job,
305 voidGetQueueInfo(
CNetServerserver,
const string& queue_name,
308 voidGetQueueInfo(
const string& queue_name,
TQueueInfo& queue_info);
313 voidPrintQueueInfo(
const string& queue_name,
CNcbiOstream& output_stream);
Pool of recycled CCompoundID objects.
Client API for NCBI NetSchedule server.
map< string, unsigned > TStatusMap
Status map, shows number of jobs in each status.
NCBI_NET_COMPONENT(NetScheduleAdmin)
EShutdownLevel
Shutdown level.
@ eNormalShutdown
Normal shutdown was requested.
@ eDie
A serious error occurred, the server shuts down.
@ eShutdownImmediate
Urgent shutdown was requested.
list< SServerQueueList > TQueueList
map< string, string > TQueueInfo
unsigned short GetPort() const
tuple< CNetScheduleAPI::EJobStatus, TLastEventIndex, TProgressMessage > TJobInfo
SNetScheduleNotificationReceiver m_Receiver
const string & GetMessage() const
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]
static const char * str(char *buf, int n)
EJobStatus
Job status codes.
EJobAffinityPreference
Affinity matching modes.
CNetScheduleAPI & operator=(SNetScheduleAPIImpl *impl)
@ eDeleted
The job has been wiped out of the database.
@ eDone
Job is ready (computed successfully)
@ eConfirmed
Final state - read confirmed.
@ eReading
Job has its output been reading.
@ eCanceled
Explicitly canceled.
@ eRunning
Running on a worker node.
@ ePending
Waiting for execution.
@ eReadFailed
Final state - read failed.
@ eFailed
Failed to run (execution timeout)
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
IO_PREFIX::ostream CNcbiOstream
Portable alias for ostream.
enum ENcbiSwitch ESwitch
Aux.
#define NCBI_XCONNECT_EXPORT
unsigned int
A callback function used to compare two keys in a database.
NCBI_XCONNECT_EXPORT int g_ParseNSOutput(const string &attr_string, const char *const *attr_names, string *attr_values, size_t attr_count)
string g_GetNetScheduleStatCommand(ENetScheduleStatTopic topic)
string g_UnquoteIfQuoted(const CTempString &str)
CJsonNode g_ServerInfoToJson(CNetServerInfo server_info, bool server_version_key)
@ eNetScheduleStatClients
@ eNetScheduleStatNotifications
@ eNetScheduleStatJobGroups
@ eNetScheduleStatAffinities
@ eNumberOfNetStheduleStatTopics
bool g_FixMisplacedPID(CJsonNode &stat_info, CTempString &executable_path, const char *pid_key)
const unsigned int kNetScheduleMaxDBDataSize
CJsonNode g_GetWorkerNodeInfo(CNetScheduleAPI api)
CJsonNode g_GenericStatToJson(CNetServer server, ENetScheduleStatTopic topic, bool verbose)
CJsonNode g_WorkerNodeInfoToJson(CNetServer worker_node)
void NCBI_EntryPoint_xnetscheduleapi(CPluginManager< SNetScheduleAPIImpl >::TDriverInfoList &info_list, CPluginManager< SNetScheduleAPIImpl >::EEntryPointRequest method)
const unsigned int kNetScheduleMaxDBErrSize
const char *const kNetScheduleAPIDriverName
NCBI_DECLARE_INTERFACE_VERSION(SNetScheduleAPIImpl, "xnetschedule_api", 1, 0, 0)
CNetScheduleAPIExt(TInstance api)
CNetScheduleAPIExt & operator=(TInstance api)
SServerQueueList(SNetServerImpl *server_impl)
bool operator()(string *server_host)
SNetScheduleNotificationReceiver()
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