X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0184f298bc4cc735d2cf2604e430d85d350d4b7c..149c63f36e15b8500b1e826bda5138318ff7ba2b:/src/kernel/activity/SleepImpl.cpp diff --git a/src/kernel/activity/SleepImpl.cpp b/src/kernel/activity/SleepImpl.cpp index d236948db8..4df963b9a9 100644 --- a/src/kernel/activity/SleepImpl.cpp +++ b/src/kernel/activity/SleepImpl.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -42,38 +42,33 @@ void SleepImpl::post() { if (surf_action_->get_state() == resource::Action::State::FAILED) { if (host_ && not host_->is_on()) - state_ = SIMIX_SRC_HOST_FAILURE; + state_ = State::SRC_HOST_FAILURE; else - state_ = SIMIX_CANCELED; + state_ = State::CANCELED; } else if (surf_action_->get_state() == resource::Action::State::FINISHED) { - state_ = SIMIX_DONE; + state_ = State::DONE; } + /* Answer all simcalls associated with the synchro */ finish(); } void SleepImpl::finish() { while (not simcalls_.empty()) { - smx_simcall_t simcall = simcalls_.front(); + const s_smx_simcall* simcall = simcalls_.front(); simcalls_.pop_front(); - if (state_ == SIMIX_SRC_HOST_FAILURE) { - /* If the host running the synchro failed, notice it. This way, the asking - * actor can be killed if it runs on that host itself */ - simcall->issuer->context_->iwannadie = true; - simcall->issuer->exception_ = std::make_exception_ptr(HostFailureException(XBT_THROW_POINT, "Host failed")); - } - simcall_process_sleep__set__result(simcall, state_); - simcall->issuer->waiting_synchro = nullptr; - if (simcall->issuer->is_suspended()) { + simcall->issuer_->waiting_synchro = nullptr; + if (simcall->issuer_->is_suspended()) { XBT_DEBUG("Wait! This process is suspended and can't wake up now."); - simcall->issuer->suspended_ = false; - simcall_HANDLER_process_suspend(simcall, simcall->issuer); + simcall->issuer_->suspended_ = false; + simcall->issuer_->suspend(); } else { - SIMIX_simcall_answer(simcall); + simcall->issuer_->simcall_answer(); } } - SIMIX_process_sleep_destroy(this); + + clean_action(); } } // namespace activity } // namespace kernel