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

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

NCBI C++ ToolKit: src/connect/services/netschedule_api_getjob.cpp Source File

<

TImpl>

GetJobImpl(deadline, holder);

ReturnNotFullyCheckedServers();

GetJobImpl(deadline, holder);

list<CNetScheduleGetJob::SEntry>

;

<

TImpl>

() {

; }

()

{

; }

<

TImpl>

& timeline, TImpl& get_job_impl) :

affinity_ladder(

.m_API->m_AffinityLadder);

affinity_ladder.back().second;

affinity_ladder(

.m_API->m_AffinityLadder);

(

.

== affinity_ladder[priority].first) {

}

(priority-- > 0);

<

TImpl>

<

TJobHolder>

(

== eStopped) {

(

== eRestarted) {

(

== m_ImmediateActions.end()) {

holder.HasJob() ? eJob : eAgain;

(*

== m_DiscoveryAction) {

NextDiscoveryIteration();

increment =

;

& prio_aff_list = holder.Affinity();

any_affinity = !holder.HasJob();

(m_Impl.CheckEntry(*

, prio_aff_list, any_affinity,

holder.job, holder.job_status)) {

(

== m_ImmediateActions.begin()) {

m_ImmediateActions.splice(m_ImmediateActions.begin(),

m_ImmediateActions,

);

->deadline =

(m_Impl.m_Timeout, 0);

->all_affinities_checked = any_affinity;

m_ScheduledActions.splice(m_ScheduledActions.end(),

m_ImmediateActions,

);

m_ImmediateActions.erase(

);

m_ImmediateActions.erase(

);

(holder.HasJob()) {

(!m_ScheduledActions.empty() &&

m_ScheduledActions.front().deadline.GetRemainingTime().IsZero()) {

m_ImmediateActions.splice(m_ImmediateActions.end(),

m_ScheduledActions, m_ScheduledActions.begin());

(

server = m_Impl.ReadNotifications()) {

MoveToImmediateActions(server);

= holder.Next(increment);

<

TImpl>

<

TJobHolder>

& deadline, TJobHolder& holder)

ret = GetJobImmediately(holder);

entry_has_more_jobs = [&](

& entry) {

m_Impl.MoreJobs(entry);

(find_if(m_ScheduledActions.begin(), m_ScheduledActions.end(),

entry_has_more_jobs) == m_ScheduledActions.end()) {

(!m_ScheduledActions.empty());

next_event_time = m_ScheduledActions.front().deadline;

last_wait = deadline < next_event_time;

(last_wait) next_event_time = deadline;

(

server = m_Impl.WaitForNotifications(next_event_time)) {

MoveToImmediateActions(server);

}

((server = m_Impl.ReadNotifications()));

}

(last_wait) {

m_ImmediateActions.splice(m_ImmediateActions.end(),

m_ScheduledActions, m_ScheduledActions.begin());

TTimeline::iterator

= timeline.begin();

(

!= timeline.end()) {

TServers::iterator j = find(servers.begin(), servers.end(), address);

(j != servers.end()) {

timeline.erase(

++);

<

TImpl>

m_ImmediateActions.clear();

m_ScheduledActions.clear();

NextDiscoveryIteration();

<

TImpl>

TTimeline::iterator

= find(m_ScheduledActions.begin(),

m_ScheduledActions.end(), entry);

(

!= m_ScheduledActions.end()) {

m_ImmediateActions.splice(m_ImmediateActions.end(),

m_ScheduledActions,

);

TTimeline::iterator j = find(m_ImmediateActions.begin(),

m_ImmediateActions.end(), entry);

(j == m_ImmediateActions.end()) {

m_ImmediateActions.push_back(entry);

<

TImpl>

m_Impl.m_API.GetService().Iterate(

servers.push_back((*it)->m_ServerInPool->m_Address);

(m_ImmediateActions, servers);

(m_ScheduledActions, servers);

(TServers::const_iterator

= servers.begin();

!= servers.end(); ++

) {

m_ImmediateActions.push_back(*

);

m_DiscoveryAction.deadline =

(m_Impl.m_Timeout, 0);

m_ScheduledActions.push_back(m_DiscoveryAction);

<

TImpl>

(

!= m_ScheduledActions.end()) {

(

->all_affinities_checked) {

m_ImmediateActions.splice(m_ImmediateActions.end(),

m_ScheduledActions,

++);

CNetScheduleAPI::EJobStatus * job_status

CAnyAffinityJob(CNetScheduleJob &j, CNetScheduleAPI::EJobStatus *js, TTimeline &timeline)

const string & Affinity() const

CMostAffinityJob(CNetScheduleJob &j, CNetScheduleAPI::EJobStatus *js, TTimeline &timeline, TImpl &get_job_impl)

TIterator Next(bool increment)

CNetScheduleJob m_PreviousJob

CNetScheduleAPI::EJobStatus * job_status

const string & Affinity() const

EResult GetJobImpl(const CDeadline &deadline, TJobHolder &holder)

void NextDiscoveryIteration()

EResult GetJobImmediately(TJobHolder &holder)

void MoveToImmediateActions(SNetServerImpl *server_impl)

void ReturnNotFullyCheckedServers()

CNetScheduleGetJob::EResult GetJob(const CDeadline &deadline, CNetScheduleJob &job, CNetScheduleAPI::EJobStatus *job_status, bool any_affinity)

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

const string & GetMsg(void) const

Get message string.

void Warning(CExceptionArgs_Base &args)

EJobStatus

Job status codes.

string job_id

Output job key.

#define numeric_limits

Pre-declaration of the "numeric_limits<>" template Forcibly overrides (using preprocessor) the origin...

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

bool IsExpired(void) const

Check if the deadline is expired.

vector< CSeq_align const * >::const_iterator TIterator

list< SSocketAddress > TServers

TTimeline::iterator TIterator

list< CNetScheduleGetJob::SEntry > TTimeline

void Filter(TTimeline &timeline, TServers &servers)

vector< pair< string, string > > TAffinityLadder

CRef< SNetServerInPool > m_ServerInPool

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