X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/08668c93eec47c236766aae49bc39e3c772180f9..0184f298bc4cc735d2cf2604e430d85d350d4b7c:/src/kernel/activity/ExecImpl.cpp diff --git a/src/kernel/activity/ExecImpl.cpp b/src/kernel/activity/ExecImpl.cpp index 07b3c4eb81..0e4d8ed443 100644 --- a/src/kernel/activity/ExecImpl.cpp +++ b/src/kernel/activity/ExecImpl.cpp @@ -72,23 +72,11 @@ ExecImpl& ExecImpl::set_hosts(const std::vector& hosts) return *this; } -ExecImpl& ExecImpl::set_name(const std::string& name) -{ - ActivityImpl::set_name(name); - return *this; -} - -ExecImpl& ExecImpl::set_tracing_category(const std::string& category) -{ - ActivityImpl::set_category(category); - return *this; -} - ExecImpl& ExecImpl::set_timeout(double timeout) { if (timeout > 0 && not MC_is_active() && not MC_record_replay_is_active()) { timeout_detector_ = hosts_.front()->pimpl_cpu->sleep(timeout); - timeout_detector_->set_data(this); + timeout_detector_->set_activity(this); } return *this; } @@ -121,12 +109,14 @@ ExecImpl* ExecImpl::start() if (hosts_.size() == 1) { surf_action_ = hosts_.front()->pimpl_cpu->execution_start(flops_amounts_.front()); surf_action_->set_priority(priority_); + surf_action_->set_category(get_tracing_category()); + if (bound_ > 0) surf_action_->set_bound(bound_); } else { surf_action_ = surf_host_model->execute_parallel(hosts_, flops_amounts_.data(), bytes_amounts_.data(), -1); } - surf_action_->set_data(this); + surf_action_->set_activity(this); } XBT_DEBUG("Create execute synchro %p: %s", this, get_cname()); @@ -134,18 +124,6 @@ ExecImpl* ExecImpl::start() return this; } -void ExecImpl::cancel() -{ - XBT_VERB("This exec %p is canceled", this); - if (surf_action_ != nullptr) - surf_action_->cancel(); -} - -double ExecImpl::get_remaining() const -{ - return surf_action_ ? surf_action_->get_remains() : 0; -} - double ExecImpl::get_seq_remaining_ratio() { return (surf_action_ == nullptr) ? 0 : surf_action_->get_remains() / surf_action_->get_cost(); @@ -253,13 +231,13 @@ ActivityImpl* ExecImpl::migrate(s4u::Host* to) resource::Action* old_action = this->surf_action_; resource::Action* new_action = to->pimpl_cpu->execution_start(old_action->get_cost()); new_action->set_remains(old_action->get_remains()); - new_action->set_data(this); + new_action->set_activity(this); new_action->set_priority(old_action->get_priority()); // FIXME: the user-defined bound seem to not be kept by LMM, that seem to overwrite it for the multi-core modeling. // I hope that the user did not provide any. - old_action->set_data(nullptr); + old_action->set_activity(nullptr); old_action->cancel(); old_action->unref(); this->surf_action_ = new_action;