From cce30a4d6a065b2b7f115057b0c1c2b5742c3247 Mon Sep 17 00:00:00 2001 From: vyzo Date: Mon, 18 Nov 2019 17:33:53 +0200 Subject: [PATCH] reset remote tracer stream on errors --- tracer.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/tracer.go b/tracer.go index 3893cb3..5d7619d 100644 --- a/tracer.go +++ b/tracer.go @@ -214,12 +214,17 @@ func (t *RemoteTracer) doWrite() { end: if !ok { - gzipW.Close() - helpers.FullClose(s) + if err != nil { + s.Reset() + } else { + gzipW.Close() + helpers.FullClose(s) + } return } if err != nil { + s.Reset() s, err = t.openStream() if err != nil { log.Errorf("error opening remote tracer stream: %s", err.Error())