fix #775; correct size of separator

slimus · Jun 23, 2020 · 46328d3 · 46328d3
1 parent 7191f0b
commit 46328d3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/output_file.go b/output_file.go
@@ -226,9 +226,11 @@ func (o *FileOutput) Write(data []byte) (n int, err error) {
 	}
 
 	n, _ = o.writer.Write(data)
-	o.writer.Write([]byte(payloadSeparator))
+	nSeparator, _ := o.writer.Write([]byte(payloadSeparator))
 
-	o.totalFileSize += int64(n + len(payloadSeparator))
+	n += nSeparator
+
+	o.totalFileSize += int64(n)
 	o.queueLength++
 
 	if Settings.outputFileConfig.outputFileMaxSize > 0 && o.totalFileSize >= Settings.outputFileConfig.outputFileMaxSize {