reset buf before calling EncodeConnectionDirect

Author: brycekahle

pkg/network/encoding/marshal/usm_http.go

@@ -37,7 +37,6 @@ func newHTTPEncoder(httpPayloads map[http.Key]*http.RequestStats) *httpEncoder {
 }
 
 func (e *httpEncoder) EncodeConnectionDirect(c network.ConnectionStats, conn *model.Connection, buf *bytes.Buffer) (staticTags uint64, dynamicTags map[string]struct{}) {
-	buf.Reset()
 	staticTags, dynamicTags = e.encodeData(c, buf)
 	conn.HttpAggregations = buf.Bytes()
 	return

pkg/network/encoding/marshal/usm_http2.go

@@ -37,7 +37,6 @@ func newHTTP2Encoder(http2Payloads map[http.Key]*http.RequestStats) *http2Encode
 }
 
 func (e *http2Encoder) EncodeConnectionDirect(c network.ConnectionStats, conn *model.Connection, buf *bytes.Buffer) (staticTags uint64, dynamicTags map[string]struct{}) {
-	buf.Reset()
 	staticTags, dynamicTags = e.encodeData(c, buf)
 	conn.Http2Aggregations = buf.Bytes()
 	return

pkg/network/encoding/marshal/usm_kafka.go

@@ -37,7 +37,6 @@ func newKafkaEncoder(kafkaPayloads map[kafka.Key]*kafka.RequestStats) *kafkaEnco
 }
 
 func (e *kafkaEncoder) EncodeConnectionDirect(c network.ConnectionStats, conn *model.Connection, buf *bytes.Buffer) (staticTags uint64, dynamicTags map[string]struct{}) {
-	buf.Reset()
 	staticTags = e.encodeData(c, buf)
 	conn.DataStreamsAggregations = buf.Bytes()
 	return

pkg/network/encoding/marshal/usm_postgres.go

@@ -37,7 +37,6 @@ func newPostgresEncoder(postgresPayloads map[postgres.Key]*postgres.RequestStat)
 }
 
 func (e *postgresEncoder) EncodeConnectionDirect(c network.ConnectionStats, conn *model.Connection, buf *bytes.Buffer) (staticTags uint64, dynamicTags map[string]struct{}) {
-	buf.Reset()
 	staticTags = e.encodeData(c, buf)
 	conn.DatabaseAggregations = buf.Bytes()
 	return

pkg/network/encoding/marshal/usm_redis.go

@@ -37,7 +37,6 @@ func newRedisEncoder(redisPayloads map[redis.Key]*redis.RequestStats) *redisEnco
 }
 
 func (e *redisEncoder) EncodeConnectionDirect(c network.ConnectionStats, conn *model.Connection, buf *bytes.Buffer) (staticTags uint64, dynamicTags map[string]struct{}) {
-	buf.Reset()
 	staticTags = e.encodeData(c, buf)
 	conn.DatabaseAggregations = buf.Bytes()
 	return

pkg/network/sender/tags.go

@@ -117,6 +117,7 @@ func (d *directSender) addTags(nc network.ConnectionStats, c *model.Connection,
 	var staticTags uint64
 	dynamicTags := nc.TLSTags.GetDynamicTags()
 	for _, encoder := range usmEncoders {
+		d.encodeBuf.Reset()
 		encoderStaticTags, encoderDynamicTags := encoder.EncodeConnectionDirect(nc, c, &d.encodeBuf)
 		staticTags |= encoderStaticTags
 		dynamicTags = mergeDynamicTags(dynamicTags, encoderDynamicTags)