A RetroSearch Logo

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

Search Query:

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

NCBI C++ ToolKit: CQueueDataBase Class Reference

Search Toolkit Book for CQueueDataBase

#include "queue_database.hpp"
(Private to src/app/netschedule.)

  CQueueDataBase (CNetScheduleServer *server, const string &path, unsigned int max_queues, bool diskless, bool reinit)     ~CQueueDataBase ()   time_t  Configure (const IRegistry &reg, CJsonNode &diff)   unsigned int  CountActiveJobs (void) const   unsigned int  CountAllJobs (void) const   bool  AnyJobs (void) const   CRef< CQueue >  OpenQueue (const string &name)   void  CreateDynamicQueue (const CNSClientId &client, const string &qname, const string &qclass, const string &description="")   void  DeleteDynamicQueue (const CNSClientId &client, const string &qname)   SQueueParameters  QueueInfo (const string &qname) const   string  GetQueueNames (const string &sep) const   void  Close (void)   bool  QueueExists (const string &qname) const   void  Purge (void)   void  StopPurge (void)   void  RunPurgeThread (void)   void  StopPurgeThread (void)   void  PurgeAffinities (void)   void  PurgeGroups (void)   void  StaleWNodes (void)   void  PurgeBlacklistedJobs (void)   void  PurgeClientRegistry (void)   void  NotifyListeners (void)   void  RunNotifThread (void)   void  StopNotifThread (void)   void  WakeupNotifThread (void)   CNSPreciseTime  SendExactNotifications (void)   void  PrintStatistics (size_t &aff_count)   void  PrintJobCounters (void)   void  RunServiceThread (void)   void  StopServiceThread (void)   void  CheckExecutionTimeout (bool logging)   void  RunExecutionWatcherThread (const CNSPreciseTime &run_delay)   void  StopExecutionWatcherThread (void)   string  PrintTransitionCounters (void)   string  PrintJobsStat (const CNSClientId &client)   string  GetQueueClassesInfo (void) const   string  GetQueueClassesConfig (void) const   string  GetQueueInfo (void) const   string  GetQueueConfig (void) const   string  GetLinkedSectionConfig (void) const   map< string, string >  GetLinkedSection (const string &section_name) const   map< string, int >  GetPauseQueues (void) const   vector< string >  GetRefuseSubmitQueues (void) const   string  GetDataPath (void) const     CQueueDataBase (const CQueueDataBase &)   CQueueDataBase &  operator= (const CQueueDataBase &)   void  x_Open (bool reinit)   void  x_CreateAndMountQueue (const string &qname, const SQueueParameters &params)   unsigned  x_PurgeUnconditional (void)   void  x_OptimizeStatusMatrix (const CNSPreciseTime &current_time)   bool  x_CheckStopPurge (void)   SQueueParameters  x_SingleQueueInfo (TQueueInfo::const_iterator found) const   bool  x_PurgeQueue (CQueue &queue, size_t status_to_start, size_t status_to_end, unsigned int start_job_id, unsigned int end_job_id, size_t max_scanned, size_t max_mark_deleted, const CNSPreciseTime &current_time, size_t &total_scanned, size_t &total_mark_deleted)   void  x_DeleteQueuesAndClasses (void)   CRef< CQueue >  x_GetLastPurged (void)   CRef< CQueue >  x_GetFirst (void)   CRef< CQueue >  x_GetNext (const string &current_name)   void  x_CreateCrashFlagFile (void)   bool  x_DoesCrashFlagFileExist (void) const   void  x_RemoveCrashFlagFile (void)   void  x_CreateDumpErrorFlagFile (void)   bool  x_DoesDumpErrorFlagFileExist (void) const   void  x_RemoveDumpErrorFlagFile (void)   bool  x_ConfigureQueueClasses (const TQueueParams &classes_from_ini, CJsonNode &diff)   bool  x_ConfigureQueues (const TQueueParams &queues_from_ini, CJsonNode &diff)   TQueueParams  x_ReadIniFileQueueClassDescriptions (const IRegistry &reg)   TQueueParams  x_ReadIniFileQueueDescriptions (const IRegistry &reg, const TQueueParams &classes)   void  x_ReadLinkedSections (const IRegistry &reg, CJsonNode &diff)   CJsonNode  x_DetectChangesInLinkedSection (const map< string, string > &old_values, const map< string, string > &new_values)   void  x_ValidateConfiguration (const TQueueParams &queues_from_ini) const   unsigned int  x_CountQueuesToAdd (const TQueueParams &queues_from_ini) const   CRef< CQueue >  x_GetQueueAt (unsigned int index)   void  x_Dump (void)   void  x_DumpQueueOrClass (FILE *f, const string &qname, const string &qclass, bool is_queue, const SQueueParameters &params)   void  x_DumpLinkedSection (FILE *f, const string &sname, const map< string, string > &values)   void  x_RemoveDump (void)   void  x_RemoveDataFiles (void)   void  x_CreateStorageVersionFile (void)   bool  x_CheckOpenPreconditions (bool reinit)   void  x_ReadDumpQueueDesrc (set< string, PNocase > &dump_static_queues, map< string, string, PNocase > &dump_dynamic_queues, TQueueParams &dump_queue_classes)   set< string, PNocase >  x_GetConfigQueues (void)   void  x_AppendDumpLinkedSections (void)   CNSPreciseTime  CalculateRuntimePrecision (void) const   void  x_BackupDump (void)   void  x_CreateSpaceReserveFile (void)   bool  x_RemoveSpaceReserveFile (void)   string  x_GetDumpSpaceFileName (void) const   void  x_RestorePauseState (const map< string, int > &paused_queues)   void  x_RestoreRefuseSubmitState (const vector< string > &refuse_submit_queues)  

