| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ClientTransportLifecycleManager.java | 27 private boolean transportInUse; field in ClientTransportLifecycleManager
57 if (inUse == transportInUse) { in notifyInUse()
60 transportInUse = inUse; in notifyInUse()
61 listener.transportInUse(inUse); in notifyInUse()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 302 verify(mockClientTransportListener, never()).transportInUse(anyBoolean()); in serverNotListening()
316 verify(mockClientTransportListener, never()).transportInUse(anyBoolean()); in clientStartStop()
336 verify(mockClientTransportListener, never()).transportInUse(anyBoolean()); in clientStartAndStopOnceConnected()
373 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(true); in openStreamPreventsTermination()
403 verify(mockClientTransportListener, never()).transportInUse(false); in openStreamPreventsTermination()
409 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(false); in openStreamPreventsTermination()
425 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(true); in shutdownNowKillsClientStream()
436 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(false); in shutdownNowKillsClientStream()
462 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(true); in shutdownNowKillsServerStream()
473 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportInUse(false); in shutdownNowKillsServerStream()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedClientTransport.java | 104 void transportInUse(boolean inUse); in transportInUse() method
|
| D | DelayedClientTransport.java | 105 listener.transportInUse(true); in start()
111 listener.transportInUse(false); in start()
|
| D | OobChannel.java | 132 public void transportInUse(boolean inUse) { in OobChannel()
|
| D | InternalSubchannel.java | 575 public void transportInUse(boolean inUse) { in transportInUse() method in InternalSubchannel.TransportListener
|
| D | ManagedChannelImpl.java | 1490 public void transportInUse(final boolean inUse) { in transportInUse() method in ManagedChannelImpl.DelayedTransportListener
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | InternalSubchannelTest.java | 830 t0.listener.transportInUse(true); in inUseState()
833 t0.listener.transportInUse(false); in inUseState()
836 t0.listener.transportInUse(true); in inUseState()
845 t1.listener.transportInUse(true); in inUseState()
849 t1.listener.transportInUse(false); in inUseState()
853 t0.listener.transportInUse(false); in inUseState()
868 t0.listener.transportInUse(true); in transportTerminateWithoutExitingInUse()
|
| D | ManagedChannelImplIdlenessTest.java | 281 t0.listener.transportInUse(true); in realTransportsHoldsOffIdleness()
288 t0.listener.transportInUse(false); in realTransportsHoldsOffIdleness()
379 oobTransportInfo.listener.transportInUse(true); in oobTransportDoesNotAffectIdleness()
|
| D | DelayedClientTransportTest.java | 308 verify(transportListener).transportInUse(true); in reprocessSemantics()
403 verify(transportListener, never()).transportInUse(false); in reprocessSemantics()
407 verify(transportListener).transportInUse(false); in reprocessSemantics()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 292 clientTransportListener.transportInUse(false);
656 clientTransportListener.transportInUse(true);
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 867 listener.transportInUse(false); in maybeClearInUse()
882 listener.transportInUse(true); in setInUse()
|