:
" clean-up during force exit"));
83 context.GetCleanupEventSource()->AddListener(
91 context.GetCleanupEventSource()->AddListener(
109dvec.reserve(
count);
112 for(
int i= 0;
i<
count; ++
i) {
114 ERR_POST(
"Input stream error. Index : "<<
i);
117 throwruntime_error(
"Worker node input stream error");
120 if(
count% 1000 == 0)
121 switch(
context.GetShutdownLevel()) {
146 switch(
context.GetShutdownLevel()) {
164 sort(dvec.begin(), dvec.end());
170 if(output_type ==
"html")
171os <<
"<html><head><title>" 172 "Sample Grid Worker Result Page" 173 "</title></head><body>" 174 "<p>Sample Grid Worker Result</p>";
177os << dvec.size() <<
' ';
179 for(
int i= 0;
i<
count; ++
i) {
181 ERR_POST(
"Output stream error. Index : "<<
i);
182 throwruntime_error(
"Worker node output stream error");
184os << dvec[
i] <<
' ';
186 if(output_type ==
"html")
187os <<
"</body></html>";
219 for(
int i= 0;
i< 10; ++
i) {
221 if(
context.IsShutdownRequested() )
@ eDie
A serious error occurred, the server shuts down.
@ eShutdownImmediate
Urgent shutdown was requested.
virtual ~CSampleIdleTask()
virtual void Run(CWorkerNodeIdleTaskContext &context)
Do the Idle task here.
CSampleIdleTask(const IWorkerNodeInitContext &context)
CSampleJobCleanupListener(const char *cleanup_type)
virtual void HandleEvent(EWorkerNodeCleanupEvent cleanup_event)
const char * m_CleanupType
int Do(CWorkerNodeJobContext &context)
Execute the job.
CSampleJob(const IWorkerNodeInitContext &context)
Worker Node Idle Task Context.
Worker Node Idle Task Interface.
Worker Node Job interface.
NetSchedule worker node application.
NCBI_WORKERNODE_MAIN(CSampleJob, 1.0.1)
#define ERR_POST(message)
Error posting with file, line number information but without error codes.
void Info(CExceptionArgs_Base &args)
EWorkerNodeCleanupEvent
Event notifying of a safe clean-up point.
@ eRegularCleanup
For jobs â run from the same thread after Do() is done; for the whole WN â run from a separate (clean...
virtual int GetInt(const string §ion, const string &name, int default_value, TFlags flags=0, EErrAction err_action=eThrow) const
Get integer value of specified parameter name.
virtual string GetString(const string §ion, const string &name, const string &default_value, TFlags flags=0) const
Get the parameter string value.
@ eReturn
Return default value.
IO_PREFIX::ostream CNcbiOstream
Portable alias for ostream.
IO_PREFIX::istream CNcbiIstream
Portable alias for istream.
static string IntToString(int value, TNumToStringFlags flags=0, int base=10)
Convert int to string.
where both of them are integers Note
constexpr auto sort(_Init &&init)
void SleepSec(unsigned long sec, EInterruptOnSignal onsignal=eRestartOnSignal)
Sleep.
Defines the CNcbiApplication and CAppException classes for creating NCBI applications.
Defines command line argument related classes.
static CS_CONTEXT * context
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