From 234ea945d5d53bde9a68b8c3ee770da19c3f5d79 Mon Sep 17 00:00:00 2001
From: haixuantao <tao.xavier@outlook.com>
Date: Thu, 5 Dec 2024 17:43:26 +0100
Subject: [PATCH] Fix clippy warning about queue size within listener loop

---
 binaries/daemon/src/node_communication/mod.rs         | 3 ---
 binaries/daemon/src/node_communication/shmem.rs       | 2 +-
 binaries/daemon/src/node_communication/tcp.rs         | 2 +-
 binaries/daemon/src/node_communication/unix_domain.rs | 2 +-
 4 files changed, 3 insertions(+), 6 deletions(-)

diff --git a/binaries/daemon/src/node_communication/mod.rs b/binaries/daemon/src/node_communication/mod.rs
index 2da07620..31b11aa4 100644
--- a/binaries/daemon/src/node_communication/mod.rs
+++ b/binaries/daemon/src/node_communication/mod.rs
@@ -184,7 +184,6 @@ struct Listener {
     subscribed_events: Option<UnboundedReceiver<Timestamped<NodeEvent>>>,
     subscribed_drop_events: Option<UnboundedReceiver<Timestamped<NodeDropEvent>>>,
     queue: VecDeque<Box<Option<Timestamped<NodeEvent>>>>,
-    queue_sizes: BTreeMap<DataId, usize>,
     clock: Arc<uhlc::HLC>,
 }
 
@@ -192,7 +191,6 @@ impl Listener {
     pub(crate) async fn run<C: Connection>(
         mut connection: C,
         daemon_tx: mpsc::Sender<Timestamped<Event>>,
-        queue_sizes: BTreeMap<DataId, usize>,
         hlc: Arc<uhlc::HLC>,
     ) {
         // receive the first message
@@ -233,7 +231,6 @@ impl Listener {
                             daemon_tx,
                             subscribed_events: None,
                             subscribed_drop_events: None,
-                            queue_sizes,
                             queue: VecDeque::new(),
                             clock: hlc.clone(),
                         };
diff --git a/binaries/daemon/src/node_communication/shmem.rs b/binaries/daemon/src/node_communication/shmem.rs
index 61133ada..9f94b25a 100644
--- a/binaries/daemon/src/node_communication/shmem.rs
+++ b/binaries/daemon/src/node_communication/shmem.rs
@@ -39,7 +39,7 @@ pub async fn listener_loop(
         }
     });
     let connection = ShmemConnection(tx);
-    Listener::run(connection, daemon_tx, queue_sizes, clock).await
+    Listener::run(connection, daemon_tx, clock).await
 }
 
 enum Operation {
diff --git a/binaries/daemon/src/node_communication/tcp.rs b/binaries/daemon/src/node_communication/tcp.rs
index 20402960..a2114a3e 100644
--- a/binaries/daemon/src/node_communication/tcp.rs
+++ b/binaries/daemon/src/node_communication/tcp.rs
@@ -54,7 +54,7 @@ async fn handle_connection_loop(
         tracing::warn!("failed to set nodelay for connection: {err}");
     }
 
-    Listener::run(TcpConnection(connection), daemon_tx, queue_sizes, clock).await
+    Listener::run(TcpConnection(connection), daemon_tx, clock).await
 }
 
 struct TcpConnection(TcpStream);
diff --git a/binaries/daemon/src/node_communication/unix_domain.rs b/binaries/daemon/src/node_communication/unix_domain.rs
index 4348afe8..5905e1e6 100644
--- a/binaries/daemon/src/node_communication/unix_domain.rs
+++ b/binaries/daemon/src/node_communication/unix_domain.rs
@@ -52,7 +52,7 @@ async fn handle_connection_loop(
     queue_sizes: BTreeMap<DataId, usize>,
     clock: Arc<HLC>,
 ) {
-    Listener::run(UnixConnection(connection), daemon_tx, queue_sizes, clock).await
+    Listener::run(UnixConnection(connection), daemon_tx, clock).await
 }
 
 struct UnixConnection(UnixStream);