From 88823b8462f73fbea76f8fde1b0134ac8060c69e Mon Sep 17 00:00:00 2001 From: Leo-Besancon Date: Tue, 2 Jul 2024 16:12:28 +0200 Subject: [PATCH] Fix async msg same slot (#4718) * fix open rpc spec (#4716) * Add eliminated_new_messages in eliminated_msg --------- Co-authored-by: Modship --- massa-execution-worker/src/speculative_async_pool.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/massa-execution-worker/src/speculative_async_pool.rs b/massa-execution-worker/src/speculative_async_pool.rs index e0d1080a275..4413fd35609 100644 --- a/massa-execution-worker/src/speculative_async_pool.rs +++ b/massa-execution-worker/src/speculative_async_pool.rs @@ -221,9 +221,14 @@ impl SpeculativeAsyncPool { } // Query eliminated messages - let eliminated_msg = + let mut eliminated_msg = self.fetch_msgs(eliminated_infos.iter().map(|(id, _)| id).collect(), true); + eliminated_msg.extend(eliminated_new_messages.iter().filter_map(|(k, v)| match v { + SetUpdateOrDelete::Set(v) => Some((*k, v.clone())), + SetUpdateOrDelete::Update(_v) => None, + SetUpdateOrDelete::Delete => None, + })); eliminated_msg }