55 unsigned int group_id,
58 SJobGCInfo job_attr(aff_id, group_id, life_time);
61 pair<unsigned int, SJobGCInfo> item(job_id, job_attr);
70 unsigned int group_id)
76 attrs->second.m_AffinityID = aff_id;
77 attrs->second.m_GroupID = group_id;
87 unsigned int * aff_id,
88 unsigned int * group_id)
95 "Testing life time of non-registered job (ID: " +
96 to_string(job_id) +
")");
98 if (current_time < attrs->second.m_LifeTime)
102 *aff_id = attrs->second.m_AffinityID;
103 *group_id = attrs->second.m_GroupID;
118 "Updating life time of non-registered job (ID: " +
119 to_string(job_id) +
")");
121 attrs->second.m_LifeTime = life_time;
136 "Updating read vacant time of non-registered job (ID: " +
137 to_string(job_id) +
")");
139 if (attrs->second.m_ReadVacantTime ==
kTimeNever)
140 attrs->second.m_ReadVacantTime = read_vacant_time;
152 "Retreiving life time of non-registered job (ID: " +
153 to_string(job_id) +
")");
155 return attrs->second.m_LifeTime;
168 return attrs->second.m_AffinityID;
181 return attrs->second.m_GroupID;
195 return attrs->second.m_SubmitTime;
209 return attrs->second.m_ReadVacantTime;
220 if (cmd_group ==
eGet)
CNSPreciseTime GetLifetime(unsigned int job_id) const
bool DeleteIfTimedOut(unsigned int job_id, const CNSPreciseTime ¤t_time, unsigned int *aff_id, unsigned int *group_id)
void UpdateReadVacantTime(unsigned int job_id, const CNSPreciseTime &read_vacant_time)
void RegisterJob(unsigned int job_id, const CNSPreciseTime &submit_time, unsigned int aff_id, unsigned int group_id, const CNSPreciseTime &life_time)
CNSPreciseTime GetPreciseReadVacantTime(unsigned int job_id) const
void UpdateLifetime(unsigned int job_id, const CNSPreciseTime &life_time)
unsigned int GetAffinityID(unsigned int job_id) const
CNSPreciseTime GetPreciseSubmitTime(unsigned int job_id) const
map< unsigned int, SJobGCInfo > m_JobsAttrs
unsigned int GetGroupID(unsigned int job_id) const
bool IsOutdatedJob(unsigned int job_id, ECommandGroup cmd_group, const CNSPreciseTime &timeout) const
void ChangeAffinityAndGroup(unsigned int job_id, unsigned int aff_id, unsigned int group_id)
static CNSPreciseTime Current(void)
NetSchedule internal exception.
const_iterator end() const
iterator_bool insert(const value_type &val)
const_iterator find(const key_type &key) const
Include a standard set of the NCBI C++ Toolkit most basic headers.
#define NCBI_THROW(exception_class, err_code, message)
Generic macro to throw an exception, given the exception class, error code and message string.
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
unsigned int
A callback function used to compare two keys in a database.
NetSchedule client specs.
NetSchedule garbage collection registry.
const CNSPreciseTime kTimeZero
const CNSPreciseTime kTimeNever
CNSPreciseTime m_SubmitTime