X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/84402e8e2ee2a2d0bef25fdceb0a263ed8b471f6..1c5b745ccccf8d1dc40f3d17a1d6dcf6bc8badf0:/src/kernel/activity/ExecImpl.cpp diff --git a/src/kernel/activity/ExecImpl.cpp b/src/kernel/activity/ExecImpl.cpp index 43739e7688..e3d9d322c0 100644 --- a/src/kernel/activity/ExecImpl.cpp +++ b/src/kernel/activity/ExecImpl.cpp @@ -49,19 +49,6 @@ void simcall_HANDLER_execution_wait(smx_simcall_t simcall, simgrid::kernel::acti } } -void simcall_HANDLER_execution_test(smx_simcall_t simcall, simgrid::kernel::activity::ExecImpl* synchro) -{ - bool res = (synchro->state_ != simgrid::kernel::activity::State::WAITING && - synchro->state_ != simgrid::kernel::activity::State::RUNNING); - if (res) { - synchro->simcalls_.push_back(simcall); - synchro->finish(); - } else { - simcall->issuer_->simcall_answer(); - } - simcall_execution_test__set__result(simcall, res); -} - void simcall_HANDLER_execution_waitany_for(smx_simcall_t simcall, simgrid::kernel::activity::ExecImpl* execs[], size_t count, double timeout) { @@ -99,18 +86,9 @@ namespace simgrid { namespace kernel { namespace activity { -ExecImpl::~ExecImpl() -{ - if (timeout_detector_) - timeout_detector_->unref(); - XBT_DEBUG("Destroy exec %p", this); -} - ExecImpl& ExecImpl::set_host(s4u::Host* host) { - if (not hosts_.empty()) - hosts_.clear(); - hosts_.push_back(host); + hosts_.assign(1, host); return *this; } @@ -123,7 +101,7 @@ ExecImpl& ExecImpl::set_hosts(const std::vector& hosts) 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_.reset(hosts_.front()->pimpl_cpu->sleep(timeout)); timeout_detector_->set_activity(this); } return *this; @@ -131,9 +109,7 @@ ExecImpl& ExecImpl::set_timeout(double timeout) ExecImpl& ExecImpl::set_flops_amount(double flops_amount) { - if (not flops_amounts_.empty()) - flops_amounts_.clear(); - flops_amounts_.push_back(flops_amount); + flops_amounts_.assign(1, flops_amount); return *this; } @@ -210,12 +186,7 @@ void ExecImpl::post() } clean_action(); - - if (timeout_detector_) { - timeout_detector_->unref(); - timeout_detector_ = nullptr; - } - + timeout_detector_.reset(); /* Answer all simcalls associated with the synchro */ finish(); } @@ -264,7 +235,7 @@ void ExecImpl::finish() case State::FAILED: XBT_DEBUG("ExecImpl::finish(): host '%s' failed", simcall->issuer_->get_host()->get_cname()); - simcall->issuer_->context_->iwannadie = true; + simcall->issuer_->context_->set_wannadie(); if (simcall->issuer_->get_host()->is_on()) simcall->issuer_->exception_ = std::make_exception_ptr(simgrid::HostFailureException(XBT_THROW_POINT, "Host failed")); @@ -291,7 +262,7 @@ void ExecImpl::finish() if (simcall->issuer_->get_host()->is_on()) simcall->issuer_->simcall_answer(); else - simcall->issuer_->context_->iwannadie = true; + simcall->issuer_->context_->set_wannadie(); } }