Updating hrtime and added time benchmarks.

Author: kellabyte

Makefile

@@ -1,4 +1,4 @@
-.PHONY: hashing http queues json
+.PHONY: hashing http queues json time
 
 projectpath = ${PWD}
 glidepath = ${PWD}/vendor/github.com/Masterminds/glide
@@ -32,6 +32,17 @@ plot: results
 http:
 	@go build -o build/http/evio http/evio.go
 
+time: results
+	@rm -rf ./results/time.*
+	@go test ./time -benchmem -bench=. | tee ./results/time.log
+	@Rscript plotting/gobench_single_nsop.r ./results/time.log ./results/time.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 1 results/time_p90.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 2 results/time_p99.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 3 results/time_p999.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 4 results/time_p9999.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 5 results/time_p99999.png
+	@Rscript ./plotting/hdr_histogram.r ./results/nanotime.histogram ./results/hrtime.histogram 6 results/time_p999999.png
+
 target:
 	@go build
 

glide.lock

@@ -49,5 +49,5 @@ import:
 - package: github.com/pltr/onering
 - package: github.com/codahale/hdrhistogram
 - package: github.com/tylertreat/hdrhistogram-writer
-- package: github.com/loov/hrtime
 - package: github.com/mailru/easyjson
+- package: github.com/loov/hrtime

glide.yaml

@@ -238,7 +238,7 @@ func recordLatencyDistribution(name string, count int, startNanos []int64, endNa
 
 func recordLatencyDistributionBenchmark(name string, bench *hrtime.BenchmarkTSC) {
 	histogram := hdrhistogram.New(1, 1000000, 5)
-	for _, lap := range bench.Laps {
+	for _, lap := range bench.Laps() {
 		histogram.RecordValue(int64(lap))
 	}
 	histwriter.WriteDistributionFile(histogram, nil, 1.0, "../results/"+name+".histogram")

queues/one_to_one_test.go

@@ -0,0 +1,48 @@
+# Introduction
+This directory includes queue implementation benchmarks for various different time stamp functions.
+
+# Guarantees
+Different time functions have different tradeoffs. 
+
+### Staleness
+_TODO_
+
+# Setup
+```
+Ubuntu Linux
+Intel(R) Xeon(R) CPU E5-2670 v2 @ 2.50GHz x 20 Cores (40 Hyperthreaded)
+L1 Cache:   320 kB
+L2 Cache:  2560 kB
+L3 Cache: 25600 kB
+Memory: 126 GB
+```
+
+# Results
+[![results](../results/time.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time.png)
+
+### p90
+[![results](../results/time_p90.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p90.png)
+### p99
+[![results](../results/time_p99.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p99.png)
+### p999
+[![results](../results/time_p999.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p999.png)
+### p9999
+[![results](../results/time_p9999.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p9999.png)
+### p99999
+[![results](../results/time_p99999.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p99999.png)
+### p999999
+[![results](../results/time_p99999.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p99999.png)
+### p9999999
+[![results](../results/time_p999999.png)](https://github.com/kellabyte/go-benchmarks/raw/master/results/time_p999999.png)
+
+```
+make queues
+
+goos: darwin
+goarch: amd64
+pkg: github.com/kellabyte/go-benchmarks/time
+BenchmarkNanotime-8   	100000000	        18.9 ns/op	  53.00 MB/s	       0 B/op	       0 allocs/op
+BenchmarkHrtime-8     	100000000	        20.6 ns/op	  48.61 MB/s	       0 B/op	       0 allocs/op
+PASS
+ok  	github.com/kellabyte/go-benchmarks/time	11.624s
+```

results/time.png

@@ -0,0 +1,57 @@
+//go:linkname nanotime runtime.nanotime
+package time
+
+import (
+	"testing"
+	_ "unsafe"
+
+	"github.com/codahale/hdrhistogram"
+	"github.com/loov/hrtime"
+	"github.com/tylertreat/hdrhistogram-writer"
+)
+
+func nanotime() int64
+
+func BenchmarkNanotime(b *testing.B) {
+	startNanos := make([]int64, b.N)
+	endNanos := make([]int64, b.N)
+
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		startNanos[i] = nanotime()
+		endNanos[i] = nanotime()
+		b.SetBytes(1)
+	}
+
+	b.StopTimer()
+	recordLatencyDistribution("nanotime", b.N, startNanos, endNanos)
+}
+
+func BenchmarkHrtime(b *testing.B) {
+	bench := hrtime.NewBenchmarkTSC(b.N)
+
+	b.ResetTimer()
+	for bench.Next() {
+		b.SetBytes(1)
+	}
+
+	b.StopTimer()
+	recordLatencyDistributionBenchmark("hrtime", bench)
+}
+
+func recordLatencyDistribution(name string, count int, startNanos []int64, endNanos []int64) {
+	histogram := hdrhistogram.New(1, 1000000, 5)
+	for i := 0; i < count; i++ {
+		diff := endNanos[i] - startNanos[i]
+		histogram.RecordValue(diff)
+	}
+	histwriter.WriteDistributionFile(histogram, nil, 1.0, "../results/"+name+".histogram")
+}
+
+func recordLatencyDistributionBenchmark(name string, bench *hrtime.BenchmarkTSC) {
+	histogram := hdrhistogram.New(1, 1000000, 5)
+	for _, lap := range bench.Laps() {
+		histogram.RecordValue(int64(lap))
+	}
+	histwriter.WriteDistributionFile(histogram, nil, 1.0, "../results/"+name+".histogram")
+}