[INFO] fetching crate rocketmq 0.0.1... [INFO] checking rocketmq-0.0.1 against master#5e3f1b148db5bfa27fee52464ae1f5d34c49d77b for pr-75502 [INFO] extracting crate rocketmq 0.0.1 into /workspace/builds/worker-13/source [INFO] validating manifest of crates.io crate rocketmq 0.0.1 on toolchain 5e3f1b148db5bfa27fee52464ae1f5d34c49d77b [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+5e3f1b148db5bfa27fee52464ae1f5d34c49d77b" "read-manifest" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] started tweaking crates.io crate rocketmq 0.0.1 [INFO] finished tweaking crates.io crate rocketmq 0.0.1 [INFO] tweaked toml for crates.io crate rocketmq 0.0.1 written to /workspace/builds/worker-13/source/Cargo.toml [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+5e3f1b148db5bfa27fee52464ae1f5d34c49d77b" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }` [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+5e3f1b148db5bfa27fee52464ae1f5d34c49d77b" "fetch" "--locked" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-13/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-13/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" "rustops/crates-build-env@sha256:a636fd89d022f18117e1dc8fb37a0a009933cdbbe082814857f0e2024962d47c" "/opt/rustwide/cargo-home/bin/cargo" "+5e3f1b148db5bfa27fee52464ae1f5d34c49d77b" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 2df89c259309b1030ae71726acd45323c40d0e6cc007281de2fe1506641165b9 [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] running `Command { std: "docker" "start" "-a" "2df89c259309b1030ae71726acd45323c40d0e6cc007281de2fe1506641165b9", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "2df89c259309b1030ae71726acd45323c40d0e6cc007281de2fe1506641165b9", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "2df89c259309b1030ae71726acd45323c40d0e6cc007281de2fe1506641165b9", kill_on_drop: false }` [INFO] [stdout] 2df89c259309b1030ae71726acd45323c40d0e6cc007281de2fe1506641165b9 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-13/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-13/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" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "rustops/crates-build-env@sha256:a636fd89d022f18117e1dc8fb37a0a009933cdbbe082814857f0e2024962d47c" "/opt/rustwide/cargo-home/bin/cargo" "+5e3f1b148db5bfa27fee52464ae1f5d34c49d77b" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 4073f4e2998b739875b5dd57f4d0dc3e53b493b6851c3066a0513655bd33adc5 [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] running `Command { std: "docker" "start" "-a" "4073f4e2998b739875b5dd57f4d0dc3e53b493b6851c3066a0513655bd33adc5", kill_on_drop: false }` [INFO] [stderr] Compiling syn v1.0.39 [INFO] [stderr] Compiling serde v1.0.115 [INFO] [stderr] Compiling pin-project-internal v0.4.23 [INFO] [stderr] Checking itoa v0.4.6 [INFO] [stderr] Checking once_cell v1.4.1 [INFO] [stderr] Checking bytes v0.5.6 [INFO] [stderr] Checking pin-project-lite v0.1.7 [INFO] [stderr] Checking try-lock v0.2.3 [INFO] [stderr] Compiling crc32fast v1.2.0 [INFO] [stderr] Compiling encoding_rs v0.8.24 [INFO] [stderr] Compiling bitflags v1.2.1 [INFO] [stderr] Checking base64 v0.12.3 [INFO] [stderr] Checking ipnet v2.3.0 [INFO] [stderr] Checking hex v0.4.2 [INFO] [stderr] Compiling hashbrown v0.8.2 [INFO] [stderr] Compiling indexmap v1.5.1 [INFO] [stderr] Checking tracing-core v0.1.15 [INFO] [stderr] Checking dirty-json v0.1.0 [INFO] [stderr] Checking log v0.4.11 [INFO] [stderr] Checking idna v0.2.0 [INFO] [stderr] Checking futures-task v0.3.5 [INFO] [stderr] Checking net2 v0.2.34 [INFO] [stderr] Checking iovec v0.1.4 [INFO] [stderr] Checking getrandom v0.1.14 [INFO] [stderr] Checking socket2 v0.3.12 [INFO] [stderr] Checking if-addrs v0.6.0 [INFO] [stderr] Checking want v0.3.0 [INFO] [stderr] Checking tracing v0.1.19 [INFO] [stderr] Checking rand_core v0.5.1 [INFO] [stderr] Checking mio v0.6.22 [INFO] [stderr] Checking http v0.2.1 [INFO] [stderr] Checking flate2 v1.0.17 [INFO] [stderr] Checking rand_chacha v0.2.2 [INFO] [stderr] Checking url v2.1.1 [INFO] [stderr] Checking rand v0.7.3 [INFO] [stderr] Checking http-body v0.3.1 [INFO] [stderr] Compiling serde_derive v1.0.115 [INFO] [stderr] Compiling futures-macro v0.3.5 [INFO] [stderr] Compiling tokio-macros v0.2.5 [INFO] [stderr] Compiling derivative v2.1.1 [INFO] [stderr] Checking tokio v0.2.22 [INFO] [stderr] Checking pin-project v0.4.23 [INFO] [stderr] Checking futures-util v0.3.5 [INFO] [stderr] Checking tokio-util v0.3.1 [INFO] [stderr] Checking h2 v0.2.6 [INFO] [stderr] Checking futures-executor v0.3.5 [INFO] [stderr] Checking futures v0.3.5 [INFO] [stderr] Checking serde_urlencoded v0.6.1 [INFO] [stderr] Checking serde_json v1.0.57 [INFO] [stderr] Checking bitflags_serde_shim v0.2.2 [INFO] [stderr] Compiling toml v0.5.6 [INFO] [stderr] Checking hyper v0.13.7 [INFO] [stderr] Compiling proc-macro-crate v0.1.5 [INFO] [stderr] Compiling num_enum_derive v0.5.1 [INFO] [stderr] Checking num_enum v0.5.1 [INFO] [stderr] Checking reqwest v0.10.8 [INFO] [stderr] Checking rocketmq v0.0.1 (/opt/rustwide/workdir) [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/client.rs:103:12 [INFO] [stdout] | [INFO] [stdout] 103 | pub fn new(options: ClientOptions) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `id` [INFO] [stdout] --> src/client.rs:113:12 [INFO] [stdout] | [INFO] [stdout] 113 | pub fn id(&self) -> String { [INFO] [stdout] | ^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke` [INFO] [stdout] --> src/client.rs:127:18 [INFO] [stdout] | [INFO] [stdout] 127 | pub async fn invoke(&self, addr: &str, cmd: RemotingCommand) -> Result { [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke_oneway` [INFO] [stdout] --> src/client.rs:132:18 [INFO] [stdout] | [INFO] [stdout] 132 | pub async fn invoke_oneway(&self, addr: &str, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `pull_message` [INFO] [stdout] --> src/client.rs:136:18 [INFO] [stdout] | [INFO] [stdout] 136 | pub async fn pull_message( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `register_consumer` [INFO] [stdout] --> src/client.rs:187:12 [INFO] [stdout] | [INFO] [stdout] 187 | pub fn register_consumer(&self, group: &str, consumer: C) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `unregister_consumer` [INFO] [stdout] --> src/client.rs:192:12 [INFO] [stdout] | [INFO] [stdout] 192 | pub fn unregister_consumer(&self, group: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `register_producer` [INFO] [stdout] --> src/client.rs:197:12 [INFO] [stdout] | [INFO] [stdout] 197 | pub fn register_producer(&self, group: &str, producer: P) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `unregister_producer` [INFO] [stdout] --> src/client.rs:202:12 [INFO] [stdout] | [INFO] [stdout] 202 | pub fn unregister_producer(&self, group: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `rebalance_imediately` [INFO] [stdout] --> src/client.rs:207:8 [INFO] [stdout] | [INFO] [stdout] 207 | fn rebalance_imediately(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `DELAY_TIME_LEVEL` [INFO] [stdout] --> src/message.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | pub const DELAY_TIME_LEVEL: &'static str = "DELAY"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `RETRY_TOPIC` [INFO] [stdout] --> src/message.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | pub const RETRY_TOPIC: &'static str = "RETRY_TOPIC"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `REAL_TOPIC` [INFO] [stdout] --> src/message.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | pub const REAL_TOPIC: &'static str = "REAL_TOPIC"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `REAL_QUEUE_ID` [INFO] [stdout] --> src/message.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | pub const REAL_QUEUE_ID: &'static str = "REAL_QID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_PREPARED` [INFO] [stdout] --> src/message.rs:18:5 [INFO] [stdout] | [INFO] [stdout] 18 | pub const TRANSACTION_PREPARED: &'static str = "TRAN_MSG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `PRODUCER_GROUP` [INFO] [stdout] --> src/message.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | pub const PRODUCER_GROUP: &'static str = "PGROUP"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MIN_OFFSET` [INFO] [stdout] --> src/message.rs:20:5 [INFO] [stdout] | [INFO] [stdout] 20 | pub const MIN_OFFSET: &'static str = "MIN_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MAX_OFFSET` [INFO] [stdout] --> src/message.rs:21:5 [INFO] [stdout] | [INFO] [stdout] 21 | pub const MAX_OFFSET: &'static str = "MAX_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `BUYER_ID` [INFO] [stdout] --> src/message.rs:22:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub const BUYER_ID: &'static str = "BUYER_ID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `ORIGIN_MESSAGE_ID` [INFO] [stdout] --> src/message.rs:23:5 [INFO] [stdout] | [INFO] [stdout] 23 | pub const ORIGIN_MESSAGE_ID: &'static str = "ORIGIN_MESSAGE_ID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSFER_FLAG` [INFO] [stdout] --> src/message.rs:24:5 [INFO] [stdout] | [INFO] [stdout] 24 | pub const TRANSFER_FLAG: &'static str = "TRANSFER_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `CORRECTION_FLAG` [INFO] [stdout] --> src/message.rs:25:5 [INFO] [stdout] | [INFO] [stdout] 25 | pub const CORRECTION_FLAG: &'static str = "CORRECTION_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MQ2_FLAG` [INFO] [stdout] --> src/message.rs:26:5 [INFO] [stdout] | [INFO] [stdout] 26 | pub const MQ2_FLAG: &'static str = "MQ2_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `RECONSUME_TIME` [INFO] [stdout] --> src/message.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 27 | pub const RECONSUME_TIME: &'static str = "RECONSUME_TIME"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MSG_REGION` [INFO] [stdout] --> src/message.rs:28:5 [INFO] [stdout] | [INFO] [stdout] 28 | pub const MSG_REGION: &'static str = "MSG_REGION"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRACE_SWITCH` [INFO] [stdout] --> src/message.rs:29:5 [INFO] [stdout] | [INFO] [stdout] 29 | pub const TRACE_SWITCH: &'static str = "TRACE_ON"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MAX_RECONSUME_TIMES` [INFO] [stdout] --> src/message.rs:31:5 [INFO] [stdout] | [INFO] [stdout] 31 | pub const MAX_RECONSUME_TIMES: &'static str = "MAX_RECONSUME_TIMES"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_PREPARED_QUEUE_OFFSET` [INFO] [stdout] --> src/message.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | pub const TRANSACTION_PREPARED_QUEUE_OFFSET: &'static str = "TRAN_PREPARED_QUEUE_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_CHECK_TIMES` [INFO] [stdout] --> src/message.rs:33:5 [INFO] [stdout] | [INFO] [stdout] 33 | pub const TRANSACTION_CHECK_TIMES: &'static str = "TRANSACTION_CHECK_TIMES"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `CHECK_IMMUNITY_TIME_IN_SECONDS` [INFO] [stdout] --> src/message.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | pub const CHECK_IMMUNITY_TIME_IN_SECONDS: &'static str = "CHECK_IMMUNITY_TIME_IN_SECONDS"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `KEY_SEPARATOR` [INFO] [stdout] --> src/message.rs:35:5 [INFO] [stdout] | [INFO] [stdout] 35 | pub const KEY_SEPARATOR: &'static str = " "; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/namesrv.rs:33:12 [INFO] [stdout] | [INFO] [stdout] 33 | pub fn new(resolver: NR) -> Result { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `get_address` [INFO] [stdout] --> src/namesrv.rs:49:12 [INFO] [stdout] | [INFO] [stdout] 49 | pub fn get_address(&self) -> String { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `len` [INFO] [stdout] --> src/namesrv.rs:58:12 [INFO] [stdout] | [INFO] [stdout] 58 | pub fn len(&self) -> usize { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `is_empty` [INFO] [stdout] --> src/namesrv.rs:62:12 [INFO] [stdout] | [INFO] [stdout] 62 | pub fn is_empty(&self) -> bool { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `update_name_server_address` [INFO] [stdout] --> src/namesrv.rs:66:12 [INFO] [stdout] | [INFO] [stdout] 66 | pub fn update_name_server_address(&mut self) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `query_topic_route_info` [INFO] [stdout] --> src/namesrv.rs:74:18 [INFO] [stdout] | [INFO] [stdout] 74 | pub async fn query_topic_route_info(&self, topic: &str) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `update_topic_route_info` [INFO] [stdout] --> src/namesrv.rs:115:18 [INFO] [stdout] | [INFO] [stdout] 115 | pub async fn update_topic_route_info(&self, topic: &str) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `update_topic_route_info_with_default` [INFO] [stdout] --> src/namesrv.rs:121:18 [INFO] [stdout] | [INFO] [stdout] 121 | pub async fn update_topic_route_info_with_default( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `is_topic_route_data_changed` [INFO] [stdout] --> src/namesrv.rs:158:8 [INFO] [stdout] | [INFO] [stdout] 158 | fn is_topic_route_data_changed(old_data: &TopicRouteData, new_data: &TopicRouteData) -> bool { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `fetch_subscribe_message_queues` [INFO] [stdout] --> src/namesrv.rs:168:18 [INFO] [stdout] | [INFO] [stdout] 168 | pub async fn fetch_subscribe_message_queues( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `fetch_publish_message_queues` [INFO] [stdout] --> src/namesrv.rs:193:18 [INFO] [stdout] | [INFO] [stdout] 193 | pub async fn fetch_publish_message_queues( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `find_broker_addr_by_topic` [INFO] [stdout] --> src/namesrv.rs:220:12 [INFO] [stdout] | [INFO] [stdout] 220 | pub fn find_broker_addr_by_topic(&self, topic: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `find_broker_addr_by_name` [INFO] [stdout] --> src/namesrv.rs:241:12 [INFO] [stdout] | [INFO] [stdout] 241 | pub fn find_broker_addr_by_name(&self, broker_name: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `selector` [INFO] [stdout] --> src/producer/mod.rs:38:5 [INFO] [stdout] | [INFO] [stdout] 38 | selector: Box, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/protocol/mod.rs:30:12 [INFO] [stdout] | [INFO] [stdout] 30 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `with_header` [INFO] [stdout] --> src/protocol/mod.rs:52:12 [INFO] [stdout] | [INFO] [stdout] 52 | pub fn with_header( [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `code` [INFO] [stdout] --> src/protocol/mod.rs:71:12 [INFO] [stdout] | [INFO] [stdout] 71 | pub fn code(&self) -> i16 { [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `mark_response_type` [INFO] [stdout] --> src/protocol/mod.rs:79:12 [INFO] [stdout] | [INFO] [stdout] 79 | pub fn mark_response_type(&mut self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant is never constructed: `Connected` [INFO] [stdout] --> src/remoting/client.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | Connected(Arc), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant is never constructed: `Connecting` [INFO] [stdout] --> src/remoting/client.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | Connecting(Vec, Error>>>), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/remoting/client.rs:28:12 [INFO] [stdout] | [INFO] [stdout] 28 | pub fn new() -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke` [INFO] [stdout] --> src/remoting/client.rs:34:18 [INFO] [stdout] | [INFO] [stdout] 34 | pub async fn invoke(&self, addr: &str, cmd: RemotingCommand) -> Result { [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke_oneway` [INFO] [stdout] --> src/remoting/client.rs:40:18 [INFO] [stdout] | [INFO] [stdout] 40 | pub async fn invoke_oneway(&self, addr: &str, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/client.rs:103:12 [INFO] [stdout] | [INFO] [stdout] 103 | pub fn new(options: ClientOptions) -> Self { [INFO] [stdout] | ^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `get_connection` [INFO] [stdout] --> src/remoting/client.rs:46:18 [INFO] [stdout] | [INFO] [stdout] 46 | pub async fn get_connection(&self, addr: &str) -> Result, Error> { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `connect` [INFO] [stdout] --> src/remoting/client.rs:67:14 [INFO] [stdout] | [INFO] [stdout] 67 | async fn connect(&self, addr: &str) -> Result, Error> { [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `id` [INFO] [stdout] --> src/client.rs:113:12 [INFO] [stdout] | [INFO] [stdout] 113 | pub fn id(&self) -> String { [INFO] [stdout] | ^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke` [INFO] [stdout] --> src/client.rs:127:18 [INFO] [stdout] | [INFO] [stdout] 127 | pub async fn invoke(&self, addr: &str, cmd: RemotingCommand) -> Result { [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `tx` [INFO] [stdout] --> src/remoting/connection.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | tx: mpsc::UnboundedSender, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke_oneway` [INFO] [stdout] --> src/client.rs:132:18 [INFO] [stdout] | [INFO] [stdout] 132 | pub async fn invoke_oneway(&self, addr: &str, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `registrations_tx` [INFO] [stdout] --> src/remoting/connection.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | registrations_tx: mpsc::UnboundedSender<(i32, oneshot::Sender)>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `pull_message` [INFO] [stdout] --> src/client.rs:136:18 [INFO] [stdout] | [INFO] [stdout] 136 | pub async fn pull_message( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `receiver_shutdown` [INFO] [stdout] --> src/remoting/connection.rs:18:5 [INFO] [stdout] | [INFO] [stdout] 18 | receiver_shutdown: Option>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `register_consumer` [INFO] [stdout] --> src/client.rs:187:12 [INFO] [stdout] | [INFO] [stdout] 187 | pub fn register_consumer(&self, group: &str, consumer: C) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `opaque_id` [INFO] [stdout] --> src/remoting/connection.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | opaque_id: AtomicI32, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/remoting/connection.rs:23:12 [INFO] [stdout] | [INFO] [stdout] 23 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `unregister_consumer` [INFO] [stdout] --> src/client.rs:192:12 [INFO] [stdout] | [INFO] [stdout] 192 | pub fn unregister_consumer(&self, group: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `send` [INFO] [stdout] --> src/remoting/connection.rs:36:18 [INFO] [stdout] | [INFO] [stdout] 36 | pub async fn send(&self, cmd: RemotingCommand) -> Result { [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `register_producer` [INFO] [stdout] --> src/client.rs:197:12 [INFO] [stdout] | [INFO] [stdout] 197 | pub fn register_producer(&self, group: &str, producer: P) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `unregister_producer` [INFO] [stdout] --> src/client.rs:202:12 [INFO] [stdout] | [INFO] [stdout] 202 | pub fn unregister_producer(&self, group: &str) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `send_oneway` [INFO] [stdout] --> src/remoting/connection.rs:51:18 [INFO] [stdout] | [INFO] [stdout] 51 | pub async fn send_oneway(&self, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `rebalance_imediately` [INFO] [stdout] --> src/client.rs:207:8 [INFO] [stdout] | [INFO] [stdout] 207 | fn rebalance_imediately(&self) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `outbound` [INFO] [stdout] --> src/remoting/connection.rs:64:5 [INFO] [stdout] | [INFO] [stdout] 64 | outbound: mpsc::UnboundedSender, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `DELAY_TIME_LEVEL` [INFO] [stdout] --> src/message.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | pub const DELAY_TIME_LEVEL: &'static str = "DELAY"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/remoting/connection.rs:71:12 [INFO] [stdout] | [INFO] [stdout] 71 | pub fn new( [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `RETRY_TOPIC` [INFO] [stdout] --> src/message.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | pub const RETRY_TOPIC: &'static str = "RETRY_TOPIC"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `addr` [INFO] [stdout] --> src/remoting/connection.rs:127:5 [INFO] [stdout] | [INFO] [stdout] 127 | addr: String, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `REAL_TOPIC` [INFO] [stdout] --> src/message.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | pub const REAL_TOPIC: &'static str = "REAL_TOPIC"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `sender` [INFO] [stdout] --> src/remoting/connection.rs:128:5 [INFO] [stdout] | [INFO] [stdout] 128 | sender: ConnectionSender, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `REAL_QUEUE_ID` [INFO] [stdout] --> src/message.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | pub const REAL_QUEUE_ID: &'static str = "REAL_QID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `new` [INFO] [stdout] --> src/remoting/connection.rs:132:18 [INFO] [stdout] | [INFO] [stdout] 132 | pub async fn new(addr: &str) -> Result { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_PREPARED` [INFO] [stdout] --> src/message.rs:18:5 [INFO] [stdout] | [INFO] [stdout] 18 | pub const TRANSACTION_PREPARED: &'static str = "TRAN_MSG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `prepare_stream` [INFO] [stdout] --> src/remoting/connection.rs:140:14 [INFO] [stdout] | [INFO] [stdout] 140 | async fn prepare_stream(addr: String) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `PRODUCER_GROUP` [INFO] [stdout] --> src/message.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | pub const PRODUCER_GROUP: &'static str = "PGROUP"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `connect` [INFO] [stdout] --> src/remoting/connection.rs:147:14 [INFO] [stdout] | [INFO] [stdout] 147 | async fn connect(stream: S) -> Result [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MIN_OFFSET` [INFO] [stdout] --> src/message.rs:20:5 [INFO] [stdout] | [INFO] [stdout] 20 | pub const MIN_OFFSET: &'static str = "MIN_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `sender` [INFO] [stdout] --> src/remoting/connection.rs:175:12 [INFO] [stdout] | [INFO] [stdout] 175 | pub fn sender(&self) -> &ConnectionSender { [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MAX_OFFSET` [INFO] [stdout] --> src/message.rs:21:5 [INFO] [stdout] | [INFO] [stdout] 21 | pub const MAX_OFFSET: &'static str = "MAX_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: constant is never used: `MASTER_ID` [INFO] [stdout] --> src/route.rs:11:1 [INFO] [stdout] | [INFO] [stdout] 11 | pub(crate) const MASTER_ID: i64 = 0; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `BUYER_ID` [INFO] [stdout] --> src/message.rs:22:5 [INFO] [stdout] | [INFO] [stdout] 22 | pub const BUYER_ID: &'static str = "BUYER_ID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `select_broker_addr` [INFO] [stdout] --> src/route.rs:38:12 [INFO] [stdout] | [INFO] [stdout] 38 | pub fn select_broker_addr(&self) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `ORIGIN_MESSAGE_ID` [INFO] [stdout] --> src/message.rs:23:5 [INFO] [stdout] | [INFO] [stdout] 23 | pub const ORIGIN_MESSAGE_ID: &'static str = "ORIGIN_MESSAGE_ID"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `from_bytes` [INFO] [stdout] --> src/route.rs:64:12 [INFO] [stdout] | [INFO] [stdout] 64 | pub fn from_bytes(bytes: &[u8]) -> Result { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSFER_FLAG` [INFO] [stdout] --> src/message.rs:24:5 [INFO] [stdout] | [INFO] [stdout] 24 | pub const TRANSFER_FLAG: &'static str = "TRANSFER_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `to_publish_info` [INFO] [stdout] --> src/route.rs:72:12 [INFO] [stdout] | [INFO] [stdout] 72 | pub fn to_publish_info(&self, topic: &str) -> TopicPublishInfo { [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `CORRECTION_FLAG` [INFO] [stdout] --> src/message.rs:25:5 [INFO] [stdout] | [INFO] [stdout] 25 | pub const CORRECTION_FLAG: &'static str = "CORRECTION_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct is never constructed: `TopicPublishInfo` [INFO] [stdout] --> src/route.rs:132:12 [INFO] [stdout] | [INFO] [stdout] 132 | pub struct TopicPublishInfo { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MQ2_FLAG` [INFO] [stdout] --> src/message.rs:26:5 [INFO] [stdout] | [INFO] [stdout] 26 | pub const MQ2_FLAG: &'static str = "MQ2_FLAG"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `get_queue_id_by_broker` [INFO] [stdout] --> src/route.rs:141:12 [INFO] [stdout] | [INFO] [stdout] 141 | pub fn get_queue_id_by_broker(&self, broker_name: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `RECONSUME_TIME` [INFO] [stdout] --> src/message.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 27 | pub const RECONSUME_TIME: &'static str = "RECONSUME_TIME"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `len` [INFO] [stdout] --> src/route.rs:149:12 [INFO] [stdout] | [INFO] [stdout] 149 | pub fn len(&self) -> usize { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MSG_REGION` [INFO] [stdout] --> src/message.rs:28:5 [INFO] [stdout] | [INFO] [stdout] 28 | pub const MSG_REGION: &'static str = "MSG_REGION"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `is_empty` [INFO] [stdout] --> src/route.rs:153:12 [INFO] [stdout] | [INFO] [stdout] 153 | pub fn is_empty(&self) -> bool { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRACE_SWITCH` [INFO] [stdout] --> src/message.rs:29:5 [INFO] [stdout] | [INFO] [stdout] 29 | pub const TRACE_SWITCH: &'static str = "TRACE_ON"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `MAX_RECONSUME_TIMES` [INFO] [stdout] --> src/message.rs:31:5 [INFO] [stdout] | [INFO] [stdout] 31 | pub const MAX_RECONSUME_TIMES: &'static str = "MAX_RECONSUME_TIMES"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_PREPARED_QUEUE_OFFSET` [INFO] [stdout] --> src/message.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | pub const TRANSACTION_PREPARED_QUEUE_OFFSET: &'static str = "TRAN_PREPARED_QUEUE_OFFSET"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `TRANSACTION_CHECK_TIMES` [INFO] [stdout] --> src/message.rs:33:5 [INFO] [stdout] | [INFO] [stdout] 33 | pub const TRANSACTION_CHECK_TIMES: &'static str = "TRANSACTION_CHECK_TIMES"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `CHECK_IMMUNITY_TIME_IN_SECONDS` [INFO] [stdout] --> src/message.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | pub const CHECK_IMMUNITY_TIME_IN_SECONDS: &'static str = "CHECK_IMMUNITY_TIME_IN_SECONDS"; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated constant is never used: `KEY_SEPARATOR` [INFO] [stdout] --> src/message.rs:35:5 [INFO] [stdout] | [INFO] [stdout] 35 | pub const KEY_SEPARATOR: &'static str = " "; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `get_address` [INFO] [stdout] --> src/namesrv.rs:49:12 [INFO] [stdout] | [INFO] [stdout] 49 | pub fn get_address(&self) -> String { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `len` [INFO] [stdout] --> src/namesrv.rs:58:12 [INFO] [stdout] | [INFO] [stdout] 58 | pub fn len(&self) -> usize { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `is_empty` [INFO] [stdout] --> src/namesrv.rs:62:12 [INFO] [stdout] | [INFO] [stdout] 62 | pub fn is_empty(&self) -> bool { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `update_name_server_address` [INFO] [stdout] --> src/namesrv.rs:66:12 [INFO] [stdout] | [INFO] [stdout] 66 | pub fn update_name_server_address(&mut self) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `selector` [INFO] [stdout] --> src/producer/mod.rs:38:5 [INFO] [stdout] | [INFO] [stdout] 38 | selector: Box, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `code` [INFO] [stdout] --> src/protocol/mod.rs:71:12 [INFO] [stdout] | [INFO] [stdout] 71 | pub fn code(&self) -> i16 { [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `invoke_oneway` [INFO] [stdout] --> src/remoting/client.rs:40:18 [INFO] [stdout] | [INFO] [stdout] 40 | pub async fn invoke_oneway(&self, addr: &str, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `receiver_shutdown` [INFO] [stdout] --> src/remoting/connection.rs:18:5 [INFO] [stdout] | [INFO] [stdout] 18 | receiver_shutdown: Option>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `send_oneway` [INFO] [stdout] --> src/remoting/connection.rs:51:18 [INFO] [stdout] | [INFO] [stdout] 51 | pub async fn send_oneway(&self, cmd: RemotingCommand) -> Result<(), Error> { [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `outbound` [INFO] [stdout] --> src/remoting/connection.rs:64:5 [INFO] [stdout] | [INFO] [stdout] 64 | outbound: mpsc::UnboundedSender, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field is never read: `addr` [INFO] [stdout] --> src/remoting/connection.rs:127:5 [INFO] [stdout] | [INFO] [stdout] 127 | addr: String, [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `select_broker_addr` [INFO] [stdout] --> src/route.rs:38:12 [INFO] [stdout] | [INFO] [stdout] 38 | pub fn select_broker_addr(&self) -> &str { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `get_queue_id_by_broker` [INFO] [stdout] --> src/route.rs:141:12 [INFO] [stdout] | [INFO] [stdout] 141 | pub fn get_queue_id_by_broker(&self, broker_name: &str) -> Option { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `len` [INFO] [stdout] --> src/route.rs:149:12 [INFO] [stdout] | [INFO] [stdout] 149 | pub fn len(&self) -> usize { [INFO] [stdout] | ^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: associated function is never used: `is_empty` [INFO] [stdout] --> src/route.rs:153:12 [INFO] [stdout] | [INFO] [stdout] 153 | pub fn is_empty(&self) -> bool { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 46 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 79 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 2m 04s [INFO] running `Command { std: "docker" "inspect" "4073f4e2998b739875b5dd57f4d0dc3e53b493b6851c3066a0513655bd33adc5", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "4073f4e2998b739875b5dd57f4d0dc3e53b493b6851c3066a0513655bd33adc5", kill_on_drop: false }` [INFO] [stdout] 4073f4e2998b739875b5dd57f4d0dc3e53b493b6851c3066a0513655bd33adc5