diff --git a/tokio-executor/Cargo.toml b/tokio-executor/Cargo.toml index 465bae8d6f3..2d8a7161b1d 100644 --- a/tokio-executor/Cargo.toml +++ b/tokio-executor/Cargo.toml @@ -21,7 +21,7 @@ keywords = ["futures", "tokio"] categories = ["concurrency", "asynchronous"] [dependencies] -crossbeam-utils = "0.6.2" +crossbeam-utils = "0.7.0" futures = "0.1.19" [dev-dependencies] diff --git a/tokio-reactor/Cargo.toml b/tokio-reactor/Cargo.toml index 028493ed14b..6d2faebd53e 100644 --- a/tokio-reactor/Cargo.toml +++ b/tokio-reactor/Cargo.toml @@ -21,7 +21,7 @@ Event loop that drives Tokio I/O resources. categories = ["asynchronous", "network-programming"] [dependencies] -crossbeam-utils = "0.6.0" +crossbeam-utils = "0.7.0" futures = "0.1.19" lazy_static = "1.0.2" log = "0.4.1" diff --git a/tokio-threadpool/Cargo.toml b/tokio-threadpool/Cargo.toml index 38f7e4097e4..5db03aec480 100644 --- a/tokio-threadpool/Cargo.toml +++ b/tokio-threadpool/Cargo.toml @@ -24,8 +24,8 @@ categories = ["concurrency", "asynchronous"] tokio-executor = "0.1.8" futures = "0.1.19" crossbeam-deque = "0.7.0" -crossbeam-queue = "0.1.0" -crossbeam-utils = "0.6.4" +crossbeam-queue = "0.2.0" +crossbeam-utils = "0.7.0" num_cpus = "1.2" slab = "0.4.1" log = "0.4" diff --git a/tokio-threadpool/tests/threadpool.rs b/tokio-threadpool/tests/threadpool.rs index bd6736f9aaa..06c007444a7 100644 --- a/tokio-threadpool/tests/threadpool.rs +++ b/tokio-threadpool/tests/threadpool.rs @@ -131,7 +131,7 @@ fn force_shutdown_drops_futures() { b.fetch_add(1, Relaxed); }) .build(); - let mut tx = pool.sender().clone(); + let tx = pool.sender().clone(); tx.spawn(Never(num_drop.clone())).unwrap(); @@ -190,7 +190,7 @@ fn drop_threadpool_drops_futures() { b.fetch_add(1, Relaxed); }) .build(); - let mut tx = pool.sender().clone(); + let tx = pool.sender().clone(); tx.spawn(Never(num_drop.clone())).unwrap(); @@ -219,7 +219,7 @@ fn many_oneshot_futures() { for _ in 0..50 { let pool = ThreadPool::new(); - let mut tx = pool.sender().clone(); + let tx = pool.sender().clone(); let cnt = Arc::new(AtomicUsize::new(0)); for _ in 0..NUM { @@ -251,7 +251,7 @@ fn many_multishot_futures() { for _ in 0..50 { let pool = ThreadPool::new(); - let mut pool_tx = pool.sender().clone(); + let pool_tx = pool.sender().clone(); let mut start_txs = Vec::with_capacity(TRACKS); let mut final_rxs = Vec::with_capacity(TRACKS); diff --git a/tokio-timer/Cargo.toml b/tokio-timer/Cargo.toml index 6330299b112..2c5e929eec1 100644 --- a/tokio-timer/Cargo.toml +++ b/tokio-timer/Cargo.toml @@ -22,7 +22,7 @@ Timer facilities for Tokio [dependencies] futures = "0.1.19" tokio-executor = "0.1.1" -crossbeam-utils = "0.6.0" +crossbeam-utils = "0.7.0" # Backs `DelayQueue` slab = "0.4.1" diff --git a/tokio-timer/tests/queue.rs b/tokio-timer/tests/queue.rs index eeba610414b..613b6c6ddda 100644 --- a/tokio-timer/tests/queue.rs +++ b/tokio-timer/tests/queue.rs @@ -390,7 +390,7 @@ fn reset_first_expiring_item_to_expire_later() { let epoch = time.now(); let foo = queue.insert_at("foo", epoch + ms(200)); - let bar = queue.insert_at("bar", epoch + ms(250)); + let _bar = queue.insert_at("bar", epoch + ms(250)); task.enter(|| { assert_not_ready!(queue);