opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

move inPayload.RecvTime to after unmarshal

Browse Source
This commit is contained in:
Menghan Li
2016-11-07 16:09:26 -08:00
parent d23fdd776b
commit 3f9a96ea71
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
rpc_util.go
View File

@ -331,7 +331,6 @@ func recv(p *parser, c Codec, s *transport.Stream, dc Decompressor, m interface{
return err
}
if inPayload != nil {
inPayload.RecvTime = time.Now()
inPayload.WireLength = len(d)
}
if err := checkRecvPayload(pf, s.RecvCompress(), dc); err != nil {
@ -352,6 +351,7 @@ func recv(p *parser, c Codec, s *transport.Stream, dc Decompressor, m interface{
return Errorf(codes.Internal, "grpc: failed to unmarshal the received message %v", err)
}
if inPayload != nil {
inPayload.RecvTime = time.Now()
inPayload.Payload = m
// TODO truncate large payload.
inPayload.Data = d