| /external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/ |
| D | TestUtils.java | 86 final ConnectionClientTransport transport;
93 MockClientTransportInfo(ConnectionClientTransport transport,
116 doAnswer(new Answer<ConnectionClientTransport>() {
118 public ConnectionClientTransport answer(InvocationOnMock invocation) throws Throwable {
119 final ConnectionClientTransport mockTransport = mock(ConnectionClientTransport.class);
|
| D | AbstractTransportTest.java | 375 assumeTrue(client instanceof ConnectionClientTransport); in checkClientAttributes()
376 ConnectionClientTransport connectionClient = (ConnectionClientTransport) client; in checkClientAttributes()
799 assertThat(((ConnectionClientTransport) client).getAttributes() in basicStream()
818 .isSameInstanceAs(((ConnectionClientTransport) client).getAttributes()); in basicStream()
843 assertThat(((ConnectionClientTransport) client).getAttributes() in basicStream()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalSubchannel.java | 125 private final Collection<ConnectionClientTransport> transports = new ArrayList<>();
128 private final InUseStateAggregator<ConnectionClientTransport> inUseStateAggregator =
129 new InUseStateAggregator<ConnectionClientTransport>() {
145 private ConnectionClientTransport pendingTransport;
251 ConnectionClientTransport transport = in startNewTransport()
409 ConnectionClientTransport savedPendingTransport; in shutdown()
461 final ConnectionClientTransport transport, final boolean inUse) { in handleTransportInUseState()
535 final ConnectionClientTransport transport;
538 TransportListener(ConnectionClientTransport transport) { in TransportListener()
654 private final ConnectionClientTransport delegate;
[all …]
|
| D | CallCredentialsApplyingTransportFactory.java | 56 public ConnectionClientTransport newClientTransport( in newClientTransport()
78 private final ConnectionClientTransport delegate;
96 CallCredentialsApplyingTransport(ConnectionClientTransport delegate, String authority) { in CallCredentialsApplyingTransport()
102 protected ConnectionClientTransport delegate() { in delegate()
|
| D | ForwardingConnectionClientTransport.java | 31 abstract class ForwardingConnectionClientTransport implements ConnectionClientTransport {
79 protected abstract ConnectionClientTransport delegate(); in delegate()
|
| D | ConnectionClientTransport.java | 26 public interface ConnectionClientTransport extends ManagedClientTransport { interface
|
| D | KeepAliveManager.java | 265 private final ConnectionClientTransport transport;
267 public ClientKeepAlivePinger(ConnectionClientTransport transport) { in ClientKeepAlivePinger()
|
| D | ClientTransportFactory.java | 42 ConnectionClientTransport newClientTransport( in newClientTransport()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InternalInProcess.java | 22 import io.grpc.internal.ConnectionClientTransport;
46 public static ConnectionClientTransport createInProcessTransport( in createInProcessTransport()
|
| D | InProcessChannelBuilder.java | 30 import io.grpc.internal.ConnectionClientTransport;
255 public ConnectionClientTransport newClientTransport( in newClientTransport()
|
| D | InProcessTransport.java | 47 import io.grpc.internal.ConnectionClientTransport;
82 final class InProcessTransport implements ServerTransport, ConnectionClientTransport {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | KeepAliveManagerTest.java | 107 ConnectionClientTransport transport = mock(ConnectionClientTransport.class); in clientKeepAlivePinger_pingTimeout()
122 ConnectionClientTransport transport = mock(ConnectionClientTransport.class); in clientKeepAlivePinger_pingFailure()
|
| D | ManagedChannelImplTest.java | 501 ConnectionClientTransport mockTransport = transportInfo.transport; in startCallBeforeNameResolution()
580 ConnectionClientTransport mockTransport = transportInfo.transport; in newCallWithConfigSelector()
783 ConnectionClientTransport mockTransport = transportInfo.transport; in subtestCallsAndShutdown()
1016 ConnectionClientTransport mockTransport = transportInfo.transport; in callOptionsExecutor()
1917 ConnectionClientTransport mockTransport = transportInfo.transport; in subchannelChannel_normalUsage()
1945 ConnectionClientTransport mockTransport = transportInfo.transport; in subchannelChannel_failWhenNotReady()
1976 ConnectionClientTransport mockTransport = transportInfo.transport; in subchannelChannel_failWaitForReady()
2153 final ConnectionClientTransport transport = transportInfo.transport; in informationPropagatedToNewStreamAndCallCredentials()
2713 ConnectionClientTransport mockTransport = transportInfo.transport; in idleMode_resetsDelayedTransportPicker()
2787 ConnectionClientTransport mockTransport = transportInfo.transport; in enterIdle_exitsIdleIfDelayedStreamPending()
[all …]
|
| D | InternalSubchannelTest.java | 815 ConnectionClientTransport firstTransport = transports.poll().transport; in updateAddresses_disjoint_readyTwice()
838 ConnectionClientTransport secondTransport = transports.peek().transport; in updateAddresses_disjoint_readyTwice()
|
| D | CallCredentialsApplyingTest.java | 75 private ConnectionClientTransport mockTransport;
|
| /external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/ |
| D | BinderChannelBuilder.java | 33 import io.grpc.internal.ConnectionClientTransport;
280 public ConnectionClientTransport newClientTransport( in newClientTransport()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 33 import io.grpc.internal.ConnectionClientTransport;
50 class CronetClientTransport implements ConnectionClientTransport {
|
| D | CronetChannelBuilder.java | 35 import io.grpc.internal.ConnectionClientTransport;
263 public ConnectionClientTransport newClientTransport( in newClientTransport()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientTransport.java | 39 import io.grpc.internal.ConnectionClientTransport;
71 class NettyClientTransport implements ConnectionClientTransport {
|
| D | NettyChannelBuilder.java | 42 import io.grpc.internal.ConnectionClientTransport;
712 public ConnectionClientTransport newClientTransport( in newClientTransport()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpChannelBuilder.java | 39 import io.grpc.internal.ConnectionClientTransport;
830 public ConnectionClientTransport newClientTransport( in newClientTransport()
|
| D | OkHttpClientTransport.java | 46 import io.grpc.internal.ConnectionClientTransport;
109 class OkHttpClientTransport implements ConnectionClientTransport, TransportExceptionHandler,
|
| /external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/internal/ |
| D | BinderTransport.java | 52 import io.grpc.internal.ConnectionClientTransport;
553 implements ConnectionClientTransport, Bindable.Observer {
|