feat(node/service): removed unbounded channels in kona-service actors and replaced with bounded ones#2045
Conversation
There was a problem hiding this comment.
Pull Request Overview
This PR replaces unbounded mpsc channels with bounded ones in several actor modules, ensuring that channel send operations now await their completion.
- Replace unbounded channels with their bounded counterparts and update send calls to be asynchronous.
- Update tests and supporting actor logic to align with the new bounded channel semantics.
Reviewed Changes
Copilot reviewed 6 out of 6 changed files in this pull request and generated 1 comment.
Show a summary per file
| File | Description |
|---|---|
| crates/supervisor/service/src/actors/l1_watcher_rpc.rs | Updated channel type and replaced synchronous send with asynchronous send awaiting the result. |
| crates/node/service/src/service/validator.rs | Replaced unbounded channels with bounded channels for consistency. |
| crates/node/service/src/actors/runtime.rs | Changed channel type in runtime actor and updated send calls to be asynchronous. |
| crates/node/service/src/actors/network.rs | Updated channel types and adjusted send calls to use .await for async behavior. |
| crates/node/service/src/actors/engine/actor.rs | Updated channel types and ensured send calls await proper completion. |
| crates/node/service/src/actors/derivation.rs | Replaced unbounded channels with bounded ones and updated send operations accordingly. |
Codecov ReportAttention: Patch coverage is
✅ All tests successful. No failed tests found.
☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
clabby
left a comment
There was a problem hiding this comment.
Looking good, thank you.
One nit along with Copilot's, then glad to approve :)
|
@clabby made the changes |
clabby
left a comment
There was a problem hiding this comment.
Looks good, pending CI. Thanks!
… and replaced with bounded ones (op-rs/kona#2045) Fixes op-rs/kona#1993
… and replaced with bounded ones (op-rs/kona#2045) Fixes #1993
Fixes #1993