40 #define NCBI_USE_ERRCODE_X ConnServ_WorkerNode
121 cleanup_thread->Run();
124 cleanup_thread->Join();
SGridWorkerNodeImpl * m_WorkerNode
virtual void * Main()
Derived (user-created) class must provide a real thread function.
IGridWorkerNodeApp_Listener * m_Listener
static CGridGlobals & GetInstance()
CFastMutex m_ListenersLock
virtual void CallEventHandlers()
virtual void RemoveListener(IWorkerNodeCleanupEventListener *listener)
void RemoveListeners(const TListeners &listeners)
virtual void AddListener(IWorkerNodeCleanupEventListener *listener)
virtual void AddListener(IWorkerNodeCleanupEventListener *listener)
virtual void CallEventHandlers()
CWorkerNodeCleanup * m_WorkerNodeCleanup
virtual void RemoveListener(IWorkerNodeCleanupEventListener *listener)
virtual void OnGridWorkerStop()=0
Notify that CGridWorkerNode::Run() has just finished.
iterator_bool insert(const value_type &val)
#define ITERATE(Type, Var, Cont)
ITERATE macro to sequence through container elements.
#define LOG_POST_X(err_subcode, message)
#define ERR_POST_X(err_subcode, message)
Error posting with default error code and given error subcode.
#define NCBI_CATCH_ALL_X(err_subcode, message)
void Info(CExceptionArgs_Base &args)
@ eRegularCleanup
For jobs – run from the same thread after Do() is done; for the whole WN – run from a separate (clean...
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
void Post(unsigned int count=1)
Increment the semaphore by "count".
unique_ptr< IGridWorkerNodeApp_Listener > m_Listener
CRef< CWorkerNodeCleanup > m_CleanupEventSource
unsigned m_ThreadPoolTimeout
int g(Seg_Gsm *spe, Seq_Mtf *psm, Thd_Gsm *tdg)