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

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

NCBI C++ ToolKit: src/app/netschedule/ns_queue.hpp Source File

(

& queue_name,

& max_input_size,

& max_output_size,

& aff_token,

& group,

vector< pair<CJob, string> > & batch,

& group,

& job_key,

& auth_token,

timeout,

list<string> * aff_list,

exclusive_new_affinity,

prioritized_aff,

list<string> * group_list,

& added_pref_aff);

list<string> & aff_to_add,

list<string> & aff_to_del,

list<string> & aff,

&

,

data_version);

& client_phid,

& progress_msg,

address,

need_progress_msg,

* last_event_index);

&

);

& job_key,

& auth_token,

& job_key,

& auth_token,

& aff_token,

& group,

& auth_token_ok,

& job_key,

& job_key,

is_ns_rollback =

);

& group,

& aff_token,

vector<TJobStatus> & statuses,

vector<string> & warnings);

timeout,

list<string> * aff_list,

reader_affinity,

exclusive_new_affinity,

prioritized_aff,

list<string> * group_list,

affinity_may_change,

group_may_change,

& added_pref_aff);

& job_key,

& auth_token);

& job_key,

& auth_token,

& err_msg,

& job_key,

& auth_token,

& job_key,

& job_key,

& auth_token,

& err_msg,

& client_was_found,

& old_session,

& had_wn_pref_affs,

& had_reader_pref_affs);

last_job,

add_job_id,

(

max_deleted);

& group,

& aff_token,

vector<TJobStatus> & job_statuses,

start_after_job_id,

(

job_id)

;

& client_was_found,

& session_was_reset,

& old_session,

& had_wn_pref_affs,

& had_reader_pref_affs);

& group_token,

& aff_token,

vector<string> & warnings)

;

& group_token,

& aff_token,

vector<string> & warnings)

;

(

& dump_dir_name);

(

& dump_dir_name);

(

& dump_dir_name);

& job_key,

& auth_token,

& err_msg,

(

jid,

excl,

aid) :

vector<unsigned int> & aff_ids,

use_pref_affinity,

exclusive_new_affinity,

prioritized_aff,

vector<unsigned int> & aff_ids,

use_pref_affinity,

exclusive_new_affinity,

prioritized_aff,

& scope);

picked_earlier,

picked_earlier,

& scope);

picked_earlier,

picked_earlier,

& scope);

& auth_token,

timeout,

exclusive_new_affinity,

timeout,

exclusive_new_affinity,

port);

start_after_job_id,

reader_affinity,

exclusive_new_affinity,

affinity_may_change,

group_may_change);

& job_key,

vector<CNetScheduleAPI::EJobStatus>

(program_name.empty())

unsigned int Count(void) const

bool IsAllowed(unsigned int ha) const

NetScheduler threaded server.

All clients registered to connect.

bool IsMatchingClient(const CQueueClientInfo &cinfo) const

bool IsConfigured() const

CFastMutex m_OperationLock

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

TPauseStatus GetPauseStatus(void) const

void SetPauseStatus(const CNSClientId &client, TPauseStatus status)

CFastMutex m_JobsToDeleteLock

unsigned int CountActiveJobs(void) const

map< string, size_t > x_GetRunningJobsPerClientIP(void)

CNSScopeRegistry m_ScopeRegistry

bool IsSubmitAllowed(unsigned host) const

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

CNSPreciseTime m_ClientRegistryTimeoutSubmitter

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

string DecorateJob(unsigned int job_id) const

void TimeLineRemove(unsigned int job_id)

void PurgeClientRegistry(const CNSPreciseTime &current_time)

map< unsigned int, CJob > m_Jobs

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

unsigned int m_DumpAffBufferSize

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

unsigned m_ReadFailedRetries

TPauseStatus m_PauseStatus

CNetScheduleServer * m_Server

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)

unsigned CountStatus(TJobStatus) const

bool IsProgramAllowed(const string &program_name) const

CQueueDataBase & m_QueueDB

CNSPreciseTime m_PendingTimeout

CJobStatusTracker m_StatusTracker

size_t GetClientsCount(void) const

unsigned m_MaxJobsPerClient

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_CheckExecutionTimeout(const CNSPreciseTime &queue_run_timeout, const CNSPreciseTime &queue_read_timeout, unsigned job_id, const CNSPreciseTime &curr_time, bool logging)

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

string PrintNotificationsList(bool verbose) const

unsigned int m_ClientRegistryMinWorkerNodes

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

const string & GetQueueName() const

void SetRefuseSubmits(bool val)

void PrintStatistics(size_t &aff_count) const

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

unsigned int LoadFromDump(const string &dump_dir_name)

string PrintClientsList(bool verbose) const

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

void NotifyListenersPeriodically(const CNSPreciseTime &current_time)

CNSPreciseTime m_ReadTimeout

CStatisticsCounters m_StatisticsCountersLastPrinted

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

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

bool ShouldPerfLogTransitions(void) const

void CheckExecutionTimeout(bool logging)

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

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

void RestorePauseStatus(TPauseStatus status)

CNSPreciseTime m_ClientRegistryTimeoutReader

unsigned int m_ClientRegistryMinUnknowns

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

unsigned int GetJobsToDeleteCount(void) const

CNSPreciseTime m_ReadBlacklistTime

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 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)

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

CNSPreciseTime m_ReaderTimeout

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

string GetAffinityTokenByID(unsigned int aff_id) const

CJobTimeLine * m_RunTimeLine

void Dump(const string &dump_dir_name)

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)

unsigned int PurgeAffinities(void)

void UpdatePerfLoggingSettings(const string &qclass)

