stats: add WireLength to stats.InPayload (#2692) (#2711)

2019-03-26 06:42:16 +08:00
parent 6d8271a06c
commit ed10349f45
1 changed files with 6 additions and 4 deletions
--- a/stream.go
+++ b/stream.go
@ -882,6 +882,7 @@ func (a *csAttempt) recvMsg(m interface{}, payInfo *payloadInfo) (err error) {
 			Payload:  m,
 			// TODO truncate large payload.
 			Data:       payInfo.uncompressedBytes,
+			WireLength: payInfo.wireLength,
 			Length:     len(payInfo.uncompressedBytes),
 		})
 	}
@ -1468,6 +1469,7 @@ func (ss *serverStream) RecvMsg(m interface{}) (err error) {
 			Payload:  m,
 			// TODO truncate large payload.
 			Data:       payInfo.uncompressedBytes,
+			WireLength: payInfo.wireLength,
 			Length:     len(payInfo.uncompressedBytes),
 		})
 	}