Skip to content

Commit

Permalink
Fix async msg same slot (#4718)
Browse files Browse the repository at this point in the history
* fix open rpc spec (#4716)

* Add eliminated_new_messages in eliminated_msg

---------

Co-authored-by: Modship <yeskinokay@gmail.com>
  • Loading branch information
Leo-Besancon and modship authored Jul 2, 2024
1 parent 5ae7c4c commit cb5c15a
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion massa-execution-worker/src/speculative_async_pool.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

Expand Down

0 comments on commit cb5c15a

Please sign in to comment.