| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ClientTransportLifecycleManager.java | 26 private boolean transportShutdown; field in ClientTransportLifecycleManager
39 if (transportReady || transportShutdown) { in notifyReady()
47 if (transportShutdown) { in notifyShutdown()
50 transportShutdown = true; in notifyShutdown()
53 listener.transportShutdown(s); in notifyShutdown()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | InternalSubchannelTest.java | 188 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
213 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED); in singleAddressReconnect()
245 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
284 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
297 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
322 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
333 transports.poll().listener.transportShutdown(Status.RESOURCE_EXHAUSTED); in twoAddressesReconnect()
364 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
377 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
386 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
[all …]
|
| D | DelayedClientTransportTest.java | 149 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in newStreamThenAssignTransportThenShutdown()
159 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in transportTerminatedThenAssignTransport()
168 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in assignTransportThenShutdownThenNewStream()
180 verify(transportListener).transportShutdown(any(Status.class)); in assignTransportThenShutdownNowThenNewStream()
215 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in newStreamThenShutdownTransportThenAssignTransport()
245 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in newStreamThenShutdownTransportThenCancelStream()
257 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in shutdownThenNewStream()
270 verify(transportListener).transportShutdown(any(Status.class)); in startStreamThenShutdownNow()
278 verify(transportListener).transportShutdown(any(Status.class)); in shutdownNowThenNewStream()
437 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in reprocessSemantics()
|
| D | ManagedChannelImplTest.java | 540 transportListener.transportShutdown(Status.UNAVAILABLE); in subtestCallsAndShutdown()
668 transportListener.transportShutdown(Status.UNAVAILABLE); in callOptionsExecutor()
868 badTransportInfo.listener.transportShutdown(Status.UNAVAILABLE); in firstResolvedServerFailedToConnect()
1012 transportInfo1.listener.transportShutdown(Status.UNAVAILABLE); in allServersFailedToConnect()
1019 transportInfo2.listener.transportShutdown(server2Error); in allServersFailedToConnect()
1099 transportInfo1.listener.transportShutdown(Status.UNAVAILABLE); in subchannels()
1101 transportInfo2.listener.transportShutdown(Status.UNAVAILABLE); in subchannels()
1125 ti1.listener.transportShutdown(Status.UNAVAILABLE.withDescription("shutdown now")); in subchannelsWhenChannelShutdownNow()
1126 ti2.listener.transportShutdown(Status.UNAVAILABLE.withDescription("shutdown now")); in subchannelsWhenChannelShutdownNow()
1194 transportInfo.listener.transportShutdown(Status.UNAVAILABLE); in oobchannels()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedClientTransport.java | 82 void transportShutdown(Status s); in transportShutdown() method
|
| D | DelayedClientTransport.java | 215 listener.transportShutdown(status); in shutdown()
|
| D | OobChannel.java | 117 public void transportShutdown(Status s) { in OobChannel()
|
| D | InternalSubchannel.java | 580 public void transportShutdown(Status s) { in transportShutdown() method in InternalSubchannel.TransportListener
|
| D | ManagedChannelImpl.java | 1480 public void transportShutdown(Status s) { in transportShutdown() method in ManagedChannelImpl.DelayedTransportListener
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 296 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameThrowIoException()
322 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameThrowsError()
338 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameReturnFalse()
379 verify(transportListener).transportShutdown(isA(Status.class)); in receivedHeadersForInvalidStreamShouldKillConnection()
390 verify(transportListener).transportShutdown(isA(Status.class)); in receivedDataForInvalidStreamShouldKillConnection()
812 verify(transportListener).transportShutdown(same(SHUTDOWN_REASON)); in stopNormally()
846 verify(transportListener).transportShutdown(isA(Status.class)); in receiveGoAway()
917 verify(transportListener).transportShutdown(isA(Status.class)); in streamIdExhausted()
1224 verify(transportListener).transportShutdown(isA(Status.class)); in receiveDataForUnknownStreamUpdateConnectionWindow()
1244 verify(transportListener).transportShutdown(isA(Status.class)); in receiveWindowUpdateForUnknownStream()
[all …]
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientTransportTest.java | 114 verify(clientTransportListener).transportShutdown(any(Status.class)); in shutdownTransport()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 216 listener.transportShutdown(status);
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 298 inOrder.verify(mockClientTransportListener).transportShutdown(statusCaptor.capture()); in serverNotListening()
314 inOrder.verify(mockClientTransportListener).transportShutdown(same(shutdownReason)); in clientStartStop()
330 inOrder.verify(mockClientTransportListener).transportShutdown(any(Status.class)); in clientStartAndStopOnceConnected()
385 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportShutdown(any(Status.class)); in openStreamPreventsTermination()
434 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportShutdown(any(Status.class)); in shutdownNowKillsClientStream()
471 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportShutdown(any(Status.class)); in shutdownNowKillsServerStream()
517 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportShutdown(any(Status.class)); in ping_duringShutdown()
563 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportShutdown(any(Status.class)); in newStream_duringShutdown()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 678 listener.transportShutdown(goAwayStatus); in shutdown()
751 listener.transportShutdown(status); in startGoAway()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 253 clientTransportListener.transportShutdown(s);
|