From d2e04c7f6c9da430df4db9a427a5a3606bb3373f Mon Sep 17 00:00:00 2001
From: MOZGIII <mike-n@narod.ru>
Date: Sat, 21 Mar 2020 02:57:33 +0300
Subject: [PATCH] --wip-- [skip ci]

---
 src/topology/mod.rs |  2 +-
 tests/buffering.rs  | 19 +++++--------------
 2 files changed, 6 insertions(+), 15 deletions(-)

diff --git a/src/topology/mod.rs b/src/topology/mod.rs
index 4173b848b7ceed..0f8537e7337e31 100644
--- a/src/topology/mod.rs
+++ b/src/topology/mod.rs
@@ -113,7 +113,7 @@ impl RunningTopology {
         }
         let mut check_handles2 = check_handles.clone();
 
-        let deadline = Instant::now() + Duration::from_secs(60);
+        let deadline = Instant::now() + Duration::from_secs(5);
 
         let timeout = timer::Delay::new(deadline)
             .map(move |_| {
diff --git a/tests/buffering.rs b/tests/buffering.rs
index 6aaf308f09b725..7828772a236a58 100644
--- a/tests/buffering.rs
+++ b/tests/buffering.rs
@@ -198,7 +198,7 @@ fn test_max_size() {
 
 #[test]
 fn test_max_size_resume() {
-    vector::test_util::trace_init();
+    test_util::trace_init();
 
     let data_dir = tempdir().unwrap();
     let data_dir = data_dir.path().to_path_buf();
@@ -246,12 +246,9 @@ fn test_max_size_resume() {
     let send2 = send_lines(in_addr2, input_lines2.clone().into_iter());
     rt.block_on(send1.join(send2)).unwrap();
 
-    std::thread::sleep(std::time::Duration::from_millis(100));
-
     let output_lines = receive(&out_addr);
 
-    rt.block_on(topology.stop()).unwrap();
-
+    block_on(topology.stop()).unwrap();
     shutdown_on_idle(rt);
 
     let output_lines = output_lines.wait();
@@ -259,9 +256,8 @@ fn test_max_size_resume() {
 }
 
 #[test]
-#[ignore]
 fn test_reclaim_disk_space() {
-    vector::test_util::trace_init();
+    test_util::trace_init();
 
     let data_dir = tempdir().unwrap();
     let data_dir = data_dir.path().to_path_buf();
@@ -299,10 +295,8 @@ fn test_reclaim_disk_space() {
     let send = send_lines(in_addr, input_lines.clone().into_iter());
     rt.block_on(send).unwrap();
 
-    std::thread::sleep(std::time::Duration::from_millis(10000));
-
-    rt.shutdown_now().wait().unwrap();
-    drop(topology);
+    block_on(topology.stop()).unwrap();
+    shutdown_on_idle(rt);
 
     let before_disk_size: u64 = walkdir::WalkDir::new(&data_dir)
         .into_iter()
@@ -344,10 +338,7 @@ fn test_reclaim_disk_space() {
     let send = send_lines(in_addr, input_lines2.clone().into_iter());
     rt.block_on(send).unwrap();
 
-    std::thread::sleep(std::time::Duration::from_millis(1000));
-
     block_on(topology.stop()).unwrap();
-
     shutdown_on_idle(rt);
 
     let output_lines = output_lines.wait();