From 021e27fc5af34eab44297b9a49a53a65b27f6865 Mon Sep 17 00:00:00 2001 From: Fred Suter Date: Sun, 19 Nov 2023 13:18:41 -0500 Subject: [PATCH] add specifying handling of timeout for MessImpl (none for now). Fix a bug on incomplete message transfer --- src/kernel/activity/ActivityImpl.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/kernel/activity/ActivityImpl.cpp b/src/kernel/activity/ActivityImpl.cpp index 69a6936e0d..015ca2064b 100644 --- a/src/kernel/activity/ActivityImpl.cpp +++ b/src/kernel/activity/ActivityImpl.cpp @@ -108,6 +108,10 @@ void ActivityImpl::wait_for(actor::ActorImpl* issuer, double timeout) if (state_ != State::WAITING && state_ != State::RUNNING) { finish(); } else { + /* As Messages in Message Queues are virtually instantaneous, we do not need a timeout */ + /* Or maybe we do, and will have to implement a specific way to handle them is need arises */ + if (dynamic_cast(this) != nullptr) + return; /* we need a sleep action (even when the timeout is infinite) to be notified of host failures */ /* Comms handle that a bit differently of the other activities */ if (auto* comm = dynamic_cast(this)) { -- 2.20.1