Skip to content

Commit 91997c9

Browse files
committed
fixes test cases
1 parent 1bc9f1a commit 91997c9

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

binder/src/main/java/io/grpc/binder/internal/BinderClientTransport.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@
5454
import io.grpc.internal.GrpcUtil;
5555
import io.grpc.internal.ManagedClientTransport;
5656
import io.grpc.internal.ObjectPool;
57+
import io.grpc.internal.SimpleDisconnectError;
5758
import io.grpc.internal.StatsTraceContext;
5859
import java.util.concurrent.Executor;
5960
import 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

cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import io.grpc.internal.ConnectionClientTransport;
3535
import io.grpc.internal.GrpcAttributes;
3636
import io.grpc.internal.GrpcUtil;
37+
import io.grpc.internal.SimpleDisconnectError;
3738
import io.grpc.internal.StatsTraceContext;
3839
import io.grpc.internal.TransportTracer;
3940
import 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;

0 commit comments

Comments
 (0)