[INFO] fetching crate rzmq 0.5.13...
[INFO] testing rzmq-0.5.13 against beta-2026-04-21 for beta-1.96-2
[INFO] extracting crate rzmq 0.5.13 into /workspace/builds/worker-4-tc2/source
[INFO] started tweaking crates.io crate rzmq 0.5.13
[INFO] removed 0 missing examples
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate rzmq 0.5.13
[INFO] tweaked toml for crates.io crate rzmq 0.5.13 written to /workspace/builds/worker-4-tc2/source/Cargo.toml
[INFO] validating manifest of crates.io crate rzmq 0.5.13 on toolchain beta-2026-04-21
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2026-04-21" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate rzmq 0.5.13 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" "+beta-2026-04-21" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-04-21" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] d614ab26b4d91abcc54194ae6ea98755c0ef839a2aebbd00b846c618231fb7cc
[INFO] running `Command { std: "docker" "start" "-a" "d614ab26b4d91abcc54194ae6ea98755c0ef839a2aebbd00b846c618231fb7cc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "d614ab26b4d91abcc54194ae6ea98755c0ef839a2aebbd00b846c618231fb7cc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "d614ab26b4d91abcc54194ae6ea98755c0ef839a2aebbd00b846c618231fb7cc", kill_on_drop: false }`
[INFO] [stdout] d614ab26b4d91abcc54194ae6ea98755c0ef839a2aebbd00b846c618231fb7cc
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-04-21" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] f19106215c1d41805f286975747fb290dca2e653fdef612d416407c4c1838b5c
[INFO] running `Command { std: "docker" "start" "-a" "f19106215c1d41805f286975747fb290dca2e653fdef612d416407c4c1838b5c", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.180
[INFO] [stderr]    Compiling futures-core v0.3.31
[INFO] [stderr]    Compiling futures-sink v0.3.31
[INFO] [stderr]    Compiling zerocopy v0.8.37
[INFO] [stderr]    Compiling memchr v2.7.6
[INFO] [stderr]    Compiling futures-task v0.3.31
[INFO] [stderr]    Compiling futures-io v0.3.31
[INFO] [stderr]    Compiling bytes v1.11.0
[INFO] [stderr]    Compiling tracing-core v0.1.36
[INFO] [stderr]    Compiling hashbrown v0.14.5
[INFO] [stderr]    Compiling bitflags v2.10.0
[INFO] [stderr]    Compiling atomic_float v1.1.0
[INFO] [stderr]    Compiling syn v2.0.114
[INFO] [stderr]    Compiling linked-hash-map v0.5.6
[INFO] [stderr]    Compiling futures-channel v0.3.31
[INFO] [stderr]    Compiling parking_lot_core v0.9.12
[INFO] [stderr]    Compiling getrandom v0.3.4
[INFO] [stderr]    Compiling socket2 v0.6.2
[INFO] [stderr]    Compiling seize v0.5.1
[INFO] [stderr]    Compiling mio v1.1.1
[INFO] [stderr]    Compiling rand_core v0.9.5
[INFO] [stderr]    Compiling parking_lot v0.12.5
[INFO] [stderr]    Compiling dashmap v5.5.3
[INFO] [stderr]    Compiling papaya v0.2.3
[INFO] [stderr]    Compiling futures-intrusive v0.5.0
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]    Compiling thiserror-impl v2.0.18
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]    Compiling async-recursion v1.1.1
[INFO] [stderr]    Compiling async-trait v0.1.89
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling futures-util v0.3.31
[INFO] [stderr]    Compiling thiserror v2.0.18
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling rand_chacha v0.9.0
[INFO] [stderr]    Compiling rand v0.9.2
[INFO] [stderr]    Compiling futures-executor v0.3.31
[INFO] [stderr]    Compiling fibre v0.5.1
[INFO] [stderr]    Compiling futures v0.3.31
[INFO] [stderr]    Compiling tokio-util v0.7.18
[INFO] [stderr]    Compiling rzmq v0.5.13 (/opt/rustwide/workdir)
[INFO] [stdout] warning: the usage of Script Group `Greek` in this crate consists solely of mixed script confusables
[INFO] [stdout]    --> src/throttle/mod.rs:129:11
[INFO] [stdout]     |
[INFO] [stdout] 129 |       let α = self.shared.config.adaptive_learning_rate;
[INFO] [stdout]     |           ^
[INFO] [stdout]     |
[INFO] [stdout]     = note: the usage includes 'α' (U+03B1)
[INFO] [stdout]     = note: please recheck to make sure their usages are indeed what you want
[INFO] [stdout]     = note: `#[warn(mixed_script_confusables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SystemEvent`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:3:33
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::runtime::{ActorType, SystemEvent}; // Adjust imports as needed
[INFO] [stdout]   |                                 ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicBool` and `Ordering`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::sync::atomic::{AtomicBool, Ordering};
[INFO] [stdout]   |                         ^^^^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `latch::CountDownLatch`
[INFO] [stdout]   --> src/runtime/mod.rs:20:16
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) use latch::CountDownLatch;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `IDataCipher`
[INFO] [stdout]  --> src/security/mechanism.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use super::{IDataCipher, ZmqError};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]  --> src/security/null.rs:3:13
[INFO] [stdout]   |
[INFO] [stdout] 3 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]   |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]   --> src/security/plain.rs:11:13
[INFO] [stdout]    |
[INFO] [stdout] 11 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]    |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::message::Metadata`
[INFO] [stdout]   --> src/security/mod.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | use crate::message::Metadata;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::os::fd::AsRawFd`
[INFO] [stdout]   --> src/sessionx/actor.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use std::os::fd::AsRawFd; // For AsRawFd bound if S needs it for cork_info init
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/sessionx/actor.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/pipe_manager.rs:9:39
[INFO] [stdout]   |
[INFO] [stdout] 9 | use crate::socket::core::{SocketCore, command_processor};
[INFO] [stdout]   |                                       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/shutdown.rs:5:27
[INFO] [stdout]   |
[INFO] [stdout] 5 | use crate::socket::core::{command_processor, pipe_manager, SocketCore};
[INFO] [stdout]   |                           ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `fair_queue::FairQueue`
[INFO] [stdout]   --> src/socket/patterns/mod.rs:11:16
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub(crate) use fair_queue::FairQueue;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `command::Command` and `mailbox::MailboxSender as SessionMailboxSender`
[INFO] [stdout]  --> src/socket/connection_iface.rs:8:22
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::runtime::{command::Command, mailbox::MailboxSender as SessionMailboxSender};
[INFO] [stdout]   |                      ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/socket/connection_iface.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::socket::core::pipe_manager::run_pipe_reader_task`
[INFO] [stdout]  --> src/transport/inproc.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use crate::socket::core::pipe_manager::run_pipe_reader_task;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SocketAddr as StdSocketAddr`
[INFO] [stdout]   --> src/transport/tcp.rs:34:16
[INFO] [stdout]    |
[INFO] [stdout] 34 | use std::net::{SocketAddr as StdSocketAddr, ToSocketAddrs};
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, and `warn`
[INFO] [stdout]   --> src/transport/tcp.rs:42:15
[INFO] [stdout]    |
[INFO] [stdout] 42 | use tracing::{debug, error, info, trace, warn};
[INFO] [stdout]    |               ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `MailboxSender`
[INFO] [stdout]   --> src/lib.rs:42:43
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub(crate) use runtime::{MailboxReceiver, MailboxSender};
[INFO] [stdout]    |                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 363 |     Ok(Endpoint::Tcp(_addr, ref uri_from_parse)) => {
[INFO] [stdout]     |     -------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 418 |     Ok(Endpoint::Ipc(ref path_buf, ref uri_from_parse)) => {
[INFO] [stdout]     |     --------------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 469 |     Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 489 |     Err(e) => bind_result = Err(e), // Error from parse_endpoint
[INFO] [stdout]     |     ------ matches some of the same values
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 554 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 529 | /     Ok(Endpoint::Tcp(_, ref parsed_uri_for_connecter))
[INFO] [stdout] 530 | |     | Ok(Endpoint::Ipc(_, ref parsed_uri_for_connecter)) => {
[INFO] [stdout]     | |________________________________________________________- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 542 |       Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |       ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 551 |       Err(e) => {
[INFO] [stdout]     |       ------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 554 |       _ => {
[INFO] [stdout]     |       ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 575 |     Ok(Endpoint::Tcp(_, _)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 606 |     Ok(Endpoint::Ipc(path_buf, _)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 626 |     Ok(Endpoint::Inproc(_)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 629 |     Err(err) => {
[INFO] [stdout]     |     -------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:284:19
[INFO] [stdout]     |
[INFO] [stdout] 284 |               let mut setup_successful = true;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:490:9
[INFO] [stdout]     |
[INFO] [stdout] 490 |     let mut connection_outcome: Result<
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:187:29
[INFO] [stdout]     |
[INFO] [stdout] 187 |   async fn run_command_loop(mut self, parent_socket_id: usize) {
[INFO] [stdout]     |                             ----^^^^
[INFO] [stdout]     |                             |
[INFO] [stdout]     |                             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connector_context_clone`
[INFO] [stdout]    --> src/transport/inproc.rs:100:7
[INFO] [stdout]     |
[INFO] [stdout] 100 |   let connector_context_clone = core_arc.context.clone();
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connector_context_clone`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/socket/dealer_socket.rs:512:11
[INFO] [stdout]     |
[INFO] [stdout] 512 |       let mut transaction_guard = self.current_send_transaction.lock().await;
[INFO] [stdout]     |           ----^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |           |
[INFO] [stdout]     |           help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connection_id_opt`
[INFO] [stdout]    --> src/socket/dealer_socket.rs:669:28
[INFO] [stdout]     |
[INFO] [stdout] 669 |     let (endpoint_uri_opt, connection_id_opt) = {
[INFO] [stdout]     |                            ^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection_id_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `interaction_model_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:282:89
[INFO] [stdout]     |
[INFO] [stdout] 282 |               let mut interaction_model_for_event: Option<ConnectionInteractionModel> = None;
[INFO] [stdout]     |                                                                                         ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 314 |               interaction_model_for_event = Some(ConnectionInteractionModel::ViaSca {
[INFO] [stdout]     |               --------------------------- `interaction_model_for_event` is overwritten here before the previous value is read
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `managing_actor_task_id_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:283:74
[INFO] [stdout]     |
[INFO] [stdout] 283 |               let mut managing_actor_task_id_for_event: Option<TaskId> = None;
[INFO] [stdout]     |                                                                          ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 318 |               managing_actor_task_id_for_event = Some(sca_task_handle.id());
[INFO] [stdout]     |               ------------------------------------------------------------- `managing_actor_task_id_for_event` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:238:54
[INFO] [stdout]     |
[INFO] [stdout] 238 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 378 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `sca_or_session_join_handle_opt`
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_sca_or_session_join_handle_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `setup_successful` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:485:19
[INFO] [stdout]     |
[INFO] [stdout] 485 |                   setup_successful = false;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:304:54
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 590 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISocketConnection` is more private than the item `SystemEvent::NewConnectionEstablished::connection_iface`
[INFO] [stdout]   --> src/runtime/system_events.rs:93:5
[INFO] [stdout]    |
[INFO] [stdout] 93 |     connection_iface: Option<Arc<dyn ISocketConnection>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `SystemEvent::NewConnectionEstablished::connection_iface` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISocketConnection` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/connection_iface.rs:33:1
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `ProcessTokenAction` is more private than the item `Mechanism::process_token`
[INFO] [stdout]   --> src/security/mechanism.rs:36:3
[INFO] [stdout]    |
[INFO] [stdout] 36 |   fn process_token(&mut self, token: &[u8]) -> Result<ProcessTokenAction, ZmqError>;
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::process_token` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `ProcessTokenAction` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/mechanism.rs:16:1
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISecureFramer` is more private than the item `Mechanism::into_framer`
[INFO] [stdout]   --> src/security/mechanism.rs:88:1
[INFO] [stdout]    |
[INFO] [stdout] 88 | fn into_framer(self: Box<Self>) -> Result<(Box<dyn ISecureFramer>, Option<Vec<u8>>), ZmqError>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::into_framer` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISecureFramer` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/framer.rs:9:1
[INFO] [stdout]    |
[INFO] [stdout]  9 | pub(crate) trait ISecureFramer: Send + Sync + 'static {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `PipeState` is more private than the item `WritePipeCoordinator::remove_pipe`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:46:3
[INFO] [stdout]    |
[INFO] [stdout] 46 |   pub async fn remove_pipe(&self, pipe_id: PipeId) -> Option<Arc<PipeState>> {
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `WritePipeCoordinator::remove_pipe` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `PipeState` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:12:1
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct PipeState {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `binder_core_id` is never read
[INFO] [stdout]   --> src/context.rs:25:14
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub(crate) struct InprocBinding {
[INFO] [stdout]    |                   ------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 25 |   pub(crate) binder_core_id: usize,
[INFO] [stdout]    |              ^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `InprocBinding` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_socket_command_sender` is never used
[INFO] [stdout]    --> src/context.rs:220:17
[INFO] [stdout]     |
[INFO] [stdout]  55 | impl ContextInner {
[INFO] [stdout]     | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 220 |   pub(crate) fn get_socket_command_sender(&self, handle: usize) -> Option<MailboxSender> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PeerAddress` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:76:12
[INFO] [stdout]    |
[INFO] [stdout] 76 | pub struct PeerAddress(pub SocketAddr);
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ZapUserId` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:80:12
[INFO] [stdout]    |
[INFO] [stdout] 80 | pub struct ZapUserId(pub String);
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `notify` is never read
[INFO] [stdout]  --> src/runtime/latch.rs:8:3
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub(crate) struct CountDownLatch {
[INFO] [stdout]   |                   -------------- field in this struct
[INFO] [stdout] 7 |   count: Arc<AtomicUsize>,
[INFO] [stdout] 8 |   notify: Arc<Notify>,
[INFO] [stdout]   |   ^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `CountDownLatch` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `count_down`, and `await_` are never used
[INFO] [stdout]   --> src/runtime/latch.rs:13:10
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl CountDownLatch {
[INFO] [stdout]    | ------------------- associated items in this implementation
[INFO] [stdout] 12 |   /// Creates a new latch initialized with the given count.
[INFO] [stdout] 13 |   pub fn new(count: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 27 |   pub async fn count_down(&self) {
[INFO] [stdout]    |                ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub async fn await_(&self) {
[INFO] [stdout]    |                ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `IDataCipher` is never used
[INFO] [stdout]  --> src/security/cipher.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub trait IDataCipher: Send + Sync + 'static {
[INFO] [stdout]   |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PassThroughDataCipher` is never constructed
[INFO] [stdout]   --> src/security/cipher.rs:18:19
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub(crate) struct PassThroughDataCipher;
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LengthPrefixedFramer` is never constructed
[INFO] [stdout]   --> src/security/framer.rs:44:19
[INFO] [stdout]    |
[INFO] [stdout] 44 | pub(crate) struct LengthPrefixedFramer {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/security/framer.rs:51:17
[INFO] [stdout]    |
[INFO] [stdout] 50 | impl LengthPrefixedFramer {
[INFO] [stdout]    | ------------------------- associated function in this implementation
[INFO] [stdout] 51 |   pub(crate) fn new(cipher: Box<dyn IDataCipher>) -> Self {
[INFO] [stdout]    |                 ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `ContinueWaiting` is never constructed
[INFO] [stdout]   --> src/security/mechanism.rs:18:3
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    |                 ------------------ variant in this enum
[INFO] [stdout] 17 |   /// No immediate action is required. The handler should wait for the next event.
[INFO] [stdout] 18 |   ContinueWaiting,
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `ProcessTokenAction` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `Initializing` is never constructed
[INFO] [stdout]   --> src/security/plain.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | enum PlainState {
[INFO] [stdout]    |      ---------- variant in this enum
[INFO] [stdout] 16 |   Initializing, // Start state (not strictly used as we set initial state in new())
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `PlainState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `fd` and `is_expecting_first_frame` are never used
[INFO] [stdout]   --> src/sessionx/cork.rs:37:17
[INFO] [stdout]    |
[INFO] [stdout] 17 | impl TcpCorkInfoX {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub(crate) fn fd(&self) -> RawFd {
[INFO] [stdout]    |                 ^^
[INFO] [stdout] ...
[INFO] [stdout] 47 |   pub(crate) fn is_expecting_first_frame(&self) -> bool {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SourcePipeReadId` is never constructed
[INFO] [stdout]    --> src/socket/mod.rs:228:8
[INFO] [stdout]     |
[INFO] [stdout] 228 | struct SourcePipeReadId(usize);
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_pipe_reader_task` is never used
[INFO] [stdout]   --> src/socket/core/pipe_manager.rs:23:21
[INFO] [stdout]    |
[INFO] [stdout] 23 | pub(crate) async fn run_pipe_reader_task(
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `cleanup_session_state_by_uri` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:271:21
[INFO] [stdout]     |
[INFO] [stdout] 271 | pub(crate) async fn cleanup_session_state_by_uri(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `send_msg_with_timeout` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:640:21
[INFO] [stdout]     |
[INFO] [stdout] 640 | pub(crate) async fn send_msg_with_timeout(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `current_phase` is never used
[INFO] [stdout]   --> src/socket/core/shutdown.rs:14:17
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl ShutdownCoordinator {
[INFO] [stdout]    | ------------------------ method in this implementation
[INFO] [stdout] 14 |   pub(crate) fn current_phase(&self) -> ShutdownPhase {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_pipe_sender` is never used
[INFO] [stdout]    --> src/socket/core/state.rs:161:17
[INFO] [stdout]     |
[INFO] [stdout] 141 | impl CoreState {
[INFO] [stdout]     | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 161 |   pub(crate) fn get_pipe_sender(&self, pipe_write_id: usize) -> Option<AsyncSender<Vec<Msg>>> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `use_send_zerocopy` and `use_recv_multishot` are never read
[INFO] [stdout]    --> src/socket/options.rs:215:7
[INFO] [stdout]     |
[INFO] [stdout] 203 | pub(crate) struct ZmtpEngineConfig {
[INFO] [stdout]     |                   ---------------- fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 215 |   pub use_send_zerocopy: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 216 |   pub use_recv_multishot: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ZmtpEngineConfig` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_duration_ms_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:301:15
[INFO] [stdout]     |
[INFO] [stdout] 301 | pub(crate) fn parse_duration_ms_option(value: &[u8]) -> Result<Option<Duration>, ZmqError> {
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_key_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:444:15
[INFO] [stdout]     |
[INFO] [stdout] 444 | pub(crate) fn parse_key_option<const N: usize>(
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `hwm` is never read
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub(crate) struct FairQueue<T: Send + 'static> {
[INFO] [stdout]    |                   --------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 16 |   hwm: usize,
[INFO] [stdout]    |   ^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FairQueue` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `pipe_attached`, `pipe_detached`, `capacity`, `len`, and `is_empty` are never used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:31:10
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl<T: Send + 'static> FairQueue<T> {
[INFO] [stdout]    | ------------------------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 31 |   pub fn pipe_attached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn pipe_detached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 82 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |   pub fn len(&self) -> usize {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 92 |   pub fn is_empty(&self) -> bool {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `decoders` is never read
[INFO] [stdout]   --> src/socket/patterns/framing.rs:21:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub(crate) struct FramingLatch {
[INFO] [stdout]    |                   ------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 21 |   decoders: [FramingOp; 2],
[INFO] [stdout]    |   ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FramingLatch` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `decode` is never used
[INFO] [stdout]   --> src/socket/patterns/framing.rs:45:10
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl FramingLatch {
[INFO] [stdout]    | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 45 |   pub fn decode(&self, frames: &mut Vec<Msg>) {
[INFO] [stdout]    |          ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_identity_by_read_pipe` is never used
[INFO] [stdout]   --> src/socket/patterns/router.rs:97:16
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl RouterMap {
[INFO] [stdout]    | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 97 |   pub async fn get_identity_by_read_pipe(&self, pipe_read_id: usize) -> Option<Blob> {
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get_connection_id` and `as_any` are never used
[INFO] [stdout]   --> src/socket/connection_iface.rs:45:6
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    |                  ----------------- methods in this trait
[INFO] [stdout] ...
[INFO] [stdout] 45 |   fn get_connection_id(&self) -> usize;
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 46 |   fn as_any(&self) -> &dyn Any;
[INFO] [stdout]    |      ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/ipc.rs:37:3
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub(crate) struct IpcListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 37 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/tcp.rs:57:3
[INFO] [stdout]    |
[INFO] [stdout] 50 | pub(crate) struct TcpListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 57 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_current_balance` is never used
[INFO] [stdout]    --> src/throttle/mod.rs:174:10
[INFO] [stdout]     |
[INFO] [stdout] 173 | impl ThrottleGuard {
[INFO] [stdout]     | ------------------ method in this implementation
[INFO] [stdout] 174 |   pub fn get_current_balance(&self) -> i32 {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `linear_strategy` is never used
[INFO] [stdout]   --> src/throttle/strategies.rs:35:8
[INFO] [stdout]    |
[INFO] [stdout] 35 | pub fn linear_strategy(state: &ThrottleStateView) -> f64 {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SegmentTiming` is never constructed
[INFO] [stdout]   --> src/profiler.rs:12:19
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct SegmentTiming {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LoopProfiler` is never constructed
[INFO] [stdout]   --> src/profiler.rs:19:19
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub(crate) struct LoopProfiler {
[INFO] [stdout]    |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `INITIAL_SEGMENT_LABEL`, `new`, `loop_start`, `mark_segment_end_and_start_new`, and `log_and_reset_for_next_loop` are never used
[INFO] [stdout]   --> src/profiler.rs:31:9
[INFO] [stdout]    |
[INFO] [stdout] 30 | impl LoopProfiler {
[INFO] [stdout]    | ----------------- associated items in this implementation
[INFO] [stdout] 31 |   const INITIAL_SEGMENT_LABEL: &'static str = "loop_setup";
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 32 |
[INFO] [stdout] 33 |   pub fn new(threshold: Duration, log_interval: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 46 |   pub fn loop_start(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 53 |   pub fn mark_segment_end_and_start_new(&mut self, next_segment_label: &'static str) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 64 |   pub fn log_and_reset_for_next_loop(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:97:5
[INFO] [stdout]    |
[INFO] [stdout] 97 |     self.sender.close();
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 97 |     let _ = self.sender.close();
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 37.46s
[INFO] running `Command { std: "docker" "inspect" "f19106215c1d41805f286975747fb290dca2e653fdef612d416407c4c1838b5c", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "f19106215c1d41805f286975747fb290dca2e653fdef612d416407c4c1838b5c", kill_on_drop: false }`
[INFO] [stdout] f19106215c1d41805f286975747fb290dca2e653fdef612d416407c4c1838b5c
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-04-21" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] d556b693d1f308c4259d4eff61a3e5d9ac788ad1f36815a70c3f0afd65acace4
[INFO] running `Command { std: "docker" "start" "-a" "d556b693d1f308c4259d4eff61a3e5d9ac788ad1f36815a70c3f0afd65acace4", kill_on_drop: false }`
[INFO] [stderr]    Compiling zerocopy v0.8.37
[INFO] [stderr]    Compiling zmij v1.0.19
[INFO] [stderr]    Compiling regex-syntax v0.8.8
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling alloca v0.4.0
[INFO] [stderr]    Compiling tracing-core v0.1.36
[INFO] [stderr]    Compiling plotters-backend v0.3.7
[INFO] [stderr]    Compiling zerocopy-derive v0.8.37
[INFO] [stderr]    Compiling serde_derive v1.0.228
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling clap_builder v4.5.56
[INFO] [stderr]    Compiling itertools v0.13.0
[INFO] [stderr]    Compiling cast v0.3.0
[INFO] [stderr]    Compiling rayon v1.11.0
[INFO] [stderr]    Compiling page_size v0.6.0
[INFO] [stderr]    Compiling sdd v3.0.10
[INFO] [stderr]    Compiling oorandom v11.1.5
[INFO] [stderr]    Compiling anes v0.1.6
[INFO] [stderr]    Compiling plotters-svg v0.3.7
[INFO] [stderr]    Compiling scc v2.4.0
[INFO] [stderr]    Compiling serde_json v1.0.149
[INFO] [stderr]    Compiling sharded-slab v0.1.7
[INFO] [stderr]    Compiling serial_test_derive v3.3.1
[INFO] [stderr]    Compiling itertools v0.12.1
[INFO] [stderr]    Compiling thread_local v1.1.9
[INFO] [stderr]    Compiling nu-ansi-term v0.50.3
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling tracing-log v0.2.0
[INFO] [stderr]    Compiling plotters v0.3.7
[INFO] [stderr]    Compiling regex-automata v0.4.13
[INFO] [stderr]    Compiling clap v4.5.56
[INFO] [stderr]    Compiling criterion-plot v0.8.1
[INFO] [stderr]    Compiling serial_test v3.3.1
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]    Compiling tinytemplate v1.2.1
[INFO] [stderr]    Compiling regex v1.12.2
[INFO] [stderr]    Compiling matchers v0.2.0
[INFO] [stderr]    Compiling tracing-subscriber v0.3.22
[INFO] [stderr]    Compiling tokio-util v0.7.18
[INFO] [stderr]    Compiling tokio-stream v0.1.18
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling half v2.7.1
[INFO] [stderr]    Compiling tokio-test v0.4.5
[INFO] [stderr]    Compiling ciborium-ll v0.2.2
[INFO] [stderr]    Compiling rand_chacha v0.9.0
[INFO] [stderr]    Compiling ciborium v0.2.2
[INFO] [stderr]    Compiling rand v0.9.2
[INFO] [stderr]    Compiling rzmq v0.5.13 (/opt/rustwide/workdir)
[INFO] [stderr]    Compiling criterion v0.8.1
[INFO] [stdout] warning: the usage of Script Group `Greek` in this crate consists solely of mixed script confusables
[INFO] [stdout]    --> src/throttle/mod.rs:129:11
[INFO] [stdout]     |
[INFO] [stdout] 129 |       let α = self.shared.config.adaptive_learning_rate;
[INFO] [stdout]     |           ^
[INFO] [stdout]     |
[INFO] [stdout]     = note: the usage includes 'α' (U+03B1)
[INFO] [stdout]     = note: please recheck to make sure their usages are indeed what you want
[INFO] [stdout]     = note: `#[warn(mixed_script_confusables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SystemEvent`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:3:33
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::runtime::{ActorType, SystemEvent}; // Adjust imports as needed
[INFO] [stdout]   |                                 ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicBool` and `Ordering`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::sync::atomic::{AtomicBool, Ordering};
[INFO] [stdout]   |                         ^^^^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `latch::CountDownLatch`
[INFO] [stdout]   --> src/runtime/mod.rs:20:16
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) use latch::CountDownLatch;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `IDataCipher`
[INFO] [stdout]  --> src/security/mechanism.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use super::{IDataCipher, ZmqError};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]  --> src/security/null.rs:3:13
[INFO] [stdout]   |
[INFO] [stdout] 3 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]   |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]   --> src/security/plain.rs:11:13
[INFO] [stdout]    |
[INFO] [stdout] 11 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]    |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::message::Metadata`
[INFO] [stdout]   --> src/security/mod.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | use crate::message::Metadata;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::os::fd::AsRawFd`
[INFO] [stdout]   --> src/sessionx/actor.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use std::os::fd::AsRawFd; // For AsRawFd bound if S needs it for cork_info init
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/sessionx/actor.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/pipe_manager.rs:9:39
[INFO] [stdout]   |
[INFO] [stdout] 9 | use crate::socket::core::{SocketCore, command_processor};
[INFO] [stdout]   |                                       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/shutdown.rs:5:27
[INFO] [stdout]   |
[INFO] [stdout] 5 | use crate::socket::core::{command_processor, pipe_manager, SocketCore};
[INFO] [stdout]   |                           ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `fair_queue::FairQueue`
[INFO] [stdout]   --> src/socket/patterns/mod.rs:11:16
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub(crate) use fair_queue::FairQueue;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `command::Command` and `mailbox::MailboxSender as SessionMailboxSender`
[INFO] [stdout]  --> src/socket/connection_iface.rs:8:22
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::runtime::{command::Command, mailbox::MailboxSender as SessionMailboxSender};
[INFO] [stdout]   |                      ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/socket/connection_iface.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::socket::core::pipe_manager::run_pipe_reader_task`
[INFO] [stdout]  --> src/transport/inproc.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use crate::socket::core::pipe_manager::run_pipe_reader_task;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SocketAddr as StdSocketAddr`
[INFO] [stdout]   --> src/transport/tcp.rs:34:16
[INFO] [stdout]    |
[INFO] [stdout] 34 | use std::net::{SocketAddr as StdSocketAddr, ToSocketAddrs};
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, and `warn`
[INFO] [stdout]   --> src/transport/tcp.rs:42:15
[INFO] [stdout]    |
[INFO] [stdout] 42 | use tracing::{debug, error, info, trace, warn};
[INFO] [stdout]    |               ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `MailboxSender`
[INFO] [stdout]   --> src/lib.rs:42:43
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub(crate) use runtime::{MailboxReceiver, MailboxSender};
[INFO] [stdout]    |                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 363 |     Ok(Endpoint::Tcp(_addr, ref uri_from_parse)) => {
[INFO] [stdout]     |     -------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 418 |     Ok(Endpoint::Ipc(ref path_buf, ref uri_from_parse)) => {
[INFO] [stdout]     |     --------------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 469 |     Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 489 |     Err(e) => bind_result = Err(e), // Error from parse_endpoint
[INFO] [stdout]     |     ------ matches some of the same values
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 554 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 529 | /     Ok(Endpoint::Tcp(_, ref parsed_uri_for_connecter))
[INFO] [stdout] 530 | |     | Ok(Endpoint::Ipc(_, ref parsed_uri_for_connecter)) => {
[INFO] [stdout]     | |________________________________________________________- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 542 |       Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |       ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 551 |       Err(e) => {
[INFO] [stdout]     |       ------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 554 |       _ => {
[INFO] [stdout]     |       ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 575 |     Ok(Endpoint::Tcp(_, _)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 606 |     Ok(Endpoint::Ipc(path_buf, _)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 626 |     Ok(Endpoint::Inproc(_)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 629 |     Err(err) => {
[INFO] [stdout]     |     -------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling bench_matrix v0.2.1
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:284:19
[INFO] [stdout]     |
[INFO] [stdout] 284 |               let mut setup_successful = true;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:490:9
[INFO] [stdout]     |
[INFO] [stdout] 490 |     let mut connection_outcome: Result<
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:187:29
[INFO] [stdout]     |
[INFO] [stdout] 187 |   async fn run_command_loop(mut self, parent_socket_id: usize) {
[INFO] [stdout]     |                             ----^^^^
[INFO] [stdout]     |                             |
[INFO] [stdout]     |                             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: the usage of Script Group `Greek` in this crate consists solely of mixed script confusables
[INFO] [stdout]    --> src/throttle/mod.rs:129:11
[INFO] [stdout]     |
[INFO] [stdout] 129 |       let α = self.shared.config.adaptive_learning_rate;
[INFO] [stdout]     |           ^
[INFO] [stdout]     |
[INFO] [stdout]     = note: the usage includes 'α' (U+03B1)
[INFO] [stdout]     = note: please recheck to make sure their usages are indeed what you want
[INFO] [stdout]     = note: `#[warn(mixed_script_confusables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SystemEvent`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:3:33
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::runtime::{ActorType, SystemEvent}; // Adjust imports as needed
[INFO] [stdout]   |                                 ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicBool` and `Ordering`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:5:25
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::sync::atomic::{AtomicBool, Ordering};
[INFO] [stdout]   |                         ^^^^^^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::sync::Arc`
[INFO] [stdout]  --> src/runtime/actor_drop_guard.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::sync::Arc;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `latch::CountDownLatch`
[INFO] [stdout]   --> src/runtime/mod.rs:20:16
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) use latch::CountDownLatch;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `IDataCipher`
[INFO] [stdout]  --> src/security/mechanism.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use super::{IDataCipher, ZmqError};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]  --> src/security/null.rs:3:13
[INFO] [stdout]   |
[INFO] [stdout] 3 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]   |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stdout]   --> src/security/plain.rs:11:13
[INFO] [stdout]    |
[INFO] [stdout] 11 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stdout]    |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::message::Metadata`
[INFO] [stdout]   --> src/security/mod.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | use crate::message::Metadata;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::os::fd::AsRawFd`
[INFO] [stdout]   --> src/sessionx/actor.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use std::os::fd::AsRawFd; // For AsRawFd bound if S needs it for cork_info init
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/sessionx/actor.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 18 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/pipe_manager.rs:9:39
[INFO] [stdout]   |
[INFO] [stdout] 9 | use crate::socket::core::{SocketCore, command_processor};
[INFO] [stdout]   |                                       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `command_processor`
[INFO] [stdout]  --> src/socket/core/shutdown.rs:5:27
[INFO] [stdout]   |
[INFO] [stdout] 5 | use crate::socket::core::{command_processor, pipe_manager, SocketCore};
[INFO] [stdout]   |                           ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `fair_queue::FairQueue`
[INFO] [stdout]   --> src/socket/patterns/mod.rs:11:16
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub(crate) use fair_queue::FairQueue;
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `command::Command` and `mailbox::MailboxSender as SessionMailboxSender`
[INFO] [stdout]  --> src/socket/connection_iface.rs:8:22
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::runtime::{command::Command, mailbox::MailboxSender as SessionMailboxSender};
[INFO] [stdout]   |                      ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::time::Duration`
[INFO] [stdout]   --> src/socket/connection_iface.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::time::Duration;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::socket::core::pipe_manager::run_pipe_reader_task`
[INFO] [stdout]  --> src/transport/inproc.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use crate::socket::core::pipe_manager::run_pipe_reader_task;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SocketAddr as StdSocketAddr`
[INFO] [stdout]   --> src/transport/tcp.rs:34:16
[INFO] [stdout]    |
[INFO] [stdout] 34 | use std::net::{SocketAddr as StdSocketAddr, ToSocketAddrs};
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, and `warn`
[INFO] [stdout]   --> src/transport/tcp.rs:42:15
[INFO] [stdout]    |
[INFO] [stdout] 42 | use tracing::{debug, error, info, trace, warn};
[INFO] [stdout]    |               ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `MailboxSender`
[INFO] [stdout]   --> src/lib.rs:42:43
[INFO] [stdout]    |
[INFO] [stdout] 42 | pub(crate) use runtime::{MailboxReceiver, MailboxSender};
[INFO] [stdout]    |                                           ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stdout]     |
[INFO] [stdout] 363 |     Ok(Endpoint::Tcp(_addr, ref uri_from_parse)) => {
[INFO] [stdout]     |     -------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 418 |     Ok(Endpoint::Ipc(ref path_buf, ref uri_from_parse)) => {
[INFO] [stdout]     |     --------------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 469 |     Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 489 |     Err(e) => bind_result = Err(e), // Error from parse_endpoint
[INFO] [stdout]     |     ------ matches some of the same values
[INFO] [stdout] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 554 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stdout]     |
[INFO] [stdout] 529 | /     Ok(Endpoint::Tcp(_, ref parsed_uri_for_connecter))
[INFO] [stdout] 530 | |     | Ok(Endpoint::Ipc(_, ref parsed_uri_for_connecter)) => {
[INFO] [stdout]     | |________________________________________________________- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 542 |       Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stdout]     |       ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 551 |       Err(e) => {
[INFO] [stdout]     |       ------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 554 |       _ => {
[INFO] [stdout]     |       ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stdout]     |
[INFO] [stdout] 575 |     Ok(Endpoint::Tcp(_, _)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 606 |     Ok(Endpoint::Ipc(path_buf, _)) => {
[INFO] [stdout]     |     ------------------------------ matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 626 |     Ok(Endpoint::Inproc(_)) => {
[INFO] [stdout]     |     ----------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 629 |     Err(err) => {
[INFO] [stdout]     |     -------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 641 |     _ => {
[INFO] [stdout]     |     ^ collectively making this unreachable
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connector_context_clone`
[INFO] [stdout]    --> src/transport/inproc.rs:100:7
[INFO] [stdout]     |
[INFO] [stdout] 100 |   let connector_context_clone = core_arc.context.clone();
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connector_context_clone`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/socket/dealer_socket.rs:512:11
[INFO] [stdout]     |
[INFO] [stdout] 512 |       let mut transaction_guard = self.current_send_transaction.lock().await;
[INFO] [stdout]     |           ----^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |           |
[INFO] [stdout]     |           help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connection_id_opt`
[INFO] [stdout]    --> src/socket/dealer_socket.rs:669:28
[INFO] [stdout]     |
[INFO] [stdout] 669 |     let (endpoint_uri_opt, connection_id_opt) = {
[INFO] [stdout]     |                            ^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection_id_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:284:19
[INFO] [stdout]     |
[INFO] [stdout] 284 |               let mut setup_successful = true;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/ipc.rs:490:9
[INFO] [stdout]     |
[INFO] [stdout] 490 |     let mut connection_outcome: Result<
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:187:29
[INFO] [stdout]     |
[INFO] [stdout] 187 |   async fn run_command_loop(mut self, parent_socket_id: usize) {
[INFO] [stdout]     |                             ----^^^^
[INFO] [stdout]     |                             |
[INFO] [stdout]     |                             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `interaction_model_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:282:89
[INFO] [stdout]     |
[INFO] [stdout] 282 |               let mut interaction_model_for_event: Option<ConnectionInteractionModel> = None;
[INFO] [stdout]     |                                                                                         ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 314 |               interaction_model_for_event = Some(ConnectionInteractionModel::ViaSca {
[INFO] [stdout]     |               --------------------------- `interaction_model_for_event` is overwritten here before the previous value is read
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `managing_actor_task_id_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:283:74
[INFO] [stdout]     |
[INFO] [stdout] 283 |               let mut managing_actor_task_id_for_event: Option<TaskId> = None;
[INFO] [stdout]     |                                                                          ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 318 |               managing_actor_task_id_for_event = Some(sca_task_handle.id());
[INFO] [stdout]     |               ------------------------------------------------------------- `managing_actor_task_id_for_event` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:238:54
[INFO] [stdout]     |
[INFO] [stdout] 238 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 378 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `sca_or_session_join_handle_opt`
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_sca_or_session_join_handle_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `setup_successful` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:485:19
[INFO] [stdout]     |
[INFO] [stdout] 485 |                   setup_successful = false;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:304:54
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 590 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISocketConnection` is more private than the item `SystemEvent::NewConnectionEstablished::connection_iface`
[INFO] [stdout]   --> src/runtime/system_events.rs:93:5
[INFO] [stdout]    |
[INFO] [stdout] 93 |     connection_iface: Option<Arc<dyn ISocketConnection>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `SystemEvent::NewConnectionEstablished::connection_iface` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISocketConnection` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/connection_iface.rs:33:1
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `ProcessTokenAction` is more private than the item `Mechanism::process_token`
[INFO] [stdout]   --> src/security/mechanism.rs:36:3
[INFO] [stdout]    |
[INFO] [stdout] 36 |   fn process_token(&mut self, token: &[u8]) -> Result<ProcessTokenAction, ZmqError>;
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::process_token` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `ProcessTokenAction` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/mechanism.rs:16:1
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISecureFramer` is more private than the item `Mechanism::into_framer`
[INFO] [stdout]   --> src/security/mechanism.rs:88:1
[INFO] [stdout]    |
[INFO] [stdout] 88 | fn into_framer(self: Box<Self>) -> Result<(Box<dyn ISecureFramer>, Option<Vec<u8>>), ZmqError>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::into_framer` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISecureFramer` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/framer.rs:9:1
[INFO] [stdout]    |
[INFO] [stdout]  9 | pub(crate) trait ISecureFramer: Send + Sync + 'static {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `PipeState` is more private than the item `WritePipeCoordinator::remove_pipe`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:46:3
[INFO] [stdout]    |
[INFO] [stdout] 46 |   pub async fn remove_pipe(&self, pipe_id: PipeId) -> Option<Arc<PipeState>> {
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `WritePipeCoordinator::remove_pipe` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `PipeState` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:12:1
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct PipeState {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `binder_core_id` is never read
[INFO] [stdout]   --> src/context.rs:25:14
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub(crate) struct InprocBinding {
[INFO] [stdout]    |                   ------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 25 |   pub(crate) binder_core_id: usize,
[INFO] [stdout]    |              ^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `InprocBinding` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_socket_command_sender` is never used
[INFO] [stdout]    --> src/context.rs:220:17
[INFO] [stdout]     |
[INFO] [stdout]  55 | impl ContextInner {
[INFO] [stdout]     | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 220 |   pub(crate) fn get_socket_command_sender(&self, handle: usize) -> Option<MailboxSender> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PeerAddress` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:76:12
[INFO] [stdout]    |
[INFO] [stdout] 76 | pub struct PeerAddress(pub SocketAddr);
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ZapUserId` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:80:12
[INFO] [stdout]    |
[INFO] [stdout] 80 | pub struct ZapUserId(pub String);
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `notify` is never read
[INFO] [stdout]  --> src/runtime/latch.rs:8:3
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub(crate) struct CountDownLatch {
[INFO] [stdout]   |                   -------------- field in this struct
[INFO] [stdout] 7 |   count: Arc<AtomicUsize>,
[INFO] [stdout] 8 |   notify: Arc<Notify>,
[INFO] [stdout]   |   ^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `CountDownLatch` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `count_down`, and `await_` are never used
[INFO] [stdout]   --> src/runtime/latch.rs:13:10
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl CountDownLatch {
[INFO] [stdout]    | ------------------- associated items in this implementation
[INFO] [stdout] 12 |   /// Creates a new latch initialized with the given count.
[INFO] [stdout] 13 |   pub fn new(count: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 27 |   pub async fn count_down(&self) {
[INFO] [stdout]    |                ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub async fn await_(&self) {
[INFO] [stdout]    |                ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `IDataCipher` is never used
[INFO] [stdout]  --> src/security/cipher.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub trait IDataCipher: Send + Sync + 'static {
[INFO] [stdout]   |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PassThroughDataCipher` is never constructed
[INFO] [stdout]   --> src/security/cipher.rs:18:19
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub(crate) struct PassThroughDataCipher;
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LengthPrefixedFramer` is never constructed
[INFO] [stdout]   --> src/security/framer.rs:44:19
[INFO] [stdout]    |
[INFO] [stdout] 44 | pub(crate) struct LengthPrefixedFramer {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/security/framer.rs:51:17
[INFO] [stdout]    |
[INFO] [stdout] 50 | impl LengthPrefixedFramer {
[INFO] [stdout]    | ------------------------- associated function in this implementation
[INFO] [stdout] 51 |   pub(crate) fn new(cipher: Box<dyn IDataCipher>) -> Self {
[INFO] [stdout]    |                 ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `ContinueWaiting` is never constructed
[INFO] [stdout]   --> src/security/mechanism.rs:18:3
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    |                 ------------------ variant in this enum
[INFO] [stdout] 17 |   /// No immediate action is required. The handler should wait for the next event.
[INFO] [stdout] 18 |   ContinueWaiting,
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `ProcessTokenAction` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `Initializing` is never constructed
[INFO] [stdout]   --> src/security/plain.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | enum PlainState {
[INFO] [stdout]    |      ---------- variant in this enum
[INFO] [stdout] 16 |   Initializing, // Start state (not strictly used as we set initial state in new())
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `PlainState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `fd` and `is_expecting_first_frame` are never used
[INFO] [stdout]   --> src/sessionx/cork.rs:37:17
[INFO] [stdout]    |
[INFO] [stdout] 17 | impl TcpCorkInfoX {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub(crate) fn fd(&self) -> RawFd {
[INFO] [stdout]    |                 ^^
[INFO] [stdout] ...
[INFO] [stdout] 47 |   pub(crate) fn is_expecting_first_frame(&self) -> bool {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SourcePipeReadId` is never constructed
[INFO] [stdout]    --> src/socket/mod.rs:228:8
[INFO] [stdout]     |
[INFO] [stdout] 228 | struct SourcePipeReadId(usize);
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_pipe_reader_task` is never used
[INFO] [stdout]   --> src/socket/core/pipe_manager.rs:23:21
[INFO] [stdout]    |
[INFO] [stdout] 23 | pub(crate) async fn run_pipe_reader_task(
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `cleanup_session_state_by_uri` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:271:21
[INFO] [stdout]     |
[INFO] [stdout] 271 | pub(crate) async fn cleanup_session_state_by_uri(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `send_msg_with_timeout` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:640:21
[INFO] [stdout]     |
[INFO] [stdout] 640 | pub(crate) async fn send_msg_with_timeout(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `current_phase` is never used
[INFO] [stdout]   --> src/socket/core/shutdown.rs:14:17
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl ShutdownCoordinator {
[INFO] [stdout]    | ------------------------ method in this implementation
[INFO] [stdout] 14 |   pub(crate) fn current_phase(&self) -> ShutdownPhase {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_pipe_sender` is never used
[INFO] [stdout]    --> src/socket/core/state.rs:161:17
[INFO] [stdout]     |
[INFO] [stdout] 141 | impl CoreState {
[INFO] [stdout]     | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 161 |   pub(crate) fn get_pipe_sender(&self, pipe_write_id: usize) -> Option<AsyncSender<Vec<Msg>>> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `use_send_zerocopy` and `use_recv_multishot` are never read
[INFO] [stdout]    --> src/socket/options.rs:215:7
[INFO] [stdout]     |
[INFO] [stdout] 203 | pub(crate) struct ZmtpEngineConfig {
[INFO] [stdout]     |                   ---------------- fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 215 |   pub use_send_zerocopy: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 216 |   pub use_recv_multishot: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ZmtpEngineConfig` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_duration_ms_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:301:15
[INFO] [stdout]     |
[INFO] [stdout] 301 | pub(crate) fn parse_duration_ms_option(value: &[u8]) -> Result<Option<Duration>, ZmqError> {
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_key_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:444:15
[INFO] [stdout]     |
[INFO] [stdout] 444 | pub(crate) fn parse_key_option<const N: usize>(
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `hwm` is never read
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub(crate) struct FairQueue<T: Send + 'static> {
[INFO] [stdout]    |                   --------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 16 |   hwm: usize,
[INFO] [stdout]    |   ^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FairQueue` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `pipe_attached`, `pipe_detached`, `capacity`, `len`, and `is_empty` are never used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:31:10
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl<T: Send + 'static> FairQueue<T> {
[INFO] [stdout]    | ------------------------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 31 |   pub fn pipe_attached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn pipe_detached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 82 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |   pub fn len(&self) -> usize {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 92 |   pub fn is_empty(&self) -> bool {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `decoders` is never read
[INFO] [stdout]   --> src/socket/patterns/framing.rs:21:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub(crate) struct FramingLatch {
[INFO] [stdout]    |                   ------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 21 |   decoders: [FramingOp; 2],
[INFO] [stdout]    |   ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FramingLatch` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `decode` is never used
[INFO] [stdout]   --> src/socket/patterns/framing.rs:45:10
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl FramingLatch {
[INFO] [stdout]    | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 45 |   pub fn decode(&self, frames: &mut Vec<Msg>) {
[INFO] [stdout]    |          ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_identity_by_read_pipe` is never used
[INFO] [stdout]   --> src/socket/patterns/router.rs:97:16
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl RouterMap {
[INFO] [stdout]    | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 97 |   pub async fn get_identity_by_read_pipe(&self, pipe_read_id: usize) -> Option<Blob> {
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get_connection_id` and `as_any` are never used
[INFO] [stdout]   --> src/socket/connection_iface.rs:45:6
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    |                  ----------------- methods in this trait
[INFO] [stdout] ...
[INFO] [stdout] 45 |   fn get_connection_id(&self) -> usize;
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 46 |   fn as_any(&self) -> &dyn Any;
[INFO] [stdout]    |      ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/ipc.rs:37:3
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub(crate) struct IpcListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 37 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/tcp.rs:57:3
[INFO] [stdout]    |
[INFO] [stdout] 50 | pub(crate) struct TcpListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 57 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_current_balance` is never used
[INFO] [stdout]    --> src/throttle/mod.rs:174:10
[INFO] [stdout]     |
[INFO] [stdout] 173 | impl ThrottleGuard {
[INFO] [stdout]     | ------------------ method in this implementation
[INFO] [stdout] 174 |   pub fn get_current_balance(&self) -> i32 {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `linear_strategy` is never used
[INFO] [stdout]   --> src/throttle/strategies.rs:35:8
[INFO] [stdout]    |
[INFO] [stdout] 35 | pub fn linear_strategy(state: &ThrottleStateView) -> f64 {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SegmentTiming` is never constructed
[INFO] [stdout]   --> src/profiler.rs:12:19
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct SegmentTiming {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LoopProfiler` is never constructed
[INFO] [stdout]   --> src/profiler.rs:19:19
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub(crate) struct LoopProfiler {
[INFO] [stdout]    |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `INITIAL_SEGMENT_LABEL`, `new`, `loop_start`, `mark_segment_end_and_start_new`, and `log_and_reset_for_next_loop` are never used
[INFO] [stdout]   --> src/profiler.rs:31:9
[INFO] [stdout]    |
[INFO] [stdout] 30 | impl LoopProfiler {
[INFO] [stdout]    | ----------------- associated items in this implementation
[INFO] [stdout] 31 |   const INITIAL_SEGMENT_LABEL: &'static str = "loop_setup";
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 32 |
[INFO] [stdout] 33 |   pub fn new(threshold: Duration, log_interval: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 46 |   pub fn loop_start(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 53 |   pub fn mark_segment_end_and_start_new(&mut self, next_segment_label: &'static str) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 64 |   pub fn log_and_reset_for_next_loop(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:97:5
[INFO] [stdout]    |
[INFO] [stdout] 97 |     self.sender.close();
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 97 |     let _ = self.sender.close();
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connector_context_clone`
[INFO] [stdout]    --> src/transport/inproc.rs:100:7
[INFO] [stdout]     |
[INFO] [stdout] 100 |   let connector_context_clone = core_arc.context.clone();
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connector_context_clone`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/socket/dealer_socket.rs:512:11
[INFO] [stdout]     |
[INFO] [stdout] 512 |       let mut transaction_guard = self.current_send_transaction.lock().await;
[INFO] [stdout]     |           ----^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |           |
[INFO] [stdout]     |           help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `connection_id_opt`
[INFO] [stdout]    --> src/socket/dealer_socket.rs:669:28
[INFO] [stdout]     |
[INFO] [stdout] 669 |     let (endpoint_uri_opt, connection_id_opt) = {
[INFO] [stdout]     |                            ^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection_id_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `interaction_model_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:282:89
[INFO] [stdout]     |
[INFO] [stdout] 282 |               let mut interaction_model_for_event: Option<ConnectionInteractionModel> = None;
[INFO] [stdout]     |                                                                                         ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 314 |               interaction_model_for_event = Some(ConnectionInteractionModel::ViaSca {
[INFO] [stdout]     |               --------------------------- `interaction_model_for_event` is overwritten here before the previous value is read
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `managing_actor_task_id_for_event` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:283:74
[INFO] [stdout]     |
[INFO] [stdout] 283 |               let mut managing_actor_task_id_for_event: Option<TaskId> = None;
[INFO] [stdout]     |                                                                          ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 318 |               managing_actor_task_id_for_event = Some(sca_task_handle.id());
[INFO] [stdout]     |               ------------------------------------------------------------- `managing_actor_task_id_for_event` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/ipc.rs:238:54
[INFO] [stdout]     |
[INFO] [stdout] 238 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 378 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `sca_or_session_join_handle_opt`
[INFO] [stdout]    --> src/transport/tcp.rs:354:19
[INFO] [stdout]     |
[INFO] [stdout] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_sca_or_session_join_handle_opt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `setup_successful` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:485:19
[INFO] [stdout]     |
[INFO] [stdout] 485 |                   setup_successful = false;
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stdout]    --> src/transport/tcp.rs:304:54
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stdout]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 590 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stdout]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISocketConnection` is more private than the item `SystemEvent::NewConnectionEstablished::connection_iface`
[INFO] [stdout]   --> src/runtime/system_events.rs:93:5
[INFO] [stdout]    |
[INFO] [stdout] 93 |     connection_iface: Option<Arc<dyn ISocketConnection>>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `SystemEvent::NewConnectionEstablished::connection_iface` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISocketConnection` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/connection_iface.rs:33:1
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    = note: `#[warn(private_interfaces)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `ProcessTokenAction` is more private than the item `Mechanism::process_token`
[INFO] [stdout]   --> src/security/mechanism.rs:36:3
[INFO] [stdout]    |
[INFO] [stdout] 36 |   fn process_token(&mut self, token: &[u8]) -> Result<ProcessTokenAction, ZmqError>;
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::process_token` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `ProcessTokenAction` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/mechanism.rs:16:1
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `ISecureFramer` is more private than the item `Mechanism::into_framer`
[INFO] [stdout]   --> src/security/mechanism.rs:88:1
[INFO] [stdout]    |
[INFO] [stdout] 88 | fn into_framer(self: Box<Self>) -> Result<(Box<dyn ISecureFramer>, Option<Vec<u8>>), ZmqError>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::into_framer` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but trait `ISecureFramer` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/security/framer.rs:9:1
[INFO] [stdout]    |
[INFO] [stdout]  9 | pub(crate) trait ISecureFramer: Send + Sync + 'static {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type `PipeState` is more private than the item `WritePipeCoordinator::remove_pipe`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:46:3
[INFO] [stdout]    |
[INFO] [stdout] 46 |   pub async fn remove_pipe(&self, pipe_id: PipeId) -> Option<Arc<PipeState>> {
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `WritePipeCoordinator::remove_pipe` is reachable at visibility `pub`
[INFO] [stdout]    |
[INFO] [stdout] note: but type `PipeState` is only usable at visibility `pub(crate)`
[INFO] [stdout]   --> src/socket/patterns/pipe_coordinator.rs:12:1
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct PipeState {
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `binder_core_id` is never read
[INFO] [stdout]   --> src/context.rs:25:14
[INFO] [stdout]    |
[INFO] [stdout] 21 | pub(crate) struct InprocBinding {
[INFO] [stdout]    |                   ------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 25 |   pub(crate) binder_core_id: usize,
[INFO] [stdout]    |              ^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `InprocBinding` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_socket_command_sender` is never used
[INFO] [stdout]    --> src/context.rs:220:17
[INFO] [stdout]     |
[INFO] [stdout]  55 | impl ContextInner {
[INFO] [stdout]     | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 220 |   pub(crate) fn get_socket_command_sender(&self, handle: usize) -> Option<MailboxSender> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PeerAddress` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:76:12
[INFO] [stdout]    |
[INFO] [stdout] 76 | pub struct PeerAddress(pub SocketAddr);
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ZapUserId` is never constructed
[INFO] [stdout]   --> src/message/metadata.rs:80:12
[INFO] [stdout]    |
[INFO] [stdout] 80 | pub struct ZapUserId(pub String);
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `notify` is never read
[INFO] [stdout]  --> src/runtime/latch.rs:8:3
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub(crate) struct CountDownLatch {
[INFO] [stdout]   |                   -------------- field in this struct
[INFO] [stdout] 7 |   count: Arc<AtomicUsize>,
[INFO] [stdout] 8 |   notify: Arc<Notify>,
[INFO] [stdout]   |   ^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `CountDownLatch` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `count_down`, and `await_` are never used
[INFO] [stdout]   --> src/runtime/latch.rs:13:10
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl CountDownLatch {
[INFO] [stdout]    | ------------------- associated items in this implementation
[INFO] [stdout] 12 |   /// Creates a new latch initialized with the given count.
[INFO] [stdout] 13 |   pub fn new(count: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 27 |   pub async fn count_down(&self) {
[INFO] [stdout]    |                ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub async fn await_(&self) {
[INFO] [stdout]    |                ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait `IDataCipher` is never used
[INFO] [stdout]  --> src/security/cipher.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | pub trait IDataCipher: Send + Sync + 'static {
[INFO] [stdout]   |           ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `PassThroughDataCipher` is never constructed
[INFO] [stdout]   --> src/security/cipher.rs:18:19
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub(crate) struct PassThroughDataCipher;
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LengthPrefixedFramer` is never constructed
[INFO] [stdout]   --> src/security/framer.rs:44:19
[INFO] [stdout]    |
[INFO] [stdout] 44 | pub(crate) struct LengthPrefixedFramer {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/security/framer.rs:51:17
[INFO] [stdout]    |
[INFO] [stdout] 50 | impl LengthPrefixedFramer {
[INFO] [stdout]    | ------------------------- associated function in this implementation
[INFO] [stdout] 51 |   pub(crate) fn new(cipher: Box<dyn IDataCipher>) -> Self {
[INFO] [stdout]    |                 ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `ContinueWaiting` is never constructed
[INFO] [stdout]   --> src/security/mechanism.rs:18:3
[INFO] [stdout]    |
[INFO] [stdout] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stdout]    |                 ------------------ variant in this enum
[INFO] [stdout] 17 |   /// No immediate action is required. The handler should wait for the next event.
[INFO] [stdout] 18 |   ContinueWaiting,
[INFO] [stdout]    |   ^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `ProcessTokenAction` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `Initializing` is never constructed
[INFO] [stdout]   --> src/security/plain.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | enum PlainState {
[INFO] [stdout]    |      ---------- variant in this enum
[INFO] [stdout] 16 |   Initializing, // Start state (not strictly used as we set initial state in new())
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `PlainState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `fd` and `is_expecting_first_frame` are never used
[INFO] [stdout]   --> src/sessionx/cork.rs:37:17
[INFO] [stdout]    |
[INFO] [stdout] 17 | impl TcpCorkInfoX {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 37 |   pub(crate) fn fd(&self) -> RawFd {
[INFO] [stdout]    |                 ^^
[INFO] [stdout] ...
[INFO] [stdout] 47 |   pub(crate) fn is_expecting_first_frame(&self) -> bool {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SourcePipeReadId` is never constructed
[INFO] [stdout]    --> src/socket/mod.rs:228:8
[INFO] [stdout]     |
[INFO] [stdout] 228 | struct SourcePipeReadId(usize);
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `run_pipe_reader_task` is never used
[INFO] [stdout]   --> src/socket/core/pipe_manager.rs:23:21
[INFO] [stdout]    |
[INFO] [stdout] 23 | pub(crate) async fn run_pipe_reader_task(
[INFO] [stdout]    |                     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `cleanup_session_state_by_uri` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:271:21
[INFO] [stdout]     |
[INFO] [stdout] 271 | pub(crate) async fn cleanup_session_state_by_uri(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `send_msg_with_timeout` is never used
[INFO] [stdout]    --> src/socket/core/pipe_manager.rs:640:21
[INFO] [stdout]     |
[INFO] [stdout] 640 | pub(crate) async fn send_msg_with_timeout(
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `current_phase` is never used
[INFO] [stdout]   --> src/socket/core/shutdown.rs:14:17
[INFO] [stdout]    |
[INFO] [stdout] 13 | impl ShutdownCoordinator {
[INFO] [stdout]    | ------------------------ method in this implementation
[INFO] [stdout] 14 |   pub(crate) fn current_phase(&self) -> ShutdownPhase {
[INFO] [stdout]    |                 ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_pipe_sender` is never used
[INFO] [stdout]    --> src/socket/core/state.rs:161:17
[INFO] [stdout]     |
[INFO] [stdout] 141 | impl CoreState {
[INFO] [stdout]     | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 161 |   pub(crate) fn get_pipe_sender(&self, pipe_write_id: usize) -> Option<AsyncSender<Vec<Msg>>> {
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `use_send_zerocopy` and `use_recv_multishot` are never read
[INFO] [stdout]    --> src/socket/options.rs:215:7
[INFO] [stdout]     |
[INFO] [stdout] 203 | pub(crate) struct ZmtpEngineConfig {
[INFO] [stdout]     |                   ---------------- fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 215 |   pub use_send_zerocopy: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 216 |   pub use_recv_multishot: bool,
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `ZmtpEngineConfig` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_duration_ms_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:301:15
[INFO] [stdout]     |
[INFO] [stdout] 301 | pub(crate) fn parse_duration_ms_option(value: &[u8]) -> Result<Option<Duration>, ZmqError> {
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `parse_key_option` is never used
[INFO] [stdout]    --> src/socket/options.rs:444:15
[INFO] [stdout]     |
[INFO] [stdout] 444 | pub(crate) fn parse_key_option<const N: usize>(
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `hwm` is never read
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:16:3
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub(crate) struct FairQueue<T: Send + 'static> {
[INFO] [stdout]    |                   --------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 16 |   hwm: usize,
[INFO] [stdout]    |   ^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FairQueue` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `pipe_attached`, `pipe_detached`, `capacity`, `len`, and `is_empty` are never used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:31:10
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl<T: Send + 'static> FairQueue<T> {
[INFO] [stdout]    | ------------------------------------ methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 31 |   pub fn pipe_attached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn pipe_detached(&self, pipe_read_id: usize) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 82 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |   pub fn len(&self) -> usize {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 92 |   pub fn is_empty(&self) -> bool {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `decoders` is never read
[INFO] [stdout]   --> src/socket/patterns/framing.rs:21:3
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub(crate) struct FramingLatch {
[INFO] [stdout]    |                   ------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 21 |   decoders: [FramingOp; 2],
[INFO] [stdout]    |   ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `FramingLatch` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `decode` is never used
[INFO] [stdout]   --> src/socket/patterns/framing.rs:45:10
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl FramingLatch {
[INFO] [stdout]    | ----------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 45 |   pub fn decode(&self, frames: &mut Vec<Msg>) {
[INFO] [stdout]    |          ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_identity_by_read_pipe` is never used
[INFO] [stdout]   --> src/socket/patterns/router.rs:97:16
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl RouterMap {
[INFO] [stdout]    | -------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 97 |   pub async fn get_identity_by_read_pipe(&self, pipe_read_id: usize) -> Option<Blob> {
[INFO] [stdout]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `get_connection_id` and `as_any` are never used
[INFO] [stdout]   --> src/socket/connection_iface.rs:45:6
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stdout]    |                  ----------------- methods in this trait
[INFO] [stdout] ...
[INFO] [stdout] 45 |   fn get_connection_id(&self) -> usize;
[INFO] [stdout]    |      ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 46 |   fn as_any(&self) -> &dyn Any;
[INFO] [stdout]    |      ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/ipc.rs:37:3
[INFO] [stdout]    |
[INFO] [stdout] 29 | pub(crate) struct IpcListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 37 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `socket_logic` is never read
[INFO] [stdout]   --> src/transport/tcp.rs:57:3
[INFO] [stdout]    |
[INFO] [stdout] 50 | pub(crate) struct TcpListener {
[INFO] [stdout]    |                   ----------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 57 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stdout]    |   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_current_balance` is never used
[INFO] [stdout]    --> src/throttle/mod.rs:174:10
[INFO] [stdout]     |
[INFO] [stdout] 173 | impl ThrottleGuard {
[INFO] [stdout]     | ------------------ method in this implementation
[INFO] [stdout] 174 |   pub fn get_current_balance(&self) -> i32 {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `linear_strategy` is never used
[INFO] [stdout]   --> src/throttle/strategies.rs:35:8
[INFO] [stdout]    |
[INFO] [stdout] 35 | pub fn linear_strategy(state: &ThrottleStateView) -> f64 {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `SegmentTiming` is never constructed
[INFO] [stdout]   --> src/profiler.rs:12:19
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub(crate) struct SegmentTiming {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `LoopProfiler` is never constructed
[INFO] [stdout]   --> src/profiler.rs:19:19
[INFO] [stdout]    |
[INFO] [stdout] 19 | pub(crate) struct LoopProfiler {
[INFO] [stdout]    |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `INITIAL_SEGMENT_LABEL`, `new`, `loop_start`, `mark_segment_end_and_start_new`, and `log_and_reset_for_next_loop` are never used
[INFO] [stdout]   --> src/profiler.rs:31:9
[INFO] [stdout]    |
[INFO] [stdout] 30 | impl LoopProfiler {
[INFO] [stdout]    | ----------------- associated items in this implementation
[INFO] [stdout] 31 |   const INITIAL_SEGMENT_LABEL: &'static str = "loop_setup";
[INFO] [stdout]    |         ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 32 |
[INFO] [stdout] 33 |   pub fn new(threshold: Duration, log_interval: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 46 |   pub fn loop_start(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 53 |   pub fn mark_segment_end_and_start_new(&mut self, next_segment_label: &'static str) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 64 |   pub fn log_and_reset_for_next_loop(&mut self) {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/socket/patterns/fair_queue.rs:97:5
[INFO] [stdout]    |
[INFO] [stdout] 97 |     self.sender.close();
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 97 |     let _ = self.sender.close();
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/transport_failures.rs:4:12
[INFO] [stdout]   |
[INFO] [stdout] 4 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::path::Path`
[INFO] [stdout]  --> tests/transport_failures.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use std::path::Path;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/req_router.rs:7:12
[INFO] [stdout]   |
[INFO] [stdout] 7 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]  --> tests/tcp_corking.rs:9:7
[INFO] [stdout]   |
[INFO] [stdout] 9 | const SHORT_TIMEOUT: Duration = Duration::from_millis(500);
[INFO] [stdout]   |       ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/dealer_rep.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/router_router.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, MsgFlags, SocketType, ZmqError, socket::options::ROUTING_ID};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Context` and `Socket`
[INFO] [stdout]  --> tests/push_pull.rs:4:12
[INFO] [stdout]   |
[INFO] [stdout] 4 | use rzmq::{Context, Msg, Socket, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^       ^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/inproc_minimal.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/req_rep_advanced.rs:1:12
[INFO] [stdout]   |
[INFO] [stdout] 1 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `RCVTIMEO`
[INFO] [stdout]  --> tests/dns.rs:3:15
[INFO] [stdout]   |
[INFO] [stdout] 3 |     options::{RCVTIMEO, RECONNECT_IVL}, SocketEvent, SNDTIMEO
[INFO] [stdout]   |               ^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]  --> tests/dealer_rep.rs:6:7
[INFO] [stdout]   |
[INFO] [stdout] 6 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stdout]   |       ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]   --> tests/transport_failures.rs:11:7
[INFO] [stdout]    |
[INFO] [stdout] 11 | const SHORT_TIMEOUT: Duration = Duration::from_millis(250);
[INFO] [stdout]    |       ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `LONG_TIMEOUT` is never used
[INFO] [stdout]  --> tests/router_router.rs:6:7
[INFO] [stdout]   |
[INFO] [stdout] 6 | const LONG_TIMEOUT: Duration = Duration::from_secs(2);
[INFO] [stdout]   |       ^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `wait_for_handshake_events` is never used
[INFO] [stdout]   --> examples/common/mod.rs:33:14
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub async fn wait_for_handshake_events(
[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 `OwnedPermitGuard` is never constructed
[INFO] [stdout]  --> examples/common/capacity_gate.rs:8:19
[INFO] [stdout]   |
[INFO] [stdout] 8 | pub(crate) struct OwnedPermitGuard {
[INFO] [stdout]   |                   ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `CapacityGate` is never constructed
[INFO] [stdout]   --> examples/common/capacity_gate.rs:20:19
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) struct CapacityGate {
[INFO] [stdout]    |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `PermitGuard` is never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:25:17
[INFO] [stdout]    |
[INFO] [stdout] 25 | pub(crate) type PermitGuard<'a> = GenericSemaphoreReleaser<'a, RawMutex>;
[INFO] [stdout]    |                 ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `acquire`, `acquire_owned`, `release`, `get_permits`, and `capacity` are never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:28:10
[INFO] [stdout]    |
[INFO] [stdout] 27 | impl CapacityGate {
[INFO] [stdout]    | ----------------- associated items in this implementation
[INFO] [stdout] 28 |   pub fn new(capacity: usize) -> Self {
[INFO] [stdout]    |          ^^^
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn acquire(&self) -> impl Future<Output = PermitGuard<'_>> {
[INFO] [stdout]    |          ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 42 |   pub fn acquire_owned(self: Arc<Self>) -> impl Future<Output = OwnedPermitGuard> {
[INFO] [stdout]    |          ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 55 |   pub fn release(&self) {
[INFO] [stdout]    |          ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |   pub fn get_permits(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 67 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]   --> tests/req_router.rs:11:7
[INFO] [stdout]    |
[INFO] [stdout] 11 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stdout]    |       ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `dealer_endpoint_uri` is never read
[INFO] [stdout]    --> tests/dealer_router_advanced.rs:331:33
[INFO] [stdout]     |
[INFO] [stdout] 331 |   let mut dealer_endpoint_uri = "".to_string(); // Store the specific endpoint URI seen by router
[INFO] [stdout]     |                                 ^^^^^^^^^^^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 351 |       } => dealer_endpoint_uri = format!("tcp://{}", peer_addr), // Should be tcp://<peer_ip>:<peer_port>
[INFO] [stdout]     |            ------------------- `dealer_endpoint_uri` is overwritten here before the previous value is read
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variants `Off` and `Verbose` are never constructed
[INFO] [stdout]   --> examples/dealrtr_multitask.rs:30:3
[INFO] [stdout]    |
[INFO] [stdout] 29 | enum PrintLogLevel {
[INFO] [stdout]    |      ------------- variants in this enum
[INFO] [stdout] 30 |   Off,
[INFO] [stdout]    |   ^^^
[INFO] [stdout] 31 |   Info,
[INFO] [stdout] 32 |   Verbose,
[INFO] [stdout]    |   ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `PrintLogLevel` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `id` is never read
[INFO] [stdout]    --> examples/dealrtr_multitask.rs:107:3
[INFO] [stdout]     |
[INFO] [stdout] 106 | struct DealerSenderStats {
[INFO] [stdout]     |        ----------------- field in this struct
[INFO] [stdout] 107 |   id: usize,
[INFO] [stdout]     |   ^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `DealerSenderStats` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `wait_for_event` is never used
[INFO] [stdout]  --> examples/common/mod.rs:8:14
[INFO] [stdout]   |
[INFO] [stdout] 8 | pub async fn wait_for_event(
[INFO] [stdout]   |              ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `wait_for_handshake_events` is never used
[INFO] [stdout]   --> examples/common/mod.rs:33:14
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub async fn wait_for_handshake_events(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `capacity` is never read
[INFO] [stdout]   --> examples/common/capacity_gate.rs:21:3
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) struct CapacityGate {
[INFO] [stdout]    |                   ------------ field in this struct
[INFO] [stdout] 21 |   capacity: usize,
[INFO] [stdout]    |   ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `CapacityGate` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `PermitGuard` is never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:25:17
[INFO] [stdout]    |
[INFO] [stdout] 25 | pub(crate) type PermitGuard<'a> = GenericSemaphoreReleaser<'a, RawMutex>;
[INFO] [stdout]    |                 ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `acquire`, `get_permits`, and `capacity` are never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:36:10
[INFO] [stdout]    |
[INFO] [stdout] 27 | impl CapacityGate {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn acquire(&self) -> impl Future<Output = PermitGuard<'_>> {
[INFO] [stdout]    |          ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |   pub fn get_permits(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 67 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> examples/dealrtr_multitask.rs:299:3
[INFO] [stdout]     |
[INFO] [stdout] 299 | /   tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stdout] 300 | |     .await
[INFO] [stdout] 301 | |     .expect("Context termination timed out!");
[INFO] [stdout]     | |_____________________________________________^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 299 |   let _ = tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stdout]     |   +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variants `Off` and `Verbose` are never constructed
[INFO] [stdout]   --> examples/dealrtr_multiclient.rs:31:3
[INFO] [stdout]    |
[INFO] [stdout] 30 | enum PrintLogLevel {
[INFO] [stdout]    |      ------------- variants in this enum
[INFO] [stdout] 31 |   Off,
[INFO] [stdout]    |   ^^^
[INFO] [stdout] 32 |   Info,
[INFO] [stdout] 33 |   Verbose,
[INFO] [stdout]    |   ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `PrintLogLevel` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `id` is never read
[INFO] [stdout]    --> examples/dealrtr_multiclient.rs:122:3
[INFO] [stdout]     |
[INFO] [stdout] 121 | struct DealerSenderStats {
[INFO] [stdout]     |        ----------------- field in this struct
[INFO] [stdout] 122 |   id: usize,
[INFO] [stdout]     |   ^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `DealerSenderStats` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `wait_for_event` is never used
[INFO] [stdout]  --> examples/common/mod.rs:8:14
[INFO] [stdout]   |
[INFO] [stdout] 8 | pub async fn wait_for_event(
[INFO] [stdout]   |              ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `wait_for_handshake_events` is never used
[INFO] [stdout]   --> examples/common/mod.rs:33:14
[INFO] [stdout]    |
[INFO] [stdout] 33 | pub async fn wait_for_handshake_events(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `capacity` is never read
[INFO] [stdout]   --> examples/common/capacity_gate.rs:21:3
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub(crate) struct CapacityGate {
[INFO] [stdout]    |                   ------------ field in this struct
[INFO] [stdout] 21 |   capacity: usize,
[INFO] [stdout]    |   ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `CapacityGate` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias `PermitGuard` is never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:25:17
[INFO] [stdout]    |
[INFO] [stdout] 25 | pub(crate) type PermitGuard<'a> = GenericSemaphoreReleaser<'a, RawMutex>;
[INFO] [stdout]    |                 ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `acquire`, `get_permits`, and `capacity` are never used
[INFO] [stdout]   --> examples/common/capacity_gate.rs:36:10
[INFO] [stdout]    |
[INFO] [stdout] 27 | impl CapacityGate {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 36 |   pub fn acquire(&self) -> impl Future<Output = PermitGuard<'_>> {
[INFO] [stdout]    |          ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |   pub fn get_permits(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 67 |   pub fn capacity(&self) -> usize {
[INFO] [stdout]    |          ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> examples/dealrtr_multiclient.rs:330:3
[INFO] [stdout]     |
[INFO] [stdout] 330 | /   tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stdout] 331 | |     .await
[INFO] [stdout] 332 | |     .expect("Context termination timed out!");
[INFO] [stdout]     | |_____________________________________________^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 330 |   let _ = tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stdout]     |   +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/push_pull_lifecycle.rs:1:12
[INFO] [stdout]   |
[INFO] [stdout] 1 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]  --> tests/push_pull_lifecycle.rs:9:7
[INFO] [stdout]   |
[INFO] [stdout] 9 | const SHORT_TIMEOUT: Duration = Duration::from_millis(250);
[INFO] [stdout]   |       ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/req_rep.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stdout]  --> tests/req_rep.rs:7:7
[INFO] [stdout]   |
[INFO] [stdout] 7 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stdout]   |       ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/dealer_router.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, MsgFlags, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::HashSet`
[INFO] [stdout]  --> tests/dealer_router.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::collections::HashSet;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Context`, `LINGER`, `RCVHWM`, and `SNDHWM`
[INFO] [stdout]  --> tests/socket_options.rs:2:36
[INFO] [stdout]   |
[INFO] [stdout] 2 |   socket::options::{LAST_ENDPOINT, LINGER, RCVHWM, SNDHWM},
[INFO] [stdout]   |                                    ^^^^^^  ^^^^^^  ^^^^^^
[INFO] [stdout] 3 |   Context, Msg, SocketType, ZmqError,
[INFO] [stdout]   |   ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/dealer_dealer.rs:3:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Context`
[INFO] [stdout]  --> tests/pub_sub.rs:5:12
[INFO] [stdout]   |
[INFO] [stdout] 5 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stdout]   |            ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::HashSet`
[INFO] [stdout]  --> tests/pub_sub.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use std::collections::HashSet;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `expected_connections`
[INFO] [stdout]    --> tests/shutdown_race.rs:611:7
[INFO] [stdout]     |
[INFO] [stdout] 611 |   let expected_connections = Arc::new(tokio::sync::Semaphore::new(TCP_NUM_PUSHERS)); // To count connections
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_expected_connections`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `NUM_PULLERS` is never used
[INFO] [stdout]   --> tests/shutdown_race.rs:26:7
[INFO] [stdout]    |
[INFO] [stdout] 26 | const NUM_PULLERS: usize = 2;
[INFO] [stdout]    |       ^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `TCP_NUM_PULLERS` is never used
[INFO] [stdout]    --> tests/shutdown_race.rs:546:7
[INFO] [stdout]     |
[INFO] [stdout] 546 | const TCP_NUM_PULLERS: usize = 1; // Must be 1 for TCP bind
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> tests/shutdown_race.rs:486:3
[INFO] [stdout]     |
[INFO] [stdout] 486 |   pull_socket.close().await;
[INFO] [stdout]     |   ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 486 |   let _ = pull_socket.close().await;
[INFO] [stdout]     |   +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> tests/shutdown_race.rs:488:5
[INFO] [stdout]     |
[INFO] [stdout] 488 |     sck.close().await;
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 488 |     let _ = sck.close().await;
[INFO] [stdout]     |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> tests/security_plain.rs:166:7
[INFO] [stdout]     |
[INFO] [stdout] 160 |       Ok(Ok(event)) => {
[INFO] [stdout]     |       ------------- matches all the relevant values
[INFO] [stdout] ...
[INFO] [stdout] 166 |       Ok(Ok(_)) => {}, // Ignore other events
[INFO] [stdout]     |       ^^^^^^^^^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> tests/security_plain.rs:200:7
[INFO] [stdout]     |
[INFO] [stdout] 200 |   let mut monitor = client.monitor_default().await?;
[INFO] [stdout]     |       ----^^^^^^^
[INFO] [stdout]     |       |
[INFO] [stdout]     |       help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> tests/security_plain.rs:255:29
[INFO] [stdout]     |
[INFO] [stdout] 255 |   if let Ok((client_socket, mut client_monitor)) = client_setup_result {
[INFO] [stdout]     |                             ----^^^^^^^^^^^^^^
[INFO] [stdout]     |                             |
[INFO] [stdout]     |                             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: constant `TEST_TIMEOUT` is never used
[INFO] [stdout]   --> tests/security_plain.rs:11:7
[INFO] [stdout]    |
[INFO] [stdout] 11 | const TEST_TIMEOUT: Duration = Duration::from_secs(5); // Timeout for async test operations
[INFO] [stdout]    |       ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 54.92s
[INFO] running `Command { std: "docker" "inspect" "d556b693d1f308c4259d4eff61a3e5d9ac788ad1f36815a70c3f0afd65acace4", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "d556b693d1f308c4259d4eff61a3e5d9ac788ad1f36815a70c3f0afd65acace4", kill_on_drop: false }`
[INFO] [stdout] d556b693d1f308c4259d4eff61a3e5d9ac788ad1f36815a70c3f0afd65acace4
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-04-21" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] 1ec33a9b88db8aae9b049b2dd64edfb1c7f3e31419b111e02d9c2c9e48a8e6de
[INFO] running `Command { std: "docker" "start" "-a" "1ec33a9b88db8aae9b049b2dd64edfb1c7f3e31419b111e02d9c2c9e48a8e6de", kill_on_drop: false }`
[INFO] [stderr] warning: the usage of Script Group `Greek` in this crate consists solely of mixed script confusables
[INFO] [stderr]    --> src/throttle/mod.rs:129:11
[INFO] [stderr]     |
[INFO] [stderr] 129 |       let α = self.shared.config.adaptive_learning_rate;
[INFO] [stderr]     |           ^
[INFO] [stderr]     |
[INFO] [stderr]     = note: the usage includes 'α' (U+03B1)
[INFO] [stderr]     = note: please recheck to make sure their usages are indeed what you want
[INFO] [stderr]     = note: `#[warn(mixed_script_confusables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `SystemEvent`
[INFO] [stderr]  --> src/runtime/actor_drop_guard.rs:3:33
[INFO] [stderr]   |
[INFO] [stderr] 3 | use crate::runtime::{ActorType, SystemEvent}; // Adjust imports as needed
[INFO] [stderr]   |                                 ^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `AtomicBool` and `Ordering`
[INFO] [stderr]  --> src/runtime/actor_drop_guard.rs:5:25
[INFO] [stderr]   |
[INFO] [stderr] 5 | use std::sync::atomic::{AtomicBool, Ordering};
[INFO] [stderr]   |                         ^^^^^^^^^^  ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::sync::Arc`
[INFO] [stderr]  --> src/runtime/actor_drop_guard.rs:6:5
[INFO] [stderr]   |
[INFO] [stderr] 6 | use std::sync::Arc;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `latch::CountDownLatch`
[INFO] [stderr]   --> src/runtime/mod.rs:20:16
[INFO] [stderr]    |
[INFO] [stderr] 20 | pub(crate) use latch::CountDownLatch;
[INFO] [stderr]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `IDataCipher`
[INFO] [stderr]  --> src/security/mechanism.rs:1:13
[INFO] [stderr]   |
[INFO] [stderr] 1 | use super::{IDataCipher, ZmqError};
[INFO] [stderr]   |             ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stderr]  --> src/security/null.rs:3:13
[INFO] [stderr]   |
[INFO] [stderr] 3 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stderr]   |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `IDataCipher` and `cipher::PassThroughDataCipher`
[INFO] [stderr]   --> src/security/plain.rs:11:13
[INFO] [stderr]    |
[INFO] [stderr] 11 | use super::{IDataCipher, Mechanism, MechanismStatus, cipher::PassThroughDataCipher};
[INFO] [stderr]    |             ^^^^^^^^^^^                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `crate::message::Metadata`
[INFO] [stderr]   --> src/security/mod.rs:12:5
[INFO] [stderr]    |
[INFO] [stderr] 12 | use crate::message::Metadata;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::os::fd::AsRawFd`
[INFO] [stderr]   --> src/sessionx/actor.rs:16:5
[INFO] [stderr]    |
[INFO] [stderr] 16 | use std::os::fd::AsRawFd; // For AsRawFd bound if S needs it for cork_info init
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::time::Duration`
[INFO] [stderr]   --> src/sessionx/actor.rs:18:5
[INFO] [stderr]    |
[INFO] [stderr] 18 | use std::time::Duration;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `command_processor`
[INFO] [stderr]  --> src/socket/core/pipe_manager.rs:9:39
[INFO] [stderr]   |
[INFO] [stderr] 9 | use crate::socket::core::{SocketCore, command_processor};
[INFO] [stderr]   |                                       ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `command_processor`
[INFO] [stderr]  --> src/socket/core/shutdown.rs:5:27
[INFO] [stderr]   |
[INFO] [stderr] 5 | use crate::socket::core::{command_processor, pipe_manager, SocketCore};
[INFO] [stderr]   |                           ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `fair_queue::FairQueue`
[INFO] [stderr]   --> src/socket/patterns/mod.rs:11:16
[INFO] [stderr]    |
[INFO] [stderr] 11 | pub(crate) use fair_queue::FairQueue;
[INFO] [stderr]    |                ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `command::Command` and `mailbox::MailboxSender as SessionMailboxSender`
[INFO] [stderr]  --> src/socket/connection_iface.rs:8:22
[INFO] [stderr]   |
[INFO] [stderr] 8 | use crate::runtime::{command::Command, mailbox::MailboxSender as SessionMailboxSender};
[INFO] [stderr]   |                      ^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::time::Duration`
[INFO] [stderr]   --> src/socket/connection_iface.rs:21:5
[INFO] [stderr]    |
[INFO] [stderr] 21 | use std::time::Duration;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `crate::socket::core::pipe_manager::run_pipe_reader_task`
[INFO] [stderr]  --> src/transport/inproc.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use crate::socket::core::pipe_manager::run_pipe_reader_task;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `SocketAddr as StdSocketAddr`
[INFO] [stderr]   --> src/transport/tcp.rs:34:16
[INFO] [stderr]    |
[INFO] [stderr] 34 | use std::net::{SocketAddr as StdSocketAddr, ToSocketAddrs};
[INFO] [stderr]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `debug`, `error`, `info`, `trace`, and `warn`
[INFO] [stderr]   --> src/transport/tcp.rs:42:15
[INFO] [stderr]    |
[INFO] [stderr] 42 | use tracing::{debug, error, info, trace, warn};
[INFO] [stderr]    |               ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `MailboxSender`
[INFO] [stderr]   --> src/lib.rs:42:43
[INFO] [stderr]    |
[INFO] [stderr] 42 | pub(crate) use runtime::{MailboxReceiver, MailboxSender};
[INFO] [stderr]    |                                           ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stderr]     |
[INFO] [stderr] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stderr]     |     ^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr] note: multiple earlier patterns match some of the same values
[INFO] [stderr]    --> src/socket/core/command_processor.rs:490:5
[INFO] [stderr]     |
[INFO] [stderr] 363 |     Ok(Endpoint::Tcp(_addr, ref uri_from_parse)) => {
[INFO] [stderr]     |     -------------------------------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 418 |     Ok(Endpoint::Ipc(ref path_buf, ref uri_from_parse)) => {
[INFO] [stderr]     |     --------------------------------------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 469 |     Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stderr]     |     ------------------------------ matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 489 |     Err(e) => bind_result = Err(e), // Error from parse_endpoint
[INFO] [stderr]     |     ------ matches some of the same values
[INFO] [stderr] 490 |     _ => bind_result = Err(ZmqError::UnsupportedTransport(endpoint.to_string())),
[INFO] [stderr]     |     ^ collectively making this unreachable
[INFO] [stderr]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stderr]     |
[INFO] [stderr] 554 |     _ => {
[INFO] [stderr]     |     ^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr] note: multiple earlier patterns match some of the same values
[INFO] [stderr]    --> src/socket/core/command_processor.rs:554:5
[INFO] [stderr]     |
[INFO] [stderr] 529 | /     Ok(Endpoint::Tcp(_, ref parsed_uri_for_connecter))
[INFO] [stderr] 530 | |     | Ok(Endpoint::Ipc(_, ref parsed_uri_for_connecter)) => {
[INFO] [stderr]     | |________________________________________________________- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 542 |       Ok(Endpoint::Inproc(ref name)) => {
[INFO] [stderr]     |       ------------------------------ matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 551 |       Err(e) => {
[INFO] [stderr]     |       ------ matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 554 |       _ => {
[INFO] [stderr]     |       ^ collectively making this unreachable
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stderr]     |
[INFO] [stderr] 641 |     _ => {
[INFO] [stderr]     |     ^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr] note: multiple earlier patterns match some of the same values
[INFO] [stderr]    --> src/socket/core/command_processor.rs:641:5
[INFO] [stderr]     |
[INFO] [stderr] 575 |     Ok(Endpoint::Tcp(_, _)) => {
[INFO] [stderr]     |     ----------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 606 |     Ok(Endpoint::Ipc(path_buf, _)) => {
[INFO] [stderr]     |     ------------------------------ matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 626 |     Ok(Endpoint::Inproc(_)) => {
[INFO] [stderr]     |     ----------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 629 |     Err(err) => {
[INFO] [stderr]     |     -------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 641 |     _ => {
[INFO] [stderr]     |     ^ collectively making this unreachable
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/transport/ipc.rs:284:19
[INFO] [stderr]     |
[INFO] [stderr] 284 |               let mut setup_successful = true;
[INFO] [stderr]     |                   ----^^^^^^^^^^^^^^^^
[INFO] [stderr]     |                   |
[INFO] [stderr]     |                   help: remove this `mut`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/transport/ipc.rs:490:9
[INFO] [stderr]     |
[INFO] [stderr] 490 |     let mut connection_outcome: Result<
[INFO] [stderr]     |         ----^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/transport/tcp.rs:187:29
[INFO] [stderr]     |
[INFO] [stderr] 187 |   async fn run_command_loop(mut self, parent_socket_id: usize) {
[INFO] [stderr]     |                             ----^^^^
[INFO] [stderr]     |                             |
[INFO] [stderr]     |                             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/transport/tcp.rs:354:19
[INFO] [stderr]     |
[INFO] [stderr] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stderr]     |                   ----^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |                   |
[INFO] [stderr]     |                   help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `connector_context_clone`
[INFO] [stderr]    --> src/transport/inproc.rs:100:7
[INFO] [stderr]     |
[INFO] [stderr] 100 |   let connector_context_clone = core_arc.context.clone();
[INFO] [stderr]     |       ^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connector_context_clone`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/socket/dealer_socket.rs:512:11
[INFO] [stderr]     |
[INFO] [stderr] 512 |       let mut transaction_guard = self.current_send_transaction.lock().await;
[INFO] [stderr]     |           ----^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |           |
[INFO] [stderr]     |           help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `connection_id_opt`
[INFO] [stderr]    --> src/socket/dealer_socket.rs:669:28
[INFO] [stderr]     |
[INFO] [stderr] 669 |     let (endpoint_uri_opt, connection_id_opt) = {
[INFO] [stderr]     |                            ^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_connection_id_opt`
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `interaction_model_for_event` is never read
[INFO] [stderr]    --> src/transport/ipc.rs:282:89
[INFO] [stderr]     |
[INFO] [stderr] 282 |               let mut interaction_model_for_event: Option<ConnectionInteractionModel> = None;
[INFO] [stderr]     |                                                                                         ^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 314 |               interaction_model_for_event = Some(ConnectionInteractionModel::ViaSca {
[INFO] [stderr]     |               --------------------------- `interaction_model_for_event` is overwritten here before the previous value is read
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `managing_actor_task_id_for_event` is never read
[INFO] [stderr]    --> src/transport/ipc.rs:283:74
[INFO] [stderr]     |
[INFO] [stderr] 283 |               let mut managing_actor_task_id_for_event: Option<TaskId> = None;
[INFO] [stderr]     |                                                                          ^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 318 |               managing_actor_task_id_for_event = Some(sca_task_handle.id());
[INFO] [stderr]     |               ------------------------------------------------------------- `managing_actor_task_id_for_event` is overwritten here before the previous value is read
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stderr]    --> src/transport/ipc.rs:238:54
[INFO] [stderr]     |
[INFO] [stderr] 238 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stderr]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 378 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stderr]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `sca_or_session_join_handle_opt`
[INFO] [stderr]    --> src/transport/tcp.rs:354:19
[INFO] [stderr]     |
[INFO] [stderr] 354 |               let mut sca_or_session_join_handle_opt: Option<JoinHandle<()>> = None;
[INFO] [stderr]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_sca_or_session_join_handle_opt`
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `setup_successful` is never read
[INFO] [stderr]    --> src/transport/tcp.rs:485:19
[INFO] [stderr]     |
[INFO] [stderr] 485 |                   setup_successful = false;
[INFO] [stderr]     |                   ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = help: maybe it is overwritten before being read?
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `loop_error_to_report` is never read
[INFO] [stderr]    --> src/transport/tcp.rs:304:54
[INFO] [stderr]     |
[INFO] [stderr] 304 |     let mut loop_error_to_report: Option<ZmqError> = None;
[INFO] [stderr]     |                                                      ^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 590 |             loop_error_to_report = Some(ZmqError::from_io_endpoint(e, &endpoint_uri));
[INFO] [stderr]     |             -------------------- `loop_error_to_report` is overwritten here before the previous value is read
[INFO] [stderr] 
[INFO] [stderr] warning: trait `ISocketConnection` is more private than the item `SystemEvent::NewConnectionEstablished::connection_iface`
[INFO] [stderr]   --> src/runtime/system_events.rs:93:5
[INFO] [stderr]    |
[INFO] [stderr] 93 |     connection_iface: Option<Arc<dyn ISocketConnection>>,
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field `SystemEvent::NewConnectionEstablished::connection_iface` is reachable at visibility `pub`
[INFO] [stderr]    |
[INFO] [stderr] note: but trait `ISocketConnection` is only usable at visibility `pub(crate)`
[INFO] [stderr]   --> src/socket/connection_iface.rs:33:1
[INFO] [stderr]    |
[INFO] [stderr] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    = note: `#[warn(private_interfaces)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: type `ProcessTokenAction` is more private than the item `Mechanism::process_token`
[INFO] [stderr]   --> src/security/mechanism.rs:36:3
[INFO] [stderr]    |
[INFO] [stderr] 36 |   fn process_token(&mut self, token: &[u8]) -> Result<ProcessTokenAction, ZmqError>;
[INFO] [stderr]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::process_token` is reachable at visibility `pub`
[INFO] [stderr]    |
[INFO] [stderr] note: but type `ProcessTokenAction` is only usable at visibility `pub(crate)`
[INFO] [stderr]   --> src/security/mechanism.rs:16:1
[INFO] [stderr]    |
[INFO] [stderr] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: trait `ISecureFramer` is more private than the item `Mechanism::into_framer`
[INFO] [stderr]   --> src/security/mechanism.rs:88:1
[INFO] [stderr]    |
[INFO] [stderr] 88 | fn into_framer(self: Box<Self>) -> Result<(Box<dyn ISecureFramer>, Option<Vec<u8>>), ZmqError>;
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `Mechanism::into_framer` is reachable at visibility `pub`
[INFO] [stderr]    |
[INFO] [stderr] note: but trait `ISecureFramer` is only usable at visibility `pub(crate)`
[INFO] [stderr]   --> src/security/framer.rs:9:1
[INFO] [stderr]    |
[INFO] [stderr]  9 | pub(crate) trait ISecureFramer: Send + Sync + 'static {
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: type `PipeState` is more private than the item `WritePipeCoordinator::remove_pipe`
[INFO] [stderr]   --> src/socket/patterns/pipe_coordinator.rs:46:3
[INFO] [stderr]    |
[INFO] [stderr] 46 |   pub async fn remove_pipe(&self, pipe_id: PipeId) -> Option<Arc<PipeState>> {
[INFO] [stderr]    |   ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ method `WritePipeCoordinator::remove_pipe` is reachable at visibility `pub`
[INFO] [stderr]    |
[INFO] [stderr] note: but type `PipeState` is only usable at visibility `pub(crate)`
[INFO] [stderr]   --> src/socket/patterns/pipe_coordinator.rs:12:1
[INFO] [stderr]    |
[INFO] [stderr] 12 | pub(crate) struct PipeState {
[INFO] [stderr]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `binder_core_id` is never read
[INFO] [stderr]   --> src/context.rs:25:14
[INFO] [stderr]    |
[INFO] [stderr] 21 | pub(crate) struct InprocBinding {
[INFO] [stderr]    |                   ------------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 25 |   pub(crate) binder_core_id: usize,
[INFO] [stderr]    |              ^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `InprocBinding` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: method `get_socket_command_sender` is never used
[INFO] [stderr]    --> src/context.rs:220:17
[INFO] [stderr]     |
[INFO] [stderr]  55 | impl ContextInner {
[INFO] [stderr]     | ----------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 220 |   pub(crate) fn get_socket_command_sender(&self, handle: usize) -> Option<MailboxSender> {
[INFO] [stderr]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `PeerAddress` is never constructed
[INFO] [stderr]   --> src/message/metadata.rs:76:12
[INFO] [stderr]    |
[INFO] [stderr] 76 | pub struct PeerAddress(pub SocketAddr);
[INFO] [stderr]    |            ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `ZapUserId` is never constructed
[INFO] [stderr]   --> src/message/metadata.rs:80:12
[INFO] [stderr]    |
[INFO] [stderr] 80 | pub struct ZapUserId(pub String);
[INFO] [stderr]    |            ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `notify` is never read
[INFO] [stderr]  --> src/runtime/latch.rs:8:3
[INFO] [stderr]   |
[INFO] [stderr] 6 | pub(crate) struct CountDownLatch {
[INFO] [stderr]   |                   -------------- field in this struct
[INFO] [stderr] 7 |   count: Arc<AtomicUsize>,
[INFO] [stderr] 8 |   notify: Arc<Notify>,
[INFO] [stderr]   |   ^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `CountDownLatch` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `count_down`, and `await_` are never used
[INFO] [stderr]   --> src/runtime/latch.rs:13:10
[INFO] [stderr]    |
[INFO] [stderr] 11 | impl CountDownLatch {
[INFO] [stderr]    | ------------------- associated items in this implementation
[INFO] [stderr] 12 |   /// Creates a new latch initialized with the given count.
[INFO] [stderr] 13 |   pub fn new(count: usize) -> Self {
[INFO] [stderr]    |          ^^^
[INFO] [stderr] ...
[INFO] [stderr] 27 |   pub async fn count_down(&self) {
[INFO] [stderr]    |                ^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 37 |   pub async fn await_(&self) {
[INFO] [stderr]    |                ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: trait `IDataCipher` is never used
[INFO] [stderr]  --> src/security/cipher.rs:5:11
[INFO] [stderr]   |
[INFO] [stderr] 5 | pub trait IDataCipher: Send + Sync + 'static {
[INFO] [stderr]   |           ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `PassThroughDataCipher` is never constructed
[INFO] [stderr]   --> src/security/cipher.rs:18:19
[INFO] [stderr]    |
[INFO] [stderr] 18 | pub(crate) struct PassThroughDataCipher;
[INFO] [stderr]    |                   ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `LengthPrefixedFramer` is never constructed
[INFO] [stderr]   --> src/security/framer.rs:44:19
[INFO] [stderr]    |
[INFO] [stderr] 44 | pub(crate) struct LengthPrefixedFramer {
[INFO] [stderr]    |                   ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `new` is never used
[INFO] [stderr]   --> src/security/framer.rs:51:17
[INFO] [stderr]    |
[INFO] [stderr] 50 | impl LengthPrefixedFramer {
[INFO] [stderr]    | ------------------------- associated function in this implementation
[INFO] [stderr] 51 |   pub(crate) fn new(cipher: Box<dyn IDataCipher>) -> Self {
[INFO] [stderr]    |                 ^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant `ContinueWaiting` is never constructed
[INFO] [stderr]   --> src/security/mechanism.rs:18:3
[INFO] [stderr]    |
[INFO] [stderr] 16 | pub(crate) enum ProcessTokenAction {
[INFO] [stderr]    |                 ------------------ variant in this enum
[INFO] [stderr] 17 |   /// No immediate action is required. The handler should wait for the next event.
[INFO] [stderr] 18 |   ContinueWaiting,
[INFO] [stderr]    |   ^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `ProcessTokenAction` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: variant `Initializing` is never constructed
[INFO] [stderr]   --> src/security/plain.rs:16:3
[INFO] [stderr]    |
[INFO] [stderr] 15 | enum PlainState {
[INFO] [stderr]    |      ---------- variant in this enum
[INFO] [stderr] 16 |   Initializing, // Start state (not strictly used as we set initial state in new())
[INFO] [stderr]    |   ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `PlainState` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: methods `fd` and `is_expecting_first_frame` are never used
[INFO] [stderr]   --> src/sessionx/cork.rs:37:17
[INFO] [stderr]    |
[INFO] [stderr] 17 | impl TcpCorkInfoX {
[INFO] [stderr]    | ----------------- methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 37 |   pub(crate) fn fd(&self) -> RawFd {
[INFO] [stderr]    |                 ^^
[INFO] [stderr] ...
[INFO] [stderr] 47 |   pub(crate) fn is_expecting_first_frame(&self) -> bool {
[INFO] [stderr]    |                 ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `SourcePipeReadId` is never constructed
[INFO] [stderr]    --> src/socket/mod.rs:228:8
[INFO] [stderr]     |
[INFO] [stderr] 228 | struct SourcePipeReadId(usize);
[INFO] [stderr]     |        ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `run_pipe_reader_task` is never used
[INFO] [stderr]   --> src/socket/core/pipe_manager.rs:23:21
[INFO] [stderr]    |
[INFO] [stderr] 23 | pub(crate) async fn run_pipe_reader_task(
[INFO] [stderr]    |                     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `cleanup_session_state_by_uri` is never used
[INFO] [stderr]    --> src/socket/core/pipe_manager.rs:271:21
[INFO] [stderr]     |
[INFO] [stderr] 271 | pub(crate) async fn cleanup_session_state_by_uri(
[INFO] [stderr]     |                     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `send_msg_with_timeout` is never used
[INFO] [stderr]    --> src/socket/core/pipe_manager.rs:640:21
[INFO] [stderr]     |
[INFO] [stderr] 640 | pub(crate) async fn send_msg_with_timeout(
[INFO] [stderr]     |                     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `current_phase` is never used
[INFO] [stderr]   --> src/socket/core/shutdown.rs:14:17
[INFO] [stderr]    |
[INFO] [stderr] 13 | impl ShutdownCoordinator {
[INFO] [stderr]    | ------------------------ method in this implementation
[INFO] [stderr] 14 |   pub(crate) fn current_phase(&self) -> ShutdownPhase {
[INFO] [stderr]    |                 ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `get_pipe_sender` is never used
[INFO] [stderr]    --> src/socket/core/state.rs:161:17
[INFO] [stderr]     |
[INFO] [stderr] 141 | impl CoreState {
[INFO] [stderr]     | -------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 161 |   pub(crate) fn get_pipe_sender(&self, pipe_write_id: usize) -> Option<AsyncSender<Vec<Msg>>> {
[INFO] [stderr]     |                 ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `use_send_zerocopy` and `use_recv_multishot` are never read
[INFO] [stderr]    --> src/socket/options.rs:215:7
[INFO] [stderr]     |
[INFO] [stderr] 203 | pub(crate) struct ZmtpEngineConfig {
[INFO] [stderr]     |                   ---------------- fields in this struct
[INFO] [stderr] ...
[INFO] [stderr] 215 |   pub use_send_zerocopy: bool,
[INFO] [stderr]     |       ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 216 |   pub use_recv_multishot: bool,
[INFO] [stderr]     |       ^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `ZmtpEngineConfig` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: function `parse_duration_ms_option` is never used
[INFO] [stderr]    --> src/socket/options.rs:301:15
[INFO] [stderr]     |
[INFO] [stderr] 301 | pub(crate) fn parse_duration_ms_option(value: &[u8]) -> Result<Option<Duration>, ZmqError> {
[INFO] [stderr]     |               ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `parse_key_option` is never used
[INFO] [stderr]    --> src/socket/options.rs:444:15
[INFO] [stderr]     |
[INFO] [stderr] 444 | pub(crate) fn parse_key_option<const N: usize>(
[INFO] [stderr]     |               ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `hwm` is never read
[INFO] [stderr]   --> src/socket/patterns/fair_queue.rs:16:3
[INFO] [stderr]    |
[INFO] [stderr] 13 | pub(crate) struct FairQueue<T: Send + 'static> {
[INFO] [stderr]    |                   --------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 16 |   hwm: usize,
[INFO] [stderr]    |   ^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `FairQueue` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: methods `pipe_attached`, `pipe_detached`, `capacity`, `len`, and `is_empty` are never used
[INFO] [stderr]   --> src/socket/patterns/fair_queue.rs:31:10
[INFO] [stderr]    |
[INFO] [stderr] 19 | impl<T: Send + 'static> FairQueue<T> {
[INFO] [stderr]    | ------------------------------------ methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 31 |   pub fn pipe_attached(&self, pipe_read_id: usize) {
[INFO] [stderr]    |          ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 36 |   pub fn pipe_detached(&self, pipe_read_id: usize) {
[INFO] [stderr]    |          ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 82 |   pub fn capacity(&self) -> usize {
[INFO] [stderr]    |          ^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 87 |   pub fn len(&self) -> usize {
[INFO] [stderr]    |          ^^^
[INFO] [stderr] ...
[INFO] [stderr] 92 |   pub fn is_empty(&self) -> bool {
[INFO] [stderr]    |          ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `decoders` is never read
[INFO] [stderr]   --> src/socket/patterns/framing.rs:21:3
[INFO] [stderr]    |
[INFO] [stderr] 15 | pub(crate) struct FramingLatch {
[INFO] [stderr]    |                   ------------ field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 21 |   decoders: [FramingOp; 2],
[INFO] [stderr]    |   ^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `FramingLatch` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: method `decode` is never used
[INFO] [stderr]   --> src/socket/patterns/framing.rs:45:10
[INFO] [stderr]    |
[INFO] [stderr] 24 | impl FramingLatch {
[INFO] [stderr]    | ----------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 45 |   pub fn decode(&self, frames: &mut Vec<Msg>) {
[INFO] [stderr]    |          ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `get_identity_by_read_pipe` is never used
[INFO] [stderr]   --> src/socket/patterns/router.rs:97:16
[INFO] [stderr]    |
[INFO] [stderr] 24 | impl RouterMap {
[INFO] [stderr]    | -------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 97 |   pub async fn get_identity_by_read_pipe(&self, pipe_read_id: usize) -> Option<Blob> {
[INFO] [stderr]    |                ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `get_connection_id` and `as_any` are never used
[INFO] [stderr]   --> src/socket/connection_iface.rs:45:6
[INFO] [stderr]    |
[INFO] [stderr] 33 | pub(crate) trait ISocketConnection: Send + Sync + fmt::Debug {
[INFO] [stderr]    |                  ----------------- methods in this trait
[INFO] [stderr] ...
[INFO] [stderr] 45 |   fn get_connection_id(&self) -> usize;
[INFO] [stderr]    |      ^^^^^^^^^^^^^^^^^
[INFO] [stderr] 46 |   fn as_any(&self) -> &dyn Any;
[INFO] [stderr]    |      ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `socket_logic` is never read
[INFO] [stderr]   --> src/transport/ipc.rs:37:3
[INFO] [stderr]    |
[INFO] [stderr] 29 | pub(crate) struct IpcListener {
[INFO] [stderr]    |                   ----------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 37 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stderr]    |   ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `socket_logic` is never read
[INFO] [stderr]   --> src/transport/tcp.rs:57:3
[INFO] [stderr]    |
[INFO] [stderr] 50 | pub(crate) struct TcpListener {
[INFO] [stderr]    |                   ----------- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 57 |   socket_logic: Arc<dyn ISocket>,
[INFO] [stderr]    |   ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `get_current_balance` is never used
[INFO] [stderr]    --> src/throttle/mod.rs:174:10
[INFO] [stderr]     |
[INFO] [stderr] 173 | impl ThrottleGuard {
[INFO] [stderr]     | ------------------ method in this implementation
[INFO] [stderr] 174 |   pub fn get_current_balance(&self) -> i32 {
[INFO] [stderr]     |          ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `linear_strategy` is never used
[INFO] [stderr]   --> src/throttle/strategies.rs:35:8
[INFO] [stderr]    |
[INFO] [stderr] 35 | pub fn linear_strategy(state: &ThrottleStateView) -> f64 {
[INFO] [stderr]    |        ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `SegmentTiming` is never constructed
[INFO] [stderr]   --> src/profiler.rs:12:19
[INFO] [stderr]    |
[INFO] [stderr] 12 | pub(crate) struct SegmentTiming {
[INFO] [stderr]    |                   ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `LoopProfiler` is never constructed
[INFO] [stderr]   --> src/profiler.rs:19:19
[INFO] [stderr]    |
[INFO] [stderr] 19 | pub(crate) struct LoopProfiler {
[INFO] [stderr]    |                   ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `INITIAL_SEGMENT_LABEL`, `new`, `loop_start`, `mark_segment_end_and_start_new`, and `log_and_reset_for_next_loop` are never used
[INFO] [stderr]   --> src/profiler.rs:31:9
[INFO] [stderr]    |
[INFO] [stderr] 30 | impl LoopProfiler {
[INFO] [stderr]    | ----------------- associated items in this implementation
[INFO] [stderr] 31 |   const INITIAL_SEGMENT_LABEL: &'static str = "loop_setup";
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 32 |
[INFO] [stderr] 33 |   pub fn new(threshold: Duration, log_interval: usize) -> Self {
[INFO] [stderr]    |          ^^^
[INFO] [stderr] ...
[INFO] [stderr] 46 |   pub fn loop_start(&mut self) {
[INFO] [stderr]    |          ^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 53 |   pub fn mark_segment_end_and_start_new(&mut self, next_segment_label: &'static str) {
[INFO] [stderr]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 64 |   pub fn log_and_reset_for_next_loop(&mut self) {
[INFO] [stderr]    |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]   --> src/socket/patterns/fair_queue.rs:97:5
[INFO] [stderr]    |
[INFO] [stderr] 97 |     self.sender.close();
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]    = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] help: use `let _ = ...` to ignore the resulting value
[INFO] [stderr]    |
[INFO] [stderr] 97 |     let _ = self.sender.close();
[INFO] [stderr]    |     +++++++
[INFO] [stderr] 
[INFO] [stderr] warning: `rzmq` (lib) generated 76 warnings (run `cargo fix --lib -p rzmq` to apply 27 suggestions)
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/transport_failures.rs:4:12
[INFO] [stderr]   |
[INFO] [stderr] 4 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::path::Path`
[INFO] [stderr]  --> tests/transport_failures.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use std::path::Path;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]   --> tests/transport_failures.rs:11:7
[INFO] [stderr]    |
[INFO] [stderr] 11 | const SHORT_TIMEOUT: Duration = Duration::from_millis(250);
[INFO] [stderr]    |       ^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/req_rep_advanced.rs:1:12
[INFO] [stderr]   |
[INFO] [stderr] 1 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `RCVTIMEO`
[INFO] [stderr]  --> tests/dns.rs:3:15
[INFO] [stderr]   |
[INFO] [stderr] 3 |     options::{RCVTIMEO, RECONNECT_IVL}, SocketEvent, SNDTIMEO
[INFO] [stderr]   |               ^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/pub_sub.rs:5:12
[INFO] [stderr]   |
[INFO] [stderr] 5 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::collections::HashSet`
[INFO] [stderr]  --> tests/pub_sub.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use std::collections::HashSet;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]  --> tests/tcp_corking.rs:9:7
[INFO] [stderr]   |
[INFO] [stderr] 9 | const SHORT_TIMEOUT: Duration = Duration::from_millis(500);
[INFO] [stderr]   |       ^^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/req_router.rs:7:12
[INFO] [stderr]   |
[INFO] [stderr] 7 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]   --> tests/req_router.rs:11:7
[INFO] [stderr]    |
[INFO] [stderr] 11 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stderr]    |       ^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> tests/security_plain.rs:166:7
[INFO] [stderr]     |
[INFO] [stderr] 160 |       Ok(Ok(event)) => {
[INFO] [stderr]     |       ------------- matches all the relevant values
[INFO] [stderr] ...
[INFO] [stderr] 166 |       Ok(Ok(_)) => {}, // Ignore other events
[INFO] [stderr]     |       ^^^^^^^^^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> tests/security_plain.rs:200:7
[INFO] [stderr]     |
[INFO] [stderr] 200 |   let mut monitor = client.monitor_default().await?;
[INFO] [stderr]     |       ----^^^^^^^
[INFO] [stderr]     |       |
[INFO] [stderr]     |       help: remove this `mut`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> tests/security_plain.rs:255:29
[INFO] [stderr]     |
[INFO] [stderr] 255 |   if let Ok((client_socket, mut client_monitor)) = client_setup_result {
[INFO] [stderr]     |                             ----^^^^^^^^^^^^^^
[INFO] [stderr]     |                             |
[INFO] [stderr]     |                             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: constant `TEST_TIMEOUT` is never used
[INFO] [stderr]   --> tests/security_plain.rs:11:7
[INFO] [stderr]    |
[INFO] [stderr] 11 | const TEST_TIMEOUT: Duration = Duration::from_secs(5); // Timeout for async test operations
[INFO] [stderr]    |       ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variants `Off` and `Verbose` are never constructed
[INFO] [stderr]   --> examples/dealrtr_multitask.rs:30:3
[INFO] [stderr]    |
[INFO] [stderr] 29 | enum PrintLogLevel {
[INFO] [stderr]    |      ------------- variants in this enum
[INFO] [stderr] 30 |   Off,
[INFO] [stderr]    |   ^^^
[INFO] [stderr] 31 |   Info,
[INFO] [stderr] 32 |   Verbose,
[INFO] [stderr]    |   ^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `PrintLogLevel` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: field `id` is never read
[INFO] [stderr]    --> examples/dealrtr_multitask.rs:107:3
[INFO] [stderr]     |
[INFO] [stderr] 106 | struct DealerSenderStats {
[INFO] [stderr]     |        ----------------- field in this struct
[INFO] [stderr] 107 |   id: usize,
[INFO] [stderr]     |   ^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `DealerSenderStats` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: function `wait_for_event` is never used
[INFO] [stderr]  --> examples/common/mod.rs:8:14
[INFO] [stderr]   |
[INFO] [stderr] 8 | pub async fn wait_for_event(
[INFO] [stderr]   |              ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `wait_for_handshake_events` is never used
[INFO] [stderr]   --> examples/common/mod.rs:33:14
[INFO] [stderr]    |
[INFO] [stderr] 33 | pub async fn wait_for_handshake_events(
[INFO] [stderr]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `capacity` is never read
[INFO] [stderr]   --> examples/common/capacity_gate.rs:21:3
[INFO] [stderr]    |
[INFO] [stderr] 20 | pub(crate) struct CapacityGate {
[INFO] [stderr]    |                   ------------ field in this struct
[INFO] [stderr] 21 |   capacity: usize,
[INFO] [stderr]    |   ^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `CapacityGate` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: type alias `PermitGuard` is never used
[INFO] [stderr]   --> examples/common/capacity_gate.rs:25:17
[INFO] [stderr]    |
[INFO] [stderr] 25 | pub(crate) type PermitGuard<'a> = GenericSemaphoreReleaser<'a, RawMutex>;
[INFO] [stderr]    |                 ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `acquire`, `get_permits`, and `capacity` are never used
[INFO] [stderr]   --> examples/common/capacity_gate.rs:36:10
[INFO] [stderr]    |
[INFO] [stderr] 27 | impl CapacityGate {
[INFO] [stderr]    | ----------------- methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 36 |   pub fn acquire(&self) -> impl Future<Output = PermitGuard<'_>> {
[INFO] [stderr]    |          ^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 62 |   pub fn get_permits(&self) -> usize {
[INFO] [stderr]    |          ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 67 |   pub fn capacity(&self) -> usize {
[INFO] [stderr]    |          ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]    --> examples/dealrtr_multitask.rs:299:3
[INFO] [stderr]     |
[INFO] [stderr] 299 | /   tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stderr] 300 | |     .await
[INFO] [stderr] 301 | |     .expect("Context termination timed out!");
[INFO] [stderr]     | |_____________________________________________^
[INFO] [stderr]     |
[INFO] [stderr]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] help: use `let _ = ...` to ignore the resulting value
[INFO] [stderr]     |
[INFO] [stderr] 299 |   let _ = tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stderr]     |   +++++++
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/dealer_dealer.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/dealer_rep.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]  --> tests/dealer_rep.rs:6:7
[INFO] [stderr]   |
[INFO] [stderr] 6 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stderr]   |       ^^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `expected_connections`
[INFO] [stderr]    --> tests/shutdown_race.rs:611:7
[INFO] [stderr]     |
[INFO] [stderr] 611 |   let expected_connections = Arc::new(tokio::sync::Semaphore::new(TCP_NUM_PUSHERS)); // To count connections
[INFO] [stderr]     |       ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_expected_connections`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `NUM_PULLERS` is never used
[INFO] [stderr]   --> tests/shutdown_race.rs:26:7
[INFO] [stderr]    |
[INFO] [stderr] 26 | const NUM_PULLERS: usize = 2;
[INFO] [stderr]    |       ^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `TCP_NUM_PULLERS` is never used
[INFO] [stderr]    --> tests/shutdown_race.rs:546:7
[INFO] [stderr]     |
[INFO] [stderr] 546 | const TCP_NUM_PULLERS: usize = 1; // Must be 1 for TCP bind
[INFO] [stderr]     |       ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]    --> tests/shutdown_race.rs:486:3
[INFO] [stderr]     |
[INFO] [stderr] 486 |   pull_socket.close().await;
[INFO] [stderr]     |   ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] help: use `let _ = ...` to ignore the resulting value
[INFO] [stderr]     |
[INFO] [stderr] 486 |   let _ = pull_socket.close().await;
[INFO] [stderr]     |   +++++++
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]    --> tests/shutdown_race.rs:488:5
[INFO] [stderr]     |
[INFO] [stderr] 488 |     sck.close().await;
[INFO] [stderr]     |     ^^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr] help: use `let _ = ...` to ignore the resulting value
[INFO] [stderr]     |
[INFO] [stderr] 488 |     let _ = sck.close().await;
[INFO] [stderr]     |     +++++++
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Context`, `LINGER`, `RCVHWM`, and `SNDHWM`
[INFO] [stderr]  --> tests/socket_options.rs:2:36
[INFO] [stderr]   |
[INFO] [stderr] 2 |   socket::options::{LAST_ENDPOINT, LINGER, RCVHWM, SNDHWM},
[INFO] [stderr]   |                                    ^^^^^^  ^^^^^^  ^^^^^^
[INFO] [stderr] 3 |   Context, Msg, SocketType, ZmqError,
[INFO] [stderr]   |   ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: `rzmq` (test "transport_failures") generated 3 warnings (run `cargo fix --test "transport_failures" -p rzmq` to apply 2 suggestions)
[INFO] [stderr] warning: `rzmq` (test "req_rep_advanced") generated 1 warning (run `cargo fix --test "req_rep_advanced" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "dns") generated 1 warning (run `cargo fix --test "dns" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "pub_sub") generated 2 warnings (run `cargo fix --test "pub_sub" -p rzmq` to apply 2 suggestions)
[INFO] [stderr] warning: `rzmq` (test "tcp_corking") generated 1 warning
[INFO] [stderr] warning: `rzmq` (test "req_router") generated 2 warnings (run `cargo fix --test "req_router" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "security_plain") generated 4 warnings (run `cargo fix --test "security_plain" -p rzmq` to apply 2 suggestions)
[INFO] [stderr] warning: `rzmq` (example "dealrtr_multitask") generated 8 warnings
[INFO] [stderr] warning: `rzmq` (test "dealer_dealer") generated 1 warning (run `cargo fix --test "dealer_dealer" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "dealer_rep") generated 2 warnings (run `cargo fix --test "dealer_rep" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "shutdown_race") generated 5 warnings (run `cargo fix --test "shutdown_race" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "socket_options") generated 1 warning (run `cargo fix --test "socket_options" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: variants `Off` and `Verbose` are never constructed
[INFO] [stderr]   --> examples/dealrtr_multiclient.rs:31:3
[INFO] [stderr]    |
[INFO] [stderr] 30 | enum PrintLogLevel {
[INFO] [stderr]    |      ------------- variants in this enum
[INFO] [stderr] 31 |   Off,
[INFO] [stderr]    |   ^^^
[INFO] [stderr] 32 |   Info,
[INFO] [stderr] 33 |   Verbose,
[INFO] [stderr]    |   ^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `PrintLogLevel` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: field `id` is never read
[INFO] [stderr]    --> examples/dealrtr_multiclient.rs:122:3
[INFO] [stderr]     |
[INFO] [stderr] 121 | struct DealerSenderStats {
[INFO] [stderr]     |        ----------------- field in this struct
[INFO] [stderr] 122 |   id: usize,
[INFO] [stderr]     |   ^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `DealerSenderStats` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` that must be used
[INFO] [stderr]    --> examples/dealrtr_multiclient.rs:330:3
[INFO] [stderr]     |
[INFO] [stderr] 330 | /   tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stderr] 331 | |     .await
[INFO] [stderr] 332 | |     .expect("Context termination timed out!");
[INFO] [stderr]     | |_____________________________________________^
[INFO] [stderr]     |
[INFO] [stderr]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]     = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] help: use `let _ = ...` to ignore the resulting value
[INFO] [stderr]     |
[INFO] [stderr] 330 |   let _ = tokio::time::timeout(SHUTDOWN_TIMEOUT, ctx.term())
[INFO] [stderr]     |   +++++++
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `dealer_endpoint_uri` is never read
[INFO] [stderr]    --> tests/dealer_router_advanced.rs:331:33
[INFO] [stderr]     |
[INFO] [stderr] 331 |   let mut dealer_endpoint_uri = "".to_string(); // Store the specific endpoint URI seen by router
[INFO] [stderr]     |                                 ^^^^^^^^^^^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 351 |       } => dealer_endpoint_uri = format!("tcp://{}", peer_addr), // Should be tcp://<peer_ip>:<peer_port>
[INFO] [stderr]     |            ------------------- `dealer_endpoint_uri` is overwritten here before the previous value is read
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/router_router.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, MsgFlags, SocketType, ZmqError, socket::options::ROUTING_ID};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `LONG_TIMEOUT` is never used
[INFO] [stderr]  --> tests/router_router.rs:6:7
[INFO] [stderr]   |
[INFO] [stderr] 6 | const LONG_TIMEOUT: Duration = Duration::from_secs(2);
[INFO] [stderr]   |       ^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/push_pull_lifecycle.rs:1:12
[INFO] [stderr]   |
[INFO] [stderr] 1 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]  --> tests/push_pull_lifecycle.rs:9:7
[INFO] [stderr]   |
[INFO] [stderr] 9 | const SHORT_TIMEOUT: Duration = Duration::from_millis(250);
[INFO] [stderr]   |       ^^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: function `wait_for_handshake_events` is never used
[INFO] [stderr]   --> examples/common/mod.rs:33:14
[INFO] [stderr]    |
[INFO] [stderr] 33 | pub async fn wait_for_handshake_events(
[INFO] [stderr]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: struct `OwnedPermitGuard` is never constructed
[INFO] [stderr]  --> examples/common/capacity_gate.rs:8:19
[INFO] [stderr]   |
[INFO] [stderr] 8 | pub(crate) struct OwnedPermitGuard {
[INFO] [stderr]   |                   ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `CapacityGate` is never constructed
[INFO] [stderr]   --> examples/common/capacity_gate.rs:20:19
[INFO] [stderr]    |
[INFO] [stderr] 20 | pub(crate) struct CapacityGate {
[INFO] [stderr]    |                   ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `acquire`, `acquire_owned`, `release`, `get_permits`, and `capacity` are never used
[INFO] [stderr]   --> examples/common/capacity_gate.rs:28:10
[INFO] [stderr]    |
[INFO] [stderr] 27 | impl CapacityGate {
[INFO] [stderr]    | ----------------- associated items in this implementation
[INFO] [stderr] 28 |   pub fn new(capacity: usize) -> Self {
[INFO] [stderr]    |          ^^^
[INFO] [stderr] ...
[INFO] [stderr] 36 |   pub fn acquire(&self) -> impl Future<Output = PermitGuard<'_>> {
[INFO] [stderr]    |          ^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 42 |   pub fn acquire_owned(self: Arc<Self>) -> impl Future<Output = OwnedPermitGuard> {
[INFO] [stderr]    |          ^^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 55 |   pub fn release(&self) {
[INFO] [stderr]    |          ^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 62 |   pub fn get_permits(&self) -> usize {
[INFO] [stderr]    |          ^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 67 |   pub fn capacity(&self) -> usize {
[INFO] [stderr]    |          ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/req_rep.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: constant `SHORT_TIMEOUT` is never used
[INFO] [stderr]  --> tests/req_rep.rs:7:7
[INFO] [stderr]   |
[INFO] [stderr] 7 | const SHORT_TIMEOUT: Duration = Duration::from_millis(200);
[INFO] [stderr]   |       ^^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/dealer_router.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, MsgFlags, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::collections::HashSet`
[INFO] [stderr]  --> tests/dealer_router.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | use std::collections::HashSet;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Context`
[INFO] [stderr]  --> tests/inproc_minimal.rs:3:12
[INFO] [stderr]   |
[INFO] [stderr] 3 | use rzmq::{Context, Msg, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Context` and `Socket`
[INFO] [stderr]  --> tests/push_pull.rs:4:12
[INFO] [stderr]   |
[INFO] [stderr] 4 | use rzmq::{Context, Msg, Socket, SocketType, ZmqError};
[INFO] [stderr]   |            ^^^^^^^       ^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: `rzmq` (example "dealrtr_multiclient") generated 8 warnings (5 duplicates)
[INFO] [stderr] warning: `rzmq` (test "dealer_router_advanced") generated 1 warning
[INFO] [stderr] warning: `rzmq` (test "router_router") generated 2 warnings (run `cargo fix --test "router_router" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (lib test) generated 76 warnings (76 duplicates)
[INFO] [stderr] warning: `rzmq` (test "push_pull_lifecycle") generated 2 warnings (run `cargo fix --test "push_pull_lifecycle" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (example "req_rep_flurry") generated 5 warnings (1 duplicate)
[INFO] [stderr] warning: `rzmq` (test "req_rep") generated 2 warnings (run `cargo fix --test "req_rep" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "dealer_router") generated 2 warnings (run `cargo fix --test "dealer_router" -p rzmq` to apply 2 suggestions)
[INFO] [stderr] warning: `rzmq` (test "inproc_minimal") generated 1 warning (run `cargo fix --test "inproc_minimal" -p rzmq` to apply 1 suggestion)
[INFO] [stderr] warning: `rzmq` (test "push_pull") generated 1 warning (run `cargo fix --test "push_pull" -p rzmq` to apply 1 suggestion)
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.33s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/rzmq-1159a6f40c89fae4)
[INFO] [stdout] 
[INFO] [stdout] running 6 tests
[INFO] [stdout] test socket::patterns::framing::tests::test_router_auto_encode ... ok
[INFO] [stdout] test socket::patterns::framing::tests::test_dealer_auto_encode ... ok
[INFO] [stdout] test runtime::waitgroup::tests::test_waitgroup_wait_on_zero ... ok
[INFO] [stdout] test runtime::waitgroup::tests::test_waitgroup_add_done_wait ... ok
[INFO] [stdout] test runtime::waitgroup::tests::test_waitgroup_add_after_wait_starts ... ok
[INFO] [stdout] test runtime::waitgroup::tests::test_waitgroup_done_panic_on_zero - should panic ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.08s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/common.rs (/opt/rustwide/target/debug/deps/common-1597be361a95e37c)
[INFO] [stdout] 
[INFO] [stdout] running 0 tests
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/dealer_dealer.rs (/opt/rustwide/target/debug/deps/dealer_dealer-5f1199e084af6143)
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test test_dealer_dealer_tcp_bidirectional ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.22s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/dealer_rep.rs (/opt/rustwide/target/debug/deps/dealer_rep-e8065a6212b3d4a2)
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test test_dealer_rep_tcp_basic ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.23s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/dealer_router.rs (/opt/rustwide/target/debug/deps/dealer_router-62f64ae5f8262441)
[INFO] [stdout] 
[INFO] [stdout] running 3 tests
[INFO] [stdout] test test_dealer_router_inproc_basic ... ok
[INFO] [stdout] test test_dealer_router_ipc_basic ... ok
[INFO] [stdout] test test_dealer_router_tcp_basic ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.24s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/dealer_router_advanced.rs (/opt/rustwide/target/debug/deps/dealer_router_advanced-785302c47b4aa08b)
[INFO] [stdout] 
[INFO] [stdout] running 8 tests
[INFO] [stdout] test test_dealer_router_router_sends_to_unknown_mandatory_true ... ok
[INFO] [stdout] test test_router_routing_after_peer_disconnect ... ok
[INFO] [stdout] test test_dealer_router_dealer_disconnects_router_sends ... ok
[INFO] [stdout] test test_dealer_routing_after_peer_disconnect ... ok
[INFO] [stdout] test test_dealer_router_router_sends_to_unknown_mandatory_false ... ok
[INFO] [stdout] test test_dealer_router_multi_part_dealer_to_router ... ok
[INFO] [stdout] test test_dealer_router_multiple_dealers ... ok
[INFO] [stdout] test test_dealer_router_multi_part_router_to_dealer ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 5.36s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/dns.rs (/opt/rustwide/target/debug/deps/dns-10c52e798c08cceb)
[INFO] [stdout] 
[INFO] [stdout] running 4 tests
[INFO] [stdout] test test_dns_bind_to_non_existent_host_fails ... ok
[INFO] [stdout] test test_dns_bind_to_localhost_succeeds ... ok
[INFO] [stdout] test test_dns_connect_to_localhost_succeeds ... ok
[INFO] [stderr]      Running tests/inproc_minimal.rs (/opt/rustwide/target/debug/deps/inproc_minimal-d1768361544f4d6b)
[INFO] [stdout] test test_dns_connect_to_non_existent_host_fails ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.66s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test test_inproc_minimal_pipe ... ok
[INFO] [stderr]      Running tests/lifecycle.rs (/opt/rustwide/target/debug/deps/lifecycle-b1de3efd3f2117f1)
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.13s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 4 tests
[INFO] [stdout] test test_context_term_closes_sockets ... ok
[INFO] [stdout] test test_concurrent_term_and_op ... ok
[INFO] [stdout] test test_socket_explicit_close_triggers_disconnect_event ... ok
[INFO] [stdout] test test_socket_close_stops_connection ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.51s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/pub_sub.rs (/opt/rustwide/target/debug/deps/pub_sub-5b2c7cd8e59e796a)
[INFO] [stdout] 
[INFO] [stdout] running 8 tests
[INFO] [stdout] test test_pub_sub_ipc_basic ... ok
[INFO] [stdout] test test_pub_sub_tcp_basic ... ok
[INFO] [stdout] test test_pub_sub_subscriber_disconnects ... ok
[INFO] [stdout] test test_pub_sub_tcp_multiple_subs ... ok
[INFO] [stdout] test test_pub_sub_inproc_basic ... ok
[INFO] [stdout] test test_pub_sub_late_subscriber ... ok
[INFO] [stdout] test test_pub_sub_unsubscribe ... ok
[INFO] [stdout] test test_pub_sub_tcp_topic_filter ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 4.94s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/push_pull.rs (/opt/rustwide/target/debug/deps/push_pull-be55bdb407e758b3)
[INFO] [stdout] 
[INFO] [stdout] running 9 tests
[INFO] [stdout] test test_push_pull_inproc_multiple_clients ... ok
[INFO] [stdout] test test_push_pull_inproc_basic_messaging ... ok
[INFO] [stdout] test test_push_pull_ipc_basic_messaging ... ok
[INFO] [stdout] test test_push_pull_tcp_basic_messaging ... ok
[INFO] [stdout] test test_push_pull_tcp_connect_before_bind ... ok
[INFO] [stdout] test test_push_pull_hwm_sndtimeo_0 ... ok
[INFO] [stdout] test test_push_pull_tcp_multiple_messages ... ok
[INFO] [stdout] test test_pull_rcvtimeo ... ok
[INFO] [stderr]      Running tests/push_pull_lifecycle.rs (/opt/rustwide/target/debug/deps/push_pull_lifecycle-397cea63796c1b13)
[INFO] [stdout] test test_push_sndtimeo_positive_no_peer ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.73s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test test_push_pull_explicit_close_then_term ... ok
[INFO] [stderr]      Running tests/reconnect_tests.rs (/opt/rustwide/target/debug/deps/reconnect_tests-4a6a7ab4d9b5d5b3)
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.32s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 3 tests
[INFO] [stdout] test test_push_pull_reconnect_advanced_style ... ok
[INFO] [stdout] test test_req_rep_reconnect_advanced_style ... ok
[INFO] [stdout] test test_dealer_router_multiple_disconnect_reconnect_cycle ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 5.07s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/req_rep.rs (/opt/rustwide/target/debug/deps/req_rep-ed264dc98fec59c5)
[INFO] [stdout] 
[INFO] [stdout] running 4 tests
[INFO] [stdout] test test_req_rep_inproc_basic ... ok
[INFO] [stdout] test test_req_rep_ipc_basic ... ok
[INFO] [stdout] test test_req_rep_tcp_basic ... ok
[INFO] [stderr]      Running tests/req_rep_advanced.rs (/opt/rustwide/target/debug/deps/req_rep_advanced-0f95d782ffa06d42)
[INFO] [stdout] test test_req_rep_tcp_connect_before_bind ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.34s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 5 tests
[INFO] [stdout] test test_req_rep_rep_send_without_request ... ok
[INFO] [stdout] test test_req_rep_req_send_without_recv ... ok
[INFO] [stdout] test test_req_rep_req_disconnects_before_reply ... ok
[INFO] [stdout] test test_req_rep_rep_recv_without_request ... ok
[INFO] [stdout] test test_req_rep_rep_disconnects_while_req_waiting ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 1.32s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/req_router.rs (/opt/rustwide/target/debug/deps/req_router-a8a89c9c36b249af)
[INFO] [stdout] 
[INFO] [stdout] running 3 tests
[INFO] [stdout] test test_req_router_multiple_req_clients ... ok
[INFO] [stdout] test test_req_router_rzmq_to_rzmq ... ok
[INFO] [stdout] test test_req_router_req_disconnects_before_reply ... ok
[INFO] [stderr]      Running tests/router_router.rs (/opt/rustwide/target/debug/deps/router_router-a71bb39424859a4a)
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.43s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 2 tests
[INFO] [stdout] test test_router_router_tcp_forwarding ... ok
[INFO] [stdout] test test_router_chain_forwarding ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.32s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/security_plain.rs (/opt/rustwide/target/debug/deps/security_plain-1bf572eeb0c9e767)
[INFO] [stdout] 
[INFO] [stdout] running 5 tests
[INFO] [stdout] test test_plain_security_enforcement ... ok
[INFO] [stdout] test test_null_client_to_plain_server_fails ... ok
[INFO] [stdout] test test_plain_client_no_credentials ... ok
[INFO] [stdout] test test_plain_client_to_null_server_fails ... ok
[INFO] [stdout] test test_plain_successful_handshake ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.41s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/shutdown_race.rs (/opt/rustwide/target/debug/deps/shutdown_race-ca6f607c372d24ad)
[INFO] [stdout] 
[INFO] [stdout] running 3 tests
[INFO] [stdout] test test_chaotic_shutdown_tcp ... ok
[INFO] [stdout] test test_chaotic_shutdown ... ok
[INFO] [stdout] test test_push_pull_concurrent_shutdown_race ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 3.18s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/socket_options.rs (/opt/rustwide/target/debug/deps/socket_options-29f9804be68092a7)
[INFO] [stdout] 
[INFO] [stdout] running 3 tests
[INFO] [stdout] test test_option_last_endpoint_inproc ... ok
[INFO] [stdout] test test_option_last_endpoint_ipc ... ok
[INFO] [stdout] test test_option_last_endpoint_tcp_ephemeral_port ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.28s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/tcp_corking.rs (/opt/rustwide/target/debug/deps/tcp_corking-a697b3668cf1ccb6)
[INFO] [stdout] 
[INFO] [stdout] running 6 tests
[INFO] [stdout] test test_tcp_cork_state_management_with_more_flag ... ok
[INFO] [stdout] test test_tcp_cork_single_part_message_cork_disabled ... ok
[INFO] [stdout] test test_tcp_cork_multi_part_message_cork_disabled ... ok
[INFO] [stdout] test test_tcp_cork_multi_part_message_cork_enabled ... ok
[INFO] [stdout] test test_tcp_cork_single_part_message_cork_enabled ... ok
[INFO] [stdout] test test_tcp_cork_ping_pong_interaction ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.92s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/transport_failures.rs (/opt/rustwide/target/debug/deps/transport_failures-01b2a0dd8c5e07c1)
[INFO] [stdout] 
[INFO] [stdout] running 4 tests
[INFO] [stdout] test test_ipc_bind_fail_directory_exists ... ok
[INFO] [stdout] test test_ipc_bind_succeeds_over_existing_file ... ok
[INFO] [stdout] test test_tcp_connect_fail_no_listener ... ok
[INFO] [stdout] test test_ipc_connect_fail_no_listener ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.32s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests rzmq
[INFO] [stderr] warning: the usage of Script Group `Greek` in this crate consists solely of mixed script confusables
[INFO] [stderr]    --> src/throttle/mod.rs:129:11
[INFO] [stderr]     |
[INFO] [stderr] 129 |       let α = self.shared.config.adaptive_learning_rate;
[INFO] [stderr]     |           ^
[INFO] [stderr]     |
[INFO] [stderr]     = note: the usage includes 'α' (U+03B1)
[INFO] [stderr]     = note: please recheck to make sure their usages are indeed what you want
[INFO] [stderr]     = note: `#[warn(mixed_script_confusables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: 1 warning emitted
[INFO] [stderr] 
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test src/throttle/mod.rs - throttle (line 27) ... ignored
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 1 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stdout] all doctests ran in 0.33s; merged doctests compilation took 0.32s
[INFO] running `Command { std: "docker" "inspect" "1ec33a9b88db8aae9b049b2dd64edfb1c7f3e31419b111e02d9c2c9e48a8e6de", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "1ec33a9b88db8aae9b049b2dd64edfb1c7f3e31419b111e02d9c2c9e48a8e6de", kill_on_drop: false }`
[INFO] [stdout] 1ec33a9b88db8aae9b049b2dd64edfb1c7f3e31419b111e02d9c2c9e48a8e6de
