[INFO] cloning repository https://github.com/konata233/kyuu-msg-queue-netty-io
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/konata233/kyuu-msg-queue-netty-io" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkonata233%2Fkyuu-msg-queue-netty-io", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkonata233%2Fkyuu-msg-queue-netty-io'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 167db2c643bba390ee959233196861f7b06b71fb
[INFO] checking konata233/kyuu-msg-queue-netty-io against try#9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869 for pr-129249
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkonata233%2Fkyuu-msg-queue-netty-io" "/workspace/builds/worker-4-tc2/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-4-tc2/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/konata233/kyuu-msg-queue-netty-io on toolchain 9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/konata233/kyuu-msg-queue-netty-io
[INFO] finished tweaking git repo https://github.com/konata233/kyuu-msg-queue-netty-io
[INFO] tweaked toml for git repo https://github.com/konata233/kyuu-msg-queue-netty-io written to /workspace/builds/worker-4-tc2/source/Cargo.toml
[INFO] crate git repo https://github.com/konata233/kyuu-msg-queue-netty-io 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" "+9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:f3a9d4ad9d972b27faf3965f35b62e55ba32bbce8f20bc8fe909558a86702fde" "/opt/rustwide/cargo-home/bin/cargo" "+9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 89042a714aa2d0b190401ed1b9df026b156018e957a381e26b7af9e6507a7e3e
[INFO] running `Command { std: "docker" "start" "-a" "89042a714aa2d0b190401ed1b9df026b156018e957a381e26b7af9e6507a7e3e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "89042a714aa2d0b190401ed1b9df026b156018e957a381e26b7af9e6507a7e3e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "89042a714aa2d0b190401ed1b9df026b156018e957a381e26b7af9e6507a7e3e", kill_on_drop: false }`
[INFO] [stdout] 89042a714aa2d0b190401ed1b9df026b156018e957a381e26b7af9e6507a7e3e
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:f3a9d4ad9d972b27faf3965f35b62e55ba32bbce8f20bc8fe909558a86702fde" "/opt/rustwide/cargo-home/bin/cargo" "+9543f8ea2aae74b8f13ac2a6e6c0ecdca9810869" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 019f77501aaeab459ed53dfd640f031ba28d2fb77fd7ca813d20af6080feeb32
[INFO] running `Command { std: "docker" "start" "-a" "019f77501aaeab459ed53dfd640f031ba28d2fb77fd7ca813d20af6080feeb32", kill_on_drop: false }`
[INFO] [stderr]     Checking msg-queue-netty-io v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `crate::mq::protocol::protobase::Deserialize`
[INFO] [stdout]  --> src/main.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::mq::protocol::protobase::Deserialize;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::mq::protocol::protobase::Serialize`
[INFO] [stdout]  --> src/main.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use crate::mq::protocol::protobase::Serialize;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Read` and `Write`
[INFO] [stdout]  --> src/main.rs:6:15
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::io::{Read, Write};
[INFO] [stdout]   |               ^^^^  ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::mq::protocol::protobase::Deserialize`
[INFO] [stdout]  --> src/main.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::mq::protocol::protobase::Deserialize;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::mq::protocol::protobase::Serialize`
[INFO] [stdout]  --> src/main.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use crate::mq::protocol::protobase::Serialize;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Read` and `Write`
[INFO] [stdout]  --> src/main.rs:6:15
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::io::{Read, Write};
[INFO] [stdout]   |               ^^^^  ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/mq/io/session.rs:107:13
[INFO] [stdout]     |
[INFO] [stdout] 96  | /             return if ch == channel.clone() {
[INFO] [stdout] 97  | |                 Ok((Some(head), Box::from(buf)))
[INFO] [stdout] 98  | |             } else {
[INFO] [stdout] 99  | |                 self.cache.get_mut(&ch).unwrap().push_back(Box::from(buf));
[INFO] [stdout] ...   |
[INFO] [stdout] 106 | |             };
[INFO] [stdout]     | |_____________- any code following this expression is unreachable
[INFO] [stdout] 107 |               Ok((Some(head), Box::from(buf)))
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/mq/io/session.rs:107:13
[INFO] [stdout]     |
[INFO] [stdout] 96  | /             return if ch == channel.clone() {
[INFO] [stdout] 97  | |                 Ok((Some(head), Box::from(buf)))
[INFO] [stdout] 98  | |             } else {
[INFO] [stdout] 99  | |                 self.cache.get_mut(&ch).unwrap().push_back(Box::from(buf));
[INFO] [stdout] ...   |
[INFO] [stdout] 106 | |             };
[INFO] [stdout]     | |_____________- any code following this expression is unreachable
[INFO] [stdout] 107 |               Ok((Some(head), Box::from(buf)))
[INFO] [stdout]     |               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]  --> src/test/mpsc_test.rs:7:9
[INFO] [stdout]   |
[INFO] [stdout] 7 |     let mut session = session::Session::new("127.0.0.1:11451", "MQ_HOST".to_string());
[INFO] [stdout]   |         ----^^^^^^^
[INFO] [stdout]   |         |
[INFO] [stdout]   |         help: remove this `mut`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]  --> src/test/mpsc_test.rs:8:9
[INFO] [stdout]   |
[INFO] [stdout] 8 |     let mut session = Arc::from(RwLock::from(session));
[INFO] [stdout]   |         ----^^^^^^^
[INFO] [stdout]   |         |
[INFO] [stdout]   |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `version` is never read
[INFO] [stdout]   --> src/mq/io/factory.rs:66:5
[INFO] [stdout]    |
[INFO] [stdout] 63 | pub struct MessageFactory {
[INFO] [stdout]    |            -------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 66 |     version: [u8; 4],
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `create_exchange`, `create_queue`, `drop_exchange`, and `drop_queue` are never used
[INFO] [stdout]  --> src/mq/api/common.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 4 | pub trait ChannelApi {
[INFO] [stdout]   |           ---------- methods in this trait
[INFO] [stdout] 5 |     fn create_exchange(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^
[INFO] [stdout] 6 |     fn create_queue(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^
[INFO] [stdout] 7 |     fn drop_exchange(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^^
[INFO] [stdout] 8 |     fn drop_queue(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_queue` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:12:8
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub trait ChannelQueueApi {
[INFO] [stdout]    |           --------------- method in this trait
[INFO] [stdout] 12 |     fn get_queue(&mut self, routing_chain: RoutingChain) -> Result<Queue, Box<dyn std::error::Error>>;
[INFO] [stdout]    |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `FetchResult` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:15:10
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub enum FetchResult {
[INFO] [stdout]    |          ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `FetchResultString` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:22:10
[INFO] [stdout]    |
[INFO] [stdout] 22 | pub enum FetchResultString {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `routing_chain`, `channel_name`, `host_name`, and `session` are never read
[INFO] [stdout]   --> src/mq/api/queue.rs:9:5
[INFO] [stdout]    |
[INFO] [stdout] 8  | pub struct Queue {
[INFO] [stdout]    |            ----- fields in this struct
[INFO] [stdout] 9  |     routing_chain: RoutingChain,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 10 |     channel_name: String,
[INFO] [stdout]    |     ^^^^^^^^^^^^
[INFO] [stdout] 11 |     host_name: String,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 12 |     session: Arc<RwLock<Session>>,
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `push`, `fetch`, `push_string`, `fetch_string`, `fetch_simple`, and `fetch_simple_string` are never used
[INFO] [stdout]   --> src/mq/api/queue.rs:25:12
[INFO] [stdout]    |
[INFO] [stdout] 15 | impl Queue {
[INFO] [stdout]    | ---------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 25 |     pub fn push(&self, data: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 41 |     pub fn fetch(&self) -> Result<(Option<DataHead>, Option<Vec<u8>>), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 59 |     pub fn push_string(&self, data: String) -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 63 |     pub fn fetch_string(&self) -> Result<(Option<DataHead>, Option<String>), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 68 |     pub fn fetch_simple(&self) -> FetchResult {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |     pub fn fetch_simple_string(&self) -> FetchResultString {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `mpsc_test` is never used
[INFO] [stdout]  --> src/test/mpsc_test.rs:6:8
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub fn mpsc_test() -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]   |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]  --> src/test/mpsc_test.rs:7:9
[INFO] [stdout]   |
[INFO] [stdout] 7 |     let mut session = session::Session::new("127.0.0.1:11451", "MQ_HOST".to_string());
[INFO] [stdout]   |         ----^^^^^^^
[INFO] [stdout]   |         |
[INFO] [stdout]   |         help: remove this `mut`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]  --> src/test/mpsc_test.rs:8:9
[INFO] [stdout]   |
[INFO] [stdout] 8 |     let mut session = Arc::from(RwLock::from(session));
[INFO] [stdout]   |         ----^^^^^^^
[INFO] [stdout]   |         |
[INFO] [stdout]   |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]   --> src/mq/io/channel.rs:64:9
[INFO] [stdout]    |
[INFO] [stdout] 64 | /         self.send(
[INFO] [stdout] 65 | |             self.get_factory()
[INFO] [stdout] 66 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 67 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 68 | |                 .data(name.into_bytes())
[INFO] [stdout] 69 | |                 .build()
[INFO] [stdout] 70 | |         ).into()
[INFO] [stdout]    | |________________^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[deny(self_type_conversion)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]   --> src/mq/io/channel.rs:79:9
[INFO] [stdout]    |
[INFO] [stdout] 79 | /         self.send(
[INFO] [stdout] 80 | |             self.get_factory()
[INFO] [stdout] 81 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 82 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 83 | |                 .data(name.into_bytes())
[INFO] [stdout] 84 | |                 .build()
[INFO] [stdout] 85 | |         ).into()
[INFO] [stdout]    | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]    --> src/mq/io/channel.rs:94:9
[INFO] [stdout]     |
[INFO] [stdout] 94  | /         self.send(
[INFO] [stdout] 95  | |             self.get_factory()
[INFO] [stdout] 96  | |                 .routing_mod(routing_mod)
[INFO] [stdout] 97  | |                 .routing_chain(routing_chain)
[INFO] [stdout] 98  | |                 .data(name.into_bytes())
[INFO] [stdout] 99  | |                 .build()
[INFO] [stdout] 100 | |         ).into()
[INFO] [stdout]     | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]    --> src/mq/io/channel.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 | /         self.send(
[INFO] [stdout] 110 | |             self.get_factory()
[INFO] [stdout] 111 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 112 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 113 | |                 .data(name.into_bytes())
[INFO] [stdout] 114 | |                 .build()
[INFO] [stdout] 115 | |         ).into()
[INFO] [stdout]     | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:33:5
[INFO] [stdout]    |
[INFO] [stdout] 33 |     channel.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 33 |     let _ = channel.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:46:5
[INFO] [stdout]    |
[INFO] [stdout] 46 |     channel.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 46 |     let _ = channel.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `version` is never read
[INFO] [stdout]   --> src/mq/io/factory.rs:66:5
[INFO] [stdout]    |
[INFO] [stdout] 63 | pub struct MessageFactory {
[INFO] [stdout]    |            -------------- field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 66 |     version: [u8; 4],
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:64:13
[INFO] [stdout]    |
[INFO] [stdout] 64 |             channel2.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 64 |             let _ = channel2.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:86:13
[INFO] [stdout]    |
[INFO] [stdout] 86 |             channel_cloned.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 86 |             let _ = channel_cloned.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:31:5
[INFO] [stdout]    |
[INFO] [stdout] 31 |     producer.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 31 |     let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:44:5
[INFO] [stdout]    |
[INFO] [stdout] 44 |     producer.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 44 |     let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:60:13
[INFO] [stdout]    |
[INFO] [stdout] 60 |             producer.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 60 |             let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `create_exchange`, `create_queue`, `drop_exchange`, and `drop_queue` are never used
[INFO] [stdout]  --> src/mq/api/common.rs:5:8
[INFO] [stdout]   |
[INFO] [stdout] 4 | pub trait ChannelApi {
[INFO] [stdout]   |           ---------- methods in this trait
[INFO] [stdout] 5 |     fn create_exchange(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^^^^
[INFO] [stdout] 6 |     fn create_queue(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^
[INFO] [stdout] 7 |     fn drop_exchange(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^^^^
[INFO] [stdout] 8 |     fn drop_queue(&mut self, name: String, routing_chain: RoutingChain) -> Result<(), Box<dyn std::error::Error>>;
[INFO] [stdout]   |        ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: method `get_queue` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:12:8
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub trait ChannelQueueApi {
[INFO] [stdout]    |           --------------- method in this trait
[INFO] [stdout] 12 |     fn get_queue(&mut self, routing_chain: RoutingChain) -> Result<Queue, Box<dyn std::error::Error>>;
[INFO] [stdout]    |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `FetchResult` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:15:10
[INFO] [stdout]    |
[INFO] [stdout] 15 | pub enum FetchResult {
[INFO] [stdout]    |          ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: enum `FetchResultString` is never used
[INFO] [stdout]   --> src/mq/api/common.rs:22:10
[INFO] [stdout]    |
[INFO] [stdout] 22 | pub enum FetchResultString {
[INFO] [stdout]    |          ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `routing_chain`, `channel_name`, `host_name`, and `session` are never read
[INFO] [stdout]   --> src/mq/api/queue.rs:9:5
[INFO] [stdout]    |
[INFO] [stdout] 8  | pub struct Queue {
[INFO] [stdout]    |            ----- fields in this struct
[INFO] [stdout] 9  |     routing_chain: RoutingChain,
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 10 |     channel_name: String,
[INFO] [stdout]    |     ^^^^^^^^^^^^
[INFO] [stdout] 11 |     host_name: String,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 12 |     session: Arc<RwLock<Session>>,
[INFO] [stdout]    |     ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `push`, `fetch`, `push_string`, `fetch_string`, `fetch_simple`, and `fetch_simple_string` are never used
[INFO] [stdout]   --> src/mq/api/queue.rs:25:12
[INFO] [stdout]    |
[INFO] [stdout] 15 | impl Queue {
[INFO] [stdout]    | ---------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 25 |     pub fn push(&self, data: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^
[INFO] [stdout] ...
[INFO] [stdout] 41 |     pub fn fetch(&self) -> Result<(Option<DataHead>, Option<Vec<u8>>), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 59 |     pub fn push_string(&self, data: String) -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 63 |     pub fn fetch_string(&self) -> Result<(Option<DataHead>, Option<String>), Box<dyn std::error::Error>> {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 68 |     pub fn fetch_simple(&self) -> FetchResult {
[INFO] [stdout]    |            ^^^^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 87 |     pub fn fetch_simple_string(&self) -> FetchResultString {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `mpsc_test` is never used
[INFO] [stdout]  --> src/test/mpsc_test.rs:6:8
[INFO] [stdout]   |
[INFO] [stdout] 6 | pub fn mpsc_test() -> Result<(), Box<dyn std::error::Error>> {
[INFO] [stdout]   |        ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]   --> src/mq/io/channel.rs:64:9
[INFO] [stdout]    |
[INFO] [stdout] 64 | /         self.send(
[INFO] [stdout] 65 | |             self.get_factory()
[INFO] [stdout] 66 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 67 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 68 | |                 .data(name.into_bytes())
[INFO] [stdout] 69 | |                 .build()
[INFO] [stdout] 70 | |         ).into()
[INFO] [stdout]    | |________________^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[deny(self_type_conversion)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]   --> src/mq/io/channel.rs:79:9
[INFO] [stdout]    |
[INFO] [stdout] 79 | /         self.send(
[INFO] [stdout] 80 | |             self.get_factory()
[INFO] [stdout] 81 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 82 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 83 | |                 .data(name.into_bytes())
[INFO] [stdout] 84 | |                 .build()
[INFO] [stdout] 85 | |         ).into()
[INFO] [stdout]    | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `msg-queue-netty-io` (bin "msg-queue-netty-io") due to 4 previous errors; 21 warnings emitted
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]    --> src/mq/io/channel.rs:94:9
[INFO] [stdout]     |
[INFO] [stdout] 94  | /         self.send(
[INFO] [stdout] 95  | |             self.get_factory()
[INFO] [stdout] 96  | |                 .routing_mod(routing_mod)
[INFO] [stdout] 97  | |                 .routing_chain(routing_chain)
[INFO] [stdout] 98  | |                 .data(name.into_bytes())
[INFO] [stdout] 99  | |                 .build()
[INFO] [stdout] 100 | |         ).into()
[INFO] [stdout]     | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: this conversion is useless `Result<(), Box<dyn std::error::Error>>` to `Result<(), Box<dyn std::error::Error>>`
[INFO] [stdout]    --> src/mq/io/channel.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 | /         self.send(
[INFO] [stdout] 110 | |             self.get_factory()
[INFO] [stdout] 111 | |                 .routing_mod(routing_mod)
[INFO] [stdout] 112 | |                 .routing_chain(routing_chain)
[INFO] [stdout] 113 | |                 .data(name.into_bytes())
[INFO] [stdout] 114 | |                 .build()
[INFO] [stdout] 115 | |         ).into()
[INFO] [stdout]     | |________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:33:5
[INFO] [stdout]    |
[INFO] [stdout] 33 |     channel.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 33 |     let _ = channel.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:46:5
[INFO] [stdout]    |
[INFO] [stdout] 46 |     channel.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 46 |     let _ = channel.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:64:13
[INFO] [stdout]    |
[INFO] [stdout] 64 |             channel2.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 64 |             let _ = channel2.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/mpsc_test.rs:86:13
[INFO] [stdout]    |
[INFO] [stdout] 86 |             channel_cloned.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 86 |             let _ = channel_cloned.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:31:5
[INFO] [stdout]    |
[INFO] [stdout] 31 |     producer.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 31 |     let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:44:5
[INFO] [stdout]    |
[INFO] [stdout] 44 |     producer.write().unwrap().send(msg);
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 44 |     let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |     +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]   --> src/test/spmc_test.rs:60:13
[INFO] [stdout]    |
[INFO] [stdout] 60 |             producer.write().unwrap().send(msg);
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] help: use `let _ = ...` to ignore the resulting value
[INFO] [stdout]    |
[INFO] [stdout] 60 |             let _ = producer.write().unwrap().send(msg);
[INFO] [stdout]    |             +++++++
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `msg-queue-netty-io` (bin "msg-queue-netty-io" test) due to 4 previous errors; 21 warnings emitted
[INFO] running `Command { std: "docker" "inspect" "019f77501aaeab459ed53dfd640f031ba28d2fb77fd7ca813d20af6080feeb32", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "019f77501aaeab459ed53dfd640f031ba28d2fb77fd7ca813d20af6080feeb32", kill_on_drop: false }`
[INFO] [stdout] 019f77501aaeab459ed53dfd640f031ba28d2fb77fd7ca813d20af6080feeb32