WIP

core/src/serf/api.rs

@@ -589,7 +589,6 @@ where
       // channel signals that we are cleaned up outside of Serf.
       *s = SerfState::Shutdown;
     }
-    tracing::error!("debug: shutdown memberlist");
     self.inner.memberlist.shutdown().await?;
     self.inner.shutdown_tx.close();
 
@@ -598,7 +597,6 @@ where
       snap.wait().await;
     }
 
-    tracing::error!("debug: shutdown serf handles");
     loop {
       if let Ok(mut handles) = self.inner.handles.try_borrow_mut() {
         let mut futs = core::mem::take(&mut *handles);

core/src/serf/base/tests/serf/event.rs

@@ -988,6 +988,10 @@ pub async fn serf_query_filter<T>(
 
   assert_eq!(acks.len(), 1, "missing acks {acks:?}");
   assert_eq!(responses.len(), 1, "missing responses {responses:?}");
+
+  for s in serfs.iter() {
+    s.shutdown().await.unwrap();
+  }
 }
 
 /// Unit test for serf query deduplicate