src/app/netschedule/ns_queue.cpp File Reference

#include <ncbi_pch.hpp>
#include "ns_queue.hpp"
#include "background_host.hpp"
#include "ns_util.hpp"
#include "ns_format.hpp"
#include <corelib/ncbi_system.hpp>
#include <corelib/request_ctx.hpp>
#include <db/bdb/bdb_trans.hpp>
#include <util/qparse/query_parse.hpp>
#include <util/qparse/query_exec.hpp>
#include <util/qparse/query_exec_bv.hpp>
#include <util/bitset/bmalgo.h>

Include dependency graph for ns_queue.cpp:

Go to the source code of this file.

Classes
class	CTruncateRequest
class	CAffinityResolver
struct	SAffinityJobs
class	CQueryFunctionEQ
Defines
#define	GetIntNoErr(name, dflt)   reg.GetInt(sname, name, dflt, 0, IRegistry::eReturn)
#define	JSQ_PREFIX   "NCBI_JSQ_"
#define	NS_PRINT_TIME(msg, t)
#define	NS_PFNAME(x_fname)   (fflag ? x_fname : "")
Typedefs
typedef map< unsigned, SAffinityJobs >	TAffinities
Functions
static void	s_LogSubmit (CQueue &q, CJob &job, SQueueDescription &qdesc)
Variables
static const unsigned	k_max_dead_locks = 100
const unsigned	kMeasureInterval = 1
const unsigned	kDecayInterval = 10
const unsigned	kFixedShift = 7
const unsigned	kFixed_1 = 1 << kFixedShift
const unsigned	kDecayExp = 116

---

Define Documentation

#define GetIntNoErr (  name, dflt   )     reg.GetInt(sname, name, dflt, 0, IRegistry::eReturn)

#define JSQ_PREFIX   "NCBI_JSQ_"

Referenced by CQueue::NotifyListeners().

#define NS_PFNAME (  x_fname   )     (fflag ? x_fname : "")

Definition at line 3187 of file ns_queue.cpp. Referenced by CQueue::x_PrintJobStat().

#define NS_PRINT_TIME (  msg, t   )

Value: do \ { time_t tt = t; \ CTime _t(tt); _t.ToLocalTime(); \ out << msg << (tt ? _t.AsString() : kEmptyStr) << fsp; \ } while(0) Definition at line 3180 of file ns_queue.cpp. Referenced by CQueue::x_PrintJobStat().

---

Typedef Documentation

typedef map<unsigned, SAffinityJobs> TAffinities

Definition at line 1987 of file ns_queue.cpp.

---

Function Documentation

static void s_LogSubmit (  CQueue &  q, CJob &  job, SQueueDescription &  qdesc )  [static]

Definition at line 577 of file ns_queue.cpp. References CDiagContext::Extra(), FormatHostName(), CJob::GetAffinityToken(), CJob::GetClientIP(), CJob::GetClientSID(), GetDiagContext(), CJob::GetId(), CJob::GetInput(), CJob::GetMask(), CJob::GetProgressMsg(), CQueue::GetQueueName(), CDiagContext::GetRequestContext(), CJob::GetSubmAddr(), CJob::GetSubmPort(), CJob::GetSubmTimeout(), CJob::GetTags(), ITERATE, CDiagContext_Extra::Print(), CRequestContext::SetClientIP(), CRequestContext::SetSessionID(), and NStr::UIntToString(). Referenced by CQueue::Submit().

---

Variable Documentation

const unsigned k_max_dead_locks = 100 [static]

Definition at line 785 of file ns_queue.cpp.

const unsigned kDecayExp = 116

Definition at line 3391 of file ns_queue.cpp.

const unsigned kDecayInterval = 10

Definition at line 3387 of file ns_queue.cpp.

const unsigned kFixed_1 = 1 << kFixedShift

Definition at line 3389 of file ns_queue.cpp. Referenced by CQueue::GetAverage().

const unsigned kFixedShift = 7

Definition at line 3388 of file ns_queue.cpp.

const unsigned kMeasureInterval = 1

Definition at line 3385 of file ns_queue.cpp. Referenced by CQueue::GetAverage().

---