void SetParameters(const SQueueParameters &params)

CNetScheduleKeyGenerator m_KeyGenerator

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

void SetClientScope(const CNSClientId &client)

CQueueClientInfoList m_ProgramVersionList

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

string PrintTransitionCounters(void) const

string PrintScopesList(bool verbose) const

CNSPreciseTime m_BlacklistTime

CNSPreciseTime NotifyExactListeners(void)

void CancelWaitRead(const CNSClientId &client)

CNetScheduleAccessList m_SubmHosts

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)

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)

unsigned int GetNextJobIdForBatch(unsigned count)

TParameterList GetParameters() const

void MarkClientAsAdmin(const CNSClientId &client)

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

TQueueKind GetQueueKind(void) const

CNSClientsRegistry m_ClientsRegistry

size_t GetNotifCount(void) const

unsigned GetFailedRetries() const

string x_GetJobsDumpFileName(const string &dump_dname) const

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

string MakeJobKey(unsigned int job_id) const

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

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)

unsigned int m_JobsToDeleteOps

bool GetRefuseSubmits(void) const

size_t GetGroupsCount(void) const

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

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

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

void RemoveDump(const string &dump_dir_name)

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

CNSPreciseTime m_ClientRegistryTimeoutAdmin

unsigned int CountAllJobs(void) const

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

void x_LogSubmit(const CJob &job)

void x_Erase(const TNSBitVector &job_ids, TJobStatus status)

Erase jobs from all structures, request delayed db deletion.

unsigned int m_DumpGroupBufferSize

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

CNSPreciseTime m_WNodeTimeout

list< pair< string, string > > TParameterList

CNetScheduleAccessList m_WnodeHosts

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

unsigned int m_ClientRegistryMinSubmitters

bool IsReaderAllowed(unsigned host) const

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

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

CNSPreciseTime m_ClientRegistryTimeoutWorkerNode

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

TJobStatus GetJobStatus(unsigned job_id) const

CNSPreciseTime GetMaxPendingWaitTimeout() const

void GetLinkedSections(map< string, map< string, string > > &linked_sections) const

unsigned int m_ReadJobsOps

TNSBitVector m_JobsToDelete

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)

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)

CNSPreciseTime GetTimeout() const

CNSPreciseTime GetReadTimeout() const

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

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 m_ClientRegistryMinReaders

CNSNotificationList m_NotificationsList

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)

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

size_t GetGroupSlotsUsed(void) const

void RegisterSocketWriteError(const CNSClientId &client)

size_t GetAffSlotsUsed(void) const

unsigned int m_ClientRegistryMinAdmins

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

CNSPreciseTime m_MaxPendingReadWaitTimeout

CNSPreciseTime m_ClientRegistryTimeoutUnknown

unsigned int PurgeGroups(void)

size_t GetScopeSlotsUsed(void) const

CStatisticsCounters m_StatisticsCounters

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)

bool IsWorkerAllowed(unsigned host) const

CNSAffinityRegistry m_AffinityRegistry

unsigned int m_DumpBufferSize

const bool & m_LogBatchEachJob

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)

CNetScheduleAccessList m_ReaderHosts

CNSPreciseTime GetPendingTimeout() const

CNSPreciseTime x_GetEstimatedJobLifetime(unsigned int job_id, TJobStatus status) const

map< string, string > m_LinkedSections

void PrintJobCounters(void) const

size_t GetGCBacklogCount(void) const

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

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

CNSGroupsRegistry m_GroupRegistry

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

CNSPreciseTime GetRunTimeout() const

CNSPreciseTime m_NotifHifreqPeriod

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

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

unsigned int m_DumpClientBufferSize

void StaleNodes(const CNSPreciseTime &current_time)

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

CJobGCRegistry m_GCRegistry

void PurgeBlacklistedJobs(void)

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

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

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

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 EraseJob(unsigned job_id, TJobStatus status)

void CancelWaitGet(const CNSClientId &client)

CNSPreciseTime m_MaxPendingWaitTimeout

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

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)

bool m_ShouldPerfLogTransitions

CNSPreciseTime m_RunTimeout

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)

unsigned int m_NotifLofreqMult

unsigned int DeleteBatch(unsigned int max_deleted)

CNSPreciseTime m_StatisticsCountersLastPrintedTimestamp

CNSPreciseTime m_HandicapTimeout

CRWLock m_RunTimeLineLock

vector< CNetScheduleAPI::EJobStatus > m_StatesForRead

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

CNSPreciseTime m_NotifHifreqInterval

void CountTransition(CNetScheduleAPI::EJobStatus from, CNetScheduleAPI::EJobStatus to, ETransitionPathOption path_option=eNone)

Timeline class for fast approximate time tracking.

Bitvector Bit-vector container with runtime compression of bits.

size_type count() const noexcept

population count (count of ON bits)

static const struct attribute attributes[]

static SQLCHAR output[256]

EJobStatus

Job status codes.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

void ParseVersionString(const string &vstr, string *program_name, CVersionInfo *ver)

Parse string, extract version info and program name (case insensitive)

NetSchedule job status tracker.

Process information in the NCBI Registry, including working with configuration files.

The NCBI C++/STL use hints.

NetSchedule garbage collection registry.

CTimeLine< TNSBitVector > CJobTimeLine

NetSchedule queue client version control.

static SLJIT_INLINE sljit_ins st(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

static CNamedPipeClient * client

Netschedule queue client info.

CVersionInfo version_info

x_SJobPick(unsigned int jid, bool excl, unsigned int aid)

Statistical information about bitset's memory allocation details.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4