diff --git a/substrate/Cargo.lock b/substrate/Cargo.lock index d376a322e086febfccf9647ff2ca4bbbce66eb5c..1adf135f0e508152ce45f7352e276934868dde31 100644 --- a/substrate/Cargo.lock +++ b/substrate/Cargo.lock @@ -2216,7 +2216,7 @@ dependencies = [ "lazy_static 1.0.1 (registry+https://github.com/rust-lang/crates.io-index)", "libc 0.2.41 (registry+https://github.com/rust-lang/crates.io-index)", "num_cpus 1.8.0 (registry+https://github.com/rust-lang/crates.io-index)", - "rand 0.3.22 (registry+https://github.com/rust-lang/crates.io-index)", + "rand 0.4.2 (registry+https://github.com/rust-lang/crates.io-index)", ] [[package]] @@ -2874,7 +2874,7 @@ dependencies = [ "tokio 0.1.7 (registry+https://github.com/rust-lang/crates.io-index)", "tokio-io 0.1.7 (registry+https://github.com/rust-lang/crates.io-index)", "tokio-timer 0.2.4 (registry+https://github.com/rust-lang/crates.io-index)", - "varint 0.1.0 (git+https://github.com/tomaka/libp2p-rs?branch=polkadot-2)", + "unsigned-varint 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", ] [[package]] @@ -3759,6 +3759,16 @@ dependencies = [ "void 1.0.2 (registry+https://github.com/rust-lang/crates.io-index)", ] +[[package]] +name = "unsigned-varint" +version = "0.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +dependencies = [ + "bytes 0.4.8 (registry+https://github.com/rust-lang/crates.io-index)", + "quick-error 1.2.2 (registry+https://github.com/rust-lang/crates.io-index)", + "tokio-codec 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", +] + [[package]] name = "untrusted" version = "0.5.1" @@ -4258,6 +4268,7 @@ dependencies = [ "checksum unicode-width 0.1.5 (registry+https://github.com/rust-lang/crates.io-index)" = "882386231c45df4700b275c7ff55b6f3698780a650026380e72dabe76fa46526" "checksum unicode-xid 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)" = "fc72304796d0818e357ead4e000d19c9c174ab23dc11093ac919054d20a6a7fc" "checksum unreachable 1.0.0 (registry+https://github.com/rust-lang/crates.io-index)" = "382810877fe448991dfc7f0dd6e3ae5d58088fd0ea5e35189655f84e6814fa56" +"checksum unsigned-varint 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)" = "f5c1441164e5da61f00acd15f5a9e61939693c2c6e8b9fae36a220b82de7e212" "checksum untrusted 0.5.1 (registry+https://github.com/rust-lang/crates.io-index)" = "f392d7819dbe58833e26872f5f6f0d68b7bbbe90fc3667e98731c4a15ad9a7ae" "checksum url 1.7.0 (registry+https://github.com/rust-lang/crates.io-index)" = "f808aadd8cfec6ef90e4a14eb46f24511824d1ac596b9682703c87056c8678b7" "checksum utf8-ranges 1.0.0 (registry+https://github.com/rust-lang/crates.io-index)" = "662fab6525a98beff2921d7f61a39e7d59e0b425ebc7d0d9e66d316e55124122" diff --git a/substrate/substrate/network-libp2p/Cargo.toml b/substrate/substrate/network-libp2p/Cargo.toml index 1c934ebc6a924529f09c02b76d5f7414b9a5e253..ef8c5b911d2a2519fdb95f392ab9409a8165d430 100644 --- a/substrate/substrate/network-libp2p/Cargo.toml +++ b/substrate/substrate/network-libp2p/Cargo.toml @@ -22,7 +22,7 @@ rand = "0.5.0" tokio = "0.1" tokio-io = "0.1" tokio-timer = "0.2" -varint = { git = "https://github.com/tomaka/libp2p-rs", branch = "polkadot-2" } +unsigned-varint = { version = "0.1", features = ["codec"] } [dev-dependencies] assert_matches = "1.2" diff --git a/substrate/substrate/network-libp2p/src/custom_proto.rs b/substrate/substrate/network-libp2p/src/custom_proto.rs index 574bb6247245820aacf08d0c145b377599c99fc8..4fe2ee65a0d9b10f7ae42303c1d45dedc617f0f0 100644 --- a/substrate/substrate/network-libp2p/src/custom_proto.rs +++ b/substrate/substrate/network-libp2p/src/custom_proto.rs @@ -23,7 +23,7 @@ use std::vec::IntoIter as VecIntoIter; use futures::{future, Future, stream, Stream, Sink}; use futures::sync::mpsc; use tokio_io::{AsyncRead, AsyncWrite}; -use varint::VarintCodec; +use unsigned_varint::codec::UviBytes; /// Connection upgrade for a single protocol. /// @@ -157,7 +157,7 @@ where C: AsyncRead + AsyncWrite + 'static, // TODO: 'static :-/ } let (sink, stream) = { - let framed = AsyncRead::framed(socket, VarintCodec::default()); + let framed = AsyncRead::framed(socket, UviBytes::default()); let msg_rx = msg_rx.map(Message::SendReq) .map_err(|()| unreachable!("mpsc::UnboundedReceiver never errors")); let (sink, stream) = framed.split(); diff --git a/substrate/substrate/network-libp2p/src/lib.rs b/substrate/substrate/network-libp2p/src/lib.rs index fbdfb9b2d98de2bd93369e0c222daa298894937c..b6b358d60812a7861ac18ae06553e5036cc11665 100644 --- a/substrate/substrate/network-libp2p/src/lib.rs +++ b/substrate/substrate/network-libp2p/src/lib.rs @@ -28,7 +28,7 @@ extern crate libc; extern crate libp2p; extern crate rand; extern crate bytes; -extern crate varint; +extern crate unsigned_varint; extern crate ethcore_io as io; extern crate ethereum_types;