mirror of https://github.com/grpc/grpc-java.git
Netty client shutdown would race with the negotiation handling and circumvent AbstractBufferingHandler. Use a new command in order to leave channel.close() available for abrupt killing of the connection when connecting. ping_afterTermination was previously racey that made it succeed. After fixing the test, Netty would consistently fail to call callback. After fixing Netty to fail the callback it was not using the right status because when Netty's channel is closed none of our handlers are run. This reliably fails the future with ClosedChannelException, which is useless, so now we special-case that exception and fill in the reason for shutdown. To prevent accidentally reporting Status.OK, the transports no longer use OK when calling transportShutdown. The OK status was already no longer being consumed, since keying off whether transportReady was called is more helpful. This fixes #1330 |
||
|---|---|---|
| .. | ||
| src/main | ||
| build.gradle | ||