src/app/netschedule/ns_queue.hpp File Reference

#include <corelib/ncbistl.hpp>
#include <corelib/ncbireg.hpp>
#include <util/thread_nonstop.hpp>
#include <util/time_line.hpp>
#include <connect/server_monitor.hpp>
#include "ns_types.hpp"
#include "ns_util.hpp"
#include "ns_format.hpp"
#include "ns_db.hpp"
#include "background_host.hpp"
#include "job.hpp"
#include "worker_node.hpp"
#include "job_status.hpp"
#include "queue_vc.hpp"
#include "access_list.hpp"
#include "ns_affinity.hpp"
#include <deque>
#include <map>

Include dependency graph for ns_queue.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	SQueueDbBlock
	Queue databases. More...
class	CQueueDbBlockArray
struct	SQueueParameters
	Queue parameters. More...
class	CNSTagMap
struct	SFieldsDescription
class	CQueueEnumCursor
class	CQueue
	Mutex protected Queue database with job status FSM. More...
class	CQueue::CStatisticsThread
class	CQueueParamAccessor
class	CNS_Transaction
class	CQueueGuard
class	CQueueJSGuard
Defines
#define	m_JobDB   m_QueueDbBlock->job_db
#define	m_JobInfoDB   m_QueueDbBlock->job_info_db
#define	m_RunsDB   m_QueueDbBlock->runs_db
#define	m_AffinityIdx   m_QueueDbBlock->affinity_idx
#define	m_TagDB   m_QueueDbBlock->tag_db
#define	m_DeletedJobsDB   m_QueueDbBlock->deleted_jobs_db
	Database for vectors of deleted jobs.
Typedefs
typedef deque< unsigned >	TNSShortIntSet
typedef map< TNSTag, TNSShortIntSet * >	TNSTagMap
typedef CTimeLine< TNSBitVector >	CJobTimeLine

---

Define Documentation

#define m_AffinityIdx   m_QueueDbBlock->affinity_idx

Definition at line 709 of file ns_queue.hpp. Referenced by CQueue::AddJobsToAffinity(), CQueue::ClearAffinityIdx(), CQueue::GetAffinityList(), CQueue::GetJobsWithAffinities(), CQueue::GetJobsWithAffinity(), and CQueue::x_ReadAffIdx_NoLock().

#define m_DeletedJobsDB   m_QueueDbBlock->deleted_jobs_db

Database for vectors of deleted jobs. Definition at line 743 of file ns_queue.hpp. Referenced by CQueue::FlushDeletedVectors(), and CQueue::LoadStatusMatrix().

#define m_JobDB   m_QueueDbBlock->job_db

Definition at line 697 of file ns_queue.hpp. Referenced by CQueue::CountRecs(), and CQueue::PrintStat().

#define m_JobInfoDB   m_QueueDbBlock->job_info_db

Definition at line 699 of file ns_queue.hpp.

#define m_RunsDB   m_QueueDbBlock->runs_db

Definition at line 702 of file ns_queue.hpp. Referenced by CQueue::GetRunsCursor().

#define m_TagDB   m_QueueDbBlock->tag_db

Definition at line 719 of file ns_queue.hpp. Referenced by CQueue::FlushTags(), CQueue::ReadTag(), CQueue::ReadTags(), CQueue::SetTagDbTransaction(), and CQueue::x_RemoveTags().

---

Typedef Documentation

typedef CTimeLine<TNSBitVector> CJobTimeLine

Definition at line 206 of file ns_queue.hpp.

typedef deque<unsigned> TNSShortIntSet

Definition at line 153 of file ns_queue.hpp.

typedef map<TNSTag, TNSShortIntSet*> TNSTagMap

Definition at line 154 of file ns_queue.hpp.

---