explicit buffer size for phout writer (4MB)

yandex · Dec 27, 2015 · 865daeb · 865daeb
1 parent 70471e4
commit 865daeb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aggregate/phout.go b/aggregate/phout.go
@@ -101,7 +101,7 @@ func NewPhoutResultListener(filename string) (rl ResultListener, err error) {
 	} else {
 		phoutFile, err = os.OpenFile(filename, os.O_APPEND|os.O_WRONLY|os.O_CREATE|os.O_SYNC, 0666)
 	}
-	writer := bufio.NewWriter(phoutFile)
+	writer := bufio.NewWriterSize(phoutFile, 1024*1024*4)
 	ch := make(chan Sample, 65536)
 	return &PhoutResultListener{
 		source: ch,