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

Fix connection drain error message (#1844)

Browse Source
This commit is contained in:
Menghan Li
2018-02-05 16:08:15 -08:00
committed by GitHub
parent d09ec43545
commit 104054ade9
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
transport/transport.go
View File

@ -697,13 +697,13 @@ func (e ConnectionError) Origin() error {
var ( var (
// ErrConnClosing indicates that the transport is closing. // ErrConnClosing indicates that the transport is closing.
ErrConnClosing = connectionErrorf(true, nil, "transport is closing") ErrConnClosing = connectionErrorf(true, nil, "transport is closing")
// errStreamDrain indicates that the stream is rejected by the server because // errStreamDrain indicates that the stream is rejected because the
// the server stops accepting new RPCs. // connection is draining. This could be caused by goaway or balancer
// TODO: delete this error; it is no longer necessary. // removing the address.
errStreamDrain = streamErrorf(codes.Unavailable, "the server stops accepting new RPCs") errStreamDrain = streamErrorf(codes.Unavailable, "the connection is draining")
// StatusGoAway indicates that the server sent a GOAWAY that included this // StatusGoAway indicates that the server sent a GOAWAY that included this
// stream's ID in unprocessed RPCs. // stream's ID in unprocessed RPCs.
statusGoAway = status.New(codes.Unavailable, "the server stopped accepting new RPCs") statusGoAway = status.New(codes.Unavailable, "the stream is rejected because server is draining the connection")
) )
// TODO: See if we can replace StreamError with status package errors. // TODO: See if we can replace StreamError with status package errors.