From 4b9b1a6d15109832074898e047bf38a1aa37cc33 Mon Sep 17 00:00:00 2001
From: unclejack <unclejacksons@gmail.com>
Date: Wed, 1 Apr 2015 00:23:04 +0300
Subject: [PATCH] pkg/broadcastwriter: reset after 4 KB w/o stream

Signed-off-by: Cristian Staretu <cristian.staretu@gmail.com>
Upstream-commit: 153f98bad51e2f46cf3853d2da0173bcfb4b687d
Component: engine
---
 components/engine/pkg/broadcastwriter/broadcastwriter.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/components/engine/pkg/broadcastwriter/broadcastwriter.go b/components/engine/pkg/broadcastwriter/broadcastwriter.go
index 248cd8f466..bd9b675553 100644
--- a/components/engine/pkg/broadcastwriter/broadcastwriter.go
+++ b/components/engine/pkg/broadcastwriter/broadcastwriter.go
@@ -42,9 +42,12 @@ func (w *BroadcastWriter) Write(p []byte) (n int, err error) {
 				delete(writers, sw)
 			}
 		}
-		// exit if there is no more writers
 		if len(w.streams) == 1 {
-			w.buf.Reset()
+			if w.buf.Len() >= 4096 {
+				w.buf.Reset()
+			} else {
+				w.buf.Write(p)
+			}
 			w.Unlock()
 			return len(p), nil
 		}