Add logfn wrapper for tests

To analyze test time spending

Author: frostyplanet

src/tests/test_async.rs

@@ -1,5 +1,6 @@
 use super::common::*;
 use crate::*;
+use captains_log::logfn;
 use log::*;
 use rstest::*;
 use std::sync::{
@@ -8,6 +9,7 @@ use std::sync::{
 };
 use std::time::Duration;
 
+#[logfn]
 #[rstest]
 fn test_sync() {
     use futures::FutureExt;
@@ -91,6 +93,7 @@ fn test_sync() {
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_async::<usize>(100))]
 #[case(mpsc::bounded_async::<usize>(100))]
@@ -116,6 +119,7 @@ fn test_basic_bounded_rx_drop<T: AsyncTxTrait<usize>, R: AsyncRxTrait<usize>>(
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::unbounded_async::<usize>())]
 #[case(mpsc::unbounded_async::<usize>())]
@@ -141,6 +145,7 @@ fn test_basic_unbounded_rx_drop<T: BlockingTxTrait<usize>, R: AsyncRxTrait<usize
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_async::<i32>(10))]
 #[case(mpsc::bounded_async::<i32>(10))]
@@ -186,6 +191,7 @@ fn test_basic_bounded_1_thread<T: AsyncTxTrait<i32>, R: AsyncRxTrait<i32>>(
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::unbounded_async::<i32>())]
 #[case(mpsc::unbounded_async::<i32>())]
@@ -228,6 +234,7 @@ fn test_basic_unbounded_1_thread<T: BlockingTxTrait<i32>, R: AsyncRxTrait<i32>>(
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::unbounded_async::<i32>())]
 #[case(mpsc::unbounded_async::<i32>())]
@@ -262,6 +269,7 @@ fn test_basic_unbounded_idle_select<T: BlockingTxTrait<i32>, R: AsyncRxTrait<i32
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_async::<i32>(10))]
 #[case(mpsc::bounded_async::<i32>(10))]
@@ -294,6 +302,7 @@ fn test_basic_bounded_recv_after_sender_close<T: AsyncTxTrait<i32>, R: AsyncRxTr
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::unbounded_async::<i32>())]
 #[case(mpsc::unbounded_async::<i32>())]
@@ -352,6 +361,7 @@ fn test_basic_timeout_recv_async_waker<T: AsyncTxTrait<i32>, R: AsyncRxTrait<i32
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::unbounded_async::<i32>())]
 #[case(mpsc::unbounded_async::<i32>())]
@@ -386,6 +396,7 @@ fn test_basic_unbounded_recv_timeout_async<T: BlockingTxTrait<i32>, R: AsyncRxTr
     }
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_async::<i32>(10))]
 #[case(mpsc::bounded_async::<i32>(10))]
@@ -446,6 +457,7 @@ fn test_basic_send_timeout_async<T: AsyncTxTrait<i32>, R: AsyncRxTrait<i32>>(
     }
 }
 
+#[logfn]
 #[rstest]
 #[case(mpmc::bounded_async::<i32>(1))]
 fn test_pressure_bounded_timeout_async(
@@ -565,6 +577,7 @@ fn test_pressure_bounded_timeout_async(
     }
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_async::<usize>(1))]
 #[case(spsc::bounded_async::<usize>(10))]
@@ -611,6 +624,7 @@ fn test_pressure_bounded_async_1_1<T: AsyncTxTrait<usize>, R: AsyncRxTrait<usize
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(mpsc::bounded_async::<usize>(1), 10)]
 #[case(mpsc::bounded_async::<usize>(1), 100)]
@@ -680,6 +694,7 @@ fn test_pressure_bounded_async_multi_1<R: AsyncRxTrait<usize>>(
     });
 }
 
+#[logfn]
 #[rstest]
 #[case(mpmc::bounded_async::<usize>(1), 100, 10)]
 #[case(mpmc::bounded_async::<usize>(1), 10, 100)]

src/tests/test_async_blocking.rs

