[INFO] fetching crate rzmq 0.5.13... [INFO] testing rzmq-0.5.13 against master#d933cf483edf1605142ac6899ff32536c0ad8b22 for pr-150933 [INFO] extracting crate rzmq 0.5.13 into /workspace/builds/worker-5-tc1/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-5-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate rzmq 0.5.13 on toolchain d933cf483edf1605142ac6899ff32536c0ad8b22 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "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" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded chacha20 v0.9.1 [INFO] [stderr] Downloaded poly1305 v0.8.0 [INFO] [stderr] Downloaded cipher v0.4.4 [INFO] [stderr] Downloaded inout v0.1.4 [INFO] [stderr] Downloaded universal-hash v0.5.1 [INFO] [stderr] Downloaded io_uring_buf_ring v0.2.3 [INFO] [stderr] Downloaded serial_test v3.3.1 [INFO] [stderr] Downloaded alloca v0.4.0 [INFO] [stderr] Downloaded salsa20 v0.10.2 [INFO] [stderr] Downloaded eventfd v0.2.0 [INFO] [stderr] Downloaded atomic_float v1.1.0 [INFO] [stderr] Downloaded serial_test_derive v3.3.1 [INFO] [stderr] Downloaded ghash v0.5.1 [INFO] [stderr] Downloaded ctr v0.9.2 [INFO] [stderr] Downloaded criterion-plot v0.8.1 [INFO] [stderr] Downloaded bench_matrix v0.2.1 [INFO] [stderr] Downloaded seize v0.5.1 [INFO] [stderr] Downloaded papaya v0.2.3 [INFO] [stderr] Downloaded futures-intrusive v0.5.0 [INFO] [stderr] Downloaded io-uring v0.7.11 [INFO] [stderr] Downloaded fibre v0.5.1 [INFO] [stderr] Downloaded criterion v0.8.1 [INFO] [stderr] Downloaded aes-gcm v0.10.3 [INFO] [stderr] Downloaded aes v0.8.4 [INFO] [stderr] Downloaded zerocopy-derive v0.8.37 [INFO] [stderr] Downloaded xs_x25519-dalek v2.0.2 [INFO] [stderr] Downloaded polyval v0.6.2 [INFO] [stderr] Downloaded chacha20poly1305 v0.10.1 [INFO] [stderr] Downloaded zerocopy v0.8.37 [INFO] [stderr] Downloaded xs_curve25519-dalek v4.1.4 [INFO] [stderr] Downloaded aead v0.5.2 [INFO] [stderr] Downloaded page_size v0.6.0 [INFO] [stderr] Downloaded dryoc v0.7.1 [INFO] [stderr] Downloaded snow v0.9.6 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 692a55b5c192dcae9cf87ad93effcaf1aa6d3af7cb20e7709712423bb26ee858 [INFO] running `Command { std: "docker" "start" "-a" "692a55b5c192dcae9cf87ad93effcaf1aa6d3af7cb20e7709712423bb26ee858", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "692a55b5c192dcae9cf87ad93effcaf1aa6d3af7cb20e7709712423bb26ee858", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "692a55b5c192dcae9cf87ad93effcaf1aa6d3af7cb20e7709712423bb26ee858", kill_on_drop: false }` [INFO] [stdout] 692a55b5c192dcae9cf87ad93effcaf1aa6d3af7cb20e7709712423bb26ee858 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 75c939740215253979b57f22a0e97664fd83228cf1bbaa373803e61f5accfa8c [INFO] running `Command { std: "docker" "start" "-a" "75c939740215253979b57f22a0e97664fd83228cf1bbaa373803e61f5accfa8c", kill_on_drop: false }` [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling getrandom v0.3.4 [INFO] [stderr] Compiling zerocopy v0.8.37 [INFO] [stderr] Compiling bytes v1.11.0 [INFO] [stderr] Compiling hashbrown v0.14.5 [INFO] [stderr] Compiling zeroize v1.8.2 [INFO] [stderr] Compiling atomic_float v1.1.0 [INFO] [stderr] Compiling linked-hash-map v0.5.6 [INFO] [stderr] Compiling parking_lot_core v0.9.12 [INFO] [stderr] Compiling socket2 v0.6.2 [INFO] [stderr] Compiling mio v1.1.1 [INFO] [stderr] Compiling seize v0.5.1 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling tokio-macros v2.6.0 [INFO] [stderr] Compiling tracing-attributes v0.1.31 [INFO] [stderr] Compiling thiserror-impl v2.0.18 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling async-trait v0.1.89 [INFO] [stderr] Compiling async-recursion v1.1.1 [INFO] [stderr] Compiling parking_lot v0.12.5 [INFO] [stderr] Compiling papaya v0.2.3 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling rand_core v0.9.5 [INFO] [stderr] Compiling dashmap v5.5.3 [INFO] [stderr] Compiling tokio v1.49.0 [INFO] [stderr] Compiling futures-intrusive v0.5.0 [INFO] [stderr] Compiling tracing v0.1.44 [INFO] [stderr] Compiling thiserror v2.0.18 [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 ppv-lite86 v0.2.21 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling rand v0.9.2 [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> = 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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [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 = None; [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/ipc.rs:238:54 [INFO] [stdout] | [INFO] [stdout] 238 | let mut loop_error_to_report: Option = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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> = 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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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>, [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; [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) -> Result<(Box, Option>), 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> { [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 { [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, [INFO] [stdout] 8 | notify: Arc, [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) -> 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>> { [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, 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( [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 { [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 FairQueue { [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) { [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 { [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, [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, [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 27.37s [INFO] running `Command { std: "docker" "inspect" "75c939740215253979b57f22a0e97664fd83228cf1bbaa373803e61f5accfa8c", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "75c939740215253979b57f22a0e97664fd83228cf1bbaa373803e61f5accfa8c", kill_on_drop: false }` [INFO] [stdout] 75c939740215253979b57f22a0e97664fd83228cf1bbaa373803e61f5accfa8c [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] c62e8c83a4d1eb742a301674fecb7da01f5da50ce1c6dfd81660bd735137f1ba [INFO] running `Command { std: "docker" "start" "-a" "c62e8c83a4d1eb742a301674fecb7da01f5da50ce1c6dfd81660bd735137f1ba", kill_on_drop: false }` [INFO] [stderr] Compiling zerocopy v0.8.37 [INFO] [stderr] Compiling regex-syntax v0.8.8 [INFO] [stderr] Compiling cc v1.2.55 [INFO] [stderr] Compiling tracing-core v0.1.36 [INFO] [stderr] Compiling anstyle v1.0.13 [INFO] [stderr] Compiling ciborium-io v0.2.2 [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_lex v0.7.7 [INFO] [stderr] Compiling serde_json v1.0.149 [INFO] [stderr] Compiling itertools v0.13.0 [INFO] [stderr] Compiling log v0.4.29 [INFO] [stderr] Compiling page_size v0.6.0 [INFO] [stderr] Compiling anes v0.1.6 [INFO] [stderr] Compiling sdd v3.0.10 [INFO] [stderr] Compiling sharded-slab v0.1.7 [INFO] [stderr] Compiling serial_test_derive v3.3.1 [INFO] [stderr] Compiling clap_builder v4.5.56 [INFO] [stderr] Compiling itertools v0.12.1 [INFO] [stderr] Compiling thread_local v1.1.9 [INFO] [stderr] Compiling scc v2.4.0 [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 regex-automata v0.4.13 [INFO] [stderr] Compiling alloca v0.4.0 [INFO] [stderr] Compiling criterion-plot v0.8.1 [INFO] [stderr] Compiling serial_test v3.3.1 [INFO] [stderr] Compiling clap v4.5.56 [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-stream v0.1.18 [INFO] [stderr] Compiling tokio-util v0.7.18 [INFO] [stderr] Compiling tokio-test v0.4.5 [INFO] [stderr] Compiling half v2.7.1 [INFO] [stderr] Compiling ppv-lite86 v0.2.21 [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 criterion v0.8.1 [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] [stderr] Compiling bench_matrix v0.2.1 [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> = 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/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> = None; [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/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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [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 = None; [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/ipc.rs:238:54 [INFO] [stdout] | [INFO] [stdout] 238 | let mut loop_error_to_report: Option = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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> = 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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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>, [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; [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) -> Result<(Box, Option>), 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> { [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 { [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, [INFO] [stdout] 8 | notify: Arc, [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) -> 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>> { [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, 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( [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 { [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 FairQueue { [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) { [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 { [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, [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, [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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [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 = None; [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/ipc.rs:238:54 [INFO] [stdout] | [INFO] [stdout] 238 | let mut loop_error_to_report: Option = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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> = 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 = None; [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being 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>, [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; [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) -> Result<(Box, Option>), 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> { [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 { [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, [INFO] [stdout] 8 | notify: Arc, [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) -> 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>> { [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, 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( [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 { [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 FairQueue { [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) { [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 { [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, [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, [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 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/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: 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: 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: 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 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: 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/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: 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: 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: 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: 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: 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: 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: 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] [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: 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: 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> { [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: 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: 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_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: 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> { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 42 | pub fn acquire_owned(self: Arc) -> impl Future { [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: 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/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: 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] | ^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = help: maybe it is overwritten before being read? [INFO] [stdout] = note: `#[warn(unused_assignments)]` (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: 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> { [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: 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] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 04s [INFO] running `Command { std: "docker" "inspect" "c62e8c83a4d1eb742a301674fecb7da01f5da50ce1c6dfd81660bd735137f1ba", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c62e8c83a4d1eb742a301674fecb7da01f5da50ce1c6dfd81660bd735137f1ba", kill_on_drop: false }` [INFO] [stdout] c62e8c83a4d1eb742a301674fecb7da01f5da50ce1c6dfd81660bd735137f1ba [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+d933cf483edf1605142ac6899ff32536c0ad8b22" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 5be2e6d4a61fb6aedfc2f161e7277234144a9ae1fcd7d270b82deef0dc8c1a35 [INFO] running `Command { std: "docker" "start" "-a" "5be2e6d4a61fb6aedfc2f161e7277234144a9ae1fcd7d270b82deef0dc8c1a35", 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> = 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 = None; [INFO] [stderr] | ^^^^ [INFO] [stderr] | [INFO] [stderr] = help: maybe it is overwritten before being read? [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 = None; [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/ipc.rs:238:54 [INFO] [stderr] | [INFO] [stderr] 238 | let mut loop_error_to_report: Option = None; [INFO] [stderr] | ^^^^ [INFO] [stderr] | [INFO] [stderr] = help: maybe it is overwritten before being 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> = 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 = None; [INFO] [stderr] | ^^^^ [INFO] [stderr] | [INFO] [stderr] = help: maybe it is overwritten before being 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>, [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; [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) -> Result<(Box, Option>), 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> { [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 { [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, [INFO] [stderr] 8 | notify: Arc, [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) -> 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>> { [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, 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( [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 { [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 FairQueue { [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) { [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 { [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, [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, [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/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: 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/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: 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: 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` 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: 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/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: 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: 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> { [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: 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] | ^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = help: maybe it is overwritten before being read? [INFO] [stderr] = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default [INFO] [stderr] [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 "dealer_dealer") generated 1 warning (run `cargo fix --test "dealer_dealer" -p rzmq` to apply 1 suggestion) [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 "security_plain") generated 4 warnings (run `cargo fix --test "security_plain" -p rzmq` to apply 2 suggestions) [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 "push_pull") generated 1 warning (run `cargo fix --test "push_pull" -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` (lib test) generated 76 warnings (76 duplicates) [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 "inproc_minimal") generated 1 warning (run `cargo fix --test "inproc_minimal" -p rzmq` to apply 1 suggestion) [INFO] [stderr] warning: `rzmq` (example "dealrtr_multitask") generated 8 warnings [INFO] [stderr] warning: `rzmq` (test "dealer_router_advanced") generated 1 warning [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: 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: 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> { [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] ... [INFO] [stderr] 42 | pub fn acquire_owned(self: Arc) -> impl Future { [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/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: `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/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: 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 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: 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/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: `rzmq` (example "dealrtr_multiclient") generated 8 warnings (5 duplicates) [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` (example "req_rep_flurry") generated 5 warnings (1 duplicate) [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` (test "dns") generated 1 warning (run `cargo fix --test "dns" -p rzmq` to apply 1 suggestion) [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` (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 "socket_options") generated 1 warning (run `cargo fix --test "socket_options" -p rzmq` to apply 1 suggestion) [INFO] [stderr] warning: `rzmq` (test "tcp_corking") generated 1 warning [INFO] [stderr] warning: `rzmq` (test "transport_failures") generated 3 warnings (run `cargo fix --test "transport_failures" -p rzmq` to apply 2 suggestions) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.37s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/rzmq-9903fc75884b5f6e) [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_after_wait_starts ... ok [INFO] [stdout] test runtime::waitgroup::tests::test_waitgroup_add_done_wait ... 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.10s [INFO] [stdout] [INFO] [stderr] Running tests/common.rs (/opt/rustwide/target/debug/deps/common-e692692bbcf2d339) [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-7d59faa75c1dff69) [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stderr] Running tests/dealer_rep.rs (/opt/rustwide/target/debug/deps/dealer_rep-f1ad3c94cbbe8f8c) [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.23s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stderr] Running tests/dealer_router.rs (/opt/rustwide/target/debug/deps/dealer_router-0eea38748fafe14c) [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.21s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 3 tests [INFO] [stdout] test test_dealer_router_inproc_basic ... ok [INFO] [stdout] test test_dealer_router_tcp_basic ... ok [INFO] [stdout] test test_dealer_router_ipc_basic ... ok [INFO] [stderr] Running tests/dealer_router_advanced.rs (/opt/rustwide/target/debug/deps/dealer_router_advanced-75f11e86118aa828) [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] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test test_dealer_router_multi_part_dealer_to_router ... 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_router_routing_after_peer_disconnect ... ok [INFO] [stdout] test test_dealer_router_multi_part_router_to_dealer ... ok [INFO] [stdout] test test_dealer_router_router_sends_to_unknown_mandatory_true ... ok [INFO] [stderr] Running tests/dns.rs (/opt/rustwide/target/debug/deps/dns-429acf20b7d1cd3d) [INFO] [stdout] test test_dealer_router_multiple_dealers ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 4.13s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test test_dns_bind_to_non_existent_host_fails ... ok [INFO] [stdout] test test_dns_connect_to_localhost_succeeds ... ok [INFO] [stdout] test test_dns_connect_to_non_existent_host_fails ... ok [INFO] [stdout] test test_dns_bind_to_localhost_succeeds ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.68s [INFO] [stdout] [INFO] [stderr] Running tests/inproc_minimal.rs (/opt/rustwide/target/debug/deps/inproc_minimal-cdef83a281dc4485) [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stdout] test test_inproc_minimal_pipe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.12s [INFO] [stdout] [INFO] [stderr] Running tests/lifecycle.rs (/opt/rustwide/target/debug/deps/lifecycle-2f7ff9f86a1c737d) [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.42s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stderr] Running tests/pub_sub.rs (/opt/rustwide/target/debug/deps/pub_sub-d5a19bafbf320d62) [INFO] [stdout] test test_pub_sub_tcp_multiple_subs ... ok [INFO] [stdout] test test_pub_sub_late_subscriber ... ok [INFO] [stdout] test test_pub_sub_tcp_topic_filter ... ok [INFO] [stdout] test test_pub_sub_unsubscribe ... 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_inproc_basic ... ok [INFO] [stdout] test test_pub_sub_ipc_basic ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 4.87s [INFO] [stdout] [INFO] [stderr] Running tests/push_pull.rs (/opt/rustwide/target/debug/deps/push_pull-63a598bc4bf90ae0) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test test_push_pull_inproc_basic_messaging ... ok [INFO] [stdout] test test_push_pull_inproc_multiple_clients ... 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] [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] [stderr] Running tests/push_pull_lifecycle.rs (/opt/rustwide/target/debug/deps/push_pull_lifecycle-71c600c58fd60f72) [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stdout] test test_push_pull_explicit_close_then_term ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.35s [INFO] [stdout] [INFO] [stderr] Running tests/reconnect_tests.rs (/opt/rustwide/target/debug/deps/reconnect_tests-8cd44ede97db7651) [INFO] [stdout] [INFO] [stdout] running 3 tests [INFO] [stdout] test test_req_rep_reconnect_advanced_style ... ok [INFO] [stdout] test test_dealer_router_multiple_disconnect_reconnect_cycle ... ok [INFO] [stdout] test test_push_pull_reconnect_advanced_style ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 5.12s [INFO] [stdout] [INFO] [stderr] Running tests/req_rep.rs (/opt/rustwide/target/debug/deps/req_rep-0cc224e019c55a05) [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] [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] [stderr] Running tests/req_rep_advanced.rs (/opt/rustwide/target/debug/deps/req_rep_advanced-39bb1a91651bdf20) [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test test_req_rep_req_send_without_recv ... ok [INFO] [stdout] test test_req_rep_rep_send_without_request ... ok [INFO] [stdout] test test_req_rep_rep_recv_without_request ... ok [INFO] [stdout] test test_req_rep_req_disconnects_before_reply ... ok [INFO] [stderr] Running tests/req_router.rs (/opt/rustwide/target/debug/deps/req_router-d29c86302bbf35e7) [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.33s [INFO] [stdout] [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] [stdout] [INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.44s [INFO] [stdout] [INFO] [stderr] Running tests/router_router.rs (/opt/rustwide/target/debug/deps/router_router-f4352fe9a06b07b2) [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] [stderr] Running tests/security_plain.rs (/opt/rustwide/target/debug/deps/security_plain-f828194b78fc2a02) [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.36s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test test_plain_security_enforcement ... ok [INFO] [stdout] test test_plain_client_to_null_server_fails ... ok [INFO] [stdout] test test_plain_successful_handshake ... ok [INFO] [stdout] test test_null_client_to_plain_server_fails ... ok [INFO] [stdout] test test_plain_client_no_credentials ... ok [INFO] [stderr] Running tests/shutdown_race.rs (/opt/rustwide/target/debug/deps/shutdown_race-e5955774c1f342e4) [INFO] [stdout] [INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.44s [INFO] [stdout] [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 5.74s [INFO] [stdout] [INFO] [stderr] Running tests/socket_options.rs (/opt/rustwide/target/debug/deps/socket_options-d1356bd49b3a66c4) [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-e17bffa5d32efde9) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test test_tcp_cork_single_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_state_management_with_more_flag ... ok [INFO] [stdout] test test_tcp_cork_multi_part_message_cork_disabled ... 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.97s [INFO] [stdout] [INFO] [stderr] Running tests/transport_failures.rs (/opt/rustwide/target/debug/deps/transport_failures-4da8c6460854cc3a) [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_ipc_connect_fail_no_listener ... ok [INFO] [stdout] test test_tcp_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.33s [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.47s; merged doctests compilation took 0.46s [INFO] running `Command { std: "docker" "inspect" "5be2e6d4a61fb6aedfc2f161e7277234144a9ae1fcd7d270b82deef0dc8c1a35", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "5be2e6d4a61fb6aedfc2f161e7277234144a9ae1fcd7d270b82deef0dc8c1a35", kill_on_drop: false }` [INFO] [stdout] 5be2e6d4a61fb6aedfc2f161e7277234144a9ae1fcd7d270b82deef0dc8c1a35