CQueue Class Reference

Search Toolkit Book for CQueue

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

Inheritance diagram for CQueue:

Collaboration diagram for CQueue:

Classes
struct	x_SJobPick

Public Types
enum	EQueueKind { eKindStatic = 0 , eKindDynamic = 1 }
enum	EPauseStatus { eNoPause = 0 , ePauseWithPullback = 1 , ePauseWithoutPullback = 2 }
enum	EJobReturnOption { eWithBlacklist = 0 , eWithoutBlacklist = 1 , eRollback = 2 }
typedef int	TQueueKind
typedef int	TPauseStatus
typedef int	TJobReturnOption
typedef list< pair< string, string > >	TParameterList
Public Types inherited from CObject
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
	CQueue (const string &queue_name, TQueueKind queue_kind, CNetScheduleServer *server, CQueueDataBase &qdb)
	~CQueue ()
void	Attach (void)
TQueueKind	GetQueueKind (void) const
void	SetParameters (const SQueueParameters &params)
TParameterList	GetParameters () const
CNSPreciseTime	GetTimeout () const
CNSPreciseTime	GetRunTimeout () const
CNSPreciseTime	GetReadTimeout () const
CNSPreciseTime	GetPendingTimeout () const
CNSPreciseTime	GetMaxPendingWaitTimeout () const
unsigned	GetFailedRetries () const
bool	IsSubmitAllowed (unsigned host) const
bool	IsWorkerAllowed (unsigned host) const
bool	IsReaderAllowed (unsigned host) const
bool	IsProgramAllowed (const string &program_name) const
void	GetMaxIOSizesAndLinkedSections (unsigned int &max_input_size, unsigned int &max_output_size, map< string, map< string, string > > &linked_sections) const
void	GetLinkedSections (map< string, map< string, string > > &linked_sections) const
bool	GetRefuseSubmits (void) const
void	SetRefuseSubmits (bool val)
size_t	GetAffSlotsUsed (void) const
size_t	GetGroupSlotsUsed (void) const
size_t	GetScopeSlotsUsed (void) const
size_t	GetClientsCount (void) const
size_t	GetGroupsCount (void) const
size_t	GetNotifCount (void) const
size_t	GetGCBacklogCount (void) const
const string &	GetQueueName () const
string	DecorateJob (unsigned int job_id) const
unsigned int	Submit (const CNSClientId &client, CJob &job, const string &aff_token, const string &group, bool logging, CNSRollbackInterface *&rollback_action)
unsigned	SubmitBatch (const CNSClientId &client, vector< pair< CJob, string > > &batch, const string &group, bool logging, CNSRollbackInterface *&rollback_action)
TJobStatus	PutResult (const CNSClientId &client, const CNSPreciseTime &curr, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, int ret_code, const string &output)
bool	GetJobOrWait (const CNSClientId &client, unsigned short port, unsigned int timeout, const list< string > *aff_list, bool wnode_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, bool new_format, const list< string > *group_list, CJob *new_job, CNSRollbackInterface *&rollback_action, string &added_pref_aff)
void	CancelWaitGet (const CNSClientId &client)
void	CancelWaitRead (const CNSClientId &client)
list< string >	ChangeAffinity (const CNSClientId &client, const list< string > &aff_to_add, const list< string > &aff_to_del, ECommandGroup cmd_group)
void	SetAffinity (const CNSClientId &client, const list< string > &aff, ECommandGroup cmd_group)
int	SetClientData (const CNSClientId &client, const string &data, int data_version)
TJobStatus	JobDelayExpiration (unsigned int job_id, CJob &job, const CNSPreciseTime &tm)
TJobStatus	JobDelayReadExpiration (unsigned int job_id, CJob &job, const CNSPreciseTime &tm)
TJobStatus	GetStatusAndLifetime (unsigned int job_id, string &client_ip, string &client_sid, string &client_phid, string &progress_msg, CNSPreciseTime *lifetime)
TJobStatus	GetStatusAndLifetimeAndTouch (unsigned int job_id, CJob &job, CNSPreciseTime *lifetime)
TJobStatus	SetJobListener (unsigned int job_id, CJob &job, unsigned int address, unsigned short port, const CNSPreciseTime &timeout, bool need_stolen, bool need_progress_msg, size_t *last_event_index)
bool	PutProgressMessage (unsigned int job_id, CJob &job, const string &msg)
TJobStatus	ReturnJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, string &warning, TJobReturnOption how)
TJobStatus	RescheduleJob (const CNSClientId &client, unsigned int job_id, const string &job_key, const string &auth_token, const string &aff_token, const string &group, bool &auth_token_ok, CJob &job)
TJobStatus	RedoJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job)
TJobStatus	ReadAndTouchJob (unsigned int job_id, CJob &job, CNSPreciseTime *lifetime)
TJobStatus	Cancel (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, bool is_ns_rollback=false)
unsigned int	CancelAllJobs (const CNSClientId &client, bool logging)
unsigned int	CancelSelectedJobs (const CNSClientId &client, const string &group, const string &aff_token, const vector< TJobStatus > &statuses, bool logging, vector< string > &warnings)
TJobStatus	GetJobStatus (unsigned job_id) const
bool	IsEmpty () const
unsigned int	GetNextId ()
unsigned int	GetNextJobIdForBatch (unsigned count)
bool	GetJobForReadingOrWait (const CNSClientId &client, unsigned int port, unsigned int timeout, const list< string > *aff_list, bool reader_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, const list< string > *group_list, bool affinity_may_change, bool group_may_change, CJob *job, bool *no_more_jobs, CNSRollbackInterface *&rollback_action, string &added_pref_aff)
TJobStatus	ConfirmReadingJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token)
TJobStatus	FailReadingJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, const string &err_msg, bool no_retries)
TJobStatus	ReturnReadingJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, bool is_ns_rollback, bool blacklist, TJobStatus target_status)
TJobStatus	RereadJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, bool &no_op)
void	EraseJob (unsigned job_id, TJobStatus status)
void	OptimizeMem ()
TJobStatus	FailJob (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, const string &err_msg, const string &output, int ret_code, bool no_retries, string warning)
string	GetAffinityTokenByID (unsigned int aff_id) const
void	ClearWorkerNode (const CNSClientId &client, bool &client_was_found, string &old_session, bool &had_wn_pref_affs, bool &had_reader_pref_affs)
void	NotifyListenersPeriodically (const CNSPreciseTime &current_time)
CNSPreciseTime	NotifyExactListeners (void)
string	PrintClientsList (bool verbose) const
string	PrintNotificationsList (bool verbose) const
string	PrintAffinitiesList (const CNSClientId &client, bool verbose) const
string	PrintGroupsList (const CNSClientId &client, bool verbose) const
string	PrintScopesList (bool verbose) const
void	CheckExecutionTimeout (bool logging)
SPurgeAttributes	CheckJobsExpiry (const CNSPreciseTime &current_time, SPurgeAttributes attributes, unsigned int last_job, TJobStatus status)
void	TimeLineMove (unsigned int job_id, const CNSPreciseTime &old_time, const CNSPreciseTime &new_time)
void	TimeLineAdd (unsigned int job_id, const CNSPreciseTime &job_time)
void	TimeLineRemove (unsigned int job_id)
void	TimeLineExchange (unsigned int remove_job_id, unsigned int add_job_id, const CNSPreciseTime &new_time)
unsigned int	DeleteBatch (unsigned int max_deleted)
unsigned int	PurgeAffinities (void)
unsigned int	PurgeGroups (void)
void	StaleNodes (const CNSPreciseTime &current_time)
void	PurgeBlacklistedJobs (void)
void	PurgeClientRegistry (const CNSPreciseTime &current_time)
string	PrintJobDbStat (const CNSClientId &client, unsigned int job_id, TDumpFields dump_fields)
string	PrintAllJobDbStat (const CNSClientId &client, const string &group, const string &aff_token, const vector< TJobStatus > &job_statuses, unsigned int start_after_job_id, unsigned int count, bool order_first, TDumpFields dump_fields, bool logging)
unsigned	CountStatus (TJobStatus) const
void	StatusStatistics (TJobStatus status, TNSBitVector::statistics *st) const
string	MakeJobKey (unsigned int job_id) const
void	TouchClientsRegistry (CNSClientId &client, bool &client_was_found, bool &session_was_reset, string &old_session, bool &had_wn_pref_affs, bool &had_reader_pref_affs)
void	MarkClientAsAdmin (const CNSClientId &client)
void	RegisterSocketWriteError (const CNSClientId &client)
void	SetClientScope (const CNSClientId &client)
void	PrintStatistics (size_t &aff_count) const
void	PrintJobCounters (void) const
unsigned int	GetJobsToDeleteCount (void) const
string	PrintTransitionCounters (void) const
string	PrintJobsStat (const CNSClientId &client, const string &group_token, const string &aff_token, vector< string > &warnings) const
void	GetJobsPerState (const CNSClientId &client, const string &group_token, const string &aff_token, size_t *jobs, vector< string > &warnings) const
void	CountTransition (CNetScheduleAPI::EJobStatus from, CNetScheduleAPI::EJobStatus to)
unsigned int	CountActiveJobs (void) const
unsigned int	CountAllJobs (void) const
bool	AnyJobs (void) const
TPauseStatus	GetPauseStatus (void) const
void	SetPauseStatus (const CNSClientId &client, TPauseStatus status)
void	RestorePauseStatus (TPauseStatus status)
void	RegisterQueueResumeNotification (unsigned int address, unsigned short port, bool new_format)
void	Dump (const string &dump_dir_name)
void	RemoveDump (const string &dump_dir_name)
unsigned int	LoadFromDump (const string &dump_dir_name)
bool	ShouldPerfLogTransitions (void) const
void	UpdatePerfLoggingSettings (const string &qclass)
Public Member Functions inherited from CObjectEx
	CObjectEx (void)
virtual	~CObjectEx (void)
Public Member Functions inherited from CObject
	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...
Public Member Functions inherited from CDebugDumpable
	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
Public Member Functions inherited from CWeakObject
	CWeakObject (void)
virtual	~CWeakObject (void)
CPtrToObjectProxy *	GetPtrProxy (void) const
	Get pointer to proxy object containing pointer to this object. More...

Private Member Functions
TJobStatus	x_ChangeReadingStatus (const CNSClientId &client, unsigned int job_id, const string &job_key, CJob &job, const string &auth_token, const string &err_msg, TJobStatus target_status, bool is_ns_rollback, bool no_retries)
x_SJobPick	x_FindVacantJob (const CNSClientId &client, const TNSBitVector &explicit_affs, const vector< unsigned int > &aff_ids, bool use_pref_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, const TNSBitVector &group_ids, bool has_groups, ECommandGroup cmd_group)
x_SJobPick	x_FindVacantJob (const CNSClientId &client, const TNSBitVector &explicit_affs, const vector< unsigned int > &aff_ids, bool use_pref_affinity, bool any_affinity, bool exclusive_new_affinity, bool prioritized_aff, const TNSBitVector &group_ids, bool has_groups, ECommandGroup cmd_group, const string &scope)
map< string, size_t >	x_GetRunningJobsPerClientIP (void)
bool	x_ValidateMaxJobsPerClientIP (unsigned int job_id, const map< string, size_t > &jobs_per_client_ip) const
x_SJobPick	x_FindOutdatedPendingJob (const CNSClientId &client, unsigned int picked_earlier, const TNSBitVector &group_ids)
x_SJobPick	x_FindOutdatedPendingJob (const CNSClientId &client, unsigned int picked_earlier, const TNSBitVector &group_ids, const string &scope)
x_SJobPick	x_FindOutdatedJobForReading (const CNSClientId &client, unsigned int picked_earlier, const TNSBitVector &group_ids)
x_SJobPick	x_FindOutdatedJobForReading (const CNSClientId &client, unsigned int picked_earlier, const TNSBitVector &group_ids, const string &scope)
void	x_UpdateDB_PutResultNoLock (unsigned job_id, const string &auth_token, const CNSPreciseTime &curr, int ret_code, const string &output, CJob &job, const CNSClientId &client)
void	x_UpdateDB_ProvideJobNoLock (const CNSClientId &client, const CNSPreciseTime &curr, unsigned int job_id, ECommandGroup cmd_group, CJob &job)
void	x_CheckExecutionTimeout (const CNSPreciseTime &queue_run_timeout, const CNSPreciseTime &queue_read_timeout, unsigned job_id, const CNSPreciseTime &curr_time, bool logging)
void	x_LogSubmit (const CJob &job)
void	x_ResetRunningDueToClear (const CNSClientId &client, const TNSBitVector &jobs)
void	x_ResetReadingDueToClear (const CNSClientId &client, const TNSBitVector &jobs)
void	x_ResetRunningDueToNewSession (const CNSClientId &client, const TNSBitVector &jobs)
void	x_ResetReadingDueToNewSession (const CNSClientId &client, const TNSBitVector &jobs)
TJobStatus	x_ResetDueTo (const CNSClientId &client, unsigned int job_id, const CNSPreciseTime &current_time, TJobStatus status_from, CJobEvent::EJobEvent event_type)
void	x_RegisterGetListener (const CNSClientId &client, unsigned short port, unsigned int timeout, const TNSBitVector &aff_ids, bool wnode_aff, bool any_aff, bool exclusive_new_affinity, bool new_format, const TNSBitVector &group_ids)
void	x_RegisterReadListener (const CNSClientId &client, unsigned short port, unsigned int timeout, const TNSBitVector &aff_ids, bool reader_aff, bool any_aff, bool exclusive_new_affinity, const TNSBitVector &group_ids)
bool	x_UnregisterGetListener (const CNSClientId &client, unsigned short port)
void	x_Erase (const TNSBitVector &job_ids, TJobStatus status)
	Erase jobs from all structures, request delayed db deletion. More...
string	x_DumpJobs (const TNSBitVector &jobs_to_dump, unsigned int start_after_job_id, unsigned int count, TDumpFields dump_fields, bool order_first)
unsigned int	x_CancelJobs (const CNSClientId &client, const TNSBitVector &jobs_to_cancel, bool logging)
CNSPreciseTime	x_GetEstimatedJobLifetime (unsigned int job_id, TJobStatus status) const
bool	x_NoMoreReadJobs (const CNSClientId &client, const TNSBitVector &aff_list, bool reader_affinity, bool any_affinity, bool exclusive_new_affinity, const TNSBitVector &group_list, bool affinity_may_change, bool group_may_change)
string	x_GetJobsDumpFileName (const string &dump_dname) const
void	x_ClearQueue (void)
void	x_NotifyJobChanges (const CJob &job, const string &job_key, ENotificationReason reason, const CNSPreciseTime &current_time)

