Home
last modified time | relevance | path

Searched refs:newClientTransport (Results 1 – 20 of 20) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java163 .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 …]
DCallCredentials2ApplyingTest.java109 when(mockTransportFactory.newClientTransport(address, clientTransportOptions)) in setUp()
116 transportFactory.newClientTransport(address, clientTransportOptions); in setUp()
118 verify(mockTransportFactory).newClientTransport(address, clientTransportOptions); in setUp()
DManagedChannelImplTest.java440 .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 …]
DCallCredentialsApplyingTest.java108 when(mockTransportFactory.newClientTransport(address, clientTransportOptions)) in setUp()
115 transportFactory.newClientTransport(address, clientTransportOptions); in setUp()
117 verify(mockTransportFactory).newClientTransport(address, clientTransportOptions); in setUp()
DTestUtils.java94 .newClientTransport( in captureTransports()
DManagedChannelImplIdlenessTest.java161 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/
DAbstractTransportTest.java128 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 …]
DAbstractClientTransportFactoryTest.java42 transportFactory.newClientTransport( in newClientTransportAfterCloseShouldThrow()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyTransportTest.java93 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/
DOkHttpTransportTest.java79 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport() method in OkHttpTransportTest
81 return clientFactory.newClientTransport( in newClientTransport()
DOkHttpChannelBuilderTest.java116 builder.buildTransportFactory().newClientTransport(new InetSocketAddress(5678), in usePlaintext_newClientTransportAllowed()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCallCredentialsApplyingTransportFactory.java44 public ConnectionClientTransport newClientTransport( in newClientTransport() method in CallCredentialsApplyingTransportFactory
47 delegate.newClientTransport(serverAddress, options), options.getAuthority()); in newClientTransport()
DClientTransportFactory.java36 ConnectionClientTransport newClientTransport( in newClientTransport() method
DInternalSubchannel.java241 transportFactory.newClientTransport(address, options), callsTracer); in startNewTransport()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetChannelBuilderTest.java63 transportFactory.newClientTransport( in alwaysUsePutTrue_cronetStreamIsIdempotent()
77 transportFactory.newClientTransport( in alwaysUsePut_defaultsToFalse()
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
DInProcessTransportTest.java57 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport() method in InProcessTransportTest
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessChannelBuilder.java172 public ConnectionClientTransport newClientTransport( in newClientTransport() method in InProcessChannelBuilder.InProcessClientTransportFactory
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetChannelBuilder.java231 public ConnectionClientTransport newClientTransport( in newClientTransport() method in CronetChannelBuilder.CronetTransportFactory
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyChannelBuilder.java529 public ConnectionClientTransport newClientTransport( in newClientTransport() method in NettyChannelBuilder.NettyTransportFactory
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java518 public ConnectionClientTransport newClientTransport( in newClientTransport() method in OkHttpChannelBuilder.OkHttpTransportFactory