X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/340307c06ecc6e3e02f73820da97f0c6479c62c5..b6fe7e75cd720400327e0585247824b7b82805aa:/src/simix/smx_synchro.cpp diff --git a/src/simix/smx_synchro.cpp b/src/simix/smx_synchro.cpp index c8ec7fe32c..cde0af9a52 100644 --- a/src/simix/smx_synchro.cpp +++ b/src/simix/smx_synchro.cpp @@ -7,9 +7,10 @@ #include "src/surf/surf_interface.hpp" #include "smx_private.h" -#include "xbt/log.h" +#include +#include -#include "src/simix/SynchroRaw.hpp" +#include "src/kernel/activity/SynchroRaw.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_synchro, simix, "SIMIX Synchronization (mutex, semaphores and conditions)"); @@ -26,7 +27,7 @@ static smx_synchro_t SIMIX_synchro_wait(sg_host_t smx_host, double timeout) { XBT_IN("(%p, %f)",smx_host,timeout); - simgrid::simix::Raw *sync = new simgrid::simix::Raw(); + simgrid::kernel::activity::Raw *sync = new simgrid::kernel::activity::Raw(); sync->sleep = surf_host_sleep(smx_host, timeout); sync->sleep->setData(sync); XBT_OUT(); @@ -97,7 +98,7 @@ void SIMIX_synchro_finish(smx_synchro_t synchro) namespace simgrid { namespace simix { -Mutex::Mutex() +Mutex::Mutex() : mutex_(this) { XBT_IN("(%p)", this); // Useful to initialize sleeping swag: @@ -237,9 +238,8 @@ smx_cond_t SIMIX_cond_init(void) { XBT_IN("()"); simgrid::simix::Process p; - smx_cond_t cond = xbt_new0(s_smx_cond_t, 1); + smx_cond_t cond = new s_smx_cond(); cond->sleeping = xbt_swag_new(xbt_swag_offset(p, synchro_hookup)); - cond->mutex = nullptr; cond->refcount_ = 1; XBT_OUT(); return cond; @@ -382,9 +382,8 @@ void intrusive_ptr_release(s_smx_cond_t *cond) if (count == 0) { xbt_assert(xbt_swag_size(cond->sleeping) == 0, "Cannot destroy conditional since someone is still using it"); - xbt_swag_free(cond->sleeping); - xbt_free(cond); + delete cond; } }