Private Attributes
CNetScheduleServer *	m_Server
CJobStatusTracker	m_StatusTracker
CQueueDataBase &	m_QueueDB
map< unsigned int, CJob >	m_Jobs
CJobTimeLine *	m_RunTimeLine
CRWLock	m_RunTimeLineLock
string	m_QueueName
TQueueKind	m_Kind
CFastMutex	m_OperationLock
CNSClientsRegistry	m_ClientsRegistry
CNSAffinityRegistry	m_AffinityRegistry
unsigned int	m_LastId
unsigned int	m_SavedId
CFastMutex	m_LastIdLock
CFastMutex	m_JobsToDeleteLock
TNSBitVector	m_JobsToDelete
unsigned int	m_JobsToDeleteOps
TNSBitVector	m_ReadJobs
unsigned int	m_ReadJobsOps
CFastMutex	m_ParamLock
CNSPreciseTime	m_Timeout
CNSPreciseTime	m_RunTimeout
CNSPreciseTime	m_ReadTimeout
unsigned	m_FailedRetries
unsigned	m_ReadFailedRetries
unsigned	m_MaxJobsPerClient
CNSPreciseTime	m_BlacklistTime
CNSPreciseTime	m_ReadBlacklistTime
unsigned	m_MaxInputSize
unsigned	m_MaxOutputSize
CNSPreciseTime	m_WNodeTimeout
CNSPreciseTime	m_ReaderTimeout
CNSPreciseTime	m_PendingTimeout
CNSPreciseTime	m_MaxPendingWaitTimeout
CNSPreciseTime	m_MaxPendingReadWaitTimeout
CQueueClientInfoList	m_ProgramVersionList
CNetScheduleAccessList	m_SubmHosts
CNetScheduleAccessList	m_WnodeHosts
CNetScheduleAccessList	m_ReaderHosts
CNetScheduleKeyGenerator	m_KeyGenerator
const bool &	m_Log
const bool &	m_LogBatchEachJob
bool	m_RefuseSubmits
CStatisticsCounters	m_StatisticsCounters
CStatisticsCounters	m_StatisticsCountersLastPrinted
CNSPreciseTime	m_StatisticsCountersLastPrintedTimestamp
CNSNotificationList	m_NotificationsList
CNSPreciseTime	m_NotifHifreqInterval
CNSPreciseTime	m_NotifHifreqPeriod
unsigned int	m_NotifLofreqMult
CNSPreciseTime	m_HandicapTimeout
unsigned int	m_DumpBufferSize
unsigned int	m_DumpClientBufferSize
unsigned int	m_DumpAffBufferSize
unsigned int	m_DumpGroupBufferSize
bool	m_ScrambleJobKeys
map< string, string >	m_LinkedSections
CNSGroupsRegistry	m_GroupRegistry
CJobGCRegistry	m_GCRegistry
TPauseStatus	m_PauseStatus
CNSPreciseTime	m_ClientRegistryTimeoutWorkerNode
unsigned int	m_ClientRegistryMinWorkerNodes
CNSPreciseTime	m_ClientRegistryTimeoutAdmin
unsigned int	m_ClientRegistryMinAdmins
CNSPreciseTime	m_ClientRegistryTimeoutSubmitter
unsigned int	m_ClientRegistryMinSubmitters
CNSPreciseTime	m_ClientRegistryTimeoutReader
unsigned int	m_ClientRegistryMinReaders
CNSPreciseTime	m_ClientRegistryTimeoutUnknown
unsigned int	m_ClientRegistryMinUnknowns
CNSScopeRegistry	m_ScopeRegistry
bool	m_ShouldPerfLogTransitions
vector< CNetScheduleAPI::EJobStatus >	m_StatesForRead

Friends
class	CJob
class	CQueueParamAccessor

Additional Inherited Members
Static Public Member Functions inherited from CObject
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 Public Member Functions inherited from CDebugDumpable
static void	EnableDebugDump (bool on)
Static Public Attributes inherited from CObject
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...
Protected Member Functions inherited from CObject
virtual void	DeleteThis (void)
	Virtual method "deleting" this object. More...
Protected Member Functions inherited from CWeakObject
void	CleanWeakRefs (void) const
	Method cleaning all CWeakRefs referencing at this moment to the object After calling to this method all existing CWeakRefs referencing to the object will return NULL, so it effectively will be equal to deleting the object. More...

Detailed Description

Definition at line 79 of file ns_queue.hpp.

Member Typedef Documentation

TJobReturnOption

typedef int CQueue::TJobReturnOption

Definition at line 102 of file ns_queue.hpp.

TParameterList

typedef list<pair<string, string> > CQueue::TParameterList

Definition at line 116 of file ns_queue.hpp.

TPauseStatus

typedef int CQueue::TPauseStatus

Definition at line 94 of file ns_queue.hpp.

TQueueKind

typedef int CQueue::TQueueKind

Definition at line 86 of file ns_queue.hpp.

Member Enumeration Documentation

EJobReturnOption

enum CQueue::EJobReturnOption

Enumerator
eWithBlacklist
eWithoutBlacklist
eRollback

Definition at line 97 of file ns_queue.hpp.

EPauseStatus

enum CQueue::EPauseStatus

Enumerator
eNoPause
ePauseWithPullback
ePauseWithoutPullback

Definition at line 89 of file ns_queue.hpp.

EQueueKind

enum CQueue::EQueueKind

Enumerator
eKindStatic
eKindDynamic

Definition at line 82 of file ns_queue.hpp.

Constructor & Destructor Documentation

CQueue()

CQueue::CQueue	(	const string &	queue_name,
		TQueueKind	queue_kind,
		CNetScheduleServer *	server,
		CQueueDataBase &	qdb
	)

Definition at line 66 of file ns_queue.cpp.

References _ASSERT, CNetScheduleAPI::eCanceled, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, m_AffinityRegistry, m_ClientsRegistry, m_NotificationsList, m_StatesForRead, and CNSClientsRegistry::SetRegistries().

~CQueue()

CQueue::~CQueue

(

)

Definition at line 139 of file ns_queue.cpp.

References m_RunTimeLine.

Member Function Documentation

AnyJobs()

bool CQueue::AnyJobs ( void  ) const

inline

Definition at line 452 of file ns_queue.hpp.

References CJobStatusTracker::AnyJobs(), and m_StatusTracker.

Attach()

void CQueue::Attach

(

void

)

Definition at line 145 of file ns_queue.cpp.

References CNetScheduleServer::GetJobsStartID(), m_LastId, m_QueueName, m_SavedId, m_Server, s_ReserveDelta, and CNetScheduleServer::SetJobsStartID().

Cancel()

TJobStatus CQueue::Cancel	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		bool	is_ns_rollback = false
	)

Definition at line 1678 of file ns_queue.cpp.

References client, CStatisticsCounters::CountNSSubmitRollback(), CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), CJobEvent::eCancel, CNetScheduleAPI::eCanceled, eGet, CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CJobEvent::eNSSubmitRollback, eRead, CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), CJobStatusTracker::GetStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PendingTimeout, m_ReadJobs, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, CNSNotificationList::Notify(), CJobEvent::SetNodeAddr(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), and x_NotifyJobChanges().

Referenced by CNSSubmitRollback::Rollback(), CNSBatchSubmitRollback::Rollback(), and CNetScheduleHandler::x_ProcessCancel().

CancelAllJobs()

unsigned int CQueue::CancelAllJobs	(	const CNSClientId &	client,
		bool	logging
	)

Definition at line 1761 of file ns_queue.cpp.

References client, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, CJobStatusTracker::GetJobs(), m_OperationLock, m_StatusTracker, and x_CancelJobs().

Referenced by CNetScheduleHandler::x_ProcessCancelQueue(), and CNetScheduleHandler::x_ProcessDropQueue().

CancelSelectedJobs()

unsigned int CQueue::CancelSelectedJobs	(	const CNSClientId &	client,
		const string &	group,
		const string &	aff_token,
		const vector< TJobStatus > &	statuses,
		bool	logging,
		vector< string > &	warnings
	)

Definition at line 1879 of file ns_queue.cpp.

References bm::bvector< Alloc >::clear(), client, CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, CNSAffinityRegistry::GetIDByToken(), CNSGroupsRegistry::GetJobs(), CJobStatusTracker::GetJobs(), CNSAffinityRegistry::GetJobsWithAffinity(), m_AffinityRegistry, m_GroupRegistry, m_OperationLock, m_StatusTracker, Warning(), and x_CancelJobs().

Referenced by CNetScheduleHandler::x_ProcessCancel().

CancelWaitGet()

void CQueue::CancelWaitGet

(

const CNSClientId &

client

)

Definition at line 905 of file ns_queue.cpp.

References client, ERR_POST, m_OperationLock, result, Warning(), and x_UnregisterGetListener().

Referenced by CNetScheduleHandler::x_ProcessCancelWaitGet().

CancelWaitRead()

void CQueue::CancelWaitRead

(

const CNSClientId &

client

)

Definition at line 923 of file ns_queue.cpp.

References CNSClientsRegistry::CancelWaiting(), client, eRead, ERR_POST, m_ClientsRegistry, m_OperationLock, result, and Warning().

Referenced by CNetScheduleHandler::x_ProcessCancelWaitRead().

ChangeAffinity()

list< string > CQueue::ChangeAffinity	(	const CNSClientId &	client,
		const list< string > &	aff_to_add,
		const list< string > &	aff_to_del,
		ECommandGroup	cmd_group
	)

Definition at line 942 of file ns_queue.cpp.

References CNSClientsRegistry::AppendType(), client, bm::bvector< Alloc >::count(), eGet, CNSClient::eReader, ERR_POST, CNSClient::eWorkerNode, bm::bvector< Alloc >::get_bit(), CNetScheduleServer::GetAffRegistrySettings(), CNSAffinityRegistry::GetIDByToken(), CNSClientsRegistry::GetPreferredAffinities(), m_AffinityRegistry, m_ClientsRegistry, m_OperationLock, m_Server, SNSRegistryParameters::max_records, NCBI_THROW, CNSAffinityRegistry::ResolveAffinityToken(), bm::bvector< Alloc >::set_bit(), CNSClientsRegistry::UpdatePreferredAffinities(), Warning(), and CNSClientsRegistry::WasGarbageCollected().

Referenced by CNetScheduleHandler::x_ProcessChangeAffinity().

CheckExecutionTimeout()

void CQueue::CheckExecutionTimeout

(

bool

logging

)

Definition at line 3310 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CTimeLine< BV >::ExtractObjects(), bm::bvector< Alloc >::first(), GetReadTimeout(), GetRunTimeout(), m_RunTimeLine, m_RunTimeLineLock, CNSPreciseTime::Sec(), bm::bvector< Alloc >::iterator_base::valid(), and x_CheckExecutionTimeout().

CheckJobsExpiry()

SPurgeAttributes CQueue::CheckJobsExpiry	(	const CNSPreciseTime &	current_time,
		SPurgeAttributes	attributes,
		unsigned int	last_job,
		TJobStatus	status
	)

Definition at line 3511 of file ns_queue.cpp.

References CJobStatusTracker::AnyPending(), attributes, CNSNotificationList::ClearExactGetNotifications(), CJobGCRegistry::DeleteIfTimedOut(), eJobDeleted, map_checker< Container >::end(), CNetScheduleAPI::ePending, CJobStatusTracker::Erase(), map_checker< Container >::find(), bm::bvector< Alloc >::first(), g_DoErasePerfLogging(), CJobStatusTracker::GetNext(), m_AffinityRegistry, m_GCRegistry, m_GroupRegistry, m_Jobs, m_NotificationsList, m_OperationLock, m_ScopeRegistry, m_StatusTracker, MakeJobKey(), CNSGroupsRegistry::RemoveJob(), CNSScopeRegistry::RemoveJob(), CNSAffinityRegistry::RemoveJobFromAffinity(), result, bm::bvector< Alloc >::set_bit(), bm::bvector< Alloc >::iterator_base::valid(), x_Erase(), and x_NotifyJobChanges().

Referenced by CQueueDataBase::x_PurgeQueue().

ClearWorkerNode()

void CQueue::ClearWorkerNode	(	const CNSClientId &	client,
		bool &	client_was_found,
		string &	old_session,
		bool &	had_wn_pref_affs,
		bool &	had_reader_pref_affs
	)

Definition at line 3157 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), CNSClientsRegistry::ClearClient(), client, m_ClientsRegistry, m_OperationLock, x_ResetReadingDueToClear(), and x_ResetRunningDueToClear().

Referenced by CNetScheduleHandler::x_ProcessClearWorkerNode().

ConfirmReadingJob()

TJobStatus CQueue::ConfirmReadingJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token
	)

Definition at line 2201 of file ns_queue.cpp.

References client, CNetScheduleAPI::eConfirmed, eRead, m_ClientsRegistry, CNSClientsRegistry::UnregisterJob(), and x_ChangeReadingStatus().

Referenced by CNetScheduleHandler::x_ProcessConfirm().

CountActiveJobs()

unsigned int CQueue::CountActiveJobs

(

void

)

const

Definition at line 4512 of file ns_queue.cpp.

References CJobStatusTracker::CountStatus(), CNetScheduleAPI::ePending, CNetScheduleAPI::eRunning, and m_StatusTracker.

CountAllJobs()

unsigned int CQueue::CountAllJobs ( void  ) const

inline

Definition at line 450 of file ns_queue.hpp.

References CJobStatusTracker::Count(), and m_StatusTracker.

CountStatus()

unsigned CQueue::CountStatus

(

TJobStatus

st

)

const

Definition at line 4042 of file ns_queue.cpp.

References CJobStatusTracker::CountStatus(), m_StatusTracker, and st().

Referenced by PrintStatistics(), and CNetScheduleHandler::x_ProcessStatistics().

CountTransition()

void CQueue::CountTransition ( CNetScheduleAPI::EJobStatus  from, CNetScheduleAPI::EJobStatus  to  )

inline

Definition at line 446 of file ns_queue.hpp.

References CStatisticsCounters::CountTransition(), and m_StatisticsCounters.

DecorateJob()

string CQueue::DecorateJob ( unsigned int  job_id ) const

inline

Definition at line 154 of file ns_queue.hpp.

References m_QueueName, and MakeJobKey().

Referenced by Dump(), x_CancelJobs(), x_ResetDueTo(), x_ResetReadingDueToClear(), x_ResetReadingDueToNewSession(), x_ResetRunningDueToClear(), and x_ResetRunningDueToNewSession().

DeleteBatch()

unsigned int CQueue::DeleteBatch

(

unsigned int

max_deleted

)

Definition at line 3639 of file ns_queue.cpp.

References chunk_size, CStatisticsCounters::CountDBDeletion(), map_checker< Container >::erase(), bm::bvector< Alloc >::first(), m_Jobs, m_JobsToDelete, m_JobsToDeleteLock, m_JobsToDeleteOps, m_OperationLock, m_ReadJobs, m_ReadJobsOps, m_StatisticsCounters, n, bm::bvector< Alloc >::opt_free_0, bm::bvector< Alloc >::optimize(), bm::bvector< Alloc >::set_bit(), and bm::bvector< Alloc >::iterator_base::valid().

Dump()

void CQueue::Dump

(

const string &

dump_dir_name

)

Definition at line 4638 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), DecorateJob(), CNSAffinityRegistry::Dump(), CNSGroupsRegistry::Dump(), CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, map_checker< Container >::end(), CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, map_checker< Container >::find(), bm::bvector< Alloc >::first(), CNSScopeRegistry::GetAllJobsInScopes(), CJobStatusTracker::GetJobs(), m_AffinityRegistry, m_GroupRegistry, m_Jobs, m_QueueName, m_ScopeRegistry, m_StatusTracker, NULL, RemoveDump(), bm::bvector< Alloc >::iterator_base::valid(), SJobDumpHeader::Write(), and x_GetJobsDumpFileName().

EraseJob()

void CQueue::EraseJob	(	unsigned	job_id,
		TJobStatus	status
	)

Definition at line 2472 of file ns_queue.cpp.

References CStatisticsCounters::CountTransitionToDeleted(), CJobStatusTracker::Erase(), m_JobsToDelete, m_JobsToDeleteLock, m_JobsToDeleteOps, m_StatisticsCounters, m_StatusTracker, bm::bvector< Alloc >::set_bit(), and TimeLineRemove().

FailJob()

TJobStatus CQueue::FailJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token,
		const string &	err_msg,
		const string &	output,
		int	ret_code,
		bool	no_retries,
		string	warning
	)

Definition at line 2987 of file ns_queue.cpp.

