X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a0c5b1ab11469128ad826610f54b1f0f332bd172..0aae6c51e099a78ed3fc858bd8dceca62ca1e83c:/src/kernel/activity/CommImpl.cpp?ds=sidebyside diff --git a/src/kernel/activity/CommImpl.cpp b/src/kernel/activity/CommImpl.cpp index 85ccbea5c1..7f19e426da 100644 --- a/src/kernel/activity/CommImpl.cpp +++ b/src/kernel/activity/CommImpl.cpp @@ -6,8 +6,8 @@ #include "src/kernel/activity/CommImpl.hpp" #include "simgrid/modelchecker.h" -#include "src/mc/mc_replay.h" -#include "src/simix/smx_network_private.h" +#include "src/mc/mc_replay.hpp" +#include "src/simix/smx_network_private.hpp" #include "src/surf/surf_interface.hpp" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_network); @@ -17,7 +17,6 @@ simgrid::kernel::activity::CommImpl::CommImpl(e_smx_comm_type_t _type) : type(_t state = SIMIX_WAITING; src_data = nullptr; dst_data = nullptr; - intrusive_ptr_add_ref(this); XBT_DEBUG("Create comm activity %p", this); } @@ -62,7 +61,6 @@ void simgrid::kernel::activity::CommImpl::cancel() if (state == SIMIX_WAITING) { mbox->remove(this); state = SIMIX_CANCELED; - this->unref(); } else if (not MC_is_active() /* when running the MC there are no surf actions */ && not MC_record_replay_is_active() && (state == SIMIX_READY || state == SIMIX_RUNNING)) { @@ -124,6 +122,5 @@ void simgrid::kernel::activity::CommImpl::post() /* if there are simcalls associated with the synchro, then answer them */ if (not simcalls.empty()) { SIMIX_comm_finish(this); - this->unref(); } }