From 8b7bf576d2b3ceb3e5b6cdae7a00989bebb3b4c4 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Mon, 26 Oct 2026 18:44:09 +0100
Subject: add sync lanes

---
 src/node.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

(limited to 'src/node.rs')

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;
         });
-- 
cgit v1.3.1