comm->cancel();
}
- XBT_DEBUG("%p should not be run anymore",process);
+ XBT_DEBUG("%s@%s(%ld) should not run anymore", process->get_cname(), process->iface()->get_host()->get_cname(),
+ process->pid_);
simix_global->process_list.erase(process->pid_);
if (process->host_ && process->host_process_list_hook.is_linked())
simgrid::xbt::intrusive_erase(process->host_->pimpl_->process_list_, *process);
process->suspended_ = false;
process->exception = nullptr;
+ if (process->host_->is_off())
+ process->throw_exception(std::make_exception_ptr(simgrid::HostFailureException(XBT_THROW_POINT, "Host failed")));
+
/* destroy the blocking synchro if any */
if (process->waiting_synchro != nullptr) {
- if (process->host_->is_off())
- process->throw_exception(std::make_exception_ptr(simgrid::HostFailureException(XBT_THROW_POINT, "Host failed")));
+
simgrid::kernel::activity::ExecImplPtr exec =
boost::dynamic_pointer_cast<simgrid::kernel::activity::ExecImpl>(process->waiting_synchro);
simgrid::kernel::activity::CommImplPtr comm =
} else if (io != nullptr) {
delete io.get();
} else {
- xbt_die("Unknown type of activity");
+ simgrid::kernel::activity::ActivityImplPtr activity = process->waiting_synchro;
+ xbt_die("Activity %s is of unknown type %s", activity->name_.c_str(),
+ simgrid::xbt::demangle(typeid(activity).name()).get());
}
process->waiting_synchro = nullptr;
XBT_DEBUG("Process %s@%s is dead", self->get_cname(), self->host_->get_cname());
self->context_->stop();
+ xbt_die("I should be dead by now.");
}
if (self->suspended_) {