[INFO] cloning repository https://github.com/TYPEmber/data_distributor
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/TYPEmber/data_distributor" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 960865b2859c46874e3fb57da2a86631bdebc48c
[INFO] testing TYPEmber/data_distributor against beta-2023-04-20 for beta-1.70-1
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor" "/workspace/builds/worker-7-tc2/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-7-tc2/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/TYPEmber/data_distributor on toolchain beta-2023-04-20
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2023-04-20" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/TYPEmber/data_distributor
[INFO] finished tweaking git repo https://github.com/TYPEmber/data_distributor
[INFO] tweaked toml for git repo https://github.com/TYPEmber/data_distributor written to /workspace/builds/worker-7-tc2/source/Cargo.toml
[INFO] crate git repo https://github.com/TYPEmber/data_distributor already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2023-04-20" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded vswhom-sys v0.1.0
[INFO] [stderr]   Downloaded embed-resource v1.6.2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-04-20" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 97a10f0a994f89c711e1125e314620c7919e6a142111c3c06f9bd227e2c933b3
[INFO] running `Command { std: "docker" "start" "-a" "97a10f0a994f89c711e1125e314620c7919e6a142111c3c06f9bd227e2c933b3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "97a10f0a994f89c711e1125e314620c7919e6a142111c3c06f9bd227e2c933b3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "97a10f0a994f89c711e1125e314620c7919e6a142111c3c06f9bd227e2c933b3", kill_on_drop: false }`
[INFO] [stdout] 97a10f0a994f89c711e1125e314620c7919e6a142111c3c06f9bd227e2c933b3
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-04-20" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] ac2621909809b478de26720507c7b6e6fa92cbb7eaf6f5de2d809729d0285cf4
[INFO] running `Command { std: "docker" "start" "-a" "ac2621909809b478de26720507c7b6e6fa92cbb7eaf6f5de2d809729d0285cf4", kill_on_drop: false }`
[INFO] [stderr]    Compiling cfg-if v1.0.0
[INFO] [stderr]    Compiling libc v0.2.93
[INFO] [stderr]    Compiling proc-macro2 v1.0.26
[INFO] [stderr]    Compiling unicode-xid v0.2.1
[INFO] [stderr]    Compiling syn v1.0.69
[INFO] [stderr]    Compiling version_check v0.9.3
[INFO] [stderr]    Compiling autocfg v1.0.1
[INFO] [stderr]    Compiling value-bag v1.0.0-alpha.6
[INFO] [stderr]    Compiling log v0.4.14
[INFO] [stderr]    Compiling memchr v2.3.4
[INFO] [stderr]    Compiling bytes v1.0.1
[INFO] [stderr]    Compiling lazy_static v1.4.0
[INFO] [stderr]    Compiling scopeguard v1.1.0
[INFO] [stderr]    Compiling pin-project-lite v0.2.6
[INFO] [stderr]    Compiling itoa v0.4.7
[INFO] [stderr]    Compiling getrandom v0.2.2
[INFO] [stderr]    Compiling typenum v1.13.0
[INFO] [stderr]    Compiling instant v0.1.9
[INFO] [stderr]    Compiling fnv v1.0.7
[INFO] [stderr]    Compiling smallvec v1.6.1
[INFO] [stderr]    Compiling futures-core v0.3.14
[INFO] [stderr]    Compiling ppv-lite86 v0.2.10
[INFO] [stderr]    Compiling lock_api v0.4.3
[INFO] [stderr]    Compiling futures-sink v0.3.14
[INFO] [stderr]    Compiling matches v0.1.8
[INFO] [stderr]    Compiling once_cell v1.7.2
[INFO] [stderr]    Compiling httparse v1.4.0
[INFO] [stderr]    Compiling getrandom v0.1.16
[INFO] [stderr]    Compiling tinyvec_macros v0.1.0
[INFO] [stderr]    Compiling generic-array v0.14.4
[INFO] [stderr]    Compiling unicase v2.6.0
[INFO] [stderr]    Compiling percent-encoding v2.1.0
[INFO] [stderr]    Compiling tokio v1.5.0
[INFO] [stderr]    Compiling http v0.2.4
[INFO] [stderr]    Compiling crossbeam-utils v0.8.3
[INFO] [stderr]    Compiling tinyvec v1.2.0
[INFO] [stderr]    Compiling pin-utils v0.1.0
[INFO] [stderr]    Compiling serde_derive v1.0.125
[INFO] [stderr]    Compiling slab v0.4.2
[INFO] [stderr]    Compiling futures-task v0.3.14
[INFO] [stderr]    Compiling bitflags v1.2.1
[INFO] [stderr]    Compiling form_urlencoded v1.0.1
[INFO] [stderr]    Compiling indexmap v1.6.2
[INFO] [stderr]    Compiling memoffset v0.6.3
[INFO] [stderr]    Compiling proc-macro-error-attr v1.0.4
[INFO] [stderr]    Compiling futures-util v0.3.14
[INFO] [stderr]    Compiling unicode-bidi v0.3.5
[INFO] [stderr]    Compiling ryu v1.0.5
[INFO] [stderr]    Compiling serde v1.0.125
[INFO] [stderr]    Compiling cpuid-bool v0.1.2
[INFO] [stderr]    Compiling quote v1.0.9
[INFO] [stderr]    Compiling parking_lot_core v0.8.3
[INFO] [stderr]    Compiling num_cpus v1.13.0
[INFO] [stderr]    Compiling signal-hook-registry v1.3.0
[INFO] [stderr]    Compiling rand_core v0.6.2
[INFO] [stderr]    Compiling parking_lot v0.11.1
[INFO] [stderr]    Compiling rand_chacha v0.3.0
[INFO] [stderr]    Compiling unicode-normalization v0.1.17
[INFO] [stderr]    Compiling opaque-debug v0.3.0
[INFO] [stderr]    Compiling mime_guess v2.0.3
[INFO] [stderr]    Compiling proc-macro-error v1.0.4
[INFO] [stderr]    Compiling rand v0.8.3
[INFO] [stderr]    Compiling rand_core v0.5.1
[INFO] [stderr]    Compiling tracing-core v0.1.17
[INFO] [stderr]    Compiling mime v0.3.16
[INFO] [stderr]    Compiling hashbrown v0.9.1
[INFO] [stderr]    Compiling base64 v0.13.0
[INFO] [stderr]    Compiling digest v0.9.0
[INFO] [stderr]    Compiling block-buffer v0.9.0
[INFO] [stderr]    Compiling rand_chacha v0.2.2
[INFO] [stderr]    Compiling sha-1 v0.9.4
[INFO] [stderr]    Compiling idna v0.2.3
[INFO] [stderr]    Compiling input_buffer v0.4.0
[INFO] [stderr]    Compiling futures-channel v0.3.14
[INFO] [stderr]    Compiling try-lock v0.2.3
[INFO] [stderr]    Compiling cc v1.0.67
[INFO] [stderr]    Compiling remove_dir_all v0.5.3
[INFO] [stderr]    Compiling unicode-segmentation v1.7.1
[INFO] [stderr]    Compiling unicode-width v0.1.8
[INFO] [stderr]    Compiling safemem v0.3.3
[INFO] [stderr]    Compiling byteorder v1.4.3
[INFO] [stderr]    Compiling utf-8 v0.7.6
[INFO] [stderr]    Compiling serde_json v1.0.64
[INFO] [stderr]    Compiling url v2.2.1
[INFO] [stderr]    Compiling buf_redux v0.8.4
[INFO] [stderr]    Compiling textwrap v0.11.0
[INFO] [stderr]    Compiling tempfile v3.2.0
[INFO] [stderr]    Compiling rand v0.7.3
[INFO] [stderr]    Compiling crossbeam-epoch v0.9.3
[INFO] [stderr]    Compiling embed-resource v1.6.2
[INFO] [stderr]    Compiling headers-core v0.2.0
[INFO] [stderr]    Compiling heck v0.3.2
[INFO] [stderr]    Compiling http-body v0.4.1
[INFO] [stderr]    Compiling time v0.1.43
[INFO] [stderr]    Compiling socket2 v0.4.0
[INFO] [stderr]    Compiling atty v0.2.14
[INFO] [stderr]    Compiling twoway v0.1.8
[INFO] [stderr]    Compiling httpdate v0.3.2
[INFO] [stderr]    Compiling ansi_term v0.11.0
[INFO] [stderr]    Compiling futures-io v0.3.14
[INFO] [stderr]    Compiling strsim v0.8.0
[INFO] [stderr]    Compiling vec_map v0.8.2
[INFO] [stderr]    Compiling tower-service v0.3.1
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling futures v0.3.14
[INFO] [stderr]    Compiling crossbeam-deque v0.8.0
[INFO] [stderr]    Compiling crossbeam-channel v0.5.1
[INFO] [stderr]    Compiling headers v0.3.4
[INFO] [stderr]    Compiling crossbeam-queue v0.3.1
[INFO] [stderr]    Compiling aho-corasick v0.7.15
[INFO] [stderr]    Compiling scoped-tls v1.0.0
[INFO] [stderr]    Compiling clap v2.33.3
[INFO] [stderr]    Compiling regex-syntax v0.6.23
[INFO] [stderr]    Compiling data_distributor v0.1.0 (/opt/rustwide/workdir)
[INFO] [stderr]    Compiling dashmap v4.0.2
[INFO] [stderr]    Compiling crossbeam v0.8.0
[INFO] [stderr]    Compiling regex v1.4.5
[INFO] [stderr]    Compiling ctor v0.1.20
[INFO] [stderr]    Compiling tokio-macros v1.1.0
[INFO] [stderr]    Compiling pin-project-internal v1.0.7
[INFO] [stderr]    Compiling structopt-derive v0.4.14
[INFO] [stderr]    Compiling structopt v0.3.21
[INFO] [stderr]    Compiling mio v0.7.11
[INFO] [stderr]    Compiling tracing v0.1.25
[INFO] [stderr]    Compiling tungstenite v0.12.0
[INFO] [stderr]    Compiling want v0.3.0
[INFO] [stderr]    Compiling multipart v0.17.1
[INFO] [stderr]    Compiling pin-project v1.0.7
[INFO] [stderr]    Compiling tokio-util v0.6.6
[INFO] [stderr]    Compiling tokio-stream v0.1.5
[INFO] [stderr]    Compiling tokio-tungstenite v0.13.0
[INFO] [stderr]    Compiling serde_urlencoded v0.7.0
[INFO] [stderr]    Compiling h2 v0.3.2
[INFO] [stderr]    Compiling hyper v0.14.5
[INFO] [stderr]    Compiling warp v0.3.1
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/lib.rs:166:44
[INFO] [stdout]     |
[INFO] [stdout] 166 | ...                   if let Err(e) = sender_map
[INFO] [stdout]     |                                  ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stop_for_send_thread_1`
[INFO] [stdout]    --> src/lib.rs:302:13
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stop_for_send_thread_1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_size1`
[INFO] [stdout]    --> src/lib.rs:304:13
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_size1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/lib.rs:308:25
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:308:21
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                     ----^^^^^^^^
[INFO] [stdout]     |                     |
[INFO] [stdout]     |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:302:9
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:303:9
[INFO] [stdout]     |
[INFO] [stdout] 303 |     let mut send_size = Arc::new(AtomicUsize::new(0));
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:304:9
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |         ----^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 17 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/bin/main.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::str`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::str;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::time::{sleep, Duration};
[INFO] [stdout]    |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Domain`, `SockAddr`, `Socket`, `Type`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:3:15
[INFO] [stdout]   |
[INFO] [stdout] 3 | use socket2::{Domain, SockAddr, Socket, Type};
[INFO] [stdout]   |               ^^^^^^  ^^^^^^^^  ^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{sleep, Duration};
[INFO] [stdout]   |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |             ----^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:133:17
[INFO] [stdout]     |
[INFO] [stdout] 133 |             let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |                 ----^^^^^
[INFO] [stdout]     |                 |
[INFO] [stdout]     |                 help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |         ----^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:101:9
[INFO] [stdout]     |
[INFO] [stdout] 101 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:9
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:108:9
[INFO] [stdout]     |
[INFO] [stdout] 108 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:174:9
[INFO] [stdout]     |
[INFO] [stdout] 174 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:9
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:186:13
[INFO] [stdout]     |
[INFO] [stdout] 186 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:99:9
[INFO] [stdout]    |
[INFO] [stdout] 99 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]    |         ----^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/bin/main.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |             ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]    --> src/bin/main.rs:127:9
[INFO] [stdout]     |
[INFO] [stdout] 127 |     for k in 0..multi_count {
[INFO] [stdout]     |         ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:308:9
[INFO] [stdout]     |
[INFO] [stdout] 308 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:314:9
[INFO] [stdout]     |
[INFO] [stdout] 314 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:152:9
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `test_socket_send_limited` is never used
[INFO] [stdout]    --> src/bin/main.rs:104:10
[INFO] [stdout]     |
[INFO] [stdout] 104 | async fn test_socket_send_limited() {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:392:9
[INFO] [stdout]     |
[INFO] [stdout] 392 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:398:9
[INFO] [stdout]     |
[INFO] [stdout] 398 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |             socket.send_to(&data, addr).await;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 116 |             let _ = socket.send_to(&data, addr).await;
[INFO] [stdout]     |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:136:17
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 let _ = socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:247:9
[INFO] [stdout]     |
[INFO] [stdout] 247 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:248:9
[INFO] [stdout]     |
[INFO] [stdout] 248 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:47:16
[INFO] [stdout]    |
[INFO] [stdout] 47 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:66:16
[INFO] [stdout]    |
[INFO] [stdout] 66 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:69:17
[INFO] [stdout]    |
[INFO] [stdout] 69 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:82:16
[INFO] [stdout]    |
[INFO] [stdout] 82 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:13
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `pkg_num`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:165:5
[INFO] [stdout]     |
[INFO] [stdout] 165 |     pkg_num: u32,
[INFO] [stdout]     |     ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_pkg_num`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:13
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:344:9
[INFO] [stdout]     |
[INFO] [stdout] 344 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:345:9
[INFO] [stdout]     |
[INFO] [stdout] 345 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:9
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `recv_tcp_f64` is never used
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:76:10
[INFO] [stdout]    |
[INFO] [stdout] 76 | async fn recv_tcp_f64(stream: &TcpStream, buffer_length: usize) -> Result<f64, Box<dyn Error>> {
[INFO] [stdout]    |          ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:41:16
[INFO] [stdout]    |
[INFO] [stdout] 41 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:60:16
[INFO] [stdout]    |
[INFO] [stdout] 60 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:63:17
[INFO] [stdout]    |
[INFO] [stdout] 63 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:76:16
[INFO] [stdout]    |
[INFO] [stdout] 76 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:79:17
[INFO] [stdout]    |
[INFO] [stdout] 79 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `time_limit`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     time_limit: f64,
[INFO] [stdout]     |     ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_time_limit`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:13
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:13
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:368:5
[INFO] [stdout]     |
[INFO] [stdout] 368 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:458:5
[INFO] [stdout]     |
[INFO] [stdout] 458 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `speed_rate` and `package_count` are never read
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub struct Opt {
[INFO] [stdout]    |            --- fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 18 |     speed_rate: f64,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 19 |     #[structopt(short, long, default_value = "1000000")]
[INFO] [stdout] 20 |     package_count: u32,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Opt` has a derived impl for the trait `Debug`, 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: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:105:17
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 let _ = socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:127:16
[INFO] [stdout]     |
[INFO] [stdout] 127 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 127 |                let _ = recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:158:17
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 let _ = socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:180:16
[INFO] [stdout]     |
[INFO] [stdout] 180 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 180 |                let _ = recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 29 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 9 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 49.61s
[INFO] [stderr] warning: the following packages contain code that will be rejected by a future version of Rust: buf_redux v0.8.4, multipart v0.17.1
[INFO] [stderr] note: to see what the problems were, use the option `--future-incompat-report`, or run `cargo report future-incompatibilities --id 1`
[INFO] running `Command { std: "docker" "inspect" "ac2621909809b478de26720507c7b6e6fa92cbb7eaf6f5de2d809729d0285cf4", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "ac2621909809b478de26720507c7b6e6fa92cbb7eaf6f5de2d809729d0285cf4", kill_on_drop: false }`
[INFO] [stdout] ac2621909809b478de26720507c7b6e6fa92cbb7eaf6f5de2d809729d0285cf4
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:5ff2268d62e97bff2cde7d5815dd6ed5b47097566f13b8d0ca110b04b60e07ed" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-04-20" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 8e4dedaabf35c96ee3152cb0ca9d40e23579f04e1b53822c50790c8ce6b14153
[INFO] running `Command { std: "docker" "start" "-a" "8e4dedaabf35c96ee3152cb0ca9d40e23579f04e1b53822c50790c8ce6b14153", kill_on_drop: false }`
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/lib.rs:166:44
[INFO] [stdout]     |
[INFO] [stdout] 166 | ...                   if let Err(e) = sender_map
[INFO] [stdout]     |                                  ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stop_for_send_thread_1`
[INFO] [stdout]    --> src/lib.rs:302:13
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stop_for_send_thread_1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_size1`
[INFO] [stdout]    --> src/lib.rs:304:13
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_size1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/lib.rs:308:25
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:308:21
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                     ----^^^^^^^^
[INFO] [stdout]     |                     |
[INFO] [stdout]     |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:302:9
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:303:9
[INFO] [stdout]     |
[INFO] [stdout] 303 |     let mut send_size = Arc::new(AtomicUsize::new(0));
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling data_distributor v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:304:9
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |         ----^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 17 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::str`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::str;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::time::{sleep, Duration};
[INFO] [stdout]    |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/bin/main.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `super::*`
[INFO] [stdout]  --> src/lib.rs:8:9
[INFO] [stdout]   |
[INFO] [stdout] 8 |     use super::*;
[INFO] [stdout]   |         ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Domain`, `SockAddr`, `Socket`, `Type`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:3:15
[INFO] [stdout]   |
[INFO] [stdout] 3 | use socket2::{Domain, SockAddr, Socket, Type};
[INFO] [stdout]   |               ^^^^^^  ^^^^^^^^  ^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{sleep, Duration};
[INFO] [stdout]   |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |             ----^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:133:17
[INFO] [stdout]     |
[INFO] [stdout] 133 |             let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |                 ----^^^^^
[INFO] [stdout]     |                 |
[INFO] [stdout]     |                 help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |         ----^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:99:9
[INFO] [stdout]    |
[INFO] [stdout] 99 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]    |         ----^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/bin/main.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |             ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]    --> src/bin/main.rs:127:9
[INFO] [stdout]     |
[INFO] [stdout] 127 |     for k in 0..multi_count {
[INFO] [stdout]     |         ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:152:9
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `test_socket_send_limited` is never used
[INFO] [stdout]    --> src/bin/main.rs:104:10
[INFO] [stdout]     |
[INFO] [stdout] 104 | async fn test_socket_send_limited() {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:101:9
[INFO] [stdout]     |
[INFO] [stdout] 101 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:9
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:108:9
[INFO] [stdout]     |
[INFO] [stdout] 108 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:247:9
[INFO] [stdout]     |
[INFO] [stdout] 247 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:248:9
[INFO] [stdout]     |
[INFO] [stdout] 248 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:174:9
[INFO] [stdout]     |
[INFO] [stdout] 174 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:9
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:186:13
[INFO] [stdout]     |
[INFO] [stdout] 186 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |             socket.send_to(&data, addr).await;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 116 |             let _ = socket.send_to(&data, addr).await;
[INFO] [stdout]     |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:136:17
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 let _ = socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:344:9
[INFO] [stdout]     |
[INFO] [stdout] 344 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:345:9
[INFO] [stdout]     |
[INFO] [stdout] 345 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:9
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:308:9
[INFO] [stdout]     |
[INFO] [stdout] 308 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:314:9
[INFO] [stdout]     |
[INFO] [stdout] 314 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:41:16
[INFO] [stdout]    |
[INFO] [stdout] 41 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:60:16
[INFO] [stdout]    |
[INFO] [stdout] 60 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:63:17
[INFO] [stdout]    |
[INFO] [stdout] 63 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:76:16
[INFO] [stdout]    |
[INFO] [stdout] 76 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:79:17
[INFO] [stdout]    |
[INFO] [stdout] 79 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `time_limit`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     time_limit: f64,
[INFO] [stdout]     |     ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_time_limit`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:13
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:13
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:392:9
[INFO] [stdout]     |
[INFO] [stdout] 392 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:398:9
[INFO] [stdout]     |
[INFO] [stdout] 398 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `speed_rate` and `package_count` are never read
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:18:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | pub struct Opt {
[INFO] [stdout]    |            --- fields in this struct
[INFO] [stdout] ...
[INFO] [stdout] 18 |     speed_rate: f64,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 19 |     #[structopt(short, long, default_value = "1000000")]
[INFO] [stdout] 20 |     package_count: u32,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Opt` has a derived impl for the trait `Debug`, 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: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:105:17
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 let _ = socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:127:16
[INFO] [stdout]     |
[INFO] [stdout] 127 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 127 |                let _ = recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:158:17
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 let _ = socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:180:16
[INFO] [stdout]     |
[INFO] [stdout] 180 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]     |
[INFO] [stdout] 180 |                let _ = recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:47:16
[INFO] [stdout]    |
[INFO] [stdout] 47 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:66:16
[INFO] [stdout]    |
[INFO] [stdout] 66 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:69:17
[INFO] [stdout]    |
[INFO] [stdout] 69 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:82:16
[INFO] [stdout]    |
[INFO] [stdout] 82 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:13
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `pkg_num`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:165:5
[INFO] [stdout]     |
[INFO] [stdout] 165 |     pkg_num: u32,
[INFO] [stdout]     |     ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_pkg_num`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:13
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `recv_tcp_f64` is never used
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:76:10
[INFO] [stdout]    |
[INFO] [stdout] 76 | async fn recv_tcp_f64(stream: &TcpStream, buffer_length: usize) -> Result<f64, Box<dyn Error>> {
[INFO] [stdout]    |          ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:368:5
[INFO] [stdout]     |
[INFO] [stdout] 368 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:458:5
[INFO] [stdout]     |
[INFO] [stdout] 458 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:15:17
[INFO] [stdout]    |
[INFO] [stdout] 15 | /                 (
[INFO] [stdout] 16 | |                     "127.0.0.1:19208".parse().unwrap(),
[INFO] [stdout] 17 | |                     "no comment".to_string(),
[INFO] [stdout] 18 | |                     true,
[INFO] [stdout] 19 | |                 ),
[INFO] [stdout]    | |_________________^ expected `Remote`, found `(_, String, bool)`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]  --> src/params.rs:9:21
[INFO] [stdout]   |
[INFO] [stdout] 9 |         let dis_0 = Distributor {
[INFO] [stdout]   |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:38:17
[INFO] [stdout]    |
[INFO] [stdout] 38 | /                 (
[INFO] [stdout] 39 | |                     "127.0.0.1:19211".parse().unwrap(),
[INFO] [stdout] 40 | |                     "no comment".to_string(),
[INFO] [stdout] 41 | |                     true,
[INFO] [stdout] 42 | |                 ),
[INFO] [stdout]    | |_________________^ expected `Remote`, found `(_, String, bool)`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:32:21
[INFO] [stdout]    |
[INFO] [stdout] 32 |         let dis_1 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:71:17
[INFO] [stdout]    |
[INFO] [stdout] 71 | /                 (
[INFO] [stdout] 72 | |                     "127.0.0.1:19214".parse().unwrap(),
[INFO] [stdout] 73 | |                     "no comment".to_string(),
[INFO] [stdout] 74 | |                     true,
[INFO] [stdout] 75 | |                 ),
[INFO] [stdout]    | |_________________^ expected `Remote`, found `(_, String, bool)`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:65:21
[INFO] [stdout]    |
[INFO] [stdout] 65 |         let dis_2 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:94:17
[INFO] [stdout]    |
[INFO] [stdout] 94 | /                 (
[INFO] [stdout] 95 | |                     "127.0.0.1:19217".parse().unwrap(),
[INFO] [stdout] 96 | |                     "no comment".to_string(),
[INFO] [stdout] 97 | |                     false,
[INFO] [stdout] 98 | |                 ),
[INFO] [stdout]    | |_________________^ expected `Remote`, found `(_, String, bool)`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:88:21
[INFO] [stdout]    |
[INFO] [stdout] 88 |         let dis_3 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `send_buffer` in initializer of `params::Group`
[INFO] [stdout]    --> src/params.rs:121:27
[INFO] [stdout]     |
[INFO] [stdout] 121 |         let mut group_0 = Group { vec: vec![] };
[INFO] [stdout]     |                           ^^^^^ missing `send_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `get_plain_enable` found for struct `params::Group` in the current scope
[INFO] [stdout]    --> src/params.rs:126:34
[INFO] [stdout]     |
[INFO] [stdout] 126 |         println!("{:?}", group_0.get_plain_enable());
[INFO] [stdout]     |                                  ^^^^^^^^^^^^^^^^ help: there is a method with a similar name: `get_flat_enable`
[INFO] [stdout] ...
[INFO] [stdout] 217 | pub struct Group {
[INFO] [stdout]     | ---------------- method `get_plain_enable` not found for this struct
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 9 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 2 arguments but 1 argument was supplied
[INFO] [stdout]    --> src/params.rs:158:19
[INFO] [stdout]     |
[INFO] [stdout] 158 |         let res = Group::from_flat_enable(&flat);
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^------- an argument of type `usize` is missing
[INFO] [stdout]     |
[INFO] [stdout] note: expected a tuple with 3 elements, found one with 2 elements
[INFO] [stdout]    --> src/params.rs:158:43
[INFO] [stdout]     |
[INFO] [stdout] 158 |         let res = Group::from_flat_enable(&flat);
[INFO] [stdout]     |                                           ^^^^^
[INFO] [stdout]     = note: expected reference `&Vec<(usize, std::net::SocketAddr, Vec<std::net::SocketAddr>)>`
[INFO] [stdout]                found reference `&Vec<(_, Vec<_>)>`
[INFO] [stdout] note: associated function defined here
[INFO] [stdout]    --> src/params.rs:249:12
[INFO] [stdout]     |
[INFO] [stdout] 249 |     pub fn from_flat_enable(
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^
[INFO] [stdout] 250 |         flat: &Vec<(usize, std::net::SocketAddr, Vec<std::net::SocketAddr>)>,
[INFO] [stdout]     |         --------------------------------------------------------------------
[INFO] [stdout] 251 |         send_buffer: usize,
[INFO] [stdout]     |         ------------------
[INFO] [stdout] help: provide the argument
[INFO] [stdout]     |
[INFO] [stdout] 158 |         let res = Group::from_flat_enable(/* &Vec<(usize, std::net::SocketAddr, Vec<std::net::SocketAddr>)> */, /* usize */);
[INFO] [stdout]     |                                          ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 11 previous errors; 10 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0061, E0063, E0308, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0061`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `data_distributor` (lib test) due to 12 previous errors; 10 warnings emitted
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stdout] warning: 29 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "8e4dedaabf35c96ee3152cb0ca9d40e23579f04e1b53822c50790c8ce6b14153", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "8e4dedaabf35c96ee3152cb0ca9d40e23579f04e1b53822c50790c8ce6b14153", kill_on_drop: false }`
[INFO] [stdout] 8e4dedaabf35c96ee3152cb0ca9d40e23579f04e1b53822c50790c8ce6b14153
