Compare commits

..

1 commit

Author SHA1 Message Date
593dd77d84
[#327] rpc: Fix mem leak
All checks were successful
DCO / DCO (pull_request) Successful in 26s
Tests and linters / Tests (pull_request) Successful in 1m20s
Code generation / Generate proto (pull_request) Successful in 33s
Tests and linters / Lint (pull_request) Successful in 2m16s
gRPC stream must be closed by `cancel` to prevent memleak.

Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
2025-01-30 12:53:43 +03:00

View file

@ -109,7 +109,9 @@ func (s *serverStreamReaderCloser) ReadMessage(msg message.Message) error {
err = s.rw.ReadMessage(msg)
if !errors.Is(err, io.EOF) {
s.rw.cancel()
if err != nil {
s.rw.cancel()
}
return err
}