if wait_any_for timeouts, unref remaining pending comms

diff --git a/src/s4u/s4u_Comm.cpp b/src/s4u/s4u_Comm.cpp
index c77cada..e7cc4df 100644 (file)
--- a/src/s4u/s4u_Comm.cpp
+++ b/src/s4u/s4u_Comm.cpp
@@ -322,5 +322,8 @@ int sg_comm_wait_any_for(sg_comm_t* comms, size_t count, double timeout)
   int pos = simgrid::s4u::Comm::wait_any_for(&s4u_comms, timeout);
   if (pos != -1)
     s4u_comms[pos]->unref();
+  else
+    for (const auto& c : s4u_comms)
+      c->unref();
   return pos;
 }