References client, CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), CJobEvent::eFail, CStatisticsCounters::eFail, CNetScheduleAPI::eFailed, CJobEvent::eFinalFail, eGet, CJob::eInvalidTokenFormat, map_checker< Container >::end(), CJob::eNoMatch, CStatisticsCounters::eNone, eNoPause, CJob::ePassportOnlyMatch, CNetScheduleAPI::ePending, eRead, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), CQueueParamAccessor::GetFailedRetries(), GetJobStatus(), CQueueParamAccessor::GetMaxOutputSize(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_Log, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadJobs, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), output, CNSClientsRegistry::RegisterBlacklistedJob(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), Warning(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessPutFailure().

FailReadingJob()

TJobStatus CQueue::FailReadingJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token,
		const string &	err_msg,
		bool	no_retries
	)

Definition at line 2217 of file ns_queue.cpp.

References client, eRead, CNetScheduleAPI::eReadFailed, m_ClientsRegistry, CNSClientsRegistry::MoveJobToBlacklist(), and x_ChangeReadingStatus().

Referenced by CNetScheduleHandler::x_ProcessReadFailed().

GetAffinityTokenByID()

string CQueue::GetAffinityTokenByID

(

unsigned int

aff_id

)

const

Definition at line 3151 of file ns_queue.cpp.

References CNSAffinityRegistry::GetTokenByID(), and m_AffinityRegistry.

Referenced by CNetScheduleHandler::x_PrintGetJobResponse(), and CNetScheduleHandler::x_ProcessReading().

GetAffSlotsUsed()

size_t CQueue::GetAffSlotsUsed ( void  ) const

inline

Definition at line 138 of file ns_queue.hpp.

References m_AffinityRegistry, and CNSAffinityRegistry::size().

GetClientsCount()

size_t CQueue::GetClientsCount ( void  ) const

inline

Definition at line 141 of file ns_queue.hpp.

References m_ClientsRegistry, and CNSClientsRegistry::size().

GetFailedRetries()

unsigned CQueue::GetFailedRetries ( ) const

inline

Definition at line 780 of file ns_queue.hpp.

References m_FailedRetries.

GetGCBacklogCount()

size_t CQueue::GetGCBacklogCount ( void  ) const

inline

Definition at line 144 of file ns_queue.hpp.

References bm::bvector< Alloc >::count(), m_JobsToDelete, and m_JobsToDeleteLock.

GetGroupsCount()

size_t CQueue::GetGroupsCount ( void  ) const

inline

Definition at line 142 of file ns_queue.hpp.

References m_GroupRegistry, and CNSGroupsRegistry::size().

GetGroupSlotsUsed()

size_t CQueue::GetGroupSlotsUsed ( void  ) const

inline

Definition at line 139 of file ns_queue.hpp.

References m_GroupRegistry, and CNSGroupsRegistry::size().

GetJobForReadingOrWait()

bool CQueue::GetJobForReadingOrWait	(	const CNSClientId &	client,
		unsigned int	port,
		unsigned int	timeout,
		const list< string > *	aff_list,
		bool	reader_affinity,
		bool	any_affinity,
		bool	exclusive_new_affinity,
		bool	prioritized_aff,
		const list< string > *	group_list,
		bool	affinity_may_change,
		bool	group_may_change,
		CJob *	job,
		bool *	no_more_jobs,
		CNSRollbackInterface *&	rollback_action,
		string &	added_pref_aff
	)

Definition at line 2011 of file ns_queue.cpp.

References CQueue::x_SJobPick::aff_id, CNSClientsRegistry::AppendType(), CNSClientsRegistry::CancelWaiting(), client, CStatisticsCounters::CountOutdatedPick(), CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), CNetScheduleAPI::eCanceled, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, eRead, CNSClient::eReader, CNetScheduleAPI::eReading, eStatusChanged, CQueue::x_SJobPick::exclusive, g_DoPerfLogging(), CNSClientsRegistry::GetAffinityReset(), CJob::GetExpirationTime(), GetJobStatus(), CNSAffinityRegistry::GetTokenByID(), CJobGCRegistry::IsOutdatedJob(), CNSClientsRegistry::IsPreferredByAny(), CQueue::x_SJobPick::job_id, k_NoAffinityToken, m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_MaxPendingReadWaitTimeout, m_OperationLock, m_PendingTimeout, m_ReadJobs, m_ReadJobsOps, m_ReadTimeout, m_RunTimeout, m_StatisticsCounters, m_StatusTracker, m_Timeout, MakeJobKey(), NULL, CNSClientsRegistry::RegisterJob(), CNSAffinityRegistry::ResolveAffinities(), CNSGroupsRegistry::ResolveGroups(), bm::bvector< Alloc >::set_bit(), CJobStatusTracker::SetStatus(), TimeLineAdd(), CJobGCRegistry::UpdateLifetime(), CNSClientsRegistry::UpdatePreferredAffinities(), CNSClientsRegistry::WasGarbageCollected(), x_FindOutdatedJobForReading(), x_FindVacantJob(), x_NoMoreReadJobs(), x_NotifyJobChanges(), x_RegisterReadListener(), and x_UpdateDB_ProvideJobNoLock().

Referenced by CNetScheduleHandler::x_ProcessReading().

GetJobOrWait()

bool CQueue::GetJobOrWait	(	const CNSClientId &	client,
		unsigned short	port,
		unsigned int	timeout,
		const list< string > *	aff_list,
		bool	wnode_affinity,
		bool	any_affinity,
		bool	exclusive_new_affinity,
		bool	prioritized_aff,
		bool	new_format,
		const list< string > *	group_list,
		CJob *	new_job,
		CNSRollbackInterface *&	rollback_action,
		string &	added_pref_aff
	)

Definition at line 717 of file ns_queue.cpp.

References CQueue::x_SJobPick::aff_id, CJobStatusTracker::AnyPending(), CNSClientsRegistry::AppendType(), CNSNotificationList::ClearExactGetNotifications(), client, CStatisticsCounters::CountOutdatedPick(), CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), eGet, CNetScheduleAPI::ePending, CNetScheduleAPI::eRunning, eStatusChanged, CNSClient::eWorkerNode, CQueue::x_SJobPick::exclusive, g_DoPerfLogging(), CNSClientsRegistry::GetAffinityReset(), CJob::GetExpirationTime(), GetJobStatus(), CNSAffinityRegistry::GetTokenByID(), CJobGCRegistry::IsOutdatedJob(), CNSClientsRegistry::IsPreferredByAny(), CQueue::x_SJobPick::job_id, k_NoAffinityToken, m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_MaxPendingWaitTimeout, m_NotificationsList, m_OperationLock, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_StatisticsCounters, m_StatusTracker, m_Timeout, MakeJobKey(), NULL, CNSClientsRegistry::RegisterJob(), CNSAffinityRegistry::ResolveAffinities(), CNSGroupsRegistry::ResolveGroups(), CJobStatusTracker::SetStatus(), TimeLineAdd(), CJobGCRegistry::UpdateLifetime(), CNSClientsRegistry::WasGarbageCollected(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_NotifyJobChanges(), x_RegisterGetListener(), x_UnregisterGetListener(), and x_UpdateDB_ProvideJobNoLock().

Referenced by CNetScheduleHandler::x_ProcessGetJob(), and CNetScheduleHandler::x_ProcessJobExchange().

GetJobsPerState()

void CQueue::GetJobsPerState	(	const CNSClientId &	client,
		const string &	group_token,
		const string &	aff_token,
		size_t *	jobs,
		vector< string > &	warnings
	)		const

Definition at line 4429 of file ns_queue.cpp.

References bm::bvector< Alloc >::clear(), client, bm::bvector< Alloc >::count(), g_ValidJobStatuses, g_ValidJobStatusesSize, CNSScopeRegistry::GetAllJobsInScopes(), CNSAffinityRegistry::GetIDByToken(), CNSGroupsRegistry::GetJobs(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetJobs(), CNSAffinityRegistry::GetJobsWithAffinity(), kNoScopeOnly, m_AffinityRegistry, m_GroupRegistry, m_OperationLock, m_ScopeRegistry, and m_StatusTracker.

Referenced by PrintJobsStat(), and CNetScheduleHandler::x_ProcessQueueInfo().

GetJobStatus()

TJobStatus CQueue::GetJobStatus

(

unsigned

job_id

)

const

Definition at line 1946 of file ns_queue.cpp.

References CJobStatusTracker::GetStatus(), and m_StatusTracker.

Referenced by FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), GetStatusAndLifetime(), GetStatusAndLifetimeAndTouch(), JobDelayExpiration(), JobDelayReadExpiration(), CNSClient::Print(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), CNSGroupsRegistry::x_PrintOne(), CNSScopeRegistry::x_PrintOne(), and CNSAffinityRegistry::x_PrintOne().

GetJobsToDeleteCount()

unsigned int CQueue::GetJobsToDeleteCount

(

void

)

const

Definition at line 4404 of file ns_queue.cpp.

References bm::bvector< Alloc >::count(), m_JobsToDelete, and m_JobsToDeleteLock.

Referenced by PrintTransitionCounters().

GetLinkedSections()

void CQueue::GetLinkedSections

(

map< string, map< string, string > > &

linked_sections

)

const

Definition at line 262 of file ns_queue.cpp.

References map_checker< Container >::begin(), map_checker< Container >::empty(), map_checker< Container >::end(), CQueueDataBase::GetLinkedSection(), m_LinkedSections, and m_QueueDB.

Referenced by GetMaxIOSizesAndLinkedSections(), and CNetScheduleHandler::x_ProcessQueueInfo().

GetMaxIOSizesAndLinkedSections()

void CQueue::GetMaxIOSizesAndLinkedSections	(	unsigned int &	max_input_size,
		unsigned int &	max_output_size,
		map< string, map< string, string > > &	linked_sections
	)		const

Definition at line 248 of file ns_queue.cpp.

References GetLinkedSections(), CQueueParamAccessor::GetMaxInputSize(), and CQueueParamAccessor::GetMaxOutputSize().

Referenced by CNetScheduleHandler::x_ProcessGetParam().

GetMaxPendingWaitTimeout()

CNSPreciseTime CQueue::GetMaxPendingWaitTimeout ( ) const

inline

Definition at line 776 of file ns_queue.hpp.

References m_MaxPendingWaitTimeout.

GetNextId()

unsigned int CQueue::GetNextId

(

)

Definition at line 1959 of file ns_queue.cpp.

References m_LastId, m_LastIdLock, m_QueueName, m_SavedId, m_Server, s_ReserveDelta, and CNetScheduleServer::SetJobsStartID().

Referenced by Submit().

GetNextJobIdForBatch()

unsigned int CQueue::GetNextJobIdForBatch

(

unsigned

count

)

Definition at line 1980 of file ns_queue.cpp.

References count, m_LastId, m_LastIdLock, m_QueueName, m_SavedId, m_Server, s_ReserveDelta, and CNetScheduleServer::SetJobsStartID().

Referenced by SubmitBatch().

GetNotifCount()

size_t CQueue::GetNotifCount ( void  ) const

inline

Definition at line 143 of file ns_queue.hpp.

References m_NotificationsList, and CNSNotificationList::size().

GetParameters()

CQueue::TParameterList CQueue::GetParameters

(

void

)

const

Definition at line 234 of file ns_queue.cpp.

References CQueueParamAccessor::GetNumParams(), CQueueParamAccessor::GetParamName(), CQueueParamAccessor::GetParamValue(), and n.

Referenced by CNetScheduleHandler::x_ProcessGetConfiguration().

GetPauseStatus()

TPauseStatus CQueue::GetPauseStatus ( void  ) const

inline

Definition at line 455 of file ns_queue.hpp.

References m_PauseStatus.

Referenced by CNetScheduleHandler::x_ProcessFastStatusS(), CNetScheduleHandler::x_ProcessFastStatusW(), CNetScheduleHandler::x_ProcessGetJob(), CNetScheduleHandler::x_ProcessJobExchange(), CNetScheduleHandler::x_ProcessPause(), CNetScheduleHandler::x_ProcessResume(), and CNetScheduleHandler::x_ProcessStatus().

GetPendingTimeout()

CNSPreciseTime CQueue::GetPendingTimeout ( ) const

inline

Definition at line 772 of file ns_queue.hpp.

References m_PendingTimeout.

Referenced by CJob::Print().

GetQueueKind()

TQueueKind CQueue::GetQueueKind ( void  ) const

inline

Definition at line 113 of file ns_queue.hpp.

References m_Kind.

GetQueueName()

const string& CQueue::GetQueueName ( ) const

inline

Definition at line 150 of file ns_queue.hpp.

References m_QueueName.

Referenced by g_DoErasePerfLogging(), g_DoPerfLogging(), and PrintStatistics().

GetReadTimeout()

CNSPreciseTime CQueue::GetReadTimeout ( ) const

inline

Definition at line 768 of file ns_queue.hpp.

References m_ReadTimeout.

Referenced by CheckExecutionTimeout(), JobDelayReadExpiration(), and CJob::Print().

GetRefuseSubmits()

bool CQueue::GetRefuseSubmits ( void  ) const

inline

Definition at line 136 of file ns_queue.hpp.

References m_RefuseSubmits.

Referenced by CNetScheduleHandler::x_ProcessStatistics(), CNetScheduleHandler::x_ProcessSubmit(), and CNetScheduleHandler::x_ProcessSubmitBatch().

GetRunTimeout()

CNSPreciseTime CQueue::GetRunTimeout ( ) const

inline

Definition at line 764 of file ns_queue.hpp.

References m_RunTimeout.

Referenced by CheckExecutionTimeout(), JobDelayExpiration(), and CJob::Print().

GetScopeSlotsUsed()

size_t CQueue::GetScopeSlotsUsed ( void  ) const

inline

Definition at line 140 of file ns_queue.hpp.

References m_ScopeRegistry, and CNSScopeRegistry::size().

Referenced by CNetScheduleHandler::x_ProcessSetScope().

GetStatusAndLifetime()

TJobStatus CQueue::GetStatusAndLifetime	(	unsigned int	job_id,
		string &	client_ip,
		string &	client_sid,
		string &	client_phid,
		string &	progress_msg,
		CNSPreciseTime *	lifetime
	)

Definition at line 1223 of file ns_queue.cpp.

References CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), map_checker< Container >::find(), GetJobStatus(), m_Jobs, m_OperationLock, NCBI_THROW, and x_GetEstimatedJobLifetime().

Referenced by CNetScheduleHandler::x_ProcessFastStatusW().

GetStatusAndLifetimeAndTouch()

TJobStatus CQueue::GetStatusAndLifetimeAndTouch	(	unsigned int	job_id,
		CJob &	job,
		CNSPreciseTime *	lifetime
	)

Definition at line 1252 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), map_checker< Container >::find(), GetJobStatus(), m_GCRegistry, m_Jobs, m_OperationLock, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_Timeout, NCBI_THROW, CJobGCRegistry::UpdateLifetime(), and x_GetEstimatedJobLifetime().

Referenced by CNetScheduleHandler::x_ProcessFastStatusS().

GetTimeout()

CNSPreciseTime CQueue::GetTimeout ( void  ) const

inline

Definition at line 760 of file ns_queue.hpp.

References m_Timeout.

Referenced by CJob::Print(), and x_GetEstimatedJobLifetime().

IsEmpty()

bool CQueue::IsEmpty

(

void

)

const

Definition at line 1952 of file ns_queue.cpp.

References CJobStatusTracker::AnyJobs(), m_OperationLock, and m_StatusTracker.

IsProgramAllowed()

bool CQueue::IsProgramAllowed ( const string &  program_name ) const

inline

Definition at line 799 of file ns_queue.hpp.

References CQueueClientInfo::client_name, CQueueClientInfoList::IsConfigured(), CQueueClientInfoList::IsMatchingClient(), m_ProgramVersionList, ParseVersionString(), and CQueueClientInfo::version_info.

