Skip to content

Commit

Permalink
transport: Track outoingMsg release status
Browse files Browse the repository at this point in the history
This was not correctly tracked.
  • Loading branch information
matheusd committed Aug 13, 2024
1 parent 6000253 commit df83d72
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions rpc/transport/transport.go
Original file line number Diff line number Diff line change
Expand Up @@ -219,6 +219,7 @@ type outgoingMsg struct {

func (o *outgoingMsg) Release() {
if m := o.message.Message(); !o.released && m != nil {
o.released = true
m.Release()
}
}
Expand Down

0 comments on commit df83d72

Please sign in to comment.