X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/863aeead864a309c494893a1b06ec33ed2b7daf1..568abe14c697e195ea0443db97394979a74c36a0:/src/simix/smx_synchro.cpp diff --git a/src/simix/smx_synchro.cpp b/src/simix/smx_synchro.cpp index c063d085b0..6f5395883f 100644 --- a/src/simix/smx_synchro.cpp +++ b/src/simix/smx_synchro.cpp @@ -27,9 +27,10 @@ static smx_activity_t SIMIX_synchro_wait(sg_host_t smx_host, double timeout) { XBT_IN("(%p, %f)",smx_host,timeout); - simgrid::kernel::activity::Raw *sync = new simgrid::kernel::activity::Raw(); + simgrid::kernel::activity::RawImplPtr sync = + simgrid::kernel::activity::RawImplPtr(new simgrid::kernel::activity::RawImpl()); sync->sleep = smx_host->pimpl_cpu->sleep(timeout); - sync->sleep->setData(sync); + sync->sleep->setData(&*sync); XBT_OUT(); return sync; } @@ -67,7 +68,7 @@ void SIMIX_synchro_stop_waiting(smx_actor_t process, smx_simcall_t simcall) void SIMIX_synchro_finish(smx_activity_t synchro) { - XBT_IN("(%p)",synchro); + XBT_IN("(%p)", synchro.get()); smx_simcall_t simcall = synchro->simcalls.front(); synchro->simcalls.pop_front(); @@ -89,7 +90,6 @@ void SIMIX_synchro_finish(smx_activity_t synchro) SIMIX_synchro_stop_waiting(simcall->issuer, simcall); simcall->issuer->waiting_synchro = nullptr; - delete synchro; SIMIX_simcall_answer(simcall); XBT_OUT(); } @@ -170,12 +170,11 @@ void MutexImpl::unlock(smx_actor_t issuer) /* If the mutex is not owned by the issuer, that's not good */ if (issuer != this->owner) THROWF(mismatch_error, 0, "Cannot release that mutex: it was locked by %s (pid:%ld), not by you.", - this->owner->name.c_str(),this->owner->pid); + this->owner->cname(), this->owner->pid); if (xbt_swag_size(this->sleeping) > 0) { /*process to wake up */ smx_actor_t p = (smx_actor_t) xbt_swag_extract(this->sleeping); - delete p->waiting_synchro; p->waiting_synchro = nullptr; this->owner = p; SIMIX_simcall_answer(&p->simcall); @@ -318,7 +317,6 @@ void SIMIX_cond_signal(smx_cond_t cond) if ((proc = (smx_actor_t) xbt_swag_extract(cond->sleeping))) { /* Destroy waiter's synchronization */ - delete proc->waiting_synchro; proc->waiting_synchro = nullptr; /* Now transform the cond wait simcall into a mutex lock one */ @@ -431,7 +429,6 @@ void SIMIX_sem_release(smx_sem_t sem) XBT_DEBUG("Sem release semaphore %p", sem); if ((proc = (smx_actor_t) xbt_swag_extract(sem->sleeping))) { - delete proc->waiting_synchro; proc->waiting_synchro = nullptr; SIMIX_simcall_answer(&proc->simcall); } else {