[INFO] fetching crate crossfire 2.0.25... [INFO] testing crossfire-2.0.25 against master#cdb45c87e2cd43495379f7e867e3cc15dcee9f93 for pr-145838-1 [INFO] extracting crate crossfire 2.0.25 into /workspace/builds/worker-5-tc1/source [INFO] started tweaking crates.io crate crossfire 2.0.25 [INFO] finished tweaking crates.io crate crossfire 2.0.25 [INFO] tweaked toml for crates.io crate crossfire 2.0.25 written to /workspace/builds/worker-5-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate crossfire 2.0.25 on toolchain cdb45c87e2cd43495379f7e867e3cc15dcee9f93 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate crossfire 2.0.25 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded kanal v0.1.1 [INFO] [stderr] Downloaded ring-file v0.1.2 [INFO] [stderr] Downloaded exitcode v1.1.2 [INFO] [stderr] Downloaded io-buffer v1.0.3 [INFO] [stderr] Downloaded file-rotate v0.8.0 [INFO] [stderr] Downloaded fail v0.5.1 [INFO] [stderr] Downloaded captains-log-helper v0.3.1 [INFO] [stderr] Downloaded anes v0.2.1 [INFO] [stderr] Downloaded crossfire v2.0.24 [INFO] [stderr] Downloaded captains-log v0.8.6 [INFO] [stderr] Downloaded criterion2 v3.0.2 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] ee83d83dd96550f71b2625f335dd41e8473788210d45206c6bd7396caf89b038 [INFO] running `Command { std: "docker" "start" "-a" "ee83d83dd96550f71b2625f335dd41e8473788210d45206c6bd7396caf89b038", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "ee83d83dd96550f71b2625f335dd41e8473788210d45206c6bd7396caf89b038", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "ee83d83dd96550f71b2625f335dd41e8473788210d45206c6bd7396caf89b038", kill_on_drop: false }` [INFO] [stdout] ee83d83dd96550f71b2625f335dd41e8473788210d45206c6bd7396caf89b038 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] b116d32c2bab84f6a8e3fe1922ec615d789e5907f3747ece55f699cc6343df03 [INFO] running `Command { std: "docker" "start" "-a" "b116d32c2bab84f6a8e3fe1922ec615d789e5907f3747ece55f699cc6343df03", kill_on_drop: false }` [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling once_cell v1.21.3 [INFO] [stderr] Compiling enum_dispatch v0.3.13 [INFO] [stderr] Compiling crossbeam-epoch v0.9.18 [INFO] [stderr] Compiling crossbeam-queue v0.3.12 [INFO] [stderr] Compiling crossbeam-channel v0.5.15 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling crossbeam-deque v0.8.6 [INFO] [stderr] Compiling crossbeam v0.8.4 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling crossfire v2.0.25 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 4.65s [INFO] running `Command { std: "docker" "inspect" "b116d32c2bab84f6a8e3fe1922ec615d789e5907f3747ece55f699cc6343df03", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "b116d32c2bab84f6a8e3fe1922ec615d789e5907f3747ece55f699cc6343df03", kill_on_drop: false }` [INFO] [stdout] b116d32c2bab84f6a8e3fe1922ec615d789e5907f3747ece55f699cc6343df03 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] ae5f8d3aff53f0c79209a39021c0f9d5795a65080814a01ca2d17f1cc4d4ada8 [INFO] running `Command { std: "docker" "start" "-a" "ae5f8d3aff53f0c79209a39021c0f9d5795a65080814a01ca2d17f1cc4d4ada8", kill_on_drop: false }` [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling nix v0.30.1 [INFO] [stderr] Compiling value-bag v1.11.1 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling syn v2.0.106 [INFO] [stderr] Compiling miniz_oxide v0.8.9 [INFO] [stderr] Compiling regex-automata v0.4.10 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling rstest_macros v0.26.1 [INFO] [stderr] Compiling crc32fast v1.5.0 [INFO] [stderr] Compiling half v2.6.0 [INFO] [stderr] Compiling signal-hook v0.3.18 [INFO] [stderr] Compiling ciborium-io v0.2.2 [INFO] [stderr] Compiling event-listener v5.4.1 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling signal-hook-registry v1.4.6 [INFO] [stderr] Compiling relative-path v1.9.3 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling rand_core v0.6.4 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling nanorand v0.7.0 [INFO] [stderr] Compiling spin v0.9.8 [INFO] [stderr] Compiling rand_chacha v0.3.1 [INFO] [stderr] Compiling log v0.4.27 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling bpaf v0.9.20 [INFO] [stderr] Compiling exitcode v1.1.2 [INFO] [stderr] Compiling anes v0.2.1 [INFO] [stderr] Compiling kanal v0.1.1 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling flume v0.11.1 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling rand v0.8.5 [INFO] [stderr] Compiling flate2 v1.1.2 [INFO] [stderr] Compiling backtrace v0.3.75 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling fail v0.5.1 [INFO] [stderr] Compiling io-buffer v1.0.3 [INFO] [stderr] Compiling ring-file v0.1.2 [INFO] [stderr] Compiling file-rotate v0.8.0 [INFO] [stderr] Compiling regex v1.11.2 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling enum_dispatch v0.3.13 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling captains-log-helper v0.3.1 [INFO] [stderr] Compiling tokio v1.47.1 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling rstest v0.26.1 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling crossfire v2.0.24 [INFO] [stderr] Compiling crossfire v2.0.25 (/opt/rustwide/workdir) [INFO] [stderr] Compiling captains-log v0.8.6 [INFO] [stderr] Compiling serde_json v1.0.143 [INFO] [stderr] Compiling ciborium v0.2.2 [INFO] [stderr] Compiling criterion2 v3.0.2 [INFO] [stdout] warning: struct `SpuriousTx` is never constructed [INFO] [stdout] --> src/tests/test_async.rs:908:8 [INFO] [stdout] | [INFO] [stdout] 908 | struct SpuriousTx { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SpuriousRx` is never constructed [INFO] [stdout] --> src/tests/test_async.rs:939:8 [INFO] [stdout] | [INFO] [stdout] 939 | struct SpuriousRx { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 40.15s [INFO] running `Command { std: "docker" "inspect" "ae5f8d3aff53f0c79209a39021c0f9d5795a65080814a01ca2d17f1cc4d4ada8", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "ae5f8d3aff53f0c79209a39021c0f9d5795a65080814a01ca2d17f1cc4d4ada8", kill_on_drop: false }` [INFO] [stdout] ae5f8d3aff53f0c79209a39021c0f9d5795a65080814a01ca2d17f1cc4d4ada8 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] a381df26ceacb18dcd330ff6082ded6ba19748fa311217e89c4398db70b49279 [INFO] running `Command { std: "docker" "start" "-a" "a381df26ceacb18dcd330ff6082ded6ba19748fa311217e89c4398db70b49279", kill_on_drop: false }` [INFO] [stderr] warning: struct `SpuriousTx` is never constructed [INFO] [stderr] --> src/tests/test_async.rs:908:8 [INFO] [stderr] | [INFO] [stderr] 908 | struct SpuriousTx { [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stderr] [INFO] [stderr] warning: struct `SpuriousRx` is never constructed [INFO] [stderr] --> src/tests/test_async.rs:939:8 [INFO] [stderr] | [INFO] [stderr] 939 | struct SpuriousRx { [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: `crossfire` (lib test) generated 2 warnings [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.22s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/crossfire-d0afd11091c1f089) [INFO] [stdout] [INFO] [stdout] running 281 tests [INFO] [stderr] [2025-09-01 08:02:40.212001][INFO][test_async.rs:22] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212108][INFO][test_async.rs:22] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212436][INFO][test_async.rs:350] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212017][INFO][test_async.rs:224] <<< test_basic_bounded_1_thread (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212798][INFO][test_async.rs:22] >>> test_basic_bounded_empty_full_drop_rx return () in 13.56µs >>> [INFO] [stderr] [2025-09-01 08:02:40.212417][INFO][test_async.rs:47] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212557][INFO][test_async.rs:47] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.212896][INFO][test_async.rs:47] >>> test_basic_bounded_empty_full_drop_tx return () in 11.011µs >>> [INFO] [stderr] [2025-09-01 08:02:40.212959][INFO][test_async.rs:233] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.213014][INFO][test_async.rs:47] >>> test_basic_bounded_empty_full_drop_tx return () in 8.389µs >>> [INFO] [stderr] [2025-09-01 08:02:40.212553][INFO][test_async.rs:47] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.213128][INFO][test_async.rs:47] >>> test_basic_bounded_empty_full_drop_tx return () in 6.46µs >>> [INFO] [stderr] [2025-09-01 08:02:40.213410][INFO][test_async.rs:22] >>> test_basic_bounded_empty_full_drop_rx return () in 674.02µs >>> [INFO] [stderr] [2025-09-01 08:02:40.213352][INFO][test_async.rs:224] <<< test_basic_bounded_1_thread (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.213443][INFO][test_async.rs:233] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.213580][INFO][test_async.rs:365] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.213621][INFO][test_async.rs:224] <<< test_basic_bounded_1_thread (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.213765][INFO][test_async.rs:233] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.213759][INFO][test_async.rs:174] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.213842][INFO][test_async.rs:182] run with tokio multi thread [INFO] [stdout] test locked_waker::tests::test_waker ... ok [INFO] [stdout] test collections::tests::test_locked_queue ... ok [INFO] [stdout] test collections::tests::test_weak_cell ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.214006][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.214319][INFO][test_async.rs:174] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.214398][INFO][test_async.rs:182] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.214381][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.214459][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.214461][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.214541][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.214107][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.215027][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.215121][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.215576][INFO][test_async.rs:22] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.215670][INFO][test_async.rs:22] >>> test_basic_bounded_empty_full_drop_rx return () in 10.11µs >>> [INFO] [stderr] [2025-09-01 08:02:40.218198][INFO][test_async.rs:350] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.218312][INFO][test_async.rs:365] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.218296][INFO][test_async.rs:72] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stdout] test tests::test_async::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-01 08:02:40.218409][INFO][test_async.rs:72] >>> test_basic_compile_bounded_empty_full return () in 18.66µs >>> [INFO] [stderr] [2025-09-01 08:02:40.218567][INFO][test_async.rs:174] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.218636][INFO][test_async.rs:182] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.219243][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.219329][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.219904][INFO][test_async.rs:1051] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.220028][INFO][test_async.rs:1062] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.222732][INFO][test_async.rs:350] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.222871][INFO][test_async.rs:365] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.228068][INFO][test_async.rs:480] <<< test_basic_send_timeout_async (setup_log = (), _channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.228277][INFO][test_async.rs:480] >>> test_basic_send_timeout_async return () in 1.64µs >>> [INFO] [stderr] [2025-09-01 08:02:40.228665][INFO][test_async.rs:480] <<< test_basic_send_timeout_async (setup_log = (), _channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.228882][INFO][test_async.rs:480] >>> test_basic_send_timeout_async return () in 1.02µs >>> [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_2 ... ok [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.240436][INFO][test_async.rs:480] <<< test_basic_send_timeout_async (setup_log = (), _channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.240566][INFO][test_async.rs:480] >>> test_basic_send_timeout_async return () in 810ns >>> [INFO] [stderr] [2025-09-01 08:02:40.240908][INFO][test_async.rs:412] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.240995][INFO][test_async.rs:412] >>> test_basic_timeout_recv_async_waker return () in 570ns >>> [INFO] [stderr] [2025-09-01 08:02:40.241203][INFO][test_async.rs:412] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.241286][INFO][test_async.rs:412] >>> test_basic_timeout_recv_async_waker return () in 670ns >>> [INFO] [stderr] [2025-09-01 08:02:40.241513][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 21.485338ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_4 ... ok [INFO] [stderr] [2025-09-01 08:02:40.242798][INFO][test_async.rs:269] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.242904][INFO][test_async.rs:280] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.242986][INFO][test_async.rs:412] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.243076][INFO][test_async.rs:412] >>> test_basic_timeout_recv_async_waker return () in 820ns >>> [INFO] [stderr] [2025-09-01 08:02:40.243616][INFO][test_async.rs:191] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.243654][INFO][test_async.rs:194] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.244722][INFO][test_async.rs:174] >>> test_basic_bounded_rx_drop return () in 26.085227ms >>> [INFO] [stderr] [2025-09-01 08:02:40.245653][INFO][test_async.rs:191] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.245690][INFO][test_async.rs:194] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.247405][INFO][test_async.rs:191] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.247450][INFO][test_async.rs:194] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.248720][INFO][test_async.rs:174] >>> test_basic_bounded_rx_drop return () in 34.878147ms >>> [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_3 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.251044][INFO][test_async.rs:269] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.251211][INFO][test_async.rs:280] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.251576][INFO][test_async.rs:269] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.251652][INFO][test_async.rs:280] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.252936][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 38.476757ms >>> [INFO] [stderr] [2025-09-01 08:02:40.253223][INFO][test_async.rs:313] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.253303][INFO][test_async.rs:325] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.254555][INFO][test_async.rs:313] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.254643][INFO][test_async.rs:325] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.255211][INFO][test_async.rs:174] >>> test_basic_bounded_rx_drop return () in 40.813056ms >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.255550][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 40.429296ms >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.257770][INFO][test_async.rs:350] >>> test_basic_bounded_recv_after_sender_close return () in 45.032105ms >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.258219][INFO][test_async.rs:350] >>> test_basic_bounded_recv_after_sender_close return () in 35.362466ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.259665][INFO][test_async.rs:313] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.259769][INFO][test_async.rs:325] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.259744][INFO][test_async.rs:382] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.259927][INFO][test_async.rs:396] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.260297][INFO][test_async.rs:382] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.260425][INFO][test_async.rs:350] >>> test_basic_bounded_recv_after_sender_close return () in 42.121936ms >>> [INFO] [stderr] [2025-09-01 08:02:40.260476][INFO][test_async.rs:396] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.261608][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 47.506626ms >>> [INFO] [stderr] [2025-09-01 08:02:40.262118][INFO][test_async.rs:446] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.262193][INFO][test_async.rs:446] >>> test_basic_unbounded_recv_timeout_async return () in 1.03µs >>> [INFO] [stderr] [2025-09-01 08:02:40.262389][INFO][test_async.rs:446] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.262459][INFO][test_async.rs:446] >>> test_basic_unbounded_recv_timeout_async return () in 691ns >>> [INFO] [stderr] [2025-09-01 08:02:40.262493][INFO][test_async.rs:382] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.262674][INFO][test_async.rs:396] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.263234][INFO][test_async.rs:199] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.263312][INFO][test_async.rs:207] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.264025][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 49.484125ms >>> [INFO] [stderr] [2025-09-01 08:02:40.265149][INFO][test_async.rs:446] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.265246][INFO][test_async.rs:446] >>> test_basic_unbounded_recv_timeout_async return () in 800ns >>> [INFO] [stderr] [2025-09-01 08:02:40.273127][INFO][test_async.rs:382] >>> test_basic_unbounded_recv_after_sender_close return () in 12.751048ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_5 ... ok [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_1 ... ok [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.278536][INFO][test_async.rs:199] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_conversion ... ok [INFO] [stderr] [2025-09-01 08:02:40.278670][INFO][test_async.rs:207] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.279212][INFO][test_async.rs:199] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.279293][INFO][test_async.rs:207] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.280535][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.280620][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.283574][INFO][test_async.rs:382] >>> test_basic_unbounded_recv_after_sender_close return () in 21.007667ms >>> [INFO] [stderr] [2025-09-01 08:02:40.283863][INFO][test_async.rs:216] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.283894][INFO][test_async.rs:219] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.283809][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.283922][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.287194][INFO][test_async.rs:216] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.287246][INFO][test_async.rs:219] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.288276][INFO][test_async.rs:216] try to send after rx dropped [INFO] [stderr] [2025-09-01 08:02:40.288316][INFO][test_async.rs:219] dropped tx [INFO] [stderr] [2025-09-01 08:02:40.290157][INFO][test_async.rs:199] >>> test_basic_unbounded_rx_drop return () in 11.487549ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:40.290479][INFO][test_async.rs:199] >>> test_basic_unbounded_rx_drop return () in 11.186119ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:40.290708][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.290801][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.291387][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.291460][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.316259][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 24.794747ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_04 ... ok [INFO] [stderr] [2025-09-01 08:02:40.316547][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.316654][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.318620][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 27.818287ms >>> [INFO] [stderr] [2025-09-01 08:02:40.318952][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.319034][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_03 ... ok [INFO] [stderr] [2025-09-01 08:02:40.338363][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 54.438495ms >>> [INFO] [stderr] [2025-09-01 08:02:40.338678][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.338787][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.344292][INFO][test_async.rs:199] >>> test_basic_unbounded_rx_drop return () in 80.977803ms >>> [INFO] [stderr] [2025-09-01 08:02:40.349299][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.349524][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_02 ... ok [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:40.350253][INFO][test_async.rs:1051] >>> test_basic_into_stream_1_1 return () in 130.924357ms >>> [INFO] [stderr] [2025-09-01 08:02:40.350813][INFO][test_async.rs:382] >>> test_basic_unbounded_recv_after_sender_close return () in 90.988241ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_6 ... ok [INFO] [stderr] [2025-09-01 08:02:40.351922][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.352016][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.352900][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.352994][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.359006][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 20.218488ms >>> [INFO] [stderr] [2025-09-01 08:02:40.359278][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.359403][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_1 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_07 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_11 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_08 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_12 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_10 ... ok [INFO] [stderr] [2025-09-01 08:02:40.368863][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 9.447249ms >>> [INFO] [stderr] [2025-09-01 08:02:40.369313][INFO][test_async.rs:659] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.369429][INFO][test_async.rs:680] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.384339][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 34.812947ms >>> [INFO] [stderr] [2025-09-01 08:02:40.384638][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.384737][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.386842][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 17.414148ms >>> [INFO] [stderr] [2025-09-01 08:02:40.387191][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.387282][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.398847][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 45.851505ms >>> [INFO] [stderr] [2025-09-01 08:02:40.399735][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.399843][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_06 ... ok [INFO] [stderr] [2025-09-01 08:02:40.649170][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 330.131937ms >>> [INFO] [stderr] [2025-09-01 08:02:40.649568][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.649686][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.726198][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 374.179473ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_09 ... ok [INFO] [stderr] [2025-09-01 08:02:40.726570][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.728251][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_01 ... ok [INFO] [stderr] [2025-09-01 08:02:40.783327][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 502.70478ms >>> [INFO] [stderr] [2025-09-01 08:02:40.789409][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.794328][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:40.854355][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 467.069704ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_02 ... ok [INFO] [stderr] [2025-09-01 08:02:40.856448][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:40.856636][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_05 ... ok [INFO] [stderr] [2025-09-01 08:02:41.062075][INFO][test_async.rs:659] >>> test_pressure_bounded_async_1_1 return () in 745.419507ms >>> [INFO] [stderr] [2025-09-01 08:02:41.062502][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.062639][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.142117][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 347.787206ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_06 ... ok [INFO] [stderr] [2025-09-01 08:02:41.178236][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.178392][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.256358][INFO][test_async.rs:224] >>> test_basic_bounded_1_thread return () in 1.043410796s >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:41.260247][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:41.265135][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.266035][INFO][test_async.rs:269] >>> test_basic_unbounded_1_thread return () in 1.023130289s >>> [INFO] [stderr] [2025-09-01 08:02:41.270617][INFO][test_async.rs:269] >>> test_basic_unbounded_1_thread return () in 1.019406609s >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:41.276215][INFO][test_async.rs:765] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.276349][INFO][test_async.rs:783] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.282503][INFO][test_async.rs:269] >>> test_basic_unbounded_1_thread return () in 1.030849708s >>> [INFO] [stderr] [2025-09-01 08:02:41.282973][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 633.287677ms >>> [INFO] [stderr] [2025-09-01 08:02:41.289198][INFO][test_async.rs:224] >>> test_basic_bounded_1_thread return () in 1.075754393s >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_3 ... ok [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_04 ... ok [INFO] [stderr] [2025-09-01 08:02:41.306196][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:41.306328][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.309283][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.315225][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.315371][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.315412][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.322482][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.322625][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:41.519694][INFO][test_async.rs:224] >>> test_basic_bounded_1_thread return () in 1.30592703s >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:41.575214][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.575348][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_08 ... ok [INFO] [stderr] [2025-09-01 08:02:41.756431][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 693.788952ms >>> [INFO] [stderr] [2025-09-01 08:02:41.756938][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:41.757101][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:42.000413][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 735.278007ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_10 ... ok [INFO] [stderr] [2025-09-01 08:02:42.058225][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:42.058367][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:42.769590][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 1.591193942s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_09 ... ok [INFO] [stderr] [2025-09-01 08:02:42.772124][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:42.772277][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_07 ... ok [INFO] [stderr] [2025-09-01 08:02:42.976524][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 918.153689ms >>> [INFO] [stderr] [2025-09-01 08:02:42.978310][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:42.978474][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:42.989796][INFO][test_async.rs:346] waker rx 0 [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:42.991779][INFO][test_async.rs:313] >>> test_basic_unbounded_idle_select return () in 2.737136729s >>> [INFO] [stderr] [2025-09-01 08:02:43.046916][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:43.047070][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:43.239249][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 2.854509087s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_01 ... ok [INFO] [stderr] [2025-09-01 08:02:43.314212][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:43.316882][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:43.404173][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 2.675919815s >>> [INFO] [stderr] [2025-09-01 08:02:43.404582][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:43.404757][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_05 ... ok [INFO] [stderr] [2025-09-01 08:02:43.480544][INFO][test_async.rs:346] waker rx 1 [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:43.489745][INFO][test_async.rs:313] >>> test_basic_unbounded_idle_select return () in 3.22997237s >>> [INFO] [stderr] [2025-09-01 08:02:43.493190][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:43.493299][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:43.741707][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 2.41907874s >>> [INFO] [stderr] [2025-09-01 08:02:43.843226][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_04 ... ok [INFO] [stderr] [2025-09-01 08:02:43.843398][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:44.136025][INFO][test_async.rs:346] waker rx 0 [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:44.138407][INFO][test_async.rs:313] >>> test_basic_unbounded_idle_select return () in 3.885100945s >>> [INFO] [stderr] [2025-09-01 08:02:44.138798][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:02:44.138919][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:44.996877][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 4.597031195s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_03 ... ok [INFO] [stderr] [2025-09-01 08:02:44.998506][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:44.998622][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_11 ... ok [INFO] [stderr] [2025-09-01 08:02:45.271789][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 3.995437325s >>> [INFO] [stderr] [2025-09-01 08:02:45.272426][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.272537][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:45.400946][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 402.32124ms >>> [INFO] [stderr] [2025-09-01 08:02:45.401336][INFO][test_async.rs:705] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_16 ... ok [INFO] [stderr] [2025-09-01 08:02:45.401476][INFO][test_async.rs:730] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:45.458456][INFO][test_async.rs:765] >>> test_pressure_bounded_async_multi return () in 4.601817775s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_07 ... ok [INFO] [stderr] [2025-09-01 08:02:45.458844][INFO][test_async.rs:825] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.458967][INFO][test_async.rs:834] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_13 ... ok [INFO] [stderr] [2025-09-01 08:02:45.482900][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 1.989598503s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_01 ... ok [INFO] [stderr] [2025-09-01 08:02:45.483590][INFO][test_async.rs:825] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:45.483710][INFO][test_async.rs:834] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_timeout_async::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:45.529559][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 4.223229152s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:45.530107][INFO][test_async.rs:825] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:45.530215][INFO][test_async.rs:834] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:45.561829][INFO][test_async.rs:825] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 31.610877ms >>> [INFO] [stderr] [2025-09-01 08:02:45.562162][INFO][test_async.rs:540] <<< test_pressure_bounded_timeout_async (setup_log = (), _channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.562278][INFO][test_async.rs:540] >>> test_pressure_bounded_timeout_async return () in 600ns >>> [INFO] [stderr] [2025-09-01 08:02:45.563902][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.563984][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:45.611379][INFO][test_async.rs:825] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 127.666217ms >>> [INFO] [stderr] [2025-09-01 08:02:45.611716][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.611833][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:45.744383][INFO][test_async.rs:825] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 285.414172ms >>> [INFO] [stderr] [2025-09-01 08:02:45.745047][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:45.745201][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_10 ... ok [INFO] [stderr] [2025-09-01 08:02:46.149253][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 3.102180183s >>> [INFO] [stderr] [2025-09-01 08:02:46.149676][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:02:46.149768][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:46.944099][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 794.327731ms >>> [INFO] [stderr] [2025-09-01 08:02:46.944581][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 30) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_4 ... ok [INFO] [stderr] [2025-09-01 08:02:46.944728][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:47.901144][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 956.413526ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_5 ... ok [INFO] [stderr] [2025-09-01 08:02:47.905529][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:02:47.905672][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_6 ... ok [INFO] [stderr] [2025-09-01 08:02:48.024258][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 118.583868ms >>> [INFO] [stderr] [2025-09-01 08:02:48.024587][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.025433][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:48.206711][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 181.275862ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_7 ... ok [INFO] [stderr] [2025-09-01 08:02:48.207193][INFO][test_async.rs:1083] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 50) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.207300][INFO][test_async.rs:1096] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_8 ... ok [INFO] [stderr] [2025-09-01 08:02:48.408197][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 200.89409ms >>> [INFO] [stderr] [2025-09-01 08:02:48.408659][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.408785][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:48.488616][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 2.743412818s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:48.489026][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.489180][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:48.824199][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 3.212363522s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_08 ... ok [INFO] [stderr] [2025-09-01 08:02:48.824604][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.824756][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:48.896677][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 6.124397694s >>> [INFO] [stderr] [2025-09-01 08:02:48.897099][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:02:48.897211][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:50.284000][INFO][test_async.rs:1083] >>> test_pressure_stream_multi return () in 4.720012583s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:50.284711][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 30) enter <<< [INFO] [stderr] [2025-09-01 08:02:50.284873][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_17 ... ok [INFO] [stderr] [2025-09-01 08:02:50.852930][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 5.580391548s >>> [INFO] [stderr] [2025-09-01 08:02:50.853856][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:02:50.854547][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:51.721900][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 7.87850014s >>> [INFO] [stderr] [2025-09-01 08:02:51.722447][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-01 08:02:51.722615][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_14 ... ok [INFO] [stderr] [2025-09-01 08:02:52.204498][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 10.629147348s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_05 ... ok [INFO] [stderr] [2025-09-01 08:02:52.204973][INFO][test_async.rs:1123] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 50) enter <<< [INFO] [stderr] [2025-09-01 08:02:52.205138][INFO][test_async.rs:1136] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_09 ... ok [INFO] [stderr] [2025-09-01 08:02:54.338437][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 11.359962086s >>> [INFO] [stdout] test tests::test_async::test_spurious_sink ... ok [INFO] [stdout] test tests::test_async::test_spurious_stream ... ok [INFO] [stderr] [2025-09-01 08:02:54.338818][INFO][test_async.rs:969] <<< test_spurious_sink (setup_log = ()) enter <<< [INFO] [stderr] [2025-09-01 08:02:54.338935][INFO][test_async.rs:969] >>> test_spurious_sink return () in 50ns >>> [INFO] [stderr] [2025-09-01 08:02:54.339140][INFO][test_async.rs:1010] <<< test_spurious_stream (setup_log = ()) enter <<< [INFO] [stderr] [2025-09-01 08:02:54.339220][INFO][test_async.rs:1010] >>> test_spurious_stream return () in 49ns >>> [INFO] [stderr] [2025-09-01 08:02:54.339378][INFO][test_async.rs:90] <<< test_sync () enter <<< [INFO] [stderr] [2025-09-01 08:02:54.339461][INFO][test_async.rs:94] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:56.940749][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.531961996s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:56.942378][INFO][test_async_blocking.rs:80] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:56.942626][INFO][test_async_blocking.rs:109] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:57.130168][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.640985064s >>> [INFO] [stderr] [2025-09-01 08:02:57.130667][INFO][test_async_blocking.rs:80] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.130888][INFO][test_async_blocking.rs:109] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:57.565639][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.740881655s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:57.566029][INFO][test_async_blocking.rs:80] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.566211][INFO][test_async_blocking.rs:109] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:57.582266][INFO][test_async_blocking.rs:80] >>> test_basic_1_tx_async_1_rx_blocking return () in 639.708327ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:57.582869][INFO][test_async_blocking.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:57.583034][INFO][test_async_blocking.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 16.68µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:57.584384][INFO][test_async_blocking.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:57.584589][INFO][test_async_blocking.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 21.82µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:57.584849][INFO][test_async_blocking.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:57.584952][INFO][test_async_blocking.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 10.61µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:57.585175][INFO][test_async_blocking.rs:39] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-01 08:02:57.585259][INFO][test_async_blocking.rs:39] >>> test_basic_bounded_empty_full_drop_tx return () in 9.32µs >>> [INFO] [stderr] [2025-09-01 08:02:57.585527][INFO][test_async_blocking.rs:39] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.585604][INFO][test_async_blocking.rs:39] >>> test_basic_bounded_empty_full_drop_tx return () in 8.56µs >>> [INFO] [stderr] [2025-09-01 08:02:57.585753][INFO][test_async_blocking.rs:39] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.585830][INFO][test_async_blocking.rs:39] >>> test_basic_bounded_empty_full_drop_tx return () in 9.09µs >>> [INFO] [stderr] [2025-09-01 08:02:57.585978][INFO][test_async_blocking.rs:62] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stderr] [2025-09-01 08:02:57.586061][INFO][test_async_blocking.rs:62] >>> test_basic_compile_bounded_empty_full return () in 12.8µs >>> [INFO] [stderr] [2025-09-01 08:02:57.586232][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.586355][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:57.713360][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.816146178s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_4 ... ok [INFO] [stderr] [2025-09-01 08:02:57.713777][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.714051][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:57.795276][INFO][test_async_blocking.rs:80] >>> test_basic_1_tx_async_1_rx_blocking return () in 664.450385ms >>> [INFO] [stderr] [2025-09-01 08:02:57.795721][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.795960][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:57.920988][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 12.519510321s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_18 ... ok [INFO] [stderr] [2025-09-01 08:02:57.922220][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-01 08:02:57.924179][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-01 08:02:58.194786][INFO][test_async_blocking.rs:80] >>> test_basic_1_tx_async_1_rx_blocking return () in 628.608118ms >>> [INFO] [stderr] [2025-09-01 08:02:58.195172][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:02:58.195334][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:02:58.263802][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 677.492723ms >>> [INFO] [stderr] [2025-09-01 08:02:58.264211][INFO][test_async_blocking.rs:171] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:02:58.264402][INFO][test_async_blocking.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_4 ... ok [INFO] [stderr] [2025-09-01 08:02:58.611505][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 687.385402ms >>> [INFO] [stderr] [2025-09-01 08:02:58.612130][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:58.612511][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:58.634852][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 920.896058ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-01 08:02:58.635212][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:58.635381][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_5 ... ok [INFO] [stderr] [2025-09-01 08:02:58.694469][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.409600137s >>> [INFO] [stderr] [2025-09-01 08:02:58.695015][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:58.695272][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:59.090757][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 895.460261ms >>> [INFO] [stderr] [2025-09-01 08:02:59.091231][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:59.091431][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_5 ... ok [INFO] [stderr] [2025-09-01 08:02:59.678784][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.824236387s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_6 ... ok [INFO] [stderr] [2025-09-01 08:02:59.679224][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_04 ... ok [INFO] [stderr] [2025-09-01 08:02:59.679371][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:02:59.695076][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 603.692601ms >>> [INFO] [stderr] [2025-09-01 08:02:59.695399][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:02:59.695544][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_sync ... ok [INFO] [stderr] [2025-09-01 08:03:00.356826][INFO][test_async.rs:90] >>> test_sync return () in 6.017359054s >>> [INFO] [stderr] [2025-09-01 08:03:00.357365][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:00.357595][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:00.404351][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.70913719s >>> [INFO] [stderr] [2025-09-01 08:03:00.405399][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:00.406863][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_03 ... ok [INFO] [stderr] [2025-09-01 08:03:00.539977][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.817356727s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_7 ... ok [INFO] [stderr] [2025-09-01 08:03:00.540771][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:00.541030][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:00.776689][INFO][test_async.rs:1123] >>> test_pressure_stream_multi_idle return () in 8.571549112s >>> [INFO] [stderr] [2025-09-01 08:03:00.777238][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:00.777426][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_8 ... ok [INFO] [stderr] [2025-09-01 08:03:01.076380][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 16.937456874s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_15 ... ok [INFO] [stderr] [2025-09-01 08:03:01.076920][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:01.077735][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:01.503017][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.097490492s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_08 ... ok [INFO] [stderr] [2025-09-01 08:03:01.538299][INFO][test_async_blocking.rs:228] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:01.538531][INFO][test_async_blocking.rs:263] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:02.328320][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.970783385s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_07 ... ok [INFO] [stderr] [2025-09-01 08:03:02.363957][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 8) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_11 ... ok [INFO] [stderr] [2025-09-01 08:03:02.364655][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:02.461793][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.384743343s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_12 ... ok [INFO] [stderr] [2025-09-01 08:03:02.462259][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:02.462440][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:02.528970][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 4.733067741s >>> [INFO] [stderr] [2025-09-01 08:03:02.529433][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:02.530205][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:02.535439][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 996.971431ms >>> [INFO] [stderr] [2025-09-01 08:03:02.535875][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:03:02.537292][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:02.853940][INFO][test_async_blocking.rs:171] >>> test_basic_multi_tx_async_1_rx_blocking return () in 4.589581296s >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_6 ... ok [INFO] [stderr] [2025-09-01 08:03:02.854351][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-01 08:03:02.854525][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_02 ... ok [INFO] [stderr] [2025-09-01 08:03:03.652258][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 22.336885309s >>> [INFO] [stderr] [2025-09-01 08:03:03.652679][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:03.652835][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:03.828508][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 4.132997571s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_06 ... ok [INFO] [stderr] [2025-09-01 08:03:03.828911][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:03.829097][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_02 ... ok [INFO] [stderr] [2025-09-01 08:03:05.569220][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 6.933875594s >>> [INFO] [stderr] [2025-09-01 08:03:05.578326][INFO][test_async_blocking.rs:276] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:03:05.578491][INFO][test_async_blocking.rs:307] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_10 ... ok [INFO] [stderr] [2025-09-01 08:03:05.929943][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 5.152574619s >>> [INFO] [stderr] [2025-09-01 08:03:05.930315][INFO][test_async_blocking.rs:330] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 8, rx_count = 8) enter <<< [INFO] [stderr] [2025-09-01 08:03:05.930618][INFO][test_async_blocking.rs:363] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:06.253744][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 3.399259684s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_5 ... ok [INFO] [stderr] [2025-09-01 08:03:06.254136][INFO][test_async_blocking.rs:330] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:06.294473][INFO][test_async_blocking.rs:363] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:06.636350][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 2.807306433s >>> [INFO] [stderr] [2025-09-01 08:03:06.636740][INFO][test_async_blocking.rs:330] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 10, rx_count = 300) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_7 ... ok [INFO] [stderr] [2025-09-01 08:03:06.812127][INFO][test_async_blocking.rs:363] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:07.370676][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 24.05379398s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_11 ... ok [INFO] [stderr] [2025-09-01 08:03:07.427245][INFO][test_async_blocking.rs:330] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-01 08:03:07.625271][INFO][test_async_blocking.rs:363] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:09.834432][INFO][test_async_blocking.rs:330] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 3.904008813s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:09.836617][INFO][test_async_blocking.rs:122] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:09.837846][INFO][test_async_blocking.rs:155] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:11.104737][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 8.740607666s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:11.135251][INFO][test_async_blocking.rs:122] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:11.135452][INFO][test_async_blocking.rs:155] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:11.599472][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 29.842369847s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_06 ... ok [INFO] [stderr] [2025-09-01 08:03:11.603632][INFO][test_async_blocking.rs:122] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:11.608206][INFO][test_async_blocking.rs:155] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:12.281112][INFO][test_async_blocking.rs:122] >>> test_timeout_1_tx_async_1_rx_blocking return () in 2.443303448s >>> [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:12.281717][INFO][test_blocking_async.rs:103] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:12.281862][INFO][test_blocking_async.rs:128] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:12.331427][INFO][test_async_blocking.rs:122] >>> test_timeout_1_tx_async_1_rx_blocking return () in 1.196026601s >>> [INFO] [stderr] [2025-09-01 08:03:12.331822][INFO][test_blocking_async.rs:103] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:12.334767][INFO][test_blocking_async.rs:128] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_basic_1_tx_blocking_1_rx_async::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:13.304985][INFO][test_blocking_async.rs:103] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.023157779s >>> [INFO] [stderr] [2025-09-01 08:03:13.305990][INFO][test_async_blocking.rs:122] >>> test_timeout_1_tx_async_1_rx_blocking return () in 1.702245502s >>> [INFO] [stderr] [2025-09-01 08:03:13.307417][INFO][test_blocking_async.rs:103] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.318684][INFO][test_blocking_async.rs:128] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:13.322200][INFO][test_blocking_async.rs:18] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:13.322326][INFO][test_blocking_async.rs:18] >>> test_basic_bounded_empty_full_drop_rx return () in 10.52µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:13.323940][INFO][test_blocking_async.rs:18] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:13.324558][INFO][test_blocking_async.rs:18] >>> test_basic_bounded_empty_full_drop_rx return () in 7.72µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:13.325960][INFO][test_blocking_async.rs:18] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:13.326056][INFO][test_blocking_async.rs:18] >>> test_basic_bounded_empty_full_drop_rx return () in 9.63µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:13.328354][INFO][test_blocking_async.rs:41] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_1_tx_blocking_1_rx_async::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:13.328446][INFO][test_blocking_async.rs:41] >>> test_basic_bounded_empty_full_drop_tx return () in 8.84µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-01 08:03:13.329055][INFO][test_blocking_async.rs:41] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_unbounded_empty_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:13.329167][INFO][test_blocking_async.rs:41] >>> test_basic_bounded_empty_full_drop_tx return () in 7.369µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_unbounded_empty_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:13.343210][INFO][test_blocking_async.rs:41] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_unbounded_empty_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:13.343361][INFO][test_blocking_async.rs:41] >>> test_basic_bounded_empty_full_drop_tx return () in 9.56µs >>> [INFO] [stderr] [2025-09-01 08:03:13.345106][INFO][test_blocking_async.rs:103] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.01316663s >>> [INFO] [stderr] [2025-09-01 08:03:13.379104][INFO][test_blocking_async.rs:85] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stderr] [2025-09-01 08:03:13.379303][INFO][test_blocking_async.rs:85] >>> test_basic_compile_bounded_empty_full return () in 21.9µs >>> [INFO] [stderr] [2025-09-01 08:03:13.379571][INFO][test_blocking_async.rs:64] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.379679][INFO][test_blocking_async.rs:64] >>> test_basic_unbounded_empty_drop_tx return () in 12.89µs >>> [INFO] [stderr] [2025-09-01 08:03:13.382156][INFO][test_blocking_async.rs:64] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.382139][INFO][test_blocking_async.rs:64] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.382228][INFO][test_blocking_async.rs:64] >>> test_basic_unbounded_empty_drop_tx return () in 8.59µs >>> [INFO] [stderr] [2025-09-01 08:03:13.382228][INFO][test_blocking_async.rs:64] >>> test_basic_unbounded_empty_drop_tx return () in 9.18µs >>> [INFO] [stderr] [2025-09-01 08:03:13.385761][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.385813][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:13.385878][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:13.385942][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_basic_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:14.628944][INFO][test_blocking_async.rs:103] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.310313261s >>> [INFO] [stderr] [2025-09-01 08:03:14.629603][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:14.632861][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:14.892304][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 12.42991444s >>> [INFO] [stderr] [2025-09-01 08:03:14.969886][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:14.970604][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:15.720362][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 750.330506ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_4 ... ok [INFO] [stderr] [2025-09-01 08:03:15.757293][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:15.782358][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:16.291728][INFO][test_async_blocking.rs:330] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 9.654873875s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:16.294517][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:16.294705][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_5 ... ok [INFO] [stderr] [2025-09-01 08:03:16.350611][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 568.311464ms >>> [INFO] [stderr] [2025-09-01 08:03:16.351057][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:16.351259][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:16.425251][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 74.037733ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_7 ... ok [INFO] [stderr] [2025-09-01 08:03:16.565530][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:16.565741][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:16.660973][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 366.303764ms >>> [INFO] [stderr] [2025-09-01 08:03:16.667200][INFO][test_blocking_async.rs:193] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:03:16.667375][INFO][test_blocking_async.rs:214] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:16.685614][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 119.916808ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_6 ... ok [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_8 ... ok [INFO] [stderr] [2025-09-01 08:03:16.686735][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:16.694336][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:17.172317][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 504.98246ms >>> [INFO] [stderr] [2025-09-01 08:03:17.172687][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_9 ... ok [INFO] [stderr] [2025-09-01 08:03:17.195988][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_1 ... ok [INFO] [stderr] [2025-09-01 08:03:20.942212][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 7.556360782s >>> [INFO] [stderr] [2025-09-01 08:03:20.942580][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:21.421383][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-01 08:03:21.941186][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 7.311458926s >>> [INFO] [stderr] [2025-09-01 08:03:21.943219][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:21.967432][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:22.860325][INFO][test_blocking_async.rs:193] >>> test_pressure_1_tx_blocking_1_rx_async return () in 9.474428172s >>> [INFO] [stderr] [2025-09-01 08:03:22.861529][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:22.897347][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:23.935321][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 6.762492671s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_02 ... ok [INFO] [stderr] [2025-09-01 08:03:23.939357][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:24.404452][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_04 ... ok [INFO] [stderr] [2025-09-01 08:03:25.587986][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 3.620874162s >>> [INFO] [stderr] [2025-09-01 08:03:25.592141][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:25.603947][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:26.666735][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 9.979891332s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_01 ... ok [INFO] [stderr] [2025-09-01 08:03:26.667375][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:26.718051][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_05 ... ok [INFO] [stderr] [2025-09-01 08:03:29.474962][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 6.613315735s >>> [INFO] [stderr] [2025-09-01 08:03:29.475376][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:30.039492][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_07 ... ok [INFO] [stderr] [2025-09-01 08:03:31.859489][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 6.260985861s >>> [INFO] [stderr] [2025-09-01 08:03:31.860153][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:31.860899][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:35.832707][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 3.972397946s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_10 ... ok [INFO] [stderr] [2025-09-01 08:03:35.834684][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_08 ... ok [INFO] [stderr] [2025-09-01 08:03:35.872228][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:35.999016][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 9.331514037s >>> [INFO] [stderr] [2025-09-01 08:03:36.007220][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:37.266896][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_03 has been running for over 60 seconds [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_12 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:03:44.613330][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 44.933991214s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_05 ... ok [INFO] [stderr] [2025-09-01 08:03:44.689217][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:44.721455][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:45.097471][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 9.262660954s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_11 ... ok [INFO] [stderr] [2025-09-01 08:03:45.131270][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:45.839377][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_14 ... ok [INFO] [stderr] [2025-09-01 08:03:47.049525][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.91810499s >>> [INFO] [stderr] [2025-09-01 08:03:47.079226][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:47.763396][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:48.346713][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 3.625594121s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_13 ... ok [INFO] [stderr] [2025-09-01 08:03:48.347236][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:48.347692][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:48.966374][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.886967634s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_15 ... ok [INFO] [stderr] [2025-09-01 08:03:49.292287][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-01 08:03:49.490210][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_16 ... ok [INFO] [stderr] [2025-09-01 08:03:49.761389][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.41403759s >>> [INFO] [stderr] [2025-09-01 08:03:49.761866][INFO][test_blocking_async.rs:231] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:03:50.762285][INFO][test_blocking_async.rs:281] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:51.179286][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.886810973s >>> [INFO] [stderr] [2025-09-01 08:03:51.182689][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_17 ... ok [INFO] [stderr] [2025-09-01 08:03:51.201418][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:52.991558][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 3.229575911s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_18 ... ok [INFO] [stderr] [2025-09-01 08:03:52.993564][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stderr] [2025-09-01 08:03:53.035803][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_01 ... ok [INFO] [stderr] [2025-09-01 08:03:53.065511][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 54.453202091s >>> [INFO] [stderr] [2025-09-01 08:03:53.084314][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:03:53.190722][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_01 ... ok [INFO] [stderr] [2025-09-01 08:03:53.202793][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.01997375s >>> [INFO] [stderr] [2025-09-01 08:03:53.204055][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:03:53.204818][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:54.886980][INFO][test_async_blocking.rs:330] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 48.632717258s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-01 08:03:54.887460][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stderr] [2025-09-01 08:03:54.910866][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:55.902575][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.698381333s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_04 ... ok [INFO] [stderr] [2025-09-01 08:03:55.903981][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_09 ... ok [INFO] [stderr] [2025-09-01 08:03:55.941140][INFO][test_async_blocking.rs:228] >>> test_pressure_1_tx_async_1_rx_blocking return () in 55.400233387s >>> [INFO] [stderr] [2025-09-01 08:03:55.941539][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:03:55.943652][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:56.193577][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:03:59.241363][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 3.299708984s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_07 ... ok [INFO] [stderr] [2025-09-01 08:03:59.241777][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:03:59.253636][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_02 ... ok [INFO] [stderr] [2025-09-01 08:04:00.709720][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 7.709488738s >>> [INFO] [stderr] [2025-09-01 08:04:00.712872][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 500) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_05 ... ok [INFO] [stderr] [2025-09-01 08:04:01.475802][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:01.561247][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 6.67367023s >>> [INFO] [stderr] [2025-09-01 08:04:01.582276][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 30, rx_count = 1000) enter <<< [INFO] [stderr] [2025-09-01 08:04:01.587414][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_3 has been running for over 60 seconds [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_4 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:04:03.688057][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 10.603604481s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_6 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:04:03.702072][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_03 ... ok [INFO] [stderr] [2025-09-01 08:04:03.703582][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:03.727193][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 7.823072916s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_06 ... ok [INFO] [stderr] [2025-09-01 08:04:03.728524][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stderr] [2025-09-01 08:04:05.180733][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_8 has been running for over 60 seconds [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_12 ... ok [INFO] [stderr] [2025-09-01 08:04:06.001363][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.272686475s >>> [INFO] [stderr] [2025-09-01 08:04:06.021230][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_11 ... ok [INFO] [stderr] [2025-09-01 08:04:06.194258][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.492002963s >>> [INFO] [stderr] [2025-09-01 08:04:06.204433][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-01 08:04:06.483578][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_4 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:04:08.930958][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 7.347400773s >>> [INFO] [stderr] [2025-09-01 08:04:08.967297][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 200) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_10 ... ok [INFO] [stderr] [2025-09-01 08:04:09.530946][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 3.326350021s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_14 ... ok [INFO] [stderr] [2025-09-01 08:04:09.533047][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 500) enter <<< [INFO] [stderr] [2025-09-01 08:04:10.461254][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 11.21934017s >>> [INFO] [stderr] [2025-09-01 08:04:10.487684][INFO][test_blocking_async.rs:298] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 30, rx_count = 1000) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_08 ... ok [INFO] [stderr] [2025-09-01 08:04:10.663109][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:10.677628][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:10.698300][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:11.015965][INFO][test_blocking_async.rs:348] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:11.253864][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 5.232472782s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_13 ... ok [INFO] [stderr] [2025-09-01 08:04:11.274560][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 786.729152ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_17 ... ok [INFO] [stderr] [2025-09-01 08:04:11.287218][INFO][test_blocking_async.rs:147] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.287424][INFO][test_blocking_async.rs:147] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.441211][INFO][test_blocking_async.rs:172] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:11.454778][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.487345224s >>> [INFO] [stderr] [2025-09-01 08:04:11.454949][INFO][test_blocking_async.rs:172] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_15 ... ok [INFO] [stderr] [2025-09-01 08:04:11.480363][INFO][test_blocking_async.rs:147] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.643375][INFO][test_blocking_async.rs:172] run with tokio multi thread [INFO] [stderr] [2025-09-01 08:04:11.668687][INFO][test_blocking_async.rs:147] >>> test_timeout_1_tx_blocking_1_rx_async return () in 381.185262ms >>> [INFO] [stderr] [2025-09-01 08:04:11.695222][INFO][test_blocking_context.rs:157] <<< test_basic_bounded_1_thread (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_timeout_1_tx_blocking_1_rx_async::case_1 ... ok [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_16 ... ok [INFO] [stderr] [2025-09-01 08:04:11.695045][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.161825636s >>> [INFO] [stderr] [2025-09-01 08:04:11.714215][INFO][test_blocking_context.rs:157] <<< test_basic_bounded_1_thread (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.726330][INFO][test_blocking_async.rs:147] >>> test_timeout_1_tx_blocking_1_rx_async return () in 438.971177ms >>> [INFO] [stderr] [2025-09-01 08:04:11.726748][INFO][test_blocking_context.rs:157] <<< test_basic_bounded_1_thread (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_timeout_1_tx_blocking_1_rx_async::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:11.847585][INFO][test_blocking_async.rs:147] >>> test_timeout_1_tx_blocking_1_rx_async return () in 367.047474ms >>> [INFO] [stdout] test tests::test_blocking_async::test_timeout_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:11.854403][INFO][test_blocking_context.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:11.854538][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 13.74µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:11.854703][INFO][test_blocking_context.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:11.854785][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 9.22µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:11.854960][INFO][test_blocking_context.rs:16] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:11.855040][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 11.34µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:11.855221][INFO][test_blocking_context.rs:53] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:11.855299][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 10.11µs >>> [INFO] [stderr] [2025-09-01 08:04:11.858950][INFO][test_blocking_context.rs:53] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.859046][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 13.46µs >>> [INFO] [stderr] [2025-09-01 08:04:11.898218][INFO][test_blocking_context.rs:53] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.898397][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 19.15µs >>> [INFO] [stderr] [2025-09-01 08:04:11.900223][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.904142][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 19.62µs >>> [INFO] [stderr] [2025-09-01 08:04:11.914334][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.914507][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 13.45µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:11.923264][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.925153][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 16.8µs >>> [INFO] [stderr] [2025-09-01 08:04:11.927482][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:11.929142][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 19.71µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_4 ... ok [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_5 ... ok [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_6 ... ok [INFO] [stderr] [2025-09-01 08:04:11.942237][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.942413][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 17.77µs >>> [INFO] [stderr] [2025-09-01 08:04:11.943214][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:11.943320][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 11.23µs >>> [INFO] [stderr] [2025-09-01 08:04:11.943937][INFO][test_blocking_context.rs:203] <<< test_basic_unbounded_1_thread (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:12.707339][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.01197509s >>> [INFO] [stderr] [2025-09-01 08:04:12.728590][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.001705201s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:12.743224][INFO][test_blocking_context.rs:203] <<< test_basic_unbounded_1_thread (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:12.744067][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.01094858s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:12.763245][INFO][test_blocking_context.rs:203] <<< test_basic_unbounded_1_thread (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:12.787213][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:12.787426][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 24.42µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_1 ... ok [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_2 ... ok [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:12.815253][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:12.815460][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 19.93µs >>> [INFO] [stderr] [2025-09-01 08:04:12.842307][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:12.842460][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 17.05µs >>> [INFO] [stderr] [2025-09-01 08:04:12.862435][INFO][test_blocking_context.rs:124] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:12.862587][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 14.6µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-01 08:04:12.944541][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 1.000514671s >>> [INFO] [stderr] [2025-09-01 08:04:13.009662][INFO][test_blocking_context.rs:124] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:13.009838][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 19.2µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:13.010260][INFO][test_blocking_context.rs:124] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_conversion ... ok [INFO] [stderr] [2025-09-01 08:04:13.010351][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 11.37µs >>> [INFO] [stderr] [2025-09-01 08:04:13.012003][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:13.012290][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:13.763544][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 1.000404101s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-01 08:04:13.779718][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:13.866499][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 1.103071701s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:13.942205][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_04 ... ok [INFO] [stderr] [2025-09-01 08:04:17.172295][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 3.22996111s >>> [INFO] [stderr] [2025-09-01 08:04:17.358680][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:17.469614][INFO][test_blocking_async.rs:298] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 16.756596611s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_09 ... ok [INFO] [stderr] [2025-09-01 08:04:17.484805][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:19.407033][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 5.627185132s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_03 ... ok [INFO] [stderr] [2025-09-01 08:04:19.420333][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_03 has been running for over 60 seconds [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_07 ... ok [INFO] [stderr] [2025-09-01 08:04:21.902044][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 2.481491125s >>> [INFO] [stderr] [2025-09-01 08:04:21.911216][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_08 ... ok [INFO] [stderr] [2025-09-01 08:04:23.601602][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 1.690248653s >>> [INFO] [stderr] [2025-09-01 08:04:23.601967][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_06 has been running for over 60 seconds [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_02 ... ok [INFO] [stderr] [2025-09-01 08:04:25.827899][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 12.815532142s >>> [INFO] [stderr] [2025-09-01 08:04:25.828247][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:26.041673][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 8.556703313s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_06 ... ok [INFO] [stderr] [2025-09-01 08:04:26.042068][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-01 08:04:28.818053][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 2.775815715s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_11 ... ok [INFO] [stderr] [2025-09-01 08:04:28.821161][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_09 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:04:32.106930][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 3.285649315s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_12 ... ok [INFO] [stderr] [2025-09-01 08:04:32.108506][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 2) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_12 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:04:37.667756][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 11.839398168s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_10 ... ok [INFO] [stderr] [2025-09-01 08:04:37.671227][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 16, rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:04:37.705685][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 73.766195231s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_06 ... ok [INFO] [stderr] [2025-09-01 08:04:37.707226][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 16) enter <<< [INFO] [stderr] [2025-09-01 08:04:43.926462][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 67.919116569s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_12 ... ok [INFO] [stderr] [2025-09-01 08:04:43.930546][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 2) enter <<< [INFO] [stderr] [2025-09-01 08:04:45.941629][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 8.234082185s >>> [INFO] [stderr] [2025-09-01 08:04:45.942431][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 13, rx_count = 2) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_03 ... ok [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-01 08:04:52.259791][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 109.730243041s >>> [INFO] [stderr] [2025-09-01 08:04:52.265256][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:04:58.564877][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 14.634209532s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_04 ... ok [INFO] [stderr] [2025-09-01 08:04:58.568199][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:05:01.590122][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 9.324686877s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_06 ... ok [INFO] [stderr] [2025-09-01 08:05:01.593149][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 8, rx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:05:01.888893][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 3.320576222s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_07 ... ok [INFO] [stderr] [2025-09-01 08:05:01.896243][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 8) enter <<< [INFO] [stderr] [2025-09-01 08:05:03.967772][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 103.025077915s >>> [INFO] [stderr] [2025-09-01 08:05:03.986240][INFO][test_blocking_context.rs:391] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_03 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_09 ... ok [INFO] [stderr] [2025-09-01 08:05:07.412157][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 5.515770404s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_09 ... ok [INFO] [stderr] [2025-09-01 08:05:07.413404][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:05:07.471434][INFO][test_blocking_async.rs:231] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 97.995964452s >>> [INFO] [stderr] [2025-09-01 08:05:07.472486][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-01 08:05:08.740542][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 36.631919956s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_01 ... ok [INFO] [stderr] [2025-09-01 08:05:08.792190][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-01 08:05:09.558733][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 5.572345109s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_10 ... ok [INFO] [stderr] [2025-09-01 08:05:09.817856][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 16) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_6 ... ok [INFO] [stderr] [2025-09-01 08:05:12.287614][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 128.634817501s >>> [INFO] [stderr] [2025-09-01 08:05:12.288048][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 4) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_01 ... ok [INFO] [stderr] [2025-09-01 08:05:12.473702][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 59.461583555s >>> [INFO] [stderr] [2025-09-01 08:05:12.474205][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 7) enter <<< [INFO] [stderr] [2025-09-01 08:05:13.818450][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 12.22517429s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_08 ... ok [INFO] [stderr] [2025-09-01 08:05:13.820175][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 12) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_05 has been running for over 60 seconds [INFO] [stderr] [2025-09-01 08:05:22.066382][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 64.686480559s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_05 ... ok [INFO] [stderr] [2025-09-01 08:05:22.077418][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 3) enter <<< [INFO] [stderr] [2025-09-01 08:05:22.448372][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 44.776989689s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_02 ... ok [INFO] [stderr] [2025-09-01 08:05:22.523455][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 9) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_09 ... ok [INFO] [stderr] [2025-09-01 08:05:23.474453][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 59.872302025s >>> [INFO] [stderr] [2025-09-01 08:05:23.476276][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 13) enter <<< [INFO] [stderr] [2025-09-01 08:05:24.336546][INFO][test_blocking_context.rs:391] >>> test_pressure_bounded_blocking_multi return () in 38.392790861s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_05 ... ok [INFO] [stderr] [2025-09-01 08:05:24.426065][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 2) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_01 ... ok [INFO] [stderr] [2025-09-01 08:05:24.441280][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 17.025394575s >>> [INFO] [stderr] [2025-09-01 08:05:24.442687][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 5) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_03 ... ok [INFO] [stderr] [2025-09-01 08:05:27.692075][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 166.376657507s >>> [INFO] [stderr] [2025-09-01 08:05:27.694409][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 15) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_08 ... ok [INFO] [stderr] [2025-09-01 08:05:28.521074][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 6.443502432s >>> [INFO] [stderr] [2025-09-01 08:05:28.525593][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 3) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_05 ... ok [INFO] [stderr] [2025-09-01 08:05:28.885483][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 16.597032667s >>> [INFO] [stderr] [2025-09-01 08:05:28.890213][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 7) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_02 ... ok [INFO] [stderr] [2025-09-01 08:05:30.276577][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 22.803934194s >>> [INFO] [stderr] [2025-09-01 08:05:30.473485][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 16) enter <<< [INFO] [stderr] [2025-09-01 08:05:39.746727][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 15.320369904s >>> [INFO] [stderr] [2025-09-01 08:05:39.751252][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 2) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_11 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_06 ... ok [INFO] [stderr] [2025-09-01 08:05:43.879341][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 31.404972953s >>> [INFO] [stderr] [2025-09-01 08:05:43.885706][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 8) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_17 ... ok [INFO] [stderr] [2025-09-01 08:05:44.888734][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 5.137313282s >>> [INFO] [stderr] [2025-09-01 08:05:44.889390][INFO][test_blocking_context.rs:329] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 16) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_12 ... ok [INFO] [stderr] [2025-09-01 08:05:45.847158][INFO][test_async.rs:705] >>> test_pressure_bounded_async_multi_1 return () in 182.442396206s >>> [INFO] [stderr] [2025-09-01 08:05:45.849856][INFO][test_blocking_context.rs:451] <<< test_pressure_bounded_timeout_blocking (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_14 ... ok [INFO] [stderr] [2025-09-01 08:05:46.904190][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 18.378407281s >>> [INFO] [stderr] [2025-09-01 08:05:52.188397][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 29.664735444s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_09 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_07 ... ok [INFO] [stderr] [2025-09-01 08:05:59.881535][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 46.061223772s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_18 ... ok [INFO] [stderr] [2025-09-01 08:06:01.982329][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 18.09644965s >>> [INFO] [stderr] [2025-09-01 08:06:03.885581][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 55.089462909s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_03 ... ok [INFO] [stderr] [2025-09-01 08:06:04.782458][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 40.338987478s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_12 ... ok [INFO] [stderr] [2025-09-01 08:06:05.535664][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 36.645317124s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_15 ... ok [INFO] [stderr] [2025-09-01 08:06:06.986054][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 43.509596075s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_10 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_04 has been running for over 60 seconds [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_4 ... ok [INFO] [stderr] [2025-09-01 08:06:14.261870][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 191.725869798s >>> [INFO] [stderr] [2025-09-01 08:06:14.466569][INFO][test_async_blocking.rs:276] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 188.888103749s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_8 ... ok [INFO] [stderr] [2025-09-01 08:06:18.370141][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 33.479624638s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_19 ... ok [INFO] [stderr] [2025-09-01 08:06:18.586808][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 68.768235896s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_04 ... ok [INFO] [stderr] [2025-09-01 08:06:23.768210][INFO][test_async_blocking.rs:330] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 196.340814034s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_4 ... ok [INFO] [stderr] [2025-09-01 08:06:25.485350][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 55.01170098s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_16 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_13 has been running for over 60 seconds [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_timeout_blocking::case_1 ... ok [INFO] [stderr] [2025-09-01 08:06:31.861764][INFO][test_blocking_context.rs:451] >>> test_pressure_bounded_timeout_blocking return () in 46.011647242s >>> [INFO] [stderr] [2025-09-01 08:06:32.292379][INFO][test_blocking_context.rs:329] >>> test_pressure_bounded_blocking_multi_1 return () in 64.597850173s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_13 ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 281 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 232.08s [INFO] [stdout] [INFO] [stderr] Doc-tests crossfire [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test src/mpsc.rs - mpsc (line 25) - compile fail ... ok [INFO] [stdout] test src/async_rx.rs - async_rx::AsyncRx (line 45) - compile fail ... ok [INFO] [stdout] test src/blocking_rx.rs - blocking_rx::Rx (line 33) - compile fail ... ok [INFO] [stdout] test src/async_tx.rs - async_tx::AsyncTx (line 45) - compile fail ... ok [INFO] [stdout] test src/spsc.rs - spsc (line 25) - compile fail ... ok [INFO] [stdout] test src/blocking_tx.rs - blocking_tx::Tx (line 33) - compile fail ... ok [INFO] [stdout] test src/mpsc.rs - mpsc (line 10) ... ok [INFO] [stdout] test src/spsc.rs - spsc (line 10) ... ok [INFO] [stdout] test src/async_tx.rs - async_tx::AsyncTx (line 30) ... ok [INFO] [stdout] test src/async_rx.rs - async_rx::AsyncRx (line 30) ... ok [INFO] [stdout] test src/blocking_rx.rs - blocking_rx::Rx (line 20) ... ok [INFO] [stdout] test src/blocking_tx.rs - blocking_tx::Tx (line 20) ... ok [INFO] [stdout] test src/lib.rs - (line 139) ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 2.72s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "a381df26ceacb18dcd330ff6082ded6ba19748fa311217e89c4398db70b49279", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a381df26ceacb18dcd330ff6082ded6ba19748fa311217e89c4398db70b49279", kill_on_drop: false }` [INFO] [stdout] a381df26ceacb18dcd330ff6082ded6ba19748fa311217e89c4398db70b49279