run cargo fmt

Author: andjo403

analyzeme/benches/serialization_bench.rs

@@ -2,8 +2,8 @@
 
 extern crate test;
 
-use measureme::{FileSerializationSink, MmapSerializationSink};
 use analyzeme::testing_common;
+use measureme::{FileSerializationSink, MmapSerializationSink};
 
 #[bench]
 fn bench_file_serialization_sink(bencher: &mut test::Bencher) {

analyzeme/tests/serialization.rs

@@ -1,5 +1,5 @@
-use measureme::{FileSerializationSink, MmapSerializationSink};
 use analyzeme::testing_common::run_end_to_end_serialization_test;
+use measureme::{FileSerializationSink, MmapSerializationSink};
 
 #[test]
 fn test_file_serialization_sink() {

crox/src/main.rs

@@ -61,7 +61,8 @@ fn generate_thread_to_collapsed_thread_mapping(
 
     if opt.collapse_threads {
         // collect start and end times for all threads
-        let mut thread_start_and_end: FxHashMap<u64, (SystemTime, SystemTime)> = FxHashMap::default();
+        let mut thread_start_and_end: FxHashMap<u64, (SystemTime, SystemTime)> =
+            FxHashMap::default();
         for event in data.iter() {
             thread_start_and_end
                 .entry(event.thread_id)

flamegraph/src/main.rs

@@ -3,9 +3,9 @@ use std::fs::File;
 use std::io::BufWriter;
 use std::path::PathBuf;
 
+use analyzeme::{collapse_stacks, ProfilingData};
 use inferno::flamegraph::{from_lines, Options as FlamegraphOptions};
 use structopt::StructOpt;
-use analyzeme::{collapse_stacks, ProfilingData};
 
 #[derive(StructOpt, Debug)]
 struct Opt {

mmview/src/main.rs

@@ -1,6 +1,6 @@
+use analyzeme::ProfilingData;
 use std::error::Error;
 use std::path::PathBuf;
-use analyzeme::ProfilingData;
 
 use structopt::StructOpt;
 

stack_collapse/src/main.rs

@@ -3,8 +3,8 @@ use std::fs::File;
 use std::io::{BufWriter, Write};
 use std::path::PathBuf;
 
-use structopt::StructOpt;
 use analyzeme::{collapse_stacks, ProfilingData};
+use structopt::StructOpt;
 
 #[derive(StructOpt, Debug)]
 struct Opt {

summarize/src/analysis.rs

@@ -1,9 +1,9 @@
 use crate::query_data::{QueryData, Results};
+use analyzeme::{Event, ProfilingData, Timestamp};
 use measureme::rustc::*;
 use rustc_hash::FxHashMap;
 use std::borrow::Cow;
 use std::time::SystemTime;
-use analyzeme::{Event, ProfilingData, Timestamp};
 
 /// Collects accumulated summary data for the given ProfilingData.
 ///
@@ -109,7 +109,6 @@ use analyzeme::{Event, ProfilingData, Timestamp};
 /// In this case when we encounter `e2`, the stack is `[e1, e3, e4]`, and both
 /// `e4` and `e3` need to be popped in the same step.
 pub fn perform_analysis(data: ProfilingData) -> Results {
-
     struct PerThreadState<'a> {
         stack: Vec<Event<'a>>,
         start: SystemTime,
@@ -141,13 +140,14 @@ pub fn perform_analysis(data: ProfilingData) -> Results {
             }
             Timestamp::Interval { start, end } => {
                 // This is an interval event
-                let thread = threads.entry(current_event.thread_id).or_insert_with(|| {
-                    PerThreadState {
-                        stack: Vec::new(),
-                        start,
-                        end,
-                    }
-                });
+                let thread =
+                    threads
+                        .entry(current_event.thread_id)
+                        .or_insert_with(|| PerThreadState {
+                            stack: Vec::new(),
+                            start,
+                            end,
+                        });
 
                 // Pop all events from the stack that are not parents of the
                 // current event.
@@ -207,7 +207,10 @@ pub fn perform_analysis(data: ProfilingData) -> Results {
         }
     }
 
-    let total_time = threads.values().map(|t| t.end.duration_since(t.start).unwrap()).sum();
+    let total_time = threads
+        .values()
+        .map(|t| t.end.duration_since(t.start).unwrap())
+        .sum();
 
     Results {
         query_data: query_data.drain().map(|(_, value)| value).collect(),

summarize/src/diff.rs

@@ -28,7 +28,10 @@ pub fn calculate_diff(base: Results, change: Results) -> DiffResults {
     let base_data = build_query_lookup(&base.query_data);
     let change_data = build_query_lookup(&change.query_data);
 
-    let mut all_labels = FxHashSet::with_capacity_and_hasher(base.query_data.len() + change.query_data.len(), Default::default());
+    let mut all_labels = FxHashSet::with_capacity_and_hasher(
+        base.query_data.len() + change.query_data.len(),
+        Default::default(),
+    );
     for query_data in base.query_data.iter().chain(&change.query_data) {
         all_labels.insert(&query_data.label[..]);
     }

summarize/src/main.rs

@@ -1,11 +1,11 @@
 #[macro_use]
 extern crate prettytable;
 
+use analyzeme::ProfilingData;
 use std::error::Error;
 use std::fs::File;
 use std::io::{BufReader, BufWriter};
 use std::path::PathBuf;
-use analyzeme::ProfilingData;
 
 use prettytable::Table;
 use serde::Serialize;