| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ClientTransportLifecycleManager.java | 25 private boolean transportReady; field in ClientTransportLifecycleManager
39 if (transportReady || transportShutdown) { in notifyReady()
42 transportReady = true; in notifyReady()
43 listener.transportReady(); in notifyReady()
|
| D | NettyServerHandler.java | 714 attributes = transportListener.transportReady(negotiationAttributes); in onSettingsRead()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplIdlenessTest.java | 268 t0.listener.transportReady(); in realTransportsHoldsOffIdleness()
308 t0.listener.transportReady(); in updateSubchannelAddresses_newAddressConnects()
314 t1.listener.transportReady(); in updateSubchannelAddresses_newAddressConnects()
328 t0.listener.transportReady(); in updateSubchannelAddresses_existingAddressDoesNotConnect()
398 t0.listener.transportReady(); in updateOobChannelAddresses_newAddressConnects()
404 t1.listener.transportReady(); in updateOobChannelAddresses_newAddressConnects()
418 t0.listener.transportReady(); in updateOobChannelAddresses_existingAddressDoesNotConnect()
|
| D | InternalSubchannelTest.java | 236 transports.peek().listener.transportReady(); in singleAddressReconnect()
355 transports.peek().listener.transportReady(); in twoAddressesReconnect()
445 transports.peek().listener.transportReady(); in updateAddresses_intersecting_ready()
501 transports.peek().listener.transportReady(); in updateAddresses_intersecting_connecting()
566 transports.peek().listener.transportReady(); in updateAddresses_disjoint_ready()
664 transports.peek().listener.transportReady(); in connectIsLazy()
688 transportInfo.listener.transportReady(); in shutdownWhenReady()
782 t1.listener.transportReady(); in shutdownNow()
828 t0.listener.transportReady(); in inUseState()
843 t1.listener.transportReady(); in inUseState()
[all …]
|
| D | ServerImplTest.java | 411 transportListener.transportReady(Attributes.EMPTY); in methodNotFound()
438 transportListener.transportReady(Attributes.EMPTY); in decompressorNotFound()
491 transportListener.transportReady(Attributes.EMPTY); in basicExchangeHelper()
578 public Attributes transportReady(Attributes attrs) { in transportFilters()
597 public Attributes transportReady(Attributes attrs) { in transportFilters()
626 Attributes transportAttrs = transportListener.transportReady(Attributes.newBuilder() in transportFilters()
698 transportListener.transportReady(Attributes.EMPTY); in interceptors()
743 transportListener.transportReady(Attributes.EMPTY); in exceptionInStartCallPropagatesToStream()
905 transportListener.transportReady(Attributes.EMPTY); in testCallContextIsBoundInListenerCallbacks()
971 transportListener.transportReady(Attributes.EMPTY); in testClientClose_setup()
[all …]
|
| D | ManagedChannelImplTest.java | 450 transportListener.transportReady(); in subtestCallsAndShutdown()
581 transportInfo1.listener.transportReady(); in noMoreCallbackAfterLoadBalancerShutdown()
600 transportInfo2.listener.transportReady(); in noMoreCallbackAfterLoadBalancerShutdown()
648 transportListener.transportReady(); in callOptionsExecutor()
880 goodTransportInfo.listener.transportReady(); in firstResolvedServerFailedToConnect()
1119 ti1.listener.transportReady(); in subchannelsWhenChannelShutdownNow()
1120 ti2.listener.transportReady(); in subchannelsWhenChannelShutdownNow()
1189 transportInfo.listener.transportReady(); in oobchannels()
1280 ti1.listener.transportReady(); in oobChannelsWhenChannelShutdownNow()
1281 ti2.listener.transportReady(); in oobChannelsWhenChannelShutdownNow()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ServerTransportFilter.java | 45 public Attributes transportReady(Attributes transportAttrs) { in transportReady() method in ServerTransportFilter
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerTransportListener.java | 43 Attributes transportReady(Attributes attributes); in transportReady() method
|
| D | ManagedClientTransport.java | 98 void transportReady(); in transportReady() method
|
| D | ServerImpl.java | 393 public Attributes transportReady(Attributes attributes) { in transportReady() method in ServerImpl.ServerTransportListenerImpl
398 attributes = Preconditions.checkNotNull(filter.transportReady(attributes), in transportReady()
|
| D | OobChannel.java | 127 public void transportReady() { in OobChannel()
|
| D | InternalSubchannel.java | 546 public void transportReady() { in transportReady() method in InternalSubchannel.TransportListener
|
| D | ManagedChannelImpl.java | 246 public void transportReady() {
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientTransportTest.java | 79 verify(clientTransportListener).transportReady(); in setUp()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 159 CronetClientTransport.this.listener.transportReady(); in start()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 136 serverStreamAttributes = serverTransportListener.transportReady(serverTransportAttrs); in start()
137 clientTransportListener.transportReady(); in start()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 301 verify(mockClientTransportListener, never()).transportReady(); in serverNotListening()
325 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportReady(); in clientStartAndStopOnceConnected()
346 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportReady(); in checkClientAttributes()
534 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportReady(); in ping_afterTermination()
596 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportReady(); in newStream_afterTermination()
1814 verify(listener, timeout(100)).transportReady(); in startTransport()
1865 public Attributes transportReady(Attributes attributes) { in transportReady() method in AbstractTransportTest.MockServerTransportListener
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 151 public Attributes transportReady(Attributes attributes) { in transportReady() method in NettyServerHandlerTest.ServerTransportListenerImpl
208 verify(transportListener, never()).transportReady(any(Attributes.class)); in transportReadyDelayedUntilConnectionPreface()
213 verify(transportListener).transportReady(any(Attributes.class)); in transportReadyDelayedUntilConnectionPreface()
|
| D | NettyClientTransportTest.java | 771 public Attributes transportReady(Attributes transportAttrs) { in transportCreated() method in NettyClientTransportTest.EchoServerListener
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 1087 listener.transportReady(); in settings()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 1311 public void transportReady() throws Exception { in transportReady() method in OkHttpClientTransportTest
1315 verify(transportListener).transportReady(); in transportReady()
|