A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
| inline |
side by side
Sanitize the handling of timeouts in CommImpl, ExecImpl and IoImpl
[simgrid.git]
/
src
/
kernel
/
activity
/
CommImpl.cpp
diff --git
a/src/kernel/activity/CommImpl.cpp
b/src/kernel/activity/CommImpl.cpp
index
ee24f50
..
0d81366
100644
(file)
--- a/
src/kernel/activity/CommImpl.cpp
+++ b/
src/kernel/activity/CommImpl.cpp
@@
-96,7
+96,7
@@
CommImpl::~CommImpl()
{
XBT_DEBUG("Really free communication %p in state %s (detached = %d)", this, get_state_str(), detached_);
- clean
up_surf
();
+ clean
_action
();
if (detached_ && get_state() != State::DONE) {
/* the communication has failed and was detached:
@@
-397,22
+397,6
@@
void CommImpl::cancel()
}
}
-/** @brief This is part of the cleanup process, probably an internal command */
-void CommImpl::cleanup_surf()
-{
- clean_action();
-
- if (src_timeout_) {
- src_timeout_->unref();
- src_timeout_ = nullptr;
- }
-
- if (dst_timeout_) {
- dst_timeout_->unref();
- dst_timeout_ = nullptr;
- }
-}
-
void CommImpl::post()
{
on_completion(*this);
@@
-438,7
+422,7
@@
void CommImpl::post()
src_actor_.get(), dst_actor_.get(), detached_);
/* destroy the model actions associated with the communication activity */
- clean
up_surf
();
+ clean
_action
();
/* Answer all simcalls associated with the synchro */
finish();