Downgrading tokio to registry version.

Prep for rustls.

BUILD.gn

@@ -45,7 +45,6 @@ main_extern = [
   "$rust_build:tempfile",
   "$rust_build:rand",
   "$rust_build:tokio",
-  "$rust_build:tokio_current_thread",
   "$rust_build:url",
   "//build_extra/flatbuffers/rust:flatbuffers",
   ":msg_rs",

Cargo.toml

@@ -14,8 +14,5 @@ log = "0.4.3"
 rand = "0.5.4"
 sha1 = "0.6.0"
 tempfile = "3"
-tokio = {git = "https://github.com/tokio-rs/tokio.git", rev = "5d0d2a2e1214f856993df6965825c89bfcaa879e"}
+tokio = "0.1"
 hyper = "0.12.8"
-crossbeam-deque = "= 0.5.1"
-crossbeam-epoch = "= 0.5.1"
-futures-core = "0.2.1"

build_extra/rust/BUILD.gn

@@ -73,7 +73,7 @@ rust_crate("sha1") {
 }
 
 rust_crate("tempfile") {
-  source_root = "$registry_github/tempfile-3.0.3/src/lib.rs"
+  source_root = "$registry_github/tempfile-3.0.2/src/lib.rs"
   extern = [
     ":libc",
     ":rand",
@@ -83,14 +83,13 @@ rust_crate("tempfile") {
 }
 
 rust_crate("rand") {
-  source_root = "$registry_github/rand-0.5.4/src/lib.rs"
+  source_root = "$registry_github/rand-0.4.2/src/lib.rs"
   features = [
     "std",
     "alloc",
   ]
   extern = [
     ":libc",
-    ":rand_core",
     ":winapi",
   ]
   if (is_mac) {
@@ -98,10 +97,6 @@ rust_crate("rand") {
   }
 }
 
-rust_crate("rand_core") {
-  source_root = "$registry_github/rand_core-0.2.1/src/lib.rs"
-}
-
 rust_crate("remove_dir_all") {
   source_root = "$registry_github/remove_dir_all-0.5.1/src/lib.rs"
   extern = [ ":winapi" ]
@@ -281,7 +276,7 @@ rust_crate("net2") {
 }
 
 rust_crate("slab") {
-  source_root = "$registry_github/slab-0.4.0/src/lib.rs"
+  source_root = "$registry_github/slab-0.4.1/src/lib.rs"
 }
 
 rust_crate("bytes") {
@@ -297,7 +292,8 @@ rust_crate("byteorder") {
 }
 
 rust_crate("crossbeam_deque") {
-  source_root = "$registry_github/crossbeam-deque-0.5.1/src/lib.rs"
+  source_root = "$registry_github/crossbeam-deque-0.3.1/src/lib.rs"
+  features = [ "use_std" ]
   extern = [
     ":crossbeam_epoch",
     ":crossbeam_utils",
@@ -305,8 +301,13 @@ rust_crate("crossbeam_deque") {
 }
 
 rust_crate("crossbeam_epoch") {
-  source_root = "$registry_github/crossbeam-epoch-0.5.1/src/lib.rs"
-  features = [ "use_std" ]
+  source_root = "$registry_github/crossbeam-epoch-0.4.3/src/lib.rs"
+  features = [
+    "use_std",
+    "lazy_static",
+    "default",
+    "crossbeam-utils",
+  ]
   extern = [
     ":arrayvec",
     ":cfg_if",
@@ -318,8 +319,11 @@ rust_crate("crossbeam_epoch") {
 }
 
 rust_crate("crossbeam_utils") {
-  source_root = "$registry_github/crossbeam-utils-0.4.1/src/lib.rs"
-  features = [ "use_std" ]
+  source_root = "$registry_github/crossbeam-utils-0.3.2/src/lib.rs"
+  features = [
+    "use_std",
+    "default",
+  ]
   extern = [ ":cfg_if" ]
 }
 
@@ -333,7 +337,11 @@ rust_crate("nodrop") {
 }
 
 rust_crate("lazy_static") {
-  source_root = "$registry_github/lazy_static-1.0.2/src/lib.rs"
+  source_root = "$registry_github/lazy_static-1.1.0/src/lib.rs"
+  args = [
+    "--cfg",
+    "lazy_static_inline_impl",
+  ]
 }
 
 rust_crate("memoffset") {
@@ -429,10 +437,6 @@ rust_crate("fnv") {
   source_root = "$registry_github/fnv-1.0.6/lib.rs"
 }
 
-rust_crate("futures_core") {
-  source_root = "$registry_github/futures-core-0.2.1/src/lib.rs"
-}
-
 rust_crate("futures_cpupool") {
   source_root = "$registry_github/futures-cpupool-0.1.8/src/lib.rs"
   extern = [
@@ -475,10 +479,8 @@ rust_crate("want") {
   ]
 }
 
-tokio_root = "$crates/git/checkouts/tokio-377c595163f99a10/5d0d2a2/"
-
 rust_crate("tokio") {
-  source_root = "$tokio_root/src/lib.rs"
+  source_root = "$registry_github/tokio-0.1.7/src/lib.rs"
   extern = [
     ":futures",
     ":mio",
@@ -488,27 +490,18 @@ rust_crate("tokio") {
     ":tokio_reactor",
     ":tokio_tcp",
     ":tokio_threadpool",
-    ":tokio_current_thread",
     ":tokio_timer",
     ":tokio_udp",
   ]
 }
 
 rust_crate("tokio_executor") {
-  source_root = "$tokio_root/tokio-executor/src/lib.rs"
+  source_root = "$registry_github/tokio-executor-0.1.3/src/lib.rs"
   extern = [ ":futures" ]
 }
 
-rust_crate("tokio_current_thread") {
-  source_root = "$tokio_root/tokio-current-thread/src/lib.rs"
-  extern = [
-    ":tokio_executor",
-    ":futures",
-  ]
-}
-
 rust_crate("tokio_fs") {
-  source_root = "$tokio_root//tokio-fs/src/lib.rs"
+  source_root = "$registry_github/tokio-fs-0.1.3/src/lib.rs"
   extern = [
     ":futures",
     ":tokio_io",
@@ -517,7 +510,7 @@ rust_crate("tokio_fs") {
 }
 
 rust_crate("tokio_io") {
-  source_root = "$tokio_root/tokio-io/src/lib.rs"
+  source_root = "$registry_github/tokio-io-0.1.7/src/lib.rs"
   extern = [
     ":bytes",
     ":futures",
@@ -526,7 +519,7 @@ rust_crate("tokio_io") {
 }
 
 rust_crate("tokio_timer") {
-  source_root = "$tokio_root/tokio-timer/src/lib.rs"
+  source_root = "$registry_github/tokio-timer-0.2.5/src/lib.rs"
   extern = [
     ":futures",
     ":tokio_executor",
@@ -534,7 +527,7 @@ rust_crate("tokio_timer") {
 }
 
 rust_crate("tokio_udp") {
-  source_root = "$tokio_root/tokio-udp/src/lib.rs"
+  source_root = "$registry_github/tokio-udp-0.1.1/src/lib.rs"
   extern = [
     ":bytes",
     ":futures",
@@ -547,7 +540,7 @@ rust_crate("tokio_udp") {
 }
 
 rust_crate("tokio_codec") {
-  source_root = "$tokio_root/tokio-codec/src/lib.rs"
+  source_root = "$registry_github/tokio-codec-0.1.0/src/lib.rs"
   extern = [
     ":bytes",
     ":futures",
@@ -556,7 +549,7 @@ rust_crate("tokio_codec") {
 }
 
 rust_crate("tokio_reactor") {
-  source_root = "$tokio_root/tokio-reactor/src/lib.rs"
+  source_root = "$registry_github/tokio-reactor-0.1.3/src/lib.rs"
   extern = [
     ":futures",
     ":log",
@@ -568,7 +561,7 @@ rust_crate("tokio_reactor") {
 }
 
 rust_crate("tokio_tcp") {
-  source_root = "$tokio_root/tokio-tcp/src/lib.rs"
+  source_root = "$registry_github/tokio-tcp-0.1.1/src/lib.rs"
   extern = [
     ":bytes",
     ":futures",
@@ -580,7 +573,7 @@ rust_crate("tokio_tcp") {
 }
 
 rust_crate("tokio_threadpool") {
-  source_root = "$tokio_root/tokio-threadpool/src/lib.rs"
+  source_root = "$registry_github/tokio-threadpool-0.1.5/src/lib.rs"
   extern = [
     ":crossbeam_deque",
     ":crossbeam_utils",

src/fs.rs

@@ -5,7 +5,7 @@ use std::io::Write;
 use std::path::{Path, PathBuf};
 
 use rand;
-use rand::RngCore;
+use rand::Rng;
 
 pub fn write_file_sync(path: &Path, content: &[u8]) -> std::io::Result<()> {
   let mut f = File::create(path)?;
@@ -23,8 +23,9 @@ pub fn make_temp_dir(
     Some(ref p) => p.to_path_buf(),
     None => std::env::temp_dir(),
   }.join("_");
+  let mut rng = rand::thread_rng();
   loop {
-    let unique = rand::thread_rng().next_u32();
+    let unique = rng.gen::<u32>();
     buf.set_file_name(format!("{}{:08x}{}", prefix_, unique, suffix_));
     // TODO: on posix, set mode flags to 0o700.
     let r = create_dir(buf.as_path());

src/main.rs

@@ -7,7 +7,6 @@ extern crate rand;
 extern crate sha1;
 extern crate tempfile;
 extern crate tokio;
-extern crate tokio_current_thread;
 extern crate url;
 #[macro_use]
 extern crate log;

third_party

@@ -1 +1 @@
-Subproject commit 7641f8fd22d0db48a05b844cd2091d352f7a9740
+Subproject commit 0398b184060eb0f4e8e1b9ab20b1e21a4f37755c