| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | Http2Ping.java | 20 import io.grpc.internal.ClientTransport.PingCallback;
93 public void addCallback(final ClientTransport.PingCallback callback, Executor executor) { in addCallback()
124 Map<ClientTransport.PingCallback, Executor> callbacks; in complete()
135 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in complete()
148 Map<ClientTransport.PingCallback, Executor> callbacks; in failed()
158 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in failed()
190 private static Runnable asRunnable(final ClientTransport.PingCallback callback, in asRunnable()
205 private static Runnable asRunnable(final ClientTransport.PingCallback callback,
|
| D | MetadataApplierImpl.java | 33 private final ClientTransport transport;
53 ClientTransport transport, MethodDescriptor<?, ?> method, Metadata origHeaders, in MetadataApplierImpl()
|
| D | DelayedClientTransport.java | 150 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in newStream()
291 final ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in reprocess()
354 private void createRealStream(ClientTransport transport) { in createRealStream()
|
| D | AbstractSubchannel.java | 35 abstract ClientTransport obtainActiveTransport(); in obtainActiveTransport()
|
| D | ManagedClientTransport.java | 36 public interface ManagedClientTransport extends ClientTransport {
|
| D | ClientTransport.java | 34 public interface ClientTransport extends InternalInstrumented<SocketStats> { interface
|
| D | FailingClientTransport.java | 35 class FailingClientTransport implements ClientTransport {
|
| D | GrpcUtil.java | 665 static ClientTransport getTransportFromPickResult(PickResult result, boolean isWaitForReady) { in getTransportFromPickResult()
666 final ClientTransport transport; in getTransportFromPickResult()
678 return new ClientTransport() { in getTransportFromPickResult()
|
| D | OobChannel.java | 89 public ClientTransport get(PickSubchannelArgs args) {
152 ClientTransport obtainActiveTransport() { in setSubchannel()
|
| D | ManagedChannelImpl.java | 468 public ClientTransport get(PickSubchannelArgs args) {
495 ClientTransport transport = GrpcUtil.getTransportFromPickResult(
528 ClientTransport transport =
1388 ClientTransport obtainActiveTransport() { in obtainActiveTransport()
|
| D | KeepAliveManager.java | 268 transport.ping(new ClientTransport.PingCallback() { in ping()
|
| D | ClientCallImpl.java | 129 ClientTransport get(PickSubchannelArgs args); in get()
241 ClientTransport transport = clientTransportProvider.get( in start()
|
| D | InternalSubchannel.java | 195 ClientTransport obtainActiveTransport() { in obtainActiveTransport()
196 ClientTransport savedTransport = activeTransport; in obtainActiveTransport()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | GrpcUtilTest.java | 233 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_errorPickResult_waitForReady()
242 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_errorPickResult_failFast()
258 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_dropPickResult_waitForReady()
274 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_dropPickResult_failFast()
|
| D | KeepAliveManagerTest.java | 125 verify(transport, times(0)).ping(isA(ClientTransport.PingCallback.class), in keepAlivePingDelayedByIncomingData()
152 ArgumentCaptor<ClientTransport.PingCallback> pingCallbackCaptor = in clientKeepAlivePinger_pingFailure()
153 ArgumentCaptor.forClass(ClientTransport.PingCallback.class); in clientKeepAlivePinger_pingFailure()
155 ClientTransport.PingCallback pingCallback = pingCallbackCaptor.getValue(); in clientKeepAlivePinger_pingFailure()
240 verify(transport, times(0)).ping(isA(ClientTransport.PingCallback.class), isA(Executor.class)); in transportGoesIdle()
|
| D | DelayedClientTransportTest.java | 72 @Mock private ClientTransport mockRealTransport;
73 @Mock private ClientTransport mockRealTransport2;
|
| D | ClientCallImplTest.java | 102 @Mock private ClientTransport clientTransport;
109 private ClientTransport transport;
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | SendPingCommand.java | 19 import io.grpc.internal.ClientTransport.PingCallback;
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | picker_wrapper.go | 133 …ontext.Context, failfast bool, opts balancer.PickOptions) (transport.ClientTransport, func(balance…
285 func (ss *stickyStore) get(mdKey, stickyKey string) (transport.ClientTransport, bool) {
|
| D | clientconn.go | 1015 func (cc *ClientConn) getTransport(ctx context.Context, failfast bool) (transport.ClientTransport, …
1130 transport transport.ClientTransport
1452 …ddrConn) wait(ctx context.Context, hasBalancer, failfast bool) (transport.ClientTransport, error) {
1493 func (ac *addrConn) getReadyTransport() (transport.ClientTransport, bool) {
|
| D | stream.go | 258 t transport.ClientTransport
361 t transport.ClientTransport
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | transport.go | 490 …ntext.Context, target TargetInfo, opts ConnectOptions, onSuccess func()) (ClientTransport, error) {
541 type ClientTransport interface { interface
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 61 import io.grpc.internal.ClientTransport;
62 import io.grpc.internal.ClientTransport.PingCallback;
739 private static class PingCallbackImpl implements ClientTransport.PingCallback {
|
| D | NettyClientTransportTest.java | 53 import io.grpc.internal.ClientTransport;
437 ClientTransport.PingCallback pingCallback = new ClientTransport.PingCallback() { in failingToConstructChannelShouldFailGracefully()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 60 import io.grpc.internal.ClientTransport;
496 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping()
518 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping_duringShutdown()
538 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping_afterTermination()
|