Home
last modified time | relevance | path

Searched refs:PingCallback (Results 1 – 25 of 29) sorted by relevance

12

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DHttp2Ping.java20 import io.grpc.internal.ClientTransport.PingCallback;
53 @GuardedBy("this") private Map<PingCallback, Executor> callbacks
54 = new LinkedHashMap<PingCallback, Executor>();
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()
170 public static void notifyFailed(PingCallback callback, Executor executor, Throwable cause) { in notifyFailed()
190 private static Runnable asRunnable(final ClientTransport.PingCallback callback, in asRunnable()
[all …]
DClientTransport.java65 void ping(PingCallback callback, Executor executor); in ping()
71 interface PingCallback { interface
DForwardingConnectionClientTransport.java53 public void ping(PingCallback callback, Executor executor) { in ping()
DFailingClientTransport.java53 public void ping(final PingCallback callback, Executor executor) { in ping()
DKeepAliveManager.java268 transport.ping(new ClientTransport.PingCallback() { in ping()
DDelayedClientTransport.java189 public final void ping(final PingCallback callback, Executor executor) { in ping()
DGrpcUtil.java687 public void ping(PingCallback callback, Executor executor) { in getTransportFromPickResult()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DSendPingCommand.java19 import io.grpc.internal.ClientTransport.PingCallback;
26 private final PingCallback callback;
29 SendPingCommand(PingCallback callback, Executor executor) { in SendPingCommand()
34 PingCallback callback() { in callback()
DNettyClientHandler.java32 import io.grpc.internal.ClientTransport.PingCallback;
591 PingCallback callback = msg.callback(); in sendPingFrame()
DNettyClientTransport.java127 public void ping(final PingCallback callback, final Executor executor) { in ping()
/external/libchrome/ipc/
Dipc_perftest_util.h107 void Ping(const std::string& value, PingCallback callback) override;
109 void SyncPing(const std::string& value, PingCallback callback) override;
Dipc_perftest_util.cc132 void ReflectorImpl::Ping(const std::string& value, PingCallback callback) { in Ping()
136 void ReflectorImpl::SyncPing(const std::string& value, PingCallback callback) { in SyncPing()
Dipc_mojo_perftest.cc403 void Ping(PingCallback callback) override { std::move(callback).Run(); } in Ping()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java125 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()
/external/libchrome/mojo/public/cpp/bindings/tests/
Dsync_method_unittest.cc128 void Ping(const PingCallback& callback) override { PingImpl(callback); } in Ping()
150 void Ping(const PingCallback& callback) override { PingImpl(callback); } in Ping()
178 void Ping(const PingCallback& callback) override { PingImpl(callback); } in Ping()
278 [this](const typename Interface::PingCallback& callback) { in SetUp()
629 impl.set_ping_handler([&ptr](const TestSync::PingCallback& callback) { in TYPED_TEST()
642 this->impl_->set_ping_handler([ptr](const TestSync::PingCallback& callback) { in SEQUENCED_TASK_RUNNER_TYPED_TEST()
659 impl.set_ping_handler([&impl](const TestSync::PingCallback& callback) { in TYPED_TEST()
674 [&impl](const TestSync::PingCallback& callback) { in SEQUENCED_TASK_RUNNER_TYPED_TEST()
Dbindings_perftest.cc37 void Ping(const PingCallback& callback) override;
43 void PingServiceImpl::Ping(const PingCallback& callback) { in Ping()
Dtest_helpers_unittest.cc36 void Ping(const PingCallback& callback) override { in Ping()
Dbinding_set_unittest.cc97 void Ping(const PingCallback& callback) override { in Ping()
350 void Ping(const PingCallback& callback) override { in Ping()
589 void Ping(const PingCallback& callback) override {} in Ping()
Dbinding_unittest.cc304 void Ping(const PingCallback& callback) override { in Ping()
Dinterface_ptr_unittest.cc714 void Ping(const PingCallback& callback) override { callback.Run(); } in Ping()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java62 import io.grpc.internal.ClientTransport.PingCallback;
674 private ChannelFuture sendPing(PingCallback callback) { in sendPing()
739 private static class PingCallbackImpl implements ClientTransport.PingCallback {
DNettyClientTransportTest.java443 ClientTransport.PingCallback pingCallback = new ClientTransport.PingCallback() { in failingToConstructChannelShouldFailGracefully()
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientTransport.java227 public void ping(final PingCallback callback, Executor executor) {
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java496 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()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java165 public synchronized void ping(final PingCallback callback, Executor executor) {

12