fud v2

src/server.rs

@@ -168,13 +168,15 @@ where
 
             let server = self.clone();
             let listener_clone = listener.clone();
+
             tokio::spawn(async move {
-                let s = server.clone();
+
                 backoff::future::retry::<_, BoxError, _, _, _>(
                     ExponentialBackoff::default(),
                     || async {
                         match listener_clone.accept().await {
                             Ok((socket, _addr)) => {
+                                let s = server.clone();
                                 let conn = Connection {
                                     consensus: s.consensus.clone(),
                                     mempool: s.mempool.clone(),
@@ -183,6 +185,7 @@ where
                                 };
 
                                 if let Err(e) = conn.run(socket).await {
+                                    drop(s);
                                     match e.downcast::<tower::load_shed::error::Overloaded>() {
                                         Err(e) => {
                                             tracing::error!({ %e }, "error in a connection handler");