X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2e149d576acfd464c0b170a52845f3e94dde9d1c..66e4277badef8f22852720b79a78e1f091c3b679:/src/simix/ActorImpl.cpp diff --git a/src/simix/ActorImpl.cpp b/src/simix/ActorImpl.cpp index 9b0f19bdbb..6560ccd4e4 100644 --- a/src/simix/ActorImpl.cpp +++ b/src/simix/ActorImpl.cpp @@ -56,12 +56,6 @@ void SIMIX_process_cleanup(smx_actor_t process) XBT_DEBUG("Cleanup process %s (%p), waiting synchro %p", process->get_cname(), process, process->waiting_synchro.get()); - /* Unregister from the kill timer if any */ - if (process->kill_timer != nullptr) { - SIMIX_timer_remove(process->kill_timer); - process->kill_timer = nullptr; - } - simix_global->mutex.lock(); simix_global->process_list.erase(process->pid_); @@ -201,8 +195,8 @@ smx_activity_t ActorImpl::sleep(double duration) simgrid::kernel::activity::SleepImpl* synchro = new simgrid::kernel::activity::SleepImpl(); synchro->host = host_; - synchro->surf_sleep = host_->pimpl_cpu->sleep(duration); - synchro->surf_sleep->set_data(synchro); + synchro->surf_action_ = host_->pimpl_cpu->sleep(duration); + synchro->surf_action_->set_data(synchro); XBT_DEBUG("Create sleep synchronization %p", synchro); return synchro; @@ -468,8 +462,8 @@ void SIMIX_process_kill(smx_actor_t actor, smx_actor_t issuer) if (i != actor->waiting_synchro->simcalls_.end()) actor->waiting_synchro->simcalls_.remove(&actor->simcall); } else if (sleep != nullptr) { - if (sleep->surf_sleep) - sleep->surf_sleep->cancel(); + if (sleep->surf_action_) + sleep->surf_action_->cancel(); sleep->post(); } else if (raw != nullptr) { SIMIX_synchro_stop_waiting(actor, &actor->simcall); @@ -632,8 +626,8 @@ smx_activity_t SIMIX_process_join(smx_actor_t issuer, smx_actor_t process, doubl SIMIX_process_on_exit(process, [](int, void* arg) { auto sleep = static_cast(arg); - if (sleep->surf_sleep) - sleep->surf_sleep->finish(simgrid::kernel::resource::Action::State::FINISHED); + if (sleep->surf_action_) + sleep->surf_action_->finish(simgrid::kernel::resource::Action::State::FINISHED); intrusive_ptr_release(sleep); }, res.get()); @@ -659,9 +653,9 @@ void SIMIX_process_sleep_destroy(smx_activity_t synchro) simgrid::kernel::activity::SleepImplPtr sleep = boost::dynamic_pointer_cast(synchro); - if (sleep->surf_sleep) { - sleep->surf_sleep->unref(); - sleep->surf_sleep = nullptr; + if (sleep->surf_action_) { + sleep->surf_action_->unref(); + sleep->surf_action_ = nullptr; } }