Merge pull request #17 from programatik29/master

ignore all errors by default

src/proto/client.rs

@@ -63,7 +63,12 @@ where
         let start = Instant::now();
         let counter = Arc::new(AtomicUsize::new(0));
 
-        let mut connection = self.connect_retry(start, self.time_for, &counter).await?;
+        let mut connection = match self.connect_retry(start, self.time_for, &counter).await {
+            Ok(conn) => conn,
+            Err(_) => {
+                return Ok(WorkerResult::default());
+            }
+        };
 
         let mut times: Vec<Duration> = Vec::with_capacity(self.predicted_size);
 
@@ -75,7 +80,11 @@ where
                     }
                 },
                 _ = (&mut connection.handle) => {
-                    connection = self.connect_retry(start, self.time_for, &counter).await?;
+                    match self.connect_retry(start, self.time_for, &counter).await {
+                        Ok(conn) => connection = conn,
+                        // Errors are ignored currently.
+                        Err(_) => break,
+                    }
                 }
             };
         }

src/results.rs

@@ -13,10 +13,7 @@ fn get_percentile(request_times: &Vec<Duration>, pct: f64) -> Duration {
     }
 
     let e = format!("failed to calculate P{} avg latency", (1.0 - pct) * 100f64);
-    let pct = request_times
-        .chunks(len as usize)
-        .next()
-        .expect(&e);
+    let pct = request_times.chunks(len as usize).next().expect(&e);
 
     let total: f64 = pct.iter().map(|dur| dur.as_secs_f64()).sum();
 
@@ -26,6 +23,7 @@ fn get_percentile(request_times: &Vec<Duration>, pct: f64) -> Duration {
 }
 
 /// Contains and handles results from the workers
+#[derive(Default)]
 pub struct WorkerResult {
     /// The total time taken for each worker.
     pub total_times: Vec<Duration>,