reset remote tracer stream on errors

2019-11-18 17:33:53 +02:00 · 2019-11-18 17:33:53 +02:00 · cce30a4d6a
parent abe4763c01
commit cce30a4d6a
1 changed files with 7 additions and 2 deletions
--- 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())