Definition at line 67 of file queue_database.hpp.

◆ CQueueDataBase() [1/2]

Definition at line 59 of file queue_database.cpp.

References CDirEntry::AddTrailingPathSeparator(), DeserializePauseState(), DeserializeRefuseSubmitState(), GetPauseQueues(), GetRefuseSubmitQueues(), CNetScheduleServer::GetRefuseSubmits(), kDumpSubdirName(), CNetScheduleServer::LoadJobsStartIDs(), m_DataPath, m_Diskless, m_DumpPath, m_Server, SerializePauseState(), SerializeRefuseSubmitState(), x_Open(), x_RemoveDataFiles(), x_RestorePauseState(), and x_RestoreRefuseSubmitState().

◆ ~CQueueDataBase() CQueueDataBase::~CQueueDataBase ( ) ◆ CQueueDataBase() [2/2] ◆ AnyJobs() bool CQueueDataBase::AnyJobs ( void  ) const ◆ CalculateRuntimePrecision() CNSPreciseTime CQueueDataBase::CalculateRuntimePrecision ( void  ) const private ◆ CheckExecutionTimeout() void CQueueDataBase::CheckExecutionTimeout ( bool  logging ) ◆ Close() void CQueueDataBase::Close ( void  )

Definition at line 1189 of file queue_database.cpp.

References map_checker< Container >::clear(), ERR_POST, CNetScheduleServer::IsDrainShutdown(), CNetScheduleServer::IsLogStatisticsThread(), LOG_POST, m_Diskless, m_QueueClasses, m_Queues, m_Server, CStatisticsCounters::PrintServerWide(), PrintStatistics(), StopExecutionWatcherThread(), StopNotifThread(), StopPurgeThread(), StopServiceThread(), Warning(), CNetScheduleServer::WasDBDrained(), x_Dump(), x_RemoveCrashFlagFile(), x_RemoveDataFiles(), and x_RemoveDumpErrorFlagFile().

Referenced by CNetScheduleServer::Exit(), and ~CQueueDataBase().

◆ Configure()

Definition at line 895 of file queue_database.cpp.

References CalculateRuntimePrecision(), m_ConfigureLock, m_MaxQueues, m_Queues, NCBI_THROW, map_checker< Container >::size(), x_ConfigureQueueClasses(), x_ConfigureQueues(), x_CountQueuesToAdd(), x_ReadIniFileQueueClassDescriptions(), x_ReadIniFileQueueDescriptions(), x_ReadLinkedSections(), and x_ValidateConfiguration().

Referenced by CNetScheduleServer::Configure().

◆ CountActiveJobs() unsigned int CQueueDataBase::CountActiveJobs ( void  ) const ◆ CountAllJobs() unsigned int CQueueDataBase::CountAllJobs ( void  ) const ◆ CreateDynamicQueue()

Definition at line 1027 of file queue_database.cpp.

References CQueueClientInfoList::AddClientInfo(), client, CQueueClientInfo::client_name, SQueueParameters::delete_request, SQueueParameters::description, eAccess, CQueue::eKindDynamic, map_checker< Container >::end(), map_checker< Container >::find(), CNetScheduleAccessList::IsAllowed(), CQueueClientInfoList::IsMatchingClient(), SQueueParameters::kind, m_ConfigureLock, m_MaxQueues, m_QueueClasses, m_Queues, m_Server, NCBI_THROW, ok, ParseVersionString(), SQueueParameters::qclass, CNetScheduleServer::RegisterAlert(), CNetScheduleAccessList::SetHosts(), map_checker< Container >::size(), CQueueClientInfo::version_info, and x_CreateAndMountQueue().

Referenced by CNetScheduleServer::CreateDynamicQueue().

