RetroSearch Browse

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

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

NCBI C++ ToolKit: SGridWorkerNodeImpl Struct Reference

Search Toolkit Book for SGridWorkerNodeImpl

#include "grid_worker_impl.hpp"
(Private to src/connect/services.)

struct SJobsInProgress Bookkeeping of jobs being executed (to prevent simultaneous runs of the same job) More...
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 ()

Definition at line 183 of file grid_worker_impl.hpp.

◆ TJobWatchers ◆ SGridWorkerNodeImpl() ◆ AddJobWatcher() ◆ EnterExclusiveMode() bool SGridWorkerNodeImpl::EnterExclusiveMode ( ) ◆ GetAppName() string SGridWorkerNodeImpl::GetAppName ( void ) const inline ◆ GetArgs() const CArgs & SGridWorkerNodeImpl::GetArgs ( ) const overridevirtual ◆ GetCleanupEventSource() ◆ GetClientName() const string& SGridWorkerNodeImpl::GetClientName ( void ) const inline ◆ GetConfig() ◆ GetEnvironment() ◆ 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().

◆ GetNetCacheAPI() ◆ GetNetScheduleAPI() ◆ GetQueueName() const string& SGridWorkerNodeImpl::GetQueueName ( ) const inline ◆ GetServiceName() const string& SGridWorkerNodeImpl::GetServiceName ( void ) const inline ◆ Init() 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().

◆ IsExclusiveMode() bool SGridWorkerNodeImpl::IsExclusiveMode ( ) const inline ◆ LeaveExclusiveMode() void SGridWorkerNodeImpl::LeaveExclusiveMode ( ) ◆ OfflineRun() 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().

◆ 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().

◆ WaitForExclusiveJobToFinish() bool SGridWorkerNodeImpl::WaitForExclusiveJobToFinish ( ) ◆ x_AreMastersBusy() 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().

◆ x_ClearNode() void SGridWorkerNodeImpl::x_ClearNode ( ) ◆ x_NotifyJobWatchers() ◆ x_StartWorkerThreads() 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().

◆ x_StopWorkerThreads() void SGridWorkerNodeImpl::x_StopWorkerThreads ( ) ◆ x_WNCleanUp() int SGridWorkerNodeImpl::x_WNCleanUp ( ) ◆ x_WNCoreInit() 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().

◆ m_AdminHosts set<unsigned int> SGridWorkerNodeImpl::m_AdminHosts ◆ m_App ◆ m_CheckStatusPeriod unsigned SGridWorkerNodeImpl::m_CheckStatusPeriod ◆ m_CleanupEventSource ◆ m_CommitJobInterval unsigned SGridWorkerNodeImpl::m_CommitJobInterval ◆ m_ExclusiveJobSemaphore CSemaphore SGridWorkerNodeImpl::m_ExclusiveJobSemaphore ◆ m_IdleThread ◆ m_IsProcessingExclusiveJob bool SGridWorkerNodeImpl::m_IsProcessingExclusiveJob ◆ m_JobCommitterThread ◆ m_JobProcessorFactory ◆ m_JobProcessorMutex CFastMutex SGridWorkerNodeImpl::m_JobProcessorMutex mutable ◆ m_JobsInProgress ◆ m_JobsPerClientIP ◆ m_JobsPerSessionID ◆ m_JobWatcherMutex ◆ m_Listener ◆ m_LogRequested bool SGridWorkerNodeImpl::m_LogRequested ◆ m_Masters ◆ m_MaxThreads unsigned int SGridWorkerNodeImpl::m_MaxThreads ◆ m_NetCacheAPI ◆ m_NetScheduleAPI ◆ m_NSExecutor ◆ m_NSTimeout unsigned int SGridWorkerNodeImpl::m_NSTimeout ◆ m_ProgressLogRequested bool SGridWorkerNodeImpl::m_ProgressLogRequested ◆ m_QueueEmbeddedOutputSize size_t SGridWorkerNodeImpl::m_QueueEmbeddedOutputSize ◆ m_QueueTimeout unsigned SGridWorkerNodeImpl::m_QueueTimeout ◆ m_Registry ◆ m_SingleThreadForced bool SGridWorkerNodeImpl::m_SingleThreadForced ◆ m_StartupTime time_t SGridWorkerNodeImpl::m_StartupTime ◆ m_SuspendResume ◆ m_SynRegistry ◆ m_ThreadPool ◆ m_ThreadPoolTimeout unsigned SGridWorkerNodeImpl::m_ThreadPoolTimeout ◆ m_TotalMemoryLimit Uint8 SGridWorkerNodeImpl::m_TotalMemoryLimit ◆ m_TotalTimeLimit unsigned SGridWorkerNodeImpl::m_TotalTimeLimit ◆ m_Watchers

The documentation for this struct was generated from the following files:

src/connect/services/grid_worker_impl.hpp
src/connect/services/grid_worker.cpp
src/connect/services/wn_cleanup.cpp
src/connect/services/wn_commit_thread.cpp
src/connect/services/wn_offline_mode.cpp

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