diff options
| author | tv <tv@krebsco.de> | 2026-10-26 18:44:09 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 18:44:09 +0100 |
| commit | 8b7bf576d2b3ceb3e5b6cdae7a00989bebb3b4c4 (patch) | |
| tree | d0896b2d61fe12cdafb8571bfbf6449c3a2ebf20 /src/node.rs | |
| parent | 27a996d3bf1b9e385602ff2cd7744d81057ef836 (diff) | |
add sync lanes
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/node.rs b/src/node.rs index 9200d16..5b55c8d 100644 --- a/src/node.rs +++ b/src/node.rs @@ -136,13 +136,17 @@ impl Node { let Self { state, sync_rx } = self; let consumer_state = state.clone(); + let lanes = Arc::new(peer::SyncLanes::start(&state)); tokio::spawn(async move { let inner_state = consumer_state.clone(); let _ = consumer_state .transport .start_consumer(Box::new(move |sender, msg, _payload_len| { let state_clone = inner_state.clone(); - Box::pin(async move { peer::handle_message(&state_clone, sender, msg).await }) + let lanes = Arc::clone(&lanes); + Box::pin(async move { + peer::handle_message(&state_clone, &lanes, sender, msg).await + }) })) .await; }); |