◆ DeleteDynamicQueue() ◆ GetDataPath() string CQueueDataBase::GetDataPath ( void  ) const inline ◆ GetLinkedSection() ◆ GetLinkedSectionConfig() string CQueueDataBase::GetLinkedSectionConfig ( void  ) const ◆ GetNextId() unsigned int CQueueDataBase::GetNextId ( ) protected ◆ GetNextIdBatch() unsigned int CQueueDataBase::GetNextIdBatch ( unsigned int  count ) protected ◆ GetPauseQueues() map< string, int > CQueueDataBase::GetPauseQueues ( void  ) const ◆ GetQueueClassesConfig() string CQueueDataBase::GetQueueClassesConfig ( void  ) const ◆ GetQueueClassesInfo() string CQueueDataBase::GetQueueClassesInfo ( void  ) const ◆ GetQueueConfig() string CQueueDataBase::GetQueueConfig ( void  ) const ◆ GetQueueInfo() string CQueueDataBase::GetQueueInfo ( void  ) const ◆ GetQueueNames() ◆ GetRefuseSubmitQueues() vector< string > CQueueDataBase::GetRefuseSubmitQueues ( void  ) const ◆ NotifyListeners() void CQueueDataBase::NotifyListeners ( void  ) ◆ OpenQueue() ◆ operator=() ◆ PrintJobCounters() void CQueueDataBase::PrintJobCounters ( void  ) ◆ PrintJobsStat() ◆ PrintStatistics() void CQueueDataBase::PrintStatistics ( size_t &  aff_count ) ◆ PrintTransitionCounters() string CQueueDataBase::PrintTransitionCounters ( void  ) ◆ Purge() void CQueueDataBase::Purge ( void  )

Definition at line 1558 of file queue_database.cpp.

References CNSPreciseTime::Current(), CNetScheduleServer::GetMarkdelBatchSize(), CRef< C, Locker >::GetObject(), CNetScheduleServer::GetScanBatchSize(), CRef< C, Locker >::IsNull(), kStatusesSize, m_FreeStatusMemCnt, m_PurgeJobScanned, m_PurgeQueue, m_PurgeStatusIndex, m_Server, x_DeleteQueuesAndClasses(), x_GetFirst(), x_GetLastPurged(), x_GetNext(), x_OptimizeStatusMatrix(), x_PurgeQueue(), and x_PurgeUnconditional().

Referenced by CJobQueueCleanerThread::x_DoJob().

◆ PurgeAffinities() void CQueueDataBase::PurgeAffinities ( void  ) ◆ PurgeBlacklistedJobs() void CQueueDataBase::PurgeBlacklistedJobs ( void  ) ◆ PurgeClientRegistry() void CQueueDataBase::PurgeClientRegistry ( void  ) ◆ PurgeGroups() void CQueueDataBase::PurgeGroups ( void  ) ◆ QueueExists() ◆ QueueInfo() ◆ RunExecutionWatcherThread() ◆ RunNotifThread() void CQueueDataBase::RunNotifThread ( void  ) ◆ RunPurgeThread() void CQueueDataBase::RunPurgeThread ( void  ) ◆ RunServiceThread() void CQueueDataBase::RunServiceThread ( void  ) ◆ SendExactNotifications() ◆ StaleWNodes() void CQueueDataBase::StaleWNodes ( void  ) ◆ StopExecutionWatcherThread() void CQueueDataBase::StopExecutionWatcherThread ( void  ) ◆ StopNotifThread() void CQueueDataBase::StopNotifThread ( void  ) ◆ StopPurge() void CQueueDataBase::StopPurge ( void  ) ◆ StopPurgeThread() void CQueueDataBase::StopPurgeThread ( void  ) ◆ StopServiceThread() void CQueueDataBase::StopServiceThread ( void  ) ◆ WakeupNotifThread() void CQueueDataBase::WakeupNotifThread ( void  ) ◆ x_AppendDumpLinkedSections() void CQueueDataBase::x_AppendDumpLinkedSections ( void  ) private

Definition at line 2784 of file queue_database.cpp.

References map_checker< Container >::end(), CFile::Exists(), CDir::Exists(), f, map_checker< Container >::find(), SOneStructDumpHeader::fixed_size, map_checker< Container >::insert(), kLinkedSectionsFileName(), m_DumpPath, m_LinkedSections, NULL, SOneStructDumpHeader::Read(), SLinkedSectionDump::Read(), SLinkedSectionDump::section, SLinkedSectionDump::section_size, val, SLinkedSectionDump::value, SLinkedSectionDump::value_name, SLinkedSectionDump::value_name_size, and SLinkedSectionDump::value_size.

Referenced by x_Open().

◆ x_BackupDump() void CQueueDataBase::x_BackupDump ( void  ) private ◆ x_CheckOpenPreconditions() bool CQueueDataBase::x_CheckOpenPreconditions ( bool  reinit ) private

