[INFO] cloning repository https://github.com/a-givertzman/fr-service
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/a-givertzman/fr-service" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fa-givertzman%2Ffr-service", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fa-givertzman%2Ffr-service'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 9f96aaff3ceee829c21b22937f85a731b92a784e
[INFO] testing a-givertzman/fr-service against 1.75.0 for beta-1.76-1
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fa-givertzman%2Ffr-service" "/workspace/builds/worker-4-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-4-tc1/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/a-givertzman/fr-service on toolchain 1.75.0
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.75.0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/a-givertzman/fr-service
[INFO] finished tweaking git repo https://github.com/a-givertzman/fr-service
[INFO] tweaked toml for git repo https://github.com/a-givertzman/fr-service written to /workspace/builds/worker-4-tc1/source/Cargo.toml
[INFO] crate git repo https://github.com/a-givertzman/fr-service 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" "+1.75.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] ccc1a4f47c12d7cdd285e3f0c4bdf7a8b0845ecb364bbd0ea82c7030f59c7de3
[INFO] running `Command { std: "docker" "start" "-a" "ccc1a4f47c12d7cdd285e3f0c4bdf7a8b0845ecb364bbd0ea82c7030f59c7de3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "ccc1a4f47c12d7cdd285e3f0c4bdf7a8b0845ecb364bbd0ea82c7030f59c7de3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "ccc1a4f47c12d7cdd285e3f0c4bdf7a8b0845ecb364bbd0ea82c7030f59c7de3", kill_on_drop: false }`
[INFO] [stdout] ccc1a4f47c12d7cdd285e3f0c4bdf7a8b0845ecb364bbd0ea82c7030f59c7de3
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 453dd5f5d5bac35bd88fffd25cc4f58ec07095b4af16fe581dd5088c37c47410
[INFO] running `Command { std: "docker" "start" "-a" "453dd5f5d5bac35bd88fffd25cc4f58ec07095b4af16fe581dd5088c37c47410", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.67
[INFO] [stderr]    Compiling unicode-ident v1.0.12
[INFO] [stderr]    Compiling serde v1.0.188
[INFO] [stderr]    Compiling libc v0.2.148
[INFO] [stderr]    Compiling autocfg v1.1.0
[INFO] [stderr]    Compiling memchr v2.6.3
[INFO] [stderr]    Compiling rustix v0.38.14
[INFO] [stderr]    Compiling cfg-if v1.0.0
[INFO] [stderr]    Compiling bitflags v2.4.0
[INFO] [stderr]    Compiling linux-raw-sys v0.4.7
[INFO] [stderr]    Compiling regex-syntax v0.7.5
[INFO] [stderr]    Compiling num-traits v0.2.17
[INFO] [stderr]    Compiling equivalent v1.0.1
[INFO] [stderr]    Compiling ppv-lite86 v0.2.17
[INFO] [stderr]    Compiling serde_json v1.0.107
[INFO] [stderr]    Compiling ryu v1.0.15
[INFO] [stderr]    Compiling itoa v1.0.9
[INFO] [stderr]    Compiling aho-corasick v1.1.1
[INFO] [stderr]    Compiling hashbrown v0.14.1
[INFO] [stderr]    Compiling quote v1.0.33
[INFO] [stderr]    Compiling syn v2.0.37
[INFO] [stderr]    Compiling getrandom v0.2.10
[INFO] [stderr]    Compiling rand_core v0.6.4
[INFO] [stderr]    Compiling is-terminal v0.4.9
[INFO] [stderr]    Compiling indexmap v2.0.2
[INFO] [stderr]    Compiling humantime v2.1.0
[INFO] [stderr]    Compiling rand_chacha v0.3.1
[INFO] [stderr]    Compiling log v0.4.20
[INFO] [stderr]    Compiling termcolor v1.3.0
[INFO] [stderr]    Compiling unsafe-libyaml v0.2.9
[INFO] [stderr]    Compiling inventory v0.3.12
[INFO] [stderr]    Compiling once_cell v1.18.0
[INFO] [stderr]    Compiling iana-time-zone v0.1.58
[INFO] [stderr]    Compiling rand v0.8.5
[INFO] [stderr]    Compiling chrono v0.4.31
[INFO] [stderr]    Compiling regex-automata v0.3.8
[INFO] [stderr]    Compiling serde_derive v1.0.188
[INFO] [stderr]    Compiling typetag-impl v0.2.13
[INFO] [stderr]    Compiling regex v1.9.5
[INFO] [stderr]    Compiling env_logger v0.10.0
[INFO] [stderr]    Compiling erased-serde v0.3.31
[INFO] [stderr]    Compiling serde_yaml v0.9.25
[INFO] [stderr]    Compiling typetag v0.2.13
[INFO] [stderr]    Compiling fr-service v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_decode_message.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Read, BufReader, ErrorKind}};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^             ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_decode_message.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, debug, trace};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_deserialize.rs:3:16
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{io::{BufReader, Read}, net::TcpStream};
[INFO] [stdout]   |                ^^^^^^^^^         ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_deserialize.rs:6:17
[INFO] [stdout]   |
[INFO] [stdout] 6 | use log::{warn, error, trace, LevelFilter};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `str::FromStr`
[INFO] [stdout]  --> src/conf/api_client_config.rs:4:15
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stdout]   |               ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stdout]  --> src/conf/api_client_config.rs:6:40
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stdout]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `super::conf_keywd::ConfKind`
[INFO] [stdout]  --> src/conf/api_client_config.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use super::conf_keywd::ConfKind;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `net::SocketAddr`, `str::FromStr`, `time::Duration`
[INFO] [stdout]  --> src/conf/multi_queue_config.rs:4:15
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stdout]   |               ^^^^^^^^^^^^  ^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stdout]  --> src/conf/multi_queue_config.rs:6:40
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stdout]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AtomicUsize`
[INFO] [stdout]  --> src/services/task/task_test_receiver.rs:3:86
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{sync::{mpsc::{Receiver, Sender, self}, Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex}, thread::{self, JoinHandle}, co...
[INFO] [stdout]   |                                                                                      ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `warn`
[INFO] [stdout]  --> src/services/multi_queue/multi_queue.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{info, warn, error, debug, trace};
[INFO] [stdout]   |                 ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/services/multi_queue/subscriptions.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, debug, trace};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicBool`, `AtomicUsize`, `MutexGuard`, `Once`, `Ordering`
[INFO] [stdout]  --> src/tcp/tcp_client_connect.rs:3:93
[INFO] [stdout]   |
[INFO] [stdout] 3 | ...sync::{Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex, mpsc::{Sender, Receiver, self}, Once, MutexGuard}, thread};
[INFO] [stdout]   |                         ^^^^^^^^^^  ^^^^^^^^  ^^^^^^^^^^^                                          ^^^^  ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `net::TcpStream`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:5:30
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, LevelFilter, debug, trace};
[INFO] [stdout]   |                              ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ErrorKind`
[INFO] [stdout]  --> src/tcp/tcp_socket.rs:3:50
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, BufReader, ErrorKind, Read}, sync::atomic::AtomicBool};
[INFO] [stdout]   |                                                  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Read`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:3:39
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stdout]   |                                       ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `err`
[INFO] [stdout]    --> src/conf/fn_conf_keywd.rs:119:33
[INFO] [stdout]     |
[INFO] [stdout] 119 | ...                   Err(err) => {
[INFO] [stdout]     |                           ^^^ help: if this is intentional, prefix it with an underscore: `_err`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:179:21
[INFO] [stdout]     |
[INFO] [stdout] 179 |             let mut connectionClosed = false;
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:213:57
[INFO] [stdout]     |
[INFO] [stdout] 213 | ...                   connectionClosed = true;
[INFO] [stdout]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:220:49
[INFO] [stdout]     |
[INFO] [stdout] 220 | ...                   connectionClosed = true;
[INFO] [stdout]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `point`
[INFO] [stdout]   --> src/services/task/nested_function/fn_.rs:13:23
[INFO] [stdout]    |
[INFO] [stdout] 13 |     fn add(&mut self, point: PointType) {
[INFO] [stdout]    |                       ^^^^^ help: if this is intentional, prefix it with an underscore: `_point`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `id`
[INFO] [stdout]   --> src/services/task/nested_function/fn_count.rs:31:16
[INFO] [stdout]    |
[INFO] [stdout] 31 |     pub fn new(id: impl Into<String>, initial: f64, input: FnInOutRef) -> Self {
[INFO] [stdout]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `id`
[INFO] [stdout]   --> src/services/task/nested_function/fn_ge.rs:26:16
[INFO] [stdout]    |
[INFO] [stdout] 26 |     pub fn new(id: impl Into<String>, input1: FnInOutRef, input2: FnInOutRef) -> Self {
[INFO] [stdout]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `receiverId`
[INFO] [stdout]   --> src/services/service.rs:19:29
[INFO] [stdout]    |
[INFO] [stdout] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stdout]    |                             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `points`
[INFO] [stdout]   --> src/services/service.rs:19:47
[INFO] [stdout]    |
[INFO] [stdout] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stdout]    |                                               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `receiverId`
[INFO] [stdout]   --> src/services/service.rs:24:31
[INFO] [stdout]    |
[INFO] [stdout] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stdout]    |                               ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `points`
[INFO] [stdout]   --> src/services/service.rs:24:49
[INFO] [stdout]    |
[INFO] [stdout] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stdout]    |                                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `inner` is never read
[INFO] [stdout]   --> src/main.rs:24:9
[INFO] [stdout]    |
[INFO] [stdout] 20 | struct Ikea<S, T, Q> 
[INFO] [stdout]    |        ---- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub inner: Vec<S>, 
[INFO] [stdout]    |         ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Ikea` 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: struct `Inner` is never constructed
[INFO] [stdout]   --> src/main.rs:77:8
[INFO] [stdout]    |
[INFO] [stdout] 77 | struct Inner<T, Q> 
[INFO] [stdout]    |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `cmpValue` are never used
[INFO] [stdout]    --> src/core_/point/point_type.rs:54:12
[INFO] [stdout]     |
[INFO] [stdout] 51  | impl PointType {
[INFO] [stdout]     | -------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 54  |     pub fn new<T: ToPoint>(txId: usize, name: &str, value: T) -> Self {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 131 |     pub fn cmpValue(&self, other: &PointType) -> bool {
[INFO] [stdout]     |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `Active` is never constructed
[INFO] [stdout]   --> src/core_/net/protocols/jds/jds_decode_message.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | enum Status {
[INFO] [stdout]    |      ------ variant in this enum
[INFO] [stdout] 11 |     Active,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `id` is never read
[INFO] [stdout]   --> src/core_/retain_buffer/retain_buffer.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub struct RetainBuffer<T> {
[INFO] [stdout]    |            ------------ field in this struct
[INFO] [stdout] 14 |     id: String,
[INFO] [stdout]    |     ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `store` is never used
[INFO] [stdout]   --> src/core_/retain_buffer/retain_buffer.rs:66:12
[INFO] [stdout]    |
[INFO] [stdout] 20 | impl<T> RetainBuffer<T> {
[INFO] [stdout]    | ----------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 66 |     pub fn store(&self) {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: static `TCP_PORT_COUNTER` is never used
[INFO] [stdout]  --> src/core_/testing/test_session.rs:4:8
[INFO] [stdout]   |
[INFO] [stdout] 4 | static TCP_PORT_COUNTER: AtomicUsize = AtomicUsize::new(9000);
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TestSession` is never constructed
[INFO] [stdout]  --> src/core_/testing/test_session.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct TestSession {}
[INFO] [stdout]   |            ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated functions `freeTcpPortInt` and `freeTcpPortStr` are never used
[INFO] [stdout]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl TestSession {
[INFO] [stdout]    | ---------------- associated functions in this implementation
[INFO] [stdout] 12 |     /// Returns any free available TCP port as usize
[INFO] [stdout] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 19 |     pub fn freeTcpPortStr() -> String {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variants `Bool`, `Int`, `Float`, and `String` are never constructed
[INFO] [stdout]   --> src/core_/testing/test_stuff/test_value.rs:7:5
[INFO] [stdout]    |
[INFO] [stdout] 6  | pub enum Value {
[INFO] [stdout]    |          ----- variants in this enum
[INFO] [stdout] 7  |     Bool(bool),
[INFO] [stdout]    |     ^^^^
[INFO] [stdout] 8  |     Int(i64),
[INFO] [stdout]    |     ^^^
[INFO] [stdout] 9  |     Float(f64),
[INFO] [stdout]    |     ^^^^^
[INFO] [stdout] 10 |     String(String),
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Value` has derived impls for the traits `Clone` and `Debug`, but these are intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `toString` and `toPoint` are never used
[INFO] [stdout]   --> src/core_/testing/test_stuff/test_value.rs:13:12
[INFO] [stdout]    |
[INFO] [stdout] 12 | impl Value {
[INFO] [stdout]    | ---------- methods in this implementation
[INFO] [stdout] 13 |     pub fn toString(&self) -> String {
[INFO] [stdout]    |            ^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 21 |     pub fn toPoint(&self, txId: usize, name: &str) -> PointType {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/core_/testing/test_stuff/random_test_values.rs:21:13
[INFO] [stdout]    |
[INFO] [stdout] 18 | impl RandomTestValues {
[INFO] [stdout]    | --------------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 21 |     pub fn  new(parent: impl Into<String>, initial: Vec<Value>, iterations: usize) -> Self {
[INFO] [stdout]    |             ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `MaxTestDuration` is never constructed
[INFO] [stdout]  --> src/core_/testing/test_stuff/max_test_duration.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct MaxTestDuration {
[INFO] [stdout]   |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `run`, and `exit` are never used
[INFO] [stdout]   --> src/core_/testing/test_stuff/max_test_duration.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 16 | impl MaxTestDuration {
[INFO] [stdout]    | -------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 19 |     pub fn new(parent: impl Into<String>, duration: Duration) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 28 |     pub fn run(&self) -> Result<JoinHandle<()>, std::io::Error> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 52 |     pub fn exit(&self) {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `asBool`, `asI64`, and `remove` are never used
[INFO] [stdout]    --> src/conf/conf_tree.rs:86:12
[INFO] [stdout]     |
[INFO] [stdout] 19  | impl ConfTree {
[INFO] [stdout]     | ------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 86  |     pub fn asBool(&self, key: &str) -> Result<bool, String> {
[INFO] [stdout]     |            ^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 99  |     pub fn asI64(&self, key: &str) -> Result<i64, String> {
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 139 |     pub fn remove(&mut self, key: &str) -> Result<serde_yaml::Value, String> {
[INFO] [stdout]     |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated functions `new`, `fromYamlValue`, and `read` are never used
[INFO] [stdout]   --> src/conf/api_client_config.rs:45:12
[INFO] [stdout]    |
[INFO] [stdout] 33 | impl ApiClientConfig {
[INFO] [stdout]    | -------------------- associated functions in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 45 |     pub fn new(confTree: &mut ConfTree) -> ApiClientConfig {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 85 |     pub(crate) fn fromYamlValue(value: &serde_yaml::Value) -> ApiClientConfig {
[INFO] [stdout]    |                   ^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 90 |     pub fn read(path: &str) -> ApiClientConfig {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `first` is never used
[INFO] [stdout]   --> src/conf/service_config.rs:34:12
[INFO] [stdout]    |
[INFO] [stdout] 20 | impl ServiceConfig {
[INFO] [stdout]    | ------------------ method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 34 |     pub fn first(&self) -> Option<ConfTree> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/api_cient/api_client.rs:34:12
[INFO] [stdout]    |
[INFO] [stdout] 30 | impl ApiClient {
[INFO] [stdout]    | -------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 34 |     pub fn new(parent: impl Into<String>, conf: ApiClientConfig) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `asBytes` is never used
[INFO] [stdout]   --> src/services/api_cient/api_query.rs:61:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | impl ApiQuery {
[INFO] [stdout]    | ------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 61 |     pub fn asBytes(&self) -> Vec<u8> {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `asBytes` and `error` are never used
[INFO] [stdout]   --> src/services/api_cient/api_reply.rs:37:12
[INFO] [stdout]    |
[INFO] [stdout] 21 | impl SqlReply {
[INFO] [stdout]    | ------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 37 |     pub fn asBytes(&self) -> Vec<u8> {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 47 |     pub fn error(
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `empty`, `asJason`, and `toString` are never used
[INFO] [stdout]    --> src/services/api_cient/api_error.rs:19:12
[INFO] [stdout]     |
[INFO] [stdout] 16  | impl ApiError {
[INFO] [stdout]     | ------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 19  |     pub fn new(message: impl Into<String>, details: impl Into<String>) -> Self {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 28  |     pub fn empty() -> Self {
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 66  |     pub fn asJason(&self, debug: bool) -> serde_json::Value {
[INFO] [stdout]     |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 108 |     pub fn toString(self) -> String {
[INFO] [stdout]     |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/tcp_client/tcp_client.rs:42:12
[INFO] [stdout]    |
[INFO] [stdout] 38 | impl TcpClient {
[INFO] [stdout]    | -------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 42 |     pub fn new(parent: impl Into<String>, conf: TcpClientConfig, services: Arc<Mutex<Services>>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `sendQueues` and `recvQueues` are never read
[INFO] [stdout]   --> src/services/queues/queues.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub struct Queues {
[INFO] [stdout]    |            ------ fields in this struct
[INFO] [stdout] 12 |     // vars: HashMap<String, FnInOutRef>,
[INFO] [stdout] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Queues` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `addSendQueue`, `addRecvQueue`, `getSendQueue`, and `getRecvQueue` are never used
[INFO] [stdout]   --> src/services/queues/queues.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 16 | impl Queues {
[INFO] [stdout]    | ----------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 19 |     pub fn new() -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/task/task.rs:33:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | impl Task {
[INFO] [stdout]    | --------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 33 |     pub fn new(parent: impl Into<String>, conf: TaskConfig, services: Arc<Mutex<Services>>) -> Task {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `names` is never used
[INFO] [stdout]   --> src/services/task/task_node_vars.rs:36:8
[INFO] [stdout]    |
[INFO] [stdout] 17 | impl TaskNodeVars {
[INFO] [stdout]    | ----------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 36 |     fn names(collection: &HashMap<String, FnInOutRef>) -> Vec<String> {
[INFO] [stdout]    |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `getVars` and `getOuts` are never used
[INFO] [stdout]   --> src/services/task/task_eval_node.rs:82:12
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl TaskEvalNode {
[INFO] [stdout]    | ----------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 82 |     pub fn getVars(&self) -> &Vec<FnInOutRef> {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |     pub fn getOuts(&self) -> &Vec<FnInOutRef> {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `received` are never used
[INFO] [stdout]   --> src/services/task/task_test_receiver.rs:22:12
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl TaskTestReceiver {
[INFO] [stdout]    | --------------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 22 |     pub fn new(recvQueue: &str, iterations: usize) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 35 |     pub fn received(&self) -> Arc<Mutex<Vec<PointType>>> {
[INFO] [stdout]    |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new` and `sent` are never used
[INFO] [stdout]   --> src/services/task/task_test_producer.rs:25:12
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl TaskTestProducer {
[INFO] [stdout]    | --------------------- associated items in this implementation
[INFO] [stdout] 25 |     pub fn new(iterations: usize, link: &str, services: Arc<Mutex<Services>>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 38 |     pub fn sent(&self) -> Arc<Mutex<Vec<PointType>>> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/task/queue_send_mpsc_channel.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | impl<T> QueueSendMpscChannel<T> {
[INFO] [stdout]    | ------------------------------- associated function in this implementation
[INFO] [stdout] 19 |     pub fn new(send: Sender<T>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]   --> src/services/task/nested_function/fn_add.rs:91:8
[INFO] [stdout]    |
[INFO] [stdout] 91 | pub fn resetCount() {
[INFO] [stdout]    |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnMul` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:114:12
[INFO] [stdout]     |
[INFO] [stdout] 114 | pub struct FnMul;
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnOr` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:115:12
[INFO] [stdout]     |
[INFO] [stdout] 115 | pub struct FnOr;
[INFO] [stdout]     |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnCompare` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:116:12
[INFO] [stdout]     |
[INFO] [stdout] 116 | pub struct FnCompare;
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]   --> src/services/task/nested_function/fn_count.rs:94:8
[INFO] [stdout]    |
[INFO] [stdout] 94 | pub fn resetCount() {
[INFO] [stdout]    |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]    --> src/services/task/nested_function/fn_ge.rs:113:8
[INFO] [stdout]     |
[INFO] [stdout] 113 | pub fn resetCount() {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: static `COUNT` is never used
[INFO] [stdout]    --> src/services/task/nested_function/fn_timer.rs:186:8
[INFO] [stdout]     |
[INFO] [stdout] 186 | static COUNT: AtomicUsize = AtomicUsize::new(0);
[INFO] [stdout]     |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]    --> src/services/task/nested_function/fn_timer.rs:187:8
[INFO] [stdout]     |
[INFO] [stdout] 187 | pub fn resetCount() {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `insert`, `get`, and `subscribe` are never used
[INFO] [stdout]   --> src/services/services.rs:22:12
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl Services {
[INFO] [stdout]    | ------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 22 |     pub fn new(parent: impl Into<String>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 30 |     pub fn insert(&mut self, id:&str, service: Arc<Mutex<dyn Service + Send>>) {
[INFO] [stdout]    |            ^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 38 |     pub fn get(&self, name: &str) -> Arc<Mutex<dyn Service>> {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 55 |     pub fn subscribe(&mut self, service: &str, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/multi_queue/multi_queue.rs:32:12
[INFO] [stdout]    |
[INFO] [stdout] 28 | impl MultiQueue {
[INFO] [stdout]    | --------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 32 |     pub fn new(parent: impl Into<String>, conf: MultiQueueConfig, services: Arc<Mutex<Services>>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/multi_queue/subscriptions.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 24 | impl Subscriptions {
[INFO] [stdout]    | ------------------ associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 27 |     pub fn new(parent: impl Into<String>, ) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `exitSend` is never read
[INFO] [stdout]   --> src/tcp/tcp_client_connect.rs:44:5
[INFO] [stdout]    |
[INFO] [stdout] 39 | pub struct TcpClientConnect {
[INFO] [stdout]    |            ---------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 44 |     exitSend: Sender<bool>,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `connect_timeout` and `exit` are never used
[INFO] [stdout]    --> src/tcp/tcp_client_connect.rs:151:12
[INFO] [stdout]     |
[INFO] [stdout] 49  | impl TcpClientConnect {
[INFO] [stdout]     | --------------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 151 |     pub fn connect_timeout(&self, timeout: Duration) -> Result<TcpStream, std::io::Error> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 156 |     pub fn exit(&self) -> Sender<bool> {
[INFO] [stdout]     |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `buffered` is never read
[INFO] [stdout]   --> src/tcp/tcp_stream_write.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub struct TcpStreamWrite {
[INFO] [stdout]    |            -------------- field in this struct
[INFO] [stdout] 15 |     id: String,
[INFO] [stdout] 16 |     buffered: bool,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TcpSocket` is never constructed
[INFO] [stdout]   --> src/tcp/tcp_socket.rs:11:8
[INFO] [stdout]    |
[INFO] [stdout] 11 | struct TcpSocket {
[INFO] [stdout]    |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `read`, `write`, and `readAll` are never used
[INFO] [stdout]   --> src/tcp/tcp_socket.rs:20:12
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl TcpSocket {
[INFO] [stdout]    | -------------- associated items in this implementation
[INFO] [stdout] 20 |     pub fn new(parent: impl Into<String>, tcpStream: TcpStream) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 30 |     pub fn read(&mut self) -> Result<Vec<u8>, String> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 42 |     pub fn write(&mut self, bytes: &[u8]) -> Result<usize, String> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |     fn readAll(selfId: &str, bytes: &mut Vec<u8>, stream: &mut BufReader<TcpStream>) -> ConnectionStatus<(), String> {
[INFO] [stdout]    |        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait method `aproxEq` should have a snake case name
[INFO] [stdout]  --> src/core_/aprox_eq/aprox_eq.rs:4:8
[INFO] [stdout]   |
[INFO] [stdout] 4 |     fn aproxEq(&self, other: T, decimals: usize) -> bool;
[INFO] [stdout]   |        ^^^^^^^ help: convert the identifier to snake case: `aprox_eq`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait method `typeOf` should have a snake case name
[INFO] [stdout]  --> src/core_/types/type_of.rs:2:8
[INFO] [stdout]   |
[INFO] [stdout] 2 |     fn typeOf(&self) {
[INFO] [stdout]   |        ^^^^^^ help: convert the identifier to snake case: `type_of`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `freeTcpPortInt` should have a snake case name
[INFO] [stdout]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stdout]    |
[INFO] [stdout] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_int`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `freeTcpPortStr` should have a snake case name
[INFO] [stdout]   --> src/core_/testing/test_session.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 19 |     pub fn freeTcpPortStr() -> String {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_str`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: structure field `sendQueues` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `send_queues`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: structure field `recvQueues` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `recv_queues`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `addSendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:35:12
[INFO] [stdout]    |
[INFO] [stdout] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `addRecvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:45:12
[INFO] [stdout]    |
[INFO] [stdout] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `getSendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:60:12
[INFO] [stdout]    |
[INFO] [stdout] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `sendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:62:18
[INFO] [stdout]    |
[INFO] [stdout] 62 |             Some(sendQueue) => sendQueue.clone(),
[INFO] [stdout]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `getRecvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:70:12
[INFO] [stdout]    |
[INFO] [stdout] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `recvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:72:18
[INFO] [stdout]    |
[INFO] [stdout] 72 |             Some(recvQueue) => recvQueue,
[INFO] [stdout]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 86 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 25.18s
[INFO] running `Command { std: "docker" "inspect" "453dd5f5d5bac35bd88fffd25cc4f58ec07095b4af16fe581dd5088c37c47410", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "453dd5f5d5bac35bd88fffd25cc4f58ec07095b4af16fe581dd5088c37c47410", kill_on_drop: false }`
[INFO] [stdout] 453dd5f5d5bac35bd88fffd25cc4f58ec07095b4af16fe581dd5088c37c47410
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] b42bb7814a9c0f5573dfe0ed5281d89875b276238f2c0b2c4064d1e3a985fdb5
[INFO] running `Command { std: "docker" "start" "-a" "b42bb7814a9c0f5573dfe0ed5281d89875b276238f2c0b2c4064d1e3a985fdb5", kill_on_drop: false }`
[INFO] [stderr]    Compiling fr-service v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused imports: `debug`, `warn`
[INFO] [stdout]  --> src/tests/unit/core_/retain_buffer/retain_buffer_test.rs:4:15
[INFO] [stdout]   |
[INFO] [stdout] 4 |     use log::{warn, info, debug};
[INFO] [stdout]   |               ^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/tests/unit/core_/retain_buffer/retain_buffer_test.rs:5:34
[INFO] [stdout]   |
[INFO] [stdout] 5 |     use std::{sync::Once, time::{Duration, Instant}};
[INFO] [stdout]   |                                  ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `warn`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:5:15
[INFO] [stdout]   |
[INFO] [stdout] 5 |     use log::{warn, info, debug};
[INFO] [stdout]   |               ^^^^        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `serde_json::json`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:6:9
[INFO] [stdout]   |
[INFO] [stdout] 6 |     use serde_json::json;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:7:42
[INFO] [stdout]   |
[INFO] [stdout] 7 |     use std::{sync::{Once, mpsc}, time::{Duration, Instant}};
[INFO] [stdout]   |                                          ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `warn`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:5:15
[INFO] [stdout]   |
[INFO] [stdout] 5 |     use log::{warn, info, debug};
[INFO] [stdout]   |               ^^^^        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `serde_json::json`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:6:9
[INFO] [stdout]   |
[INFO] [stdout] 6 |     use serde_json::json;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `Instant`
[INFO] [stdout]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:7:42
[INFO] [stdout]   |
[INFO] [stdout] 7 |     use std::{sync::{Once, mpsc}, time::{Duration, Instant}};
[INFO] [stdout]   |                                          ^^^^^^^^  ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `warn`
[INFO] [stdout]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:5:15
[INFO] [stdout]   |
[INFO] [stdout] 5 |     use log::{warn, info, debug};
[INFO] [stdout]   |               ^^^^        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `thread_rng`
[INFO] [stdout]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:6:16
[INFO] [stdout]   |
[INFO] [stdout] 6 |     use rand::{thread_rng, Rng};
[INFO] [stdout]   |                ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `net::TcpStream`
[INFO] [stdout]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:7:68
[INFO] [stdout]   |
[INFO] [stdout] 7 |     use std::{sync::{atomic::{AtomicUsize, Ordering}, Arc, Mutex}, net::TcpStream, thread};
[INFO] [stdout]   |                                                                    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Instant`
[INFO] [stdout]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:8:44
[INFO] [stdout]   |
[INFO] [stdout] 8 |     use std::{sync::Once, time::{Duration, Instant}};
[INFO] [stdout]   |                                            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Instant`
[INFO] [stdout]  --> src/tests/unit/services/multi_queue/multi_queue_subscription_test.rs:5:58
[INFO] [stdout]   |
[INFO] [stdout] 5 |     use std::{sync::{Once, Arc, Mutex}, time::{Duration, Instant}, thread::{self, JoinHandle}, any::Any, collections::HashMap};
[INFO] [stdout]   |                                                          ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_decode_message.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Read, BufReader, ErrorKind}};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^             ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_decode_message.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, debug, trace};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_deserialize.rs:3:16
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{io::{BufReader, Read}, net::TcpStream};
[INFO] [stdout]   |                ^^^^^^^^^         ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]  --> src/core_/net/protocols/jds/jds_deserialize.rs:6:17
[INFO] [stdout]   |
[INFO] [stdout] 6 | use log::{warn, error, trace, LevelFilter};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `str::FromStr`
[INFO] [stdout]  --> src/conf/api_client_config.rs:4:15
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stdout]   |               ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stdout]  --> src/conf/api_client_config.rs:6:40
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stdout]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `super::conf_keywd::ConfKind`
[INFO] [stdout]  --> src/conf/api_client_config.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use super::conf_keywd::ConfKind;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `net::SocketAddr`, `str::FromStr`, `time::Duration`
[INFO] [stdout]  --> src/conf/multi_queue_config.rs:4:15
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stdout]   |               ^^^^^^^^^^^^  ^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stdout]  --> src/conf/multi_queue_config.rs:6:40
[INFO] [stdout]   |
[INFO] [stdout] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stdout]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AtomicUsize`
[INFO] [stdout]  --> src/services/task/task_test_receiver.rs:3:86
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{sync::{mpsc::{Receiver, Sender, self}, Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex}, thread::{self, JoinHandle}, co...
[INFO] [stdout]   |                                                                                      ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `warn`
[INFO] [stdout]  --> src/services/multi_queue/multi_queue.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{info, warn, error, debug, trace};
[INFO] [stdout]   |                 ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/services/multi_queue/subscriptions.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, debug, trace};
[INFO] [stdout]   |                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `AtomicBool`, `AtomicUsize`, `MutexGuard`, `Once`, `Ordering`
[INFO] [stdout]  --> src/tcp/tcp_client_connect.rs:3:93
[INFO] [stdout]   |
[INFO] [stdout] 3 | ...sync::{Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex, mpsc::{Sender, Receiver, self}, Once, MutexGuard}, thread};
[INFO] [stdout]   |                         ^^^^^^^^^^  ^^^^^^^^  ^^^^^^^^^^^                                          ^^^^  ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `net::TcpStream`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `debug`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:5:30
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{warn, LevelFilter, debug, trace};
[INFO] [stdout]   |                              ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `ErrorKind`
[INFO] [stdout]  --> src/tcp/tcp_socket.rs:3:50
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, BufReader, ErrorKind, Read}, sync::atomic::AtomicBool};
[INFO] [stdout]   |                                                  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Read`
[INFO] [stdout]  --> src/tcp/tcp_stream_write.rs:3:39
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stdout]   |                                       ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `json`
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:62:14
[INFO] [stdout]    |
[INFO] [stdout] 62 |         for (json, target) in testData {
[INFO] [stdout]    |              ^^^^ help: if this is intentional, prefix it with an underscore: `_json`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `target`
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:62:20
[INFO] [stdout]    |
[INFO] [stdout] 62 |         for (json, target) in testData {
[INFO] [stdout]    |                    ^^^^^^ help: if this is intentional, prefix it with an underscore: `_target`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `recv`
[INFO] [stdout]   --> src/tests/unit/services/multi_queue/mock_send_service.rs:28:20
[INFO] [stdout]    |
[INFO] [stdout] 28 |         let (send, recv) = mpsc::channel::<PointType>();
[INFO] [stdout]    |                    ^^^^ help: if this is intentional, prefix it with an underscore: `_recv`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `name`
[INFO] [stdout]   --> src/tests/unit/services/multi_queue/mock_tcp_server.rs:68:27
[INFO] [stdout]    |
[INFO] [stdout] 68 |     fn getLink(&mut self, name: &str) -> std::sync::mpsc::Sender<crate::core_::point::point_type::PointType> {
[INFO] [stdout]    |                           ^^^^ help: if this is intentional, prefix it with an underscore: `_name`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `err`
[INFO] [stdout]    --> src/conf/fn_conf_keywd.rs:119:33
[INFO] [stdout]     |
[INFO] [stdout] 119 | ...                   Err(err) => {
[INFO] [stdout]     |                           ^^^ help: if this is intentional, prefix it with an underscore: `_err`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:179:21
[INFO] [stdout]     |
[INFO] [stdout] 179 |             let mut connectionClosed = false;
[INFO] [stdout]     |                     ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:213:57
[INFO] [stdout]     |
[INFO] [stdout] 213 | ...                   connectionClosed = true;
[INFO] [stdout]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `connectionClosed` is never read
[INFO] [stdout]    --> src/services/api_cient/api_client.rs:220:49
[INFO] [stdout]     |
[INFO] [stdout] 220 | ...                   connectionClosed = true;
[INFO] [stdout]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `point`
[INFO] [stdout]   --> src/services/task/nested_function/fn_.rs:13:23
[INFO] [stdout]    |
[INFO] [stdout] 13 |     fn add(&mut self, point: PointType) {
[INFO] [stdout]    |                       ^^^^^ help: if this is intentional, prefix it with an underscore: `_point`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `id`
[INFO] [stdout]   --> src/services/task/nested_function/fn_count.rs:31:16
[INFO] [stdout]    |
[INFO] [stdout] 31 |     pub fn new(id: impl Into<String>, initial: f64, input: FnInOutRef) -> Self {
[INFO] [stdout]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `id`
[INFO] [stdout]   --> src/services/task/nested_function/fn_ge.rs:26:16
[INFO] [stdout]    |
[INFO] [stdout] 26 |     pub fn new(id: impl Into<String>, input1: FnInOutRef, input2: FnInOutRef) -> Self {
[INFO] [stdout]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `receiverId`
[INFO] [stdout]   --> src/services/service.rs:19:29
[INFO] [stdout]    |
[INFO] [stdout] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stdout]    |                             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `points`
[INFO] [stdout]   --> src/services/service.rs:19:47
[INFO] [stdout]    |
[INFO] [stdout] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stdout]    |                                               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `receiverId`
[INFO] [stdout]   --> src/services/service.rs:24:31
[INFO] [stdout]    |
[INFO] [stdout] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stdout]    |                               ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `points`
[INFO] [stdout]   --> src/services/service.rs:24:49
[INFO] [stdout]    |
[INFO] [stdout] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stdout]    |                                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `inner` is never read
[INFO] [stdout]   --> src/main.rs:24:9
[INFO] [stdout]    |
[INFO] [stdout] 20 | struct Ikea<S, T, Q> 
[INFO] [stdout]    |        ---- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 24 |     pub inner: Vec<S>, 
[INFO] [stdout]    |         ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Ikea` 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: struct `Inner` is never constructed
[INFO] [stdout]   --> src/main.rs:77:8
[INFO] [stdout]    |
[INFO] [stdout] 77 | struct Inner<T, Q> 
[INFO] [stdout]    |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: static `INIT` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:12:12
[INFO] [stdout]    |
[INFO] [stdout] 12 |     static INIT: Once = Once::new();
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `initOnce` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:16:8
[INFO] [stdout]    |
[INFO] [stdout] 16 |     fn initOnce() {
[INFO] [stdout]    |        ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `initEach` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:27:8
[INFO] [stdout]    |
[INFO] [stdout] 27 |     fn initEach() -> () {
[INFO] [stdout]    |        ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `ts` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:31:8
[INFO] [stdout]    |
[INFO] [stdout] 31 |     fn ts() -> DateTime<Utc> {
[INFO] [stdout]    |        ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `tsStr` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:34:8
[INFO] [stdout]    |
[INFO] [stdout] 34 |     fn tsStr(ts: DateTime<Utc>) -> String {
[INFO] [stdout]    |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `test_point_from_json_bytes` is never used
[INFO] [stdout]   --> src/tests/unit/core_/point/point_from_json_test.rs:39:8
[INFO] [stdout]    |
[INFO] [stdout] 39 |     fn test_point_from_json_bytes() {
[INFO] [stdout]    |        ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `id` is never used
[INFO] [stdout]   --> src/tests/unit/services/multi_queue/mock_recv_service.rs:35:12
[INFO] [stdout]    |
[INFO] [stdout] 20 | impl MockRecvService {
[INFO] [stdout]    | -------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 35 |     pub fn id(&self) -> String {
[INFO] [stdout]    |            ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `id` is never used
[INFO] [stdout]   --> src/tests/unit/services/multi_queue/mock_send_service.rs:45:12
[INFO] [stdout]    |
[INFO] [stdout] 25 | impl MockSendService {
[INFO] [stdout]    | -------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 45 |     pub fn id(&self) -> String {
[INFO] [stdout]    |            ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `sent` is never used
[INFO] [stdout]   --> src/tests/unit/services/multi_queue/mock_tcp_server.rs:49:12
[INFO] [stdout]    |
[INFO] [stdout] 26 | impl MockTcpServer {
[INFO] [stdout]    | ------------------ method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 49 |     pub fn sent(&self) -> Arc<Mutex<Vec<PointType>>> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/core_/point/point_type.rs:54:12
[INFO] [stdout]    |
[INFO] [stdout] 51 | impl PointType {
[INFO] [stdout]    | -------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 54 |     pub fn new<T: ToPoint>(txId: usize, name: &str, value: T) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `Active` is never constructed
[INFO] [stdout]   --> src/core_/net/protocols/jds/jds_decode_message.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | enum Status {
[INFO] [stdout]    |      ------ variant in this enum
[INFO] [stdout] 11 |     Active,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `id` is never read
[INFO] [stdout]   --> src/core_/retain_buffer/retain_buffer.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | pub struct RetainBuffer<T> {
[INFO] [stdout]    |            ------------ field in this struct
[INFO] [stdout] 14 |     id: String,
[INFO] [stdout]    |     ^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `store` is never used
[INFO] [stdout]   --> src/core_/retain_buffer/retain_buffer.rs:66:12
[INFO] [stdout]    |
[INFO] [stdout] 20 | impl<T> RetainBuffer<T> {
[INFO] [stdout]    | ----------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 66 |     pub fn store(&self) {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `freeTcpPortInt` is never used
[INFO] [stdout]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stdout]    |
[INFO] [stdout] 11 | impl TestSession {
[INFO] [stdout]    | ---------------- associated function in this implementation
[INFO] [stdout] 12 |     /// Returns any free available TCP port as usize
[INFO] [stdout] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `remove` is never used
[INFO] [stdout]    --> src/conf/conf_tree.rs:139:12
[INFO] [stdout]     |
[INFO] [stdout] 19  | impl ConfTree {
[INFO] [stdout]     | ------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 139 |     pub fn remove(&mut self, key: &str) -> Result<serde_yaml::Value, String> {
[INFO] [stdout]     |            ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `first` is never used
[INFO] [stdout]   --> src/conf/service_config.rs:34:12
[INFO] [stdout]    |
[INFO] [stdout] 20 | impl ServiceConfig {
[INFO] [stdout]    | ------------------ method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 34 |     pub fn first(&self) -> Option<ConfTree> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `asBytes` is never used
[INFO] [stdout]   --> src/services/api_cient/api_query.rs:61:12
[INFO] [stdout]    |
[INFO] [stdout] 29 | impl ApiQuery {
[INFO] [stdout]    | ------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 61 |     pub fn asBytes(&self) -> Vec<u8> {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `error` is never used
[INFO] [stdout]   --> src/services/api_cient/api_reply.rs:47:12
[INFO] [stdout]    |
[INFO] [stdout] 21 | impl SqlReply {
[INFO] [stdout]    | ------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 47 |     pub fn error(
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `asJason`, and `toString` are never used
[INFO] [stdout]    --> src/services/api_cient/api_error.rs:19:12
[INFO] [stdout]     |
[INFO] [stdout] 16  | impl ApiError {
[INFO] [stdout]     | ------------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 19  |     pub fn new(message: impl Into<String>, details: impl Into<String>) -> Self {
[INFO] [stdout]     |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 66  |     pub fn asJason(&self, debug: bool) -> serde_json::Value {
[INFO] [stdout]     |            ^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 108 |     pub fn toString(self) -> String {
[INFO] [stdout]     |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `sendQueues` and `recvQueues` are never read
[INFO] [stdout]   --> src/services/queues/queues.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub struct Queues {
[INFO] [stdout]    |            ------ fields in this struct
[INFO] [stdout] 12 |     // vars: HashMap<String, FnInOutRef>,
[INFO] [stdout] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `Queues` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `addSendQueue`, `addRecvQueue`, `getSendQueue`, and `getRecvQueue` are never used
[INFO] [stdout]   --> src/services/queues/queues.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 16 | impl Queues {
[INFO] [stdout]    | ----------- associated items in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 19 |     pub fn new() -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `names` is never used
[INFO] [stdout]   --> src/services/task/task_node_vars.rs:36:8
[INFO] [stdout]    |
[INFO] [stdout] 17 | impl TaskNodeVars {
[INFO] [stdout]    | ----------------- associated function in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 36 |     fn names(collection: &HashMap<String, FnInOutRef>) -> Vec<String> {
[INFO] [stdout]    |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function `new` is never used
[INFO] [stdout]   --> src/services/task/queue_send_mpsc_channel.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | impl<T> QueueSendMpscChannel<T> {
[INFO] [stdout]    | ------------------------------- associated function in this implementation
[INFO] [stdout] 19 |     pub fn new(send: Sender<T>) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]   --> src/services/task/nested_function/fn_add.rs:91:8
[INFO] [stdout]    |
[INFO] [stdout] 91 | pub fn resetCount() {
[INFO] [stdout]    |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnMul` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:114:12
[INFO] [stdout]     |
[INFO] [stdout] 114 | pub struct FnMul;
[INFO] [stdout]     |            ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnOr` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:115:12
[INFO] [stdout]     |
[INFO] [stdout] 115 | pub struct FnOr;
[INFO] [stdout]     |            ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `FnCompare` is never constructed
[INFO] [stdout]    --> src/services/task/nested_function/fn_add.rs:116:12
[INFO] [stdout]     |
[INFO] [stdout] 116 | pub struct FnCompare;
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: static `COUNT` is never used
[INFO] [stdout]    --> src/services/task/nested_function/fn_timer.rs:186:8
[INFO] [stdout]     |
[INFO] [stdout] 186 | static COUNT: AtomicUsize = AtomicUsize::new(0);
[INFO] [stdout]     |        ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `resetCount` is never used
[INFO] [stdout]    --> src/services/task/nested_function/fn_timer.rs:187:8
[INFO] [stdout]     |
[INFO] [stdout] 187 | pub fn resetCount() {
[INFO] [stdout]     |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `connect_timeout` is never used
[INFO] [stdout]    --> src/tcp/tcp_client_connect.rs:151:12
[INFO] [stdout]     |
[INFO] [stdout] 49  | impl TcpClientConnect {
[INFO] [stdout]     | --------------------- method in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 151 |     pub fn connect_timeout(&self, timeout: Duration) -> Result<TcpStream, std::io::Error> {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `buffered` is never read
[INFO] [stdout]   --> src/tcp/tcp_stream_write.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 14 | pub struct TcpStreamWrite {
[INFO] [stdout]    |            -------------- field in this struct
[INFO] [stdout] 15 |     id: String,
[INFO] [stdout] 16 |     buffered: bool,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TcpSocket` is never constructed
[INFO] [stdout]   --> src/tcp/tcp_socket.rs:11:8
[INFO] [stdout]    |
[INFO] [stdout] 11 | struct TcpSocket {
[INFO] [stdout]    |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `read`, `write`, and `readAll` are never used
[INFO] [stdout]   --> src/tcp/tcp_socket.rs:20:12
[INFO] [stdout]    |
[INFO] [stdout] 19 | impl TcpSocket {
[INFO] [stdout]    | -------------- associated items in this implementation
[INFO] [stdout] 20 |     pub fn new(parent: impl Into<String>, tcpStream: TcpStream) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] ...
[INFO] [stdout] 30 |     pub fn read(&mut self) -> Result<Vec<u8>, String> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 42 |     pub fn write(&mut self, bytes: &[u8]) -> Result<usize, String> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 62 |     fn readAll(selfId: &str, bytes: &mut Vec<u8>, stream: &mut BufReader<TcpStream>) -> ConnectionStatus<(), String> {
[INFO] [stdout]    |        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait method `aproxEq` should have a snake case name
[INFO] [stdout]  --> src/core_/aprox_eq/aprox_eq.rs:4:8
[INFO] [stdout]   |
[INFO] [stdout] 4 |     fn aproxEq(&self, other: T, decimals: usize) -> bool;
[INFO] [stdout]   |        ^^^^^^^ help: convert the identifier to snake case: `aprox_eq`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: trait method `typeOf` should have a snake case name
[INFO] [stdout]  --> src/core_/types/type_of.rs:2:8
[INFO] [stdout]   |
[INFO] [stdout] 2 |     fn typeOf(&self) {
[INFO] [stdout]   |        ^^^^^^ help: convert the identifier to snake case: `type_of`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `freeTcpPortInt` should have a snake case name
[INFO] [stdout]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stdout]    |
[INFO] [stdout] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_int`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `freeTcpPortStr` should have a snake case name
[INFO] [stdout]   --> src/core_/testing/test_session.rs:19:12
[INFO] [stdout]    |
[INFO] [stdout] 19 |     pub fn freeTcpPortStr() -> String {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_str`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: structure field `sendQueues` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `send_queues`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: structure field `recvQueues` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:14:5
[INFO] [stdout]    |
[INFO] [stdout] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `recv_queues`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `addSendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:35:12
[INFO] [stdout]    |
[INFO] [stdout] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `addRecvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:45:12
[INFO] [stdout]    |
[INFO] [stdout] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `getSendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:60:12
[INFO] [stdout]    |
[INFO] [stdout] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `sendQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:62:18
[INFO] [stdout]    |
[INFO] [stdout] 62 |             Some(sendQueue) => sendQueue.clone(),
[INFO] [stdout]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `send_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `getRecvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:70:12
[INFO] [stdout]    |
[INFO] [stdout] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stdout]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `recvQueue` should have a snake case name
[INFO] [stdout]   --> src/services/queues/queues.rs:72:18
[INFO] [stdout]    |
[INFO] [stdout] 72 |             Some(recvQueue) => recvQueue,
[INFO] [stdout]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `recv_queue`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 92 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 9.08s
[INFO] running `Command { std: "docker" "inspect" "b42bb7814a9c0f5573dfe0ed5281d89875b276238f2c0b2c4064d1e3a985fdb5", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "b42bb7814a9c0f5573dfe0ed5281d89875b276238f2c0b2c4064d1e3a985fdb5", kill_on_drop: false }`
[INFO] [stdout] b42bb7814a9c0f5573dfe0ed5281d89875b276238f2c0b2c4064d1e3a985fdb5
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] 2cef58ab5074dfb159244bccb79bb4b0efe265c30fe8839323c4cef42af090a6
[INFO] running `Command { std: "docker" "start" "-a" "2cef58ab5074dfb159244bccb79bb4b0efe265c30fe8839323c4cef42af090a6", kill_on_drop: false }`
[INFO] [stderr] warning: unused imports: `debug`, `warn`
[INFO] [stderr]  --> src/tests/unit/core_/retain_buffer/retain_buffer_test.rs:4:15
[INFO] [stderr]   |
[INFO] [stderr] 4 |     use log::{warn, info, debug};
[INFO] [stderr]   |               ^^^^        ^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Duration`, `Instant`
[INFO] [stderr]  --> src/tests/unit/core_/retain_buffer/retain_buffer_test.rs:5:34
[INFO] [stderr]   |
[INFO] [stderr] 5 |     use std::{sync::Once, time::{Duration, Instant}};
[INFO] [stderr]   |                                  ^^^^^^^^  ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `debug`, `warn`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:5:15
[INFO] [stderr]   |
[INFO] [stderr] 5 |     use log::{warn, info, debug};
[INFO] [stderr]   |               ^^^^        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `serde_json::json`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:6:9
[INFO] [stderr]   |
[INFO] [stderr] 6 |     use serde_json::json;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Duration`, `Instant`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_serialize_test.rs:7:42
[INFO] [stderr]   |
[INFO] [stderr] 7 |     use std::{sync::{Once, mpsc}, time::{Duration, Instant}};
[INFO] [stderr]   |                                          ^^^^^^^^  ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `debug`, `warn`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:5:15
[INFO] [stderr]   |
[INFO] [stderr] 5 |     use log::{warn, info, debug};
[INFO] [stderr]   |               ^^^^        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `serde_json::json`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:6:9
[INFO] [stderr]   |
[INFO] [stderr] 6 |     use serde_json::json;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Duration`, `Instant`
[INFO] [stderr]  --> src/tests/unit/core_/net/protocols/jds/jds_encode_message_test.rs:7:42
[INFO] [stderr]   |
[INFO] [stderr] 7 |     use std::{sync::{Once, mpsc}, time::{Duration, Instant}};
[INFO] [stderr]   |                                          ^^^^^^^^  ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `debug`, `warn`
[INFO] [stderr]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:5:15
[INFO] [stderr]   |
[INFO] [stderr] 5 |     use log::{warn, info, debug};
[INFO] [stderr]   |               ^^^^        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `thread_rng`
[INFO] [stderr]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:6:16
[INFO] [stderr]   |
[INFO] [stderr] 6 |     use rand::{thread_rng, Rng};
[INFO] [stderr]   |                ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `net::TcpStream`
[INFO] [stderr]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:7:68
[INFO] [stderr]   |
[INFO] [stderr] 7 |     use std::{sync::{atomic::{AtomicUsize, Ordering}, Arc, Mutex}, net::TcpStream, thread};
[INFO] [stderr]   |                                                                    ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Instant`
[INFO] [stderr]  --> src/tests/unit/tcp/multiple_call_connect_test.rs:8:44
[INFO] [stderr]   |
[INFO] [stderr] 8 |     use std::{sync::Once, time::{Duration, Instant}};
[INFO] [stderr]   |                                            ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Instant`
[INFO] [stderr]  --> src/tests/unit/services/multi_queue/multi_queue_subscription_test.rs:5:58
[INFO] [stderr]   |
[INFO] [stderr] 5 |     use std::{sync::{Once, Arc, Mutex}, time::{Duration, Instant}, thread::{self, JoinHandle}, any::Any, collections::HashMap};
[INFO] [stderr]   |                                                          ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stderr]  --> src/core_/net/protocols/jds/jds_decode_message.rs:3:11
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{net::TcpStream, io::{Read, BufReader, ErrorKind}};
[INFO] [stderr]   |           ^^^^^^^^^^^^^^             ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `debug`
[INFO] [stderr]  --> src/core_/net/protocols/jds/jds_decode_message.rs:5:17
[INFO] [stderr]   |
[INFO] [stderr] 5 | use log::{warn, debug, trace};
[INFO] [stderr]   |                 ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `BufReader`, `net::TcpStream`
[INFO] [stderr]  --> src/core_/net/protocols/jds/jds_deserialize.rs:3:16
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{io::{BufReader, Read}, net::TcpStream};
[INFO] [stderr]   |                ^^^^^^^^^         ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `error`
[INFO] [stderr]  --> src/core_/net/protocols/jds/jds_deserialize.rs:6:17
[INFO] [stderr]   |
[INFO] [stderr] 6 | use log::{warn, error, trace, LevelFilter};
[INFO] [stderr]   |                 ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `str::FromStr`
[INFO] [stderr]  --> src/conf/api_client_config.rs:4:15
[INFO] [stderr]   |
[INFO] [stderr] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stderr]   |               ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stderr]  --> src/conf/api_client_config.rs:6:40
[INFO] [stderr]   |
[INFO] [stderr] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stderr]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `super::conf_keywd::ConfKind`
[INFO] [stderr]  --> src/conf/api_client_config.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 | use super::conf_keywd::ConfKind;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `net::SocketAddr`, `str::FromStr`, `time::Duration`
[INFO] [stderr]  --> src/conf/multi_queue_config.rs:4:15
[INFO] [stderr]   |
[INFO] [stderr] 4 | use std::{fs, str::FromStr, time::Duration, net::SocketAddr};
[INFO] [stderr]   |               ^^^^^^^^^^^^  ^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `conf_duration::ConfDuration`, `conf_keywd::ConfKeywd`
[INFO] [stderr]  --> src/conf/multi_queue_config.rs:6:40
[INFO] [stderr]   |
[INFO] [stderr] 6 | use crate::conf::{conf_tree::ConfTree, conf_duration::ConfDuration, conf_keywd::ConfKeywd, service_config::ServiceConfig};
[INFO] [stderr]   |                                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `AtomicUsize`
[INFO] [stderr]  --> src/services/task/task_test_receiver.rs:3:86
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{sync::{mpsc::{Receiver, Sender, self}, Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex}, thread::{self, JoinHandle}, co...
[INFO] [stderr]   |                                                                                      ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `warn`
[INFO] [stderr]  --> src/services/multi_queue/multi_queue.rs:5:17
[INFO] [stderr]   |
[INFO] [stderr] 5 | use log::{info, warn, error, debug, trace};
[INFO] [stderr]   |                 ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `debug`
[INFO] [stderr]  --> src/services/multi_queue/subscriptions.rs:5:17
[INFO] [stderr]   |
[INFO] [stderr] 5 | use log::{warn, debug, trace};
[INFO] [stderr]   |                 ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `AtomicBool`, `AtomicUsize`, `MutexGuard`, `Once`, `Ordering`
[INFO] [stderr]  --> src/tcp/tcp_client_connect.rs:3:93
[INFO] [stderr]   |
[INFO] [stderr] 3 | ...sync::{Arc, atomic::{AtomicBool, Ordering, AtomicUsize}, Mutex, mpsc::{Sender, Receiver, self}, Once, MutexGuard}, thread};
[INFO] [stderr]   |                         ^^^^^^^^^^  ^^^^^^^^  ^^^^^^^^^^^                                          ^^^^  ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `net::TcpStream`
[INFO] [stderr]  --> src/tcp/tcp_stream_write.rs:3:11
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stderr]   |           ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `debug`
[INFO] [stderr]  --> src/tcp/tcp_stream_write.rs:5:30
[INFO] [stderr]   |
[INFO] [stderr] 5 | use log::{warn, LevelFilter, debug, trace};
[INFO] [stderr]   |                              ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `ErrorKind`
[INFO] [stderr]  --> src/tcp/tcp_socket.rs:3:50
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{net::TcpStream, io::{Write, BufReader, ErrorKind, Read}, sync::atomic::AtomicBool};
[INFO] [stderr]   |                                                  ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Read`
[INFO] [stderr]  --> src/tcp/tcp_stream_write.rs:3:39
[INFO] [stderr]   |
[INFO] [stderr] 3 | use std::{net::TcpStream, io::{Write, Read}};
[INFO] [stderr]   |                                       ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `json`
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:62:14
[INFO] [stderr]    |
[INFO] [stderr] 62 |         for (json, target) in testData {
[INFO] [stderr]    |              ^^^^ help: if this is intentional, prefix it with an underscore: `_json`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `target`
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:62:20
[INFO] [stderr]    |
[INFO] [stderr] 62 |         for (json, target) in testData {
[INFO] [stderr]    |                    ^^^^^^ help: if this is intentional, prefix it with an underscore: `_target`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `recv`
[INFO] [stderr]   --> src/tests/unit/services/multi_queue/mock_send_service.rs:28:20
[INFO] [stderr]    |
[INFO] [stderr] 28 |         let (send, recv) = mpsc::channel::<PointType>();
[INFO] [stderr]    |                    ^^^^ help: if this is intentional, prefix it with an underscore: `_recv`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `name`
[INFO] [stderr]   --> src/tests/unit/services/multi_queue/mock_tcp_server.rs:68:27
[INFO] [stderr]    |
[INFO] [stderr] 68 |     fn getLink(&mut self, name: &str) -> std::sync::mpsc::Sender<crate::core_::point::point_type::PointType> {
[INFO] [stderr]    |                           ^^^^ help: if this is intentional, prefix it with an underscore: `_name`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `err`
[INFO] [stderr]    --> src/conf/fn_conf_keywd.rs:119:33
[INFO] [stderr]     |
[INFO] [stderr] 119 | ...                   Err(err) => {
[INFO] [stderr]     |                           ^^^ help: if this is intentional, prefix it with an underscore: `_err`
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `connectionClosed` is never read
[INFO] [stderr]    --> src/services/api_cient/api_client.rs:179:21
[INFO] [stderr]     |
[INFO] [stderr] 179 |             let mut connectionClosed = false;
[INFO] [stderr]     |                     ^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = help: maybe it is overwritten before being read?
[INFO] [stderr]     = note: `#[warn(unused_assignments)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `connectionClosed` is never read
[INFO] [stderr]    --> src/services/api_cient/api_client.rs:213:57
[INFO] [stderr]     |
[INFO] [stderr] 213 | ...                   connectionClosed = true;
[INFO] [stderr]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = help: maybe it is overwritten before being read?
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `connectionClosed` is never read
[INFO] [stderr]    --> src/services/api_cient/api_client.rs:220:49
[INFO] [stderr]     |
[INFO] [stderr] 220 | ...                   connectionClosed = true;
[INFO] [stderr]     |                       ^^^^^^^^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = help: maybe it is overwritten before being read?
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `point`
[INFO] [stderr]   --> src/services/task/nested_function/fn_.rs:13:23
[INFO] [stderr]    |
[INFO] [stderr] 13 |     fn add(&mut self, point: PointType) {
[INFO] [stderr]    |                       ^^^^^ help: if this is intentional, prefix it with an underscore: `_point`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `id`
[INFO] [stderr]   --> src/services/task/nested_function/fn_count.rs:31:16
[INFO] [stderr]    |
[INFO] [stderr] 31 |     pub fn new(id: impl Into<String>, initial: f64, input: FnInOutRef) -> Self {
[INFO] [stderr]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `id`
[INFO] [stderr]   --> src/services/task/nested_function/fn_ge.rs:26:16
[INFO] [stderr]    |
[INFO] [stderr] 26 |     pub fn new(id: impl Into<String>, input1: FnInOutRef, input2: FnInOutRef) -> Self {
[INFO] [stderr]    |                ^^ help: if this is intentional, prefix it with an underscore: `_id`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `receiverId`
[INFO] [stderr]   --> src/services/service.rs:19:29
[INFO] [stderr]    |
[INFO] [stderr] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stderr]    |                             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `points`
[INFO] [stderr]   --> src/services/service.rs:19:47
[INFO] [stderr]    |
[INFO] [stderr] 19 |     fn subscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Receiver<PointType> {
[INFO] [stderr]    |                                               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `receiverId`
[INFO] [stderr]   --> src/services/service.rs:24:31
[INFO] [stderr]    |
[INFO] [stderr] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stderr]    |                               ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_receiverId`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `points`
[INFO] [stderr]   --> src/services/service.rs:24:49
[INFO] [stderr]    |
[INFO] [stderr] 24 |     fn unsubscribe(&mut self, receiverId: &str, points: &Vec<String>) -> Result<(), String> {
[INFO] [stderr]    |                                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_points`
[INFO] [stderr] 
[INFO] [stderr] warning: field `inner` is never read
[INFO] [stderr]   --> src/main.rs:24:9
[INFO] [stderr]    |
[INFO] [stderr] 20 | struct Ikea<S, T, Q> 
[INFO] [stderr]    |        ---- field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 24 |     pub inner: Vec<S>, 
[INFO] [stderr]    |         ^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `Ikea` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr]    = note: `#[warn(dead_code)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: struct `Inner` is never constructed
[INFO] [stderr]   --> src/main.rs:77:8
[INFO] [stderr]    |
[INFO] [stderr] 77 | struct Inner<T, Q> 
[INFO] [stderr]    |        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: static `INIT` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:12:12
[INFO] [stderr]    |
[INFO] [stderr] 12 |     static INIT: Once = Once::new();
[INFO] [stderr]    |            ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `initOnce` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:16:8
[INFO] [stderr]    |
[INFO] [stderr] 16 |     fn initOnce() {
[INFO] [stderr]    |        ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `initEach` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:27:8
[INFO] [stderr]    |
[INFO] [stderr] 27 |     fn initEach() -> () {
[INFO] [stderr]    |        ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `ts` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:31:8
[INFO] [stderr]    |
[INFO] [stderr] 31 |     fn ts() -> DateTime<Utc> {
[INFO] [stderr]    |        ^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `tsStr` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:34:8
[INFO] [stderr]    |
[INFO] [stderr] 34 |     fn tsStr(ts: DateTime<Utc>) -> String {
[INFO] [stderr]    |        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `test_point_from_json_bytes` is never used
[INFO] [stderr]   --> src/tests/unit/core_/point/point_from_json_test.rs:39:8
[INFO] [stderr]    |
[INFO] [stderr] 39 |     fn test_point_from_json_bytes() {
[INFO] [stderr]    |        ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `id` is never used
[INFO] [stderr]   --> src/tests/unit/services/multi_queue/mock_recv_service.rs:35:12
[INFO] [stderr]    |
[INFO] [stderr] 20 | impl MockRecvService {
[INFO] [stderr]    | -------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 35 |     pub fn id(&self) -> String {
[INFO] [stderr]    |            ^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `id` is never used
[INFO] [stderr]   --> src/tests/unit/services/multi_queue/mock_send_service.rs:45:12
[INFO] [stderr]    |
[INFO] [stderr] 25 | impl MockSendService {
[INFO] [stderr]    | -------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 45 |     pub fn id(&self) -> String {
[INFO] [stderr]    |            ^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `sent` is never used
[INFO] [stderr]   --> src/tests/unit/services/multi_queue/mock_tcp_server.rs:49:12
[INFO] [stderr]    |
[INFO] [stderr] 26 | impl MockTcpServer {
[INFO] [stderr]    | ------------------ method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 49 |     pub fn sent(&self) -> Arc<Mutex<Vec<PointType>>> {
[INFO] [stderr]    |            ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `new` is never used
[INFO] [stderr]   --> src/core_/point/point_type.rs:54:12
[INFO] [stderr]    |
[INFO] [stderr] 51 | impl PointType {
[INFO] [stderr]    | -------------- associated function in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 54 |     pub fn new<T: ToPoint>(txId: usize, name: &str, value: T) -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant `Active` is never constructed
[INFO] [stderr]   --> src/core_/net/protocols/jds/jds_decode_message.rs:11:5
[INFO] [stderr]    |
[INFO] [stderr] 10 | enum Status {
[INFO] [stderr]    |      ------ variant in this enum
[INFO] [stderr] 11 |     Active,
[INFO] [stderr]    |     ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `id` is never read
[INFO] [stderr]   --> src/core_/retain_buffer/retain_buffer.rs:14:5
[INFO] [stderr]    |
[INFO] [stderr] 13 | pub struct RetainBuffer<T> {
[INFO] [stderr]    |            ------------ field in this struct
[INFO] [stderr] 14 |     id: String,
[INFO] [stderr]    |     ^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `store` is never used
[INFO] [stderr]   --> src/core_/retain_buffer/retain_buffer.rs:66:12
[INFO] [stderr]    |
[INFO] [stderr] 20 | impl<T> RetainBuffer<T> {
[INFO] [stderr]    | ----------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 66 |     pub fn store(&self) {
[INFO] [stderr]    |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `freeTcpPortInt` is never used
[INFO] [stderr]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stderr]    |
[INFO] [stderr] 11 | impl TestSession {
[INFO] [stderr]    | ---------------- associated function in this implementation
[INFO] [stderr] 12 |     /// Returns any free available TCP port as usize
[INFO] [stderr] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `remove` is never used
[INFO] [stderr]    --> src/conf/conf_tree.rs:139:12
[INFO] [stderr]     |
[INFO] [stderr] 19  | impl ConfTree {
[INFO] [stderr]     | ------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 139 |     pub fn remove(&mut self, key: &str) -> Result<serde_yaml::Value, String> {
[INFO] [stderr]     |            ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `first` is never used
[INFO] [stderr]   --> src/conf/service_config.rs:34:12
[INFO] [stderr]    |
[INFO] [stderr] 20 | impl ServiceConfig {
[INFO] [stderr]    | ------------------ method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 34 |     pub fn first(&self) -> Option<ConfTree> {
[INFO] [stderr]    |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `asBytes` is never used
[INFO] [stderr]   --> src/services/api_cient/api_query.rs:61:12
[INFO] [stderr]    |
[INFO] [stderr] 29 | impl ApiQuery {
[INFO] [stderr]    | ------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 61 |     pub fn asBytes(&self) -> Vec<u8> {
[INFO] [stderr]    |            ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `error` is never used
[INFO] [stderr]   --> src/services/api_cient/api_reply.rs:47:12
[INFO] [stderr]    |
[INFO] [stderr] 21 | impl SqlReply {
[INFO] [stderr]    | ------------- associated function in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 47 |     pub fn error(
[INFO] [stderr]    |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `asJason`, and `toString` are never used
[INFO] [stderr]    --> src/services/api_cient/api_error.rs:19:12
[INFO] [stderr]     |
[INFO] [stderr] 16  | impl ApiError {
[INFO] [stderr]     | ------------- associated items in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 19  |     pub fn new(message: impl Into<String>, details: impl Into<String>) -> Self {
[INFO] [stderr]     |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 66  |     pub fn asJason(&self, debug: bool) -> serde_json::Value {
[INFO] [stderr]     |            ^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 108 |     pub fn toString(self) -> String {
[INFO] [stderr]     |            ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `sendQueues` and `recvQueues` are never read
[INFO] [stderr]   --> src/services/queues/queues.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 11 | pub struct Queues {
[INFO] [stderr]    |            ------ fields in this struct
[INFO] [stderr] 12 |     // vars: HashMap<String, FnInOutRef>,
[INFO] [stderr] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stderr]    |     ^^^^^^^^^^
[INFO] [stderr] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stderr]    |     ^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `Queues` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `addSendQueue`, `addRecvQueue`, `getSendQueue`, and `getRecvQueue` are never used
[INFO] [stderr]   --> src/services/queues/queues.rs:19:12
[INFO] [stderr]    |
[INFO] [stderr] 16 | impl Queues {
[INFO] [stderr]    | ----------- associated items in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 19 |     pub fn new() -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stderr]    |            ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stderr]    |            ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stderr]    |            ^^^^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stderr]    |            ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `names` is never used
[INFO] [stderr]   --> src/services/task/task_node_vars.rs:36:8
[INFO] [stderr]    |
[INFO] [stderr] 17 | impl TaskNodeVars {
[INFO] [stderr]    | ----------------- associated function in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 36 |     fn names(collection: &HashMap<String, FnInOutRef>) -> Vec<String> {
[INFO] [stderr]    |        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated function `new` is never used
[INFO] [stderr]   --> src/services/task/queue_send_mpsc_channel.rs:19:12
[INFO] [stderr]    |
[INFO] [stderr] 18 | impl<T> QueueSendMpscChannel<T> {
[INFO] [stderr]    | ------------------------------- associated function in this implementation
[INFO] [stderr] 19 |     pub fn new(send: Sender<T>) -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `resetCount` is never used
[INFO] [stderr]   --> src/services/task/nested_function/fn_add.rs:91:8
[INFO] [stderr]    |
[INFO] [stderr] 91 | pub fn resetCount() {
[INFO] [stderr]    |        ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `FnMul` is never constructed
[INFO] [stderr]    --> src/services/task/nested_function/fn_add.rs:114:12
[INFO] [stderr]     |
[INFO] [stderr] 114 | pub struct FnMul;
[INFO] [stderr]     |            ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `FnOr` is never constructed
[INFO] [stderr]    --> src/services/task/nested_function/fn_add.rs:115:12
[INFO] [stderr]     |
[INFO] [stderr] 115 | pub struct FnOr;
[INFO] [stderr]     |            ^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `FnCompare` is never constructed
[INFO] [stderr]    --> src/services/task/nested_function/fn_add.rs:116:12
[INFO] [stderr]     |
[INFO] [stderr] 116 | pub struct FnCompare;
[INFO] [stderr]     |            ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: static `COUNT` is never used
[INFO] [stderr]    --> src/services/task/nested_function/fn_timer.rs:186:8
[INFO] [stderr]     |
[INFO] [stderr] 186 | static COUNT: AtomicUsize = AtomicUsize::new(0);
[INFO] [stderr]     |        ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `resetCount` is never used
[INFO] [stderr]    --> src/services/task/nested_function/fn_timer.rs:187:8
[INFO] [stderr]     |
[INFO] [stderr] 187 | pub fn resetCount() {
[INFO] [stderr]     |        ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: method `connect_timeout` is never used
[INFO] [stderr]    --> src/tcp/tcp_client_connect.rs:151:12
[INFO] [stderr]     |
[INFO] [stderr] 49  | impl TcpClientConnect {
[INFO] [stderr]     | --------------------- method in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 151 |     pub fn connect_timeout(&self, timeout: Duration) -> Result<TcpStream, std::io::Error> {
[INFO] [stderr]     |            ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: field `buffered` is never read
[INFO] [stderr]   --> src/tcp/tcp_stream_write.rs:16:5
[INFO] [stderr]    |
[INFO] [stderr] 14 | pub struct TcpStreamWrite {
[INFO] [stderr]    |            -------------- field in this struct
[INFO] [stderr] 15 |     id: String,
[INFO] [stderr] 16 |     buffered: bool,
[INFO] [stderr]    |     ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `TcpSocket` is never constructed
[INFO] [stderr]   --> src/tcp/tcp_socket.rs:11:8
[INFO] [stderr]    |
[INFO] [stderr] 11 | struct TcpSocket {
[INFO] [stderr]    |        ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `read`, `write`, and `readAll` are never used
[INFO] [stderr]   --> src/tcp/tcp_socket.rs:20:12
[INFO] [stderr]    |
[INFO] [stderr] 19 | impl TcpSocket {
[INFO] [stderr]    | -------------- associated items in this implementation
[INFO] [stderr] 20 |     pub fn new(parent: impl Into<String>, tcpStream: TcpStream) -> Self {
[INFO] [stderr]    |            ^^^
[INFO] [stderr] ...
[INFO] [stderr] 30 |     pub fn read(&mut self) -> Result<Vec<u8>, String> {
[INFO] [stderr]    |            ^^^^
[INFO] [stderr] ...
[INFO] [stderr] 42 |     pub fn write(&mut self, bytes: &[u8]) -> Result<usize, String> {
[INFO] [stderr]    |            ^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 62 |     fn readAll(selfId: &str, bytes: &mut Vec<u8>, stream: &mut BufReader<TcpStream>) -> ConnectionStatus<(), String> {
[INFO] [stderr]    |        ^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: trait method `aproxEq` should have a snake case name
[INFO] [stderr]  --> src/core_/aprox_eq/aprox_eq.rs:4:8
[INFO] [stderr]   |
[INFO] [stderr] 4 |     fn aproxEq(&self, other: T, decimals: usize) -> bool;
[INFO] [stderr]   |        ^^^^^^^ help: convert the identifier to snake case: `aprox_eq`
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: trait method `typeOf` should have a snake case name
[INFO] [stderr]  --> src/core_/types/type_of.rs:2:8
[INFO] [stderr]   |
[INFO] [stderr] 2 |     fn typeOf(&self) {
[INFO] [stderr]   |        ^^^^^^ help: convert the identifier to snake case: `type_of`
[INFO] [stderr] 
[INFO] [stderr] warning: method `freeTcpPortInt` should have a snake case name
[INFO] [stderr]   --> src/core_/testing/test_session.rs:13:12
[INFO] [stderr]    |
[INFO] [stderr] 13 |     pub fn freeTcpPortInt() -> usize {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_int`
[INFO] [stderr] 
[INFO] [stderr] warning: method `freeTcpPortStr` should have a snake case name
[INFO] [stderr]   --> src/core_/testing/test_session.rs:19:12
[INFO] [stderr]    |
[INFO] [stderr] 19 |     pub fn freeTcpPortStr() -> String {
[INFO] [stderr]    |            ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `free_tcp_port_str`
[INFO] [stderr] 
[INFO] [stderr] warning: structure field `sendQueues` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 |     sendQueues: HashMap<String, Sender<PointType>>,
[INFO] [stderr]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `send_queues`
[INFO] [stderr] 
[INFO] [stderr] warning: structure field `recvQueues` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:14:5
[INFO] [stderr]    |
[INFO] [stderr] 14 |     recvQueues: HashMap<String, Receiver<PointType>>,
[INFO] [stderr]    |     ^^^^^^^^^^ help: convert the identifier to snake case: `recv_queues`
[INFO] [stderr] 
[INFO] [stderr] warning: method `addSendQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:35:12
[INFO] [stderr]    |
[INFO] [stderr] 35 |     pub fn addSendQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, send: Sender<PointType>) {
[INFO] [stderr]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_send_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: method `addRecvQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:45:12
[INFO] [stderr]    |
[INFO] [stderr] 45 |     pub fn addRecvQueue(&mut self, name: impl Into<String> + std::fmt::Debug + Clone, recv: Receiver<PointType>) {
[INFO] [stderr]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `add_recv_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: method `getSendQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:60:12
[INFO] [stderr]    |
[INFO] [stderr] 60 |     pub fn getSendQueue(&mut self, name: &str) -> Sender<PointType> {
[INFO] [stderr]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_send_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: variable `sendQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:62:18
[INFO] [stderr]    |
[INFO] [stderr] 62 |             Some(sendQueue) => sendQueue.clone(),
[INFO] [stderr]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `send_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: method `getRecvQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:70:12
[INFO] [stderr]    |
[INFO] [stderr] 70 |     pub fn getRecvQueue(&mut self, name: &str) -> Receiver<PointType> {
[INFO] [stderr]    |            ^^^^^^^^^^^^ help: convert the identifier to snake case: `get_recv_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: variable `recvQueue` should have a snake case name
[INFO] [stderr]   --> src/services/queues/queues.rs:72:18
[INFO] [stderr]    |
[INFO] [stderr] 72 |             Some(recvQueue) => recvQueue,
[INFO] [stderr]    |                  ^^^^^^^^^ help: convert the identifier to snake case: `recv_queue`
[INFO] [stderr] 
[INFO] [stderr] warning: `fr-service` (bin "fr-service" test) generated 92 warnings (run `cargo fix --bin "fr-service" --tests` to apply 41 suggestions)
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 0.09s
[INFO] [stderr]      Running unittests src/main.rs (/opt/rustwide/target/debug/deps/fr_service-8673edccce0da605)
[INFO] [stdout] 
[INFO] [stdout] running 64 tests
[INFO] [stdout] test tests::unit::conf::config_tree::conf_tree_test::test_config_tree_as_type ... ok
[INFO] [stdout] test tests::unit::conf::config_tree::conf_tree_test::test_config_tree_valid ... ok
[INFO] [stdout] test tests::unit::conf::conf_duration_test::test_create_valid ... ok
[INFO] [stdout] test tests::unit::conf::fn_config::fn_config_new_test::test_fn_config_new_valid ... ok
[INFO] [stdout] test tests::unit::conf::conf_keyword_test::tests::test_create_valid ... ok
[INFO] [stdout] test tests::unit::conf::conf_duration_test::test_create_invalid ... ok
[INFO] [stdout] test tests::unit::core_::aprox_eq_test::test_f32 ... ok
[INFO] [stdout] test tests::unit::core_::aprox_eq_test::test_f64 ... ok
[INFO] [stdout] test tests::unit::core_::format::format_test::test_name_sufix ... ok
[INFO] [stdout] test tests::unit::core_::format::format_test::test_prepare ... ok
[INFO] [stdout] test tests::unit::core_::format::format_test::test_simple_name ... ok
[INFO] [stdout] test tests::unit::conf::fn_conf_keyword_test::test_create_invalid ... ok
[INFO] [stdout] test tests::unit::conf::metric_config::metric_config_read_test::test_fn_config_read_valid ... ok
[INFO] [stdout] test tests::unit::core_::net::protocols::jds::jds_encode_message_test::tests::test_ ... ok
[INFO] [stdout] test tests::unit::core_::net::protocols::jds::jds_serialize_test::tests::test_ ... ok
[INFO] [stdout] test tests::unit::core_::retain_buffer::retain_buffer_test::tests::test_retain_buffer ... ok
[INFO] [stdout] test tests::unit::core_::retain_buffer::retain_buffer_test::tests::test_retain_buffer_capacity ... ok
[INFO] [stdout] test tests::unit::core_::switch_state_test::test_single ... ok
[INFO] [stdout] test tests::unit::conf::fn_config::fn_config_read_test::test_fn_config_read_valid ... ok
[INFO] [stdout] test tests::unit::core_::switch_state_test::test_start_step_back ... ok
[INFO] [stdout] test tests::unit::core_::switch_state_test::test_stot_step_back ... ok
[INFO] [stdout] test tests::unit::services::api_client::api_query_test::test_api_query ... ok
[INFO] [stdout] test tests::unit::services::multi_queue::multi_queue_performance_test::tests::test_multi_queue_match_performance ... ignored, Performance test | run this test to estimate performance of multiqueue with matching producer's id
[INFO] [stdout] test tests::unit::services::multi_queue::multi_queue_performance_test::tests::test_multi_queue_performance ... ignored, Performance test | run this test estimate performance of multiqueue without matching producer's id
[INFO] [stdout] test tests::unit::services::multi_queue::multi_queue_read_test::tests::test_multi_queue_static_single ... ok
[INFO] [stdout] test tests::unit::conf::metric_config::metric_config_new_test::test_metric_config_new_valid ... ok
[INFO] [stdout] test tests::unit::services::multi_queue::multi_queue_read_write_test::tests::test_multi_queue_static_single ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_add_test::tests::test_bool ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_add_test::tests::test_int ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_count_test::test_multiple ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_count_test::test_multiple_reset ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_count_test::test_single ... ok
[INFO] [stdout] test tests::unit::conf::fn_conf_keyword_test::test_create_valid ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_input_test::test_float ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_input_test::test_bool ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_input_test::test_int ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_input_test::test_string ... ok
[INFO] [stdout] test tests::unit::core_::net::protocols::jds::jds_decode_message_test::tests::test_jds_decode_message ... ok
[INFO] [stdout] test tests::unit::conf::task_config::task_config_read_test::tests::test_fn_config_read_valid ... ok
[INFO] [stdout] test tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions ... FAILED
[INFO] [stdout] test tests::unit::services::task::functions::fn_trip_test::test_multiple_float ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_trip_test::test_multiple_int ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_trip_test::test_single_int ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_var_test::tests::test_bool ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_var_test::tests::test_float ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_var_test::tests::test_int ... ok
[INFO] [stdout] test tests::unit::core_::net::protocols::jds::jds_deserialize_test::tests::test_jds_deserialize ... ok
[INFO] [stdout] test tests::unit::services::task::task_cycle_test::test_task_cycle ... FAILED
[INFO] [stdout] test tests::unit::services::api_client::api_client_test::tests::test_ApiClient ... ok
[INFO] [stdout] test tests::unit::services::task::task_test::tests::test_task_tranfer ... ignored, TODO - transfered values assertion not implemented yet
[INFO] [stdout] test tests::unit::conf::task_config::task_config_new_test::tests::test_fn_config_new_valid ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_timer_test::test_initial_repeat ... ok
[INFO] [stdout] test tests::unit::services::task::task_nodes::task_nodes_test::tests::test_task_nodes ... ok
[INFO] [stdout] test tests::unit::tcp::read_bytes_performance::tests::test_read_bytes_performance ... ignored, Performance test | run this test to compare performance of different methods socket reading
[INFO] [stdout] test tests::unit::services::task::functions::fn_timer_test::test_elapsed_repeat_false ... ok
[INFO] [stdout] test tests::unit::services::task::task_test::tests::test_task_struct ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_timer_test::test_total_elapsed_repeat ... ok
[INFO] [stdout] test tests::unit::tcp::tcp_stream_write_test::tests::test_ ... ok
[INFO] [stdout] test tests::unit::services::task::functions::fn_timer_test::test_total_elapsed_repeat_reset ... ok
[INFO] [stdout] test tests::unit::tcp::tcp_client_connect_test::tests::test_success ... ok
[INFO] [stdout] test tests::unit::services::tcp_client::tcp_client_read_test::tests::test_TcpClient_read ... ok
[INFO] [stdout] test tests::unit::services::tcp_client::tcp_client_write_test::tests::test_TcpClient_write ... ok
[INFO] [stdout] test tests::unit::tcp::tcp_client_connect_test::tests::test_failure ... ok
[INFO] [stdout] test tests::unit::tcp::multiple_call_connect_test::tests::test_task_cycle ... ok
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions stdout ----
[INFO] [stdout] 
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests] test_multi_queue - Static subscriptions - Single send
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::services::multi_queue::multi_queue] test/MultiQueue.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::services::multi_queue::multi_queue] test/MultiQueue.run | started
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread0/MockRecvSendService.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread0/MockRecvSendService.run | starting - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread1/MockRecvSendService.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread1/MockRecvSendService.run | starting - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread2/MockRecvSendService.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread2/MockRecvSendService.run | starting - ok
[INFO] [stdout] All MockRecvSendService threads - finished
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread0/MockRecvSendService.run | Preparing thread Send - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread1/MockRecvSendService.run | Preparing thread Send - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread2/MockRecvSendService.run | Preparing thread Send - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::services::multi_queue::multi_queue] test/MultiQueue.run | Preparing thread - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread0/MockRecvSendService.run | Preparing thread Recv - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread1/MockRecvSendService.run | Preparing thread Recv - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_recv_send_service] tread2/MockRecvSendService.run | Preparing thread Recv - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread0/MockTcpServer.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests] Waiting for service: "ThreadId(101)-Some(\"tread0/MockTcpServer.run | Send\")"...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread0/MockTcpServer.run | Preparing thread Recv - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread0/MockTcpServer.run | Preparing thread Send - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread0/MockTcpServer.run | Exit thread Send
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests] Waiting for thread: 'ThreadId(101)-Some("tread0/MockTcpServer.run | Send")' - finished
[INFO] [stdout] Static service Received( tread0/MockRecvSendService ): 3274
[INFO] [stdout] Static service Received( tread1/MockRecvSendService ): 3275
[INFO] [stdout] Static service Received( tread2/MockRecvSendService ): 3274
[INFO] [stdout] Dynamic service Received( tread0/MockTcpServer ): 0
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread1/MockTcpServer.run | starting...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests] Waiting for service: "ThreadId(105)-Some(\"tread1/MockTcpServer.run | Send\")"...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread1/MockTcpServer.run | Preparing thread Send - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread1/MockTcpServer.run | Preparing thread Recv - ok
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::mock_tcp_server] tread1/MockTcpServer.run | Exit thread Send
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests] Waiting for thread: 'ThreadId(105)-Some("tread1/MockTcpServer.run | Send")' - finished
[INFO] [stdout] thread 'tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions' panicked at src/tests/unit/services/multi_queue/multi_queue_subscription_test.rs:118:13:
[INFO] [stdout] 
[INFO] [stdout] result: 702
[INFO] [stdout] target: 0
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0: rust_begin_unwind
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/std/src/panicking.rs:645:5
[INFO] [stdout]    1: core::panicking::panic_fmt
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/panicking.rs:72:14
[INFO] [stdout]    2: fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions
[INFO] [stdout]              at ./src/tests/unit/services/multi_queue/multi_queue_subscription_test.rs:118:13
[INFO] [stdout]    3: fr_service::tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions::{{closure}}
[INFO] [stdout]              at ./src/tests/unit/services/multi_queue/multi_queue_subscription_test.rs:38:40
[INFO] [stdout]    4: core::ops::function::FnOnce::call_once
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/ops/function.rs:250:5
[INFO] [stdout]    5: core::ops::function::FnOnce::call_once
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/ops/function.rs:250:5
[INFO] [stdout] note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
[INFO] [stdout] 
[INFO] [stdout] ---- tests::unit::services::task::task_cycle_test::test_task_cycle stdout ----
[INFO] [stdout] 
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::task::task_cycle_test] test_task_cycle
[INFO] [stdout] 
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::task::task_cycle_test] target cycle interval: 1 ms
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::task::task_cycle_test] detecting load range...
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::task::task_cycle_test] load range 1...2446
[INFO] [stdout] [2024-01-05T19:25:47Z INFO  fr_service::tests::unit::services::task::task_cycle_test] elapsed for max load: 1.29217ms
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.002526669
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00385883
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00430909
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.004725501
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397573
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00626875
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003914279
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007341259
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00690555
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00368385
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003977429
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00400798
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00289922
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00776847
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007960099
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00201313
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.004728951
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003359739
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00371693
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007844979
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397434
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003978849
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.0039718
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003979269
[INFO] [stdout] [2024-01-05T19:25:47Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397777
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003978119
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397976
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397611
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003972129
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00397762
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.006817719
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007939809
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00396246
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003978479
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.0039657
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003964559
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00401556
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007014179
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.003354379
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.007725869
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.00324978
[INFO] [stdout] [2024-01-05T19:25:48Z WARN  fr_service::tests::unit::services::task::task_cycle_test] values must be aprox equals (3 digits): targetInSecs: 0.001 != cycleElapsed 0.006389539
[INFO] [stdout] thread 'tests::unit::services::task::task_cycle_test::test_task_cycle' panicked at src/tests/unit/services/task/task_cycle_test.rs:106:9:
[INFO] [stdout] to much errors (42), a few errors will be ok, but not more then 5% (20) of test cycles
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0: rust_begin_unwind
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/std/src/panicking.rs:645:5
[INFO] [stdout]    1: core::panicking::panic_fmt
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/panicking.rs:72:14
[INFO] [stdout]    2: fr_service::tests::unit::services::task::task_cycle_test::test_task_cycle
[INFO] [stdout]              at ./src/tests/unit/services/task/task_cycle_test.rs:106:9
[INFO] [stdout]    3: fr_service::tests::unit::services::task::task_cycle_test::test_task_cycle::{{closure}}
[INFO] [stdout]              at ./src/tests/unit/services/task/task_cycle_test.rs:33:21
[INFO] [stdout]    4: core::ops::function::FnOnce::call_once
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/ops/function.rs:250:5
[INFO] [stdout]    5: core::ops::function::FnOnce::call_once
[INFO] [stdout]              at /rustc/82e1608dfa6e0b5569232559e3d385fea5a93112/library/core/src/ops/function.rs:250:5
[INFO] [stdout] note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     tests::unit::services::multi_queue::multi_queue_subscription_test::tests::test_multi_queue_subscribtions
[INFO] [stdout]     tests::unit::services::task::task_cycle_test::test_task_cycle
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 58 passed; 2 failed; 4 ignored; 0 measured; 0 filtered out; finished in 5.53s
[INFO] [stdout] 
[INFO] [stderr] error: test failed, to rerun pass `--bin fr-service`
[INFO] running `Command { std: "docker" "inspect" "2cef58ab5074dfb159244bccb79bb4b0efe265c30fe8839323c4cef42af090a6", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "2cef58ab5074dfb159244bccb79bb4b0efe265c30fe8839323c4cef42af090a6", kill_on_drop: false }`
[INFO] [stdout] 2cef58ab5074dfb159244bccb79bb4b0efe265c30fe8839323c4cef42af090a6