Referenced by CNetScheduleHandler::x_UpdateClientPassedChecks().

IsReaderAllowed()

bool CQueue::IsReaderAllowed ( unsigned  host ) const

inline

Definition at line 794 of file ns_queue.hpp.

References CNetScheduleAccessList::IsAllowed(), and m_ReaderHosts.

Referenced by CNetScheduleHandler::x_UpdateClientPassedChecks().

IsSubmitAllowed()

bool CQueue::IsSubmitAllowed ( unsigned  host ) const

inline

Definition at line 784 of file ns_queue.hpp.

References CNetScheduleAccessList::IsAllowed(), and m_SubmHosts.

Referenced by CNetScheduleHandler::x_UpdateClientPassedChecks().

IsWorkerAllowed()

bool CQueue::IsWorkerAllowed ( unsigned  host ) const

inline

Definition at line 789 of file ns_queue.hpp.

References CNetScheduleAccessList::IsAllowed(), and m_WnodeHosts.

Referenced by CNetScheduleHandler::x_UpdateClientPassedChecks().

JobDelayExpiration()

TJobStatus CQueue::JobDelayExpiration	(	unsigned int	job_id,
		CJob &	job,
		const CNSPreciseTime &	tm
	)

Definition at line 1126 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CNetScheduleAPI::eRunning, map_checker< Container >::find(), GetJobStatus(), GetRunTimeout(), kTimeZero, m_Jobs, m_OperationLock, and TimeLineMove().

Referenced by CNetScheduleHandler::x_ProcessJobDelayExpiration().

JobDelayReadExpiration()

TJobStatus CQueue::JobDelayReadExpiration	(	unsigned int	job_id,
		CJob &	job,
		const CNSPreciseTime &	tm
	)

Definition at line 1173 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CNetScheduleAPI::eReading, map_checker< Container >::find(), GetJobStatus(), GetReadTimeout(), kTimeZero, m_Jobs, m_OperationLock, and TimeLineMove().

Referenced by CNetScheduleHandler::x_ProcessJobDelayReadExpiration().

LoadFromDump()

unsigned int CQueue::LoadFromDump

(

const string &

dump_dir_name

)

Definition at line 4729 of file ns_queue.cpp.

References CNSAffinityRegistry::AddJobToAffinity(), CNSGroupsRegistry::AddJobToGroup(), CTimeLine< BV >::AddObject(), CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, CNSAffinityRegistry::FinalizeAffinityDictionaryLoading(), CNSGroupsRegistry::FinalizeGroupDictionaryLoading(), AutoArray< X, Del >::get(), CJob::GetAffinityId(), CJob::GetGroupId(), CTimeLine< BV >::GetHead(), CJob::GetId(), GetJobExpirationTime(), CJob::GetLastTouch(), CJob::GetReadTimeout(), CJob::GetRunTimeout(), CJob::GetStatus(), CJob::GetSubmitTime(), CJob::GetTimeout(), kNetScheduleMaxOverflowSize, kTimeZero, CNSAffinityRegistry::LoadFromDump(), CNSGroupsRegistry::LoadFromDump(), CJob::LoadFromDump(), m_AffinityRegistry, m_GCRegistry, m_GroupRegistry, m_Jobs, m_PendingTimeout, m_QueueName, m_ReadTimeout, m_RunTimeLine, m_RunTimeout, m_StatusTracker, m_Timeout, NULL, SJobDumpHeader::Read(), CJobGCRegistry::RegisterJob(), CJobStatusTracker::SetExactStatusNoLock(), x_ClearQueue(), and x_GetJobsDumpFileName().

MakeJobKey()

string CQueue::MakeJobKey

(

unsigned int

job_id

)

const

Definition at line 4055 of file ns_queue.cpp.

References CNetScheduleKeyGenerator::Generate(), CNetScheduleKeyGenerator::GenerateCompoundID(), CNetScheduleServer::GetCompoundIDPool(), m_KeyGenerator, m_ScrambleJobKeys, and m_Server.

Referenced by CheckJobsExpiry(), DecorateJob(), g_DoErasePerfLogging(), g_DoPerfLogging(), GetJobForReadingOrWait(), GetJobOrWait(), CNSClient::Print(), PutProgressMessage(), CNSSubmitRollback::Rollback(), CNSBatchSubmitRollback::Rollback(), CNSGetJobRollback::Rollback(), CNSReadJobRollback::Rollback(), SetJobListener(), CJob::x_AppendKey(), x_CancelJobs(), x_CheckExecutionTimeout(), x_LogSubmit(), CNetScheduleHandler::x_PrintGetJobResponse(), CNSGroupsRegistry::x_PrintOne(), CNSScopeRegistry::x_PrintOne(), CNSAffinityRegistry::x_PrintOne(), CNetScheduleHandler::x_ProcessReading(), CNetScheduleHandler::x_ProcessSubmit(), and x_ResetDueTo().

MarkClientAsAdmin()

void CQueue::MarkClientAsAdmin

(

const CNSClientId &

client

)

Definition at line 4097 of file ns_queue.cpp.

References client, m_ClientsRegistry, and CNSClientsRegistry::MarkAsAdmin().

Referenced by CNetScheduleHandler::x_ProcessRefuseSubmits(), and CNetScheduleHandler::x_ProcessStatistics().

NotifyExactListeners()

CNSPreciseTime CQueue::NotifyExactListeners

(

void

)

Definition at line 3246 of file ns_queue.cpp.

References m_NotificationsList, and CNSNotificationList::NotifyExactListeners().

NotifyListenersPeriodically()

void CQueue::NotifyListenersPeriodically

(

const CNSPreciseTime &

current_time

)

Definition at line 3186 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), CJobStatusTracker::AnyPending(), CNSNotificationList::CheckOutdatedJobs(), CNSNotificationList::CheckTimeout(), eGet, eRead, CJobStatusTracker::GetOutdatedPendingJobs(), CJobStatusTracker::GetOutdatedReadVacantJobs(), kTimeNever, kTimeZero, m_ClientsRegistry, m_GCRegistry, m_MaxPendingReadWaitTimeout, m_MaxPendingWaitTimeout, m_NotifHifreqInterval, m_NotifHifreqPeriod, m_NotificationsList, m_NotifLofreqMult, m_OperationLock, m_ReadJobs, m_StatusTracker, and CNSNotificationList::NotifyPeriodically().

OptimizeMem()

void CQueue::OptimizeMem

(

)

Definition at line 2503 of file ns_queue.cpp.

References m_StatusTracker, and CJobStatusTracker::OptimizeMem().

PrintAffinitiesList()

string CQueue::PrintAffinitiesList	(	const CNSClientId &	client,
		bool	verbose
	)		const

Definition at line 3268 of file ns_queue.cpp.

References client, CNSScopeRegistry::GetAllJobsInScopes(), CNSScopeRegistry::GetJobs(), kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_DumpAffBufferSize, m_OperationLock, m_ScopeRegistry, and CNSAffinityRegistry::Print().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintAllJobDbStat()

string CQueue::PrintAllJobDbStat	(	const CNSClientId &	client,
		const string &	group,
		const string &	aff_token,
		const vector< TJobStatus > &	job_statuses,
		unsigned int	start_after_job_id,
		unsigned int	count,
		bool	order_first,
		TDumpFields	dump_fields,
		bool	logging
	)

Definition at line 3867 of file ns_queue.cpp.

References bm::bvector< Alloc >::clear(), client, count, CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, CNSScopeRegistry::GetAllJobsInScopes(), CNSAffinityRegistry::GetIDByToken(), CNSGroupsRegistry::GetJobs(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetJobs(), CNSAffinityRegistry::GetJobsWithAffinity(), kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_GroupRegistry, m_OperationLock, m_ScopeRegistry, m_StatusTracker, CNSClientsRegistry::MarkAsAdmin(), Warning(), and x_DumpJobs().

Referenced by CNetScheduleHandler::x_ProcessDump().

PrintClientsList()

string CQueue::PrintClientsList

(

bool

verbose

)

const

Definition at line 3252 of file ns_queue.cpp.

References m_ClientsRegistry, m_DumpClientBufferSize, m_OperationLock, and CNSClientsRegistry::PrintClientsList().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintGroupsList()

string CQueue::PrintGroupsList	(	const CNSClientId &	client,
		bool	verbose
	)		const

Definition at line 3286 of file ns_queue.cpp.

References client, CNSScopeRegistry::GetAllJobsInScopes(), CNSScopeRegistry::GetJobs(), kNoScopeOnly, m_DumpGroupBufferSize, m_GroupRegistry, m_OperationLock, m_ScopeRegistry, and CNSGroupsRegistry::Print().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintJobCounters()

void CQueue::PrintJobCounters

(

void

)

const

Definition at line 4387 of file ns_queue.cpp.

References CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, g_DoPerfLogging(), CJobStatusTracker::GetJobCounters(), and m_StatusTracker.

PrintJobDbStat()

string CQueue::PrintJobDbStat	(	const CNSClientId &	client,
		unsigned int	job_id,
		TDumpFields	dump_fields
	)

Definition at line 3810 of file ns_queue.cpp.

References client, eGCEraseTime, map_checker< Container >::end(), eScope, map_checker< Container >::find(), bm::bvector< Alloc >::get_bit(), CNSScopeRegistry::GetAllJobsInScopes(), CNSScopeRegistry::GetJobs(), CNSScopeRegistry::GetJobScope(), CJobGCRegistry::GetLifetime(), kNewLine(), kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_Jobs, m_JobsToDelete, m_JobsToDeleteLock, m_OperationLock, m_ScopeRegistry, CNSClientsRegistry::MarkAsAdmin(), and NS_FormatPreciseTime().

Referenced by CNetScheduleHandler::x_ProcessDump().

PrintJobsStat()

string CQueue::PrintJobsStat	(	const CNSClientId &	client,
		const string &	group_token,
		const string &	aff_token,
		vector< string > &	warnings
	)		const

Definition at line 4486 of file ns_queue.cpp.

References client, g_ValidJobStatuses, g_ValidJobStatusesSize, GetJobsPerState(), result, and CNetScheduleAPI::StatusToString().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintNotificationsList()

string CQueue::PrintNotificationsList

(

bool

verbose

)

const

Definition at line 3260 of file ns_queue.cpp.

References m_AffinityRegistry, m_ClientsRegistry, m_GroupRegistry, m_NotificationsList, m_OperationLock, and CNSNotificationList::Print().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintScopesList()

string CQueue::PrintScopesList

(

bool

verbose

)

const

Definition at line 3303 of file ns_queue.cpp.

References m_OperationLock, m_ScopeRegistry, and CNSScopeRegistry::Print().

Referenced by CNetScheduleHandler::x_StatisticsNew().

PrintStatistics()

void CQueue::PrintStatistics

(

size_t &

aff_count

)

const

Definition at line 4331 of file ns_queue.cpp.

References CountStatus(), ctx, CNSPreciseTime::Current(), delta(), CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::ePending, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, CNetScheduleHandler::eStatus_OK, CDiagContext_Extra::Flush(), GetDiagContext(), GetQueueName(), m_AffinityRegistry, m_StatisticsCounters, m_StatisticsCountersLastPrinted, m_StatisticsCountersLastPrintedTimestamp, NS_FormatPreciseTimeAsSec(), NULL, CDiagContext_Extra::Print(), CStatisticsCounters::PrintDelta(), CDiagContext::PrintRequestStart(), CDiagContext::PrintRequestStop(), CStatisticsCounters::PrintTransitions(), CDiagContext::SetRequestContext(), and CNSAffinityRegistry::size().

PrintTransitionCounters()

string CQueue::PrintTransitionCounters

(

void

)

const

Definition at line 4411 of file ns_queue.cpp.

References GetJobsToDeleteCount(), kNewLine(), m_AffinityRegistry, m_ClientsRegistry, m_StatisticsCounters, output, CStatisticsCounters::PrintTransitions(), CNSAffinityRegistry::size(), and CNSClientsRegistry::size().

Referenced by CNetScheduleHandler::x_ProcessStatistics().

PurgeAffinities()

unsigned int CQueue::PurgeAffinities

(

void

)

Definition at line 3706 of file ns_queue.cpp.

References CNSAffinityRegistry::CheckRemoveCandidates(), CNSAffinityRegistry::CollectGarbage(), SNSRegistryParameters::dirt_percentage, CNetScheduleServer::GetAffRegistrySettings(), SNSRegistryParameters::high_mark_percentage, SNSRegistryParameters::high_removal, SNSRegistryParameters::low_mark_percentage, SNSRegistryParameters::low_removal, m_AffinityRegistry, m_Server, SNSRegistryParameters::max_records, and CNSAffinityRegistry::size().

PurgeBlacklistedJobs()

void CQueue::PurgeBlacklistedJobs

(

void

)

Definition at line 3786 of file ns_queue.cpp.

References eGet, eRead, CNSClientsRegistry::GCBlacklistedJobs(), m_ClientsRegistry, and m_StatusTracker.

PurgeClientRegistry()

void CQueue::PurgeClientRegistry

(

const CNSPreciseTime &

current_time

)

Definition at line 3793 of file ns_queue.cpp.

References m_ClientRegistryMinAdmins, m_ClientRegistryMinReaders, m_ClientRegistryMinSubmitters, m_ClientRegistryMinUnknowns, m_ClientRegistryMinWorkerNodes, m_ClientRegistryTimeoutAdmin, m_ClientRegistryTimeoutReader, m_ClientRegistryTimeoutSubmitter, m_ClientRegistryTimeoutUnknown, m_ClientRegistryTimeoutWorkerNode, m_ClientsRegistry, m_Log, m_OperationLock, and CNSClientsRegistry::Purge().

PurgeGroups()

unsigned int CQueue::PurgeGroups

(

void

)

Definition at line 3742 of file ns_queue.cpp.

References CNSGroupsRegistry::CheckRemoveCandidates(), CNSGroupsRegistry::CollectGarbage(), SNSRegistryParameters::dirt_percentage, CNetScheduleServer::GetGroupRegistrySettings(), SNSRegistryParameters::high_mark_percentage, SNSRegistryParameters::high_removal, SNSRegistryParameters::low_mark_percentage, SNSRegistryParameters::low_removal, m_GroupRegistry, m_Server, SNSRegistryParameters::max_records, and CNSGroupsRegistry::size().

PutProgressMessage()

bool CQueue::PutProgressMessage	(	unsigned int	job_id,
		CJob &	job,
		const string &	msg
	)

Definition at line 1336 of file ns_queue.cpp.

References CNSPreciseTime::Current(), map_checker< Container >::end(), eProgressMessageChanged, map_checker< Container >::find(), m_GCRegistry, m_Jobs, m_OperationLock, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_Timeout, MakeJobKey(), msg(), CJobGCRegistry::UpdateLifetime(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessPutMessage().

PutResult()

TJobStatus CQueue::PutResult	(	const CNSClientId &	client,
		const CNSPreciseTime &	curr,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token,
		int	ret_code,
		const string &	output
	)

Definition at line 650 of file ns_queue.cpp.

References client, CStatisticsCounters::CountTransition(), CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, eGet, CNetScheduleAPI::ePending, eRead, CNetScheduleAPI::eRunning, eStatusChanged, g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), CJob::GetAffinityId(), CJob::GetExpirationTime(), GetJobStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_MaxOutputSize, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PendingTimeout, m_ReadJobs, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), output, CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), x_NotifyJobChanges(), and x_UpdateDB_PutResultNoLock().

Referenced by CNetScheduleHandler::x_ProcessJobExchange(), and CNetScheduleHandler::x_ProcessPut().

ReadAndTouchJob()

TJobStatus CQueue::ReadAndTouchJob	(	unsigned int	job_id,
		CJob &	job,
		CNSPreciseTime *	lifetime
	)

