X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/499ee6ecf7dd2ec57ed57613da3ea947d42de781..281053ec9111f89a48c64f603cda926b9f6912af:/src/kernel/resource/Model.cpp diff --git a/src/kernel/resource/Model.cpp b/src/kernel/resource/Model.cpp index fab52e2bb5..63e662a208 100644 --- a/src/kernel/resource/Model.cpp +++ b/src/kernel/resource/Model.cpp @@ -16,21 +16,14 @@ Model::Model(Model::UpdateAlgo algo) : update_algorithm_(algo) {} Model::~Model() { - delete ready_action_set_; - delete running_action_set_; + delete inited_action_set_; + delete started_action_set_; delete failed_action_set_; - delete done_action_set_; + delete finished_action_set_; + delete ignored_action_set_; delete maxmin_system_; } -Action* Model::actionHeapPop() -{ - Action* action = action_heap_.top().second; - action_heap_.pop(); - action->heap_clear_handle(); - return action; -} - Action::ModifiedSet* Model::get_modified_set() const { return maxmin_system_->modified_set_; @@ -58,11 +51,11 @@ double Model::next_occuring_event_lazy(double now) maxmin_system_->modified_set_->pop_front(); bool max_duration_flag = false; - if (action->get_state_set() != running_action_set_) + if (action->get_state_set() != started_action_set_) continue; /* bogus priority, skip it */ - if (action->get_priority() <= 0 || action->get_type() == Action::Type::latency) + if (action->get_priority() <= 0 || action->get_type() == ActionHeap::Type::latency) continue; action->update_remains_lazy(now); @@ -93,7 +86,7 @@ double Model::next_occuring_event_lazy(double now) action->get_start_time(), min, share, action->get_max_duration()); if (min > -1) { - action->heapUpdate(min, max_duration_flag ? Action::Type::max_duration : Action::Type::normal); + action_heap_.update(action, min, max_duration_flag ? ActionHeap::Type::max_duration : ActionHeap::Type::normal); XBT_DEBUG("Insert at heap action(%p) min %f now %f", action, min, now); } else DIE_IMPOSSIBLE; @@ -101,7 +94,7 @@ double Model::next_occuring_event_lazy(double now) // hereafter must have already the min value for this resource model if (not action_heap_.empty()) { - double min = actionHeapTopDate() - now; + double min = action_heap_.top_date() - now; XBT_DEBUG("minimum with the HEAP %f", min); return min; } else { @@ -116,7 +109,7 @@ double Model::next_occuring_event_full(double /*now*/) double min = -1; - for (Action& action : *get_running_action_set()) { + for (Action& action : *get_started_action_set()) { double value = action.get_variable()->get_value(); if (value > 0) { if (action.get_remains() > 0)