Home
last modified time | relevance | path

Searched refs:KeepAliveManager (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DKeepAliveManager.java32 public class KeepAliveManager { class
49 synchronized (KeepAliveManager.this) {
67 synchronized (KeepAliveManager.this) {
125 public KeepAliveManager(KeepAlivePinger keepAlivePinger, ScheduledExecutorService scheduler, in KeepAliveManager() method in KeepAliveManager
133 KeepAliveManager(KeepAlivePinger keepAlivePinger, ScheduledExecutorService scheduler, in KeepAliveManager() method in KeepAliveManager
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientTransport.java39 import io.grpc.internal.KeepAliveManager;
40 import io.grpc.internal.KeepAliveManager.ClientKeepAlivePinger;
77 private KeepAliveManager keepAliveManager;
187 keepAliveManager = new KeepAliveManager(
367 KeepAliveManager keepAliveManager() {
DNettyServerBuilder.java33 import io.grpc.internal.KeepAliveManager;
301 keepAliveTimeInNanos = KeepAliveManager.clampKeepAliveTimeInNanos(keepAliveTimeInNanos); in keepAliveTime()
323 KeepAliveManager.clampKeepAliveTimeoutInNanos(keepAliveTimeoutInNanos); in keepAliveTimeout()
DNettyClientHandler.java35 import io.grpc.internal.KeepAliveManager;
101 private final KeepAliveManager keepAliveManager;
114 @Nullable KeepAliveManager keepAliveManager, in newHandler()
154 KeepAliveManager keepAliveManager, in newHandler()
222 KeepAliveManager keepAliveManager, in NettyClientHandler()
DNettyServerHandler.java41 import io.grpc.internal.KeepAliveManager;
124 private KeepAliveManager keepAliveManager;
340 keepAliveManager = new KeepAliveManager(new KeepAlivePinger(ctx), ctx.executor(), in handlerAdded()
520 KeepAliveManager getKeepAliveManagerForTest() { in getKeepAliveManagerForTest()
525 void setKeepAliveManagerForTest(KeepAliveManager keepAliveManager) { in setKeepAliveManagerForTest()
794 private final class KeepAlivePinger implements KeepAliveManager.KeepAlivePinger {
DNettyChannelBuilder.java38 import io.grpc.internal.KeepAliveManager;
298 keepAliveTimeNanos = KeepAliveManager.clampKeepAliveTimeInNanos(keepAliveTimeNanos); in keepAliveTime()
315 keepAliveTimeoutNanos = KeepAliveManager.clampKeepAliveTimeoutInNanos(keepAliveTimeoutNanos); in keepAliveTimeout()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java28 import io.grpc.internal.KeepAliveManager.ClientKeepAlivePinger;
29 import io.grpc.internal.KeepAliveManager.KeepAlivePinger;
46 private KeepAliveManager keepAliveManager;
53 static class FakeTicker extends KeepAliveManager.Ticker {
65 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, false); in setUp()
253 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, true); in transportGoesIdle_doesntCauseIdleWhenEnabled()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java35 import io.grpc.internal.KeepAliveManager;
255 keepAliveTimeNanos = KeepAliveManager.clampKeepAliveTimeInNanos(keepAliveTimeNanos); in keepAliveTime()
272 keepAliveTimeoutNanos = KeepAliveManager.clampKeepAliveTimeoutInNanos(keepAliveTimeoutNanos); in keepAliveTimeout()
DOkHttpClientTransport.java51 import io.grpc.internal.KeepAliveManager;
52 import io.grpc.internal.KeepAliveManager.ClientKeepAlivePinger;
186 private KeepAliveManager keepAliveManager;
418 keepAliveManager = new KeepAliveManager( in start()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java64 import io.grpc.internal.KeepAliveManager;
116 private KeepAliveManager mockKeepAliveManager = null;
165 mockKeepAliveManager = mock(KeepAliveManager.class); in setUp()
DNettyServerHandlerTest.java62 import io.grpc.internal.KeepAliveManager;
129 private KeepAliveManager spyKeepAliveManager;
192 mock(KeepAliveManager.class, delegatesTo(handler().getKeepAliveManagerForTest())); in manualSetUp()