Definition at line 1650 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), map_checker< Container >::find(), GetJobStatus(), m_GCRegistry, m_Jobs, m_OperationLock, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_Timeout, NCBI_THROW, CJobGCRegistry::UpdateLifetime(), and x_GetEstimatedJobLifetime().

Referenced by CNetScheduleHandler::x_ProcessGetMessage(), and CNetScheduleHandler::x_ProcessStatus().

RedoJob()

TJobStatus CQueue::RedoJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job
	)

Definition at line 1590 of file ns_queue.cpp.

References client, CStatisticsCounters::CountRedo(), CNSPreciseTime::Current(), eGet, CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), eNoPause, CNetScheduleAPI::ePending, CNetScheduleAPI::eReading, CJobEvent::eRedo, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), GetJobStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), CJobStatusTracker::SetStatus(), CJobGCRegistry::UpdateLifetime(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessRedo().

RegisterQueueResumeNotification()

void CQueue::RegisterQueueResumeNotification	(	unsigned int	address,
		unsigned short	port,
		bool	new_format
	)

Definition at line 4537 of file ns_queue.cpp.

References CNSNotificationList::AddToQueueResumedNotifications(), and m_NotificationsList.

Referenced by CNetScheduleHandler::x_ProcessGetJob(), and CNetScheduleHandler::x_ProcessJobExchange().

RegisterSocketWriteError()

void CQueue::RegisterSocketWriteError

(

const CNSClientId &

client

)

Definition at line 4103 of file ns_queue.cpp.

References client, m_ClientsRegistry, m_OperationLock, and CNSClientsRegistry::RegisterSocketWriteError().

RemoveDump()

void CQueue::RemoveDump

(

const string &

dump_dir_name

)

Definition at line 4709 of file ns_queue.cpp.

References m_AffinityRegistry, m_GroupRegistry, m_QueueName, remove(), CNSAffinityRegistry::RemoveDump(), CNSGroupsRegistry::RemoveDump(), and x_GetJobsDumpFileName().

Referenced by Dump().

RereadJob()

TJobStatus CQueue::RereadJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		bool &	no_op
	)

Definition at line 2258 of file ns_queue.cpp.

References client, CStatisticsCounters::CountReread(), CNSPreciseTime::Current(), CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CNetScheduleAPI::ePending, eRead, CNetScheduleAPI::eReading, CJobEvent::eReread, CNetScheduleAPI::eRunning, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), GetJobStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PendingTimeout, m_ReadJobs, m_ReadJobsOps, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), bm::bvector< Alloc >::set_bit(), CJobEvent::SetNodeAddr(), CJobStatusTracker::SetStatus(), CJobGCRegistry::UpdateLifetime(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessReread().

RescheduleJob()

TJobStatus CQueue::RescheduleJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		const string &	auth_token,
		const string &	aff_token,
		const string &	group,
		bool &	auth_token_ok,
		CJob &	job
	)

Definition at line 1470 of file ns_queue.cpp.

References CNSGroupsRegistry::AddJob(), CNSAffinityRegistry::AddJobToAffinity(), CJobGCRegistry::ChangeAffinityAndGroup(), client, CStatisticsCounters::CountToPendingRescheduled(), CNSPreciseTime::Current(), CJob::eCompleteMatch, eGet, CJob::eInvalidTokenFormat, map_checker< Container >::end(), eNoPause, CNetScheduleAPI::ePending, CJobEvent::eReschedule, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), CJob::GetAffinityId(), GetJobStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), CNSGroupsRegistry::RemoveJob(), CNSAffinityRegistry::RemoveJobFromAffinity(), CNSAffinityRegistry::ResolveAffinity(), CNSGroupsRegistry::ResolveGroup(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessReschedule().

RestorePauseStatus()

void CQueue::RestorePauseStatus ( TPauseStatus  status )

inline

Definition at line 460 of file ns_queue.hpp.

References m_PauseStatus.

ReturnJob()

TJobStatus CQueue::ReturnJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token,
		string &	warning,
		TJobReturnOption	how
	)

Definition at line 1362 of file ns_queue.cpp.

References client, CStatisticsCounters::CountNSGetRollback(), CStatisticsCounters::CountToPendingWithoutBlacklist(), CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), eGet, CJob::eInvalidTokenFormat, map_checker< Container >::end(), CJob::eNoMatch, eNoPause, CJobEvent::eNSGetRollback, CJob::ePassportOnlyMatch, CNetScheduleAPI::ePending, CJobEvent::eReturn, CJobEvent::eReturnNoBlacklist, eRollback, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, eWithBlacklist, eWithoutBlacklist, map_checker< Container >::find(), g_DoPerfLogging(), GetJobStatus(), CJob::GetRunCount(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), CNSClientsRegistry::RegisterBlacklistedJob(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), Warning(), and x_NotifyJobChanges().

Referenced by CNSGetJobRollback::Rollback(), and CNetScheduleHandler::x_ProcessReturn().

ReturnReadingJob()

TJobStatus CQueue::ReturnReadingJob	(	const CNSClientId &	client,
		unsigned int	job_id,
		const string &	job_key,
		CJob &	job,
		const string &	auth_token,
		bool	is_ns_rollback,
		bool	blacklist,
		TJobStatus	target_status
	)

Definition at line 2235 of file ns_queue.cpp.

References client, eRead, m_ClientsRegistry, CNSClientsRegistry::MoveJobToBlacklist(), CNSClientsRegistry::UnregisterJob(), and x_ChangeReadingStatus().

Referenced by CNSReadJobRollback::Rollback(), and CNetScheduleHandler::x_ProcessReadRollback().

SetAffinity()

void CQueue::SetAffinity	(	const CNSClientId &	client,
		const list< string > &	aff,
		ECommandGroup	cmd_group
	)

Definition at line 1069 of file ns_queue.cpp.

References CNSClientsRegistry::AppendType(), client, eGet, CNSClient::eReader, CNSClient::eWorkerNode, bm::bvector< Alloc >::get_bit(), CNetScheduleServer::GetAffRegistrySettings(), CNSClientsRegistry::GetPreferredAffinities(), m_AffinityRegistry, m_ClientsRegistry, m_OperationLock, m_Server, SNSRegistryParameters::max_records, NCBI_THROW, CNSAffinityRegistry::ResolveAffinityToken(), bm::bvector< Alloc >::set_bit(), and CNSClientsRegistry::SetPreferredAffinities().

Referenced by CNetScheduleHandler::x_ProcessSetAffinity().

SetClientData()

int CQueue::SetClientData	(	const CNSClientId &	client,
		const string &	data,
		int	data_version
	)

Definition at line 1119 of file ns_queue.cpp.

References client, data, m_ClientsRegistry, and CNSClientsRegistry::SetClientData().

Referenced by CNetScheduleHandler::x_ProcessSetClientData().

SetClientScope()

void CQueue::SetClientScope

(

const CNSClientId &

client

)

Definition at line 4110 of file ns_queue.cpp.

References client, m_ClientsRegistry, m_OperationLock, and CNSClientsRegistry::SetLastScope().

Referenced by CNetScheduleHandler::x_ProcessSetScope(), and CNetScheduleHandler::x_UpdateClientPassedChecks().

SetJobListener()

TJobStatus CQueue::SetJobListener	(	unsigned int	job_id,
		CJob &	job,
		unsigned int	address,
		unsigned short	port,
		const CNSPreciseTime &	timeout,
		bool	need_stolen,
		bool	need_progress_msg,
		size_t *	last_event_index
	)

Definition at line 1281 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), eNotificationStolen, map_checker< Container >::find(), kTimeZero, m_Jobs, m_OperationLock, MakeJobKey(), and x_NotifyJobChanges().

Referenced by CNetScheduleHandler::x_ProcessListenJob().

SetParameters()

void CQueue::SetParameters

(

const SQueueParameters &

params

)

Definition at line 159 of file ns_queue.cpp.

References CQueueClientInfoList::AddClientInfo(), SQueueParameters::blacklist_time, SQueueParameters::CalculateRuntimePrecision(), CQueueClientInfoList::Clear(), SQueueParameters::client_registry_min_admins, SQueueParameters::client_registry_min_readers, SQueueParameters::client_registry_min_submitters, SQueueParameters::client_registry_min_unknowns, 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, SQueueParameters::dump_aff_buffer_size, SQueueParameters::dump_buffer_size, SQueueParameters::dump_client_buffer_size, SQueueParameters::dump_group_buffer_size, SQueueParameters::failed_retries, SQueueParameters::linked_sections, m_BlacklistTime, m_ClientRegistryMinAdmins, m_ClientRegistryMinReaders, m_ClientRegistryMinSubmitters, m_ClientRegistryMinUnknowns, m_ClientRegistryMinWorkerNodes, m_ClientRegistryTimeoutAdmin, m_ClientRegistryTimeoutReader, m_ClientRegistryTimeoutSubmitter, m_ClientRegistryTimeoutUnknown, m_ClientRegistryTimeoutWorkerNode, m_ClientsRegistry, m_DumpAffBufferSize, m_DumpBufferSize, m_DumpClientBufferSize, m_DumpGroupBufferSize, m_FailedRetries, m_HandicapTimeout, m_LinkedSections, m_MaxInputSize, m_MaxJobsPerClient, m_MaxOutputSize, m_MaxPendingReadWaitTimeout, m_MaxPendingWaitTimeout, m_NotifHifreqInterval, m_NotifHifreqPeriod, m_NotifLofreqMult, m_ParamLock, m_PendingTimeout, m_ProgramVersionList, m_ReadBlacklistTime, m_ReaderHosts, m_ReaderTimeout, m_ReadFailedRetries, m_ReadTimeout, m_RunTimeLine, m_RunTimeout, m_ScrambleJobKeys, m_SubmHosts, m_Timeout, m_WnodeHosts, m_WNodeTimeout, SQueueParameters::max_input_size, SQueueParameters::max_jobs_per_client, SQueueParameters::max_output_size, SQueueParameters::max_pending_read_wait_timeout, SQueueParameters::max_pending_wait_timeout, SQueueParameters::notif_handicap, SQueueParameters::notif_hifreq_interval, SQueueParameters::notif_hifreq_period, SQueueParameters::notif_lofreq_mult, SQueueParameters::pending_timeout, precision, SQueueParameters::program_name, SQueueParameters::qclass, SQueueParameters::read_blacklist_time, SQueueParameters::read_failed_retries, SQueueParameters::read_timeout, SQueueParameters::reader_hosts, SQueueParameters::reader_timeout, SQueueParameters::run_timeout, SQueueParameters::scramble_job_keys, CNSClientsRegistry::SetBlacklistTimeouts(), CNetScheduleAccessList::SetHosts(), SQueueParameters::subm_hosts, SQueueParameters::timeout, UpdatePerfLoggingSettings(), SQueueParameters::wnode_hosts, and SQueueParameters::wnode_timeout.

SetPauseStatus()

void CQueue::SetPauseStatus	(	const CNSClientId &	client,
		TPauseStatus	status
	)

Definition at line 4522 of file ns_queue.cpp.

References CJobStatusTracker::AnyPending(), client, eNoPause, m_ClientsRegistry, m_NotificationsList, m_PauseStatus, m_Server, m_StatusTracker, CNSClientsRegistry::MarkAsAdmin(), CNSNotificationList::onQueueResumed(), and SerializePauseState().

Referenced by CNetScheduleHandler::x_ProcessPause(), and CNetScheduleHandler::x_ProcessResume().

SetRefuseSubmits()

void CQueue::SetRefuseSubmits ( bool  val )

inline

Definition at line 137 of file ns_queue.hpp.

References m_RefuseSubmits, and val.

Referenced by CNetScheduleHandler::x_ProcessRefuseSubmits().

ShouldPerfLogTransitions()

bool CQueue::ShouldPerfLogTransitions ( void  ) const

inline

Definition at line 470 of file ns_queue.hpp.

References m_ShouldPerfLogTransitions.

Referenced by g_DoErasePerfLogging(), and g_DoPerfLogging().

StaleNodes()

void CQueue::StaleNodes

(

const CNSPreciseTime &

current_time

)

Definition at line 3776 of file ns_queue.cpp.

References m_ClientsRegistry, m_Log, m_OperationLock, m_ReaderTimeout, m_WNodeTimeout, and CNSClientsRegistry::StaleNodes().

StatusStatistics()

void CQueue::StatusStatistics	(	TJobStatus	status,
		TNSBitVector::statistics *	st
	)		const

Definition at line 4048 of file ns_queue.cpp.

References m_StatusTracker, st(), and CJobStatusTracker::StatusStatistics().

Referenced by CNetScheduleHandler::x_ProcessStatistics().

Submit()

unsigned int CQueue::Submit	(	const CNSClientId &	client,
		CJob &	job,
		const string &	aff_token,
		const string &	group,
		bool	logging,
		CNSRollbackInterface *&	rollback_action
	)

Definition at line 399 of file ns_queue.cpp.

