Dec 06 19:47:41.699 INFO testing tokio-mqttc-0.0.2 against try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468 for pr-56514 Dec 06 19:47:41.700 INFO running `"docker" "create" "-v" "/mnt/big/crater/work/local/target-dirs/pr-56514/worker-2/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/target:rw,Z" "-v" "/mnt/big/crater/work/local/test-source/worker-2/pr-56514/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/source:ro,Z" "-v" "/mnt/big/crater/work/local/cargo-home:/cargo-home:ro,Z" "-v" "/mnt/big/crater/work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "SOURCE_DIR=/source" "-e" "USER_ID=1000" "-e" "CMD=cargo +6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468-alt build --frozen" "-e" "CARGO_TARGET_DIR=/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/cargo-home" "-e" "RUSTUP_HOME=/rustup-home" "-m" "1536M" "--network" "none" "crater"` Dec 06 19:47:41.884 INFO [stdout] 4648851eda99cd24164414f314608277a81393f1998dbc5b19cc8e29e9977aaf Dec 06 19:47:41.886 INFO running `"docker" "start" "-a" "4648851eda99cd24164414f314608277a81393f1998dbc5b19cc8e29e9977aaf"` Dec 06 19:47:42.366 INFO [stderr] usermod: no changes Dec 06 19:47:42.552 INFO [stderr] Compiling futures-mutex v0.1.2 Dec 06 19:47:42.552 INFO [stderr] Compiling touch v0.0.1 Dec 06 19:47:42.555 INFO [stderr] Compiling bincode v0.9.2 Dec 06 19:47:42.556 INFO [stderr] Compiling linked-hash-map v0.5.1 Dec 06 19:47:43.676 INFO [stderr] Compiling tokio-mqttc v0.0.2 (/source) Dec 06 19:47:47.677 INFO [stderr] warning: unused import: `Error` Dec 06 19:47:47.678 INFO [stderr] --> src/proto/types.rs:4:14 Dec 06 19:47:47.678 INFO [stderr] | Dec 06 19:47:47.678 INFO [stderr] 4 | use errors::{Error, ErrorKind}; Dec 06 19:47:47.678 INFO [stderr] | ^^^^^ Dec 06 19:47:47.678 INFO [stderr] | Dec 06 19:47:47.678 INFO [stderr] = note: #[warn(unused_imports)] on by default Dec 06 19:47:47.678 INFO [stderr] Dec 06 19:47:47.678 INFO [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` Dec 06 19:47:47.678 INFO [stderr] --> src/proto/types.rs:5:5 Dec 06 19:47:47.678 INFO [stderr] | Dec 06 19:47:47.678 INFO [stderr] 5 | use linked_hash_map::LinkedHashMap; Dec 06 19:47:47.678 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.678 INFO [stderr] Dec 06 19:47:47.683 INFO [stderr] warning: unused imports: `IResult`, `be_u16` Dec 06 19:47:47.683 INFO [stderr] --> src/proto/headers.rs:3:11 Dec 06 19:47:47.683 INFO [stderr] | Dec 06 19:47:47.683 INFO [stderr] 3 | use nom::{IResult, be_u16}; Dec 06 19:47:47.683 INFO [stderr] | ^^^^^^^ ^^^^^^ Dec 06 19:47:47.683 INFO [stderr] Dec 06 19:47:47.683 INFO [stderr] warning: unused import: `std::io` Dec 06 19:47:47.683 INFO [stderr] --> src/proto/mod.rs:8:5 Dec 06 19:47:47.683 INFO [stderr] | Dec 06 19:47:47.683 INFO [stderr] 8 | use std::io; Dec 06 19:47:47.683 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.683 INFO [stderr] Dec 06 19:47:47.683 INFO [stderr] warning: unused import: `Entry` Dec 06 19:47:47.683 INFO [stderr] --> src/proto/mod.rs:12:23 Dec 06 19:47:47.683 INFO [stderr] | Dec 06 19:47:47.683 INFO [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; Dec 06 19:47:47.683 INFO [stderr] | ^^^^^ Dec 06 19:47:47.683 INFO [stderr] Dec 06 19:47:47.683 INFO [stderr] warning: unused import: `Writer` Dec 06 19:47:47.684 INFO [stderr] --> src/proto/mod.rs:13:38 Dec 06 19:47:47.684 INFO [stderr] | Dec 06 19:47:47.684 INFO [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Dec 06 19:47:47.684 INFO [stderr] | ^^^^^^ Dec 06 19:47:47.684 INFO [stderr] Dec 06 19:47:47.684 INFO [stderr] warning: unused import: `self::headers::*` Dec 06 19:47:47.684 INFO [stderr] --> src/proto/mod.rs:15:5 Dec 06 19:47:47.684 INFO [stderr] | Dec 06 19:47:47.684 INFO [stderr] 15 | use self::headers::*; Dec 06 19:47:47.684 INFO [stderr] | ^^^^^^^^^^^^^^^^ Dec 06 19:47:47.684 INFO [stderr] Dec 06 19:47:47.685 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.685 INFO [stderr] --> src/tokio/mqtt_loop.rs:13:5 Dec 06 19:47:47.685 INFO [stderr] | Dec 06 19:47:47.685 INFO [stderr] 13 | use take::Take; Dec 06 19:47:47.685 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.685 INFO [stderr] Dec 06 19:47:47.685 INFO [stderr] warning: unused import: `MqttFramedWriter` Dec 06 19:47:47.685 INFO [stderr] --> src/tokio/mqtt_loop.rs:21:13 Dec 06 19:47:47.685 INFO [stderr] | Dec 06 19:47:47.685 INFO [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Dec 06 19:47:47.685 INFO [stderr] | ^^^^^^^^^^^^^^^^ Dec 06 19:47:47.685 INFO [stderr] Dec 06 19:47:47.686 INFO [stderr] warning: unused import: `super::response::ResponseProcessor` Dec 06 19:47:47.686 INFO [stderr] --> src/tokio/mqtt_loop.rs:23:5 Dec 06 19:47:47.686 INFO [stderr] | Dec 06 19:47:47.686 INFO [stderr] 23 | use super::response::ResponseProcessor; Dec 06 19:47:47.686 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.687 INFO [stderr] Dec 06 19:47:47.687 INFO [stderr] warning: unused import: `super::request::RequestProcessor` Dec 06 19:47:47.687 INFO [stderr] --> src/tokio/mqtt_loop.rs:24:5 Dec 06 19:47:47.687 INFO [stderr] | Dec 06 19:47:47.687 INFO [stderr] 24 | use super::request::RequestProcessor; Dec 06 19:47:47.687 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.687 INFO [stderr] Dec 06 19:47:47.687 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.687 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 Dec 06 19:47:47.687 INFO [stderr] | Dec 06 19:47:47.687 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.687 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.687 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 4 | use take::Take; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 6 | use bincode; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.688 INFO [stderr] warning: unused import: `PublishState` Dec 06 19:47:47.688 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 Dec 06 19:47:47.688 INFO [stderr] | Dec 06 19:47:47.688 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Dec 06 19:47:47.688 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:47.688 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 4 | use take::Take; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `PacketType` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `OneTimeKey` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `BoxFuture` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 7 | use take::Take; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Dec 06 19:47:47.693 INFO [stderr] | Dec 06 19:47:47.693 INFO [stderr] 9 | use bincode; Dec 06 19:47:47.693 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.693 INFO [stderr] Dec 06 19:47:47.693 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Dec 06 19:47:47.693 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] 12 | PacketId, TopicName}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 6 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 8 | use take::Take; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 10 | use bincode; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] 13 | PacketId, TopicName}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.694 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.694 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 Dec 06 19:47:47.694 INFO [stderr] | Dec 06 19:47:47.694 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.694 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.694 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^ ^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 9 | use take::Take; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 11 | use bincode; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] 14 | PacketId, TopicName}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.695 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 Dec 06 19:47:47.695 INFO [stderr] | Dec 06 19:47:47.695 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.695 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.695 INFO [stderr] Dec 06 19:47:47.695 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 9 | use take::Take; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 11 | use bincode; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `bytes::Bytes` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 4 | use bytes::Bytes; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.696 INFO [stderr] | ^^^^ ^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 8 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 10 | use take::Take; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.696 INFO [stderr] 12 | use bincode; Dec 06 19:47:47.696 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.696 INFO [stderr] Dec 06 19:47:47.696 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:47.696 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Dec 06 19:47:47.696 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] 15 | PacketId, TopicName}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `Result` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `bytes::Bytes` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 4 | use bytes::Bytes; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 9 | use take::Take; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] 14 | PacketId, TopicName}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `Result` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:47.697 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.697 INFO [stderr] Dec 06 19:47:47.697 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:47.697 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 Dec 06 19:47:47.697 INFO [stderr] | Dec 06 19:47:47.697 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 9 | use take::Take; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 11 | use bincode; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.698 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:47.698 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 Dec 06 19:47:47.698 INFO [stderr] | Dec 06 19:47:47.698 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:47.698 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:47.698 INFO [stderr] Dec 06 19:47:47.762 INFO [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:47.763 INFO [stderr] --> src/types.rs:3:5 Dec 06 19:47:47.763 INFO [stderr] | Dec 06 19:47:47.763 INFO [stderr] 3 | use futures::future::BoxFuture; Dec 06 19:47:47.763 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.763 INFO [stderr] | Dec 06 19:47:47.763 INFO [stderr] = note: #[warn(deprecated)] on by default Dec 06 19:47:47.763 INFO [stderr] Dec 06 19:47:47.763 INFO [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:47.763 INFO [stderr] --> src/types.rs:5:5 Dec 06 19:47:47.763 INFO [stderr] | Dec 06 19:47:47.763 INFO [stderr] 5 | use futures::stream::BoxStream; Dec 06 19:47:47.763 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.763 INFO [stderr] Dec 06 19:47:47.763 INFO [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:47.763 INFO [stderr] --> src/types.rs:7:29 Dec 06 19:47:47.763 INFO [stderr] | Dec 06 19:47:47.763 INFO [stderr] 7 | pub type BoxMqttFuture = BoxFuture; Dec 06 19:47:47.763 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.763 INFO [stderr] Dec 06 19:47:47.763 INFO [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:47.763 INFO [stderr] --> src/types.rs:9:29 Dec 06 19:47:47.763 INFO [stderr] | Dec 06 19:47:47.763 INFO [stderr] 9 | pub type BoxMqttStream = BoxStream; Dec 06 19:47:47.763 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.763 INFO [stderr] Dec 06 19:47:47.764 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:47.764 INFO [stderr] --> src/tokio/mod.rs:12:5 Dec 06 19:47:47.764 INFO [stderr] | Dec 06 19:47:47.764 INFO [stderr] 12 | use tokio_io::codec::Framed; Dec 06 19:47:47.764 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.764 INFO [stderr] Dec 06 19:47:47.764 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:47.764 INFO [stderr] --> src/tokio/mod.rs:27:40 Dec 06 19:47:47.764 INFO [stderr] | Dec 06 19:47:47.764 INFO [stderr] 27 | type MqttFramedReader = SplitStream>; Dec 06 19:47:47.764 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.764 INFO [stderr] Dec 06 19:47:47.764 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:47.764 INFO [stderr] --> src/tokio/mod.rs:28:38 Dec 06 19:47:47.764 INFO [stderr] | Dec 06 19:47:47.764 INFO [stderr] 28 | type MqttFramedWriter = SplitSink>; Dec 06 19:47:47.764 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:47.764 INFO [stderr] Dec 06 19:47:48.184 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:48.184 INFO [stderr] --> src/proto/types.rs:271:13 Dec 06 19:47:48.184 INFO [stderr] | Dec 06 19:47:48.184 INFO [stderr] 271 | out.put_u16::(self.len() as u16); Dec 06 19:47:48.184 INFO [stderr] | ^^^^^^^ Dec 06 19:47:48.184 INFO [stderr] Dec 06 19:47:48.277 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Dec 06 19:47:48.277 INFO [stderr] --> src/proto/headers.rs:135:40 Dec 06 19:47:48.277 INFO [stderr] | Dec 06 19:47:48.277 INFO [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) Dec 06 19:47:48.277 INFO [stderr] | ^^^^^^^ Dec 06 19:47:48.277 INFO [stderr] Dec 06 19:47:48.277 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:48.277 INFO [stderr] --> src/proto/headers.rs:140:13 Dec 06 19:47:48.277 INFO [stderr] | Dec 06 19:47:48.277 INFO [stderr] 140 | out.put_u16::(self.0); Dec 06 19:47:48.277 INFO [stderr] | ^^^^^^^ Dec 06 19:47:48.277 INFO [stderr] Dec 06 19:47:48.277 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Dec 06 19:47:48.278 INFO [stderr] --> src/proto/headers.rs:170:41 Dec 06 19:47:48.278 INFO [stderr] | Dec 06 19:47:48.278 INFO [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Dec 06 19:47:48.278 INFO [stderr] | ^^^^^^^ Dec 06 19:47:48.278 INFO [stderr] Dec 06 19:47:48.278 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:48.278 INFO [stderr] --> src/proto/headers.rs:175:13 Dec 06 19:47:48.278 INFO [stderr] | Dec 06 19:47:48.278 INFO [stderr] 175 | out.put_u16::(self.0); Dec 06 19:47:48.278 INFO [stderr] | ^^^^^^^ Dec 06 19:47:48.278 INFO [stderr] Dec 06 19:47:48.290 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.290 INFO [stderr] --> src/client.rs:223:55 Dec 06 19:47:48.290 INFO [stderr] | Dec 06 19:47:48.290 INFO [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Dec 06 19:47:48.290 INFO [stderr] | ^^^^^ Dec 06 19:47:48.290 INFO [stderr] Dec 06 19:47:48.300 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.300 INFO [stderr] --> src/client.rs:266:63 Dec 06 19:47:48.300 INFO [stderr] | Dec 06 19:47:48.300 INFO [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() Dec 06 19:47:48.300 INFO [stderr] | ^^^^^ Dec 06 19:47:48.300 INFO [stderr] Dec 06 19:47:48.335 INFO [stderr] warning: use of deprecated item '>::send': renamed to `unbounded_send` Dec 06 19:47:48.335 INFO [stderr] --> src/tokio/mqtt_loop.rs:54:32 Dec 06 19:47:48.335 INFO [stderr] | Dec 06 19:47:48.335 INFO [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Dec 06 19:47:48.335 INFO [stderr] | ^^^^ Dec 06 19:47:48.335 INFO [stderr] Dec 06 19:47:48.338 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.338 INFO [stderr] --> src/tokio/mqtt_loop.rs:60:47 Dec 06 19:47:48.338 INFO [stderr] | Dec 06 19:47:48.338 INFO [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) Dec 06 19:47:48.338 INFO [stderr] | ^^^^^ Dec 06 19:47:48.338 INFO [stderr] Dec 06 19:47:48.345 INFO [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Dec 06 19:47:48.345 INFO [stderr] --> src/tokio/mqtt_loop.rs:266:34 Dec 06 19:47:48.345 INFO [stderr] | Dec 06 19:47:48.345 INFO [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Dec 06 19:47:48.345 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.345 INFO [stderr] Dec 06 19:47:48.361 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.361 INFO [stderr] --> src/tokio/mqtt_loop.rs:317:14 Dec 06 19:47:48.361 INFO [stderr] | Dec 06 19:47:48.361 INFO [stderr] 317 | .boxed() Dec 06 19:47:48.361 INFO [stderr] | ^^^^^ Dec 06 19:47:48.361 INFO [stderr] Dec 06 19:47:48.368 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.368 INFO [stderr] --> src/tokio/mqtt_loop.rs:519:42 Dec 06 19:47:48.368 INFO [stderr] | Dec 06 19:47:48.368 INFO [stderr] 519 | .boxed(), Dec 06 19:47:48.368 INFO [stderr] | ^^^^^ Dec 06 19:47:48.368 INFO [stderr] Dec 06 19:47:48.380 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.380 INFO [stderr] --> src/tokio/response.rs:83:40 Dec 06 19:47:48.380 INFO [stderr] | Dec 06 19:47:48.380 INFO [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Dec 06 19:47:48.380 INFO [stderr] | ^^^^^ Dec 06 19:47:48.380 INFO [stderr] Dec 06 19:47:48.418 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:48.418 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Dec 06 19:47:48.418 INFO [stderr] | Dec 06 19:47:48.418 INFO [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Dec 06 19:47:48.418 INFO [stderr] | ^^^^^ Dec 06 19:47:48.418 INFO [stderr] Dec 06 19:47:48.564 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:48.564 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Dec 06 19:47:48.564 INFO [stderr] | Dec 06 19:47:48.564 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.564 INFO [stderr] | ^^^^ Dec 06 19:47:48.564 INFO [stderr] Dec 06 19:47:48.564 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:48.564 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Dec 06 19:47:48.564 INFO [stderr] | Dec 06 19:47:48.564 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.564 INFO [stderr] | ^^^^ Dec 06 19:47:48.564 INFO [stderr] Dec 06 19:47:48.564 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.564 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Dec 06 19:47:48.564 INFO [stderr] | Dec 06 19:47:48.564 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.564 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.564 INFO [stderr] Dec 06 19:47:48.564 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:48.564 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 Dec 06 19:47:48.564 INFO [stderr] | Dec 06 19:47:48.564 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.564 INFO [stderr] | ^^^^ Dec 06 19:47:48.564 INFO [stderr] Dec 06 19:47:48.564 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.564 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 Dec 06 19:47:48.564 INFO [stderr] | Dec 06 19:47:48.564 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.564 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.565 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.565 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 Dec 06 19:47:48.565 INFO [stderr] | Dec 06 19:47:48.565 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.565 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.565 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:48.565 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Dec 06 19:47:48.565 INFO [stderr] | Dec 06 19:47:48.565 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.565 INFO [stderr] | ^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.565 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.565 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Dec 06 19:47:48.565 INFO [stderr] | Dec 06 19:47:48.565 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.565 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.565 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.565 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Dec 06 19:47:48.565 INFO [stderr] | Dec 06 19:47:48.565 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.565 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.565 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:48.565 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 Dec 06 19:47:48.565 INFO [stderr] | Dec 06 19:47:48.565 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:48.565 INFO [stderr] | ^^^^^^ Dec 06 19:47:48.565 INFO [stderr] Dec 06 19:47:48.847 INFO [stderr] warning: variable does not need to be mutable Dec 06 19:47:48.847 INFO [stderr] --> src/tokio/mqtt_loop.rs:320:31 Dec 06 19:47:48.847 INFO [stderr] | Dec 06 19:47:48.847 INFO [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Dec 06 19:47:48.847 INFO [stderr] | ----^^^ Dec 06 19:47:48.847 INFO [stderr] | | Dec 06 19:47:48.847 INFO [stderr] | help: remove this `mut` Dec 06 19:47:48.847 INFO [stderr] | Dec 06 19:47:48.847 INFO [stderr] = note: #[warn(unused_mut)] on by default Dec 06 19:47:48.847 INFO [stderr] Dec 06 19:47:49.040 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:49.040 INFO [stderr] --> src/tokio/mqtt_loop.rs:571:17 Dec 06 19:47:49.040 INFO [stderr] | Dec 06 19:47:49.040 INFO [stderr] 571 | self.poll_queues(sourceitem); Dec 06 19:47:49.040 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:49.040 INFO [stderr] | Dec 06 19:47:49.040 INFO [stderr] = note: #[warn(unused_must_use)] on by default Dec 06 19:47:49.040 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:49.040 INFO [stderr] Dec 06 19:47:49.044 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:49.044 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 Dec 06 19:47:49.044 INFO [stderr] | Dec 06 19:47:49.044 INFO [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( Dec 06 19:47:49.044 INFO [stderr] 105 | | MqttPacket::pub_ack_packet(*id), Dec 06 19:47:49.044 INFO [stderr] 106 | | )); Dec 06 19:47:49.044 INFO [stderr] | |___________________________^ Dec 06 19:47:49.044 INFO [stderr] | Dec 06 19:47:49.044 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:49.044 INFO [stderr] Dec 06 19:47:49.044 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:49.044 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 Dec 06 19:47:49.044 INFO [stderr] | Dec 06 19:47:49.044 INFO [stderr] 128 | / requester.unbounded_send( Dec 06 19:47:49.044 INFO [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Dec 06 19:47:49.044 INFO [stderr] 130 | | ); Dec 06 19:47:49.044 INFO [stderr] | |______________________________^ Dec 06 19:47:49.044 INFO [stderr] | Dec 06 19:47:49.044 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:49.044 INFO [stderr] Dec 06 19:47:49.051 INFO [stderr] warning: unused `futures::sink::Send` that must be used Dec 06 19:47:49.051 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Dec 06 19:47:49.051 INFO [stderr] | Dec 06 19:47:49.051 INFO [stderr] 100 | requester.send(LoopRequest::Internal(rel)); Dec 06 19:47:49.051 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:49.051 INFO [stderr] | Dec 06 19:47:49.051 INFO [stderr] = note: futures do nothing unless polled Dec 06 19:47:49.051 INFO [stderr] Dec 06 19:47:50.664 INFO [stderr] Finished dev [unoptimized + debuginfo] target(s) in 8.27s Dec 06 19:47:50.674 INFO [stderr] su: No module specific data is present Dec 06 19:47:51.138 INFO running `"docker" "inspect" "4648851eda99cd24164414f314608277a81393f1998dbc5b19cc8e29e9977aaf"` Dec 06 19:47:51.209 INFO running `"docker" "rm" "-f" "4648851eda99cd24164414f314608277a81393f1998dbc5b19cc8e29e9977aaf"` Dec 06 19:47:51.272 INFO [stdout] 4648851eda99cd24164414f314608277a81393f1998dbc5b19cc8e29e9977aaf Dec 06 19:47:51.275 INFO running `"docker" "create" "-v" "/mnt/big/crater/work/local/target-dirs/pr-56514/worker-2/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/target:rw,Z" "-v" "/mnt/big/crater/work/local/test-source/worker-2/pr-56514/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/source:ro,Z" "-v" "/mnt/big/crater/work/local/cargo-home:/cargo-home:ro,Z" "-v" "/mnt/big/crater/work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "SOURCE_DIR=/source" "-e" "USER_ID=1000" "-e" "CMD=cargo +6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468-alt test --frozen --no-run" "-e" "CARGO_TARGET_DIR=/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/cargo-home" "-e" "RUSTUP_HOME=/rustup-home" "-m" "1536M" "--network" "none" "crater"` Dec 06 19:47:51.446 INFO [stdout] 5e344e3c49ac2ddbf07c552e3a35aa9ae287a8f5ae2df0879e029219568dff64 Dec 06 19:47:51.448 INFO running `"docker" "start" "-a" "5e344e3c49ac2ddbf07c552e3a35aa9ae287a8f5ae2df0879e029219568dff64"` Dec 06 19:47:52.026 INFO [stderr] usermod: no changes Dec 06 19:47:52.203 INFO [stderr] Compiling nom-test-helpers v2.0.0 Dec 06 19:47:52.585 INFO [stderr] Compiling tokio-mqttc v0.0.2 (/source) Dec 06 19:47:57.937 INFO [stderr] warning: unused import: `Error` Dec 06 19:47:57.937 INFO [stderr] --> src/proto/types.rs:4:14 Dec 06 19:47:57.937 INFO [stderr] | Dec 06 19:47:57.937 INFO [stderr] 4 | use errors::{Error, ErrorKind}; Dec 06 19:47:57.937 INFO [stderr] | ^^^^^ Dec 06 19:47:57.937 INFO [stderr] | Dec 06 19:47:57.937 INFO [stderr] = note: #[warn(unused_imports)] on by default Dec 06 19:47:57.937 INFO [stderr] Dec 06 19:47:57.937 INFO [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` Dec 06 19:47:57.937 INFO [stderr] --> src/proto/types.rs:5:5 Dec 06 19:47:57.937 INFO [stderr] | Dec 06 19:47:57.937 INFO [stderr] 5 | use linked_hash_map::LinkedHashMap; Dec 06 19:47:57.937 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.937 INFO [stderr] Dec 06 19:47:57.942 INFO [stderr] warning: unused imports: `IResult`, `be_u16` Dec 06 19:47:57.942 INFO [stderr] --> src/proto/headers.rs:3:11 Dec 06 19:47:57.942 INFO [stderr] | Dec 06 19:47:57.942 INFO [stderr] 3 | use nom::{IResult, be_u16}; Dec 06 19:47:57.942 INFO [stderr] | ^^^^^^^ ^^^^^^ Dec 06 19:47:57.942 INFO [stderr] Dec 06 19:47:57.942 INFO [stderr] warning: unused import: `std::io` Dec 06 19:47:57.942 INFO [stderr] --> src/proto/mod.rs:8:5 Dec 06 19:47:57.942 INFO [stderr] | Dec 06 19:47:57.942 INFO [stderr] 8 | use std::io; Dec 06 19:47:57.942 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.942 INFO [stderr] Dec 06 19:47:57.942 INFO [stderr] warning: unused import: `Entry` Dec 06 19:47:57.942 INFO [stderr] --> src/proto/mod.rs:12:23 Dec 06 19:47:57.942 INFO [stderr] | Dec 06 19:47:57.942 INFO [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; Dec 06 19:47:57.942 INFO [stderr] | ^^^^^ Dec 06 19:47:57.942 INFO [stderr] Dec 06 19:47:57.942 INFO [stderr] warning: unused import: `Writer` Dec 06 19:47:57.942 INFO [stderr] --> src/proto/mod.rs:13:38 Dec 06 19:47:57.942 INFO [stderr] | Dec 06 19:47:57.942 INFO [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Dec 06 19:47:57.942 INFO [stderr] | ^^^^^^ Dec 06 19:47:57.942 INFO [stderr] Dec 06 19:47:57.943 INFO [stderr] warning: unused import: `self::headers::*` Dec 06 19:47:57.943 INFO [stderr] --> src/proto/mod.rs:15:5 Dec 06 19:47:57.943 INFO [stderr] | Dec 06 19:47:57.943 INFO [stderr] 15 | use self::headers::*; Dec 06 19:47:57.943 INFO [stderr] | ^^^^^^^^^^^^^^^^ Dec 06 19:47:57.943 INFO [stderr] Dec 06 19:47:57.943 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.943 INFO [stderr] --> src/tokio/mqtt_loop.rs:13:5 Dec 06 19:47:57.943 INFO [stderr] | Dec 06 19:47:57.943 INFO [stderr] 13 | use take::Take; Dec 06 19:47:57.943 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.943 INFO [stderr] Dec 06 19:47:57.943 INFO [stderr] warning: unused import: `MqttFramedWriter` Dec 06 19:47:57.943 INFO [stderr] --> src/tokio/mqtt_loop.rs:21:13 Dec 06 19:47:57.943 INFO [stderr] | Dec 06 19:47:57.943 INFO [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Dec 06 19:47:57.943 INFO [stderr] | ^^^^^^^^^^^^^^^^ Dec 06 19:47:57.943 INFO [stderr] Dec 06 19:47:57.943 INFO [stderr] warning: unused import: `super::response::ResponseProcessor` Dec 06 19:47:57.943 INFO [stderr] --> src/tokio/mqtt_loop.rs:23:5 Dec 06 19:47:57.943 INFO [stderr] | Dec 06 19:47:57.943 INFO [stderr] 23 | use super::response::ResponseProcessor; Dec 06 19:47:57.943 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.943 INFO [stderr] Dec 06 19:47:57.943 INFO [stderr] warning: unused import: `super::request::RequestProcessor` Dec 06 19:47:57.943 INFO [stderr] --> src/tokio/mqtt_loop.rs:24:5 Dec 06 19:47:57.943 INFO [stderr] | Dec 06 19:47:57.943 INFO [stderr] 24 | use super::request::RequestProcessor; Dec 06 19:47:57.943 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.943 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 4 | use take::Take; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 6 | use bincode; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused import: `PublishState` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.948 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.948 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.948 INFO [stderr] Dec 06 19:47:57.948 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:57.948 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 Dec 06 19:47:57.948 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 4 | use take::Take; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `PacketType` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `OneTimeKey` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `BoxFuture` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 7 | use take::Take; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 9 | use bincode; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] 12 | PacketId, TopicName}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Dec 06 19:47:57.949 INFO [stderr] | Dec 06 19:47:57.949 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.949 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.949 INFO [stderr] Dec 06 19:47:57.949 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.949 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 6 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 8 | use take::Take; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 10 | use bincode; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] 13 | PacketId, TopicName}; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.950 INFO [stderr] | ^^^^ ^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 9 | use take::Take; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 11 | use bincode; Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] Dec 06 19:47:57.950 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:57.950 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 Dec 06 19:47:57.950 INFO [stderr] | Dec 06 19:47:57.950 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.950 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.950 INFO [stderr] 14 | PacketId, TopicName}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 9 | use take::Take; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 11 | use bincode; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:57.951 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.951 INFO [stderr] Dec 06 19:47:57.951 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:57.951 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Dec 06 19:47:57.951 INFO [stderr] | Dec 06 19:47:57.951 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `bytes::Bytes` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 4 | use bytes::Bytes; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^ ^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 8 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 10 | use take::Take; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 12 | use bincode; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] 15 | PacketId, TopicName}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `Result` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused import: `bytes::Bytes` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 4 | use bytes::Bytes; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.952 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.952 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Dec 06 19:47:57.952 INFO [stderr] | Dec 06 19:47:57.952 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.952 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.952 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `AsyncSink` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 9 | use take::Take; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] 14 | PacketId, TopicName}; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `Result` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 1 | use std::collections::hash_map::Entry; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `std::ops::Deref` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 2 | use std::ops::Deref; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^ ^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `take::Take` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 9 | use take::Take; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused import: `bincode` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 11 | use bincode; Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Dec 06 19:47:57.953 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Dec 06 19:47:57.953 INFO [stderr] Dec 06 19:47:57.953 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Dec 06 19:47:57.953 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 Dec 06 19:47:57.953 INFO [stderr] | Dec 06 19:47:57.953 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Dec 06 19:47:57.954 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.954 INFO [stderr] Dec 06 19:47:57.954 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Dec 06 19:47:57.954 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 Dec 06 19:47:57.954 INFO [stderr] | Dec 06 19:47:57.954 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Dec 06 19:47:57.954 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Dec 06 19:47:57.954 INFO [stderr] Dec 06 19:47:58.032 INFO [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.032 INFO [stderr] --> src/types.rs:3:5 Dec 06 19:47:58.032 INFO [stderr] | Dec 06 19:47:58.032 INFO [stderr] 3 | use futures::future::BoxFuture; Dec 06 19:47:58.032 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.032 INFO [stderr] | Dec 06 19:47:58.032 INFO [stderr] = note: #[warn(deprecated)] on by default Dec 06 19:47:58.032 INFO [stderr] Dec 06 19:47:58.032 INFO [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.032 INFO [stderr] --> src/types.rs:5:5 Dec 06 19:47:58.032 INFO [stderr] | Dec 06 19:47:58.032 INFO [stderr] 5 | use futures::stream::BoxStream; Dec 06 19:47:58.032 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.033 INFO [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.033 INFO [stderr] --> src/types.rs:7:29 Dec 06 19:47:58.033 INFO [stderr] | Dec 06 19:47:58.033 INFO [stderr] 7 | pub type BoxMqttFuture = BoxFuture; Dec 06 19:47:58.033 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.033 INFO [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.033 INFO [stderr] --> src/types.rs:9:29 Dec 06 19:47:58.033 INFO [stderr] | Dec 06 19:47:58.033 INFO [stderr] 9 | pub type BoxMqttStream = BoxStream; Dec 06 19:47:58.033 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.033 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:58.033 INFO [stderr] --> src/tokio/mod.rs:12:5 Dec 06 19:47:58.033 INFO [stderr] | Dec 06 19:47:58.033 INFO [stderr] 12 | use tokio_io::codec::Framed; Dec 06 19:47:58.033 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.033 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:58.033 INFO [stderr] --> src/tokio/mod.rs:27:40 Dec 06 19:47:58.033 INFO [stderr] | Dec 06 19:47:58.033 INFO [stderr] 27 | type MqttFramedReader = SplitStream>; Dec 06 19:47:58.033 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.033 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Dec 06 19:47:58.033 INFO [stderr] --> src/tokio/mod.rs:28:38 Dec 06 19:47:58.033 INFO [stderr] | Dec 06 19:47:58.033 INFO [stderr] 28 | type MqttFramedWriter = SplitSink>; Dec 06 19:47:58.033 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:58.033 INFO [stderr] Dec 06 19:47:58.533 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:58.533 INFO [stderr] --> src/proto/types.rs:271:13 Dec 06 19:47:58.534 INFO [stderr] | Dec 06 19:47:58.534 INFO [stderr] 271 | out.put_u16::(self.len() as u16); Dec 06 19:47:58.534 INFO [stderr] | ^^^^^^^ Dec 06 19:47:58.534 INFO [stderr] Dec 06 19:47:58.680 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Dec 06 19:47:58.680 INFO [stderr] --> src/proto/headers.rs:135:40 Dec 06 19:47:58.680 INFO [stderr] | Dec 06 19:47:58.680 INFO [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) Dec 06 19:47:58.680 INFO [stderr] | ^^^^^^^ Dec 06 19:47:58.680 INFO [stderr] Dec 06 19:47:58.680 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:58.680 INFO [stderr] --> src/proto/headers.rs:140:13 Dec 06 19:47:58.680 INFO [stderr] | Dec 06 19:47:58.680 INFO [stderr] 140 | out.put_u16::(self.0); Dec 06 19:47:58.680 INFO [stderr] | ^^^^^^^ Dec 06 19:47:58.680 INFO [stderr] Dec 06 19:47:58.680 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Dec 06 19:47:58.680 INFO [stderr] --> src/proto/headers.rs:170:41 Dec 06 19:47:58.680 INFO [stderr] | Dec 06 19:47:58.680 INFO [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Dec 06 19:47:58.680 INFO [stderr] | ^^^^^^^ Dec 06 19:47:58.680 INFO [stderr] Dec 06 19:47:58.680 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Dec 06 19:47:58.680 INFO [stderr] --> src/proto/headers.rs:175:13 Dec 06 19:47:58.680 INFO [stderr] | Dec 06 19:47:58.680 INFO [stderr] 175 | out.put_u16::(self.0); Dec 06 19:47:58.680 INFO [stderr] | ^^^^^^^ Dec 06 19:47:58.680 INFO [stderr] Dec 06 19:47:58.712 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.712 INFO [stderr] --> src/client.rs:223:55 Dec 06 19:47:58.712 INFO [stderr] | Dec 06 19:47:58.712 INFO [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Dec 06 19:47:58.712 INFO [stderr] | ^^^^^ Dec 06 19:47:58.712 INFO [stderr] Dec 06 19:47:58.736 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.736 INFO [stderr] --> src/client.rs:266:63 Dec 06 19:47:58.736 INFO [stderr] | Dec 06 19:47:58.736 INFO [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() Dec 06 19:47:58.736 INFO [stderr] | ^^^^^ Dec 06 19:47:58.736 INFO [stderr] Dec 06 19:47:58.781 INFO [stderr] warning: use of deprecated item '>::send': renamed to `unbounded_send` Dec 06 19:47:58.781 INFO [stderr] --> src/tokio/mqtt_loop.rs:54:32 Dec 06 19:47:58.781 INFO [stderr] | Dec 06 19:47:58.781 INFO [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Dec 06 19:47:58.781 INFO [stderr] | ^^^^ Dec 06 19:47:58.781 INFO [stderr] Dec 06 19:47:58.792 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.792 INFO [stderr] --> src/tokio/mqtt_loop.rs:60:47 Dec 06 19:47:58.792 INFO [stderr] | Dec 06 19:47:58.792 INFO [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) Dec 06 19:47:58.792 INFO [stderr] | ^^^^^ Dec 06 19:47:58.792 INFO [stderr] Dec 06 19:47:58.796 INFO [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Dec 06 19:47:58.796 INFO [stderr] --> src/tokio/mqtt_loop.rs:266:34 Dec 06 19:47:58.800 INFO [stderr] | Dec 06 19:47:58.800 INFO [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Dec 06 19:47:58.800 INFO [stderr] | ^^^^^^ Dec 06 19:47:58.800 INFO [stderr] Dec 06 19:47:58.809 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.809 INFO [stderr] --> src/tokio/mqtt_loop.rs:317:14 Dec 06 19:47:58.809 INFO [stderr] | Dec 06 19:47:58.809 INFO [stderr] 317 | .boxed() Dec 06 19:47:58.809 INFO [stderr] | ^^^^^ Dec 06 19:47:58.809 INFO [stderr] Dec 06 19:47:58.820 INFO [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.820 INFO [stderr] --> src/tokio/mqtt_loop.rs:519:42 Dec 06 19:47:58.820 INFO [stderr] | Dec 06 19:47:58.820 INFO [stderr] 519 | .boxed(), Dec 06 19:47:58.820 INFO [stderr] | ^^^^^ Dec 06 19:47:58.820 INFO [stderr] Dec 06 19:47:58.832 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.836 INFO [stderr] --> src/tokio/response.rs:83:40 Dec 06 19:47:58.836 INFO [stderr] | Dec 06 19:47:58.836 INFO [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Dec 06 19:47:58.836 INFO [stderr] | ^^^^^ Dec 06 19:47:58.836 INFO [stderr] Dec 06 19:47:58.873 INFO [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 Dec 06 19:47:58.873 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Dec 06 19:47:58.873 INFO [stderr] | Dec 06 19:47:58.873 INFO [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Dec 06 19:47:58.873 INFO [stderr] | ^^^^^ Dec 06 19:47:58.873 INFO [stderr] Dec 06 19:47:59.049 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:59.050 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Dec 06 19:47:59.050 INFO [stderr] | Dec 06 19:47:59.050 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.050 INFO [stderr] | ^^^^ Dec 06 19:47:59.050 INFO [stderr] Dec 06 19:47:59.050 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:59.050 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Dec 06 19:47:59.050 INFO [stderr] | Dec 06 19:47:59.050 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.050 INFO [stderr] | ^^^^ Dec 06 19:47:59.050 INFO [stderr] Dec 06 19:47:59.050 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.050 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Dec 06 19:47:59.050 INFO [stderr] | Dec 06 19:47:59.050 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.051 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.051 INFO [stderr] Dec 06 19:47:59.051 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:59.051 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 Dec 06 19:47:59.051 INFO [stderr] | Dec 06 19:47:59.051 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.051 INFO [stderr] | ^^^^ Dec 06 19:47:59.051 INFO [stderr] Dec 06 19:47:59.051 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.056 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 Dec 06 19:47:59.056 INFO [stderr] | Dec 06 19:47:59.056 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.056 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.056 INFO [stderr] Dec 06 19:47:59.056 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.056 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 Dec 06 19:47:59.056 INFO [stderr] | Dec 06 19:47:59.056 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.056 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.056 INFO [stderr] Dec 06 19:47:59.056 INFO [stderr] warning: unused import: `Sink` Dec 06 19:47:59.056 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Dec 06 19:47:59.056 INFO [stderr] | Dec 06 19:47:59.056 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.056 INFO [stderr] | ^^^^ Dec 06 19:47:59.056 INFO [stderr] Dec 06 19:47:59.056 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.056 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Dec 06 19:47:59.056 INFO [stderr] | Dec 06 19:47:59.056 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.056 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.056 INFO [stderr] Dec 06 19:47:59.057 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.057 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Dec 06 19:47:59.057 INFO [stderr] | Dec 06 19:47:59.057 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.057 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.057 INFO [stderr] Dec 06 19:47:59.057 INFO [stderr] warning: unused import: `Stream` Dec 06 19:47:59.057 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 Dec 06 19:47:59.057 INFO [stderr] | Dec 06 19:47:59.057 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Dec 06 19:47:59.057 INFO [stderr] | ^^^^^^ Dec 06 19:47:59.057 INFO [stderr] Dec 06 19:47:59.412 INFO [stderr] warning: variable does not need to be mutable Dec 06 19:47:59.412 INFO [stderr] --> src/tokio/mqtt_loop.rs:320:31 Dec 06 19:47:59.412 INFO [stderr] | Dec 06 19:47:59.412 INFO [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Dec 06 19:47:59.412 INFO [stderr] | ----^^^ Dec 06 19:47:59.412 INFO [stderr] | | Dec 06 19:47:59.412 INFO [stderr] | help: remove this `mut` Dec 06 19:47:59.412 INFO [stderr] | Dec 06 19:47:59.412 INFO [stderr] = note: #[warn(unused_mut)] on by default Dec 06 19:47:59.412 INFO [stderr] Dec 06 19:47:59.664 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:59.664 INFO [stderr] --> src/tokio/mqtt_loop.rs:571:17 Dec 06 19:47:59.664 INFO [stderr] | Dec 06 19:47:59.664 INFO [stderr] 571 | self.poll_queues(sourceitem); Dec 06 19:47:59.664 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:59.664 INFO [stderr] | Dec 06 19:47:59.664 INFO [stderr] = note: #[warn(unused_must_use)] on by default Dec 06 19:47:59.664 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:59.664 INFO [stderr] Dec 06 19:47:59.672 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:59.672 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 Dec 06 19:47:59.672 INFO [stderr] | Dec 06 19:47:59.672 INFO [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( Dec 06 19:47:59.672 INFO [stderr] 105 | | MqttPacket::pub_ack_packet(*id), Dec 06 19:47:59.672 INFO [stderr] 106 | | )); Dec 06 19:47:59.672 INFO [stderr] | |___________________________^ Dec 06 19:47:59.672 INFO [stderr] | Dec 06 19:47:59.672 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:59.672 INFO [stderr] Dec 06 19:47:59.672 INFO [stderr] warning: unused `std::result::Result` that must be used Dec 06 19:47:59.672 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 Dec 06 19:47:59.672 INFO [stderr] | Dec 06 19:47:59.672 INFO [stderr] 128 | / requester.unbounded_send( Dec 06 19:47:59.672 INFO [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Dec 06 19:47:59.672 INFO [stderr] 130 | | ); Dec 06 19:47:59.672 INFO [stderr] | |______________________________^ Dec 06 19:47:59.672 INFO [stderr] | Dec 06 19:47:59.672 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Dec 06 19:47:59.673 INFO [stderr] Dec 06 19:47:59.673 INFO [stderr] warning: unused `futures::sink::Send` that must be used Dec 06 19:47:59.673 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Dec 06 19:47:59.673 INFO [stderr] | Dec 06 19:47:59.673 INFO [stderr] 100 | requester.send(LoopRequest::Internal(rel)); Dec 06 19:47:59.673 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:47:59.673 INFO [stderr] | Dec 06 19:47:59.673 INFO [stderr] = note: futures do nothing unless polled Dec 06 19:47:59.673 INFO [stderr] Dec 06 19:48:00.796 INFO [stderr] warning: unused `#[macro_use]` import Dec 06 19:48:00.796 INFO [stderr] --> examples/client.rs:1:1 Dec 06 19:48:00.796 INFO [stderr] | Dec 06 19:48:00.796 INFO [stderr] 1 | #[macro_use] Dec 06 19:48:00.796 INFO [stderr] | ^^^^^^^^^^^^ Dec 06 19:48:00.796 INFO [stderr] | Dec 06 19:48:00.796 INFO [stderr] = note: #[warn(unused_imports)] on by default Dec 06 19:48:00.796 INFO [stderr] Dec 06 19:48:00.796 INFO [stderr] warning: unused import: `tokio_mqttc::persistence::*` Dec 06 19:48:00.796 INFO [stderr] --> examples/client.rs:11:5 Dec 06 19:48:00.796 INFO [stderr] | Dec 06 19:48:00.796 INFO [stderr] 11 | use tokio_mqttc::persistence::*; Dec 06 19:48:00.796 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:48:00.796 INFO [stderr] Dec 06 19:48:00.796 INFO [stderr] warning: unused import: `tokio_mqttc::proto::*` Dec 06 19:48:00.796 INFO [stderr] --> examples/client.rs:13:5 Dec 06 19:48:00.796 INFO [stderr] | Dec 06 19:48:00.796 INFO [stderr] 13 | use tokio_mqttc::proto::*; Dec 06 19:48:00.796 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:48:00.796 INFO [stderr] Dec 06 19:48:00.805 INFO [stderr] warning: unused import: `tokio_core::reactor::Handle` Dec 06 19:48:00.805 INFO [stderr] --> examples/client.rs:41:5 Dec 06 19:48:00.805 INFO [stderr] | Dec 06 19:48:00.805 INFO [stderr] 41 | use tokio_core::reactor::Handle; Dec 06 19:48:00.805 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Dec 06 19:48:00.805 INFO [stderr] Dec 06 19:48:00.805 INFO [stderr] warning: unused imports: `Sink`, `future` Dec 06 19:48:00.805 INFO [stderr] --> examples/client.rs:45:15 Dec 06 19:48:00.805 INFO [stderr] | Dec 06 19:48:00.805 INFO [stderr] 45 | use futures::{future, Future, Stream, Sink}; Dec 06 19:48:00.805 INFO [stderr] | ^^^^^^ ^^^^ Dec 06 19:48:00.805 INFO [stderr] Dec 06 19:48:01.057 INFO [stderr] warning: unused import: `Stream` Dec 06 19:48:01.057 INFO [stderr] --> examples/client.rs:45:31 Dec 06 19:48:01.057 INFO [stderr] | Dec 06 19:48:01.057 INFO [stderr] 45 | use futures::{future, Future, Stream, Sink}; Dec 06 19:48:01.057 INFO [stderr] | ^^^^^^ Dec 06 19:48:01.057 INFO [stderr] Dec 06 19:48:05.572 INFO [stderr] Finished dev [unoptimized + debuginfo] target(s) in 13.52s Dec 06 19:48:05.576 INFO [stderr] su: No module specific data is present Dec 06 19:48:06.338 INFO running `"docker" "inspect" "5e344e3c49ac2ddbf07c552e3a35aa9ae287a8f5ae2df0879e029219568dff64"` Dec 06 19:48:06.566 INFO running `"docker" "rm" "-f" "5e344e3c49ac2ddbf07c552e3a35aa9ae287a8f5ae2df0879e029219568dff64"` Dec 06 19:48:06.892 INFO [stdout] 5e344e3c49ac2ddbf07c552e3a35aa9ae287a8f5ae2df0879e029219568dff64 Dec 06 19:48:06.896 INFO running `"docker" "create" "-v" "/mnt/big/crater/work/local/target-dirs/pr-56514/worker-2/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/target:rw,Z" "-v" "/mnt/big/crater/work/local/test-source/worker-2/pr-56514/try#6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468:/source:ro,Z" "-v" "/mnt/big/crater/work/local/cargo-home:/cargo-home:ro,Z" "-v" "/mnt/big/crater/work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "SOURCE_DIR=/source" "-e" "USER_ID=1000" "-e" "CMD=cargo +6eb0fd3ac58f9b16bddb9924a17c3b6c156aa468-alt test --frozen" "-e" "CARGO_TARGET_DIR=/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/cargo-home" "-e" "RUSTUP_HOME=/rustup-home" "-m" "1536M" "--network" "none" "crater"` Dec 06 19:48:07.334 INFO [stdout] 7f15dbb99fe9c0c7de7fdf2b5b34e49038b103196d702414550f50e259942906 Dec 06 19:48:07.342 INFO running `"docker" "start" "-a" "7f15dbb99fe9c0c7de7fdf2b5b34e49038b103196d702414550f50e259942906"` Dec 06 19:48:08.565 INFO [stderr] usermod: no changes Dec 06 19:48:08.860 INFO [stderr] Finished dev [unoptimized + debuginfo] target(s) in 0.25s Dec 06 19:48:08.876 INFO [stderr] Running /target/debug/deps/tokio_mqttc-31265aa14ad02996 Dec 06 19:48:08.876 INFO [stdout] Dec 06 19:48:08.876 INFO [stdout] running 10 tests Dec 06 19:48:08.876 INFO [stdout] test proto::parsers::vle_tests::four_byte_vle ... ok Dec 06 19:48:08.876 INFO [stdout] test proto::parsers::vle_tests::incomplete_vle ... ok Dec 06 19:48:08.876 INFO [stdout] test proto::parsers::vle_tests::two_byte_vle ... ok Dec 06 19:48:08.876 INFO [stdout] test proto::parsers::vle_tests::overflow_vle ... ok Dec 06 19:48:08.876 INFO [stdout] test tests::it_works ... ok Dec 06 19:48:08.879 INFO [stdout] test tokio::tests::complex_single_level_filter ... ok Dec 06 19:48:08.879 INFO [stdout] test proto::parsers::vle_tests::one_byte_vle ... ok Dec 06 19:48:08.879 INFO [stdout] test proto::parsers::vle_tests::three_byte_vle ... ok Dec 06 19:48:08.880 INFO [stdout] test tokio::tests::simple_filter ... ok Dec 06 19:48:08.881 INFO [stdout] test tokio::tests::single_level_filter ... ok Dec 06 19:48:08.881 INFO [stdout] Dec 06 19:48:08.881 INFO [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out Dec 06 19:48:08.881 INFO [stdout] Dec 06 19:48:08.883 INFO [stderr] Doc-tests tokio-mqttc Dec 06 19:48:17.746 INFO [stdout] Dec 06 19:48:17.746 INFO [stdout] running 0 tests Dec 06 19:48:17.746 INFO [stdout] Dec 06 19:48:17.746 INFO [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out Dec 06 19:48:17.746 INFO [stdout] Dec 06 19:48:17.762 INFO [stderr] su: No module specific data is present Dec 06 19:48:18.948 INFO running `"docker" "inspect" "7f15dbb99fe9c0c7de7fdf2b5b34e49038b103196d702414550f50e259942906"` Dec 06 19:48:19.195 INFO running `"docker" "rm" "-f" "7f15dbb99fe9c0c7de7fdf2b5b34e49038b103196d702414550f50e259942906"` Dec 06 19:48:19.516 INFO [stdout] 7f15dbb99fe9c0c7de7fdf2b5b34e49038b103196d702414550f50e259942906