Definition at line 2467 of file queue_database.cpp.

References buf, eDumpError, eNoDump, CFileIO_Base::eOpen, CFileIO_Base::eRead, eReinit, ERR_POST, eStartAfterCrash, CFile::Exists(), CDir::Exists(), f, CNcbiApplicationAPI::GetVersion(), CNcbiApplication::Instance(), kDBStorageVersionFileName(), kDumpSubdirName(), LOG_POST, m_DataPath, m_DumpPath, m_Server, msg(), NCBI_THROW, NETSCHEDULED_STORAGE_VERSION, Note, CVersionInfo::Print(), CNetScheduleServer::RegisterAlert(), NStr::Split(), Warning(), x_DoesCrashFlagFileExist(), and x_DoesDumpErrorFlagFileExist().

Referenced by x_Open().

◆ x_CheckStopPurge() bool CQueueDataBase::x_CheckStopPurge ( void  ) private ◆ x_ConfigureQueueClasses() ◆ x_ConfigureQueues()

Definition at line 716 of file queue_database.cpp.

References CJsonNode::AppendString(), map_checker< Container >::begin(), CQueue::eKindDynamic, map_checker< Container >::end(), ERR_POST, map_checker< Container >::find(), CJsonNode::GetSize(), m_QueueClasses, m_Queues, CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), CJsonNode::NewStringNode(), CJsonNode::SetByKey(), string, and x_CreateAndMountQueue().

Referenced by Configure(), and x_Open().

◆ x_CountQueuesToAdd() ◆ x_CreateAndMountQueue() ◆ x_CreateCrashFlagFile() void CQueueDataBase::x_CreateCrashFlagFile ( void  ) private ◆ x_CreateDumpErrorFlagFile() void CQueueDataBase::x_CreateDumpErrorFlagFile ( void  ) private ◆ x_CreateSpaceReserveFile() void CQueueDataBase::x_CreateSpaceReserveFile ( void  ) private

Definition at line 2877 of file queue_database.cpp.

References buffer, CDir::Create(), eDumpSpaceError, ERR_POST, CDir::Exists(), free(), CNetScheduleServer::GetReserveDumpSpace(), kDumpReservedSpaceFileBuffer, m_DumpPath, m_Server, malloc(), msg(), NULL, CNetScheduleServer::RegisterAlert(), strerror(), string, and x_GetDumpSpaceFileName().

Referenced by x_Open().

◆ x_CreateStorageVersionFile() void CQueueDataBase::x_CreateStorageVersionFile ( void  ) private ◆ x_DeleteQueuesAndClasses() void CQueueDataBase::x_DeleteQueuesAndClasses ( void  ) private ◆ x_DetectChangesInLinkedSection() ◆ x_DoesCrashFlagFileExist() bool CQueueDataBase::x_DoesCrashFlagFileExist ( void  ) const private ◆ x_DoesDumpErrorFlagFileExist() bool CQueueDataBase::x_DoesDumpErrorFlagFileExist ( void  ) const private ◆ x_Dump() void CQueueDataBase::x_Dump ( void  ) private

Definition at line 2128 of file queue_database.cpp.

References map_checker< Container >::begin(), set< Key, Compare >::begin(), NStr::CompareNocase(), CDir::Create(), CQueue::eKindStatic, set< Key, Compare >::empty(), map_checker< Container >::end(), set< Key, Compare >::end(), ERR_POST, CDir::Exists(), map_checker< Container >::find(), set< Key, Compare >::find(), SOneStructDumpHeader::fixed_size, set< Key, Compare >::insert(), kLinkedSectionsFileName(), kQClassDescriptionFileName(), LOG_POST, m_DumpPath, m_LinkedSections, m_QueueClasses, m_Queues, Note, NULL, remove(), set< Key, Compare >::size(), SOneStructDumpHeader::Write(), x_DumpLinkedSection(), x_DumpQueueOrClass(), x_RemoveDumpErrorFlagFile(), and x_RemoveSpaceReserveFile().

Referenced by Close().

◆ x_DumpLinkedSection() ◆ x_DumpQueueOrClass()

Definition at line 2282 of file queue_database.cpp.

