[INFO] fetching crate gneiss-mqtt 0.3.0... [INFO] checking gneiss-mqtt-0.3.0 against master#ab869e094a907cc5d19b4080f22eccaf347f1f95 for pr-129604 [INFO] extracting crate gneiss-mqtt 0.3.0 into /workspace/builds/worker-7-tc1/source [INFO] validating manifest of crates.io crate gneiss-mqtt 0.3.0 on toolchain ab869e094a907cc5d19b4080f22eccaf347f1f95 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ab869e094a907cc5d19b4080f22eccaf347f1f95" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate gneiss-mqtt 0.3.0 [INFO] finished tweaking crates.io crate gneiss-mqtt 0.3.0 [INFO] tweaked toml for crates.io crate gneiss-mqtt 0.3.0 written to /workspace/builds/worker-7-tc1/source/Cargo.toml [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ab869e094a907cc5d19b4080f22eccaf347f1f95" "generate-lockfile" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Locking 161 packages to latest compatible versions [INFO] [stderr] Adding addr2line v0.22.0 (latest: v0.24.1) [INFO] [stderr] Adding bindgen v0.69.4 (latest: v0.70.1) [INFO] [stderr] Adding core-foundation v0.9.4 (latest: v0.10.0) [INFO] [stderr] Adding foreign-types v0.3.2 (latest: v0.5.0) [INFO] [stderr] Adding foreign-types-shared v0.1.1 (latest: v0.3.1) [INFO] [stderr] Adding generic-array v0.14.7 (latest: v1.1.0) [INFO] [stderr] Adding gimli v0.29.0 (latest: v0.31.0) [INFO] [stderr] Adding hermit-abi v0.3.9 (latest: v0.4.0) [INFO] [stderr] Adding http v0.2.12 (latest: v1.1.0) [INFO] [stderr] Adding idna v0.5.0 (latest: v1.0.2) [INFO] [stderr] Adding itertools v0.12.1 (latest: v0.13.0) [INFO] [stderr] Adding linux-raw-sys v0.4.14 (latest: v0.6.5) [INFO] [stderr] Adding miniz_oxide v0.7.4 (latest: v0.8.0) [INFO] [stderr] Adding rustc-hash v1.1.0 (latest: v2.0.0) [INFO] [stderr] Adding rustls-native-certs v0.7.3 (latest: v0.8.0) [INFO] [stderr] Adding tokio-tungstenite v0.20.1 (latest: v0.23.1) [INFO] [stderr] Adding tungstenite v0.20.1 (latest: v0.24.0) [INFO] [stderr] Adding wasi v0.11.0+wasi-snapshot-preview1 (latest: v0.13.2+wasi-0.2.1) [INFO] [stderr] Adding which v4.4.2 (latest: v6.0.3) [INFO] [stderr] Adding windows-sys v0.52.0 (latest: v0.59.0) [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ab869e094a907cc5d19b4080f22eccaf347f1f95" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded stream-ws v0.1.1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:923055f121b5182466d55868a8b05e67af8ba4a3a3f6bad814e953ca3cd3ac2a" "/opt/rustwide/cargo-home/bin/cargo" "+ab869e094a907cc5d19b4080f22eccaf347f1f95" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] bdb15058b4cf208453a576577912c4c2c72e6bb4cc5dffddb09591f19ce6d91f [INFO] running `Command { std: "docker" "start" "-a" "bdb15058b4cf208453a576577912c4c2c72e6bb4cc5dffddb09591f19ce6d91f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "bdb15058b4cf208453a576577912c4c2c72e6bb4cc5dffddb09591f19ce6d91f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "bdb15058b4cf208453a576577912c4c2c72e6bb4cc5dffddb09591f19ce6d91f", kill_on_drop: false }` [INFO] [stdout] bdb15058b4cf208453a576577912c4c2c72e6bb4cc5dffddb09591f19ce6d91f [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-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:923055f121b5182466d55868a8b05e67af8ba4a3a3f6bad814e953ca3cd3ac2a" "/opt/rustwide/cargo-home/bin/cargo" "+ab869e094a907cc5d19b4080f22eccaf347f1f95" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] be8703a3062f4edc732a29f5bbe113c9347c88b17728ba3f2de62357d9cba55e [INFO] running `Command { std: "docker" "start" "-a" "be8703a3062f4edc732a29f5bbe113c9347c88b17728ba3f2de62357d9cba55e", kill_on_drop: false }` [INFO] [stderr] Checking once_cell v1.19.0 [INFO] [stderr] Checking allocator-api2 v0.2.18 [INFO] [stderr] Checking assert_matches v1.5.0 [INFO] [stderr] Compiling ahash v0.8.11 [INFO] [stderr] Checking zerocopy v0.7.35 [INFO] [stderr] Checking ppv-lite86 v0.2.20 [INFO] [stderr] Checking hashbrown v0.14.5 [INFO] [stderr] Checking rand_chacha v0.3.1 [INFO] [stderr] Checking rand v0.8.5 [INFO] [stderr] Checking lru v0.12.4 [INFO] [stderr] Checking uuid v1.10.0 [INFO] [stderr] Checking gneiss-mqtt v0.3.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused import: `crate::client::*` [INFO] [stdout] --> src/config.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use crate::client::*; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::client::*` [INFO] [stdout] --> src/config.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use crate::client::*; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `InboundAliasResolver` is never constructed [INFO] [stdout] --> src/alias.rs:256:19 [INFO] [stdout] | [INFO] [stdout] 256 | pub(crate) struct InboundAliasResolver { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated items `new`, `reset_for_new_connection`, and `resolve_topic_alias` are never used [INFO] [stdout] --> src/alias.rs:263:12 [INFO] [stdout] | [INFO] [stdout] 262 | impl InboundAliasResolver { [INFO] [stdout] | ------------------------- associated items in this implementation [INFO] [stdout] 263 | pub fn new(maximum_alias_value: u16) -> InboundAliasResolver { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 270 | pub(crate) fn reset_for_new_connection(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 274 | pub(crate) fn resolve_topic_alias(&mut self, alias: &Option, topic: &mut String) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: type alias `ResponseHandler` is never used [INFO] [stdout] --> src/client.rs:477:17 [INFO] [stdout] | [INFO] [stdout] 477 | pub(crate) type ResponseHandler = Box MqttResult<()> + Send + Sync>; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `PublishOptionsInternal` is never constructed [INFO] [stdout] --> src/client.rs:479:19 [INFO] [stdout] | [INFO] [stdout] 479 | pub(crate) struct PublishOptionsInternal { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `SubscribeOptionsInternal` is never constructed [INFO] [stdout] --> src/client.rs:484:19 [INFO] [stdout] | [INFO] [stdout] 484 | pub(crate) struct SubscribeOptionsInternal { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `UnsubscribeOptionsInternal` is never constructed [INFO] [stdout] --> src/client.rs:489:19 [INFO] [stdout] | [INFO] [stdout] 489 | pub(crate) struct UnsubscribeOptionsInternal { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `StopOptionsInternal` is never constructed [INFO] [stdout] --> src/client.rs:495:19 [INFO] [stdout] | [INFO] [stdout] 495 | pub(crate) struct StopOptionsInternal { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `StopOptionsInternal` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `OperationOptions` is never used [INFO] [stdout] --> src/client.rs:499:17 [INFO] [stdout] | [INFO] [stdout] 499 | pub(crate) enum OperationOptions { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ClientImplState` is never used [INFO] [stdout] --> src/client.rs:511:17 [INFO] [stdout] | [INFO] [stdout] 511 | pub(crate) enum ClientImplState { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: type alias `CallbackSpawnerFunction` is never used [INFO] [stdout] --> src/client.rs:532:17 [INFO] [stdout] | [INFO] [stdout] 532 | pub(crate) type CallbackSpawnerFunction = Box, Arc) + Send + Sync>; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MqttClientImpl` is never constructed [INFO] [stdout] --> src/client.rs:534:19 [INFO] [stdout] | [INFO] [stdout] 534 | pub(crate) struct MqttClientImpl { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/client.rs:562:19 [INFO] [stdout] | [INFO] [stdout] 560 | impl MqttClientImpl { [INFO] [stdout] | ------------------- associated items in this implementation [INFO] [stdout] 561 | [INFO] [stdout] 562 | pub(crate) fn new(client_config: MqttClientOptions, connect_config: ConnectOptions, callback_spawner: CallbackSpawnerFunction) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 597 | pub(crate) fn connect_timeout(&self) -> &Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 601 | pub(crate) fn get_current_state(&self) -> ClientImplState { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 605 | pub(crate) fn get_protocol_state(&self) -> ProtocolStateType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 609 | fn add_listener(&mut self, id: u64, listener: ClientEventListener) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 613 | fn remove_listener(&mut self, id: u64) { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 617 | fn broadcast_event(&self, event: Arc) { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 625 | pub(crate) fn apply_error(&mut self, error: MqttError) { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 633 | pub(crate) fn handle_incoming_operation(&mut self, operation: OperationOptions) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 706 | fn dispatch_packet_events(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 740 | pub(crate) fn handle_incoming_bytes(&mut self, bytes: &[u8]) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 754 | pub(crate) fn handle_write_completion(&mut self) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 766 | pub(crate) fn handle_service(&mut self, outbound_data: &mut Vec) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 777 | fn clamp_reconnect_period(&self, mut reconnect_period: Duration) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 785 | fn compute_uniform_jitter_period(&self, max_nanos: u128) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 791 | pub(crate) fn advance_reconnect_period(&mut self) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 805 | pub(crate) fn compute_optional_state_transition(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 843 | pub(crate) fn get_next_connected_service_time(&mut self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 851 | fn emit_connection_attempt_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 858 | fn emit_connection_success_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 869 | fn emit_connection_failure_event(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 882 | fn emit_disconnection_event(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 895 | fn emit_stopped_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 902 | fn reset_state_for_new_connection(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 912 | pub(crate) fn transition_to_state(&mut self, mut new_state: ClientImplState) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `endpoint` and `port` are never read [INFO] [stdout] --> src/config.rs:37:16 [INFO] [stdout] | [INFO] [stdout] 36 | pub struct HttpProxyOptions { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 37 | pub(crate) endpoint: String, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 38 | pub(crate) port: u16, [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `HttpProxyOptions` has a derived impl for the trait `Clone`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `options` is never read [INFO] [stdout] --> src/config.rs:141:16 [INFO] [stdout] | [INFO] [stdout] 140 | pub struct TlsOptions { [INFO] [stdout] | ---------- field in this struct [INFO] [stdout] 141 | pub(crate) options: TlsData [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `TlsOptions` has a derived impl for the trait `Clone`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `to_connect_packet` is never used [INFO] [stdout] --> src/config.rs:304:19 [INFO] [stdout] | [INFO] [stdout] 301 | impl ConnectOptions { [INFO] [stdout] | ------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 304 | pub(crate) fn to_connect_packet(&self, connected_previously: bool) -> ConnectPacket { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `normalize` is never used [INFO] [stdout] --> src/config.rs:589:19 [INFO] [stdout] | [INFO] [stdout] 588 | impl ReconnectOptions { [INFO] [stdout] | --------------------- method in this implementation [INFO] [stdout] 589 | pub(crate) fn normalize(&mut self) { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `endpoint` and `port` are never read [INFO] [stdout] --> src/config.rs:737:5 [INFO] [stdout] | [INFO] [stdout] 736 | pub struct GenericClientBuilder { [INFO] [stdout] | -------------------- fields in this struct [INFO] [stdout] 737 | endpoint: String, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 738 | port: u16, [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `TlsConfiguration` is never used [INFO] [stdout] --> src/config.rs:749:17 [INFO] [stdout] | [INFO] [stdout] 749 | pub(crate) enum TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_tls_impl_from_options` is never used [INFO] [stdout] --> src/config.rs:758:4 [INFO] [stdout] | [INFO] [stdout] 758 | fn get_tls_impl_from_options(tls_options: Option<&TlsOptions>) -> TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_tls_impl` is never used [INFO] [stdout] --> src/config.rs:822:8 [INFO] [stdout] | [INFO] [stdout] 773 | impl GenericClientBuilder { [INFO] [stdout] | ------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 822 | fn get_tls_impl(&self) -> TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `Endpoint` is never constructed [INFO] [stdout] --> src/config.rs:884:19 [INFO] [stdout] | [INFO] [stdout] 884 | pub(crate) struct Endpoint { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `new` is never used [INFO] [stdout] --> src/config.rs:890:19 [INFO] [stdout] | [INFO] [stdout] 889 | impl Endpoint { [INFO] [stdout] | ------------- associated function in this implementation [INFO] [stdout] 890 | pub(crate) fn new(endpoint: &str, port: u16) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `make_addr` is never used [INFO] [stdout] --> src/config.rs:898:15 [INFO] [stdout] | [INFO] [stdout] 898 | pub(crate) fn make_addr(endpoint: &str, port: u16) -> std::io::Result { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_endpoints` is never used [INFO] [stdout] --> src/config.rs:904:15 [INFO] [stdout] | [INFO] [stdout] 904 | pub(crate) fn compute_endpoints(endpoint: String, port: u16, http_proxy_options: &Option) -> (Endpoint, Option src/decode.rs:33:7 [INFO] [stdout] | [INFO] [stdout] 33 | const DECODE_BUFFER_DEFAULT_SIZE : usize = 16 * 1024; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `DecoderState` is never used [INFO] [stdout] --> src/decode.rs:105:6 [INFO] [stdout] | [INFO] [stdout] 105 | enum DecoderState { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `DecoderDirective` is never used [INFO] [stdout] --> src/decode.rs:113:6 [INFO] [stdout] | [INFO] [stdout] 113 | enum DecoderDirective { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `DecodingContext` is never constructed [INFO] [stdout] --> src/decode.rs:119:19 [INFO] [stdout] | [INFO] [stdout] 119 | pub(crate) struct DecodingContext<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `Decoder` is never constructed [INFO] [stdout] --> src/decode.rs:125:19 [INFO] [stdout] | [INFO] [stdout] 125 | pub(crate) struct Decoder { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_packet` is never used [INFO] [stdout] --> src/decode.rs:135:4 [INFO] [stdout] | [INFO] [stdout] 135 | fn decode_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/decode.rs:163:12 [INFO] [stdout] | [INFO] [stdout] 162 | impl Decoder { [INFO] [stdout] | ------------ associated items in this implementation [INFO] [stdout] 163 | pub fn new() -> Decoder { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 172 | pub fn reset_for_new_connection(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 176 | fn process_read_packet_type<'a>(&mut self, bytes: &'a [u8]) -> (DecoderDirective, &'a[u8]) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 187 | fn process_read_total_remaining_length<'a>(&mut self, bytes: &'a[u8], context: &DecodingContext) -> (DecoderDirective, &'a[u8]) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 220 | fn process_read_packet_body<'a>(&mut self, bytes: &'a[u8], context: &mut DecodingContext) -> (DecoderDirective, &'a[u8]) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 250 | pub fn decode_bytes(&mut self, bytes: &[u8], context: &mut DecodingContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 282 | fn reset_for_new_packet(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 288 | fn reset(&mut self) { [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `DecodeVliResult` is never used [INFO] [stdout] --> src/decode.rs:297:17 [INFO] [stdout] | [INFO] [stdout] 297 | pub(crate) enum DecodeVliResult<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_vli` is never used [INFO] [stdout] --> src/decode.rs:302:15 [INFO] [stdout] | [INFO] [stdout] 302 | pub(crate) fn decode_vli(buffer: &[u8]) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_vli_into_mutable` is never used [INFO] [stdout] --> src/decode.rs:327:15 [INFO] [stdout] | [INFO] [stdout] 327 | pub(crate) fn decode_vli_into_mutable<'a>(buffer: &'a[u8], value: &mut usize) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_length_prefixed_string` is never used [INFO] [stdout] --> src/decode.rs:341:15 [INFO] [stdout] | [INFO] [stdout] 341 | pub(crate) fn decode_length_prefixed_string<'a>(bytes: &'a[u8], value: &mut String) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_length_prefixed_string` is never used [INFO] [stdout] --> src/decode.rs:359:15 [INFO] [stdout] | [INFO] [stdout] 359 | pub(crate) fn decode_optional_length_prefixed_string<'a>(bytes: &'a[u8], value: &mut Option) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_length_prefixed_bytes` is never used [INFO] [stdout] --> src/decode.rs:412:15 [INFO] [stdout] | [INFO] [stdout] 412 | pub(crate) fn decode_optional_length_prefixed_bytes<'a>(bytes: &'a[u8], value: &mut Option>) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_user_property` is never used [INFO] [stdout] --> src/decode.rs:463:15 [INFO] [stdout] | [INFO] [stdout] 463 | pub(crate) fn decode_user_property<'a>(bytes: &'a[u8], properties: &mut Option>) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_u8_as_bool` is never used [INFO] [stdout] --> src/decode.rs:490:15 [INFO] [stdout] | [INFO] [stdout] 490 | pub(crate) fn decode_optional_u8_as_bool<'a>(bytes: &'a[u8], value: &mut Option) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_u8_as_enum` is never used [INFO] [stdout] --> src/decode.rs:513:15 [INFO] [stdout] | [INFO] [stdout] 513 | pub(crate) fn decode_u8_as_enum<'a, T>(bytes: &'a[u8], value: &mut T, converter: fn(u8) -> MqttResult) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_u8_as_enum` is never used [INFO] [stdout] --> src/decode.rs:524:15 [INFO] [stdout] | [INFO] [stdout] 524 | pub(crate) fn decode_optional_u8_as_enum<'a, T>(bytes: &'a[u8], value: &mut Option, converter: fn(u8) -> MqttResult) -> MqttResult<... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_u16` is never used [INFO] [stdout] --> src/decode.rs:540:15 [INFO] [stdout] | [INFO] [stdout] 540 | pub(crate) fn decode_u16<'a>(bytes: &'a[u8], value: &mut u16) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_u16` is never used [INFO] [stdout] --> src/decode.rs:551:15 [INFO] [stdout] | [INFO] [stdout] 551 | pub(crate) fn decode_optional_u16<'a>(bytes: &'a[u8], value: &mut Option) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_optional_u32` is never used [INFO] [stdout] --> src/decode.rs:567:15 [INFO] [stdout] | [INFO] [stdout] 567 | pub(crate) fn decode_optional_u32<'a>(bytes: &'a[u8], value: &mut Option) -> MqttResult<&'a[u8]> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `EncodingContext` is never constructed [INFO] [stdout] --> src/encode.rs:29:19 [INFO] [stdout] | [INFO] [stdout] 29 | pub(crate) struct EncodingContext { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `EncodingContext` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_encoding_steps` is never used [INFO] [stdout] --> src/encode.rs:33:4 [INFO] [stdout] | [INFO] [stdout] 33 | fn write_encoding_steps(mqtt_packet: &MqttPacket, context: &EncodingContext, steps: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `EncodeResult` is never used [INFO] [stdout] --> src/encode.rs:56:17 [INFO] [stdout] | [INFO] [stdout] 56 | pub(crate) enum EncodeResult { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `Encoder` is never constructed [INFO] [stdout] --> src/encode.rs:61:19 [INFO] [stdout] | [INFO] [stdout] 61 | pub(crate) struct Encoder { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated items `new`, `reset`, and `encode` are never used [INFO] [stdout] --> src/encode.rs:66:12 [INFO] [stdout] | [INFO] [stdout] 65 | impl Encoder { [INFO] [stdout] | ------------ associated items in this implementation [INFO] [stdout] 66 | pub fn new() -> Encoder { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 72 | pub fn reset(&mut self, packet: &MqttPacket, context: &EncodingContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^ [INFO] [stdout] ... [INFO] [stdout] 78 | pub fn encode( [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `EncodingStep` is never used [INFO] [stdout] --> src/encode.rs:106:17 [INFO] [stdout] | [INFO] [stdout] 106 | pub(crate) enum EncodingStep { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: static `MAXIMUM_VARIABLE_LENGTH_INTEGER` is never used [INFO] [stdout] --> src/encode.rs:481:12 [INFO] [stdout] | [INFO] [stdout] 481 | pub static MAXIMUM_VARIABLE_LENGTH_INTEGER: usize = (1 << 28) - 1; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_user_properties_length` is never used [INFO] [stdout] --> src/encode.rs:483:8 [INFO] [stdout] | [INFO] [stdout] 483 | pub fn compute_user_properties_length(properties: &Option>) -> usize { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_variable_length_integer_encode_size` is never used [INFO] [stdout] --> src/encode.rs:497:8 [INFO] [stdout] | [INFO] [stdout] 497 | pub fn compute_variable_length_integer_encode_size(value: usize) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `encode_vli` is never used [INFO] [stdout] --> src/encode.rs:511:4 [INFO] [stdout] | [INFO] [stdout] 511 | fn encode_vli(value: u32, dest: &mut Vec) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `process_byte_slice_encoding` is never used [INFO] [stdout] --> src/encode.rs:534:4 [INFO] [stdout] | [INFO] [stdout] 534 | fn process_byte_slice_encoding(bytes: &[u8], offset: usize, dest: &mut Vec) -> usize { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `process_encoding_step` is never used [INFO] [stdout] --> src/encode.rs:549:15 [INFO] [stdout] | [INFO] [stdout] 549 | pub(crate) fn process_encoding_step( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated functions are never used [INFO] [stdout] --> src/error.rs:203:19 [INFO] [stdout] | [INFO] [stdout] 201 | impl MqttError { [INFO] [stdout] | -------------- associated functions in this implementation [INFO] [stdout] 202 | [INFO] [stdout] 203 | pub(crate) fn new_unimplemented(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 227 | pub(crate) fn new_encoding_failure(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 235 | pub(crate) fn new_protocol_error(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 243 | pub(crate) fn new_inbound_topic_alias_not_valid(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 251 | pub(crate) fn new_connection_establishment_failure(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 259 | pub(crate) fn new_internal_state_error(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 267 | pub(crate) fn new_connection_closed(source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 275 | pub(crate) fn new_offline_queue_policy_failed() -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 282 | pub(crate) fn new_ack_timeout() -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 289 | pub(crate) fn new_client_closed() -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 296 | pub(crate) fn new_user_initiated_disconnect() -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 334 | pub(crate) fn new_packet_validation(packet_type: PacketType, source: impl Into>) -> Self { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `fold_mqtt_result` is never used [INFO] [stdout] --> src/error.rs:536:15 [INFO] [stdout] | [INFO] [stdout] 536 | pub(crate) fn fold_mqtt_result(base: MqttResult, new_result: MqttResult) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_packet_type_for_logging` is never used [INFO] [stdout] --> src/logging.rs:137:4 [INFO] [stdout] | [INFO] [stdout] 137 | fn get_packet_type_for_logging(packet: &MqttPacket) -> &'static str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `log_packet` is never used [INFO] [stdout] --> src/logging.rs:179:15 [INFO] [stdout] | [INFO] [stdout] 179 | pub(crate) fn log_packet(prefix: &str, packet: &MqttPacket) { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `AuthPacket` is never constructed [INFO] [stdout] --> src/mqtt/mod.rs:768:19 [INFO] [stdout] | [INFO] [stdout] 768 | pub(crate) struct AuthPacket { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `AuthPacket` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ConnectPacket` is never constructed [INFO] [stdout] --> src/mqtt/mod.rs:946:19 [INFO] [stdout] | [INFO] [stdout] 946 | pub(crate) struct ConnectPacket { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `ConnectPacket` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `PingreqPacket` is never constructed [INFO] [stdout] --> src/mqtt/mod.rs:1163:19 [INFO] [stdout] | [INFO] [stdout] 1163 | pub(crate) struct PingreqPacket {} [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `PingreqPacket` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `PingrespPacket` is never constructed [INFO] [stdout] --> src/mqtt/mod.rs:1167:19 [INFO] [stdout] | [INFO] [stdout] 1167 | pub(crate) struct PingrespPacket {} [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `PingrespPacket` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `MqttPacket` is never used [INFO] [stdout] --> src/mqtt/mod.rs:1695:17 [INFO] [stdout] | [INFO] [stdout] 1695 | pub(crate) enum MqttPacket { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_auth_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/auth.rs:20:4 [INFO] [stdout] | [INFO] [stdout] 20 | fn compute_auth_packet_length_properties(packet: &AuthPacket) -> MqttResult<(u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_auth_packet_authentication_method` is never used [INFO] [stdout] --> src/mqtt/auth.rs:38:4 [INFO] [stdout] | [INFO] [stdout] 38 | fn get_auth_packet_authentication_method(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_auth_packet_authentication_data` is never used [INFO] [stdout] --> src/mqtt/auth.rs:42:4 [INFO] [stdout] | [INFO] [stdout] 42 | fn get_auth_packet_authentication_data(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_auth_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/auth.rs:46:4 [INFO] [stdout] | [INFO] [stdout] 46 | fn get_auth_packet_reason_string(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_auth_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/auth.rs:50:4 [INFO] [stdout] | [INFO] [stdout] 50 | fn get_auth_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_auth_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/auth.rs:61:15 [INFO] [stdout] | [INFO] [stdout] 61 | pub(crate) fn write_auth_encoding_steps(packet: &AuthPacket, _: &EncodingContext, steps: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_auth_properties` is never used [INFO] [stdout] --> src/mqtt/auth.rs:83:4 [INFO] [stdout] | [INFO] [stdout] 83 | fn decode_auth_properties(property_bytes: &[u8], packet : &mut AuthPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_auth_packet` is never used [INFO] [stdout] --> src/mqtt/auth.rs:105:15 [INFO] [stdout] | [INFO] [stdout] 105 | pub(crate) fn decode_auth_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_auth_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/auth.rs:135:15 [INFO] [stdout] | [INFO] [stdout] 135 | pub(crate) fn validate_auth_packet_outbound(packet: &AuthPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_auth_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/auth.rs:152:15 [INFO] [stdout] | [INFO] [stdout] 152 | pub(crate) fn validate_auth_packet_outbound_internal(packet: &AuthPacket, context: &OutboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_auth_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/auth.rs:164:15 [INFO] [stdout] | [INFO] [stdout] 164 | pub(crate) fn validate_auth_packet_inbound_internal(packet: &AuthPacket, _: &InboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_connack_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/connack.rs:131:15 [INFO] [stdout] | [INFO] [stdout] 131 | pub(crate) fn write_connack_encoding_steps(_: &ConnackPacket, _: &EncodingContext, _: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_connack_properties` is never used [INFO] [stdout] --> src/mqtt/connack.rs:135:4 [INFO] [stdout] | [INFO] [stdout] 135 | fn decode_connack_properties(property_bytes: &[u8], packet : &mut ConnackPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_connack_packet` is never used [INFO] [stdout] --> src/mqtt/connack.rs:170:15 [INFO] [stdout] | [INFO] [stdout] 170 | pub(crate) fn decode_connack_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_connack_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/connack.rs:213:15 [INFO] [stdout] | [INFO] [stdout] 213 | pub(crate) fn validate_connack_packet_inbound_internal(packet: &ConnackPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_client_id` is never used [INFO] [stdout] --> src/mqtt/connect.rs:18:4 [INFO] [stdout] | [INFO] [stdout] 18 | fn get_connect_packet_client_id(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_authentication_method` is never used [INFO] [stdout] --> src/mqtt/connect.rs:22:4 [INFO] [stdout] | [INFO] [stdout] 22 | fn get_connect_packet_authentication_method(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_authentication_data` is never used [INFO] [stdout] --> src/mqtt/connect.rs:26:4 [INFO] [stdout] | [INFO] [stdout] 26 | fn get_connect_packet_authentication_data(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_username` is never used [INFO] [stdout] --> src/mqtt/connect.rs:30:4 [INFO] [stdout] | [INFO] [stdout] 30 | fn get_connect_packet_username(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_password` is never used [INFO] [stdout] --> src/mqtt/connect.rs:34:4 [INFO] [stdout] | [INFO] [stdout] 34 | fn get_connect_packet_password(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/connect.rs:38:4 [INFO] [stdout] | [INFO] [stdout] 38 | fn get_connect_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_content_type` is never used [INFO] [stdout] --> src/mqtt/connect.rs:48:4 [INFO] [stdout] | [INFO] [stdout] 48 | fn get_connect_packet_will_content_type(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_response_topic` is never used [INFO] [stdout] --> src/mqtt/connect.rs:60:4 [INFO] [stdout] | [INFO] [stdout] 60 | fn get_connect_packet_will_response_topic(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_correlation_data` is never used [INFO] [stdout] --> src/mqtt/connect.rs:72:4 [INFO] [stdout] | [INFO] [stdout] 72 | fn get_connect_packet_will_correlation_data(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_topic` is never used [INFO] [stdout] --> src/mqtt/connect.rs:84:4 [INFO] [stdout] | [INFO] [stdout] 84 | fn get_connect_packet_will_topic(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_payload` is never used [INFO] [stdout] --> src/mqtt/connect.rs:94:4 [INFO] [stdout] | [INFO] [stdout] 94 | fn get_connect_packet_will_payload(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_packet_will_user_property` is never used [INFO] [stdout] --> src/mqtt/connect.rs:106:4 [INFO] [stdout] | [INFO] [stdout] 106 | fn get_connect_packet_will_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: static `MQTT5_CONNECT_PROTOCOL_BYTES` is never used [INFO] [stdout] --> src/mqtt/connect.rs:118:8 [INFO] [stdout] | [INFO] [stdout] 118 | static MQTT5_CONNECT_PROTOCOL_BYTES: [u8; 7] = [0, 4, 77, 81, 84, 84, 5]; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_connect_protocol_bytes` is never used [INFO] [stdout] --> src/mqtt/connect.rs:119:4 [INFO] [stdout] | [INFO] [stdout] 119 | fn get_connect_protocol_bytes(_: &MqttPacket) -> &'static [u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_connect_flags` is never used [INFO] [stdout] --> src/mqtt/connect.rs:123:4 [INFO] [stdout] | [INFO] [stdout] 123 | fn compute_connect_flags(packet: &ConnectPacket) -> u8 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_connect_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/connect.rs:149:4 [INFO] [stdout] | [INFO] [stdout] 149 | fn compute_connect_packet_length_properties(packet: &ConnectPacket) -> MqttResult<(u32, u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_connect_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/connect.rs:209:15 [INFO] [stdout] | [INFO] [stdout] 209 | pub(crate) fn write_connect_encoding_steps(packet: &ConnectPacket, _: &EncodingContext, steps: &mut VecDeque) -> MqttResult... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_connect_packet` is never used [INFO] [stdout] --> src/mqtt/connect.rs:428:15 [INFO] [stdout] | [INFO] [stdout] 428 | pub(crate) fn decode_connect_packet(_: u8, _: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_connect_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/connect.rs:432:15 [INFO] [stdout] | [INFO] [stdout] 432 | pub(crate) fn validate_connect_packet_outbound(packet: &ConnectPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_disconnect_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:18:4 [INFO] [stdout] | [INFO] [stdout] 18 | fn compute_disconnect_packet_length_properties(packet: &DisconnectPacket) -> MqttResult<(u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_disconnect_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:39:4 [INFO] [stdout] | [INFO] [stdout] 39 | fn get_disconnect_packet_reason_string(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_disconnect_packet_server_reference` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:43:4 [INFO] [stdout] | [INFO] [stdout] 43 | fn get_disconnect_packet_server_reference(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_disconnect_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:47:4 [INFO] [stdout] | [INFO] [stdout] 47 | fn get_disconnect_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_disconnect_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:58:15 [INFO] [stdout] | [INFO] [stdout] 58 | pub(crate) fn write_disconnect_encoding_steps(packet: &DisconnectPacket, _: &EncodingContext, steps: &mut VecDeque) -> Mqtt... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_disconnect_properties` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:86:4 [INFO] [stdout] | [INFO] [stdout] 86 | fn decode_disconnect_properties(property_bytes: &[u8], packet : &mut DisconnectPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_disconnect_packet` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:108:15 [INFO] [stdout] | [INFO] [stdout] 108 | pub(crate) fn decode_disconnect_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_disconnect_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:142:15 [INFO] [stdout] | [INFO] [stdout] 142 | pub(crate) fn validate_disconnect_packet_outbound(packet: &DisconnectPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_disconnect_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:151:15 [INFO] [stdout] | [INFO] [stdout] 151 | pub(crate) fn validate_disconnect_packet_outbound_internal(packet: &DisconnectPacket, context: &OutboundValidationContext) -> MqttResult<... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_disconnect_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/disconnect.rs:178:15 [INFO] [stdout] | [INFO] [stdout] 178 | pub(crate) fn validate_disconnect_packet_inbound_internal(packet: &DisconnectPacket, _: &InboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_pingreq_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/pingreq.rs:15:15 [INFO] [stdout] | [INFO] [stdout] 15 | pub(crate) fn write_pingreq_encoding_steps(_: &PingreqPacket, _: &EncodingContext, steps: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pingreq_packet` is never used [INFO] [stdout] --> src/mqtt/pingreq.rs:41:15 [INFO] [stdout] | [INFO] [stdout] 41 | pub(crate) fn decode_pingreq_packet(_: u8, _: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_pingresp_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/pingresp.rs:24:15 [INFO] [stdout] | [INFO] [stdout] 24 | pub(crate) fn write_pingresp_encoding_steps(_: &PingrespPacket, _: &EncodingContext, _: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PINGRESP_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/pingresp.rs:28:7 [INFO] [stdout] | [INFO] [stdout] 28 | const PINGRESP_FIRST_BYTE : u8 = PACKET_TYPE_PINGRESP << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pingresp_packet` is never used [INFO] [stdout] --> src/mqtt/pingresp.rs:30:15 [INFO] [stdout] | [INFO] [stdout] 30 | pub(crate) fn decode_pingresp_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_puback_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/puback.rs:18:37 [INFO] [stdout] | [INFO] [stdout] 18 | define_ack_packet_lengths_function!(compute_puback_packet_length_properties, PubackPacket, PubackReasonCode); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_lengths_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_puback_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/puback.rs:19:43 [INFO] [stdout] | [INFO] [stdout] 19 | define_ack_packet_reason_string_accessor!(get_puback_packet_reason_string, Puback); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_reason_string_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_puback_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/puback.rs:20:43 [INFO] [stdout] | [INFO] [stdout] 20 | define_ack_packet_user_property_accessor!(get_puback_packet_user_property, Puback); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_user_property_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_puback_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/puback.rs:23:34 [INFO] [stdout] | [INFO] [stdout] 23 | define_ack_packet_encoding_impl!(write_puback_encoding_steps, PubackPacket, PubackReasonCode, PUBACK_FIRST_BYTE, compute_puback_packet_le... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_encoding_impl` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_puback_properties` is never used [INFO] [stdout] --> src/mqtt/puback.rs:25:47 [INFO] [stdout] | [INFO] [stdout] 25 | define_ack_packet_decode_properties_function!(decode_puback_properties, PubackPacket, "Puback"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_properties_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_puback_packet` is never used [INFO] [stdout] --> src/mqtt/puback.rs:26:36 [INFO] [stdout] | [INFO] [stdout] 26 | define_ack_packet_decode_function!(decode_puback_packet, Puback, PubackPacket, "Puback", PUBACK_FIRST_BYTE, convert_u8_to_puback_reason_c... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_puback_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/puback.rs:28:24 [INFO] [stdout] | [INFO] [stdout] 28 | validate_ack_outbound!(validate_puback_packet_outbound, PubackPacket, PacketType::Puback, "Puback"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_puback_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/puback.rs:29:33 [INFO] [stdout] | [INFO] [stdout] 29 | validate_ack_outbound_internal!(validate_puback_packet_outbound_internal, PubackPacket, PacketType::Puback, compute_puback_packet_length_... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_puback_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/puback.rs:30:32 [INFO] [stdout] | [INFO] [stdout] 30 | validate_ack_inbound_internal!(validate_puback_packet_inbound_internal, PubackPacket, PacketType::Puback, "Puback"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_pubcomp_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:18:37 [INFO] [stdout] | [INFO] [stdout] 18 | define_ack_packet_lengths_function!(compute_pubcomp_packet_length_properties, PubcompPacket, PubcompReasonCode); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_lengths_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubcomp_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:19:43 [INFO] [stdout] | [INFO] [stdout] 19 | define_ack_packet_reason_string_accessor!(get_pubcomp_packet_reason_string, Pubcomp); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_reason_string_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubcomp_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:20:43 [INFO] [stdout] | [INFO] [stdout] 20 | define_ack_packet_user_property_accessor!(get_pubcomp_packet_user_property, Pubcomp); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_user_property_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_pubcomp_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:23:34 [INFO] [stdout] | [INFO] [stdout] 23 | define_ack_packet_encoding_impl!(write_pubcomp_encoding_steps, PubcompPacket, PubcompReasonCode, PUBCOMP_FIRST_BYTE, compute_pubcomp_pack... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_encoding_impl` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubcomp_properties` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:25:47 [INFO] [stdout] | [INFO] [stdout] 25 | define_ack_packet_decode_properties_function!(decode_pubcomp_properties, PubcompPacket, "Pubcomp"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_properties_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubcomp_packet` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:26:36 [INFO] [stdout] | [INFO] [stdout] 26 | define_ack_packet_decode_function!(decode_pubcomp_packet, Pubcomp, PubcompPacket, "Pubcomp", PUBCOMP_FIRST_BYTE, convert_u8_to_pubcomp_re... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubcomp_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:28:24 [INFO] [stdout] | [INFO] [stdout] 28 | validate_ack_outbound!(validate_pubcomp_packet_outbound, PubcompPacket, PacketType::Pubcomp, "Pubcomp"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubcomp_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:29:33 [INFO] [stdout] | [INFO] [stdout] 29 | validate_ack_outbound_internal!(validate_pubcomp_packet_outbound_internal, PubcompPacket, PacketType::Pubcomp, compute_pubcomp_packet_len... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubcomp_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubcomp.rs:30:32 [INFO] [stdout] | [INFO] [stdout] 30 | validate_ack_inbound_internal!(validate_pubcomp_packet_inbound_internal, PubcompPacket, PacketType::Pubcomp, "Pubcomp"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_publish_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/publish.rs:19:4 [INFO] [stdout] | [INFO] [stdout] 19 | fn compute_publish_packet_length_properties(packet: &PublishPacket, alias_resolution: &OutboundAliasResolution) -> MqttResult<(u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_publish_fixed_header_first_byte` is never used [INFO] [stdout] --> src/mqtt/publish.rs:78:4 [INFO] [stdout] | [INFO] [stdout] 78 | fn compute_publish_fixed_header_first_byte(packet: &PublishPacket) -> u8 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_response_topic` is never used [INFO] [stdout] --> src/mqtt/publish.rs:94:4 [INFO] [stdout] | [INFO] [stdout] 94 | fn get_publish_packet_response_topic(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_correlation_data` is never used [INFO] [stdout] --> src/mqtt/publish.rs:98:4 [INFO] [stdout] | [INFO] [stdout] 98 | fn get_publish_packet_correlation_data(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_content_type` is never used [INFO] [stdout] --> src/mqtt/publish.rs:102:4 [INFO] [stdout] | [INFO] [stdout] 102 | fn get_publish_packet_content_type(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_topic` is never used [INFO] [stdout] --> src/mqtt/publish.rs:106:4 [INFO] [stdout] | [INFO] [stdout] 106 | fn get_publish_packet_topic(packet: &MqttPacket) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/publish.rs:110:4 [INFO] [stdout] | [INFO] [stdout] 110 | fn get_publish_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_publish_packet_payload` is never used [INFO] [stdout] --> src/mqtt/publish.rs:120:4 [INFO] [stdout] | [INFO] [stdout] 120 | fn get_publish_packet_payload(packet: &MqttPacket) -> &[u8] { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_publish_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/publish.rs:131:15 [INFO] [stdout] | [INFO] [stdout] 131 | pub(crate) fn write_publish_encoding_steps(packet: &PublishPacket, context: &EncodingContext, steps: &mut VecDeque) -> Mqtt... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_publish_properties` is never used [INFO] [stdout] --> src/mqtt/publish.rs:177:4 [INFO] [stdout] | [INFO] [stdout] 177 | fn decode_publish_properties(property_bytes: &[u8], packet : &mut PublishPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_publish_packet` is never used [INFO] [stdout] --> src/mqtt/publish.rs:212:15 [INFO] [stdout] | [INFO] [stdout] 212 | pub(crate) fn decode_publish_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_publish_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/publish.rs:257:15 [INFO] [stdout] | [INFO] [stdout] 257 | pub(crate) fn validate_publish_packet_outbound(packet: &PublishPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_publish_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/publish.rs:304:15 [INFO] [stdout] | [INFO] [stdout] 304 | pub(crate) fn validate_publish_packet_outbound_internal(packet: &PublishPacket, context: &OutboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_publish_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/publish.rs:343:15 [INFO] [stdout] | [INFO] [stdout] 343 | pub(crate) fn validate_publish_packet_inbound_internal(packet: &PublishPacket, _: &InboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_pubrec_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:18:37 [INFO] [stdout] | [INFO] [stdout] 18 | define_ack_packet_lengths_function!(compute_pubrec_packet_length_properties, PubrecPacket, PubrecReasonCode); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_lengths_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubrec_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:19:43 [INFO] [stdout] | [INFO] [stdout] 19 | define_ack_packet_reason_string_accessor!(get_pubrec_packet_reason_string, Pubrec); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_reason_string_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubrec_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:20:43 [INFO] [stdout] | [INFO] [stdout] 20 | define_ack_packet_user_property_accessor!(get_pubrec_packet_user_property, Pubrec); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_user_property_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_pubrec_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:23:34 [INFO] [stdout] | [INFO] [stdout] 23 | define_ack_packet_encoding_impl!(write_pubrec_encoding_steps, PubrecPacket, PubrecReasonCode, PUBREC_FIRST_BYTE, compute_pubrec_packet_le... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_encoding_impl` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubrec_properties` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:25:47 [INFO] [stdout] | [INFO] [stdout] 25 | define_ack_packet_decode_properties_function!(decode_pubrec_properties, PubrecPacket, "Pubrec"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_properties_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubrec_packet` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:26:36 [INFO] [stdout] | [INFO] [stdout] 26 | define_ack_packet_decode_function!(decode_pubrec_packet, Pubrec, PubrecPacket, "Pubrec", PUBREC_FIRST_BYTE, convert_u8_to_pubrec_reason_c... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrec_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:28:24 [INFO] [stdout] | [INFO] [stdout] 28 | validate_ack_outbound!(validate_pubrec_packet_outbound, PubrecPacket, PacketType::Pubrec, "Pubrec"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrec_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:29:33 [INFO] [stdout] | [INFO] [stdout] 29 | validate_ack_outbound_internal!(validate_pubrec_packet_outbound_internal, PubrecPacket, PacketType::Pubrec, compute_pubrec_packet_length_... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrec_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubrec.rs:30:32 [INFO] [stdout] | [INFO] [stdout] 30 | validate_ack_inbound_internal!(validate_pubrec_packet_inbound_internal, PubrecPacket, PacketType::Pubrec, "Pubrec"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_pubrel_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:18:37 [INFO] [stdout] | [INFO] [stdout] 18 | define_ack_packet_lengths_function!(compute_pubrel_packet_length_properties, PubrelPacket, PubrelReasonCode); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_lengths_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubrel_packet_reason_string` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:19:43 [INFO] [stdout] | [INFO] [stdout] 19 | define_ack_packet_reason_string_accessor!(get_pubrel_packet_reason_string, Pubrel); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_reason_string_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_pubrel_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:20:43 [INFO] [stdout] | [INFO] [stdout] 20 | define_ack_packet_user_property_accessor!(get_pubrel_packet_user_property, Pubrel); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_user_property_accessor` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_pubrel_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:23:34 [INFO] [stdout] | [INFO] [stdout] 23 | define_ack_packet_encoding_impl!(write_pubrel_encoding_steps, PubrelPacket, PubrelReasonCode, PUBREL_FIRST_BYTE, compute_pubrel_packet_le... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_encoding_impl` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubrel_properties` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:25:47 [INFO] [stdout] | [INFO] [stdout] 25 | define_ack_packet_decode_properties_function!(decode_pubrel_properties, PubrelPacket, "Pubrel"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_properties_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_pubrel_packet` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:26:36 [INFO] [stdout] | [INFO] [stdout] 26 | define_ack_packet_decode_function!(decode_pubrel_packet, Pubrel, PubrelPacket, "Pubrel", PUBREL_FIRST_BYTE, convert_u8_to_pubrel_reason_c... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `define_ack_packet_decode_function` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrel_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:28:24 [INFO] [stdout] | [INFO] [stdout] 28 | validate_ack_outbound!(validate_pubrel_packet_outbound, PubrelPacket, PacketType::Pubrel, "Pubrel"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrel_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:29:33 [INFO] [stdout] | [INFO] [stdout] 29 | validate_ack_outbound_internal!(validate_pubrel_packet_outbound_internal, PubrelPacket, PacketType::Pubrel, compute_pubrel_packet_length_... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_outbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_pubrel_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/pubrel.rs:30:32 [INFO] [stdout] | [INFO] [stdout] 30 | validate_ack_inbound_internal!(validate_pubrel_packet_inbound_internal, PubrelPacket, PacketType::Pubrel, "Pubrel"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_suback_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/suback.rs:70:15 [INFO] [stdout] | [INFO] [stdout] 70 | pub(crate) fn write_suback_encoding_steps(_: &SubackPacket, _: &EncodingContext, _: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_suback_properties` is never used [INFO] [stdout] --> src/mqtt/suback.rs:74:4 [INFO] [stdout] | [INFO] [stdout] 74 | fn decode_suback_properties(property_bytes: &[u8], packet : &mut SubackPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_suback_packet` is never used [INFO] [stdout] --> src/mqtt/suback.rs:94:15 [INFO] [stdout] | [INFO] [stdout] 94 | pub(crate) fn decode_suback_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_suback_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/suback.rs:131:32 [INFO] [stdout] | [INFO] [stdout] 131 | validate_ack_inbound_internal!(validate_suback_packet_inbound_internal, SubackPacket, PacketType::Suback, "Suback"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_subscribe_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:19:4 [INFO] [stdout] | [INFO] [stdout] 19 | fn compute_subscribe_packet_length_properties(packet: &SubscribePacket) -> MqttResult<(u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_subscribe_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:34:4 [INFO] [stdout] | [INFO] [stdout] 34 | fn get_subscribe_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_subscribe_packet_topic_filter` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:44:4 [INFO] [stdout] | [INFO] [stdout] 44 | fn get_subscribe_packet_topic_filter(packet: &MqttPacket, index: usize) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_subscription_options_byte` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:52:4 [INFO] [stdout] | [INFO] [stdout] 52 | fn compute_subscription_options_byte(subscription: &Subscription) -> u8 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_subscribe_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:69:15 [INFO] [stdout] | [INFO] [stdout] 69 | pub(crate) fn write_subscribe_encoding_steps(packet: &SubscribePacket, _: &EncodingContext, steps: &mut VecDeque) -> MqttRe... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_subscribe_packet` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:174:15 [INFO] [stdout] | [INFO] [stdout] 174 | pub(crate) fn decode_subscribe_packet(_: u8, _: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_subscribe_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:178:15 [INFO] [stdout] | [INFO] [stdout] 178 | pub(crate) fn validate_subscribe_packet_outbound(packet: &SubscribePacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_subscribe_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/subscribe.rs:195:15 [INFO] [stdout] | [INFO] [stdout] 195 | pub(crate) fn validate_subscribe_packet_outbound_internal(packet: &SubscribePacket, context: &OutboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_unsuback_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/unsuback.rs:70:15 [INFO] [stdout] | [INFO] [stdout] 70 | pub(crate) fn write_unsuback_encoding_steps(_: &UnsubackPacket, _: &EncodingContext, _: &mut VecDeque) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_unsuback_properties` is never used [INFO] [stdout] --> src/mqtt/unsuback.rs:74:4 [INFO] [stdout] | [INFO] [stdout] 74 | fn decode_unsuback_properties(property_bytes: &[u8], packet : &mut UnsubackPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_unsuback_packet` is never used [INFO] [stdout] --> src/mqtt/unsuback.rs:94:15 [INFO] [stdout] | [INFO] [stdout] 94 | pub(crate) fn decode_unsuback_packet(first_byte: u8, packet_body: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_unsuback_packet_inbound_internal` is never used [INFO] [stdout] --> src/mqtt/unsuback.rs:132:32 [INFO] [stdout] | [INFO] [stdout] 132 | validate_ack_inbound_internal!(validate_unsuback_packet_inbound_internal, UnsubackPacket, PacketType::Unsuback, "Unsuback"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this warning originates in the macro `validate_ack_inbound_internal` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_unsubscribe_packet_length_properties` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:19:4 [INFO] [stdout] | [INFO] [stdout] 19 | fn compute_unsubscribe_packet_length_properties(packet: &UnsubscribePacket) -> MqttResult<(u32, u32)> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_unsubscribe_packet_user_property` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:33:4 [INFO] [stdout] | [INFO] [stdout] 33 | fn get_unsubscribe_packet_user_property(packet: &MqttPacket, index: usize) -> &UserProperty { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_unsubscribe_packet_topic_filter` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:43:4 [INFO] [stdout] | [INFO] [stdout] 43 | fn get_unsubscribe_packet_topic_filter(packet: &MqttPacket, index: usize) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `write_unsubscribe_encoding_steps` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:52:15 [INFO] [stdout] | [INFO] [stdout] 52 | pub(crate) fn write_unsubscribe_encoding_steps(packet: &UnsubscribePacket, _: &EncodingContext, steps: &mut VecDeque) -> Mq... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `decode_unsubscribe_packet` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:130:15 [INFO] [stdout] | [INFO] [stdout] 130 | pub(crate) fn decode_unsubscribe_packet(_: u8, _: &[u8]) -> MqttResult> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_unsubscribe_packet_outbound` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:134:15 [INFO] [stdout] | [INFO] [stdout] 134 | pub(crate) fn validate_unsubscribe_packet_outbound(packet: &UnsubscribePacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_unsubscribe_packet_outbound_internal` is never used [INFO] [stdout] --> src/mqtt/unsubscribe.rs:152:15 [INFO] [stdout] | [INFO] [stdout] 152 | pub(crate) fn validate_unsubscribe_packet_outbound_internal(packet: &UnsubscribePacket, context: &OutboundValidationContext) -> MqttResul... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_CONNECT` is never used [INFO] [stdout] --> src/mqtt/utils.rs:15:18 [INFO] [stdout] | [INFO] [stdout] 15 | pub(crate) const PACKET_TYPE_CONNECT: u8 = 1; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_CONNACK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:16:18 [INFO] [stdout] | [INFO] [stdout] 16 | pub(crate) const PACKET_TYPE_CONNACK: u8 = 2; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PUBLISH` is never used [INFO] [stdout] --> src/mqtt/utils.rs:17:18 [INFO] [stdout] | [INFO] [stdout] 17 | pub(crate) const PACKET_TYPE_PUBLISH: u8 = 3; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PUBACK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:18:18 [INFO] [stdout] | [INFO] [stdout] 18 | pub(crate) const PACKET_TYPE_PUBACK: u8 = 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PUBREC` is never used [INFO] [stdout] --> src/mqtt/utils.rs:19:18 [INFO] [stdout] | [INFO] [stdout] 19 | pub(crate) const PACKET_TYPE_PUBREC: u8 = 5; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PUBREL` is never used [INFO] [stdout] --> src/mqtt/utils.rs:20:18 [INFO] [stdout] | [INFO] [stdout] 20 | pub(crate) const PACKET_TYPE_PUBREL: u8 = 6; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PUBCOMP` is never used [INFO] [stdout] --> src/mqtt/utils.rs:21:18 [INFO] [stdout] | [INFO] [stdout] 21 | pub(crate) const PACKET_TYPE_PUBCOMP: u8 = 7; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_SUBSCRIBE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:22:18 [INFO] [stdout] | [INFO] [stdout] 22 | pub(crate) const PACKET_TYPE_SUBSCRIBE: u8 = 8; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_SUBACK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | pub(crate) const PACKET_TYPE_SUBACK: u8 = 9; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_UNSUBSCRIBE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:24:18 [INFO] [stdout] | [INFO] [stdout] 24 | pub(crate) const PACKET_TYPE_UNSUBSCRIBE: u8 = 10; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_UNSUBACK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:25:18 [INFO] [stdout] | [INFO] [stdout] 25 | pub(crate) const PACKET_TYPE_UNSUBACK: u8 = 11; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PINGREQ` is never used [INFO] [stdout] --> src/mqtt/utils.rs:26:18 [INFO] [stdout] | [INFO] [stdout] 26 | pub(crate) const PACKET_TYPE_PINGREQ: u8 = 12; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_PINGRESP` is never used [INFO] [stdout] --> src/mqtt/utils.rs:27:18 [INFO] [stdout] | [INFO] [stdout] 27 | pub(crate) const PACKET_TYPE_PINGRESP: u8 = 13; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_DISCONNECT` is never used [INFO] [stdout] --> src/mqtt/utils.rs:28:18 [INFO] [stdout] | [INFO] [stdout] 28 | pub(crate) const PACKET_TYPE_DISCONNECT: u8 = 14; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PACKET_TYPE_AUTH` is never used [INFO] [stdout] --> src/mqtt/utils.rs:29:18 [INFO] [stdout] | [INFO] [stdout] 29 | pub(crate) const PACKET_TYPE_AUTH: u8 = 15; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_PAYLOAD_FORMAT_INDICATOR` is never used [INFO] [stdout] --> src/mqtt/utils.rs:31:18 [INFO] [stdout] | [INFO] [stdout] 31 | pub(crate) const PROPERTY_KEY_PAYLOAD_FORMAT_INDICATOR: u8 = 1; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_MESSAGE_EXPIRY_INTERVAL` is never used [INFO] [stdout] --> src/mqtt/utils.rs:32:18 [INFO] [stdout] | [INFO] [stdout] 32 | pub(crate) const PROPERTY_KEY_MESSAGE_EXPIRY_INTERVAL: u8 = 2; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_CONTENT_TYPE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:33:18 [INFO] [stdout] | [INFO] [stdout] 33 | pub(crate) const PROPERTY_KEY_CONTENT_TYPE: u8 = 3; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_RESPONSE_TOPIC` is never used [INFO] [stdout] --> src/mqtt/utils.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 34 | pub(crate) const PROPERTY_KEY_RESPONSE_TOPIC: u8 = 8; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_CORRELATION_DATA` is never used [INFO] [stdout] --> src/mqtt/utils.rs:35:18 [INFO] [stdout] | [INFO] [stdout] 35 | pub(crate) const PROPERTY_KEY_CORRELATION_DATA: u8 = 9; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SUBSCRIPTION_IDENTIFIER` is never used [INFO] [stdout] --> src/mqtt/utils.rs:36:18 [INFO] [stdout] | [INFO] [stdout] 36 | pub(crate) const PROPERTY_KEY_SUBSCRIPTION_IDENTIFIER: u8 = 11; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SESSION_EXPIRY_INTERVAL` is never used [INFO] [stdout] --> src/mqtt/utils.rs:37:18 [INFO] [stdout] | [INFO] [stdout] 37 | pub(crate) const PROPERTY_KEY_SESSION_EXPIRY_INTERVAL: u8 = 17; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_ASSIGNED_CLIENT_IDENTIFIER` is never used [INFO] [stdout] --> src/mqtt/utils.rs:38:18 [INFO] [stdout] | [INFO] [stdout] 38 | pub(crate) const PROPERTY_KEY_ASSIGNED_CLIENT_IDENTIFIER: u8 = 18; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SERVER_KEEP_ALIVE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:39:18 [INFO] [stdout] | [INFO] [stdout] 39 | pub(crate) const PROPERTY_KEY_SERVER_KEEP_ALIVE: u8 = 19; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_AUTHENTICATION_METHOD` is never used [INFO] [stdout] --> src/mqtt/utils.rs:40:18 [INFO] [stdout] | [INFO] [stdout] 40 | pub(crate) const PROPERTY_KEY_AUTHENTICATION_METHOD: u8 = 21; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_AUTHENTICATION_DATA` is never used [INFO] [stdout] --> src/mqtt/utils.rs:41:18 [INFO] [stdout] | [INFO] [stdout] 41 | pub(crate) const PROPERTY_KEY_AUTHENTICATION_DATA: u8 = 22; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_REQUEST_PROBLEM_INFORMATION` is never used [INFO] [stdout] --> src/mqtt/utils.rs:42:18 [INFO] [stdout] | [INFO] [stdout] 42 | pub(crate) const PROPERTY_KEY_REQUEST_PROBLEM_INFORMATION: u8 = 23; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_WILL_DELAY_INTERVAL` is never used [INFO] [stdout] --> src/mqtt/utils.rs:43:18 [INFO] [stdout] | [INFO] [stdout] 43 | pub(crate) const PROPERTY_KEY_WILL_DELAY_INTERVAL: u8 = 24; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_REQUEST_RESPONSE_INFORMATION` is never used [INFO] [stdout] --> src/mqtt/utils.rs:44:18 [INFO] [stdout] | [INFO] [stdout] 44 | pub(crate) const PROPERTY_KEY_REQUEST_RESPONSE_INFORMATION: u8 = 25; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_RESPONSE_INFORMATION` is never used [INFO] [stdout] --> src/mqtt/utils.rs:45:18 [INFO] [stdout] | [INFO] [stdout] 45 | pub(crate) const PROPERTY_KEY_RESPONSE_INFORMATION: u8 = 26; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SERVER_REFERENCE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:46:18 [INFO] [stdout] | [INFO] [stdout] 46 | pub(crate) const PROPERTY_KEY_SERVER_REFERENCE: u8 = 28; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_REASON_STRING` is never used [INFO] [stdout] --> src/mqtt/utils.rs:47:18 [INFO] [stdout] | [INFO] [stdout] 47 | pub(crate) const PROPERTY_KEY_REASON_STRING: u8 = 31; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_RECEIVE_MAXIMUM` is never used [INFO] [stdout] --> src/mqtt/utils.rs:48:18 [INFO] [stdout] | [INFO] [stdout] 48 | pub(crate) const PROPERTY_KEY_RECEIVE_MAXIMUM: u8 = 33; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_TOPIC_ALIAS_MAXIMUM` is never used [INFO] [stdout] --> src/mqtt/utils.rs:49:18 [INFO] [stdout] | [INFO] [stdout] 49 | pub(crate) const PROPERTY_KEY_TOPIC_ALIAS_MAXIMUM: u8 = 34; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_TOPIC_ALIAS` is never used [INFO] [stdout] --> src/mqtt/utils.rs:50:18 [INFO] [stdout] | [INFO] [stdout] 50 | pub(crate) const PROPERTY_KEY_TOPIC_ALIAS: u8 = 35; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_MAXIMUM_QOS` is never used [INFO] [stdout] --> src/mqtt/utils.rs:51:18 [INFO] [stdout] | [INFO] [stdout] 51 | pub(crate) const PROPERTY_KEY_MAXIMUM_QOS: u8 = 36; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_RETAIN_AVAILABLE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:52:18 [INFO] [stdout] | [INFO] [stdout] 52 | pub(crate) const PROPERTY_KEY_RETAIN_AVAILABLE: u8 = 37; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_USER_PROPERTY` is never used [INFO] [stdout] --> src/mqtt/utils.rs:53:18 [INFO] [stdout] | [INFO] [stdout] 53 | pub(crate) const PROPERTY_KEY_USER_PROPERTY: u8 = 38; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_MAXIMUM_PACKET_SIZE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:54:18 [INFO] [stdout] | [INFO] [stdout] 54 | pub(crate) const PROPERTY_KEY_MAXIMUM_PACKET_SIZE: u8 = 39; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_WILDCARD_SUBSCRIPTIONS_AVAILABLE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:55:18 [INFO] [stdout] | [INFO] [stdout] 55 | pub(crate) const PROPERTY_KEY_WILDCARD_SUBSCRIPTIONS_AVAILABLE: u8 = 40; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SUBSCRIPTION_IDENTIFIERS_AVAILABLE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:56:18 [INFO] [stdout] | [INFO] [stdout] 56 | pub(crate) const PROPERTY_KEY_SUBSCRIPTION_IDENTIFIERS_AVAILABLE: u8 = 41; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PROPERTY_KEY_SHARED_SUBSCRIPTIONS_AVAILABLE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:57:18 [INFO] [stdout] | [INFO] [stdout] 57 | pub(crate) const PROPERTY_KEY_SHARED_SUBSCRIPTIONS_AVAILABLE: u8 = 42; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBLISH_PACKET_FIXED_HEADER_DUPLICATE_FLAG` is never used [INFO] [stdout] --> src/mqtt/utils.rs:59:18 [INFO] [stdout] | [INFO] [stdout] 59 | pub(crate) const PUBLISH_PACKET_FIXED_HEADER_DUPLICATE_FLAG : u8 = 8; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBLISH_PACKET_FIXED_HEADER_RETAIN_FLAG` is never used [INFO] [stdout] --> src/mqtt/utils.rs:60:18 [INFO] [stdout] | [INFO] [stdout] 60 | pub(crate) const PUBLISH_PACKET_FIXED_HEADER_RETAIN_FLAG : u8 = 1; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `QOS_MASK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:61:18 [INFO] [stdout] | [INFO] [stdout] 61 | pub(crate) const QOS_MASK : u8 = 3; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `UNSUBSCRIBE_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:76:18 [INFO] [stdout] | [INFO] [stdout] 76 | pub(crate) const UNSUBSCRIBE_FIRST_BYTE : u8 = (PACKET_TYPE_UNSUBSCRIBE << 4) | (0x02u8); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `UNSUBACK_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:77:18 [INFO] [stdout] | [INFO] [stdout] 77 | pub(crate) const UNSUBACK_FIRST_BYTE : u8 = PACKET_TYPE_UNSUBACK << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `SUBSCRIBE_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:78:18 [INFO] [stdout] | [INFO] [stdout] 78 | pub(crate) const SUBSCRIBE_FIRST_BYTE : u8 = (PACKET_TYPE_SUBSCRIBE << 4) | (0x02u8); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `SUBACK_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:79:18 [INFO] [stdout] | [INFO] [stdout] 79 | pub(crate) const SUBACK_FIRST_BYTE : u8 = PACKET_TYPE_SUBACK << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBREL_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:80:18 [INFO] [stdout] | [INFO] [stdout] 80 | pub(crate) const PUBREL_FIRST_BYTE : u8 = (PACKET_TYPE_PUBREL << 4) | (0x02u8); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBACK_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:81:18 [INFO] [stdout] | [INFO] [stdout] 81 | pub(crate) const PUBACK_FIRST_BYTE : u8 = PACKET_TYPE_PUBACK << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBREC_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:82:18 [INFO] [stdout] | [INFO] [stdout] 82 | pub(crate) const PUBREC_FIRST_BYTE : u8 = PACKET_TYPE_PUBREC << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `PUBCOMP_FIRST_BYTE` is never used [INFO] [stdout] --> src/mqtt/utils.rs:83:18 [INFO] [stdout] | [INFO] [stdout] 83 | pub(crate) const PUBCOMP_FIRST_BYTE : u8 = PACKET_TYPE_PUBCOMP << 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `SUBSCRIPTION_OPTIONS_NO_LOCAL_MASK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:85:18 [INFO] [stdout] | [INFO] [stdout] 85 | pub(crate) const SUBSCRIPTION_OPTIONS_NO_LOCAL_MASK : u8 = 1u8 << 2; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `SUBSCRIPTION_OPTIONS_RETAIN_AS_PUBLISHED_MASK` is never used [INFO] [stdout] --> src/mqtt/utils.rs:86:18 [INFO] [stdout] | [INFO] [stdout] 86 | pub(crate) const SUBSCRIPTION_OPTIONS_RETAIN_AS_PUBLISHED_MASK : u8 = 1u8 << 3; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `SUBSCRIPTION_OPTIONS_RETAIN_HANDLING_SHIFT` is never used [INFO] [stdout] --> src/mqtt/utils.rs:87:18 [INFO] [stdout] | [INFO] [stdout] 87 | pub(crate) const SUBSCRIPTION_OPTIONS_RETAIN_HANDLING_SHIFT : u8 = 4; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_payload_format_indicator` is never used [INFO] [stdout] --> src/mqtt/utils.rs:110:15 [INFO] [stdout] | [INFO] [stdout] 110 | pub(crate) fn convert_u8_to_payload_format_indicator(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_puback_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:128:15 [INFO] [stdout] | [INFO] [stdout] 128 | pub(crate) fn convert_u8_to_puback_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_pubrec_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:160:15 [INFO] [stdout] | [INFO] [stdout] 160 | pub(crate) fn convert_u8_to_pubrec_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_pubrel_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:192:15 [INFO] [stdout] | [INFO] [stdout] 192 | pub(crate) fn convert_u8_to_pubrel_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_pubcomp_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:210:15 [INFO] [stdout] | [INFO] [stdout] 210 | pub(crate) fn convert_u8_to_pubcomp_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_connect_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:228:15 [INFO] [stdout] | [INFO] [stdout] 228 | pub(crate) fn convert_u8_to_connect_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_authenticate_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:359:15 [INFO] [stdout] | [INFO] [stdout] 359 | pub(crate) fn convert_u8_to_authenticate_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `authenticate_reason_code_to_str` is never used [INFO] [stdout] --> src/mqtt/utils.rs:371:15 [INFO] [stdout] | [INFO] [stdout] 371 | pub(crate) fn authenticate_reason_code_to_str (reason_code: AuthenticateReasonCode) -> &'static str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_unsuback_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:379:15 [INFO] [stdout] | [INFO] [stdout] 379 | pub(crate) fn convert_u8_to_unsuback_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `convert_u8_to_suback_reason_code` is never used [INFO] [stdout] --> src/mqtt/utils.rs:407:15 [INFO] [stdout] | [INFO] [stdout] 407 | pub(crate) fn convert_u8_to_suback_reason_code(value: u8) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `mqtt_packet_to_packet_type` is never used [INFO] [stdout] --> src/mqtt/utils.rs:466:15 [INFO] [stdout] | [INFO] [stdout] 466 | pub(crate) fn mqtt_packet_to_packet_type(packet: &MqttPacket) -> PacketType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `packet_type_to_str` is never used [INFO] [stdout] --> src/mqtt/utils.rs:486:15 [INFO] [stdout] | [INFO] [stdout] 486 | pub(crate) fn packet_type_to_str(packet_type: u8) -> &'static str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `mqtt_packet_to_str` is never used [INFO] [stdout] --> src/mqtt/utils.rs:509:15 [INFO] [stdout] | [INFO] [stdout] 509 | pub(crate) fn mqtt_packet_to_str(packet: &MqttPacket) -> &'static str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `MqttOperationOptions` is never used [INFO] [stdout] --> src/protocol.rs:28:6 [INFO] [stdout] | [INFO] [stdout] 28 | enum MqttOperationOptions { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MqttOperation` is never constructed [INFO] [stdout] --> src/protocol.rs:38:19 [INFO] [stdout] | [INFO] [stdout] 38 | pub(crate) struct MqttOperation { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `bind_packet_id` and `unbind_packet_id` are never used [INFO] [stdout] --> src/protocol.rs:74:12 [INFO] [stdout] | [INFO] [stdout] 73 | impl MqttOperation { [INFO] [stdout] | ------------------ methods in this implementation [INFO] [stdout] 74 | pub fn bind_packet_id(&mut self, packet_id: u16) { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 95 | pub fn unbind_packet_id(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `PacketEvent` is never used [INFO] [stdout] --> src/protocol.rs:120:17 [INFO] [stdout] | [INFO] [stdout] 120 | pub(crate) enum PacketEvent { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ConnectionOpenedContext` is never constructed [INFO] [stdout] --> src/protocol.rs:126:19 [INFO] [stdout] | [INFO] [stdout] 126 | pub(crate) struct ConnectionOpenedContext { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `NetworkEvent` is never used [INFO] [stdout] --> src/protocol.rs:132:17 [INFO] [stdout] | [INFO] [stdout] 132 | pub(crate) enum NetworkEvent<'a> { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `NetworkEventContext` is never constructed [INFO] [stdout] --> src/protocol.rs:139:19 [INFO] [stdout] | [INFO] [stdout] 139 | pub(crate) struct NetworkEventContext<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `UserEvent` is never used [INFO] [stdout] --> src/protocol.rs:149:17 [INFO] [stdout] | [INFO] [stdout] 149 | pub(crate) enum UserEvent { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `UserEventContext` is never constructed [INFO] [stdout] --> src/protocol.rs:156:19 [INFO] [stdout] | [INFO] [stdout] 156 | pub(crate) struct UserEventContext { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ServiceContext` is never constructed [INFO] [stdout] --> src/protocol.rs:161:19 [INFO] [stdout] | [INFO] [stdout] 161 | pub(crate) struct ServiceContext<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ProtocolStateType` is never used [INFO] [stdout] --> src/protocol.rs:170:17 [INFO] [stdout] | [INFO] [stdout] 170 | pub(crate) enum ProtocolStateType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `is_connection_established` is never used [INFO] [stdout] --> src/protocol.rs:178:15 [INFO] [stdout] | [INFO] [stdout] 178 | pub(crate) fn is_connection_established(state: ProtocolStateType) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ProtocolStateConfig` is never constructed [INFO] [stdout] --> src/protocol.rs:194:19 [INFO] [stdout] | [INFO] [stdout] 194 | pub(crate) struct ProtocolStateConfig { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ProtocolQueueType` is never used [INFO] [stdout] --> src/protocol.rs:207:6 [INFO] [stdout] | [INFO] [stdout] 207 | enum ProtocolQueueType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ProtocolQueueServiceMode` is never used [INFO] [stdout] --> src/protocol.rs:222:6 [INFO] [stdout] | [INFO] [stdout] 222 | enum ProtocolQueueServiceMode { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ProtocolEnqueuePosition` is never used [INFO] [stdout] --> src/protocol.rs:228:6 [INFO] [stdout] | [INFO] [stdout] 228 | enum ProtocolEnqueuePosition { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `OperationResponse` is never used [INFO] [stdout] --> src/protocol.rs:242:6 [INFO] [stdout] | [INFO] [stdout] 242 | enum OperationResponse { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `OperationTimeoutRecord` is never constructed [INFO] [stdout] --> src/protocol.rs:249:19 [INFO] [stdout] | [INFO] [stdout] 249 | pub(crate) struct OperationTimeoutRecord { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `ProtocolState` is never constructed [INFO] [stdout] --> src/protocol.rs:267:19 [INFO] [stdout] | [INFO] [stdout] 267 | pub(crate) struct ProtocolState { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/protocol.rs:387:19 [INFO] [stdout] | [INFO] [stdout] 383 | impl ProtocolState { [INFO] [stdout] | ------------------ associated items in this implementation [INFO] [stdout] ... [INFO] [stdout] 387 | pub(crate) fn new(mut config: ProtocolStateConfig) -> ProtocolState { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 423 | pub(crate) fn state(&self) -> ProtocolStateType { [INFO] [stdout] | ^^^^^ [INFO] [stdout] ... [INFO] [stdout] 427 | pub(crate) fn handle_network_event(&mut self, context: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 454 | pub(crate) fn service(&mut self, context: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 479 | pub(crate) fn handle_user_event(&mut self, context: UserEventContext) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 515 | pub(crate) fn get_next_service_timepoint(&mut self, current_time: &Instant) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 536 | pub(crate) fn reset(&mut self, current_time: &Instant) { [INFO] [stdout] | ^^^^^ [INFO] [stdout] ... [INFO] [stdout] 570 | fn operation_packet_passes_offline_queue_policy(&self, packet: &MqttPacket) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 578 | fn log_debug(&self, f: &mut Formatter<'_>) -> Result { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 601 | fn log_trace(&self, f: &mut Formatter<'_>) -> Result { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 640 | fn log_state(&self) { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 653 | fn update_internal_clock(&mut self, current_time: &Instant) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 658 | fn get_elapsed_millis(&self, timepoint: &Instant) -> u128 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 662 | fn partition_operation_queue_by_queue_policy(&self, queue: &VecDeque, policy: &OfflineQueuePolicy) -> (VecDeque, VecDeque bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 680 | fn partition_high_priority_queue_for_disconnect(&self, iterator: T) -> (VecDeque, VecDeque) where T : Iterator MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 707 | fn complete_operation_as_success(&mut self, id : u64, completion_result: Option) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 733 | fn complete_operation_as_failure(&mut self, id : u64, error: MqttError) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 761 | fn complete_operation_sequence_as_failure(&mut self, iterator: T, error_fn: fn() -> MqttError ) -> MqttResult<()> where T : Iterat... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 771 | fn complete_operation_sequence_as_empty_success(&mut self, iterator: T) -> MqttResult<()> where T : Iterator { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 781 | fn handle_network_event_connection_opened(&mut self, context: &NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 812 | fn apply_connection_closed_to_current_operation(&mut self) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 846 | fn handle_network_event_connection_closed(&mut self, _: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 939 | fn handle_network_event_write_completion(&mut self, _: &NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 963 | fn change_state(&mut self, next_state: ProtocolStateType) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 968 | fn is_connect_packet(&self, id: u64) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 976 | fn is_connect_in_queue(&self) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 980 | fn handle_network_event_incoming_data(&mut self, context: &mut NetworkEventContext, data: &[u8]) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1048 | fn does_operation_pass_receive_maximum_flow_control(&self, id: u64) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1064 | fn dequeue_operation(&mut self, mode: ProtocolQueueServiceMode) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1090 | fn compute_outbound_alias_resolution(&self, packet: &MqttPacket) -> OutboundAliasResolution { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1098 | fn get_next_ack_timeout(&mut self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1109 | fn process_ack_timeouts(&mut self) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1120 | fn get_operation_timeout_duration(&self, operation: &MqttOperation) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1143 | fn start_operation_ack_timeout(&mut self, id: u64, now: Instant) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1161 | fn apply_ping_extension_on_operation_success(&mut self, operation: &MqttOperation) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1184 | fn on_current_operation_fully_written(&mut self, now: Instant) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1218 | fn service_disconnected(&mut self, _: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1223 | fn service_queue(&mut self, context: &mut ServiceContext, mode: ProtocolQueueServiceMode) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1297 | fn service_pending_connack(&mut self, context: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1310 | fn service_keep_alive(&mut self, context: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1340 | fn service_connected(&mut self, context: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1350 | fn service_pending_disconnect(&mut self, _: &mut ServiceContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1358 | fn get_next_service_timepoint_protocol_queue(&self, mode: ProtocolQueueServiceMode) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1396 | fn get_next_service_timepoint_disconnected(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1400 | fn get_next_service_timepoint_pending_connack(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1404 | fn get_next_service_timepoint_connected(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1420 | fn get_next_service_timepoint_pending_disconnect(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1430 | fn unbind_operation_packet_id(&mut self, id: u64) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1439 | fn clear_qos2_state(&mut self, id: u64) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1445 | fn set_publish_duplicate_flag(&mut self, id: u64, value: bool) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1454 | fn apply_session_present_to_connection(&mut self, session_present: bool) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1506 | fn handle_connack(&mut self, packet: Box, context: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1552 | fn handle_pingresp(&mut self) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1571 | fn handle_suback(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1595 | fn handle_unsuback(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1619 | fn handle_puback(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1643 | fn handle_pubrec(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1690 | fn handle_pubrel(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1717 | fn handle_pubcomp(&mut self, packet: Box) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1741 | fn handle_publish(&mut self, packet: Box, context: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1796 | fn handle_disconnect(&mut self, packet: Box, context: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1816 | fn handle_auth(&mut self, _: Box, _: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1821 | fn handle_packet(&mut self, packet: Box, context: &mut NetworkEventContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1841 | fn get_maximum_incoming_packet_size(&self) -> u32 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1849 | fn get_queue(&mut self, queue_type: ProtocolQueueType) -> &mut VecDeque { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1856 | fn enqueue_operation(&mut self, id: u64, queue_type: ProtocolQueueType, position: ProtocolEnqueuePosition) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1869 | fn create_operation(&mut self, packet: Box, options: Option) -> u64 { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1890 | fn create_connect(&self) -> Box { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1902 | fn acquire_free_packet_id(&mut self, operation_id: u64) -> MqttResult { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1927 | fn acquire_packet_id_for_operation(&mut self, operation_id: u64) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 1954 | pub(crate) fn get_negotiated_settings(&self) -> &Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `generate_connection_closed_error` is never used [INFO] [stdout] --> src/protocol.rs:1959:4 [INFO] [stdout] | [INFO] [stdout] 1959 | fn generate_connection_closed_error() -> MqttError { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `generate_offline_queue_policy_failed_error` is never used [INFO] [stdout] --> src/protocol.rs:1963:4 [INFO] [stdout] | [INFO] [stdout] 1963 | fn generate_offline_queue_policy_failed_error() -> MqttError { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `build_negotiated_settings` is never used [INFO] [stdout] --> src/protocol.rs:1967:4 [INFO] [stdout] | [INFO] [stdout] 1967 | fn build_negotiated_settings(config: &ProtocolStateConfig, packet: &ConnackPacket, existing_settings: &Option) -> Neg... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `complete_operation_with_result` is never used [INFO] [stdout] --> src/protocol.rs:1997:4 [INFO] [stdout] | [INFO] [stdout] 1997 | fn complete_operation_with_result(operation_options: &mut MqttOperationOptions, completion_result: Option) -> MqttResu... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `complete_operation_with_error` is never used [INFO] [stdout] --> src/protocol.rs:2035:4 [INFO] [stdout] | [INFO] [stdout] 2035 | fn complete_operation_with_error(operation_options: &mut MqttOperationOptions, error: MqttError) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `does_packet_pass_offline_queue_policy` is never used [INFO] [stdout] --> src/protocol.rs:2054:15 [INFO] [stdout] | [INFO] [stdout] 2054 | pub(crate) fn does_packet_pass_offline_queue_policy(packet: &MqttPacket, policy: &OfflineQueuePolicy) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `partition_operations_by_queue_policy` is never used [INFO] [stdout] --> src/protocol.rs:2072:4 [INFO] [stdout] | [INFO] [stdout] 2072 | fn partition_operations_by_queue_policy<'a, T>(iterator: T, policy: &OfflineQueuePolicy) -> (VecDeque, VecDeque) where T : Iter... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `sort_operation_deque` is never used [INFO] [stdout] --> src/protocol.rs:2087:4 [INFO] [stdout] | [INFO] [stdout] 2087 | fn sort_operation_deque(operations: &mut VecDeque) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `fold_timepoint` is never used [INFO] [stdout] --> src/protocol.rs:2092:4 [INFO] [stdout] | [INFO] [stdout] 2092 | fn fold_timepoint(base: &Option, new: &Instant) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `fold_optional_timepoint_min` is never used [INFO] [stdout] --> src/protocol.rs:2102:4 [INFO] [stdout] | [INFO] [stdout] 2102 | fn fold_optional_timepoint_min(base: &Option, new: &Option) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `MAXIMUM_STRING_PROPERTY_LENGTH` is never used [INFO] [stdout] --> src/validate.rs:28:18 [INFO] [stdout] | [INFO] [stdout] 28 | pub(crate) const MAXIMUM_STRING_PROPERTY_LENGTH : usize = 65535; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant `MAXIMUM_BINARY_PROPERTY_LENGTH` is never used [INFO] [stdout] --> src/validate.rs:29:18 [INFO] [stdout] | [INFO] [stdout] 29 | pub(crate) const MAXIMUM_BINARY_PROPERTY_LENGTH : usize = 65535; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `OutboundValidationContext` is never constructed [INFO] [stdout] --> src/validate.rs:31:19 [INFO] [stdout] | [INFO] [stdout] 31 | pub(crate) struct OutboundValidationContext<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `InboundValidationContext` is never constructed [INFO] [stdout] --> src/validate.rs:42:19 [INFO] [stdout] | [INFO] [stdout] 42 | pub(crate) struct InboundValidationContext<'a> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_user_properties` is never used [INFO] [stdout] --> src/validate.rs:48:15 [INFO] [stdout] | [INFO] [stdout] 48 | pub(crate) fn validate_user_properties(properties: &Option>, packet_type: PacketType, packet_name: &str) -> MqttResult<... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_packet_outbound` is never used [INFO] [stdout] --> src/validate.rs:67:15 [INFO] [stdout] | [INFO] [stdout] 67 | pub(crate) fn validate_packet_outbound(packet: &MqttPacket) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_packet_outbound_internal` is never used [INFO] [stdout] --> src/validate.rs:89:15 [INFO] [stdout] | [INFO] [stdout] 89 | pub(crate) fn validate_packet_outbound_internal(packet: &MqttPacket, context: &OutboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_packet_inbound_internal` is never used [INFO] [stdout] --> src/validate.rs:112:15 [INFO] [stdout] | [INFO] [stdout] 112 | pub(crate) fn validate_packet_inbound_internal(packet: &MqttPacket, context: &InboundValidationContext) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_string_length` is never used [INFO] [stdout] --> src/validate.rs:133:15 [INFO] [stdout] | [INFO] [stdout] 133 | pub(crate) fn validate_string_length(value: &str, packet_type: PacketType, packet_name: &str, field_name: &str) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_optional_string_length` is never used [INFO] [stdout] --> src/validate.rs:142:15 [INFO] [stdout] | [INFO] [stdout] 142 | pub(crate) fn validate_optional_string_length(optional_string: &Option, packet_type: PacketType, packet_name: &str, field_name: &... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `validate_optional_binary_length` is never used [INFO] [stdout] --> src/validate.rs:153:15 [INFO] [stdout] | [INFO] [stdout] 153 | pub(crate) fn validate_optional_binary_length(optional_data: &Option>, packet_type: PacketType, packet_name: &str, field_name: &s... [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `is_valid_topic` is never used [INFO] [stdout] --> src/validate.rs:230:15 [INFO] [stdout] | [INFO] [stdout] 230 | pub(crate) fn is_valid_topic(topic: &str) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `TopicFilterProperties` is never constructed [INFO] [stdout] --> src/validate.rs:243:19 [INFO] [stdout] | [INFO] [stdout] 243 | pub(crate) struct TopicFilterProperties { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_topic_filter_properties` is never used [INFO] [stdout] --> src/validate.rs:249:4 [INFO] [stdout] | [INFO] [stdout] 249 | fn compute_topic_filter_properties(topic: &str) -> TopicFilterProperties { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `is_valid_topic_filter_internal` is never used [INFO] [stdout] --> src/validate.rs:298:15 [INFO] [stdout] | [INFO] [stdout] 298 | pub(crate) fn is_valid_topic_filter_internal(filter: &str, context: &OutboundValidationContext, no_local: Option) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 302 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `StopOptionsInternal` is never constructed [INFO] [stdout] --> src/client.rs:495:19 [INFO] [stdout] | [INFO] [stdout] 495 | pub(crate) struct StopOptionsInternal { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `StopOptionsInternal` has a derived impl for the trait `Default`, but this is intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `OperationOptions` is never used [INFO] [stdout] --> src/client.rs:499:17 [INFO] [stdout] | [INFO] [stdout] 499 | pub(crate) enum OperationOptions { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `ClientImplState` is never used [INFO] [stdout] --> src/client.rs:511:17 [INFO] [stdout] | [INFO] [stdout] 511 | pub(crate) enum ClientImplState { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: type alias `CallbackSpawnerFunction` is never used [INFO] [stdout] --> src/client.rs:532:17 [INFO] [stdout] | [INFO] [stdout] 532 | pub(crate) type CallbackSpawnerFunction = Box, Arc) + Send + Sync>; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `MqttClientImpl` is never constructed [INFO] [stdout] --> src/client.rs:534:19 [INFO] [stdout] | [INFO] [stdout] 534 | pub(crate) struct MqttClientImpl { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: multiple associated items are never used [INFO] [stdout] --> src/client.rs:562:19 [INFO] [stdout] | [INFO] [stdout] 560 | impl MqttClientImpl { [INFO] [stdout] | ------------------- associated items in this implementation [INFO] [stdout] 561 | [INFO] [stdout] 562 | pub(crate) fn new(client_config: MqttClientOptions, connect_config: ConnectOptions, callback_spawner: CallbackSpawnerFunction) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] ... [INFO] [stdout] 597 | pub(crate) fn connect_timeout(&self) -> &Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 601 | pub(crate) fn get_current_state(&self) -> ClientImplState { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 605 | pub(crate) fn get_protocol_state(&self) -> ProtocolStateType { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 609 | fn add_listener(&mut self, id: u64, listener: ClientEventListener) { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 613 | fn remove_listener(&mut self, id: u64) { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 617 | fn broadcast_event(&self, event: Arc) { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 625 | pub(crate) fn apply_error(&mut self, error: MqttError) { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 633 | pub(crate) fn handle_incoming_operation(&mut self, operation: OperationOptions) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 706 | fn dispatch_packet_events(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 740 | pub(crate) fn handle_incoming_bytes(&mut self, bytes: &[u8]) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 754 | pub(crate) fn handle_write_completion(&mut self) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 766 | pub(crate) fn handle_service(&mut self, outbound_data: &mut Vec) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 777 | fn clamp_reconnect_period(&self, mut reconnect_period: Duration) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 785 | fn compute_uniform_jitter_period(&self, max_nanos: u128) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 791 | pub(crate) fn advance_reconnect_period(&mut self) -> Duration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 805 | pub(crate) fn compute_optional_state_transition(&self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 843 | pub(crate) fn get_next_connected_service_time(&mut self) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 851 | fn emit_connection_attempt_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 858 | fn emit_connection_success_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 869 | fn emit_connection_failure_event(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 882 | fn emit_disconnection_event(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 895 | fn emit_stopped_event(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 902 | fn reset_state_for_new_connection(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 912 | pub(crate) fn transition_to_state(&mut self, mut new_state: ClientImplState) -> MqttResult<()> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `endpoint` and `port` are never read [INFO] [stdout] --> src/config.rs:37:16 [INFO] [stdout] | [INFO] [stdout] 36 | pub struct HttpProxyOptions { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 37 | pub(crate) endpoint: String, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 38 | pub(crate) port: u16, [INFO] [stdout] | ^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `HttpProxyOptions` has a derived impl for the trait `Clone`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `options` is never read [INFO] [stdout] --> src/config.rs:141:16 [INFO] [stdout] | [INFO] [stdout] 140 | pub struct TlsOptions { [INFO] [stdout] | ---------- field in this struct [INFO] [stdout] 141 | pub(crate) options: TlsData [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `TlsOptions` has a derived impl for the trait `Clone`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `normalize` is never used [INFO] [stdout] --> src/config.rs:589:19 [INFO] [stdout] | [INFO] [stdout] 588 | impl ReconnectOptions { [INFO] [stdout] | --------------------- method in this implementation [INFO] [stdout] 589 | pub(crate) fn normalize(&mut self) { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `endpoint` and `port` are never read [INFO] [stdout] --> src/config.rs:737:5 [INFO] [stdout] | [INFO] [stdout] 736 | pub struct GenericClientBuilder { [INFO] [stdout] | -------------------- fields in this struct [INFO] [stdout] 737 | endpoint: String, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 738 | port: u16, [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: enum `TlsConfiguration` is never used [INFO] [stdout] --> src/config.rs:749:17 [INFO] [stdout] | [INFO] [stdout] 749 | pub(crate) enum TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_tls_impl_from_options` is never used [INFO] [stdout] --> src/config.rs:758:4 [INFO] [stdout] | [INFO] [stdout] 758 | fn get_tls_impl_from_options(tls_options: Option<&TlsOptions>) -> TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `get_tls_impl` is never used [INFO] [stdout] --> src/config.rs:822:8 [INFO] [stdout] | [INFO] [stdout] 773 | impl GenericClientBuilder { [INFO] [stdout] | ------------------------- method in this implementation [INFO] [stdout] ... [INFO] [stdout] 822 | fn get_tls_impl(&self) -> TlsConfiguration { [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `Endpoint` is never constructed [INFO] [stdout] --> src/config.rs:884:19 [INFO] [stdout] | [INFO] [stdout] 884 | pub(crate) struct Endpoint { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function `new` is never used [INFO] [stdout] --> src/config.rs:890:19 [INFO] [stdout] | [INFO] [stdout] 889 | impl Endpoint { [INFO] [stdout] | ------------- associated function in this implementation [INFO] [stdout] 890 | pub(crate) fn new(endpoint: &str, port: u16) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `make_addr` is never used [INFO] [stdout] --> src/config.rs:898:15 [INFO] [stdout] | [INFO] [stdout] 898 | pub(crate) fn make_addr(endpoint: &str, port: u16) -> std::io::Result { [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `compute_endpoints` is never used [INFO] [stdout] --> src/config.rs:904:15 [INFO] [stdout] | [INFO] [stdout] 904 | pub(crate) fn compute_endpoints(endpoint: String, port: u16, http_proxy_options: &Option) -> (Endpoint, Option src/protocol.rs:178:15 [INFO] [stdout] | [INFO] [stdout] 178 | pub(crate) fn is_connection_established(state: ProtocolStateType) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: method `state` is never used [INFO] [stdout] --> src/protocol.rs:423:19 [INFO] [stdout] | [INFO] [stdout] 383 | impl ProtocolState { [INFO] [stdout] | ------------------ method in this implementation [INFO] [stdout] ... [INFO] [stdout] 423 | pub(crate) fn state(&self) -> ProtocolStateType { [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 20 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 6.49s [INFO] running `Command { std: "docker" "inspect" "be8703a3062f4edc732a29f5bbe113c9347c88b17728ba3f2de62357d9cba55e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "be8703a3062f4edc732a29f5bbe113c9347c88b17728ba3f2de62357d9cba55e", kill_on_drop: false }` [INFO] [stdout] be8703a3062f4edc732a29f5bbe113c9347c88b17728ba3f2de62357d9cba55e