References CNSGroupsRegistry::AddJob(), CNSScopeRegistry::AddJob(), CJobStatusTracker::AddPendingJob(), CNSClientsRegistry::AddToSubmitted(), CJob::AppendEvent(), CNSAffinityRegistry::CanAccept(), CNSGroupsRegistry::CanAccept(), CNSScopeRegistry::CanAccept(), client, CStatisticsCounters::CountSubmit(), CNSPreciseTime::Current(), eGet, eNoPause, CNetScheduleAPI::eOutOfOrder, CNetScheduleAPI::ePending, CJobEvent::eSubmit, eUndefined, CNetScheduleServer::GetAffRegistrySettings(), CJob::GetExpirationTime(), CNetScheduleServer::GetGroupRegistrySettings(), CJob::GetInput(), CJob::GetMask(), GetNextId(), CNetScheduleServer::GetScopeRegistrySettings(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_MaxInputSize, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_Server, m_StatisticsCounters, m_StatusTracker, m_Timeout, SNSRegistryParameters::max_records, NCBI_THROW, CNSNotificationList::Notify(), CJobGCRegistry::RegisterJob(), CNSAffinityRegistry::ResolveAffinityToken(), CJob::SetAffinityId(), CJob::SetGroupId(), CJob::SetId(), CJob::SetLastTouch(), CJob::SetPassport(), and x_LogSubmit().

Referenced by CNetScheduleHandler::x_ProcessSubmit().

SubmitBatch()

unsigned int CQueue::SubmitBatch	(	const CNSClientId &	client,
		vector< pair< CJob, string > > &	batch,
		const string &	group,
		bool	logging,
		CNSRollbackInterface *&	rollback_action
	)

Definition at line 520 of file ns_queue.cpp.

References CNSScopeRegistry::AddJobs(), CNSGroupsRegistry::AddJobs(), CJobStatusTracker::AddPendingBatch(), CNSClientsRegistry::AddToSubmitted(), CJob::AppendEvent(), CNSAffinityRegistry::CanAccept(), CNSGroupsRegistry::CanAccept(), CNSScopeRegistry::CanAccept(), client, CStatisticsCounters::CountSubmit(), CNSPreciseTime::Current(), CJobEvent::eBatchSubmit, eGet, eNoPause, CNetScheduleAPI::ePending, eUndefined, first(), CNetScheduleServer::GetAffRegistrySettings(), CNetScheduleServer::GetGroupRegistrySettings(), GetNextJobIdForBatch(), CNetScheduleServer::GetScopeRegistrySettings(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_LogBatchEachJob, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_Server, m_StatisticsCounters, m_StatusTracker, m_Timeout, SNSRegistryParameters::max_records, NCBI_THROW, CNSNotificationList::Notify(), CJobGCRegistry::RegisterJob(), CNSGroupsRegistry::ResolveGroup(), bm::bvector< Alloc >::set_bit(), bm::bvector< Alloc >::set_range(), CJob::SetAffinityId(), CJob::SetGroupId(), CJob::SetId(), CJob::SetLastTouch(), CJob::SetPassport(), bm::bvector< Alloc >::size(), and x_LogSubmit().

TimeLineAdd()

void CQueue::TimeLineAdd	(	unsigned int	job_id,
		const CNSPreciseTime &	job_time
	)

Definition at line 3603 of file ns_queue.cpp.

References CTimeLine< BV >::AddObject(), m_RunTimeLine, m_RunTimeLineLock, and CNSPreciseTime::Sec().

Referenced by GetJobForReadingOrWait(), GetJobOrWait(), and x_CheckExecutionTimeout().

TimeLineExchange()

void CQueue::TimeLineExchange	(	unsigned int	remove_job_id,
		unsigned int	add_job_id,
		const CNSPreciseTime &	new_time
	)

Definition at line 3624 of file ns_queue.cpp.

References CTimeLine< BV >::AddObject(), m_RunTimeLine, m_RunTimeLineLock, CTimeLine< BV >::RemoveObject(), and CNSPreciseTime::Sec().

TimeLineMove()

void CQueue::TimeLineMove	(	unsigned int	job_id,
		const CNSPreciseTime &	old_time,
		const CNSPreciseTime &	new_time
	)

Definition at line 3591 of file ns_queue.cpp.

References m_RunTimeLine, m_RunTimeLineLock, CTimeLine< BV >::MoveObject(), and CNSPreciseTime::Sec().

Referenced by JobDelayExpiration(), and JobDelayReadExpiration().

TimeLineRemove()

void CQueue::TimeLineRemove

(

unsigned int

job_id

)

Definition at line 3614 of file ns_queue.cpp.

References m_RunTimeLine, m_RunTimeLineLock, and CTimeLine< BV >::RemoveObject().

Referenced by Cancel(), EraseJob(), FailJob(), PutResult(), RescheduleJob(), ReturnJob(), x_CancelJobs(), x_ChangeReadingStatus(), and x_ResetDueTo().

TouchClientsRegistry()

void CQueue::TouchClientsRegistry	(	CNSClientId &	client,
		bool &	client_was_found,
		bool &	session_was_reset,
		string &	old_session,
		bool &	had_wn_pref_affs,
		bool &	had_reader_pref_affs
	)

Definition at line 4064 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), client, m_ClientsRegistry, m_OperationLock, CGuard< Resource, Lock, Unlock, ReportExceptions >::Release(), CNSClientsRegistry::Touch(), x_ResetReadingDueToNewSession(), and x_ResetRunningDueToNewSession().

Referenced by CNetScheduleHandler::x_ProcessMsgRequest(), and CNetScheduleHandler::x_ProcessSetQueue().

UpdatePerfLoggingSettings()

void CQueue::UpdatePerfLoggingSettings

(

const string &

qclass

)

Definition at line 227 of file ns_queue.cpp.

References m_QueueName, m_Server, m_ShouldPerfLogTransitions, and CNetScheduleServer::ShouldPerfLogTransitions().

Referenced by SetParameters().

x_CancelJobs()

unsigned int CQueue::x_CancelJobs ( const CNSClientId &  client, const TNSBitVector &  jobs_to_cancel, bool  logging  )

private

Definition at line 1782 of file ns_queue.cpp.

References client, count, CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), DecorateJob(), CJobEvent::eCancel, CNetScheduleAPI::eCanceled, eGet, map_checker< Container >::end(), eRead, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, CDiagContext::Extra(), map_checker< Container >::find(), bm::bvector< Alloc >::first(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), CNSScopeRegistry::GetAllJobsInScopes(), GetDiagContext(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetStatus(), kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_PendingTimeout, m_ReadJobs, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, MakeJobKey(), CNSNotificationList::Notify(), CDiagContext_Extra::Print(), CJobEvent::SetNodeAddr(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), bm::bvector< Alloc >::iterator_base::valid(), and x_NotifyJobChanges().

Referenced by CancelAllJobs(), and CancelSelectedJobs().

x_ChangeReadingStatus()

TJobStatus CQueue::x_ChangeReadingStatus ( const CNSClientId &  client, unsigned int  job_id, const string &  job_key, CJob &  job, const string &  auth_token, const string &  err_msg, TJobStatus  target_status, bool  is_ns_rollback, bool  no_retries  )

private

Definition at line 2341 of file ns_queue.cpp.

References _ASSERT, client, CStatisticsCounters::CountNSReadRollback(), CStatisticsCounters::CountTransition(), CNSPreciseTime::Current(), CNetScheduleAPI::eCanceled, CNetScheduleAPI::eConfirmed, CNetScheduleAPI::eDone, CStatisticsCounters::eFail, CNetScheduleAPI::eFailed, CJob::eInvalidTokenFormat, CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CJob::eNoMatch, CStatisticsCounters::eNone, CJobEvent::eNSReadRollback, eRead, CJobEvent::eReadDone, CJobEvent::eReadFail, CNetScheduleAPI::eReadFailed, CJobEvent::eReadFinalFail, CNetScheduleAPI::eReading, CJobEvent::eReadRollback, eStatusChanged, map_checker< Container >::find(), g_DoPerfLogging(), GetJobStatus(), m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PendingTimeout, m_ReadFailedRetries, m_ReadJobs, m_ReadJobsOps, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, NCBI_THROW, CNSNotificationList::Notify(), bm::bvector< Alloc >::set_bit(), CJobStatusTracker::SetStatus(), CJobEvent::SetTimestamp(), CNetScheduleAPI::StatusToString(), TimeLineRemove(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), and x_NotifyJobChanges().

Referenced by ConfirmReadingJob(), FailReadingJob(), and ReturnReadingJob().

x_CheckExecutionTimeout()

void CQueue::x_CheckExecutionTimeout ( const CNSPreciseTime &  queue_run_timeout, const CNSPreciseTime &  queue_read_timeout, unsigned  job_id, const CNSPreciseTime &  curr_time, bool  logging  )

private

Definition at line 3332 of file ns_queue.cpp.

References CStatisticsCounters::CountTransition(), CNetScheduleAPI::eCanceled, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, eGet, map_checker< Container >::end(), eNoPause, CNetScheduleAPI::ePending, eRead, CNetScheduleAPI::eReadFailed, CNetScheduleAPI::eReading, CJobEvent::eReadTimeout, CNetScheduleAPI::eRunning, eStatusChanged, CJobEvent::eTimeout, CStatisticsCounters::eTimeout, CDiagContext::Extra(), map_checker< Container >::find(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), GetDiagContext(), GetJobStatus(), kTimeZero, m_AffinityRegistry, m_ClientsRegistry, m_FailedRetries, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_QueueName, m_ReadFailedRetries, m_ReadJobs, m_ReadJobsOps, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, MakeJobKey(), CNSClientsRegistry::MoveJobToBlacklist(), CNSNotificationList::Notify(), NS_FormatPreciseTime(), CDiagContext_Extra::Print(), bm::bvector< Alloc >::set_bit(), CJobStatusTracker::SetStatus(), TimeLineAdd(), CNSClientsRegistry::UnregisterJob(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), and x_NotifyJobChanges().

Referenced by CheckExecutionTimeout().

x_ClearQueue()

void CQueue::x_ClearQueue ( void  )

private

Definition at line 4831 of file ns_queue.cpp.

References map_checker< Container >::clear(), bm::bvector< Alloc >::clear(), CNSAffinityRegistry::Clear(), CJobGCRegistry::Clear(), CNSGroupsRegistry::Clear(), CNSScopeRegistry::Clear(), CJobStatusTracker::ClearAll(), m_AffinityRegistry, m_GCRegistry, m_GroupRegistry, m_Jobs, m_JobsToDelete, m_ReadJobs, m_RunTimeLine, m_ScopeRegistry, m_StatusTracker, and CTimeLine< BV >::ReInit().

Referenced by LoadFromDump().

x_DumpJobs()

string CQueue::x_DumpJobs ( const TNSBitVector &  jobs_to_dump, unsigned int  start_after_job_id, unsigned int  count, TDumpFields  dump_fields, bool  order_first  )

private

Definition at line 3943 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), buffer, bm::bvector< Alloc >::count(), count, eGCEraseTime, map_checker< Container >::end(), eScope, map_checker< Container >::find(), bm::bvector< Alloc >::first(), CNSScopeRegistry::GetJobScope(), CJobGCRegistry::GetLifetime(), kEmptyStr, kNewLine(), m_AffinityRegistry, m_DumpBufferSize, m_GCRegistry, m_GroupRegistry, m_Jobs, m_OperationLock, m_ScopeRegistry, NS_FormatPreciseTime(), Print(), result, and bm::bvector< Alloc >::iterator_base::valid().

Referenced by PrintAllJobDbStat().

x_Erase()

void CQueue::x_Erase ( const TNSBitVector &  job_ids, TJobStatus  status  )

private

Erase jobs from all structures, request delayed db deletion.

Definition at line 2489 of file ns_queue.cpp.

References bm::bvector< Alloc >::count(), CStatisticsCounters::CountTransitionToDeleted(), m_JobsToDelete, m_JobsToDeleteLock, m_JobsToDeleteOps, and m_StatisticsCounters.

Referenced by CheckJobsExpiry().

x_FindOutdatedJobForReading() [1/2]

CQueue::x_SJobPick CQueue::x_FindOutdatedJobForReading ( const CNSClientId &  client, unsigned int  picked_earlier, const TNSBitVector &  group_ids  )

private

Definition at line 2927 of file ns_queue.cpp.

References client, CQueue::x_SJobPick::job_id, kTimeZero, and m_MaxPendingReadWaitTimeout.

Referenced by GetJobForReadingOrWait().

x_FindOutdatedJobForReading() [2/2]

CQueue::x_SJobPick CQueue::x_FindOutdatedJobForReading ( const CNSClientId &  client, unsigned int  picked_earlier, const TNSBitVector &  group_ids, const string &  scope  )

private

