Home
last modified time | relevance | path

Searched refs:keepAliveManager (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java46 private KeepAliveManager keepAliveManager; field in KeepAliveManagerTest
65 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, false); in setUp()
72 keepAliveManager.onTransportActive(); in sendKeepAlivePings()
96 keepAliveManager.onDataReceived(); in sendKeepAlivePings()
113 keepAliveManager.onTransportActive(); in keepAlivePingDelayedByIncomingData()
121 keepAliveManager.onDataReceived(); in keepAlivePingDelayedByIncomingData()
170 keepAliveManager.onTransportActive(); in onTransportTerminationCancelsShutdownFuture()
183 keepAliveManager.onTransportTermination(); in onTransportTerminationCancelsShutdownFuture()
192 keepAliveManager.onTransportActive(); in keepAlivePingTimesOut()
217 keepAliveManager.onDataReceived(); in keepAlivePingTimesOut()
[all …]
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientHandler.java101 private final KeepAliveManager keepAliveManager; field in NettyClientHandler
114 @Nullable KeepAliveManager keepAliveManager, in newHandler() argument
138 keepAliveManager, in newHandler()
154 KeepAliveManager keepAliveManager, in newHandler() argument
209 keepAliveManager, in newHandler()
222 KeepAliveManager keepAliveManager, in NettyClientHandler() argument
230 this.keepAliveManager = keepAliveManager; in NettyClientHandler()
265 if (NettyClientHandler.this.keepAliveManager != null) { in NettyClientHandler()
266 NettyClientHandler.this.keepAliveManager.onTransportActive(); in NettyClientHandler()
278 if (NettyClientHandler.this.keepAliveManager != null) { in NettyClientHandler()
[all …]
DNettyServerHandler.java124 private KeepAliveManager keepAliveManager; field in NettyServerHandler
340 keepAliveManager = new KeepAliveManager(new KeepAlivePinger(ctx), ctx.executor(), in handlerAdded()
342 keepAliveManager.onTransportStarted(); in handlerAdded()
521 return keepAliveManager; in getKeepAliveManagerForTest()
525 void setKeepAliveManagerForTest(KeepAliveManager keepAliveManager) { in setKeepAliveManagerForTest() argument
526 this.keepAliveManager = keepAliveManager; in setKeepAliveManagerForTest()
535 if (keepAliveManager != null) { in channelInactive()
536 keepAliveManager.onTransportTermination(); in channelInactive()
721 if (keepAliveManager != null) { in onDataRead()
722 keepAliveManager.onDataReceived(); in onDataRead()
[all …]
DNettyClientTransport.java78 private KeepAliveManager keepAliveManager; field in NettyClientTransport
191 keepAliveManager = new KeepAliveManager(
198 keepAliveManager,
278 if (keepAliveManager != null) {
279 keepAliveManager.onTransportStarted();
377 KeepAliveManager keepAliveManager() {
378 return keepAliveManager;
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java186 private KeepAliveManager keepAliveManager; field in OkHttpClientTransport
418 keepAliveManager = new KeepAliveManager( in start()
421 keepAliveManager.onTransportStarted(); in start()
839 if (keepAliveManager != null) { in stopIfNecessary()
840 keepAliveManager.onTransportTermination(); in stopIfNecessary()
868 if (keepAliveManager != null) { in maybeClearInUse()
872 keepAliveManager.onTransportIdle(); in maybeClearInUse()
883 if (keepAliveManager != null) { in setInUse()
888 keepAliveManager.onTransportActive(); in setInUse()
969 if (keepAliveManager != null) { in run()
[all …]
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java561 assertNotNull(transport.keepAliveManager()); in keepAliveEnabled()
573 assertNull(transport.keepAliveManager()); in keepAliveDisabled()