References map_checker< Container >::begin(), SQueueDescriptionDump::blacklist_time, SQueueParameters::blacklist_time, SQueueDescriptionDump::client_registry_min_admins, SQueueParameters::client_registry_min_admins, SQueueDescriptionDump::client_registry_min_readers, SQueueParameters::client_registry_min_readers, SQueueDescriptionDump::client_registry_min_submitters, SQueueParameters::client_registry_min_submitters, SQueueDescriptionDump::client_registry_min_unknowns, SQueueParameters::client_registry_min_unknowns, SQueueDescriptionDump::client_registry_min_worker_nodes, SQueueParameters::client_registry_min_worker_nodes, SQueueDescriptionDump::client_registry_timeout_admin, SQueueParameters::client_registry_timeout_admin, SQueueDescriptionDump::client_registry_timeout_reader, SQueueParameters::client_registry_timeout_reader, SQueueDescriptionDump::client_registry_timeout_submitter, SQueueParameters::client_registry_timeout_submitter, SQueueDescriptionDump::client_registry_timeout_unknown, SQueueParameters::client_registry_timeout_unknown, SQueueDescriptionDump::client_registry_timeout_worker_node, SQueueParameters::client_registry_timeout_worker_node, SQueueDescriptionDump::description, SQueueParameters::description, SQueueDescriptionDump::description_size, SQueueDescriptionDump::dump_aff_buffer_size, SQueueParameters::dump_aff_buffer_size, SQueueDescriptionDump::dump_buffer_size, SQueueParameters::dump_buffer_size, SQueueDescriptionDump::dump_client_buffer_size, SQueueParameters::dump_client_buffer_size, SQueueDescriptionDump::dump_group_buffer_size, SQueueParameters::dump_group_buffer_size, map_checker< Container >::end(), f, SQueueDescriptionDump::failed_retries, SQueueParameters::failed_retries, for(), SQueueDescriptionDump::is_queue, SQueueDescriptionDump::linked_section_names, SQueueDescriptionDump::linked_section_names_size, SQueueDescriptionDump::linked_section_prefixes, SQueueDescriptionDump::linked_section_prefixes_size, SQueueParameters::linked_sections, SQueueDescriptionDump::max_input_size, SQueueParameters::max_input_size, SQueueDescriptionDump::max_jobs_per_client, SQueueParameters::max_jobs_per_client, SQueueDescriptionDump::max_output_size, SQueueParameters::max_output_size, SQueueDescriptionDump::max_pending_read_wait_timeout, SQueueParameters::max_pending_read_wait_timeout, SQueueDescriptionDump::max_pending_wait_timeout, SQueueParameters::max_pending_wait_timeout, msg(), names, SQueueDescriptionDump::notif_handicap, SQueueParameters::notif_handicap, SQueueDescriptionDump::notif_hifreq_interval, SQueueParameters::notif_hifreq_interval, SQueueDescriptionDump::notif_hifreq_period, SQueueParameters::notif_hifreq_period, SQueueDescriptionDump::notif_lofreq_mult, SQueueParameters::notif_lofreq_mult, SQueueDescriptionDump::pending_timeout, SQueueParameters::pending_timeout, SQueueDescriptionDump::program_name, SQueueParameters::program_name, SQueueDescriptionDump::program_name_size, SQueueDescriptionDump::qclass, SQueueDescriptionDump::qclass_size, SQueueDescriptionDump::qname, SQueueDescriptionDump::qname_size, SQueueDescriptionDump::read_blacklist_time, SQueueParameters::read_blacklist_time, SQueueDescriptionDump::read_failed_retries, SQueueParameters::read_failed_retries, SQueueDescriptionDump::read_timeout, SQueueParameters::read_timeout, SQueueDescriptionDump::reader_hosts, SQueueParameters::reader_hosts, SQueueDescriptionDump::reader_hosts_size, SQueueDescriptionDump::reader_timeout, SQueueParameters::reader_timeout, SQueueDescriptionDump::run_timeout, SQueueParameters::run_timeout, SQueueDescriptionDump::scramble_job_keys, SQueueParameters::scramble_job_keys, string, SQueueDescriptionDump::subm_hosts, SQueueParameters::subm_hosts, SQueueDescriptionDump::subm_hosts_size, SQueueDescriptionDump::timeout, SQueueParameters::timeout, SQueueDescriptionDump::wnode_hosts, SQueueParameters::wnode_hosts, SQueueDescriptionDump::wnode_hosts_size, SQueueDescriptionDump::wnode_timeout, SQueueParameters::wnode_timeout, and SQueueDescriptionDump::Write().

Referenced by x_Dump().

◆ x_GetConfigQueues() ◆ x_GetDumpSpaceFileName() string CQueueDataBase::x_GetDumpSpaceFileName ( void  ) const private ◆ x_GetFirst() CRef< CQueue > CQueueDataBase::x_GetFirst ( void  ) private ◆ x_GetLastPurged() CRef< CQueue > CQueueDataBase::x_GetLastPurged ( void  ) private ◆ x_GetNext() ◆ x_GetQueueAt() CRef< CQueue > CQueueDataBase::x_GetQueueAt ( unsigned int  index ) private

Definition at line 2026 of file queue_database.cpp.

References map_checker< Container >::begin(), map_checker< Container >::end(), m_ConfigureLock, m_Queues, and NULL.

