summaryrefslogtreecommitdiff
path: root/pkg/server/queue/queue.go
diff options
context:
space:
mode:
authorMikhail Osipov <mike.osipov@gmail.com>2020-09-02 22:20:13 +0300
committerMikhail Osipov <mike.osipov@gmail.com>2020-09-03 01:24:44 +0300
commit9cd014c3d6872582854e36a4df6c0a4633f3eb57 (patch)
treec86d21965bc623a1e8693bb638e7ba39fc46f153 /pkg/server/queue/queue.go
parent144f66574706c9e251c964b694e80406206cb10b (diff)
fix data steal by proxy
Diffstat (limited to 'pkg/server/queue/queue.go')
-rw-r--r--pkg/server/queue/queue.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/pkg/server/queue/queue.go b/pkg/server/queue/queue.go
index 704d884..f0c1fc9 100644
--- a/pkg/server/queue/queue.go
+++ b/pkg/server/queue/queue.go
@@ -79,6 +79,10 @@ func (q Q) Dry() {
}
func (w *writer) Write(p []byte) (int, error) {
+ if len(p) == 0 {
+ return 0, nil
+ }
+
buf := make([]byte, len(p))
copy(buf, p)
w.q <- buf