Skip to content

Commit 8890bac

Browse files
committed
* Fixed false-positive banning of conn on receiving from stream io.EOF
1 parent 0fb8af4 commit 8890bac

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
* Fixed false-positive banning of conn on receiving from stream io.EOF
2+
13
## v3.28.2
24
* Upgraded dependencies (grpc, protobuf, testify)
35

internal/conn/grpc_client_stream.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ package conn
33
import (
44
"context"
55
"errors"
6+
"io"
67
"time"
78

89
"google.golang.org/grpc"
@@ -98,7 +99,9 @@ func (s *grpcClientStream) RecvMsg(m interface{}) (err error) {
9899
err = xerrors.WithStackTrace(err)
99100
}
100101

101-
s.c.onTransportError(s.Context(), err)
102+
if !xerrors.Is(err, io.EOF) {
103+
s.c.onTransportError(s.Context(), err)
104+
}
102105

103106
return err
104107
}

0 commit comments

Comments
 (0)