Referenced by CheckExecutionTimeout(), NotifyListeners(), PurgeAffinities(), PurgeBlacklistedJobs(), PurgeClientRegistry(), PurgeGroups(), SendExactNotifications(), StaleWNodes(), x_OptimizeStatusMatrix(), and x_PurgeUnconditional().

◆ x_Open() void CQueueDataBase::x_Open ( bool  reinit ) private

Definition at line 120 of file queue_database.cpp.

References map_checker< Container >::begin(), CDir::Create(), Critical(), SQueueParameters::delete_request, eDataDirRemoveError, eDumpLoadError, CQueue::eKindDynamic, eMaxQueues, map_checker< Container >::end(), set< Key, Compare >::end(), ERR_POST, CDir::Exists(), CDiagContext::Extra(), map_checker< Container >::find(), set< Key, Compare >::find(), GetDiagContext(), CNetScheduleServer::InitNodeID(), CNcbiApplication::Instance(), SQueueParameters::kind, LOG_POST, m_DataPath, m_Diskless, m_DumpPath, m_MaxQueues, m_QueueClasses, m_Queues, m_Server, msg(), CJsonNode::NewObjectNode(), Note, CDiagContext_Extra::Print(), SQueueParameters::qclass, CNetScheduleServer::RegisterAlert(), CDir::Remove(), CNetScheduleServer::SerializeJobsStartIDs(), set< Key, Compare >::size(), string, Warning(), x_AppendDumpLinkedSections(), x_BackupDump(), x_CheckOpenPreconditions(), x_ConfigureQueues(), x_CreateAndMountQueue(), x_CreateCrashFlagFile(), x_CreateDumpErrorFlagFile(), x_CreateSpaceReserveFile(), x_CreateStorageVersionFile(), x_GetConfigQueues(), x_ReadDumpQueueDesrc(), x_ReadIniFileQueueClassDescriptions(), x_ReadIniFileQueueDescriptions(), x_ReadLinkedSections(), and x_RemoveDump().

Referenced by CQueueDataBase().

◆ x_OptimizeStatusMatrix() ◆ x_PurgeQueue() bool CQueueDataBase::x_PurgeQueue ( CQueue &  queue, size_t  status_to_start, size_t  status_to_end, unsigned int  start_job_id, unsigned int  end_job_id, size_t  max_scanned, size_t  max_mark_deleted, const CNSPreciseTime &  current_time, size_t &  total_scanned, size_t &  total_mark_deleted  ) private ◆ x_PurgeUnconditional() unsigned int CQueueDataBase::x_PurgeUnconditional ( void  ) private ◆ x_ReadDumpQueueDesrc()

Definition at line 2597 of file queue_database.cpp.

