#include "src/mc/mc_replay.hpp"
#include "src/mc/remote/Client.hpp"
#include "src/simix/smx_host_private.hpp"
-#include "src/simix/smx_io_private.hpp"
-#include "src/simix/smx_synchro_private.hpp"
#include "src/surf/HostImpl.hpp"
#include "src/surf/cpu_interface.hpp"
sleep->surf_action_->cancel();
sleep->post();
} else if (raw != nullptr) {
- SIMIX_synchro_stop_waiting(this, &simcall);
+ raw->finish();
} else if (io != nullptr) {
io->cancel();
} else {
return;
}
- XBT_DEBUG("Actor '%s'@%s is killing actor '%s'@%s", get_cname(), host_->get_cname(), actor->get_cname(),
- actor->host_->get_cname());
+ XBT_DEBUG("Actor '%s'@%s is killing actor '%s'@%s", get_cname(), host_ ? host_->get_cname() : "", actor->get_cname(),
+ actor->host_ ? actor->host_->get_cname() : "");
actor->exit();
if (kill_time <= SIMIX_get_clock())
return;
XBT_DEBUG("Set kill time %f for actor %s@%s", kill_time, get_cname(), host_->get_cname());
- kill_timer = SIMIX_timer_set(kill_time, [this] {
+ kill_timer = simix::Timer::set(kill_time, [this] {
this->exit();
kill_timer = nullptr;
});
double ActorImpl::get_kill_time()
{
- return SIMIX_timer_get_date(kill_timer);
+ return kill_timer ? kill_timer->get_date() : 0;
}
static void dying_daemon(int /*exit_status*/, void* data)
activity::RawImplPtr raw = boost::dynamic_pointer_cast<activity::RawImpl>(waiting_synchro);
if (raw != nullptr) {
- SIMIX_synchro_stop_waiting(this, &simcall);
+ raw->finish();
}
activity::IoImplPtr io = boost::dynamic_pointer_cast<activity::IoImpl>(waiting_synchro);
simgrid::kernel::activity::RawImplPtr raw =
boost::dynamic_pointer_cast<simgrid::kernel::activity::RawImpl>(actor->waiting_synchro);
if (raw != nullptr) {
- SIMIX_synchro_stop_waiting(actor, &actor->simcall);
+ raw->finish();
}
simgrid::kernel::activity::IoImplPtr io =