X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a181dd511948fe35733ca7bc5c0a3e95d10722b1..4a8bc21517c2e7759a0036d879338f84ed6bf56e:/src/s4u/s4u_Exec.cpp?ds=sidebyside diff --git a/src/s4u/s4u_Exec.cpp b/src/s4u/s4u_Exec.cpp index 5f1d222747..884433ac64 100644 --- a/src/s4u/s4u_Exec.cpp +++ b/src/s4u/s4u_Exec.cpp @@ -15,7 +15,7 @@ namespace s4u { simgrid::xbt::signal s4u::Exec::on_start; simgrid::xbt::signal s4u::Exec::on_completion; -Activity* Exec::start() +Exec* Exec::start() { pimpl_ = simcall_execution_start(name_, tracing_category_, flops_amount_, 1. / priority_, bound_, host_); state_ = State::STARTED; @@ -23,22 +23,24 @@ Activity* Exec::start() return this; } -Activity* Exec::cancel() +Exec* Exec::cancel() { simgrid::simix::simcall([this] { dynamic_cast(pimpl_.get())->cancel(); }); state_ = State::CANCELED; return this; } -Activity* Exec::wait() +Exec* Exec::wait() { + if (state_ == State::INITED) + start(); simcall_execution_wait(pimpl_); state_ = State::FINISHED; on_completion(Actor::self()); return this; } -Activity* Exec::wait(double timeout) +Exec* Exec::wait_for(double timeout) { THROW_UNIMPLEMENTED; return this;