File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
binder/src/main/java/io/grpc/binder/internal
cronet/src/main/java/io/grpc/cronet Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change 5454import io .grpc .internal .GrpcUtil ;
5555import io .grpc .internal .ManagedClientTransport ;
5656import io .grpc .internal .ObjectPool ;
57+ import io .grpc .internal .SimpleDisconnectError ;
5758import io .grpc .internal .StatsTraceContext ;
5859import java .util .concurrent .Executor ;
5960import java .util .concurrent .ScheduledFuture ;
@@ -303,7 +304,7 @@ public synchronized void shutdownNow(Status reason) {
303304 @ Override
304305 @ GuardedBy ("this" )
305306 void notifyShutdown (Status status ) {
306- clientTransportListener .transportShutdown (status );
307+ clientTransportListener .transportShutdown (status , SimpleDisconnectError . SUBCHANNEL_SHUTDOWN );
307308 }
308309
309310 @ Override
Original file line number Diff line number Diff line change 3434import io .grpc .internal .ConnectionClientTransport ;
3535import io .grpc .internal .GrpcAttributes ;
3636import io .grpc .internal .GrpcUtil ;
37+ import io .grpc .internal .SimpleDisconnectError ;
3738import io .grpc .internal .StatsTraceContext ;
3839import io .grpc .internal .TransportTracer ;
3940import java .net .InetSocketAddress ;
@@ -229,7 +230,7 @@ private void startGoAway(Status status) {
229230 startedGoAway = true ;
230231 }
231232
232- listener .transportShutdown (status );
233+ listener .transportShutdown (status , SimpleDisconnectError . SUBCHANNEL_SHUTDOWN );
233234
234235 synchronized (lock ) {
235236 goAway = true ;
You can’t perform that action at this time.
0 commit comments