References SQueueDescriptionDump::blacklist_time, SQueueParameters::blacklist_time, SQueueDescriptionDump::client_registry_min_admins, SQueueParameters::client_registry_min_admins, SQueueDescriptionDump::client_registry_min_readers, SQueueParameters::client_registry_min_readers, SQueueDescriptionDump::client_registry_min_submitters, SQueueParameters::client_registry_min_submitters, SQueueDescriptionDump::client_registry_min_unknowns, SQueueParameters::client_registry_min_unknowns, SQueueDescriptionDump::client_registry_min_worker_nodes, SQueueParameters::client_registry_min_worker_nodes, SQueueParameters::client_registry_timeout_admin, SQueueParameters::client_registry_timeout_reader, SQueueParameters::client_registry_timeout_submitter, SQueueParameters::client_registry_timeout_unknown, SQueueParameters::client_registry_timeout_worker_node, SQueueDescriptionDump::description, SQueueParameters::description, SQueueDescriptionDump::description_size, SQueueDescriptionDump::dump_aff_buffer_size, SQueueParameters::dump_aff_buffer_size, SQueueDescriptionDump::dump_buffer_size, SQueueParameters::dump_buffer_size, SQueueDescriptionDump::dump_client_buffer_size, SQueueParameters::dump_client_buffer_size, SQueueDescriptionDump::dump_group_buffer_size, SQueueParameters::dump_group_buffer_size, entries, CFile::Exists(), CDir::Exists(), f, SQueueDescriptionDump::failed_retries, SQueueParameters::failed_retries, CDir::fIgnoreRecursive, SOneStructDumpHeader::fixed_size, NStr::fSplit_MergeDelimiters, NStr::fSplit_Truncate, CDir::GetEntries(), set< Key, Compare >::insert(), SQueueDescriptionDump::is_queue, kEmptyStr, kQClassDescriptionFileName(), SQueueParameters::linked_sections, m_DumpPath, SQueueDescriptionDump::max_input_size, SQueueParameters::max_input_size, SQueueDescriptionDump::max_jobs_per_client, SQueueParameters::max_jobs_per_client, SQueueDescriptionDump::max_output_size, SQueueParameters::max_output_size, SQueueParameters::max_pending_read_wait_timeout, SQueueDescriptionDump::max_pending_wait_timeout, SQueueParameters::max_pending_wait_timeout, names, SQueueDescriptionDump::notif_handicap, SQueueParameters::notif_handicap, SQueueDescriptionDump::notif_hifreq_interval, SQueueParameters::notif_hifreq_interval, SQueueDescriptionDump::notif_hifreq_period, SQueueParameters::notif_hifreq_period, SQueueDescriptionDump::notif_lofreq_mult, SQueueParameters::notif_lofreq_mult, NULL, SQueueDescriptionDump::pending_timeout, SQueueParameters::pending_timeout, SQueueDescriptionDump::program_name, SQueueParameters::program_name, SQueueDescriptionDump::program_name_size, SQueueDescriptionDump::qclass, SQueueParameters::qclass, SQueueDescriptionDump::qclass_size, SQueueDescriptionDump::qname, SQueueDescriptionDump::qname_size, SOneStructDumpHeader::Read(), SQueueDescriptionDump::Read(), SQueueDescriptionDump::read_blacklist_time, SQueueParameters::read_blacklist_time, SQueueDescriptionDump::read_failed_retries, SQueueParameters::read_failed_retries, SQueueDescriptionDump::read_timeout, SQueueParameters::read_timeout, SQueueDescriptionDump::reader_hosts, SQueueParameters::reader_hosts, SQueueDescriptionDump::reader_hosts_size, SQueueDescriptionDump::reader_timeout, SQueueParameters::reader_timeout, SQueueDescriptionDump::run_timeout, SQueueParameters::run_timeout, SQueueDescriptionDump::scramble_job_keys, SQueueParameters::scramble_job_keys, NStr::Split(), NStr::SplitInTwo(), NStr::StartsWith(), string, SQueueDescriptionDump::subm_hosts, SQueueParameters::subm_hosts, SQueueDescriptionDump::subm_hosts_size, SQueueDescriptionDump::timeout, SQueueParameters::timeout, SQueueDescriptionDump::wnode_hosts, SQueueParameters::wnode_hosts, SQueueDescriptionDump::wnode_hosts_size, SQueueDescriptionDump::wnode_timeout, and SQueueParameters::wnode_timeout.

Referenced by x_Open().

◆ x_ReadIniFileQueueClassDescriptions() ◆ x_ReadIniFileQueueDescriptions() ◆ x_ReadLinkedSections()

Definition at line 390 of file queue_database.cpp.

References CJsonNode::AppendString(), map_checker< Container >::begin(), NStr::CompareNocase(), NStr::eCase, map_checker< Container >::end(), entries, IRegistry::EnumerateEntries(), IRegistry::EnumerateSections(), map_checker< Container >::find(), IRegistry::GetString(), ITERATE, kEmptyStr, kMaxQueueNameSize, m_LinkedSections, m_LinkedSectionsGuard, CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), CJsonNode::SetByKey(), NStr::SplitInTwo(), NStr::StartsWith(), and x_DetectChangesInLinkedSection().

Referenced by Configure(), and x_Open().

◆ x_RemoveCrashFlagFile() void CQueueDataBase::x_RemoveCrashFlagFile ( void  ) private ◆ x_RemoveDataFiles() void CQueueDataBase::x_RemoveDataFiles ( void  ) private

Definition at line 2433 of file queue_database.cpp.

References entries, CDir::Exists(), f, CDir::fIgnoreRecursive, CDir::GetEntries(), kCrashFlagFileName(), kDBStorageVersionFileName(), kDumpErrorFlagFileName(), kEmptyStr, kNodeIDFileName(), kPausedQueuesFilesName(), kRefuseSubmitFileName(), kStartJobIDsFileName(), and m_DataPath.

Referenced by Close(), and CQueueDataBase().

◆ x_RemoveDump() void CQueueDataBase::x_RemoveDump ( void  ) private ◆ x_RemoveDumpErrorFlagFile() void CQueueDataBase::x_RemoveDumpErrorFlagFile ( void  ) private ◆ x_RemoveSpaceReserveFile() bool CQueueDataBase::x_RemoveSpaceReserveFile ( void  ) private ◆ x_RestorePauseState() void CQueueDataBase::x_RestorePauseState ( const map< string, int > &  paused_queues ) private ◆ x_RestoreRefuseSubmitState() void CQueueDataBase::x_RestoreRefuseSubmitState ( const vector< string > &  refuse_submit_queues ) private ◆ x_SingleQueueInfo()

Definition at line 1154 of file queue_database.cpp.

