X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1e83888c1aed0b9146b5ae78ad474f374d28a769..183a6118a95c570b0c66695505dab7dbebc0c7b3:/src/kernel/activity/CommImpl.cpp diff --git a/src/kernel/activity/CommImpl.cpp b/src/kernel/activity/CommImpl.cpp index aebf0556c2..33d31e7d03 100644 --- a/src/kernel/activity/CommImpl.cpp +++ b/src/kernel/activity/CommImpl.cpp @@ -17,8 +17,7 @@ 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 communicate synchro %p", this); + XBT_DEBUG("Create comm activity %p", this); } simgrid::kernel::activity::CommImpl::~CommImpl() @@ -62,7 +61,6 @@ void simgrid::kernel::activity::CommImpl::cancel() if (state == SIMIX_WAITING) { mbox->remove(this); state = SIMIX_CANCELED; - SIMIX_comm_unref(this); } 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); - SIMIX_comm_unref(this); } }