X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4c8b729ca205a05b34613dfe73d5f1b542c189f6..51c23076e2b42ff07dc167dea1cb0e3a4ab3cf68:/src/s4u/s4u_Exec.cpp diff --git a/src/s4u/s4u_Exec.cpp b/src/s4u/s4u_Exec.cpp index 41ffe89a21..94e63f78ce 100644 --- a/src/s4u/s4u_Exec.cpp +++ b/src/s4u/s4u_Exec.cpp @@ -17,14 +17,14 @@ Activity* Exec::start() { pimpl_ = simcall_execution_start(nullptr, flops_amount_, 1. / priority_, 0., host_); boost::static_pointer_cast(pimpl_)->set_bound(bound_); - state_ = State::started; + state_ = State::STARTED; return this; } Activity* Exec::wait() { simcall_execution_wait(pimpl_); - state_ = State::finished; + state_ = State::FINISHED; return this; } @@ -37,16 +37,16 @@ Activity* Exec::wait(double timeout) /** @brief Returns whether the state of the exec is finished */ bool Exec::test() { - xbt_assert(state_ == State::inited || state_ == State::started || state_ == State::finished); + xbt_assert(state_ == State::INITED || state_ == State::STARTED || state_ == State::FINISHED); - if (state_ == State::finished) + if (state_ == State::FINISHED) return true; - if (state_ == State::inited) + if (state_ == State::INITED) this->start(); if (simcall_execution_test(pimpl_)) { - state_ = State::finished; + state_ = State::FINISHED; return true; } @@ -61,7 +61,7 @@ bool Exec::test() * Currently, this cannot be changed once the exec started. */ ExecPtr Exec::set_priority(double priority) { - xbt_assert(state_ == State::inited, "Cannot change the priority of an exec after its start"); + xbt_assert(state_ == State::INITED, "Cannot change the priority of an exec after its start"); priority_ = priority; return this; } @@ -72,7 +72,7 @@ ExecPtr Exec::set_priority(double priority) * Currently, this cannot be changed once the exec started. */ ExecPtr Exec::set_bound(double bound) { - xbt_assert(state_ == State::inited, "Cannot change the bound of an exec after its start"); + xbt_assert(state_ == State::INITED, "Cannot change the bound of an exec after its start"); bound_ = bound; return this; } @@ -82,9 +82,9 @@ ExecPtr Exec::set_bound(double bound) * The activity cannot be terminated already (but it may be started). */ ExecPtr Exec::set_host(Host* host) { - xbt_assert(state_ == State::inited || state_ == State::started, + xbt_assert(state_ == State::INITED || state_ == State::STARTED, "Cannot change the host of an exec once it's done (state: %d)", (int)state_); - if (state_ == State::started) + if (state_ == State::STARTED) boost::static_pointer_cast(pimpl_)->migrate(host); host_ = host; return this; @@ -99,7 +99,7 @@ Host* Exec::get_host() /** @brief Returns the amount of flops that remain to be done */ double Exec::get_remaining() { - return simgrid::simix::kernelImmediate( + return simgrid::simix::simcall( [this]() { return boost::static_pointer_cast(pimpl_)->get_remaining(); }); } @@ -109,7 +109,7 @@ double Exec::get_remaining() */ double Exec::get_remaining_ratio() { - return simgrid::simix::kernelImmediate([this]() { + return simgrid::simix::simcall([this]() { return boost::static_pointer_cast(pimpl_)->get_remaining_ratio(); }); }