References SQueueParameters::aff_slots_used, SQueueParameters::clients, SQueueParameters::gc_backlog, CNetScheduleServer::GetAffRegistrySettings(), CNetScheduleServer::GetGroupRegistrySettings(), CNetScheduleServer::GetScopeRegistrySettings(), SQueueParameters::group_slots_used, SQueueParameters::groups, m_Server, SQueueParameters::max_aff_slots, SQueueParameters::max_group_slots, SNSRegistryParameters::max_records, SQueueParameters::max_scope_slots, SQueueParameters::notif_count, SQueueParameters::pause_status, SQueueParameters::refuse_submits, and SQueueParameters::scope_slots_used.

Referenced by GetQueueInfo(), and QueueInfo().

◆ x_ValidateConfiguration() void CQueueDataBase::x_ValidateConfiguration ( const TQueueParams &  queues_from_ini ) const private ◆ m_ConfigureLock

Definition at line 176 of file queue_database.hpp.

Referenced by AnyJobs(), Configure(), CountActiveJobs(), CountAllJobs(), CreateDynamicQueue(), DeleteDynamicQueue(), GetPauseQueues(), GetQueueClassesConfig(), GetQueueClassesInfo(), GetQueueConfig(), GetQueueInfo(), GetQueueNames(), GetRefuseSubmitQueues(), OpenQueue(), PrintJobCounters(), PrintJobsStat(), PrintStatistics(), PrintTransitionCounters(), QueueExists(), QueueInfo(), x_DeleteQueuesAndClasses(), x_GetFirst(), x_GetLastPurged(), x_GetNext(), x_GetQueueAt(), x_RestorePauseState(), and x_RestoreRefuseSubmitState().

◆ m_DataPath string CQueueDataBase::m_DataPath private

Definition at line 171 of file queue_database.hpp.

Referenced by CQueueDataBase(), GetDataPath(), x_CheckOpenPreconditions(), x_CreateCrashFlagFile(), x_CreateDumpErrorFlagFile(), x_CreateStorageVersionFile(), x_DoesCrashFlagFileExist(), x_DoesDumpErrorFlagFileExist(), x_Open(), x_RemoveCrashFlagFile(), x_RemoveDataFiles(), and x_RemoveDumpErrorFlagFile().

◆ m_Diskless bool CQueueDataBase::m_Diskless private ◆ m_DumpPath string CQueueDataBase::m_DumpPath private ◆ m_ExeWatchThread ◆ m_FreeStatusMemCnt unsigned int CQueueDataBase::m_FreeStatusMemCnt private ◆ m_Host ◆ m_LastFreeMem time_t CQueueDataBase::m_LastFreeMem private ◆ m_LinkedSections ◆ m_LinkedSectionsGuard ◆ m_MaxQueues unsigned int CQueueDataBase::m_MaxQueues private ◆ m_NotifThread ◆ m_PurgeJobScanned unsigned int CQueueDataBase::m_PurgeJobScanned private ◆ m_PurgeLock ◆ m_PurgeQueue string CQueueDataBase::m_PurgeQueue private ◆ m_PurgeStatusIndex size_t CQueueDataBase::m_PurgeStatusIndex private ◆ m_PurgeThread ◆ m_QueueClasses ◆ m_Queues

Definition at line 181 of file queue_database.hpp.

Referenced by AnyJobs(), CalculateRuntimePrecision(), Close(), Configure(), CountActiveJobs(), CountAllJobs(), CreateDynamicQueue(), DeleteDynamicQueue(), GetPauseQueues(), GetQueueConfig(), GetQueueInfo(), GetQueueNames(), GetRefuseSubmitQueues(), OpenQueue(), PrintJobCounters(), PrintJobsStat(), PrintStatistics(), PrintTransitionCounters(), QueueExists(), QueueInfo(), x_ConfigureQueues(), x_CountQueuesToAdd(), x_CreateAndMountQueue(), x_DeleteQueuesAndClasses(), x_Dump(), x_GetFirst(), x_GetLastPurged(), x_GetNext(), x_GetQueueAt(), x_Open(), x_RestorePauseState(), x_RestoreRefuseSubmitState(), and x_ValidateConfiguration().

◆ m_Server

Definition at line 193 of file queue_database.hpp.

Referenced by Close(), CQueueDataBase(), CreateDynamicQueue(), Purge(), RunExecutionWatcherThread(), RunNotifThread(), RunPurgeThread(), RunServiceThread(), x_CheckOpenPreconditions(), x_CreateAndMountQueue(), x_CreateSpaceReserveFile(), x_Open(), x_PurgeUnconditional(), x_RemoveSpaceReserveFile(), x_RestoreRefuseSubmitState(), and x_SingleQueueInfo().

◆ m_ServiceThread ◆ m_StopPurge bool CQueueDataBase::m_StopPurge private

The 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