Definition at line 2955 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), client, eRead, bm::bvector< Alloc >::first(), CJobGCRegistry::GetAffinityID(), CNSScopeRegistry::GetAllJobsInScopes(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetOutdatedReadVacantJobs(), kNoScopeOnly, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_MaxPendingReadWaitTimeout, m_ReadJobs, m_ScopeRegistry, m_StatusTracker, CNSGroupsRegistry::RestrictByGroup(), bm::bvector< Alloc >::set_bit(), and CNSClientsRegistry::SubtractBlacklistedJobs().

x_FindOutdatedPendingJob() [1/2]

CQueue::x_SJobPick CQueue::x_FindOutdatedPendingJob ( const CNSClientId &  client, unsigned int  picked_earlier, const TNSBitVector &  group_ids  )

private

Definition at line 2865 of file ns_queue.cpp.

References client, CQueue::x_SJobPick::job_id, kTimeZero, and m_MaxPendingWaitTimeout.

Referenced by GetJobOrWait().

x_FindOutdatedPendingJob() [2/2]

CQueue::x_SJobPick CQueue::x_FindOutdatedPendingJob ( const CNSClientId &  client, unsigned int  picked_earlier, const TNSBitVector &  group_ids, const string &  scope  )

private

Definition at line 2892 of file ns_queue.cpp.

References CQueue::x_SJobPick::aff_id, bm::bvector< Alloc >::any(), client, eGet, CQueue::x_SJobPick::exclusive, bm::bvector< Alloc >::first(), CJobGCRegistry::GetAffinityID(), CNSScopeRegistry::GetAllJobsInScopes(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetOutdatedPendingJobs(), CQueue::x_SJobPick::job_id, kNoScopeOnly, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_MaxPendingWaitTimeout, m_ScopeRegistry, m_StatusTracker, CNSGroupsRegistry::RestrictByGroup(), bm::bvector< Alloc >::set_bit(), and CNSClientsRegistry::SubtractBlacklistedJobs().

x_FindVacantJob() [1/2]

CQueue::x_SJobPick CQueue::x_FindVacantJob ( const CNSClientId &  client, const TNSBitVector &  explicit_affs, const vector< unsigned int > &  aff_ids, bool  use_pref_affinity, bool  any_affinity, bool  exclusive_new_affinity, bool  prioritized_aff, const TNSBitVector &  group_ids, bool  has_groups, ECommandGroup  cmd_group  )

private

Definition at line 2510 of file ns_queue.cpp.

References client, and CQueue::x_SJobPick::job_id.

Referenced by GetJobForReadingOrWait(), and GetJobOrWait().

x_FindVacantJob() [2/2]

CQueue::x_SJobPick CQueue::x_FindVacantJob ( const CNSClientId &  client, const TNSBitVector &  explicit_affs, const vector< unsigned int > &  aff_ids, bool  use_pref_affinity, bool  any_affinity, bool  exclusive_new_affinity, bool  prioritized_aff, const TNSBitVector &  group_ids, bool  has_groups, ECommandGroup  cmd_group, const string &  scope  )

private

Definition at line 2547 of file ns_queue.cpp.

References CNSClientsRegistry::AddBlacklistedJobs(), bm::bvector< Alloc >::any(), client, eGet, bm::bvector< Alloc >::empty(), CNetScheduleAPI::ePending, eRead, bm::bvector< Alloc >::first(), bm::bvector< Alloc >::get_bit(), CJobGCRegistry::GetAffinityID(), CNSScopeRegistry::GetAllJobsInScopes(), CNSClientsRegistry::GetAllPreferredAffinities(), CJobStatusTracker::GetJobByStatus(), CNSGroupsRegistry::GetJobs(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetJobs(), CNSClientsRegistry::GetPreferredAffinities(), kEmptyBitVector, kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_GCRegistry, m_GroupRegistry, m_MaxJobsPerClient, m_ReadJobs, m_ScopeRegistry, m_StatesForRead, m_StatusTracker, CNSGroupsRegistry::RestrictByGroup(), bm::bvector< Alloc >::set_bit(), CNSClientsRegistry::SubtractBlacklistedJobs(), bm::bvector< Alloc >::iterator_base::valid(), x_GetRunningJobsPerClientIP(), and x_ValidateMaxJobsPerClientIP().

x_GetEstimatedJobLifetime()

CNSPreciseTime CQueue::x_GetEstimatedJobLifetime ( unsigned int  job_id, TJobStatus  status  ) const

private

Definition at line 1868 of file ns_queue.cpp.

References CNSPreciseTime::Current(), CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, CJobGCRegistry::GetLifetime(), GetTimeout(), and m_GCRegistry.

Referenced by GetStatusAndLifetime(), GetStatusAndLifetimeAndTouch(), and ReadAndTouchJob().

x_GetJobsDumpFileName()

string CQueue::x_GetJobsDumpFileName ( const string &  dump_dname ) const

private

Definition at line 4721 of file ns_queue.cpp.

References kJobsFileName(), m_QueueName, and NStr::ToUpper().

Referenced by Dump(), LoadFromDump(), and RemoveDump().

x_GetRunningJobsPerClientIP()

map< string, size_t > CQueue::x_GetRunningJobsPerClientIP ( void  )

private

Definition at line 2821 of file ns_queue.cpp.

References map_checker< Container >::end(), CNetScheduleAPI::eRunning, map_checker< Container >::find(), bm::bvector< Alloc >::first(), CJobStatusTracker::GetJobs(), m_Jobs, m_StatusTracker, and bm::bvector< Alloc >::iterator_base::valid().

Referenced by x_FindVacantJob().

x_LogSubmit()

void CQueue::x_LogSubmit ( const CJob &  job )

private

Definition at line 390 of file ns_queue.cpp.

References CDiagContext::Extra(), CDiagContext_Extra::Flush(), GetDiagContext(), CJob::GetId(), MakeJobKey(), and CDiagContext_Extra::Print().

Referenced by Submit(), and SubmitBatch().

x_NoMoreReadJobs()

bool CQueue::x_NoMoreReadJobs ( const CNSClientId &  client, const TNSBitVector &  aff_list, bool  reader_affinity, bool  any_affinity, bool  exclusive_new_affinity, const TNSBitVector &  group_list, bool  affinity_may_change, bool  group_may_change  )

private

Definition at line 276 of file ns_queue.cpp.

References bm::bvector< Alloc >::any(), bm::BM_GAP, client, CNetScheduleAPI::ePending, eRead, CNetScheduleAPI::eReading, CNetScheduleAPI::eRunning, CNSScopeRegistry::GetAllJobsInScopes(), CNSClientsRegistry::GetAllPreferredAffinities(), CNSScopeRegistry::GetJobs(), CJobStatusTracker::GetJobs(), CNSAffinityRegistry::GetJobsWithAffinities(), CNSAffinityRegistry::GetRegisteredAffinities(), kNoScopeOnly, m_AffinityRegistry, m_ClientsRegistry, m_GroupRegistry, m_ReadJobs, m_ScopeRegistry, m_StatesForRead, m_StatusTracker, and CNSGroupsRegistry::RestrictByGroup().

Referenced by GetJobForReadingOrWait().

x_NotifyJobChanges()

void CQueue::x_NotifyJobChanges ( const CJob &  job, const string &  job_key, ENotificationReason  reason, const CNSPreciseTime &  current_time  )

private

Definition at line 4847 of file ns_queue.cpp.

References CNSNotificationList::BuildJobChangedNotification(), CNetScheduleAPI::eDeleted, eJobDeleted, eNotificationStolen, eProgressMessageChanged, CJob::GetListenerNotifAddr(), CJob::GetListenerNotifPort(), CJob::GetLsnrNeedProgressMsgNotif(), CJob::GetStatus(), CJob::GetSubmAddr(), CJob::GetSubmNeedProgressMsgNotif(), CJob::GetSubmNotifPort(), m_NotificationsList, CNSNotificationList::NotifyJobChanges(), CJob::ShouldNotifyListener(), and CJob::ShouldNotifySubmitter().

Referenced by Cancel(), CheckJobsExpiry(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), PutProgressMessage(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetJobListener(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

x_RegisterGetListener()

void CQueue::x_RegisterGetListener ( const CNSClientId &  client, unsigned short  port, unsigned int  timeout, const TNSBitVector &  aff_ids, bool  wnode_aff, bool  any_aff, bool  exclusive_new_affinity, bool  new_format, const TNSBitVector &  group_ids  )

private

Definition at line 4276 of file ns_queue.cpp.

References client, eGet, m_ClientsRegistry, m_NotificationsList, CNSNotificationList::RegisterListener(), and CNSClientsRegistry::SetNodeWaiting().

Referenced by GetJobOrWait().

x_RegisterReadListener()

void CQueue::x_RegisterReadListener ( const CNSClientId &  client, unsigned short  port, unsigned int  timeout, const TNSBitVector &  aff_ids, bool  reader_aff, bool  any_aff, bool  exclusive_new_affinity, const TNSBitVector &  group_ids  )

private

Definition at line 4299 of file ns_queue.cpp.

References client, eRead, m_ClientsRegistry, m_NotificationsList, CNSNotificationList::RegisterListener(), and CNSClientsRegistry::SetNodeWaiting().

Referenced by GetJobForReadingOrWait().

x_ResetDueTo()

TJobStatus CQueue::x_ResetDueTo ( const CNSClientId &  client, unsigned int  job_id, const CNSPreciseTime &  current_time, TJobStatus  status_from, CJobEvent::EJobEvent  event_type  )

private

Definition at line 4120 of file ns_queue.cpp.

References client, CStatisticsCounters::CountTransition(), DecorateJob(), CNetScheduleAPI::eCanceled, CJobEvent::eClear, CStatisticsCounters::eClear, CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, eGet, CNetScheduleAPI::eJobNotFound, map_checker< Container >::end(), CStatisticsCounters::eNewSession, eNoPause, CNetScheduleAPI::ePending, eRead, CNetScheduleAPI::eReadFailed, ERR_POST, CNetScheduleAPI::eRunning, eStatusChanged, CJobEvent::EventToString(), map_checker< Container >::find(), g_DoPerfLogging(), bm::bvector< Alloc >::get_bit(), m_AffinityRegistry, m_ClientsRegistry, m_FailedRetries, m_GCRegistry, m_GroupRegistry, m_HandicapTimeout, m_Jobs, m_NotifHifreqPeriod, m_NotificationsList, m_OperationLock, m_PauseStatus, m_PendingTimeout, m_ReadFailedRetries, m_ReadJobs, m_ReadJobsOps, m_ReadTimeout, m_RunTimeout, m_ScopeRegistry, m_StatisticsCounters, m_StatusTracker, m_Timeout, MakeJobKey(), CNSNotificationList::Notify(), bm::bvector< Alloc >::set_bit(), CJobEvent::SetStatus(), CJobStatusTracker::SetStatus(), TimeLineRemove(), CJobGCRegistry::UpdateLifetime(), CJobGCRegistry::UpdateReadVacantTime(), and x_NotifyJobChanges().

Referenced by x_ResetReadingDueToClear(), x_ResetReadingDueToNewSession(), x_ResetRunningDueToClear(), and x_ResetRunningDueToNewSession().

x_ResetReadingDueToClear()

void CQueue::x_ResetReadingDueToClear ( const CNSClientId &  client, const TNSBitVector &  jobs  )

private

Definition at line 4228 of file ns_queue.cpp.

References client, CNSPreciseTime::Current(), DecorateJob(), CJobEvent::eClear, CNetScheduleAPI::eReading, ERR_POST, bm::bvector< Alloc >::first(), bm::bvector< Alloc >::iterator_base::valid(), and x_ResetDueTo().

Referenced by ClearWorkerNode().

x_ResetReadingDueToNewSession()

void CQueue::x_ResetReadingDueToNewSession ( const CNSClientId &  client, const TNSBitVector &  jobs  )

private

Definition at line 4260 of file ns_queue.cpp.

References client, CNSPreciseTime::Current(), DecorateJob(), CNetScheduleAPI::eReading, ERR_POST, CJobEvent::eSessionChanged, bm::bvector< Alloc >::first(), bm::bvector< Alloc >::iterator_base::valid(), and x_ResetDueTo().

Referenced by TouchClientsRegistry().

x_ResetRunningDueToClear()

void CQueue::x_ResetRunningDueToClear ( const CNSClientId &  client, const TNSBitVector &  jobs  )

private

Definition at line 4212 of file ns_queue.cpp.

References client, CNSPreciseTime::Current(), DecorateJob(), CJobEvent::eClear, ERR_POST, CNetScheduleAPI::eRunning, bm::bvector< Alloc >::first(), bm::bvector< Alloc >::iterator_base::valid(), and x_ResetDueTo().

Referenced by ClearWorkerNode().

x_ResetRunningDueToNewSession()

void CQueue::x_ResetRunningDueToNewSession ( const CNSClientId &  client, const TNSBitVector &  jobs  )

private

Definition at line 4244 of file ns_queue.cpp.

References client, CNSPreciseTime::Current(), DecorateJob(), ERR_POST, CNetScheduleAPI::eRunning, CJobEvent::eSessionChanged, bm::bvector< Alloc >::first(), bm::bvector< Alloc >::iterator_base::valid(), and x_ResetDueTo().

Referenced by TouchClientsRegistry().

x_UnregisterGetListener()

bool CQueue::x_UnregisterGetListener ( const CNSClientId &  client, unsigned short  port  )

private

Definition at line 4317 of file ns_queue.cpp.

References CNSClientsRegistry::CancelWaiting(), client, eGet, m_ClientsRegistry, m_NotificationsList, and CNSNotificationList::UnregisterListener().

Referenced by CancelWaitGet(), and GetJobOrWait().

x_UpdateDB_ProvideJobNoLock()

void CQueue::x_UpdateDB_ProvideJobNoLock ( const CNSClientId &  client, const CNSPreciseTime &  curr, unsigned int  job_id, ECommandGroup  cmd_group, CJob &  job  )

private

Definition at line 4598 of file ns_queue.cpp.

References client, eGet, map_checker< Container >::end(), CJobEvent::eRead, CNetScheduleAPI::eReading, CJobEvent::eRequest, CNetScheduleAPI::eRunning, map_checker< Container >::find(), kTimeZero, m_Jobs, NCBI_THROW, and CJobEvent::SetTimestamp().

Referenced by GetJobForReadingOrWait(), and GetJobOrWait().

x_UpdateDB_PutResultNoLock()

void CQueue::x_UpdateDB_PutResultNoLock ( unsigned  job_id, const string &  auth_token, const CNSPreciseTime &  curr, int  ret_code, const string &  output, CJob &  job, const CNSClientId &  client  )

private

Definition at line 4546 of file ns_queue.cpp.

References client, CNetScheduleAPI::eDone, CJobEvent::eDone, CJob::eInvalidTokenFormat, map_checker< Container >::end(), CJob::eNoMatch, CJob::ePassportOnlyMatch, ERR_POST, map_checker< Container >::find(), m_Jobs, NCBI_THROW, output, CJobEvent::SetStatus(), and Warning().

Referenced by PutResult().

x_ValidateMaxJobsPerClientIP()

bool CQueue::x_ValidateMaxJobsPerClientIP ( unsigned int  job_id, const map< string, size_t > &  jobs_per_client_ip  ) const

private

Definition at line 2845 of file ns_queue.cpp.

References map_checker< Container >::empty(), map_checker< Container >::end(), map_checker< Container >::find(), m_Jobs, and m_MaxJobsPerClient.

Referenced by x_FindVacantJob().

Friends And Related Function Documentation

CJob

friend class CJob

friend

Definition at line 631 of file ns_queue.hpp.

CQueueParamAccessor

friend class CQueueParamAccessor

friend

Definition at line 632 of file ns_queue.hpp.

Member Data Documentation

m_AffinityRegistry

CNSAffinityRegistry CQueue::m_AffinityRegistry

private

Definition at line 654 of file ns_queue.hpp.

Referenced by Cancel(), CancelSelectedJobs(), ChangeAffinity(), CheckJobsExpiry(), CQueue(), Dump(), FailJob(), GetAffinityTokenByID(), GetAffSlotsUsed(), GetJobForReadingOrWait(), GetJobOrWait(), GetJobsPerState(), LoadFromDump(), PrintAffinitiesList(), PrintAllJobDbStat(), PrintJobDbStat(), PrintNotificationsList(), PrintStatistics(), PrintTransitionCounters(), PurgeAffinities(), PutResult(), RedoJob(), RemoveDump(), RereadJob(), RescheduleJob(), ReturnJob(), SetAffinity(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_DumpJobs(), x_FindVacantJob(), x_NoMoreReadJobs(), and x_ResetDueTo().

m_BlacklistTime

CNSPreciseTime CQueue::m_BlacklistTime

private

Definition at line 683 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), and SetParameters().

m_ClientRegistryMinAdmins

unsigned int CQueue::m_ClientRegistryMinAdmins

private

Definition at line 738 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryMinReaders

unsigned int CQueue::m_ClientRegistryMinReaders

private

Definition at line 742 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryMinSubmitters

unsigned int CQueue::m_ClientRegistryMinSubmitters

private

Definition at line 740 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryMinUnknowns

unsigned int CQueue::m_ClientRegistryMinUnknowns

private

Definition at line 744 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryMinWorkerNodes

unsigned int CQueue::m_ClientRegistryMinWorkerNodes

private

Definition at line 736 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryTimeoutAdmin

CNSPreciseTime CQueue::m_ClientRegistryTimeoutAdmin

private

Definition at line 737 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryTimeoutReader

CNSPreciseTime CQueue::m_ClientRegistryTimeoutReader

private

Definition at line 741 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryTimeoutSubmitter

CNSPreciseTime CQueue::m_ClientRegistryTimeoutSubmitter

private

Definition at line 739 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryTimeoutUnknown

CNSPreciseTime CQueue::m_ClientRegistryTimeoutUnknown

private

Definition at line 743 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientRegistryTimeoutWorkerNode

CNSPreciseTime CQueue::m_ClientRegistryTimeoutWorkerNode

private

Definition at line 735 of file ns_queue.hpp.

Referenced by PurgeClientRegistry(), and SetParameters().

m_ClientsRegistry

CNSClientsRegistry CQueue::m_ClientsRegistry

private

Definition at line 651 of file ns_queue.hpp.

Referenced by Cancel(), CancelWaitRead(), ChangeAffinity(), ClearWorkerNode(), ConfirmReadingJob(), CQueue(), FailJob(), FailReadingJob(), GetClientsCount(), GetJobForReadingOrWait(), GetJobOrWait(), MarkClientAsAdmin(), NotifyListenersPeriodically(), PrintAffinitiesList(), PrintAllJobDbStat(), PrintClientsList(), PrintJobDbStat(), PrintNotificationsList(), PrintTransitionCounters(), PurgeBlacklistedJobs(), PurgeClientRegistry(), PutResult(), RedoJob(), RegisterSocketWriteError(), RereadJob(), RescheduleJob(), ReturnJob(), ReturnReadingJob(), SetAffinity(), SetClientData(), SetClientScope(), SetParameters(), SetPauseStatus(), StaleNodes(), Submit(), SubmitBatch(), TouchClientsRegistry(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_FindOutdatedJobForReading(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_NoMoreReadJobs(), x_RegisterGetListener(), x_RegisterReadListener(), x_ResetDueTo(), and x_UnregisterGetListener().

m_DumpAffBufferSize

unsigned int CQueue::m_DumpAffBufferSize

private

Definition at line 721 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), PrintAffinitiesList(), and SetParameters().

m_DumpBufferSize

unsigned int CQueue::m_DumpBufferSize

private

Definition at line 719 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), SetParameters(), and x_DumpJobs().

m_DumpClientBufferSize

unsigned int CQueue::m_DumpClientBufferSize

private

Definition at line 720 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), PrintClientsList(), and SetParameters().

m_DumpGroupBufferSize

unsigned int CQueue::m_DumpGroupBufferSize

private

Definition at line 722 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), PrintGroupsList(), and SetParameters().

m_FailedRetries

unsigned CQueue::m_FailedRetries

private

Definition at line 680 of file ns_queue.hpp.

Referenced by GetFailedRetries(), CQueueParamAccessor::GetFailedRetries(), CQueueParamAccessor::GetParamValue(), SetParameters(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_GCRegistry

CJobGCRegistry CQueue::m_GCRegistry

private

Definition at line 730 of file ns_queue.hpp.

Referenced by Cancel(), CheckJobsExpiry(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), GetStatusAndLifetimeAndTouch(), LoadFromDump(), NotifyListenersPeriodically(), PrintJobDbStat(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_DumpJobs(), x_FindOutdatedJobForReading(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_GetEstimatedJobLifetime(), and x_ResetDueTo().

m_GroupRegistry

CNSGroupsRegistry CQueue::m_GroupRegistry

private

Definition at line 727 of file ns_queue.hpp.

Referenced by Cancel(), CancelSelectedJobs(), CheckJobsExpiry(), Dump(), FailJob(), GetGroupsCount(), GetGroupSlotsUsed(), GetJobForReadingOrWait(), GetJobOrWait(), GetJobsPerState(), LoadFromDump(), PrintAllJobDbStat(), PrintGroupsList(), PrintJobDbStat(), PrintNotificationsList(), PurgeGroups(), PutResult(), RedoJob(), RemoveDump(), RereadJob(), RescheduleJob(), ReturnJob(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_DumpJobs(), x_FindOutdatedJobForReading(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_NoMoreReadJobs(), and x_ResetDueTo().

m_HandicapTimeout

CNSPreciseTime CQueue::m_HandicapTimeout

private

Definition at line 717 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), CQueueParamAccessor::GetParamValue(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_Jobs

map<unsigned int, CJob> CQueue::m_Jobs

private

Definition at line 638 of file ns_queue.hpp.

Referenced by Cancel(), CheckJobsExpiry(), DeleteBatch(), Dump(), FailJob(), GetStatusAndLifetime(), GetStatusAndLifetimeAndTouch(), JobDelayExpiration(), JobDelayReadExpiration(), LoadFromDump(), PrintJobDbStat(), PutProgressMessage(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetJobListener(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_DumpJobs(), x_GetRunningJobsPerClientIP(), x_ResetDueTo(), x_UpdateDB_ProvideJobNoLock(), x_UpdateDB_PutResultNoLock(), and x_ValidateMaxJobsPerClientIP().

m_JobsToDelete

TNSBitVector CQueue::m_JobsToDelete

private

Definition at line 666 of file ns_queue.hpp.

Referenced by DeleteBatch(), EraseJob(), GetGCBacklogCount(), GetJobsToDeleteCount(), PrintJobDbStat(), x_ClearQueue(), and x_Erase().

m_JobsToDeleteLock

CFastMutex CQueue::m_JobsToDeleteLock

mutableprivate

Definition at line 663 of file ns_queue.hpp.

Referenced by DeleteBatch(), EraseJob(), GetGCBacklogCount(), GetJobsToDeleteCount(), PrintJobDbStat(), and x_Erase().

m_JobsToDeleteOps

unsigned int CQueue::m_JobsToDeleteOps

private

Definition at line 667 of file ns_queue.hpp.

Referenced by DeleteBatch(), EraseJob(), and x_Erase().

m_KeyGenerator

CNetScheduleKeyGenerator CQueue::m_KeyGenerator

private

Definition at line 701 of file ns_queue.hpp.

Referenced by MakeJobKey().

m_Kind

TQueueKind CQueue::m_Kind

private

Definition at line 645 of file ns_queue.hpp.

Referenced by GetQueueKind().

m_LastId

unsigned int CQueue::m_LastId

private

Definition at line 657 of file ns_queue.hpp.

Referenced by Attach(), GetNextId(), and GetNextJobIdForBatch().

m_LastIdLock

CFastMutex CQueue::m_LastIdLock

private

Definition at line 660 of file ns_queue.hpp.

Referenced by GetNextId(), and GetNextJobIdForBatch().

m_LinkedSections

map<string, string> CQueue::m_LinkedSections

private

Definition at line 724 of file ns_queue.hpp.

Referenced by GetLinkedSections(), and SetParameters().

m_Log

const bool& CQueue::m_Log

private

Definition at line 703 of file ns_queue.hpp.

Referenced by FailJob(), PurgeClientRegistry(), and StaleNodes().

m_LogBatchEachJob

const bool& CQueue::m_LogBatchEachJob

private

Definition at line 704 of file ns_queue.hpp.

Referenced by SubmitBatch().

m_MaxInputSize

unsigned CQueue::m_MaxInputSize

private

Definition at line 685 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetMaxInputSize(), CQueueParamAccessor::GetParamValue(), SetParameters(), and Submit().

m_MaxJobsPerClient

unsigned CQueue::m_MaxJobsPerClient

private

Definition at line 682 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), SetParameters(), x_FindVacantJob(), and x_ValidateMaxJobsPerClientIP().

m_MaxOutputSize

unsigned CQueue::m_MaxOutputSize

private

Definition at line 686 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetMaxOutputSize(), CQueueParamAccessor::GetParamValue(), PutResult(), and SetParameters().

m_MaxPendingReadWaitTimeout

CNSPreciseTime CQueue::m_MaxPendingReadWaitTimeout

private

Definition at line 691 of file ns_queue.hpp.

Referenced by GetJobForReadingOrWait(), NotifyListenersPeriodically(), SetParameters(), and x_FindOutdatedJobForReading().

m_MaxPendingWaitTimeout

CNSPreciseTime CQueue::m_MaxPendingWaitTimeout

private

Definition at line 690 of file ns_queue.hpp.

Referenced by GetJobOrWait(), GetMaxPendingWaitTimeout(), NotifyListenersPeriodically(), SetParameters(), and x_FindOutdatedPendingJob().

m_NotifHifreqInterval

CNSPreciseTime CQueue::m_NotifHifreqInterval

private

Definition at line 714 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), NotifyListenersPeriodically(), and SetParameters().

m_NotifHifreqPeriod

CNSPreciseTime CQueue::m_NotifHifreqPeriod

private

Definition at line 715 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), CQueueParamAccessor::GetParamValue(), NotifyListenersPeriodically(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_NotificationsList

CNSNotificationList CQueue::m_NotificationsList

private

Definition at line 713 of file ns_queue.hpp.

Referenced by Cancel(), CheckJobsExpiry(), CQueue(), FailJob(), GetJobOrWait(), GetNotifCount(), NotifyExactListeners(), NotifyListenersPeriodically(), PrintNotificationsList(), PutResult(), RedoJob(), RegisterQueueResumeNotification(), RereadJob(), RescheduleJob(), ReturnJob(), SetPauseStatus(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_NotifyJobChanges(), x_RegisterGetListener(), x_RegisterReadListener(), x_ResetDueTo(), and x_UnregisterGetListener().

m_NotifLofreqMult

unsigned int CQueue::m_NotifLofreqMult

private

Definition at line 716 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), NotifyListenersPeriodically(), and SetParameters().

m_OperationLock

CFastMutex CQueue::m_OperationLock

mutableprivate

Definition at line 648 of file ns_queue.hpp.

Referenced by Cancel(), CancelAllJobs(), CancelSelectedJobs(), CancelWaitGet(), CancelWaitRead(), ChangeAffinity(), CheckJobsExpiry(), ClearWorkerNode(), DeleteBatch(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), GetJobsPerState(), GetStatusAndLifetime(), GetStatusAndLifetimeAndTouch(), IsEmpty(), JobDelayExpiration(), JobDelayReadExpiration(), NotifyListenersPeriodically(), PrintAffinitiesList(), PrintAllJobDbStat(), PrintClientsList(), PrintGroupsList(), PrintJobDbStat(), PrintNotificationsList(), PrintScopesList(), PurgeClientRegistry(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RegisterSocketWriteError(), RereadJob(), RescheduleJob(), ReturnJob(), SetAffinity(), SetClientScope(), SetJobListener(), StaleNodes(), Submit(), SubmitBatch(), TouchClientsRegistry(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_DumpJobs(), and x_ResetDueTo().

m_ParamLock

CFastMutex CQueue::m_ParamLock

mutableprivate

Definition at line 675 of file ns_queue.hpp.

Referenced by SetParameters().

m_PauseStatus

TPauseStatus CQueue::m_PauseStatus

private

Definition at line 732 of file ns_queue.hpp.

Referenced by FailJob(), GetPauseStatus(), RedoJob(), RescheduleJob(), RestorePauseStatus(), ReturnJob(), SetPauseStatus(), Submit(), SubmitBatch(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_PendingTimeout

CNSPreciseTime CQueue::m_PendingTimeout

private

Definition at line 689 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), GetPendingTimeout(), GetStatusAndLifetimeAndTouch(), LoadFromDump(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_ProgramVersionList

CQueueClientInfoList CQueue::m_ProgramVersionList

private

Definition at line 693 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), IsProgramAllowed(), and SetParameters().

m_QueueDB

CQueueDataBase& CQueue::m_QueueDB

private

Definition at line 636 of file ns_queue.hpp.

Referenced by GetLinkedSections().

m_QueueName

string CQueue::m_QueueName

private

Definition at line 644 of file ns_queue.hpp.

Referenced by Attach(), DecorateJob(), Dump(), GetNextId(), GetNextJobIdForBatch(), GetQueueName(), LoadFromDump(), RemoveDump(), UpdatePerfLoggingSettings(), x_CheckExecutionTimeout(), and x_GetJobsDumpFileName().

m_ReadBlacklistTime

CNSPreciseTime CQueue::m_ReadBlacklistTime

private

Definition at line 684 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), and SetParameters().

m_ReaderHosts

CNetScheduleAccessList CQueue::m_ReaderHosts

private

Definition at line 699 of file ns_queue.hpp.

Referenced by IsReaderAllowed(), and SetParameters().

m_ReaderTimeout

CNSPreciseTime CQueue::m_ReaderTimeout

private

Definition at line 688 of file ns_queue.hpp.

Referenced by SetParameters(), and StaleNodes().

m_ReadFailedRetries

unsigned CQueue::m_ReadFailedRetries

private

Definition at line 681 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), SetParameters(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_ReadJobs

TNSBitVector CQueue::m_ReadJobs

private

Definition at line 671 of file ns_queue.hpp.

Referenced by Cancel(), DeleteBatch(), FailJob(), GetJobForReadingOrWait(), NotifyListenersPeriodically(), PutResult(), RereadJob(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_FindOutdatedJobForReading(), x_FindVacantJob(), x_NoMoreReadJobs(), and x_ResetDueTo().

m_ReadJobsOps

unsigned int CQueue::m_ReadJobsOps

private

Definition at line 672 of file ns_queue.hpp.

Referenced by DeleteBatch(), GetJobForReadingOrWait(), RereadJob(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_ReadTimeout

CNSPreciseTime CQueue::m_ReadTimeout

private

Definition at line 678 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), CQueueParamAccessor::GetParamValue(), GetReadTimeout(), GetStatusAndLifetimeAndTouch(), LoadFromDump(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_RefuseSubmits

bool CQueue::m_RefuseSubmits

private

Definition at line 706 of file ns_queue.hpp.

Referenced by GetRefuseSubmits(), and SetRefuseSubmits().

m_RunTimeLine

CJobTimeLine* CQueue::m_RunTimeLine

private

Definition at line 641 of file ns_queue.hpp.

Referenced by CheckExecutionTimeout(), LoadFromDump(), SetParameters(), TimeLineAdd(), TimeLineExchange(), TimeLineMove(), TimeLineRemove(), x_ClearQueue(), and ~CQueue().

m_RunTimeLineLock

CRWLock CQueue::m_RunTimeLineLock

private

Definition at line 642 of file ns_queue.hpp.

Referenced by CheckExecutionTimeout(), TimeLineAdd(), TimeLineExchange(), TimeLineMove(), and TimeLineRemove().

m_RunTimeout

CNSPreciseTime CQueue::m_RunTimeout

private

Definition at line 677 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), CQueueParamAccessor::GetParamValue(), GetRunTimeout(), GetStatusAndLifetimeAndTouch(), LoadFromDump(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_SavedId

unsigned int CQueue::m_SavedId

private

Definition at line 658 of file ns_queue.hpp.

Referenced by Attach(), GetNextId(), and GetNextJobIdForBatch().

m_ScopeRegistry

CNSScopeRegistry CQueue::m_ScopeRegistry

private

Definition at line 746 of file ns_queue.hpp.

Referenced by Cancel(), CheckJobsExpiry(), Dump(), FailJob(), GetJobsPerState(), GetScopeSlotsUsed(), PrintAffinitiesList(), PrintAllJobDbStat(), PrintGroupsList(), PrintJobDbStat(), PrintScopesList(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_DumpJobs(), x_FindOutdatedJobForReading(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_NoMoreReadJobs(), and x_ResetDueTo().

m_ScrambleJobKeys

bool CQueue::m_ScrambleJobKeys

private

Definition at line 723 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), MakeJobKey(), and SetParameters().

m_Server

CNetScheduleServer* CQueue::m_Server

private

Definition at line 634 of file ns_queue.hpp.

Referenced by Attach(), ChangeAffinity(), GetNextId(), GetNextJobIdForBatch(), MakeJobKey(), PurgeAffinities(), PurgeGroups(), SetAffinity(), SetPauseStatus(), Submit(), SubmitBatch(), and UpdatePerfLoggingSettings().

m_ShouldPerfLogTransitions

bool CQueue::m_ShouldPerfLogTransitions

private

Definition at line 748 of file ns_queue.hpp.

Referenced by ShouldPerfLogTransitions(), and UpdatePerfLoggingSettings().

m_StatesForRead

vector<CNetScheduleAPI::EJobStatus> CQueue::m_StatesForRead

private

Definition at line 752 of file ns_queue.hpp.

Referenced by CQueue(), x_FindVacantJob(), and x_NoMoreReadJobs().

m_StatisticsCounters

CStatisticsCounters CQueue::m_StatisticsCounters

private

Definition at line 708 of file ns_queue.hpp.

Referenced by Cancel(), CountTransition(), DeleteBatch(), EraseJob(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), PrintStatistics(), PrintTransitionCounters(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_Erase(), and x_ResetDueTo().

m_StatisticsCountersLastPrinted

CStatisticsCounters CQueue::m_StatisticsCountersLastPrinted

mutableprivate

Definition at line 709 of file ns_queue.hpp.

Referenced by PrintStatistics().

m_StatisticsCountersLastPrintedTimestamp

CNSPreciseTime CQueue::m_StatisticsCountersLastPrintedTimestamp

mutableprivate

Definition at line 710 of file ns_queue.hpp.

Referenced by PrintStatistics().

m_StatusTracker

CJobStatusTracker CQueue::m_StatusTracker

private

Definition at line 635 of file ns_queue.hpp.

Referenced by AnyJobs(), Cancel(), CancelAllJobs(), CancelSelectedJobs(), CheckJobsExpiry(), CountActiveJobs(), CountAllJobs(), CountStatus(), Dump(), EraseJob(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), GetJobsPerState(), GetJobStatus(), IsEmpty(), LoadFromDump(), NotifyListenersPeriodically(), OptimizeMem(), PrintAllJobDbStat(), PrintJobCounters(), PurgeBlacklistedJobs(), PutResult(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetPauseStatus(), StatusStatistics(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), x_ClearQueue(), x_FindOutdatedJobForReading(), x_FindOutdatedPendingJob(), x_FindVacantJob(), x_GetRunningJobsPerClientIP(), x_NoMoreReadJobs(), and x_ResetDueTo().

m_SubmHosts

CNetScheduleAccessList CQueue::m_SubmHosts

private

Definition at line 695 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), IsSubmitAllowed(), and SetParameters().

m_Timeout

CNSPreciseTime CQueue::m_Timeout

private

Definition at line 676 of file ns_queue.hpp.

Referenced by Cancel(), FailJob(), GetJobForReadingOrWait(), GetJobOrWait(), CQueueParamAccessor::GetParamValue(), GetStatusAndLifetimeAndTouch(), GetTimeout(), LoadFromDump(), PutProgressMessage(), PutResult(), ReadAndTouchJob(), RedoJob(), RereadJob(), RescheduleJob(), ReturnJob(), SetParameters(), Submit(), SubmitBatch(), x_CancelJobs(), x_ChangeReadingStatus(), x_CheckExecutionTimeout(), and x_ResetDueTo().

m_WnodeHosts

CNetScheduleAccessList CQueue::m_WnodeHosts

private

Definition at line 697 of file ns_queue.hpp.

Referenced by CQueueParamAccessor::GetParamValue(), IsWorkerAllowed(), and SetParameters().

m_WNodeTimeout

CNSPreciseTime CQueue::m_WNodeTimeout

private

Definition at line 687 of file ns_queue.hpp.

Referenced by SetParameters(), and StaleNodes().

---

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

• src/app/netschedule/ns_queue.hpp
• src/app/netschedule/ns_queue.cpp