Home
last modified time | relevance | path

Searched refs:keepAliveManager (Results 1 – 7 of 7) 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.java77 private KeepAliveManager keepAliveManager; field in NettyClientTransport
187 keepAliveManager = new KeepAliveManager(
194 keepAliveManager,
268 if (keepAliveManager != null) {
269 keepAliveManager.onTransportStarted();
367 KeepAliveManager keepAliveManager() {
368 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()
838 if (keepAliveManager != null) { in stopIfNecessary()
839 keepAliveManager.onTransportTermination(); in stopIfNecessary()
867 if (keepAliveManager != null) { in maybeClearInUse()
871 keepAliveManager.onTransportIdle(); in maybeClearInUse()
882 if (keepAliveManager != null) { in setInUse()
887 keepAliveManager.onTransportActive(); in setInUse()
968 if (keepAliveManager != null) { in run()
[all …]
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java550 assertNotNull(transport.keepAliveManager()); in keepAliveEnabled()
562 assertNull(transport.keepAliveManager()); in keepAliveDisabled()
/external/grpc-grpc-java/netty/shaded/
Dgrpc-netty-shaded-1.14.0.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...