Search Toolkit Book for CNetScheduleServer
NetScheduler threaded server. More...
#include "ns_server.hpp"
(Private to src/app/netschedule.)
NetScheduler threaded server.
Definition at line 56 of file ns_server.hpp.
◆ CNetScheduleServer() CNetScheduleServer::CNetScheduleServer ( const string & dbpath, bool diskless ) ◆ ~CNetScheduleServer() CNetScheduleServer::~CNetScheduleServer ( ) virtual ◆ AcknowledgeAlert() [1/2] ◆ AcknowledgeAlert() [2/2] ◆ AddDefaultListener() ◆ AdminHostValid() bool CNetScheduleServer::AdminHostValid ( unsigned host ) const ◆ AnybodyCanReconfigure() bool CNetScheduleServer::AnybodyCanReconfigure ( void ) const inline ◆ Configure() ◆ CountActiveJobs() unsigned CNetScheduleServer::CountActiveJobs ( void ) const ◆ CreateDynamicQueue() ◆ DecrementCurrentSubmitsCounter() unsigned int CNetScheduleServer::DecrementCurrentSubmitsCounter ( void ) inline ◆ DeleteDynamicQueue() ◆ Exit() void CNetScheduleServer::Exit ( void ) protectedvirtualCleanup the server.
Called by Run method after poll cycle when all processing threads are stopped, but before releasing listening ports. Here you're still guaranteed that another instance running on the same set of ports will fail at StartListening point.
Reimplemented from CServer.
Definition at line 696 of file ns_server.cpp.
References CQueueDataBase::Close(), ctx, CDiagContext_Extra::Flush(), GetDiagContext(), IsLog(), m_QueueDB, m_SigNum, NULL, CDiagContext_Extra::Print(), CDiagContext::PrintRequestStart(), CDiagContext::PrintRequestStop(), and CDiagContext::SetRequestContext().
◆ GetAdminClientNames() string CNetScheduleServer::GetAdminClientNames ( void ) const ◆ GetAdminHosts() ◆ GetAffRegistrySettings() ◆ GetAlerts() string CNetScheduleServer::GetAlerts ( void ) const ◆ GetBackgroundHost() ◆ GetCompoundIDPool() ◆ GetCurrentSubmitsCounter() unsigned int CNetScheduleServer::GetCurrentSubmitsCounter ( void ) inline ◆ GetDataPath() string CNetScheduleServer::GetDataPath ( void ) const ◆ GetDebugConnDropAfterWrite() ◆ GetDebugConnDropBeforeWrite() ◆ GetDebugFDCount() ◆ GetDebugGarbage() string CNetScheduleServer::GetDebugGarbage ( void ) const inline ◆ GetDebugMemCount() ◆ GetDebugReplyWithGarbage() ◆ GetDebugWriteDelay() ◆ GetDeleteBatchSize() unsigned CNetScheduleServer::GetDeleteBatchSize ( void ) const inline ◆ GetDiskConfigFileChecksum() string CNetScheduleServer::GetDiskConfigFileChecksum ( void ) const inline ◆ GetDiskless() bool CNetScheduleServer::GetDiskless ( void ) const inline ◆ GetGroupRegistrySettings() ◆ GetHost() string& CNetScheduleServer::GetHost ( void ) inline ◆ GetHostNetAddr() unsigned CNetScheduleServer::GetHostNetAddr ( ) const inline ◆ GetInactivityTimeout() unsigned CNetScheduleServer::GetInactivityTimeout ( void ) const inline ◆ GetInstance() ◆ GetJobCountersInterval() const unsigned int& CNetScheduleServer::GetJobCountersInterval ( ) const inline ◆ GetJobsStartID() unsigned int CNetScheduleServer::GetJobsStartID ( const string & qname ) inline ◆ GetLinkedSectionConfig() string CNetScheduleServer::GetLinkedSectionConfig ( void ) const ◆ GetMarkdelBatchSize() unsigned CNetScheduleServer::GetMarkdelBatchSize ( void ) const inline ◆ GetMaxClientData() unsigned int CNetScheduleServer::GetMaxClientData ( void ) const inline ◆ GetNodeID() string CNetScheduleServer::GetNodeID ( void ) const inline ◆ GetPauseQueues() map< string, int > CNetScheduleServer::GetPauseQueues ( void ) const ◆ GetPort() unsigned CNetScheduleServer::GetPort ( void ) const inline ◆ GetPurgeTimeout() double CNetScheduleServer::GetPurgeTimeout ( void ) const inline ◆ GetQueueClassesConfig() string CNetScheduleServer::GetQueueClassesConfig ( void ) const ◆ GetQueueClassesInfo() string CNetScheduleServer::GetQueueClassesInfo ( void ) const ◆ GetQueueConfig() string CNetScheduleServer::GetQueueConfig ( void ) const ◆ GetQueueInfo() string CNetScheduleServer::GetQueueInfo ( void ) const ◆ GetQueueNames() ◆ GetRAMConfigFileChecksum() string CNetScheduleServer::GetRAMConfigFileChecksum ( void ) const inline ◆ GetRefuseSubmitQueues() vector< string > CNetScheduleServer::GetRefuseSubmitQueues ( void ) const ◆ GetRefuseSubmits() bool CNetScheduleServer::GetRefuseSubmits ( ) const inline ◆ GetReserveDumpSpace() unsigned int CNetScheduleServer::GetReserveDumpSpace ( void ) const inline ◆ GetScanBatchSize() unsigned CNetScheduleServer::GetScanBatchSize ( void ) const inline ◆ GetScopeRegistrySettings() ◆ GetServices() void CNetScheduleServer::GetServices ( map< string, string > & services ) const ◆ GetServiceToQueueSectionConfig() string CNetScheduleServer::GetServiceToQueueSectionConfig ( void ) const ◆ GetSessionID() string CNetScheduleServer::GetSessionID ( void ) const inline ◆ GetStartTime() const CTime& CNetScheduleServer::GetStartTime ( void ) const inline ◆ GetStateTransitionPerfLogClasses() string CNetScheduleServer::GetStateTransitionPerfLogClasses ( void ) const ◆ GetStateTransitionPerfLogQueues() string CNetScheduleServer::GetStateTransitionPerfLogQueues ( void ) const ◆ GetStatInterval() const unsigned int& CNetScheduleServer::GetStatInterval ( ) const inline ◆ GetUseHostname() bool CNetScheduleServer::GetUseHostname ( void ) const inline ◆ IncrementCurrentSubmitsCounter() unsigned int CNetScheduleServer::IncrementCurrentSubmitsCounter ( void ) inline ◆ InitNodeID() void CNetScheduleServer::InitNodeID ( const string & db_path )Definition at line 654 of file ns_server.cpp.
References CDirEntry::AddTrailingPathSeparator(), buffer, CFileIO_Base::eCreate, CFileIO_Base::eOpen, CFileIO_Base::eRead, CFileIO_Base::eReadWrite, NStr::eTrunc_End, CFile::Exists(), f, CDirEntry::GetPath(), kNodeIDFileName(), m_Diskless, m_NodeID, CDirEntry::MakePath(), n, string, NStr::TruncateSpacesInPlace(), and x_GenerateGUID().
Referenced by CQueueDataBase::x_Open().
◆ IsAdminClientName() ◆ IsDrainShutdown() bool CNetScheduleServer::IsDrainShutdown ( void ) const inline ◆ IsLog() const bool& CNetScheduleServer::IsLog ( void ) const inline ◆ IsLogBatchEachJob() const bool& CNetScheduleServer::IsLogBatchEachJob ( ) const inline ◆ IsLogCleaningThread() const bool& CNetScheduleServer::IsLogCleaningThread ( ) const inline ◆ IsLogExecutionWatcherThread() const bool& CNetScheduleServer::IsLogExecutionWatcherThread ( ) const inline ◆ IsLogNotificationThread() const bool& CNetScheduleServer::IsLogNotificationThread ( ) const inline ◆ IsLogStatisticsThread() const bool& CNetScheduleServer::IsLogStatisticsThread ( ) const inline ◆ LoadJobsStartIDs() void CNetScheduleServer::LoadJobsStartIDs ( void ) inline ◆ OpenQueue() ◆ PrintJobsStat() ◆ PrintTransitionCounters() string CNetScheduleServer::PrintTransitionCounters ( void ) ◆ QueueInfo() ◆ ReadServicesConfig()Definition at line 291 of file ns_server.cpp.
References CJsonNode::AppendString(), map_checker< Container >::begin(), NStr::CompareNocase(), map_checker< Container >::end(), entries, IRegistry::EnumerateEntries(), IRegistry::Get(), CJsonNode::GetSize(), m_QueueDB, m_Services, m_ServicesLock, CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), CQueueDataBase::QueueExists(), and CJsonNode::SetByKey().
Referenced by CNetScheduleHandler::x_ProcessReloadConfig().
◆ RegisterAlert()Definition at line 643 of file ns_server.cpp.
References m_Alerts, and CNSAlerts::Register().
Referenced by CNSClientId::CheckAccess(), CQueueDataBase::CreateDynamicQueue(), SJobDump::Read(), CServiceThread::x_CheckConfigFile(), CQueueDataBase::x_CheckOpenPreconditions(), CQueueDataBase::x_CreateSpaceReserveFile(), CQueueDataBase::x_Open(), CNetScheduleHandler::x_ProcessReloadConfig(), CQueueDataBase::x_RemoveSpaceReserveFile(), and CNetScheduleDApp::x_WritePid().
◆ ResolveService() ◆ SerializeAlerts() string CNetScheduleServer::SerializeAlerts ( void ) const ◆ SerializeJobsStartIDs() void CNetScheduleServer::SerializeJobsStartIDs ( void ) inline ◆ SetAnybodyCanReconfigure() void CNetScheduleServer::SetAnybodyCanReconfigure ( bool val ) inline ◆ SetDiskConfigFileChecksum() void CNetScheduleServer::SetDiskConfigFileChecksum ( const string & checksum ) ◆ SetDrainShutdown() void CNetScheduleServer::SetDrainShutdown ( void ) inline ◆ SetJobsStartID() void CNetScheduleServer::SetJobsStartID ( const string & qname, unsigned int value ) inline ◆ SetNSParameters()Definition at line 101 of file ns_server.cpp.
References SNS_Parameters::admin_client_names, SNS_Parameters::admin_hosts, SNS_Parameters::affinity_reg, CJsonNode::AppendBoolean(), CJsonNode::AppendInteger(), debug_conn_drop_after_write, SNS_Parameters::debug_conn_drop_after_write, debug_conn_drop_before_write, SNS_Parameters::debug_conn_drop_before_write, debug_fd_count, SNS_Parameters::debug_fd_count, debug_garbage, SNS_Parameters::debug_garbage, debug_mem_count, SNS_Parameters::debug_mem_count, debug_reply_with_garbage, SNS_Parameters::debug_reply_with_garbage, debug_write_delay, SNS_Parameters::debug_write_delay, SNS_Parameters::del_batch_size, CSocketAPI::gethostbyname(), CSocketAPI::gethostname(), CServer::GetParameters(), CJsonNode::GetSize(), SNS_Parameters::group_reg, SNS_Parameters::is_log, SNS_Parameters::job_counters_interval, kEmptyStr, SNS_Parameters::log_batch_each_job, SNS_Parameters::log_cleaning_thread, SNS_Parameters::log_execution_watcher_thread, SNS_Parameters::log_notification_thread, SNS_Parameters::log_statistics_thread, m_AdminClientNames, m_AdminClientsLock, m_AdminHosts, m_AffRegistrySettings, m_DeleteBatchSize, m_GroupRegistrySettings, m_Host, m_HostNetAddr, m_InactivityTimeout, m_JobCountersInterval, m_LogBatchEachJobFlag, m_LogCleaningThreadFlag, m_LogExecutionWatcherThreadFlag, m_LogFlag, m_LogNotificationThreadFlag, m_LogStatisticsThreadFlag, m_MarkdelBatchSize, m_MaxClientData, m_Port, m_PurgeTimeout, m_ReserveDumpSpace, m_ScanBatchSize, m_ScopeRegistrySettings, m_StateTransitionPerfLogClasses, m_StateTransitionPerfLogQueues, m_StatInterval, m_STPerfLogQCLock, m_UseHostname, SNS_Parameters::markdel_batch_size, SNS_Parameters::max_client_data, SServer_Parameters::max_connections, SNS_Parameters::network_timeout, CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), CSocketAPI::ntoa(), SNS_Parameters::port, SNS_Parameters::purge_timeout, SNS_Parameters::reserve_dump_space, SNS_Parameters::scan_batch_size, SNS_Parameters::scope_reg, CJsonNode::SetByKey(), CNetScheduleAccessList::SetHosts(), CServer::SetParameters(), SNS_Parameters::stat_interval, SNS_Parameters::state_transition_perf_log_classes, SNS_Parameters::state_transition_perf_log_queues, SNS_Parameters::use_hostname, and x_SetFromList().
Referenced by CNetScheduleHandler::x_ProcessReloadConfig().
◆ SetQueueDB() ◆ SetRAMConfigFileChecksum() void CNetScheduleServer::SetRAMConfigFileChecksum ( const string & checksum ) ◆ SetRefuseSubmits() void CNetScheduleServer::SetRefuseSubmits ( bool val ) inline ◆ SetShutdownFlag() void CNetScheduleServer::SetShutdownFlag ( int signum =0, bool db_was_drained = false ) ◆ ShouldPerfLogTransitions() ◆ ShutdownRequested() bool CNetScheduleServer::ShutdownRequested ( void ) virtual ◆ WasDBDrained() bool CNetScheduleServer::WasDBDrained ( void ) const inline ◆ x_GenerateGUID() string CNetScheduleServer::x_GenerateGUID ( void ) const private ◆ x_SetAdminClientNames() ◆ x_SetFromList() ◆ debug_conn_drop_after_write ◆ debug_conn_drop_before_write ◆ debug_fd_count ◆ debug_garbage string CNetScheduleServer::debug_garbage private ◆ debug_mem_count ◆ debug_reply_with_garbage ◆ debug_write_delay ◆ m_AdminClientNames vector<string> CNetScheduleServer::m_AdminClientNames private ◆ m_AdminClientsLock CRWLock CNetScheduleServer::m_AdminClientsLock mutableprivate ◆ m_AdminHosts ◆ m_AffRegistrySettings ◆ m_Alerts ◆ m_AnybodyCanReconfigure bool CNetScheduleServer::m_AnybodyCanReconfigure private ◆ m_BackgroundHost ◆ m_CompoundIDPool ◆ m_CurrentSubmitsCounter ◆ m_DBDrained bool CNetScheduleServer::m_DBDrained private ◆ m_DeleteBatchSize unsigned int CNetScheduleServer::m_DeleteBatchSize private ◆ m_DiskConfigFileChecksum string CNetScheduleServer::m_DiskConfigFileChecksum private ◆ m_Diskless bool CNetScheduleServer::m_Diskless private ◆ m_GroupRegistrySettings ◆ m_Host string CNetScheduleServer::m_Host private ◆ m_HostNetAddr unsigned CNetScheduleServer::m_HostNetAddr private ◆ m_InactivityTimeout unsigned int CNetScheduleServer::m_InactivityTimeout private ◆ m_JobCountersInterval unsigned int CNetScheduleServer::m_JobCountersInterval private ◆ m_LogBatchEachJobFlag bool CNetScheduleServer::m_LogBatchEachJobFlag private ◆ m_LogCleaningThreadFlag bool CNetScheduleServer::m_LogCleaningThreadFlag private ◆ m_LogExecutionWatcherThreadFlag bool CNetScheduleServer::m_LogExecutionWatcherThreadFlag private ◆ m_LogFlag bool CNetScheduleServer::m_LogFlag private ◆ m_LogNotificationThreadFlag bool CNetScheduleServer::m_LogNotificationThreadFlag private ◆ m_LogStatisticsThreadFlag bool CNetScheduleServer::m_LogStatisticsThreadFlag private ◆ m_MarkdelBatchSize unsigned int CNetScheduleServer::m_MarkdelBatchSize private ◆ m_MaxClientData unsigned int CNetScheduleServer::m_MaxClientData private ◆ m_NodeID string CNetScheduleServer::m_NodeID private ◆ m_Port unsigned CNetScheduleServer::m_Port private ◆ m_PurgeTimeout double CNetScheduleServer::m_PurgeTimeout private ◆ m_QueueDB
Definition at line 228 of file ns_server.hpp.
Referenced by Configure(), CountActiveJobs(), CreateDynamicQueue(), DeleteDynamicQueue(), Exit(), GetDataPath(), GetLinkedSectionConfig(), GetPauseQueues(), GetQueueClassesConfig(), GetQueueClassesInfo(), GetQueueConfig(), GetQueueInfo(), GetQueueNames(), GetRefuseSubmitQueues(), OpenQueue(), PrintJobsStat(), PrintTransitionCounters(), QueueInfo(), ReadServicesConfig(), SetQueueDB(), and ~CNetScheduleServer().
◆ m_RAMConfigFileChecksum string CNetScheduleServer::m_RAMConfigFileChecksum private ◆ m_RefuseSubmits bool CNetScheduleServer::m_RefuseSubmits private ◆ m_ReserveDumpSpace unsigned int CNetScheduleServer::m_ReserveDumpSpace private ◆ m_ScanBatchSize unsigned int CNetScheduleServer::m_ScanBatchSize private ◆ m_ScopeRegistrySettings ◆ m_Services ◆ m_ServicesLock ◆ m_SessionID string CNetScheduleServer::m_SessionID private ◆ m_Shutdown bool CNetScheduleServer::m_Shutdown mutableprivate ◆ m_SigNum int CNetScheduleServer::m_SigNum private ◆ m_StartIDs ◆ m_StartTime CTime CNetScheduleServer::m_StartTime private ◆ m_StateTransitionPerfLogClasses vector<string> CNetScheduleServer::m_StateTransitionPerfLogClasses private ◆ m_StateTransitionPerfLogQueues vector<string> CNetScheduleServer::m_StateTransitionPerfLogQueues private ◆ m_StatInterval unsigned int CNetScheduleServer::m_StatInterval private ◆ m_STPerfLogQCLock CRWLock CNetScheduleServer::m_STPerfLogQCLock mutableprivate ◆ m_UseHostname bool CNetScheduleServer::m_UseHostname private ◆ sm_netschedule_serverThe documentation for this class was generated from the following files:
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