[INFO] fetching crate crossfire 2.0.26... [INFO] testing crossfire-2.0.26 against try#b83b707f97d809763b7861afa7638871f3339a33 for pr-145838-2 [INFO] extracting crate crossfire 2.0.26 into /workspace/builds/worker-3-tc2/source [INFO] started tweaking crates.io crate crossfire 2.0.26 [INFO] finished tweaking crates.io crate crossfire 2.0.26 [INFO] tweaked toml for crates.io crate crossfire 2.0.26 written to /workspace/builds/worker-3-tc2/source/Cargo.toml [INFO] validating manifest of crates.io crate crossfire 2.0.26 on toolchain b83b707f97d809763b7861afa7638871f3339a33 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate crossfire 2.0.26 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" "+b83b707f97d809763b7861afa7638871f3339a33" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/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" "+b83b707f97d809763b7861afa7638871f3339a33" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 68a549b08bcf49dbed954430daa955b06b738048eb8d84f5b62df0c6a2187ec7 [INFO] running `Command { std: "docker" "start" "-a" "68a549b08bcf49dbed954430daa955b06b738048eb8d84f5b62df0c6a2187ec7", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "68a549b08bcf49dbed954430daa955b06b738048eb8d84f5b62df0c6a2187ec7", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "68a549b08bcf49dbed954430daa955b06b738048eb8d84f5b62df0c6a2187ec7", kill_on_drop: false }` [INFO] [stdout] 68a549b08bcf49dbed954430daa955b06b738048eb8d84f5b62df0c6a2187ec7 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/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" "+b83b707f97d809763b7861afa7638871f3339a33" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 2f491f0756aca012eb2dd7a3a5619ddd996d8d4a3f3885e0e82230d3c3dc0c46 [INFO] running `Command { std: "docker" "start" "-a" "2f491f0756aca012eb2dd7a3a5619ddd996d8d4a3f3885e0e82230d3c3dc0c46", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.101 [INFO] [stderr] Compiling unicode-ident v1.0.18 [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling autocfg v1.5.0 [INFO] [stderr] Compiling libc v0.2.175 [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling slab v0.4.11 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling memchr v2.7.5 [INFO] [stderr] Compiling futures-task v0.3.31 [INFO] [stderr] Compiling pin-utils v0.1.0 [INFO] [stderr] Compiling pin-project-lite v0.2.16 [INFO] [stderr] Compiling futures-io v0.3.31 [INFO] [stderr] Compiling scopeguard v1.2.0 [INFO] [stderr] Compiling cfg-if v1.0.3 [INFO] [stderr] Compiling smallvec v1.15.1 [INFO] [stderr] Compiling once_cell v1.21.3 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling lock_api v0.4.13 [INFO] [stderr] Compiling quote v1.0.40 [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 syn v2.0.106 [INFO] [stderr] Compiling crossbeam-deque v0.8.6 [INFO] [stderr] Compiling crossbeam v0.8.4 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling enum_dispatch v0.3.13 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling crossfire v2.0.26 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 12.53s [INFO] running `Command { std: "docker" "inspect" "2f491f0756aca012eb2dd7a3a5619ddd996d8d4a3f3885e0e82230d3c3dc0c46", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "2f491f0756aca012eb2dd7a3a5619ddd996d8d4a3f3885e0e82230d3c3dc0c46", kill_on_drop: false }` [INFO] [stdout] 2f491f0756aca012eb2dd7a3a5619ddd996d8d4a3f3885e0e82230d3c3dc0c46 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/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" "+b83b707f97d809763b7861afa7638871f3339a33" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 2969a6f2e91fa52a172c452b6ced5597dd78daf494d187395ca3c9dcd6db0a0c [INFO] running `Command { std: "docker" "start" "-a" "2969a6f2e91fa52a172c452b6ced5597dd78daf494d187395ca3c9dcd6db0a0c", kill_on_drop: false }` [INFO] [stderr] Compiling libc v0.2.175 [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling zerocopy v0.8.26 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling regex-syntax v0.8.6 [INFO] [stderr] Compiling once_cell v1.21.3 [INFO] [stderr] Compiling semver v1.0.26 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling cfg_aliases v0.2.1 [INFO] [stderr] Compiling crc32fast v1.5.0 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling hashbrown v0.15.5 [INFO] [stderr] Compiling value-bag v1.11.1 [INFO] [stderr] Compiling syn v2.0.106 [INFO] [stderr] Compiling equivalent v1.0.2 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling nix v0.30.1 [INFO] [stderr] Compiling adler2 v2.0.1 [INFO] [stderr] Compiling memchr v2.7.5 [INFO] [stderr] Compiling miniz_oxide v0.8.9 [INFO] [stderr] Compiling object v0.36.7 [INFO] [stderr] Compiling rayon-core v1.13.0 [INFO] [stderr] Compiling log v0.4.27 [INFO] [stderr] Compiling bitflags v2.9.3 [INFO] [stderr] Compiling toml_datetime v0.6.11 [INFO] [stderr] Compiling winnow v0.7.13 [INFO] [stderr] Compiling aho-corasick v1.1.3 [INFO] [stderr] Compiling rustc_version v0.4.1 [INFO] [stderr] Compiling half v2.6.0 [INFO] [stderr] Compiling ciborium-io v0.2.2 [INFO] [stderr] Compiling parking v2.2.1 [INFO] [stderr] Compiling serde_json v1.0.143 [INFO] [stderr] Compiling gimli v0.31.1 [INFO] [stderr] Compiling crossbeam-epoch v0.9.18 [INFO] [stderr] Compiling crossbeam-queue v0.3.12 [INFO] [stderr] Compiling indexmap v2.11.0 [INFO] [stderr] Compiling crossbeam-channel v0.5.15 [INFO] [stderr] Compiling rstest_macros v0.26.1 [INFO] [stderr] Compiling concurrent-queue v2.5.0 [INFO] [stderr] Compiling signal-hook v0.3.18 [INFO] [stderr] Compiling iana-time-zone v0.1.63 [INFO] [stderr] Compiling event-listener v5.4.1 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling flate2 v1.1.2 [INFO] [stderr] Compiling crossbeam-deque v0.8.6 [INFO] [stderr] Compiling itoa v1.0.15 [INFO] [stderr] Compiling rustc-demangle v0.1.26 [INFO] [stderr] Compiling same-file v1.0.6 [INFO] [stderr] Compiling either v1.15.0 [INFO] [stderr] Compiling crossbeam v0.8.4 [INFO] [stderr] Compiling ryu v1.0.20 [INFO] [stderr] Compiling relative-path v1.9.3 [INFO] [stderr] Compiling glob v0.3.3 [INFO] [stderr] Compiling walkdir v2.5.0 [INFO] [stderr] Compiling event-listener-strategy v0.5.4 [INFO] [stderr] Compiling spin v0.9.8 [INFO] [stderr] Compiling exitcode v1.1.2 [INFO] [stderr] Compiling bpaf v0.9.20 [INFO] [stderr] Compiling cast v0.3.0 [INFO] [stderr] Compiling arc-swap v1.7.1 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling ppv-lite86 v0.2.21 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling rand_core v0.6.4 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling signal-hook-registry v1.4.6 [INFO] [stderr] Compiling rayon v1.11.0 [INFO] [stderr] Compiling regex-automata v0.4.10 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling rand_chacha v0.3.1 [INFO] [stderr] Compiling rand v0.8.5 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling file-rotate v0.8.0 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling nanorand v0.7.0 [INFO] [stderr] Compiling oorandom v11.1.5 [INFO] [stderr] Compiling anes v0.2.1 [INFO] [stderr] Compiling futures-timer v3.0.3 [INFO] [stderr] Compiling flume v0.11.1 [INFO] [stderr] Compiling async-channel v2.5.0 [INFO] [stderr] Compiling fail v0.5.1 [INFO] [stderr] Compiling addr2line v0.24.2 [INFO] [stderr] Compiling kanal v0.1.1 [INFO] [stderr] Compiling io-buffer v1.0.3 [INFO] [stderr] Compiling ring-file v0.1.2 [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 backtrace v0.3.75 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling tokio v1.47.1 [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.26 (/opt/rustwide/workdir) [INFO] [stderr] Compiling captains-log v0.8.6 [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:945:8 [INFO] [stdout] | [INFO] [stdout] 945 | 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:976:8 [INFO] [stdout] | [INFO] [stdout] 976 | struct SpuriousRx { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 38.26s [INFO] running `Command { std: "docker" "inspect" "2969a6f2e91fa52a172c452b6ced5597dd78daf494d187395ca3c9dcd6db0a0c", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "2969a6f2e91fa52a172c452b6ced5597dd78daf494d187395ca3c9dcd6db0a0c", kill_on_drop: false }` [INFO] [stdout] 2969a6f2e91fa52a172c452b6ced5597dd78daf494d187395ca3c9dcd6db0a0c [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc2/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" "+b83b707f97d809763b7861afa7638871f3339a33" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 7e114cc6109dca138018db755933f06e90471ba3ea0501315d2f5c73b15d9ee1 [INFO] running `Command { std: "docker" "start" "-a" "7e114cc6109dca138018db755933f06e90471ba3ea0501315d2f5c73b15d9ee1", kill_on_drop: false }` [INFO] [stderr] warning: struct `SpuriousTx` is never constructed [INFO] [stderr] --> src/tests/test_async.rs:945:8 [INFO] [stderr] | [INFO] [stderr] 945 | 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:976:8 [INFO] [stderr] | [INFO] [stderr] 976 | 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-57457c4b267ea3c2) [INFO] [stdout] [INFO] [stdout] running 280 tests [INFO] [stderr] [2025-09-03 12:58:09.886141][INFO][test_async.rs:221] <<< test_basic_bounded_1_thread (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.886191][INFO][test_async.rs:221] <<< test_basic_bounded_1_thread (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.886478][INFO][test_async.rs:230] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.886692][INFO][test_async.rs:221] <<< test_basic_bounded_1_thread (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887071][INFO][test_async.rs:19] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887246][INFO][test_async.rs:19] >>> test_basic_bounded_empty_full_drop_rx return () in 19.871µs >>> [INFO] [stderr] [2025-09-03 12:58:09.887173][INFO][test_async.rs:44] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887303][INFO][test_async.rs:44] >>> test_basic_bounded_empty_full_drop_tx return () in 10.48µs >>> [INFO] [stderr] [2025-09-03 12:58:09.887073][INFO][test_async.rs:19] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887271][INFO][test_async.rs:44] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887385][INFO][test_async.rs:19] >>> test_basic_bounded_empty_full_drop_rx return () in 42.7µs >>> [INFO] [stderr] [2025-09-03 12:58:09.887396][INFO][test_async.rs:44] >>> test_basic_bounded_empty_full_drop_tx return () in 9.92µs >>> [INFO] [stderr] [2025-09-03 12:58:09.887335][INFO][test_async.rs:230] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.887403][INFO][test_async.rs:19] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887516][INFO][test_async.rs:19] >>> test_basic_bounded_empty_full_drop_rx return () in 9.871µs >>> [INFO] [stderr] [2025-09-03 12:58:09.887960][INFO][test_async.rs:357] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.888204][INFO][test_async.rs:372] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.888292][INFO][test_async.rs:357] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.887358][INFO][test_async.rs:230] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.888618][INFO][test_async.rs:372] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.888582][INFO][test_async.rs:44] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.888688][INFO][test_async.rs:44] >>> test_basic_bounded_empty_full_drop_tx return () in 9.55µs >>> [INFO] [stderr] [2025-09-03 12:58:09.888967][INFO][test_async.rs:357] <<< test_basic_bounded_recv_after_sender_close (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.889073][INFO][test_async.rs:372] run with tokio multi thread [INFO] [stdout] test collections::tests::test_locked_queue ... ok [INFO] [stdout] test locked_waker::tests::test_waker ... ok [INFO] [stdout] test collections::tests::test_weak_cell ... 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_tx::case_1 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_rx::case_1 ... 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_rx::case_2 ... ok [INFO] [stdout] test tests::test_async::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.890969][INFO][test_async.rs:171] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.891147][INFO][test_async.rs:179] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.891180][INFO][test_async.rs:69] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stderr] [2025-09-03 12:58:09.891346][INFO][test_async.rs:69] >>> test_basic_compile_bounded_empty_full return () in 26.46µs >>> [INFO] [stdout] test tests::test_async::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-03 12:58:09.891593][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.891704][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.891629][INFO][test_async.rs:490] <<< test_basic_send_timeout_async (setup_log = (), _channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.891723][INFO][test_async.rs:490] >>> test_basic_send_timeout_async return () in 1.549µs >>> [INFO] [stderr] [2025-09-03 12:58:09.891977][INFO][test_async.rs:490] <<< test_basic_send_timeout_async (setup_log = (), _channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.892077][INFO][test_async.rs:490] >>> test_basic_send_timeout_async return () in 989ns >>> [INFO] [stderr] [2025-09-03 12:58:09.892319][INFO][test_async.rs:490] <<< test_basic_send_timeout_async (setup_log = (), _channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.892437][INFO][test_async.rs:490] >>> test_basic_send_timeout_async return () in 1.11µs >>> [INFO] [stdout] test tests::test_async::test_basic_send_timeout_async::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.893017][INFO][test_async.rs:422] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.893114][INFO][test_async.rs:422] >>> test_basic_timeout_recv_async_waker return () in 970ns >>> [INFO] [stderr] [2025-09-03 12:58:09.894386][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.894500][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.895270][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.895392][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.896615][INFO][test_async.rs:171] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.896650][INFO][test_async.rs:171] <<< test_basic_bounded_rx_drop (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.896762][INFO][test_async.rs:179] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.897118][INFO][test_async.rs:179] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.897418][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.897518][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.900241][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.900391][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.902098][INFO][test_async.rs:1088] <<< test_basic_into_stream_1_1 (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.902207][INFO][test_async.rs:1099] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.903281][INFO][test_async.rs:422] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (MAsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.903484][INFO][test_async.rs:422] >>> test_basic_timeout_recv_async_waker return () in 2.81µs >>> [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.906294][INFO][test_async.rs:422] <<< test_basic_timeout_recv_async_waker (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.906464][INFO][test_async.rs:422] >>> test_basic_timeout_recv_async_waker return () in 1.82µs >>> [INFO] [stdout] test tests::test_async::test_basic_timeout_recv_async_waker::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.906726][INFO][test_async.rs:266] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.906814][INFO][test_async.rs:277] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.922228][INFO][test_async.rs:188] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.922312][INFO][test_async.rs:191] dropped tx [INFO] [stderr] [2025-09-03 12:58:09.922859][INFO][test_async.rs:188] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.923231][INFO][test_async.rs:357] >>> test_basic_bounded_recv_after_sender_close return () in 34.621243ms >>> [INFO] [stderr] [2025-09-03 12:58:09.923408][INFO][test_async.rs:188] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.923460][INFO][test_async.rs:191] dropped tx [INFO] [stderr] [2025-09-03 12:58:09.923798][INFO][test_async.rs:191] dropped tx [INFO] [stderr] [2025-09-03 12:58:09.926611][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 31.219183ms >>> [INFO] [stderr] [2025-09-03 12:58:09.939411][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 47.70558ms >>> [INFO] [stderr] [2025-09-03 12:58:09.939922][INFO][test_async.rs:357] >>> test_basic_bounded_recv_after_sender_close return () in 51.73114ms >>> [INFO] [stderr] [2025-09-03 12:58:09.941291][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 46.79221ms >>> [INFO] [stderr] [2025-09-03 12:58:09.941858][INFO][test_async.rs:171] >>> test_basic_bounded_rx_drop return () in 50.713569ms >>> [INFO] [stderr] [2025-09-03 12:58:09.942321][INFO][test_async.rs:171] >>> test_basic_bounded_rx_drop return () in 45.55972ms >>> [INFO] [stderr] [2025-09-03 12:58:09.942612][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 42.223281ms >>> [INFO] [stderr] [2025-09-03 12:58:09.943016][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 45.498831ms >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.944000][INFO][test_async.rs:171] >>> test_basic_bounded_rx_drop return () in 46.883891ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_6 ... ok [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.944428][INFO][test_async.rs:1088] >>> test_basic_into_stream_1_1 return () in 42.222692ms >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.944347][INFO][test_async.rs:357] >>> test_basic_bounded_recv_after_sender_close return () in 55.280129ms >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:09.944821][INFO][test_async.rs:310] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.945136][INFO][test_async.rs:332] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.945246][INFO][test_async.rs:310] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.946041][INFO][test_async.rs:332] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_bounded_rx_drop::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.946533][INFO][test_async.rs:456] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:09.946472][INFO][test_async.rs:266] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.947009][INFO][test_async.rs:456] >>> test_basic_unbounded_recv_timeout_async return () in 1.59µs >>> [INFO] [stderr] [2025-09-03 12:58:09.946838][INFO][test_async.rs:277] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.946395][INFO][test_async.rs:266] <<< test_basic_unbounded_1_thread (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.947198][INFO][test_async.rs:277] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.947233][INFO][test_async.rs:389] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.947550][INFO][test_async.rs:406] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.947702][INFO][test_async.rs:389] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.947982][INFO][test_async.rs:406] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.948245][INFO][test_async.rs:389] <<< test_basic_unbounded_recv_after_sender_close (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.948458][INFO][test_async.rs:456] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.948743][INFO][test_async.rs:456] <<< test_basic_unbounded_recv_timeout_async (setup_log = (), _channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.948829][INFO][test_async.rs:456] >>> test_basic_unbounded_recv_timeout_async return () in 980ns >>> [INFO] [stderr] [2025-09-03 12:58:09.948889][INFO][test_async.rs:406] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.947059][INFO][test_async.rs:310] <<< test_basic_unbounded_idle_select (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.948558][INFO][test_async.rs:456] >>> test_basic_unbounded_recv_timeout_async return () in 790ns >>> [INFO] [stdout] test tests::test_async::test_basic_into_stream_1_1::case_3 ... ok [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.950387][INFO][test_async.rs:332] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:09.951500][INFO][test_async.rs:196] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.951643][INFO][test_async.rs:204] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.952523][INFO][test_async.rs:196] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.952822][INFO][test_async.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_timeout_async::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.955543][INFO][test_async.rs:196] <<< test_basic_unbounded_rx_drop (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.955709][INFO][test_async.rs:204] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_conversion ... ok [INFO] [stderr] [2025-09-03 12:58:09.960702][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.960932][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.965812][INFO][test_async.rs:389] >>> test_basic_unbounded_recv_after_sender_close return () in 18.374716ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.968980][INFO][test_async.rs:389] >>> test_basic_unbounded_recv_after_sender_close return () in 20.410446ms >>> [INFO] [stderr] [2025-09-03 12:58:09.969248][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.969479][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.969559][INFO][test_async.rs:213] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.969607][INFO][test_async.rs:216] dropped tx [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:09.970774][INFO][test_async.rs:213] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.970859][INFO][test_async.rs:216] dropped tx [INFO] [stderr] [2025-09-03 12:58:09.974044][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (AsyncTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.974246][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.975448][INFO][test_async.rs:196] >>> test_basic_unbounded_rx_drop return () in 23.806325ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:09.982791][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:09.982964][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:09.989545][INFO][test_async.rs:196] >>> test_basic_unbounded_rx_drop return () in 33.835253ms >>> [INFO] [stderr] [2025-09-03 12:58:09.989854][INFO][test_async.rs:213] try to send after rx dropped [INFO] [stderr] [2025-09-03 12:58:09.989892][INFO][test_async.rs:216] dropped tx [INFO] [stderr] [2025-09-03 12:58:10.005416][INFO][test_async.rs:389] >>> test_basic_unbounded_recv_after_sender_close return () in 57.566078ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.005752][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 31.507974ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.005836][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.006318][INFO][test_async.rs:196] >>> test_basic_unbounded_rx_drop return () in 53.497479ms >>> [INFO] [stdout] test tests::test_async::test_basic_unbounded_rx_drop::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:10.006412][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.006564][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.006650][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.008717][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.008820][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.010519][INFO][test_async.rs:679] <<< test_pressure_bounded_async_1_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.010721][INFO][test_async.rs:693] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.029762][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 19.040006ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:10.030159][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.030330][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:10.058167][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 88.688172ms >>> [INFO] [stderr] [2025-09-03 12:58:10.059470][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.059591][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.085532][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 79.118653ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:10.090945][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:10.091132][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.091955][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 85.305452ms >>> [INFO] [stderr] [2025-09-03 12:58:10.092338][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.092453][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_05 ... ok [INFO] [stderr] [2025-09-03 12:58:10.199598][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 107.142148ms >>> [INFO] [stderr] [2025-09-03 12:58:10.228547][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 168.954904ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_03 ... ok [INFO] [stderr] [2025-09-03 12:58:10.229041][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.229161][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_01 ... ok [INFO] [stderr] [2025-09-03 12:58:10.302772][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 293.949169ms >>> [INFO] [stderr] [2025-09-03 12:58:10.305477][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.305636][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.313120][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 83.959082ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_07 ... ok [INFO] [stderr] [2025-09-03 12:58:10.323639][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.323786][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_09 ... ok [INFO] [stderr] [2025-09-03 12:58:10.284116][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:10.384176][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.390644][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 66.859036ms >>> [INFO] [stderr] [2025-09-03 12:58:10.391070][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.391208][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.405500][INFO][test_async.rs:353] waker rx 0 [INFO] [stderr] [2025-09-03 12:58:10.406978][INFO][test_async.rs:310] >>> test_basic_unbounded_idle_select return () in 461.844175ms >>> [INFO] [stderr] [2025-09-03 12:58:10.407310][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 10, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.407499][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.418147][INFO][test_async.rs:353] waker rx 0 [INFO] [stderr] [2025-09-03 12:58:10.438497][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 477.566141ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:10.443566][INFO][test_async.rs:782] <<< test_pressure_bounded_async_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.443737][INFO][test_async.rs:808] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_1_1::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:10.458968][INFO][test_async.rs:353] waker rx 1 [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.460452][INFO][test_async.rs:679] >>> test_pressure_bounded_async_1_1 return () in 477.491481ms >>> [INFO] [stderr] [2025-09-03 12:58:10.464475][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.464620][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.466121][INFO][test_async.rs:310] >>> test_basic_unbounded_idle_select return () in 520.083292ms >>> [INFO] [stderr] [2025-09-03 12:58:10.466386][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.466498][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_idle_select::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:10.665432][INFO][test_async.rs:310] >>> test_basic_unbounded_idle_select return () in 715.045522ms >>> [INFO] [stderr] [2025-09-03 12:58:10.678532][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.678698][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.827556][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 420.056283ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_11 ... ok [INFO] [stderr] [2025-09-03 12:58:10.834584][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.834751][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.927233][INFO][test_async.rs:221] >>> test_basic_bounded_1_thread return () in 1.039926454s >>> [INFO] [stderr] [2025-09-03 12:58:10.928185][INFO][test_async.rs:221] >>> test_basic_bounded_1_thread return () in 1.041759253s >>> [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:10.931082][INFO][test_async.rs:221] >>> test_basic_bounded_1_thread return () in 1.043757634s >>> [INFO] [stderr] [2025-09-03 12:58:10.933499][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.933630][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.937828][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stdout] test tests::test_async::test_basic_bounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:10.937930][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:10.947702][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:10.947807][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_basic_unbounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:10.950647][INFO][test_async.rs:266] >>> test_basic_unbounded_1_thread return () in 1.043831832s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_02 ... ok [INFO] [stderr] [2025-09-03 12:58:10.963844][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.963981][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.966733][INFO][test_async.rs:266] >>> test_basic_unbounded_1_thread return () in 1.019899728s >>> [INFO] [stderr] [2025-09-03 12:58:10.967141][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:10.967337][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:10.996696][INFO][test_async.rs:266] >>> test_basic_unbounded_1_thread return () in 1.049490002s >>> [INFO] [stderr] [2025-09-03 12:58:10.997744][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 967.417109ms >>> [INFO] [stderr] [2025-09-03 12:58:11.614509][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:11.614704][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:11.614861][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:11.615022][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_07 ... ok [INFO] [stderr] [2025-09-03 12:58:11.631113][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 683.304098ms >>> [INFO] [stderr] [2025-09-03 12:58:11.632508][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:11.632661][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:11.727108][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 1.335897262s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_10 ... ok [INFO] [stderr] [2025-09-03 12:58:11.738563][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:11.738750][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:11.941693][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 1.557520537s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_06 ... ok [INFO] [stderr] [2025-09-03 12:58:11.974946][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:11.975101][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_04 ... ok [INFO] [stderr] [2025-09-03 12:58:12.747961][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 2.656828878s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_13 ... ok [INFO] [stderr] [2025-09-03 12:58:12.749083][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:12.749256][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:12.797686][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 1.05893607s >>> [INFO] [stderr] [2025-09-03 12:58:12.798165][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:12.798291][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:12.896159][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 2.590521742s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_08 ... ok [INFO] [stderr] [2025-09-03 12:58:12.896614][INFO][test_async.rs:718] <<< 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-03 12:58:12.896736][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_16 ... ok [INFO] [stderr] [2025-09-03 12:58:12.916573][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 2.081820167s >>> [INFO] [stderr] [2025-09-03 12:58:12.918514][INFO][test_async.rs:718] <<< test_pressure_bounded_async_multi_1 (setup_log = (), channel = (MAsyncTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:12.918643][INFO][test_async.rs:749] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:12.959661][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 161.369706ms >>> [INFO] [stderr] [2025-09-03 12:58:13.042560][INFO][test_async.rs:853] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.042734][INFO][test_async.rs:862] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_01 ... ok [INFO] [stderr] [2025-09-03 12:58:13.276145][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 2.811524156s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:13.276629][INFO][test_async.rs:853] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.276787][INFO][test_async.rs:862] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.299198][INFO][test_async.rs:853] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 22.410165ms >>> [INFO] [stderr] [2025-09-03 12:58:13.299904][INFO][test_async.rs:853] <<< test_pressure_bounded_mixed_async_blocking_conversion (setup_log = (), channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.300040][INFO][test_async.rs:862] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.321243][INFO][test_async.rs:853] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 21.203526ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:13.321867][INFO][test_async.rs:550] <<< test_pressure_bounded_timeout_async (setup_log = (), _channel = (MAsyncTx, MAsyncRx)) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_timeout_async::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:13.321978][INFO][test_async.rs:550] >>> test_pressure_bounded_timeout_async return () in 750ns >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_mixed_async_blocking_conversion::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:13.322276][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.322386][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.360226][INFO][test_async.rs:853] >>> test_pressure_bounded_mixed_async_blocking_conversion return () in 317.491594ms >>> [INFO] [stderr] [2025-09-03 12:58:13.360680][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.360831][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.553477][INFO][test_async.rs:782] >>> test_pressure_bounded_async_multi return () in 3.109738624s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi::case_12 ... ok [INFO] [stderr] [2025-09-03 12:58:13.649174][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.650081][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.726652][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 365.820614ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:13.727075][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 3) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.727226][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.750100][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 427.734691ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:13.750757][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 2.135736396s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_10 ... ok [INFO] [stderr] [2025-09-03 12:58:13.753620][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.753797][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.755437][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 30) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.755548][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:13.784831][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 31.033523ms >>> [INFO] [stderr] [2025-09-03 12:58:13.785291][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.785512][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.814987][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 87.761281ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:13.815665][INFO][test_async.rs:1120] <<< test_pressure_stream_multi (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 50) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.815829][INFO][test_async.rs:1140] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.939605][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 123.775165ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_8 ... ok [INFO] [stderr] [2025-09-03 12:58:13.940318][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 154.809298ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:13.940980][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.941102][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:13.941792][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:58:13.941993][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:14.069496][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 313.945305ms >>> [INFO] [stderr] [2025-09-03 12:58:14.074498][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:14.074641][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:14.281138][INFO][test_async.rs:1120] >>> test_pressure_stream_multi return () in 631.064479ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:14.281688][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 3) enter <<< [INFO] [stderr] [2025-09-03 12:58:14.281845][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_08 ... ok [INFO] [stderr] [2025-09-03 12:58:14.759628][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 3.795644421s >>> [INFO] [stderr] [2025-09-03 12:58:14.760188][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 30) enter <<< [INFO] [stderr] [2025-09-03 12:58:14.760417][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:16.223464][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 5.289833091s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_05 ... ok [INFO] [stderr] [2025-09-03 12:58:16.223913][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:58:16.224046][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:16.346701][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 1.58627957s >>> [INFO] [stderr] [2025-09-03 12:58:16.348050][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 4) enter <<< [INFO] [stderr] [2025-09-03 12:58:16.348815][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:17.340694][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 4.443956127s >>> [INFO] [stderr] [2025-09-03 12:58:17.341502][INFO][test_async.rs:1168] <<< test_pressure_stream_multi_idle (setup_log = (), channel = (MAsyncTx, MAsyncRx), rx_count = 50) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_17 ... ok [INFO] [stderr] [2025-09-03 12:58:17.341645][INFO][test_async.rs:1188] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:18.186430][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 844.785484ms >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_8 ... ok [INFO] [stderr] [2025-09-03 12:58:18.186792][INFO][test_async.rs:1006] <<< test_spurious_sink (setup_log = ()) enter <<< [INFO] [stderr] [2025-09-03 12:58:18.186938][INFO][test_async.rs:1006] >>> test_spurious_sink return () in 60ns >>> [INFO] [stdout] test tests::test_async::test_spurious_sink ... ok [INFO] [stderr] [2025-09-03 12:58:18.187230][INFO][test_async.rs:1047] <<< test_spurious_stream (setup_log = ()) enter <<< [INFO] [stdout] test tests::test_async::test_spurious_stream ... ok [INFO] [stderr] [2025-09-03 12:58:18.187320][INFO][test_async.rs:1047] >>> test_spurious_stream return () in 50ns >>> [INFO] [stderr] [2025-09-03 12:58:18.192705][INFO][test_async.rs:87] <<< test_sync () enter <<< [INFO] [stderr] [2025-09-03 12:58:18.192792][INFO][test_async.rs:91] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:18.308519][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 4.233877611s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:18.309505][INFO][test_async_blocking.rs:78] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:18.309679][INFO][test_async_blocking.rs:107] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:18.953756][INFO][test_async_blocking.rs:78] >>> test_basic_1_tx_async_1_rx_blocking return () in 644.118607ms >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_14 ... ok [INFO] [stderr] [2025-09-03 12:58:18.955083][INFO][test_async_blocking.rs:78] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:18.955270][INFO][test_async_blocking.rs:107] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:18.999925][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 7.02482238s >>> [INFO] [stderr] [2025-09-03 12:58:19.000585][INFO][test_async_blocking.rs:78] <<< test_basic_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.000746][INFO][test_async_blocking.rs:107] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:19.609417][INFO][test_async_blocking.rs:78] >>> test_basic_1_tx_async_1_rx_blocking return () in 654.183534ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:19.610488][INFO][test_async_blocking.rs:14] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.610682][INFO][test_async_blocking.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 9.71µs >>> [INFO] [stderr] [2025-09-03 12:58:19.611778][INFO][test_async_blocking.rs:14] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.612469][INFO][test_async_blocking.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 9.21µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:19.613093][INFO][test_async_blocking.rs:14] <<< test_basic_bounded_empty_full_drop_rx (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.613214][INFO][test_async_blocking.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 9.48µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:19.613537][INFO][test_async_blocking.rs:37] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.613641][INFO][test_async_blocking.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 9.36µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:19.613822][INFO][test_async_blocking.rs:37] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.613933][INFO][test_async_blocking.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 10.58µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:19.614277][INFO][test_async_blocking.rs:37] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.614395][INFO][test_async_blocking.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 8µs >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:19.614627][INFO][test_async_blocking.rs:60] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stderr] [2025-09-03 12:58:19.614780][INFO][test_async_blocking.rs:60] >>> test_basic_compile_bounded_empty_full return () in 25.85µs >>> [INFO] [stderr] [2025-09-03 12:58:19.615006][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.615130][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-03 12:58:19.627143][INFO][test_async_blocking.rs:78] >>> test_basic_1_tx_async_1_rx_blocking return () in 626.44195ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_1_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:19.627496][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-03 12:58:19.627663][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:20.283899][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 668.806651ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:20.284853][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:20.285688][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:20.329483][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 701.856375ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:20.330010][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-03 12:58:20.330199][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_06 ... ok [INFO] [stderr] [2025-09-03 12:58:20.920729][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 9.982797846s >>> [INFO] [stderr] [2025-09-03 12:58:20.921116][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:20.921269][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:21.144008][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 858.366671ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:21.147157][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-03 12:58:21.147336][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:21.389414][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 8.470769871s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_18 ... ok [INFO] [stderr] [2025-09-03 12:58:21.390985][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:21.391762][INFO][test_async_blocking.rs:218] 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-03 12:58:21.600752][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 679.513709ms >>> [INFO] [stderr] [2025-09-03 12:58:21.601194][INFO][test_async_blocking.rs:169] <<< test_basic_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 1000) enter <<< [INFO] [stderr] [2025-09-03 12:58:21.601405][INFO][test_async_blocking.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:21.901527][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 10.286846632s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_11 ... ok [INFO] [stderr] [2025-09-03 12:58:21.901957][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:21.902114][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:21.907395][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 760.099592ms >>> [INFO] [stderr] [2025-09-03 12:58:21.907760][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:21.907999][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:22.142655][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 751.448264ms >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:22.143491][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:22.143679][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_09 ... ok [INFO] [stderr] [2025-09-03 12:58:22.690884][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 11.723544984s >>> [INFO] [stderr] [2025-09-03 12:58:22.691622][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:22.691778][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:23.382756][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.239118392s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_03 ... ok [INFO] [stderr] [2025-09-03 12:58:23.383171][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:23.383359][INFO][test_async_blocking.rs:285] 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-03 12:58:23.466062][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 3.135904868s >>> [INFO] [stderr] [2025-09-03 12:58:23.466473][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:23.466648][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:23.823410][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.131665205s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_04 ... ok [INFO] [stderr] [2025-09-03 12:58:23.823796][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:23.823978][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_sync ... ok [INFO] [stderr] [2025-09-03 12:58:24.204672][INFO][test_async.rs:87] >>> test_sync return () in 6.011879951s >>> [INFO] [stderr] [2025-09-03 12:58:24.205540][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:24.205703][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:24.324900][INFO][test_async_blocking.rs:169] >>> test_basic_multi_tx_async_1_rx_blocking return () in 2.723567394s >>> [INFO] [stdout] test tests::test_async_blocking::test_basic_multi_tx_async_1_rx_blocking::case_8 ... ok [INFO] [stderr] [2025-09-03 12:58:24.325358][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:24.326001][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:24.453622][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 10.512520146s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:24.453995][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:24.454157][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:24.637711][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 813.78206ms >>> [INFO] [stderr] [2025-09-03 12:58:24.638069][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_07 ... ok [INFO] [stderr] [2025-09-03 12:58:24.638262][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_08 ... ok [INFO] [stderr] [2025-09-03 12:58:25.040550][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 834.880357ms >>> [INFO] [stderr] [2025-09-03 12:58:25.040961][INFO][test_async_blocking.rs:242] <<< test_pressure_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:25.041140][INFO][test_async_blocking.rs:285] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_11 ... ok [INFO] [stderr] [2025-09-03 12:58:25.670167][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 1.031951046s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:25.670547][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:25.670694][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:25.704881][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 34.225493ms >>> [INFO] [stderr] [2025-09-03 12:58:25.705275][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:25.705451][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:25.829624][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 3.921680915s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_02 ... ok [INFO] [stderr] [2025-09-03 12:58:25.830011][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:25.830161][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:25.982484][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 277.066632ms >>> [INFO] [stderr] [2025-09-03 12:58:25.983033][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:25.983217][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:26.002618][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 961.51487ms >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_12 ... ok [INFO] [stderr] [2025-09-03 12:58:26.003065][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 5) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:26.003295][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:26.071866][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 68.620265ms >>> [INFO] [stderr] [2025-09-03 12:58:26.072263][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:26.072440][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_02 ... ok [INFO] [stderr] [2025-09-03 12:58:26.750922][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 16.284421006s >>> [INFO] [stderr] [2025-09-03 12:58:26.751281][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:26.751506][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:27.027757][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 276.340623ms >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:27.028111][INFO][test_async_blocking.rs:298] <<< test_pressure_multi_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:27.028265][INFO][test_async_blocking.rs:335] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:27.094397][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 10.745582807s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:27.094876][INFO][test_async_blocking.rs:358] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:27.095257][INFO][test_async_blocking.rs:397] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:27.135857][INFO][test_async_blocking.rs:358] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 40.828961ms >>> [INFO] [stderr] [2025-09-03 12:58:27.136278][INFO][test_async_blocking.rs:358] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 100, rx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:27.178381][INFO][test_async_blocking.rs:397] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_06 ... ok [INFO] [stderr] [2025-09-03 12:58:28.048042][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 4.581437278s >>> [INFO] [stderr] [2025-09-03 12:58:28.048560][INFO][test_async_blocking.rs:358] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 10, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:28.280285][INFO][test_async_blocking.rs:397] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:28.603441][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 14.321595244s >>> [INFO] [stderr] [2025-09-03 12:58:28.604090][INFO][test_async_blocking.rs:358] <<< test_pressure_multi_tx_async_multi_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:28.664419][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 4.210295025s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_10 ... ok [INFO] [stderr] [2025-09-03 12:58:28.669645][INFO][test_async_blocking.rs:120] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (AsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:28.669842][INFO][test_async_blocking.rs:153] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:28.779353][INFO][test_async_blocking.rs:397] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:29.544907][INFO][test_async_blocking.rs:120] >>> test_timeout_1_tx_async_1_rx_blocking return () in 875.098398ms >>> [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:29.545584][INFO][test_async_blocking.rs:120] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:29.545855][INFO][test_async_blocking.rs:153] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:29.611521][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 3.781389304s >>> [INFO] [stderr] [2025-09-03 12:58:29.612154][INFO][test_async_blocking.rs:120] <<< test_timeout_1_tx_async_1_rx_blocking (setup_log = (), channel = (MAsyncTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:29.613003][INFO][test_async_blocking.rs:153] run with tokio multi thread [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:30.061557][INFO][test_async_blocking.rs:358] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 2.012801471s >>> [INFO] [stderr] [2025-09-03 12:58:30.062238][INFO][test_blocking_async.rs:99] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:30.062459][INFO][test_blocking_async.rs:124] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:30.478773][INFO][test_async_blocking.rs:120] >>> test_timeout_1_tx_async_1_rx_blocking return () in 933.009086ms >>> [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:30.479884][INFO][test_blocking_async.rs:99] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_timeout_1_tx_async_1_rx_blocking::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:30.480153][INFO][test_blocking_async.rs:124] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:30.544561][INFO][test_async_blocking.rs:120] >>> test_timeout_1_tx_async_1_rx_blocking return () in 931.606707ms >>> [INFO] [stderr] [2025-09-03 12:58:30.545423][INFO][test_blocking_async.rs:99] <<< test_basic_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:30.545687][INFO][test_blocking_async.rs:124] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:31.039476][INFO][test_async_blocking.rs:358] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 3.903054809s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:31.040039][INFO][test_blocking_async.rs:14] <<< 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-03 12:58:31.040165][INFO][test_blocking_async.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 11.17µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:31.040397][INFO][test_blocking_async.rs:14] <<< 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-03 12:58:31.040493][INFO][test_blocking_async.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 8.43µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:31.040691][INFO][test_blocking_async.rs:14] <<< 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-03 12:58:31.040782][INFO][test_blocking_async.rs:14] >>> test_basic_bounded_empty_full_drop_rx return () in 9.99µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:31.040969][INFO][test_blocking_async.rs:37] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_basic_compile_bounded_empty_full ... ok [INFO] [stderr] [2025-09-03 12:58:31.041054][INFO][test_blocking_async.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 7.96µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_unbounded_empty_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:31.041214][INFO][test_blocking_async.rs:37] <<< 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_2 ... ok [INFO] [stderr] [2025-09-03 12:58:31.041296][INFO][test_blocking_async.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 7.82µs >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_unbounded_empty_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:31.041489][INFO][test_blocking_async.rs:37] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.041571][INFO][test_blocking_async.rs:37] >>> test_basic_bounded_empty_full_drop_tx return () in 8.16µs >>> [INFO] [stderr] [2025-09-03 12:58:31.041700][INFO][test_blocking_async.rs:81] <<< test_basic_compile_bounded_empty_full () enter <<< [INFO] [stderr] [2025-09-03 12:58:31.041791][INFO][test_blocking_async.rs:81] >>> test_basic_compile_bounded_empty_full return () in 18.08µs >>> [INFO] [stderr] [2025-09-03 12:58:31.041966][INFO][test_blocking_async.rs:60] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.042060][INFO][test_blocking_async.rs:60] >>> test_basic_unbounded_empty_drop_tx return () in 11.69µs >>> [INFO] [stderr] [2025-09-03 12:58:31.042233][INFO][test_blocking_async.rs:60] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.042320][INFO][test_blocking_async.rs:60] >>> test_basic_unbounded_empty_drop_tx return () in 9.14µs >>> [INFO] [stderr] [2025-09-03 12:58:31.042519][INFO][test_blocking_async.rs:60] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.042615][INFO][test_blocking_async.rs:60] >>> test_basic_unbounded_empty_drop_tx return () in 9.28µs >>> [INFO] [stderr] [2025-09-03 12:58:31.042775][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.042895][INFO][test_blocking_async.rs:218] 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-03 12:58:31.078404][INFO][test_blocking_async.rs:99] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.015989989s >>> [INFO] [stderr] [2025-09-03 12:58:31.078953][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.079188][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:31.483420][INFO][test_blocking_async.rs:99] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.003342901s >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_1_tx_blocking_1_rx_async::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:31.484924][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.485717][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:31.553085][INFO][test_blocking_async.rs:99] >>> test_basic_1_tx_blocking_1_rx_async return () in 1.00747608s >>> [INFO] [stdout] test tests::test_blocking_async::test_basic_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:31.599617][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:31.601580][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:32.722909][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 6.650502099s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:32.724170][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:32.724455][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:33.658091][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 2.058305332s >>> [INFO] [stderr] [2025-09-03 12:58:33.661203][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:33.662510][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:34.039665][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 21.290408496s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_15 ... ok [INFO] [stderr] [2025-09-03 12:58:34.040545][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:34.040720][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:34.115462][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 8.13228695s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:34.117687][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:34.118009][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:34.146432][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 1.422041975s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:34.156613][INFO][test_blocking_async.rs:189] <<< test_pressure_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:34.157558][INFO][test_blocking_async.rs:218] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.232055][INFO][test_async_blocking.rs:298] >>> test_pressure_multi_tx_async_1_rx_blocking return () in 8.203821845s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_1_rx_blocking::case_8 ... ok [INFO] [stderr] [2025-09-03 12:58:35.233324][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.234165][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.287809][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 1.169833097s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_8 ... ok [INFO] [stderr] [2025-09-03 12:58:35.288476][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.313731][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.504012][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 1.463337267s >>> [INFO] [stderr] [2025-09-03 12:58:35.504867][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 271.034853ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_7 ... ok [INFO] [stderr] [2025-09-03 12:58:35.506469][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 200) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_01 ... ok [INFO] [stderr] [2025-09-03 12:58:35.507172][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.512657][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.631721][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 1.474235584s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_9 ... ok [INFO] [stderr] [2025-09-03 12:58:35.635156][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.685560][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.703147][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.816088][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 2.153616233s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:35.820617][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.850203][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 342.548489ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_04 ... ok [INFO] [stderr] [2025-09-03 12:58:35.851277][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:35.853454][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:35.924013][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:36.020408][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 22.078417312s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:36.021519][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:36.056284][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 203.327918ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_07 ... ok [INFO] [stderr] [2025-09-03 12:58:36.057085][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:36.057617][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:36.187041][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:38.045824][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 2.757185657s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_02 ... ok [INFO] [stderr] [2025-09-03 12:58:38.049040][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.050374][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:38.163855][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 113.843447ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_10 ... ok [INFO] [stderr] [2025-09-03 12:58:38.166841][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.234728][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 2.21187206s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_08 ... ok [INFO] [stderr] [2025-09-03 12:58:38.236847][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.241715][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 2.605578569s >>> [INFO] [stderr] [2025-09-03 12:58:38.242455][INFO][test_blocking_async.rs:283] 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-03 12:58:38.244901][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.246706][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:38.318648][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:38.330086][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 84.702032ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_13 ... ok [INFO] [stderr] [2025-09-03 12:58:38.340455][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.441251][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:38.632334][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 2.810636576s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_06 ... ok [INFO] [stderr] [2025-09-03 12:58:38.633912][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:38.953172][INFO][test_async.rs:1168] >>> test_pressure_stream_multi_idle return () in 22.729124657s >>> [INFO] [stdout] test tests::test_async::test_pressure_stream_multi_idle::case_6 ... ok [INFO] [stderr] [2025-09-03 12:58:39.000562][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 6) enter <<< [INFO] [stderr] [2025-09-03 12:58:39.036960][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:39.237300][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 231.722312ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_16 ... ok [INFO] [stderr] [2025-09-03 12:58:39.240749][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100) enter <<< [INFO] [stderr] [2025-09-03 12:58:39.452280][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:39.558568][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:40.305827][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.961431383s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_14 ... ok [INFO] [stderr] [2025-09-03 12:58:40.306889][INFO][test_blocking_async.rs:235] <<< test_pressure_tx_multi_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:40.984967][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 1.744076218s >>> [INFO] [stderr] [2025-09-03 12:58:40.987004][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_17 ... ok [INFO] [stderr] [2025-09-03 12:58:40.995502][INFO][test_blocking_async.rs:283] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:40.997450][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:40.997100][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 2.828263852s >>> [INFO] [stderr] [2025-09-03 12:58:41.183431][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_11 ... ok [INFO] [stderr] [2025-09-03 12:58:41.246629][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_15 ... ok [INFO] [stderr] [2025-09-03 12:58:43.558724][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 4.924663267s >>> [INFO] [stderr] [2025-09-03 12:58:43.559408][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:43.872868][INFO][test_blocking_async.rs:350] 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-03 12:58:43.903562][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.916425024s >>> [INFO] [stderr] [2025-09-03 12:58:43.907157][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:58:43.907907][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:44.671171][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 4.363967214s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_18 ... ok [INFO] [stderr] [2025-09-03 12:58:44.673049][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stderr] [2025-09-03 12:58:44.706647][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:45.063108][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 1.15582118s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_04 ... ok [INFO] [stderr] [2025-09-03 12:58:45.063634][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:45.288816][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:45.395696][INFO][test_async_blocking.rs:358] >>> test_pressure_multi_tx_async_multi_rx_blocking return () in 16.790886891s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_multi_tx_async_multi_rx_blocking::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:45.396304][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:45.401599][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:45.691491][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 294.999639ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_07 ... ok [INFO] [stderr] [2025-09-03 12:58:45.693301][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:45.778702][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:48.626691][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 7.443086444s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_02 ... ok [INFO] [stderr] [2025-09-03 12:58:48.628752][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:49.015619][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:49.677003][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 11.438886543s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_12 ... ok [INFO] [stderr] [2025-09-03 12:58:49.677538][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 30, rx_count = 500) enter <<< [INFO] [stderr] [2025-09-03 12:58:49.691387][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_08 ... ok [INFO] [stderr] [2025-09-03 12:58:49.934342][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 4.240820669s >>> [INFO] [stderr] [2025-09-03 12:58:49.937517][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:58:49.940512][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:50.042599][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 104.093838ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_11 ... ok [INFO] [stderr] [2025-09-03 12:58:50.044453][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 20) enter <<< [INFO] [stderr] [2025-09-03 12:58:50.167290][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:50.398675][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 721.017211ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_10 ... ok [INFO] [stderr] [2025-09-03 12:58:50.399121][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:50.627425][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 5.953565743s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_05 ... ok [INFO] [stderr] [2025-09-03 12:58:50.648331][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 10, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:50.665417][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_14 ... ok [INFO] [stderr] [2025-09-03 12:58:50.845925][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 794.507446ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_12 ... ok [INFO] [stderr] [2025-09-03 12:58:50.849820][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 201.308139ms >>> [INFO] [stderr] [2025-09-03 12:58:50.870764][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 100, rx_count = 200) enter <<< [INFO] [stderr] [2025-09-03 12:58:50.874718][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 300, rx_count = 300) enter <<< [INFO] [stderr] [2025-09-03 12:58:51.256740][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:51.458484][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:53.056869][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:53.688349][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 2.817432085s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_15 ... ok [INFO] [stderr] [2025-09-03 12:58:53.740190][INFO][test_blocking_async.rs:302] <<< test_pressure_tx_multi_blocking_multi_rx_async (setup_log = (), channel = (MTx, MAsyncRx), tx_count = 30, rx_count = 500) enter <<< [INFO] [stderr] [2025-09-03 12:58:53.808050][INFO][test_blocking_async.rs:350] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:54.292518][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 552.221655ms >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_17 ... ok [INFO] [stderr] [2025-09-03 12:58:54.296720][INFO][test_blocking_async.rs:143] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (Tx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:54.351343][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 3.952064579s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_13 ... ok [INFO] [stderr] [2025-09-03 12:58:54.357774][INFO][test_blocking_async.rs:143] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, AsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:54.402394][INFO][test_blocking_async.rs:168] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:54.425464][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 3.550651233s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_16 ... ok [INFO] [stderr] [2025-09-03 12:58:54.429289][INFO][test_blocking_async.rs:143] <<< test_timeout_1_tx_blocking_1_rx_async (setup_log = (), channel = (MTx, MAsyncRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:54.458967][INFO][test_blocking_async.rs:168] run with tokio multi thread [INFO] [stderr] [2025-09-03 12:58:54.530279][INFO][test_blocking_async.rs:168] run with tokio multi thread [INFO] [stdout] test tests::test_blocking_async::test_timeout_1_tx_blocking_1_rx_async::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:54.614006][INFO][test_blocking_async.rs:143] >>> test_timeout_1_tx_blocking_1_rx_async return () in 317.065454ms >>> [INFO] [stderr] [2025-09-03 12:58:54.614863][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_2 ... ok [INFO] [stderr] [2025-09-03 12:58:54.666255][INFO][test_blocking_async.rs:143] >>> test_timeout_1_tx_blocking_1_rx_async return () in 307.493536ms >>> [INFO] [stderr] [2025-09-03 12:58:54.667035][INFO][test_blocking_context.rs:157] <<< test_basic_bounded_1_thread (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_timeout_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:54.739189][INFO][test_blocking_async.rs:143] >>> test_timeout_1_tx_blocking_1_rx_async return () in 309.197196ms >>> [INFO] [stderr] [2025-09-03 12:58:54.740716][INFO][test_blocking_context.rs:157] <<< test_basic_bounded_1_thread (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:55.616555][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.001562032s >>> [INFO] [stderr] [2025-09-03 12:58:55.621813][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-03 12:58:55.622041][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 17.47µs >>> [INFO] [stderr] [2025-09-03 12:58:55.630713][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_2 ... ok [INFO] [stderr] [2025-09-03 12:58:55.630874][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 14.7µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:55.643999][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_1 ... ok [INFO] [stderr] [2025-09-03 12:58:55.644156][INFO][test_blocking_context.rs:16] >>> test_basic_bounded_empty_full_drop_rx return () in 13.749µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_empty_full_drop_tx::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:55.644742][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_bounded_empty_full_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:55.644840][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 11.78µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:55.645143][INFO][test_blocking_context.rs:53] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:55.645239][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 10.95µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:55.645546][INFO][test_blocking_context.rs:53] <<< test_basic_bounded_empty_full_drop_tx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_4 ... ok [INFO] [stderr] [2025-09-03 12:58:55.645643][INFO][test_blocking_context.rs:53] >>> test_basic_bounded_empty_full_drop_tx return () in 10.84µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_recv_after_sender_close::case_5 ... ok [INFO] [stderr] [2025-09-03 12:58:55.645977][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_6 ... ok [INFO] [stderr] [2025-09-03 12:58:55.646072][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 11.5µs >>> [INFO] [stderr] [2025-09-03 12:58:55.646392][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:55.646486][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 9.95µs >>> [INFO] [stderr] [2025-09-03 12:58:55.646788][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:55.646879][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 9.55µs >>> [INFO] [stderr] [2025-09-03 12:58:55.647226][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:55.647323][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 13.61µs >>> [INFO] [stderr] [2025-09-03 12:58:55.647620][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:55.647714][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 10.78µs >>> [INFO] [stderr] [2025-09-03 12:58:55.648043][INFO][test_blocking_context.rs:246] <<< test_basic_recv_after_sender_close (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:55.648136][INFO][test_blocking_context.rs:246] >>> test_basic_recv_after_sender_close return () in 10.74µs >>> [INFO] [stderr] [2025-09-03 12:58:55.648525][INFO][test_blocking_context.rs:203] <<< test_basic_unbounded_1_thread (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:55.667954][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.000778603s >>> [INFO] [stderr] [2025-09-03 12:58:55.669208][INFO][test_blocking_context.rs:203] <<< test_basic_unbounded_1_thread (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_basic_bounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:55.741698][INFO][test_blocking_context.rs:157] >>> test_basic_bounded_1_thread return () in 1.000844972s >>> [INFO] [stderr] [2025-09-03 12:58:55.743026][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_unbounded_1_thread::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:56.743562][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 1.000404962s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:56.744390][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:56.744527][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 15.1µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:56.851543][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:56.851711][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 15.62µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_rx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:57.361212][INFO][test_blocking_context.rs:90] <<< test_basic_unbounded_empty_drop_rx (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:57.364755][INFO][test_blocking_context.rs:90] >>> test_basic_unbounded_empty_drop_rx return () in 16.79µs >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_empty_drop_tx::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:57.365106][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_2 ... ok [INFO] [stderr] [2025-09-03 12:58:57.365231][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 11.74µs >>> [INFO] [stderr] [2025-09-03 12:58:57.397841][INFO][test_blocking_context.rs:124] <<< test_basic_unbounded_empty_drop_tx (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:57.398054][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 19.21µs >>> [INFO] [stderr] [2025-09-03 12:58:57.448547][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_basic_unbounded_empty_drop_tx::case_3 ... ok [INFO] [stderr] [2025-09-03 12:58:57.448718][INFO][test_blocking_context.rs:124] >>> test_basic_unbounded_empty_drop_tx return () in 18.991µs >>> [INFO] [stdout] test tests::test_blocking_context::test_conversion ... ok [INFO] [stderr] [2025-09-03 12:58:57.449103][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:57.486672][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 1.838056118s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_1_thread::case_1 ... ok [INFO] [stderr] [2025-09-03 12:58:57.487294][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:57.671077][INFO][test_blocking_context.rs:203] >>> test_basic_unbounded_1_thread return () in 2.001750534s >>> [INFO] [stdout] test tests::test_blocking_context::test_basic_unbounded_1_thread::case_2 ... ok [INFO] [stderr] [2025-09-03 12:58:57.672622][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (Tx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:58:58.797031][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 13.733223476s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_06 ... ok [INFO] [stderr] [2025-09-03 12:58:58.798965][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-03 12:58:59.638567][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 838.984385ms >>> [INFO] [stderr] [2025-09-03 12:58:59.638892][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_03 ... ok [INFO] [stderr] [2025-09-03 12:58:59.828438][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 2.154442292s >>> [INFO] [stderr] [2025-09-03 12:58:59.830456][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:02.286553][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 26.779962365s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_03 ... ok [INFO] [stderr] [2025-09-03 12:59:02.319497][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_01 ... ok [INFO] [stderr] [2025-09-03 12:59:02.688392][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 40.786317185s >>> [INFO] [stderr] [2025-09-03 12:59:02.798540][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, Rx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:03.897557][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 6.410110839s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_02 ... ok [INFO] [stderr] [2025-09-03 12:59:03.900879][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 15.271964237s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_multi_rx_async::case_09 ... ok [INFO] [stderr] [2025-09-03 12:59:03.910094][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_multi_rx_async::case_03 ... ok [INFO] [stderr] [2025-09-03 12:59:03.921440][INFO][test_blocking_async.rs:302] >>> test_pressure_tx_multi_blocking_multi_rx_async return () in 20.361868189s >>> [INFO] [stderr] [2025-09-03 12:59:03.922446][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:04.274758][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:04.476223][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 1.677514131s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_08 ... ok [INFO] [stderr] [2025-09-03 12:59:04.477329][INFO][test_blocking_context.rs:282] <<< test_pressure_bounded_blocking_1_1 (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:04.631556][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 2.304351581s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_07 ... ok [INFO] [stderr] [2025-09-03 12:59:04.632291][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:59:04.825277][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 902.706913ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_11 ... ok [INFO] [stderr] [2025-09-03 12:59:04.825843][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 16, rx_count = 2) enter <<< [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_3 ... ok [INFO] [stderr] [2025-09-03 12:59:04.935736][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 33.450650849s >>> [INFO] [stderr] [2025-09-03 12:59:05.049013][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 16) enter <<< [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_05 ... ok [INFO] [stderr] [2025-09-03 12:59:05.169437][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 41.786119997s >>> [INFO] [stderr] [2025-09-03 12:59:05.170664][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 2, rx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:59:05.212892][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 580.424289ms >>> [INFO] [stderr] [2025-09-03 12:59:05.213594][INFO][test_blocking_context.rs:403] <<< 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_01 ... ok [INFO] [stderr] [2025-09-03 12:59:05.213995][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 164.810626ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_03 ... ok [INFO] [stderr] [2025-09-03 12:59:05.214426][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 10) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_06 ... ok [INFO] [stderr] [2025-09-03 12:59:05.400590][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 186.053381ms >>> [INFO] [stderr] [2025-09-03 12:59:05.402356][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 3) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_04 ... ok [INFO] [stderr] [2025-09-03 12:59:05.527594][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 356.801506ms >>> [INFO] [stderr] [2025-09-03 12:59:05.527962][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 8, rx_count = 3) enter <<< [INFO] [stderr] [2025-09-03 12:59:05.668256][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 263.699746ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_07 ... ok [INFO] [stderr] [2025-09-03 12:59:05.669099][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 3, rx_count = 8) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.058493][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 1.580943321s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_12 ... ok [INFO] [stderr] [2025-09-03 12:59:06.058805][INFO][test_blocking_context.rs:403] <<< test_pressure_bounded_blocking_multi (setup_log = (), _channel = (MTx, MRx), tx_count = 5, rx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.080514][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 410.660795ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_09 ... ok [INFO] [stderr] [2025-09-03 12:59:06.080972][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 3) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.204023][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 675.922509ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_08 ... ok [INFO] [stderr] [2025-09-03 12:59:06.205237][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 5) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.409384][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 1.195623922s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_05 ... ok [INFO] [stderr] [2025-09-03 12:59:06.562284][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 6.731625961s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_06 ... ok [INFO] [stderr] [2025-09-03 12:59:06.563462][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 16) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.571496][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 10) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.586470][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 527.549141ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_10 ... ok [INFO] [stderr] [2025-09-03 12:59:06.586838][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 4) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.814153][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 2.903866676s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_10 ... ok [INFO] [stderr] [2025-09-03 12:59:06.814574][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 7) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.857830][INFO][test_blocking_context.rs:403] >>> test_pressure_bounded_blocking_multi return () in 2.031845748s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi::case_02 ... ok [INFO] [stderr] [2025-09-03 12:59:06.861497][INFO][test_blocking_context.rs:335] <<< 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_multi_1::case_05 ... ok [INFO] [stderr] [2025-09-03 12:59:06.908610][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 320.890803ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_01 ... ok [INFO] [stderr] [2025-09-03 12:59:06.908950][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 3) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_02 ... ok [INFO] [stderr] [2025-09-03 12:59:06.940331][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 857.782362ms >>> [INFO] [stderr] [2025-09-03 12:59:06.940652][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 9) enter <<< [INFO] [stderr] [2025-09-03 12:59:06.944382][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 738.839196ms >>> [INFO] [stderr] [2025-09-03 12:59:06.944630][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, Rx), tx_count = 13) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_08 ... ok [INFO] [stderr] [2025-09-03 12:59:07.354203][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 445.131577ms >>> [INFO] [stderr] [2025-09-03 12:59:07.354517][INFO][test_blocking_context.rs:335] <<< 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_09 ... ok [INFO] [stderr] [2025-09-03 12:59:07.651425][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 707.979902ms >>> [INFO] [stderr] [2025-09-03 12:59:07.651850][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 5) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_07 ... ok [INFO] [stderr] [2025-09-03 12:59:08.680479][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.818842922s >>> [INFO] [stderr] [2025-09-03 12:59:08.706605][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 15) enter <<< [INFO] [stderr] [2025-09-03 12:59:08.753185][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.938439407s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_06 ... ok [INFO] [stderr] [2025-09-03 12:59:08.754867][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 3) enter <<< [INFO] [stderr] [2025-09-03 12:59:08.796080][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 2.224450808s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_03 ... ok [INFO] [stderr] [2025-09-03 12:59:08.796484][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 7) enter <<< [INFO] [stderr] [2025-09-03 12:59:08.869456][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.924732111s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_10 ... ok [INFO] [stderr] [2025-09-03 12:59:08.869799][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 16) enter <<< [INFO] [stderr] [2025-09-03 12:59:09.057829][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 2.493349942s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_04 ... ok [INFO] [stderr] [2025-09-03 12:59:09.058222][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 2) enter <<< [INFO] [stderr] [2025-09-03 12:59:09.084785][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 329.723772ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_14 ... ok [INFO] [stderr] [2025-09-03 12:59:09.085125][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 8) enter <<< [INFO] [stderr] [2025-09-03 12:59:09.178669][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 120.331175ms >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_17 ... ok [INFO] [stderr] [2025-09-03 12:59:09.179057][INFO][test_blocking_context.rs:335] <<< test_pressure_bounded_blocking_multi_1 (setup_log = (), _channel = (MTx, MRx), tx_count = 16) enter <<< [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_11 ... ok [INFO] [stderr] [2025-09-03 12:59:09.255188][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.900547595s >>> [INFO] [stderr] [2025-09-03 12:59:09.257443][INFO][test_blocking_context.rs:479] <<< 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_12 ... ok [INFO] [stderr] [2025-09-03 12:59:09.383862][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.731853131s >>> [INFO] [stderr] [2025-09-03 12:59:09.384825][INFO][test_blocking_context.rs:479] <<< test_pressure_bounded_timeout_blocking (setup_log = (), _channel = (MTx, MRx)) enter <<< [INFO] [stderr] [2025-09-03 12:59:09.637322][INFO][test_async_blocking.rs:242] >>> test_pressure_1_tx_async_1_rx_blocking return () in 45.311436005s >>> [INFO] [stdout] test tests::test_async_blocking::test_pressure_1_tx_async_1_rx_blocking::case_09 ... ok [INFO] [stderr] [2025-09-03 12:59:09.820098][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 949.787903ms >>> [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_15 ... ok [INFO] [stderr] [2025-09-03 12:59:09.874215][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.077603807s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_03 has been running for over 60 seconds [INFO] [stderr] [2025-09-03 12:59:10.686973][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 1.601020457s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_18 ... ok [INFO] [stderr] [2025-09-03 12:59:11.363547][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 40.320690401s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_1 ... ok [INFO] [stderr] [2025-09-03 12:59:11.382575][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 2.203397622s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_19 ... ok [INFO] [stderr] [2025-09-03 12:59:11.408048][INFO][test_blocking_context.rs:335] >>> test_pressure_bounded_blocking_multi_1 return () in 2.700665169s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_multi_1::case_13 ... ok [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-03 12:59:12.363428][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 60.73076701s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_12 ... ok [INFO] [stderr] [2025-09-03 12:59:12.887051][INFO][test_async.rs:718] >>> test_pressure_bounded_async_multi_1 return () in 62.208353873s >>> [INFO] [stdout] test tests::test_async::test_pressure_bounded_async_multi_1::case_03 ... ok [INFO] [stdout] test tests::test_blocking_async::test_pressure_1_tx_blocking_1_rx_async::case_2 ... ok [INFO] [stderr] [2025-09-03 12:59:13.352680][INFO][test_blocking_async.rs:189] >>> test_pressure_1_tx_blocking_1_rx_async return () in 42.273564476s >>> [INFO] [stderr] [2025-09-03 12:59:13.600691][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 16.151490143s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_01 ... ok [INFO] [stderr] [2025-09-03 12:59:14.146970][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 14.507963446s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_05 ... ok [INFO] [stderr] [2025-09-03 12:59:19.608841][INFO][test_blocking_context.rs:282] >>> test_pressure_bounded_blocking_1_1 return () in 15.333297004s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_blocking_1_1::case_09 ... ok [INFO] [stderr] [2025-09-03 12:59:30.845912][INFO][test_blocking_context.rs:479] >>> test_pressure_bounded_timeout_blocking return () in 21.460968117s >>> [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_timeout_blocking::case_2 ... ok [INFO] [stdout] test tests::test_blocking_context::test_pressure_bounded_timeout_blocking::case_1 ... ok [INFO] [stderr] [2025-09-03 12:59:31.112571][INFO][test_blocking_context.rs:479] >>> test_pressure_bounded_timeout_blocking return () in 21.855019138s >>> [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-03 13:00:05.774536][INFO][test_blocking_async.rs:235] >>> test_pressure_tx_multi_blocking_1_rx_async return () in 89.717292699s >>> [INFO] [stdout] test tests::test_blocking_async::test_pressure_tx_multi_blocking_1_rx_async::case_09 ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 280 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 115.89s [INFO] [stdout] [INFO] [stderr] Doc-tests crossfire [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test src/blocking_tx.rs - blocking_tx::Tx (line 33) - compile fail ... ok [INFO] [stdout] test src/blocking_rx.rs - blocking_rx::Rx (line 33) - compile fail ... ok [INFO] [stdout] test src/mpsc.rs - mpsc (line 25) - compile fail ... ok [INFO] [stdout] test src/spsc.rs - spsc (line 25) - compile fail ... ok [INFO] [stdout] test src/async_tx.rs - async_tx::AsyncTx (line 45) - compile fail ... ok [INFO] [stdout] test src/async_rx.rs - async_rx::AsyncRx (line 45) - compile fail ... 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/mpsc.rs - mpsc (line 10) ... ok [INFO] [stdout] test src/blocking_tx.rs - blocking_tx::Tx (line 20) ... ok [INFO] [stdout] test src/blocking_rx.rs - blocking_rx::Rx (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 1.47s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "7e114cc6109dca138018db755933f06e90471ba3ea0501315d2f5c73b15d9ee1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "7e114cc6109dca138018db755933f06e90471ba3ea0501315d2f5c73b15d9ee1", kill_on_drop: false }` [INFO] [stdout] 7e114cc6109dca138018db755933f06e90471ba3ea0501315d2f5c73b15d9ee1