Oct 15 16:11:44.629 INFO testing tokio-mqttc-0.0.2 against master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513 for rustdoc-test-static-cling-1 Oct 15 16:11:44.629 INFO running `"docker" "create" "-v" "/mnt/big/crater/./work/local/target-dirs/rustdoc-test-static-cling-1/worker-7/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/target:rw,Z" "-v" "/mnt/big/crater/./work/local/test-source/worker-7/rustdoc-test-static-cling-1/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/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 +0e07c4281c343e9e15a0a8fca79538ad1a8eb513-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"` Oct 15 16:11:44.843 INFO blam! 060ee43fb0907bd47f0d8a2ffd3b000c2c490e917b2ccff534e72aec295ec367 Oct 15 16:11:44.843 INFO running `"docker" "start" "-a" "060ee43fb0907bd47f0d8a2ffd3b000c2c490e917b2ccff534e72aec295ec367"` Oct 15 16:11:45.594 INFO kablam! usermod: no changes Oct 15 16:11:45.792 INFO kablam! Compiling nom v2.2.1 Oct 15 16:11:45.797 INFO kablam! Compiling futures-mutex v0.1.2 Oct 15 16:11:45.798 INFO kablam! Compiling touch v0.0.1 Oct 15 16:11:45.800 INFO kablam! Compiling serde_test v1.0.80 Oct 15 16:11:45.800 INFO kablam! Compiling bincode v0.9.2 Oct 15 16:11:45.802 INFO kablam! Compiling tokio-core v0.1.17 Oct 15 16:11:49.478 INFO kablam! Compiling linked-hash-map v0.5.1 Oct 15 16:11:50.846 INFO kablam! Compiling tokio-tls v0.1.4 Oct 15 16:11:52.949 INFO kablam! Compiling tokio-mqttc v0.0.2 (/source) Oct 15 16:11:56.123 INFO kablam! warning: unused import: `Error` Oct 15 16:11:56.123 INFO kablam! --> src/proto/types.rs:4:14 Oct 15 16:11:56.123 INFO kablam! | Oct 15 16:11:56.123 INFO kablam! 4 | use errors::{Error, ErrorKind}; Oct 15 16:11:56.123 INFO kablam! | ^^^^^ Oct 15 16:11:56.123 INFO kablam! | Oct 15 16:11:56.123 INFO kablam! = note: #[warn(unused_imports)] on by default Oct 15 16:11:56.123 INFO kablam! Oct 15 16:11:56.123 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Oct 15 16:11:56.123 INFO kablam! --> src/proto/types.rs:5:5 Oct 15 16:11:56.123 INFO kablam! | Oct 15 16:11:56.123 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Oct 15 16:11:56.123 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.123 INFO kablam! Oct 15 16:11:56.131 INFO kablam! warning: unused imports: `IResult`, `be_u16` Oct 15 16:11:56.131 INFO kablam! --> src/proto/headers.rs:3:11 Oct 15 16:11:56.131 INFO kablam! | Oct 15 16:11:56.131 INFO kablam! 3 | use nom::{IResult, be_u16}; Oct 15 16:11:56.131 INFO kablam! | ^^^^^^^ ^^^^^^ Oct 15 16:11:56.131 INFO kablam! Oct 15 16:11:56.131 INFO kablam! warning: unused import: `std::io` Oct 15 16:11:56.131 INFO kablam! --> src/proto/mod.rs:8:5 Oct 15 16:11:56.131 INFO kablam! | Oct 15 16:11:56.131 INFO kablam! 8 | use std::io; Oct 15 16:11:56.132 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.132 INFO kablam! Oct 15 16:11:56.132 INFO kablam! warning: unused import: `Entry` Oct 15 16:11:56.132 INFO kablam! --> src/proto/mod.rs:12:23 Oct 15 16:11:56.132 INFO kablam! | Oct 15 16:11:56.132 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Oct 15 16:11:56.132 INFO kablam! | ^^^^^ Oct 15 16:11:56.132 INFO kablam! Oct 15 16:11:56.132 INFO kablam! warning: unused import: `Writer` Oct 15 16:11:56.132 INFO kablam! --> src/proto/mod.rs:13:38 Oct 15 16:11:56.132 INFO kablam! | Oct 15 16:11:56.132 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Oct 15 16:11:56.132 INFO kablam! | ^^^^^^ Oct 15 16:11:56.132 INFO kablam! Oct 15 16:11:56.132 INFO kablam! warning: unused import: `self::headers::*` Oct 15 16:11:56.132 INFO kablam! --> src/proto/mod.rs:15:5 Oct 15 16:11:56.132 INFO kablam! | Oct 15 16:11:56.132 INFO kablam! 15 | use self::headers::*; Oct 15 16:11:56.132 INFO kablam! | ^^^^^^^^^^^^^^^^ Oct 15 16:11:56.132 INFO kablam! Oct 15 16:11:56.132 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.132 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Oct 15 16:11:56.133 INFO kablam! | Oct 15 16:11:56.133 INFO kablam! 13 | use take::Take; Oct 15 16:11:56.133 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.133 INFO kablam! Oct 15 16:11:56.133 INFO kablam! warning: unused import: `MqttFramedWriter` Oct 15 16:11:56.133 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Oct 15 16:11:56.133 INFO kablam! | Oct 15 16:11:56.133 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Oct 15 16:11:56.133 INFO kablam! | ^^^^^^^^^^^^^^^^ Oct 15 16:11:56.133 INFO kablam! Oct 15 16:11:56.133 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Oct 15 16:11:56.133 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Oct 15 16:11:56.133 INFO kablam! | Oct 15 16:11:56.133 INFO kablam! 23 | use super::response::ResponseProcessor; Oct 15 16:11:56.133 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.133 INFO kablam! Oct 15 16:11:56.133 INFO kablam! warning: unused import: `super::request::RequestProcessor` Oct 15 16:11:56.133 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Oct 15 16:11:56.133 INFO kablam! | Oct 15 16:11:56.133 INFO kablam! 24 | use super::request::RequestProcessor; Oct 15 16:11:56.133 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.133 INFO kablam! Oct 15 16:11:56.134 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.134 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Oct 15 16:11:56.134 INFO kablam! | Oct 15 16:11:56.134 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.134 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 4 | use take::Take; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 6 | use bincode; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `PublishState` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 4 | use take::Take; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `PacketType` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `OneTimeKey` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `BoxFuture` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.141 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Oct 15 16:11:56.141 INFO kablam! | Oct 15 16:11:56.141 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.141 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.141 INFO kablam! Oct 15 16:11:56.141 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 7 | use take::Take; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 9 | use bincode; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! 12 | PacketId, TopicName}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused imports: `ResultExt`, `Result` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.142 INFO kablam! 8 | use take::Take; Oct 15 16:11:56.142 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.142 INFO kablam! Oct 15 16:11:56.142 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.142 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Oct 15 16:11:56.142 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 10 | use bincode; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! 13 | PacketId, TopicName}; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `ResultExt`, `Result` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.143 INFO kablam! | ^^^^ ^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 9 | use take::Take; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 11 | use bincode; Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.143 INFO kablam! Oct 15 16:11:56.143 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:11:56.143 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Oct 15 16:11:56.143 INFO kablam! | Oct 15 16:11:56.143 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.143 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.143 INFO kablam! 14 | PacketId, TopicName}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 9 | use take::Take; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 11 | use bincode; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.144 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.144 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:11:56.144 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.144 INFO kablam! Oct 15 16:11:56.144 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:11:56.144 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Oct 15 16:11:56.144 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `bytes::Bytes` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 4 | use bytes::Bytes; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.145 INFO kablam! | ^^^^ ^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 10 | use take::Take; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 12 | use bincode; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! 15 | PacketId, TopicName}; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `Result` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.145 INFO kablam! Oct 15 16:11:56.145 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:11:56.145 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Oct 15 16:11:56.145 INFO kablam! | Oct 15 16:11:56.145 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:11:56.145 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `bytes::Bytes` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 4 | use bytes::Bytes; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 9 | use take::Take; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! 14 | PacketId, TopicName}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `Result` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:11:56.146 INFO kablam! Oct 15 16:11:56.146 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:11:56.146 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Oct 15 16:11:56.146 INFO kablam! | Oct 15 16:11:56.146 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:11:56.146 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.147 INFO kablam! warning: unused import: `take::Take` Oct 15 16:11:56.147 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Oct 15 16:11:56.147 INFO kablam! | Oct 15 16:11:56.147 INFO kablam! 9 | use take::Take; Oct 15 16:11:56.147 INFO kablam! | ^^^^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.147 INFO kablam! warning: unused import: `bincode` Oct 15 16:11:56.147 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Oct 15 16:11:56.147 INFO kablam! | Oct 15 16:11:56.147 INFO kablam! 11 | use bincode; Oct 15 16:11:56.147 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.147 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Oct 15 16:11:56.147 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Oct 15 16:11:56.147 INFO kablam! | Oct 15 16:11:56.147 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:11:56.147 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.147 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:11:56.147 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Oct 15 16:11:56.147 INFO kablam! | Oct 15 16:11:56.147 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:11:56.147 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.147 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:11:56.147 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Oct 15 16:11:56.147 INFO kablam! | Oct 15 16:11:56.147 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:11:56.147 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:11:56.147 INFO kablam! Oct 15 16:11:56.219 INFO kablam! 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 Oct 15 16:11:56.219 INFO kablam! --> src/types.rs:3:5 Oct 15 16:11:56.219 INFO kablam! | Oct 15 16:11:56.219 INFO kablam! 3 | use futures::future::BoxFuture; Oct 15 16:11:56.219 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.219 INFO kablam! | Oct 15 16:11:56.219 INFO kablam! = note: #[warn(deprecated)] on by default Oct 15 16:11:56.219 INFO kablam! Oct 15 16:11:56.219 INFO kablam! 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 Oct 15 16:11:56.219 INFO kablam! --> src/types.rs:5:5 Oct 15 16:11:56.219 INFO kablam! | Oct 15 16:11:56.219 INFO kablam! 5 | use futures::stream::BoxStream; Oct 15 16:11:56.219 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.219 INFO kablam! Oct 15 16:11:56.219 INFO kablam! 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 Oct 15 16:11:56.219 INFO kablam! --> src/types.rs:7:29 Oct 15 16:11:56.219 INFO kablam! | Oct 15 16:11:56.219 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Oct 15 16:11:56.219 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.219 INFO kablam! Oct 15 16:11:56.219 INFO kablam! 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 Oct 15 16:11:56.219 INFO kablam! --> src/types.rs:9:29 Oct 15 16:11:56.219 INFO kablam! | Oct 15 16:11:56.219 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Oct 15 16:11:56.219 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.219 INFO kablam! Oct 15 16:11:56.224 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:11:56.224 INFO kablam! --> src/tokio/mod.rs:12:5 Oct 15 16:11:56.224 INFO kablam! | Oct 15 16:11:56.224 INFO kablam! 12 | use tokio_io::codec::Framed; Oct 15 16:11:56.224 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.224 INFO kablam! Oct 15 16:11:56.224 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:11:56.224 INFO kablam! --> src/tokio/mod.rs:27:40 Oct 15 16:11:56.224 INFO kablam! | Oct 15 16:11:56.224 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Oct 15 16:11:56.224 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.224 INFO kablam! Oct 15 16:11:56.224 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:11:56.224 INFO kablam! --> src/tokio/mod.rs:28:38 Oct 15 16:11:56.224 INFO kablam! | Oct 15 16:11:56.224 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Oct 15 16:11:56.224 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:56.224 INFO kablam! Oct 15 16:11:56.708 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:11:56.708 INFO kablam! --> src/proto/types.rs:271:13 Oct 15 16:11:56.708 INFO kablam! | Oct 15 16:11:56.708 INFO kablam! 271 | out.put_u16::(self.len() as u16); Oct 15 16:11:56.708 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.708 INFO kablam! Oct 15 16:11:56.829 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Oct 15 16:11:56.829 INFO kablam! --> src/proto/headers.rs:135:40 Oct 15 16:11:56.829 INFO kablam! | Oct 15 16:11:56.829 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Oct 15 16:11:56.829 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.829 INFO kablam! Oct 15 16:11:56.829 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:11:56.829 INFO kablam! --> src/proto/headers.rs:140:13 Oct 15 16:11:56.829 INFO kablam! | Oct 15 16:11:56.829 INFO kablam! 140 | out.put_u16::(self.0); Oct 15 16:11:56.829 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.829 INFO kablam! Oct 15 16:11:56.830 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Oct 15 16:11:56.830 INFO kablam! --> src/proto/headers.rs:170:41 Oct 15 16:11:56.830 INFO kablam! | Oct 15 16:11:56.830 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Oct 15 16:11:56.830 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.830 INFO kablam! Oct 15 16:11:56.831 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:11:56.831 INFO kablam! --> src/proto/headers.rs:175:13 Oct 15 16:11:56.831 INFO kablam! | Oct 15 16:11:56.831 INFO kablam! 175 | out.put_u16::(self.0); Oct 15 16:11:56.831 INFO kablam! | ^^^^^^^ Oct 15 16:11:56.831 INFO kablam! Oct 15 16:11:56.847 INFO kablam! 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 Oct 15 16:11:56.847 INFO kablam! --> src/client.rs:223:55 Oct 15 16:11:56.847 INFO kablam! | Oct 15 16:11:56.847 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Oct 15 16:11:56.847 INFO kablam! | ^^^^^ Oct 15 16:11:56.847 INFO kablam! Oct 15 16:11:56.854 INFO kablam! 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 Oct 15 16:11:56.854 INFO kablam! --> src/client.rs:266:63 Oct 15 16:11:56.854 INFO kablam! | Oct 15 16:11:56.854 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Oct 15 16:11:56.854 INFO kablam! | ^^^^^ Oct 15 16:11:56.854 INFO kablam! Oct 15 16:11:56.899 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Oct 15 16:11:56.899 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Oct 15 16:11:56.899 INFO kablam! | Oct 15 16:11:56.899 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Oct 15 16:11:56.899 INFO kablam! | ^^^^ Oct 15 16:11:56.899 INFO kablam! Oct 15 16:11:56.899 INFO kablam! 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 Oct 15 16:11:56.899 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Oct 15 16:11:56.899 INFO kablam! | Oct 15 16:11:56.899 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Oct 15 16:11:56.899 INFO kablam! | ^^^^^ Oct 15 16:11:56.899 INFO kablam! Oct 15 16:11:56.906 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Oct 15 16:11:56.906 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Oct 15 16:11:56.906 INFO kablam! | Oct 15 16:11:56.906 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Oct 15 16:11:56.906 INFO kablam! | ^^^^^^ Oct 15 16:11:56.906 INFO kablam! Oct 15 16:11:56.920 INFO kablam! 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 Oct 15 16:11:56.920 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Oct 15 16:11:56.920 INFO kablam! | Oct 15 16:11:56.920 INFO kablam! 317 | .boxed() Oct 15 16:11:56.920 INFO kablam! | ^^^^^ Oct 15 16:11:56.920 INFO kablam! Oct 15 16:11:56.933 INFO kablam! 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 Oct 15 16:11:56.933 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Oct 15 16:11:56.933 INFO kablam! | Oct 15 16:11:56.933 INFO kablam! 519 | .boxed(), Oct 15 16:11:56.933 INFO kablam! | ^^^^^ Oct 15 16:11:56.933 INFO kablam! Oct 15 16:11:56.945 INFO kablam! 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 Oct 15 16:11:56.945 INFO kablam! --> src/tokio/response.rs:83:40 Oct 15 16:11:56.945 INFO kablam! | Oct 15 16:11:56.945 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Oct 15 16:11:56.945 INFO kablam! | ^^^^^ Oct 15 16:11:56.945 INFO kablam! Oct 15 16:11:56.989 INFO kablam! 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 Oct 15 16:11:56.989 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Oct 15 16:11:56.989 INFO kablam! | Oct 15 16:11:56.989 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Oct 15 16:11:56.989 INFO kablam! | ^^^^^ Oct 15 16:11:56.989 INFO kablam! Oct 15 16:11:57.173 INFO kablam! warning: unused import: `Sink` Oct 15 16:11:57.173 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Oct 15 16:11:57.173 INFO kablam! | Oct 15 16:11:57.173 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.173 INFO kablam! | ^^^^ Oct 15 16:11:57.173 INFO kablam! Oct 15 16:11:57.173 INFO kablam! warning: unused import: `Sink` Oct 15 16:11:57.173 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Oct 15 16:11:57.173 INFO kablam! | Oct 15 16:11:57.173 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.173 INFO kablam! | ^^^^ Oct 15 16:11:57.173 INFO kablam! Oct 15 16:11:57.173 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.173 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Oct 15 16:11:57.173 INFO kablam! | Oct 15 16:11:57.174 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.174 INFO kablam! | ^^^^^^ Oct 15 16:11:57.174 INFO kablam! Oct 15 16:11:57.174 INFO kablam! warning: unused import: `Sink` Oct 15 16:11:57.174 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Oct 15 16:11:57.174 INFO kablam! | Oct 15 16:11:57.174 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.174 INFO kablam! | ^^^^ Oct 15 16:11:57.174 INFO kablam! Oct 15 16:11:57.174 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.174 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Oct 15 16:11:57.174 INFO kablam! | Oct 15 16:11:57.174 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.174 INFO kablam! | ^^^^^^ Oct 15 16:11:57.174 INFO kablam! Oct 15 16:11:57.174 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.174 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Oct 15 16:11:57.174 INFO kablam! | Oct 15 16:11:57.174 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.174 INFO kablam! | ^^^^^^ Oct 15 16:11:57.174 INFO kablam! Oct 15 16:11:57.174 INFO kablam! warning: unused import: `Sink` Oct 15 16:11:57.175 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Oct 15 16:11:57.175 INFO kablam! | Oct 15 16:11:57.175 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.175 INFO kablam! | ^^^^ Oct 15 16:11:57.175 INFO kablam! Oct 15 16:11:57.175 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.175 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Oct 15 16:11:57.175 INFO kablam! | Oct 15 16:11:57.175 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.175 INFO kablam! | ^^^^^^ Oct 15 16:11:57.175 INFO kablam! Oct 15 16:11:57.175 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.175 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Oct 15 16:11:57.175 INFO kablam! | Oct 15 16:11:57.175 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.175 INFO kablam! | ^^^^^^ Oct 15 16:11:57.175 INFO kablam! Oct 15 16:11:57.175 INFO kablam! warning: unused import: `Stream` Oct 15 16:11:57.175 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Oct 15 16:11:57.175 INFO kablam! | Oct 15 16:11:57.175 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:11:57.175 INFO kablam! | ^^^^^^ Oct 15 16:11:57.175 INFO kablam! Oct 15 16:11:57.514 INFO kablam! warning: variable does not need to be mutable Oct 15 16:11:57.514 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Oct 15 16:11:57.514 INFO kablam! | Oct 15 16:11:57.514 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Oct 15 16:11:57.514 INFO kablam! | ----^^^ Oct 15 16:11:57.514 INFO kablam! | | Oct 15 16:11:57.514 INFO kablam! | help: remove this `mut` Oct 15 16:11:57.514 INFO kablam! | Oct 15 16:11:57.514 INFO kablam! = note: #[warn(unused_mut)] on by default Oct 15 16:11:57.514 INFO kablam! Oct 15 16:11:57.761 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:11:57.761 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Oct 15 16:11:57.761 INFO kablam! | Oct 15 16:11:57.761 INFO kablam! 571 | self.poll_queues(sourceitem); Oct 15 16:11:57.761 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:57.761 INFO kablam! | Oct 15 16:11:57.761 INFO kablam! = note: #[warn(unused_must_use)] on by default Oct 15 16:11:57.761 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:11:57.761 INFO kablam! Oct 15 16:11:57.770 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:11:57.770 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Oct 15 16:11:57.770 INFO kablam! | Oct 15 16:11:57.770 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Oct 15 16:11:57.770 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Oct 15 16:11:57.770 INFO kablam! 106 | | )); Oct 15 16:11:57.770 INFO kablam! | |___________________________^ Oct 15 16:11:57.770 INFO kablam! | Oct 15 16:11:57.770 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:11:57.770 INFO kablam! Oct 15 16:11:57.771 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:11:57.771 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Oct 15 16:11:57.771 INFO kablam! | Oct 15 16:11:57.771 INFO kablam! 128 | / requester.unbounded_send( Oct 15 16:11:57.771 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Oct 15 16:11:57.771 INFO kablam! 130 | | ); Oct 15 16:11:57.771 INFO kablam! | |______________________________^ Oct 15 16:11:57.771 INFO kablam! | Oct 15 16:11:57.771 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:11:57.771 INFO kablam! Oct 15 16:11:57.773 INFO kablam! warning: unused `futures::sink::Send` which must be used Oct 15 16:11:57.773 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Oct 15 16:11:57.773 INFO kablam! | Oct 15 16:11:57.773 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Oct 15 16:11:57.773 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:11:57.773 INFO kablam! | Oct 15 16:11:57.773 INFO kablam! = note: futures do nothing unless polled Oct 15 16:11:57.773 INFO kablam! Oct 15 16:11:59.787 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 14.17s Oct 15 16:11:59.796 INFO kablam! su: No module specific data is present Oct 15 16:12:00.111 INFO running `"docker" "rm" "-f" "060ee43fb0907bd47f0d8a2ffd3b000c2c490e917b2ccff534e72aec295ec367"` Oct 15 16:12:00.244 INFO blam! 060ee43fb0907bd47f0d8a2ffd3b000c2c490e917b2ccff534e72aec295ec367 Oct 15 16:12:00.248 INFO running `"docker" "create" "-v" "/mnt/big/crater/./work/local/target-dirs/rustdoc-test-static-cling-1/worker-7/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/target:rw,Z" "-v" "/mnt/big/crater/./work/local/test-source/worker-7/rustdoc-test-static-cling-1/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/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 +0e07c4281c343e9e15a0a8fca79538ad1a8eb513-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"` Oct 15 16:12:00.480 INFO blam! 4aee7c3d720734e6de25baec1e3e3522a47250bbdec98e8cb288477d729b84ab Oct 15 16:12:00.488 INFO running `"docker" "start" "-a" "4aee7c3d720734e6de25baec1e3e3522a47250bbdec98e8cb288477d729b84ab"` Oct 15 16:12:00.943 INFO kablam! usermod: no changes Oct 15 16:12:01.138 INFO kablam! Compiling nom-test-helpers v2.0.0 Oct 15 16:12:01.587 INFO kablam! Compiling tokio-mqttc v0.0.2 (/source) Oct 15 16:12:05.959 INFO kablam! warning: unused import: `Error` Oct 15 16:12:05.959 INFO kablam! --> src/proto/types.rs:4:14 Oct 15 16:12:05.959 INFO kablam! | Oct 15 16:12:05.959 INFO kablam! 4 | use errors::{Error, ErrorKind}; Oct 15 16:12:05.959 INFO kablam! | ^^^^^ Oct 15 16:12:05.959 INFO kablam! | Oct 15 16:12:05.959 INFO kablam! = note: #[warn(unused_imports)] on by default Oct 15 16:12:05.959 INFO kablam! Oct 15 16:12:05.959 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Oct 15 16:12:05.959 INFO kablam! --> src/proto/types.rs:5:5 Oct 15 16:12:05.959 INFO kablam! | Oct 15 16:12:05.959 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Oct 15 16:12:05.959 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.959 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused imports: `IResult`, `be_u16` Oct 15 16:12:05.967 INFO kablam! --> src/proto/headers.rs:3:11 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 3 | use nom::{IResult, be_u16}; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^ ^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `std::io` Oct 15 16:12:05.967 INFO kablam! --> src/proto/mod.rs:8:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 8 | use std::io; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `Entry` Oct 15 16:12:05.967 INFO kablam! --> src/proto/mod.rs:12:23 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Oct 15 16:12:05.967 INFO kablam! | ^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `Writer` Oct 15 16:12:05.967 INFO kablam! --> src/proto/mod.rs:13:38 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `self::headers::*` Oct 15 16:12:05.967 INFO kablam! --> src/proto/mod.rs:15:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 15 | use self::headers::*; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 13 | use take::Take; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `MqttFramedWriter` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 23 | use super::response::ResponseProcessor; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `super::request::RequestProcessor` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 24 | use super::request::RequestProcessor; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 4 | use take::Take; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.967 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.967 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Oct 15 16:12:05.967 INFO kablam! | Oct 15 16:12:05.967 INFO kablam! 6 | use bincode; Oct 15 16:12:05.967 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.967 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `PublishState` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 4 | use take::Take; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `PacketType` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `OneTimeKey` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `BoxFuture` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 7 | use take::Take; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.968 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.968 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Oct 15 16:12:05.968 INFO kablam! | Oct 15 16:12:05.968 INFO kablam! 9 | use bincode; Oct 15 16:12:05.968 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.968 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! 12 | PacketId, TopicName}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `ResultExt`, `Result` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 8 | use take::Take; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 10 | use bincode; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! 13 | PacketId, TopicName}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `ResultExt`, `Result` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Oct 15 16:12:05.969 INFO kablam! | Oct 15 16:12:05.969 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:12:05.969 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:12:05.969 INFO kablam! Oct 15 16:12:05.969 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.969 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.970 INFO kablam! | ^^^^ ^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 9 | use take::Take; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 11 | use bincode; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! 14 | PacketId, TopicName}; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.970 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:12:05.970 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:12:05.970 INFO kablam! Oct 15 16:12:05.970 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.970 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Oct 15 16:12:05.970 INFO kablam! | Oct 15 16:12:05.978 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.979 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 9 | use take::Take; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 11 | use bincode; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `bytes::Bytes` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 4 | use bytes::Bytes; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.983 INFO kablam! | ^^^^ ^^^^^^^^^ Oct 15 16:12:05.983 INFO kablam! Oct 15 16:12:05.983 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.983 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Oct 15 16:12:05.983 INFO kablam! | Oct 15 16:12:05.983 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.983 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 10 | use take::Take; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 12 | use bincode; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! 15 | PacketId, TopicName}; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `Result` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `bytes::Bytes` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 4 | use bytes::Bytes; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `AsyncSink` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 9 | use take::Take; Oct 15 16:12:05.984 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.984 INFO kablam! Oct 15 16:12:05.984 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Oct 15 16:12:05.984 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Oct 15 16:12:05.984 INFO kablam! | Oct 15 16:12:05.984 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! 14 | PacketId, TopicName}; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `Result` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 1 | use std::collections::hash_map::Entry; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `std::ops::Deref` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 2 | use std::ops::Deref; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^ ^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `take::Take` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 9 | use take::Take; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused import: `bincode` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 11 | use bincode; Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.985 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Oct 15 16:12:05.985 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Oct 15 16:12:05.985 INFO kablam! Oct 15 16:12:05.985 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Oct 15 16:12:05.985 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Oct 15 16:12:05.985 INFO kablam! | Oct 15 16:12:05.986 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Oct 15 16:12:05.986 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.986 INFO kablam! Oct 15 16:12:05.986 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Oct 15 16:12:05.986 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Oct 15 16:12:05.986 INFO kablam! | Oct 15 16:12:05.986 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Oct 15 16:12:05.986 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Oct 15 16:12:05.986 INFO kablam! Oct 15 16:12:06.063 INFO kablam! 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 Oct 15 16:12:06.063 INFO kablam! --> src/types.rs:3:5 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 3 | use futures::future::BoxFuture; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! = note: #[warn(deprecated)] on by default Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! 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 Oct 15 16:12:06.063 INFO kablam! --> src/types.rs:5:5 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 5 | use futures::stream::BoxStream; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! 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 Oct 15 16:12:06.063 INFO kablam! --> src/types.rs:7:29 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! 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 Oct 15 16:12:06.063 INFO kablam! --> src/types.rs:9:29 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:12:06.063 INFO kablam! --> src/tokio/mod.rs:12:5 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 12 | use tokio_io::codec::Framed; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:12:06.063 INFO kablam! --> src/tokio/mod.rs:27:40 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.063 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Oct 15 16:12:06.063 INFO kablam! --> src/tokio/mod.rs:28:38 Oct 15 16:12:06.063 INFO kablam! | Oct 15 16:12:06.063 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Oct 15 16:12:06.063 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:06.063 INFO kablam! Oct 15 16:12:06.617 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:12:06.617 INFO kablam! --> src/proto/types.rs:271:13 Oct 15 16:12:06.617 INFO kablam! | Oct 15 16:12:06.617 INFO kablam! 271 | out.put_u16::(self.len() as u16); Oct 15 16:12:06.617 INFO kablam! | ^^^^^^^ Oct 15 16:12:06.617 INFO kablam! Oct 15 16:12:06.755 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Oct 15 16:12:06.755 INFO kablam! --> src/proto/headers.rs:135:40 Oct 15 16:12:06.755 INFO kablam! | Oct 15 16:12:06.755 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Oct 15 16:12:06.755 INFO kablam! | ^^^^^^^ Oct 15 16:12:06.755 INFO kablam! Oct 15 16:12:06.755 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:12:06.755 INFO kablam! --> src/proto/headers.rs:140:13 Oct 15 16:12:06.755 INFO kablam! | Oct 15 16:12:06.755 INFO kablam! 140 | out.put_u16::(self.0); Oct 15 16:12:06.755 INFO kablam! | ^^^^^^^ Oct 15 16:12:06.755 INFO kablam! Oct 15 16:12:06.759 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Oct 15 16:12:06.759 INFO kablam! --> src/proto/headers.rs:170:41 Oct 15 16:12:06.759 INFO kablam! | Oct 15 16:12:06.759 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Oct 15 16:12:06.759 INFO kablam! | ^^^^^^^ Oct 15 16:12:06.759 INFO kablam! Oct 15 16:12:06.759 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Oct 15 16:12:06.759 INFO kablam! --> src/proto/headers.rs:175:13 Oct 15 16:12:06.759 INFO kablam! | Oct 15 16:12:06.759 INFO kablam! 175 | out.put_u16::(self.0); Oct 15 16:12:06.759 INFO kablam! | ^^^^^^^ Oct 15 16:12:06.759 INFO kablam! Oct 15 16:12:06.775 INFO kablam! 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 Oct 15 16:12:06.775 INFO kablam! --> src/client.rs:223:55 Oct 15 16:12:06.775 INFO kablam! | Oct 15 16:12:06.775 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Oct 15 16:12:06.775 INFO kablam! | ^^^^^ Oct 15 16:12:06.775 INFO kablam! Oct 15 16:12:06.783 INFO kablam! 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 Oct 15 16:12:06.783 INFO kablam! --> src/client.rs:266:63 Oct 15 16:12:06.783 INFO kablam! | Oct 15 16:12:06.783 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Oct 15 16:12:06.783 INFO kablam! | ^^^^^ Oct 15 16:12:06.783 INFO kablam! Oct 15 16:12:06.835 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Oct 15 16:12:06.835 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Oct 15 16:12:06.835 INFO kablam! | Oct 15 16:12:06.835 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Oct 15 16:12:06.835 INFO kablam! | ^^^^ Oct 15 16:12:06.835 INFO kablam! Oct 15 16:12:06.835 INFO kablam! 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 Oct 15 16:12:06.835 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Oct 15 16:12:06.835 INFO kablam! | Oct 15 16:12:06.835 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Oct 15 16:12:06.835 INFO kablam! | ^^^^^ Oct 15 16:12:06.835 INFO kablam! Oct 15 16:12:06.847 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Oct 15 16:12:06.847 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Oct 15 16:12:06.847 INFO kablam! | Oct 15 16:12:06.847 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Oct 15 16:12:06.847 INFO kablam! | ^^^^^^ Oct 15 16:12:06.847 INFO kablam! Oct 15 16:12:06.859 INFO kablam! 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 Oct 15 16:12:06.859 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Oct 15 16:12:06.859 INFO kablam! | Oct 15 16:12:06.859 INFO kablam! 317 | .boxed() Oct 15 16:12:06.859 INFO kablam! | ^^^^^ Oct 15 16:12:06.859 INFO kablam! Oct 15 16:12:06.875 INFO kablam! 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 Oct 15 16:12:06.875 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Oct 15 16:12:06.875 INFO kablam! | Oct 15 16:12:06.875 INFO kablam! 519 | .boxed(), Oct 15 16:12:06.875 INFO kablam! | ^^^^^ Oct 15 16:12:06.875 INFO kablam! Oct 15 16:12:06.891 INFO kablam! 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 Oct 15 16:12:06.891 INFO kablam! --> src/tokio/response.rs:83:40 Oct 15 16:12:06.891 INFO kablam! | Oct 15 16:12:06.891 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Oct 15 16:12:06.891 INFO kablam! | ^^^^^ Oct 15 16:12:06.891 INFO kablam! Oct 15 16:12:06.946 INFO kablam! 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 Oct 15 16:12:06.946 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Oct 15 16:12:06.946 INFO kablam! | Oct 15 16:12:06.946 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Oct 15 16:12:06.946 INFO kablam! | ^^^^^ Oct 15 16:12:06.946 INFO kablam! Oct 15 16:12:07.191 INFO kablam! warning: unused import: `Sink` Oct 15 16:12:07.191 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Oct 15 16:12:07.191 INFO kablam! | Oct 15 16:12:07.191 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Sink` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Sink` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Sink` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.192 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:07.192 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Oct 15 16:12:07.192 INFO kablam! | Oct 15 16:12:07.192 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Oct 15 16:12:07.192 INFO kablam! | ^^^^^^ Oct 15 16:12:07.192 INFO kablam! Oct 15 16:12:07.559 INFO kablam! warning: variable does not need to be mutable Oct 15 16:12:07.559 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Oct 15 16:12:07.560 INFO kablam! | Oct 15 16:12:07.560 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Oct 15 16:12:07.560 INFO kablam! | ----^^^ Oct 15 16:12:07.560 INFO kablam! | | Oct 15 16:12:07.561 INFO kablam! | help: remove this `mut` Oct 15 16:12:07.561 INFO kablam! | Oct 15 16:12:07.561 INFO kablam! = note: #[warn(unused_mut)] on by default Oct 15 16:12:07.561 INFO kablam! Oct 15 16:12:07.826 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:12:07.826 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Oct 15 16:12:07.827 INFO kablam! | Oct 15 16:12:07.827 INFO kablam! 571 | self.poll_queues(sourceitem); Oct 15 16:12:07.827 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:07.827 INFO kablam! | Oct 15 16:12:07.827 INFO kablam! = note: #[warn(unused_must_use)] on by default Oct 15 16:12:07.827 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:12:07.827 INFO kablam! Oct 15 16:12:07.835 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:12:07.835 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Oct 15 16:12:07.835 INFO kablam! | Oct 15 16:12:07.836 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Oct 15 16:12:07.836 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Oct 15 16:12:07.836 INFO kablam! 106 | | )); Oct 15 16:12:07.836 INFO kablam! | |___________________________^ Oct 15 16:12:07.836 INFO kablam! | Oct 15 16:12:07.836 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:12:07.837 INFO kablam! Oct 15 16:12:07.837 INFO kablam! warning: unused `std::result::Result` which must be used Oct 15 16:12:07.837 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Oct 15 16:12:07.837 INFO kablam! | Oct 15 16:12:07.837 INFO kablam! 128 | / requester.unbounded_send( Oct 15 16:12:07.838 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Oct 15 16:12:07.838 INFO kablam! 130 | | ); Oct 15 16:12:07.838 INFO kablam! | |______________________________^ Oct 15 16:12:07.838 INFO kablam! | Oct 15 16:12:07.838 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Oct 15 16:12:07.838 INFO kablam! Oct 15 16:12:07.842 INFO kablam! warning: unused `futures::sink::Send` which must be used Oct 15 16:12:07.843 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Oct 15 16:12:07.843 INFO kablam! | Oct 15 16:12:07.843 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Oct 15 16:12:07.843 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:07.843 INFO kablam! | Oct 15 16:12:07.843 INFO kablam! = note: futures do nothing unless polled Oct 15 16:12:07.844 INFO kablam! Oct 15 16:12:07.972 INFO kablam! warning: unused `#[macro_use]` import Oct 15 16:12:07.972 INFO kablam! --> examples/client.rs:1:1 Oct 15 16:12:07.972 INFO kablam! | Oct 15 16:12:07.973 INFO kablam! 1 | #[macro_use] Oct 15 16:12:07.973 INFO kablam! | ^^^^^^^^^^^^ Oct 15 16:12:07.974 INFO kablam! | Oct 15 16:12:07.974 INFO kablam! = note: #[warn(unused_imports)] on by default Oct 15 16:12:07.974 INFO kablam! Oct 15 16:12:07.974 INFO kablam! warning: unused import: `tokio_mqttc::persistence::*` Oct 15 16:12:07.974 INFO kablam! --> examples/client.rs:11:5 Oct 15 16:12:07.975 INFO kablam! | Oct 15 16:12:07.975 INFO kablam! 11 | use tokio_mqttc::persistence::*; Oct 15 16:12:07.975 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:07.975 INFO kablam! Oct 15 16:12:07.975 INFO kablam! warning: unused import: `tokio_mqttc::proto::*` Oct 15 16:12:07.975 INFO kablam! --> examples/client.rs:13:5 Oct 15 16:12:07.976 INFO kablam! | Oct 15 16:12:07.976 INFO kablam! 13 | use tokio_mqttc::proto::*; Oct 15 16:12:07.976 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:07.976 INFO kablam! Oct 15 16:12:07.987 INFO kablam! warning: unused import: `tokio_core::reactor::Handle` Oct 15 16:12:07.987 INFO kablam! --> examples/client.rs:41:5 Oct 15 16:12:07.987 INFO kablam! | Oct 15 16:12:07.988 INFO kablam! 41 | use tokio_core::reactor::Handle; Oct 15 16:12:07.988 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Oct 15 16:12:07.988 INFO kablam! Oct 15 16:12:07.988 INFO kablam! warning: unused imports: `Sink`, `future` Oct 15 16:12:07.988 INFO kablam! --> examples/client.rs:45:15 Oct 15 16:12:07.988 INFO kablam! | Oct 15 16:12:07.988 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Oct 15 16:12:07.989 INFO kablam! | ^^^^^^ ^^^^ Oct 15 16:12:07.989 INFO kablam! Oct 15 16:12:08.103 INFO kablam! warning: unused import: `Stream` Oct 15 16:12:08.103 INFO kablam! --> examples/client.rs:45:31 Oct 15 16:12:08.103 INFO kablam! | Oct 15 16:12:08.104 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Oct 15 16:12:08.104 INFO kablam! | ^^^^^^ Oct 15 16:12:08.104 INFO kablam! Oct 15 16:12:12.983 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 12.02s Oct 15 16:12:13.001 INFO kablam! su: No module specific data is present Oct 15 16:12:14.089 INFO running `"docker" "rm" "-f" "4aee7c3d720734e6de25baec1e3e3522a47250bbdec98e8cb288477d729b84ab"` Oct 15 16:12:14.335 INFO blam! 4aee7c3d720734e6de25baec1e3e3522a47250bbdec98e8cb288477d729b84ab Oct 15 16:12:14.344 INFO running `"docker" "create" "-v" "/mnt/big/crater/./work/local/target-dirs/rustdoc-test-static-cling-1/worker-7/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/target:rw,Z" "-v" "/mnt/big/crater/./work/local/test-source/worker-7/rustdoc-test-static-cling-1/master#0e07c4281c343e9e15a0a8fca79538ad1a8eb513:/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 +0e07c4281c343e9e15a0a8fca79538ad1a8eb513-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"` Oct 15 16:12:14.790 INFO blam! e4d54e919b656912c0294b58829fa01cf47036ac5807a77ae4526555b8d9e335 Oct 15 16:12:14.793 INFO running `"docker" "start" "-a" "e4d54e919b656912c0294b58829fa01cf47036ac5807a77ae4526555b8d9e335"` Oct 15 16:12:15.814 INFO kablam! usermod: no changes Oct 15 16:12:16.119 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 0.26s Oct 15 16:12:16.135 INFO kablam! Running /target/debug/deps/tokio_mqttc-b1152654c0abefe7 Oct 15 16:12:16.139 INFO blam! Oct 15 16:12:16.139 INFO blam! running 10 tests Oct 15 16:12:16.175 INFO blam! test proto::parsers::vle_tests::one_byte_vle ... ok Oct 15 16:12:16.179 INFO blam! test proto::parsers::vle_tests::two_byte_vle ... ok Oct 15 16:12:16.179 INFO blam! test proto::parsers::vle_tests::incomplete_vle ... ok Oct 15 16:12:16.179 INFO blam! test proto::parsers::vle_tests::four_byte_vle ... ok Oct 15 16:12:16.179 INFO blam! test proto::parsers::vle_tests::three_byte_vle ... ok Oct 15 16:12:16.179 INFO blam! test tests::it_works ... ok Oct 15 16:12:16.180 INFO blam! test tokio::tests::complex_single_level_filter ... ok Oct 15 16:12:16.180 INFO blam! test proto::parsers::vle_tests::overflow_vle ... ok Oct 15 16:12:16.185 INFO blam! test tokio::tests::simple_filter ... ok Oct 15 16:12:16.185 INFO blam! test tokio::tests::single_level_filter ... ok Oct 15 16:12:16.185 INFO blam! Oct 15 16:12:16.185 INFO blam! test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out Oct 15 16:12:16.185 INFO blam! Oct 15 16:12:16.189 INFO kablam! Doc-tests tokio-mqttc Oct 15 16:12:22.112 INFO blam! Oct 15 16:12:22.112 INFO blam! running 0 tests Oct 15 16:12:22.112 INFO blam! Oct 15 16:12:22.112 INFO blam! test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out Oct 15 16:12:22.112 INFO blam! Oct 15 16:12:22.125 INFO kablam! su: No module specific data is present Oct 15 16:12:22.515 INFO running `"docker" "rm" "-f" "e4d54e919b656912c0294b58829fa01cf47036ac5807a77ae4526555b8d9e335"` Oct 15 16:12:22.707 INFO blam! e4d54e919b656912c0294b58829fa01cf47036ac5807a77ae4526555b8d9e335