Add doc on blocked flag used in sniffer and remove tracning duplicate

stratum-mining · Mar 4, 2025 · fcdb68e · fcdb68e
1 parent a9cbf0a
commit fcdb68e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/roles/tests-integration/lib/sniffer.rs b/roles/tests-integration/lib/sniffer.rs
@@ -282,6 +282,8 @@ impl Sniffer {
         downstream_messages: MessagesAggregator,
         action: Option<Action>,
     ) -> Result<(), SnifferError> {
+        // Blocking flag used in the IgnoreFromMessage action to stop processing messages after the
+        // desired interception.
         let mut blocked = false;
         while let Ok(mut frame) = recv.recv().await {
             if blocked {
@@ -331,6 +333,8 @@ impl Sniffer {
         upstream_messages: MessagesAggregator,
         action: Option<Action>,
     ) -> Result<(), SnifferError> {
+        // Blocking flag used in the IgnoreFromMessage action to stop processing messages after the
+        // desired interception.
         let mut blocked = false;
         while let Ok(mut frame) = recv.recv().await {
             if blocked {

diff --git a/roles/tests-integration/tests/sniffer_integration.rs b/roles/tests-integration/tests/sniffer_integration.rs
@@ -156,7 +156,6 @@ async fn test_sniffer_wait_for_message_type_with_remove() {
 /// `TP -> sniffer_a -> sniffer_b -> sniffer_c -> Pool`  
 #[tokio::test]
 async fn test_sniffer_blocks_message() {
-    start_tracing();
     let (_tp, tp_addr) = start_template_provider(None);
 
     // Define an action to block SetupConnectionSuccess messages going downstream.