diff options
author | Jakob Unterwurzacher | 2015-09-17 22:08:49 +0200 |
---|---|---|
committer | Jakob Unterwurzacher | 2015-09-17 22:08:49 +0200 |
commit | 67fe4557e5225f5be1687aca3d1934ad1141a684 (patch) | |
tree | 7f8bc19e41eaba5a59109f46de6aa8b72809af96 /main_test.go | |
parent | 338925aef45d8ec960e1ba4d160dbb3848bd7a9d (diff) |
Fix read benchmark
Diffstat (limited to 'main_test.go')
-rw-r--r-- | main_test.go | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/main_test.go b/main_test.go index 6157e5a..0dfa06a 100644 --- a/main_test.go +++ b/main_test.go @@ -129,11 +129,30 @@ func BenchmarkStreamWrite(t *testing.B) { t.FailNow() } } + file.Close() } func BenchmarkStreamRead(t *testing.B) { buf := make([]byte, 1024*1024) t.SetBytes(int64(len(buf))) + + if t.N > 100 { + // Grow file so we can satisfy the test + f2, err := os.OpenFile(plainDir + "BenchmarkWrite", os.O_WRONLY | os.O_APPEND, 0666) + if err != nil { + fmt.Println(err) + t.FailNow() + } + for h := 0; h < t.N - 100 ; h++ { + _, err = f2.Write(buf) + if err != nil { + fmt.Println(err) + t.FailNow() + } + } + f2.Close() + } + file, err := os.Open(plainDir + "BenchmarkWrite") if err != nil { t.FailNow() @@ -150,4 +169,5 @@ func BenchmarkStreamRead(t *testing.B) { t.FailNow() } } + file.Close() } |