mirror-github-speiceio/marketdata-shootout
1
0
Fork 0
mirror of https://github.com/speice-io/marketdata-shootout synced 2024-11-21 15:39:07 -05:00
Code Issues Releases Wiki Activity

Add a log for overall analysis run time

Browse Source
This commit is contained in:
Bradlee Speice 2019-09-07 00:57:36 -04:00
parent 6628b5b6cd
commit 952576b579
1 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/main.rs
View File

@ -6,7 +6,7 @@ use std::io::Error;
use std::io::{BufRead, Read}; use std::io::{BufRead, Read};
use std::path::Path; use std::path::Path;
use std::str::from_utf8_unchecked; use std::str::from_utf8_unchecked;
use std::time::Instant; use std::time::{Instant, SystemTime};
use clap::{App, Arg}; use clap::{App, Arg};
use hdrhistogram::Histogram; use hdrhistogram::Histogram;
@ -50,37 +50,60 @@ fn main() {
file.read_to_end(&mut buf) file.read_to_end(&mut buf)
.expect(&format!("Unable to read file={}", path.display())); .expect(&format!("Unable to read file={}", path.display()));
let analysis_start = SystemTime::now();
let capnp_unpacked = run_analysis( let capnp_unpacked = run_analysis(
&buf, &buf,
&mut capnp_runner::CapnpWriter::new(false), &mut capnp_runner::CapnpWriter::new(false),
&mut capnp_runner::CapnpReader::new(false), &mut capnp_runner::CapnpReader::new(false),
); );
let analysis_end = SystemTime::now()
.duration_since(analysis_start)
.unwrap()
.as_secs();
println!("Cap'n Proto Unpacked total time={}s", analysis_end);
println!("Cap'n Proto Unpacked:\n{}\n", capnp_unpacked.timing_stats()); println!("Cap'n Proto Unpacked:\n{}\n", capnp_unpacked.timing_stats());
let analysis_start = SystemTime::now();
let capnp_packed = run_analysis( let capnp_packed = run_analysis(
&buf, &buf,
&mut capnp_runner::CapnpWriter::new(true), &mut capnp_runner::CapnpWriter::new(true),
&mut capnp_runner::CapnpReader::new(true), &mut capnp_runner::CapnpReader::new(true),
); );
let analysis_end = SystemTime::now()
.duration_since(analysis_start)
.unwrap()
.as_secs();
println!("Cap'n Proto Packed total time={}s", analysis_end);
assert_eq!(capnp_unpacked.summary_stats, capnp_packed.summary_stats); assert_eq!(capnp_unpacked.summary_stats, capnp_packed.summary_stats);
println!("Cap'n Proto Packed:\n{}\n", capnp_packed.timing_stats()); println!("Cap'n Proto Packed:\n{}\n", capnp_packed.timing_stats());
let analysis_start = SystemTime::now();
let flatbuffers = run_analysis( let flatbuffers = run_analysis(
&buf, &buf,
&mut flatbuffers_runner::FlatbuffersWriter::new(), &mut flatbuffers_runner::FlatbuffersWriter::new(),
&mut flatbuffers_runner::FlatbuffersReader::new(), &mut flatbuffers_runner::FlatbuffersReader::new(),
); );
let analysis_end = SystemTime::now()
.duration_since(analysis_start)
.unwrap()
.as_secs();
println!("Flatbuffers total time={}s", analysis_end);
assert_eq!(capnp_packed.summary_stats, flatbuffers.summary_stats); assert_eq!(capnp_packed.summary_stats, flatbuffers.summary_stats);
println!("Flatbuffers:\n{}\n", flatbuffers.timing_stats()); println!("Flatbuffers:\n{}\n", flatbuffers.timing_stats());
let analysis_start = SystemTime::now();
let sbe = run_analysis( let sbe = run_analysis(
&buf, &buf,
&mut sbe_runner::SBEWriter::new(), &mut sbe_runner::SBEWriter::new(),
&mut sbe_runner::SBEReader::new(), &mut sbe_runner::SBEReader::new(),
); );
let analysis_end = SystemTime::now()
.duration_since(analysis_start)
.unwrap()
.as_secs();
println!("SBE total time={}s", analysis_end);
assert_eq!(flatbuffers.summary_stats, sbe.summary_stats); assert_eq!(flatbuffers.summary_stats, sbe.summary_stats);
println!("SBE:\n{}\n", sbe.timing_stats()); println!("SBE:\n{}\n", sbe.timing_stats());