X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/13fb4af932a02ea0bd4293d1e55ac071de326f80..f5ad0a2a3554dc8f10c8fbba5715b7c92ff1d350:/src/simix/smx_synchro.cpp diff --git a/src/simix/smx_synchro.cpp b/src/simix/smx_synchro.cpp index c063d085b0..66f332c15e 100644 --- a/src/simix/smx_synchro.cpp +++ b/src/simix/smx_synchro.cpp @@ -1,5 +1,4 @@ - -/* Copyright (c) 2007-2015. The SimGrid Team. +/* Copyright (c) 2007-2017. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -27,9 +26,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 +67,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 +89,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(); } @@ -169,13 +168,12 @@ 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); + THROWF(mismatch_error, 0, "Cannot release that mutex: it was locked by %s (pid:%lu), not by you.", + 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); @@ -205,11 +203,6 @@ void SIMIX_mutex_unref(smx_mutex_t mutex) intrusive_ptr_release(mutex); } -smx_mutex_t simcall_HANDLER_mutex_init(smx_simcall_t simcall) -{ - return new simgrid::simix::MutexImpl(); -} - // Simcall handlers: void simcall_HANDLER_mutex_lock(smx_simcall_t simcall, smx_mutex_t mutex) @@ -318,7 +311,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 */ @@ -416,9 +408,6 @@ void SIMIX_sem_destroy(smx_sem_t sem) XBT_OUT(); } -void simcall_HANDLER_sem_release(smx_simcall_t simcall, smx_sem_t sem){ - SIMIX_sem_release(sem); -} /** @brief release the semaphore * * Unlock a process waiting on the semaphore. @@ -431,7 +420,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 { @@ -448,9 +436,6 @@ int SIMIX_sem_would_block(smx_sem_t sem) return (sem->value <= 0); } -int simcall_HANDLER_sem_get_capacity(smx_simcall_t simcall, smx_sem_t sem){ - return SIMIX_sem_get_capacity(sem); -} /** @brief Returns the current capacity of the semaphore */ int SIMIX_sem_get_capacity(smx_sem_t sem) { @@ -499,6 +484,3 @@ void simcall_HANDLER_sem_acquire_timeout(smx_simcall_t simcall, smx_sem_t sem, d _SIMIX_sem_wait(sem, timeout, simcall->issuer, simcall); XBT_OUT(); } -int simcall_HANDLER_sem_would_block(smx_simcall_t simcall, smx_sem_t sem) { - return SIMIX_sem_would_block(sem); -}