/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | InternalSubchannelTest.java | 163 .newClientTransport(addr, createClientTransportOptions().setEagAttributes(attr)); in eagAttribute_propagatesToTransport() 184 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 200 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 208 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 225 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 233 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 255 .newClientTransport(addr, createClientTransportOptions()); in singleAddressReconnect() 281 .newClientTransport(addr1, createClientTransportOptions()); in twoAddressesReconnect() 293 .newClientTransport(addr2, createClientTransportOptions()); in twoAddressesReconnect() 313 .newClientTransport(addr1, createClientTransportOptions()); in twoAddressesReconnect() [all …]
|
D | CallCredentials2ApplyingTest.java | 109 when(mockTransportFactory.newClientTransport(address, clientTransportOptions)) in setUp() 116 transportFactory.newClientTransport(address, clientTransportOptions); in setUp() 118 verify(mockTransportFactory).newClientTransport(address, clientTransportOptions); in setUp()
|
D | ManagedChannelImplTest.java | 440 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in subtestCallsAndShutdown() 461 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in subtestCallsAndShutdown() 549 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in subtestCallsAndShutdown() 575 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in noMoreCallbackAfterLoadBalancerShutdown() 638 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in callOptionsExecutor() 641 .newClientTransport(any(SocketAddress.class), any(ClientTransportOptions.class)); in callOptionsExecutor() 862 .newClientTransport(same(badAddress), any(ClientTransportOptions.class)); in firstResolvedServerFailedToConnect() 864 .newClientTransport(same(goodAddress), any(ClientTransportOptions.class)); in firstResolvedServerFailedToConnect() 873 .newClientTransport(same(goodAddress), any(ClientTransportOptions.class)); in firstResolvedServerFailedToConnect() 1008 .newClientTransport(same(addr1), any(ClientTransportOptions.class)); in allServersFailedToConnect() [all …]
|
D | CallCredentialsApplyingTest.java | 108 when(mockTransportFactory.newClientTransport(address, clientTransportOptions)) in setUp() 115 transportFactory.newClientTransport(address, clientTransportOptions); in setUp() 117 verify(mockTransportFactory).newClientTransport(address, clientTransportOptions); in setUp()
|
D | TestUtils.java | 94 .newClientTransport( in captureTransports()
|
D | ManagedChannelImplIdlenessTest.java | 161 verify(mockTransportFactory, never()).newClientTransport( in setUp() 363 .newClientTransport( in oobTransportDoesNotAffectIdleness() 371 .newClientTransport( in oobTransportDoesNotAffectIdleness()
|
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
D | AbstractTransportTest.java | 128 protected abstract ManagedClientTransport newClientTransport(InternalServer server); in newClientTransport() method in AbstractTransportTest 242 client = newClientTransport(server); in frameAfterRstStreamShouldNotBreakClientChannel() 289 client = newClientTransport(server); in serverNotListening() 308 client = newClientTransport(server); in clientStartStop() 322 client = newClientTransport(server); in clientStartAndStopOnceConnected() 342 client = newClientTransport(server); in checkClientAttributes() 364 client = newClientTransport(server); in openStreamPreventsTermination() 416 client = newClientTransport(server); in shutdownNowKillsClientStream() 453 client = newClientTransport(server); in shutdownNowKillsServerStream() 494 client = newClientTransport(server); in ping() [all …]
|
D | AbstractClientTransportFactoryTest.java | 42 transportFactory.newClientTransport( in newClientTransportAfterCloseShouldThrow()
|
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
D | NettyTransportTest.java | 93 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport() method in NettyTransportTest 95 return clientFactory.newClientTransport( in newClientTransport()
|
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
D | OkHttpTransportTest.java | 79 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport() method in OkHttpTransportTest 81 return clientFactory.newClientTransport( in newClientTransport()
|
D | OkHttpChannelBuilderTest.java | 116 builder.buildTransportFactory().newClientTransport(new InetSocketAddress(5678), in usePlaintext_newClientTransportAllowed()
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | CallCredentialsApplyingTransportFactory.java | 44 public ConnectionClientTransport newClientTransport( in newClientTransport() method in CallCredentialsApplyingTransportFactory 47 delegate.newClientTransport(serverAddress, options), options.getAuthority()); in newClientTransport()
|
D | ClientTransportFactory.java | 36 ConnectionClientTransport newClientTransport( in newClientTransport() method
|
D | InternalSubchannel.java | 241 transportFactory.newClientTransport(address, options), callsTracer); in startNewTransport()
|
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
D | CronetChannelBuilderTest.java | 63 transportFactory.newClientTransport( in alwaysUsePutTrue_cronetStreamIsIdempotent() 77 transportFactory.newClientTransport( in alwaysUsePut_defaultsToFalse()
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/ |
D | InProcessTransportTest.java | 57 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport() method in InProcessTransportTest
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
D | InProcessChannelBuilder.java | 172 public ConnectionClientTransport newClientTransport( in newClientTransport() method in InProcessChannelBuilder.InProcessClientTransportFactory
|
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
D | CronetChannelBuilder.java | 231 public ConnectionClientTransport newClientTransport( in newClientTransport() method in CronetChannelBuilder.CronetTransportFactory
|
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
D | NettyChannelBuilder.java | 529 public ConnectionClientTransport newClientTransport( in newClientTransport() method in NettyChannelBuilder.NettyTransportFactory
|
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
D | OkHttpChannelBuilder.java | 518 public ConnectionClientTransport newClientTransport( in newClientTransport() method in OkHttpChannelBuilder.OkHttpTransportFactory
|