NCBI C++ ToolKit
|
Search Toolkit Book for SGridWorkerNodeImpl
#include "grid_worker_impl.hpp"
(Private to src/connect/services
.)
Classes | |
struct | SJobsInProgress |
Bookkeeping of jobs being executed (to prevent simultaneous runs of the same job) More... | |
Public Types | |
typedef map< IWorkerNodeJobWatcher *, AutoPtr< IWorkerNodeJobWatcher > > | TJobWatchers |
![]() | |
enum | EAllocFillMode { eAllocFillNone = 1 , eAllocFillZero , eAllocFillPattern } |
Control filling of newly allocated memory. More... | |
typedef CObjectCounterLocker | TLockerType |
Default locker type for CRef. More... | |
typedef atomic< Uint8 > | TCounter |
Counter type is CAtomiCounter. More... | |
typedef Uint8 | TCount |
Alias for value type of counter. More... | |
Public Member Functions | |
SGridWorkerNodeImpl (CNcbiApplicationAPI &app, IWorkerNodeJobFactory *job_factory) | |
void | AddJobWatcher (IWorkerNodeJobWatcher &job_watcher, EOwnership owner=eNoOwnership) |
void | Init () |
int | Run (ESwitch daemonize, string procinfo_file_name) |
void | x_WNCoreInit () |
void | x_StartWorkerThreads () |
void | x_StopWorkerThreads () |
void | x_ClearNode () |
int | x_WNCleanUp () |
const string & | GetQueueName () const |
const string & | GetClientName () const |
const string & | GetServiceName () const |
string | GetAppName () const |
bool | EnterExclusiveMode () |
void | LeaveExclusiveMode () |
bool | IsExclusiveMode () const |
bool | WaitForExclusiveJobToFinish () |
int | OfflineRun () |
const IRegistry & | GetConfig () const override |
Get a config file registry. More... | |
const CArgs & | GetArgs () const override |
Get command line arguments. More... | |
const CNcbiEnvironment & | GetEnvironment () const override |
Get environment variables. More... | |
IWorkerNodeCleanupEventSource * | GetCleanupEventSource () const override |
Get interface for registering clean-up event listeners. More... | |
CNetScheduleAPI | GetNetScheduleAPI () const override |
Get the shared NetScheduleAPI object used by the worker node framework. More... | |
CNetCacheAPI | GetNetCacheAPI () const override |
Get the shared NetCacheAPI object used by the worker node framework. More... | |
IWorkerNodeJob * | GetJobProcessor () |
void | x_NotifyJobWatchers (const CWorkerNodeJobContext &job_context, IWorkerNodeJobWatcher::EEvent event) |
bool | x_AreMastersBusy () const |
![]() | |
CObject (void) | |
Constructor. More... | |
CObject (const CObject &src) | |
Copy constructor. More... | |
virtual | ~CObject (void) |
Destructor. More... | |
CObject & | operator= (const CObject &src) THROWS_NONE |
Assignment operator. More... | |
bool | CanBeDeleted (void) const THROWS_NONE |
Check if object can be deleted. More... | |
bool | IsAllocatedInPool (void) const THROWS_NONE |
Check if object is allocated in memory pool (not system heap) More... | |
bool | Referenced (void) const THROWS_NONE |
Check if object is referenced. More... | |
bool | ReferencedOnlyOnce (void) const THROWS_NONE |
Check if object is referenced only once. More... | |
void | AddReference (void) const |
Add reference to object. More... | |
void | RemoveReference (void) const |
Remove reference to object. More... | |
void | ReleaseReference (void) const |
Remove reference without deleting object. More... | |
virtual void | DoNotDeleteThisObject (void) |
Mark this object as not allocated in heap – do not delete this object. More... | |
virtual void | DoDeleteThisObject (void) |
Mark this object as allocated in heap – object can be deleted. More... | |
void * | operator new (size_t size) |
Define new operator for memory allocation. More... | |
void * | operator new[] (size_t size) |
Define new[] operator for 'array' memory allocation. More... | |
void | operator delete (void *ptr) |
Define delete operator for memory deallocation. More... | |
void | operator delete[] (void *ptr) |
Define delete[] operator for memory deallocation. More... | |
void * | operator new (size_t size, void *place) |
Define new operator. More... | |
void | operator delete (void *ptr, void *place) |
Define delete operator. More... | |
void * | operator new (size_t size, CObjectMemoryPool *place) |
Define new operator using memory pool. More... | |
void | operator delete (void *ptr, CObjectMemoryPool *place) |
Define delete operator. More... | |
virtual void | DebugDump (CDebugDumpContext ddc, unsigned int depth) const |
Define method for dumping debug information. More... | |
![]() | |
CDebugDumpable (void) | |
virtual | ~CDebugDumpable (void) |
void | DebugDumpText (ostream &out, const string &bundle, unsigned int depth) const |
void | DebugDumpFormat (CDebugDumpFormatter &ddf, const string &bundle, unsigned int depth) const |
void | DumpToConsole (void) const |
![]() | |
virtual | ~IWorkerNodeInitBaseContext () |
Additional Inherited Members | |
![]() | |
static NCBI_XNCBI_EXPORT void | ThrowNullPointerException (void) |
Define method to throw null pointer exception. More... | |
static NCBI_XNCBI_EXPORT void | ThrowNullPointerException (const type_info &type) |
static EAllocFillMode | GetAllocFillMode (void) |
static void | SetAllocFillMode (EAllocFillMode mode) |
static void | SetAllocFillMode (const string &value) |
Set mode from configuration parameter value. More... | |
![]() | |
static void | EnableDebugDump (bool on) |
![]() | |
static const TCount | eCounterBitsCanBeDeleted = 1 << 0 |
Define possible object states. More... | |
static const TCount | eCounterBitsInPlainHeap = 1 << 1 |
Heap signature was found. More... | |
static const TCount | eCounterBitsPlaceMask |
Mask for 'in heap' state flags. More... | |
static const int | eCounterStep = 1 << 2 |
Skip over the "in heap" bits. More... | |
static const TCount | eCounterValid = TCount(1) << (sizeof(TCount) * 8 - 2) |
Minimal value for valid objects (reference counter is zero) Must be a single bit value. More... | |
static const TCount | eCounterStateMask |
Valid object, and object in heap. More... | |
![]() | |
virtual void | DeleteThis (void) |
Virtual method "deleting" this object. More... | |
Definition at line 183 of file grid_worker_impl.hpp.
typedef map<IWorkerNodeJobWatcher*, AutoPtr<IWorkerNodeJobWatcher> > SGridWorkerNodeImpl::TJobWatchers |
Definition at line 255 of file grid_worker_impl.hpp.
SGridWorkerNodeImpl::SGridWorkerNodeImpl | ( | CNcbiApplicationAPI & | app, |
IWorkerNodeJobFactory * | job_factory | ||
) |
Definition at line 369 of file grid_worker.cpp.
References m_JobProcessorFactory, and NCBI_THROW.
void SGridWorkerNodeImpl::AddJobWatcher | ( | IWorkerNodeJobWatcher & | job_watcher, |
EOwnership | owner = eNoOwnership |
||
) |
Definition at line 937 of file grid_worker.cpp.
References map_checker< Container >::end(), eTakeOwnership, map_checker< Container >::find(), and m_Watchers.
Referenced by Run().
bool SGridWorkerNodeImpl::EnterExclusiveMode | ( | ) |
Definition at line 1032 of file grid_worker.cpp.
References _ASSERT, m_ExclusiveJobSemaphore, m_IsProcessingExclusiveJob, and CSemaphore::TryWait().
Referenced by CMainLoopThread::x_GetNextJob().
|
inline |
Definition at line 218 of file grid_worker_impl.hpp.
References CNcbiApplicationAPI::GetProgramDisplayName(), and m_App.
Referenced by x_StartWorkerThreads().
Get command line arguments.
Implements IWorkerNodeInitBaseContext.
Definition at line 335 of file grid_worker.cpp.
References CNcbiApplicationAPI::GetArgs(), and m_App.
|
overridevirtual |
Get interface for registering clean-up event listeners.
Implements IWorkerNodeInitContext.
Definition at line 345 of file grid_worker.cpp.
References m_CleanupEventSource.
Definition at line 209 of file grid_worker_impl.hpp.
References SNetServiceImpl::GetClientName(), m_NetScheduleAPI, and SNetScheduleAPIImpl::m_Service.
Referenced by CGetLoadProcessor::Authenticate(), CGetStatisticsProcessor::Process(), Run(), and x_AreMastersBusy().
Get a config file registry.
Implements IWorkerNodeInitBaseContext.
Definition at line 328 of file grid_worker.cpp.
References _ASSERT, and m_Registry.
|
overridevirtual |
Get environment variables.
Implements IWorkerNodeInitBaseContext.
Definition at line 340 of file grid_worker.cpp.
References CNcbiApplicationAPI::GetEnvironment(), and m_App.
IWorkerNodeJob * SGridWorkerNodeImpl::GetJobProcessor | ( | ) |
Definition at line 239 of file wn_commit_thread.cpp.
References CObject::AddReference(), ERR_POST_X, CNetScheduleAdmin::eShutdownImmediate, eUnknown, CGridGlobals::GetInstance(), m_JobProcessorFactory, m_JobProcessorMutex, NCBI_THROW, NULL, CGridGlobals::RequestShutdown(), s_tls, and s_TlsCleanup().
Referenced by SWorkerNodeJobContextImpl::x_RunJob(), and SOfflineJobContextImpl::x_RunJob().
|
overridevirtual |
Get the shared NetCacheAPI object used by the worker node framework.
Implements IWorkerNodeInitContext.
Definition at line 358 of file grid_worker.cpp.
References m_NetCacheAPI.
|
overridevirtual |
Get the shared NetScheduleAPI object used by the worker node framework.
Implements IWorkerNodeInitContext.
Definition at line 353 of file grid_worker.cpp.
References m_NetScheduleAPI.
Definition at line 205 of file grid_worker_impl.hpp.
References CNetScheduleAPI::GetQueueName(), and m_NetScheduleAPI.
Referenced by CGetLoadProcessor::Authenticate(), CGetStatisticsProcessor::Process(), Run(), and x_AreMastersBusy().
Definition at line 213 of file grid_worker_impl.hpp.
References m_NetScheduleAPI, SNetScheduleAPIImpl::m_Service, and SNetServiceImpl::m_ServiceName.
Referenced by x_AreMastersBusy().
void SGridWorkerNodeImpl::Init | ( | void | ) |
Definition at line 392 of file grid_worker.cpp.
References eDPF_MergeLines, eDPF_PreMergeLines, CSynRegistryBuilder::Get(), kEmptyStr, m_App, m_JobProcessorFactory, m_Listener, m_NetCacheAPI, m_NetScheduleAPI, m_Registry, m_SynRegistry, CRef< C, Locker >::Reset(), and SetDiagPostFlag().
|
inline |
Definition at line 222 of file grid_worker_impl.hpp.
References m_IsProcessingExclusiveJob.
Referenced by CGetStatisticsProcessor::Process(), SWorkerNodeJobContextImpl::x_RunJob(), and SOfflineJobContextImpl::x_RunJob().
void SGridWorkerNodeImpl::LeaveExclusiveMode | ( | ) |
Definition at line 1043 of file grid_worker.cpp.
References _ASSERT, m_ExclusiveJobSemaphore, m_IsProcessingExclusiveJob, and CSemaphore::Post().
Referenced by SWorkerNodeJobContextImpl::x_RunJob(), and SOfflineJobContextImpl::x_RunJob().
int SGridWorkerNodeImpl::OfflineRun | ( | ) |
Definition at line 171 of file wn_offline_mode.cpp.
References _ASSERT, CPoolOfThreads< TRequest >::AcceptRequest(), CDirEntry::AddTrailingPathSeparator(), NStr::EndsWith(), ERR_POST, CNetScheduleAdmin::eShutdownImmediate, CDir::fIgnorePath, CDir::fIgnoreRecursive, CNcbiApplicationAPI::GetArgs(), SNetScheduleAPIImpl::GetCompoundIDPool(), CDir::GetEntriesPtr(), CGridGlobals::GetInstance(), CWorkerNodeJobContext::GetJob(), CDirEntry::GetName(), CDirEntry::GetPath(), CPoolOfThreads< TRequest >::IsEmpty(), CDirEntry::IsFile(), ITERATE, kEmptyStr, CNetScheduleJobSerializer::LoadJobInput(), LOG_POST, m_App, m_Listener, m_NetScheduleAPI, m_QueueEmbeddedOutputSize, m_ThreadPool, m_ThreadPoolTimeout, CDirEntry::MakePath(), NULL, CGridGlobals::RequestShutdown(), CDirEntry::Reset(), SleepMilliSec(), CPoolOfThreads< TRequest >::WaitForRoom(), x_StartWorkerThreads(), x_StopWorkerThreads(), x_WNCleanUp(), and x_WNCoreInit().
Referenced by CGridWorkerApp::Run().
Definition at line 550 of file grid_worker.cpp.
References _ASSERT, AddJobWatcher(), CDirEntry::CheckAccess(), client, Critical(), CCurrentProcess::Daemonize(), SBuildInfo::date, default_timeout, CServer_Exception::eCouldntListen, eDefault, set< Key, Compare >::empty(), CTempString::empty(), eOff, eOn, ERR_POST, ERR_POST_X, Error(), eTakeOwnership, CFile::Exists(), f, CProcess::fDF_AllowExceptions, CProcess::fDF_KeepCWD, CProcess::fDF_KeepStdin, CProcess::fDF_KeepStdout, CCurrentProcess::Fork(), NStr::fSplit_MergeDelimiters, NStr::fSplit_Truncate, CDirEntry::fWrite, CNetScheduleAPI::GetAdmin(), CNcbiApplicationAPI::GetArgs(), CVersionAPI::GetBuildInfo(), GetClientName(), CNetScheduleAPI::GetExecutor(), CProcess::CExitInfo::GetExitCode(), CNcbiApplicationAPI::GetFullVersion(), CSocketAPI::gethostbyname(), CSocketAPI::gethostname(), CGridGlobals::GetInstance(), CGridGlobals::GetJobWatcher(), SThreadSafe< TType >::GetLock(), CCurrentProcess::GetPid(), CDiagContext::GetPID(), CNetScheduleNotificationHandler::GetPort(), CNetScheduleAdmin::GetQueueInfo(), GetQueueName(), CDeadline::GetRemainingTime(), CDiagContext::GetRequestContext(), CNetScheduleAPI::GetServerParams(), CProcess::CExitInfo::GetSignal(), Info(), set< Key, Compare >::insert(), int, CProcess::CExitInfo::IsExited(), CProcess::CExitInfo::IsPresent(), CWorkerNodeIdleThread::IsShutdownRequested(), CProcess::CExitInfo::IsSignaled(), CTimeout::IsZero(), ITERATE, CThread::Join(), kEmptyStr, kInfiniteTimeoutMs, kNetScheduleAPIDriverName, LOG_POST, LOG_POST_X, m_AdminHosts, m_App, m_CheckStatusPeriod, SNetScheduleAPIImpl::m_ClientNode, SNetScheduleAPIImpl::m_ClientSession, m_CommitJobInterval, m_IdleThread, m_JobCommitterThread, m_JobProcessorFactory, m_JobsPerClientIP, m_JobsPerSessionID, m_Listener, m_Masters, m_MaxThreads, m_NetScheduleAPI, SNetScheduleExecutorImpl::m_NotificationHandler, m_NSExecutor, m_NSTimeout, m_QueueEmbeddedOutputSize, m_QueueTimeout, m_SuspendResume, m_SynRegistry, SNetScheduleAPIImpl::m_UseEmbeddedStorage, max(), CNetScheduleAPI::SServerParams::max_output_size, NULL, NStr::NumericToString(), SSocketAddress::Parse(), CWNJobWatcher::Print(), remove(), CWorkerNodeIdleThread::RequestShutdown(), CRef< C, Locker >::Reset(), CRunningJobLimit::ResetJobCounter(), SNetScheduleExecutorImpl::retry_on_exception, CThread::Run(), SNetScheduleAPIImpl::SetAuthParam(), CNetScheduleAPI::SetClientNode(), CWNJobWatcher::SetInfiniteLoopTime(), CWNJobWatcher::SetMaxFailuresAllowed(), CWNJobWatcher::SetMaxJobsAllowed(), CNetScheduleAPI::SetProgramVersion(), CRequestContext::SetSessionID(), CGridGlobals::SetUDPPort(), signum(), SleepMilliSec(), SleepSec(), NStr::Split(), NStr::SplitInTwo(), CJobCommitterThread::Stop(), NStr::StringToUInt(), SBuildInfo::tag, NStr::TruncateSpaces(), CProcess::Wait(), Warning(), x_ClearNode(), x_StartWorkerThreads(), x_StopWorkerThreads(), x_WNCleanUp(), and x_WNCoreInit().
bool SGridWorkerNodeImpl::WaitForExclusiveJobToFinish | ( | ) |
Definition at line 1051 of file grid_worker.cpp.
References m_ExclusiveJobSemaphore, m_NSTimeout, CSemaphore::Post(), and CSemaphore::TryWait().
Referenced by CMainLoopThread::x_GetNextJob().
bool SGridWorkerNodeImpl::x_AreMastersBusy | ( | ) | const |
Definition at line 982 of file grid_worker.cpp.
References eIO_Open, eIO_Success, eOff, ERR_POST_X, GetClientName(), GetQueueName(), GetServiceName(), CSocket::GetStatus(), ITERATE, m_Masters, msg(), CSocket::ReadLine(), NStr::Replace(), NStr::StartsWith(), NStr::StringToInt(), and CSocket::Write().
Referenced by CMainLoopThread::x_GetNextJob().
void SGridWorkerNodeImpl::x_ClearNode | ( | ) |
Definition at line 911 of file grid_worker.cpp.
References CNetServiceException::eCommunicationError, ERR_POST_X, NStr::Find(), CException::GetErrCode(), m_NetScheduleAPI, NPOS, CException::what(), and SNetScheduleAPIImpl::x_ClearNode().
Referenced by Run().
void SGridWorkerNodeImpl::x_NotifyJobWatchers | ( | const CWorkerNodeJobContext & | job_context, |
IWorkerNodeJobWatcher::EEvent | event | ||
) |
Definition at line 952 of file grid_worker.cpp.
References m_JobWatcherMutex, m_Watchers, NCBI_CATCH_ALL_X, and NON_CONST_ITERATE.
Referenced by SWorkerNodeJobContextImpl::x_RunJob().
void SGridWorkerNodeImpl::x_StartWorkerThreads | ( | ) |
Definition at line 492 of file grid_worker.cpp.
References _ASSERT, ERR_POST_X, CNetScheduleAdmin::eShutdownImmediate, GetAppName(), CGridGlobals::GetInstance(), kMax_UInt, m_MaxThreads, m_SynRegistry, m_ThreadPool, CGridGlobals::RequestShutdown(), and CPoolOfThreads< TRequest >::Spawn().
Referenced by OfflineRun(), and Run().
void SGridWorkerNodeImpl::x_StopWorkerThreads | ( | ) |
Definition at line 896 of file grid_worker.cpp.
References ERR_POST_X, Info(), CStdPoolOfThreads::KillAllThreads(), LOG_POST_X, m_ThreadPool, and NULL.
Referenced by OfflineRun(), and Run().
int SGridWorkerNodeImpl::x_WNCleanUp | ( | ) |
Definition at line 116 of file wn_cleanup.cpp.
References ERR_POST_X, CGridGlobals::GetExitCode(), CGridGlobals::GetInstance(), Info(), LOG_POST_X, m_Listener, and m_ThreadPoolTimeout.
Referenced by OfflineRun(), and Run().
void SGridWorkerNodeImpl::x_WNCoreInit | ( | ) |
Definition at line 451 of file grid_worker.cpp.
References _ASSERT, NStr::CompareNocase(), DEFAULT_NS_TIMEOUT, ERR_POST_X, CSystemInfo::GetCpuCount(), CGridGlobals::GetInstance(), kEmptyStr, m_LogRequested, m_MaxThreads, m_NSTimeout, m_ProgressLogRequested, m_SingleThreadForced, m_StartupTime, m_SynRegistry, m_ThreadPoolTimeout, m_TotalMemoryLimit, m_TotalTimeLimit, CGridGlobals::SetReuseJobObject(), CGridGlobals::SetWorker(), NStr::StringToUInt(), and NStr::StringToUInt8_DataSize().
Referenced by OfflineRun(), and Run().
Definition at line 270 of file grid_worker_impl.hpp.
Referenced by Run().
CNcbiApplicationAPI& SGridWorkerNodeImpl::m_App |
Definition at line 281 of file grid_worker_impl.hpp.
Referenced by GetAppName(), GetArgs(), GetEnvironment(), Init(), OfflineRun(), and Run().
unsigned SGridWorkerNodeImpl::m_CheckStatusPeriod |
Definition at line 246 of file grid_worker_impl.hpp.
Referenced by Run().
CRef<CWorkerNodeCleanup> SGridWorkerNodeImpl::m_CleanupEventSource |
Definition at line 262 of file grid_worker_impl.hpp.
Referenced by GetCleanupEventSource(), and CGridCleanupThread::Main().
unsigned SGridWorkerNodeImpl::m_CommitJobInterval |
Definition at line 245 of file grid_worker_impl.hpp.
Referenced by Run(), and CJobCommitterThread::x_CommitJob().
CSemaphore SGridWorkerNodeImpl::m_ExclusiveJobSemaphore |
Definition at line 247 of file grid_worker_impl.hpp.
Referenced by EnterExclusiveMode(), LeaveExclusiveMode(), and WaitForExclusiveJobToFinish().
CRef<CWorkerNodeIdleThread> SGridWorkerNodeImpl::m_IdleThread |
Definition at line 277 of file grid_worker_impl.hpp.
Referenced by Run().
bool SGridWorkerNodeImpl::m_IsProcessingExclusiveJob |
Definition at line 248 of file grid_worker_impl.hpp.
Referenced by EnterExclusiveMode(), IsExclusiveMode(), and LeaveExclusiveMode().
CRef<CJobCommitterThread> SGridWorkerNodeImpl::m_JobCommitterThread |
Definition at line 276 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::Main(), Run(), and SWorkerNodeJobContextImpl::x_RunJob().
unique_ptr<IWorkerNodeJobFactory> SGridWorkerNodeImpl::m_JobProcessorFactory |
Definition at line 235 of file grid_worker_impl.hpp.
Referenced by GetJobProcessor(), Init(), Run(), and SGridWorkerNodeImpl().
|
mutable |
Definition at line 244 of file grid_worker_impl.hpp.
Referenced by GetJobProcessor().
SJobsInProgress SGridWorkerNodeImpl::m_JobsInProgress |
Definition at line 329 of file grid_worker_impl.hpp.
Referenced by CJobCommitterThread::x_CommitJob(), and CMainLoopThread::x_GetNextJob().
CRunningJobLimit SGridWorkerNodeImpl::m_JobsPerClientIP |
Definition at line 259 of file grid_worker_impl.hpp.
Referenced by Run(), and SWorkerNodeJobContextImpl::x_RunJob().
CRunningJobLimit SGridWorkerNodeImpl::m_JobsPerSessionID |
Definition at line 260 of file grid_worker_impl.hpp.
Referenced by Run(), and SWorkerNodeJobContextImpl::x_RunJob().
CFastMutex SGridWorkerNodeImpl::m_JobWatcherMutex |
Definition at line 256 of file grid_worker_impl.hpp.
Referenced by x_NotifyJobWatchers().
unique_ptr<IGridWorkerNodeApp_Listener> SGridWorkerNodeImpl::m_Listener |
Definition at line 279 of file grid_worker_impl.hpp.
Referenced by Init(), OfflineRun(), Run(), and x_WNCleanUp().
bool SGridWorkerNodeImpl::m_LogRequested |
Definition at line 285 of file grid_worker_impl.hpp.
Referenced by SWorkerNodeJobContextImpl::x_RunJob(), and x_WNCoreInit().
set<SSocketAddress> SGridWorkerNodeImpl::m_Masters |
Definition at line 269 of file grid_worker_impl.hpp.
Referenced by Run(), and x_AreMastersBusy().
unsigned int SGridWorkerNodeImpl::m_MaxThreads |
Definition at line 242 of file grid_worker_impl.hpp.
Referenced by Run(), x_StartWorkerThreads(), and x_WNCoreInit().
CNetCacheAPI SGridWorkerNodeImpl::m_NetCacheAPI |
Definition at line 237 of file grid_worker_impl.hpp.
Referenced by GetNetCacheAPI(), and Init().
CNetScheduleAPI SGridWorkerNodeImpl::m_NetScheduleAPI |
Definition at line 238 of file grid_worker_impl.hpp.
Referenced by GetClientName(), GetNetScheduleAPI(), GetQueueName(), GetServiceName(), Init(), OfflineRun(), Run(), and x_ClearNode().
CNetScheduleExecutor SGridWorkerNodeImpl::m_NSExecutor |
Definition at line 239 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::CImpl::CheckEntry(), CMainLoopThread::CImpl::CheckState(), CMainLoopThread::CImpl::ReadNotifications(), CMainLoopThread::CImpl::ReturnJob(), Run(), CMainLoopThread::CImpl::WaitForNotifications(), CJobCommitterThread::x_CommitJob(), CMainLoopThread::x_GetNextJob(), and CMainLoopThread::CImpl::x_ProcessRequestJobNotification().
unsigned int SGridWorkerNodeImpl::m_NSTimeout |
Definition at line 243 of file grid_worker_impl.hpp.
Referenced by Run(), WaitForExclusiveJobToFinish(), CMainLoopThread::x_GetNextJob(), and x_WNCoreInit().
bool SGridWorkerNodeImpl::m_ProgressLogRequested |
Definition at line 286 of file grid_worker_impl.hpp.
Referenced by SWorkerNodeJobContextImpl::PutProgressMessage(), and x_WNCoreInit().
size_t SGridWorkerNodeImpl::m_QueueEmbeddedOutputSize |
Definition at line 287 of file grid_worker_impl.hpp.
Referenced by SWorkerNodeJobContextImpl::GetOStream(), OfflineRun(), and Run().
unsigned SGridWorkerNodeImpl::m_QueueTimeout |
Definition at line 252 of file grid_worker_impl.hpp.
Referenced by Run(), and CJobCommitterThread::x_CommitJob().
Definition at line 283 of file grid_worker_impl.hpp.
Referenced by GetConfig(), and Init().
bool SGridWorkerNodeImpl::m_SingleThreadForced |
Definition at line 284 of file grid_worker_impl.hpp.
Referenced by x_WNCoreInit().
time_t SGridWorkerNodeImpl::m_StartupTime |
Definition at line 251 of file grid_worker_impl.hpp.
Referenced by x_WNCoreInit().
SThreadSafe<SSuspendResume> SGridWorkerNodeImpl::m_SuspendResume |
Definition at line 272 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::CImpl::CheckState(), SWorkerNodeJobContextImpl::GetShutdownLevel(), SWorkerNodeJobContextImpl::ResetJobContext(), and Run().
CSynRegistry::TPtr SGridWorkerNodeImpl::m_SynRegistry |
Definition at line 282 of file grid_worker_impl.hpp.
Referenced by Init(), CGetStatisticsProcessor::Process(), Run(), x_StartWorkerThreads(), and x_WNCoreInit().
CStdPoolOfThreads* SGridWorkerNodeImpl::m_ThreadPool |
Definition at line 240 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::Main(), OfflineRun(), x_StartWorkerThreads(), and x_StopWorkerThreads().
unsigned SGridWorkerNodeImpl::m_ThreadPoolTimeout |
Definition at line 288 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::Main(), OfflineRun(), x_WNCleanUp(), and x_WNCoreInit().
Uint8 SGridWorkerNodeImpl::m_TotalMemoryLimit |
Definition at line 249 of file grid_worker_impl.hpp.
Referenced by x_WNCoreInit().
unsigned SGridWorkerNodeImpl::m_TotalTimeLimit |
Definition at line 250 of file grid_worker_impl.hpp.
Referenced by CMainLoopThread::Main(), and x_WNCoreInit().
TJobWatchers SGridWorkerNodeImpl::m_Watchers |
Definition at line 257 of file grid_worker_impl.hpp.
Referenced by AddJobWatcher(), and x_NotifyJobWatchers().