@@ -1,12 +1,14 @@
 use super::common::*;
 use crate::*;
+use captains_log::logfn;
 use log::*;
 use rstest::*;
 use std::sync::atomic::{AtomicUsize, Ordering};
 use std::sync::Arc;
 use std::thread;
 use std::time::Duration;
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_async_rx_blocking::<usize>(100))]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(100))]
@@ -49,6 +51,7 @@ fn test_basic_1_tx_async_1_rx_blocking<T: AsyncTxTrait<usize>, R: BlockingRxTrai
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_async_rx_blocking::<usize>(100))]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(100))]
@@ -98,6 +101,7 @@ fn test_timeout_1_tx_async_1_rx_blocking<T: AsyncTxTrait<usize>, R: BlockingRxTr
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(10), 8)]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(10), 100)]
@@ -163,6 +167,7 @@ fn test_basic_multi_tx_async_1_rx_blocking<R: BlockingRxTrait<usize>>(
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_async_rx_blocking::<usize>(1))]
 #[case(spsc::bounded_tx_async_rx_blocking::<usize>(10))]
@@ -211,6 +216,7 @@ fn test_pressure_1_tx_async_1_rx_blocking<T: AsyncTxTrait<usize>, R: BlockingRxT
     assert_eq!(counter.as_ref().load(Ordering::Acquire), round);
 }
 
+#[logfn]
 #[rstest]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(10), 8)]
 #[case(mpsc::bounded_tx_async_rx_blocking::<usize>(10), 10)]
@@ -270,6 +276,7 @@ fn test_pressure_multi_tx_async_1_rx_blocking<R: BlockingRxTrait<usize>>(
     assert_eq!(counter.as_ref().load(Ordering::Acquire), round * (tx_count));
 }
 
+#[logfn]
 #[rstest]
 #[case(mpmc::bounded_tx_async_rx_blocking::<usize>(10), 8, 8)]
 #[case(mpmc::bounded_tx_async_rx_blocking::<usize>(10), 100, 100)]

src/tests/test_blocking_async.rs

@@ -1,5 +1,6 @@
 use super::common::*;
 use crate::*;
+use captains_log::logfn;
 use log::*;
 use rstest::*;
 use std::sync::{
@@ -9,6 +10,7 @@ use std::sync::{
 use std::thread;
 use std::time::*;
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_blocking_rx_async::<usize>(10))]
 #[case(mpsc::bounded_tx_blocking_rx_async::<usize>(10))]
@@ -53,6 +55,7 @@ fn test_basic_1_tx_blocking_1_rx_async<T: BlockingTxTrait<usize>, R: AsyncRxTrai
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_blocking_rx_async::<usize>(10))]
 #[case(mpsc::bounded_tx_blocking_rx_async::<usize>(10))]
@@ -99,6 +102,7 @@ fn test_timeout_1_tx_blocking_1_rx_async<T: BlockingTxTrait<usize>, R: AsyncRxTr
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(spsc::bounded_tx_blocking_rx_async::<usize>(1))]
 #[case(mpsc::bounded_tx_blocking_rx_async::<usize>(1))]
@@ -137,6 +141,7 @@ fn test_pressure_1_tx_blocking_1_rx_async<T: BlockingTxTrait<usize>, R: AsyncRxT
     let _ = th.join();
 }
 
+#[logfn]
 #[rstest]
 #[case(mpsc::bounded_tx_blocking_rx_async::<usize>(1), 10)]
 #[case(mpsc::bounded_tx_blocking_rx_async::<usize>(1), 100)]
@@ -204,6 +209,7 @@ fn test_pressure_tx_multi_blocking_1_rx_async<R: AsyncRxTrait<usize>>(
     }
 }
 
+#[logfn]
 #[rstest]
 #[case(mpmc::bounded_tx_blocking_rx_async::<usize>(1), 10, 10)]
 #[case(mpmc::bounded_tx_blocking_rx_async::<usize>(1), 100, 20)]