Home
last modified time | relevance | path

Searched refs:keepAlivePinger (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DKeepAliveManager.java39 private final KeepAlivePinger keepAlivePinger; field in KeepAliveManager
58 keepAlivePinger.onPingTimeout();
85 keepAlivePinger.ping();
125 public KeepAliveManager(KeepAlivePinger keepAlivePinger, ScheduledExecutorService scheduler, in KeepAliveManager() argument
128 this(keepAlivePinger, scheduler, SYSTEM_TICKER, keepAliveTimeInNanos, keepAliveTimeoutInNanos, in KeepAliveManager()
133 KeepAliveManager(KeepAlivePinger keepAlivePinger, ScheduledExecutorService scheduler, in KeepAliveManager() argument
136 this.keepAlivePinger = checkNotNull(keepAlivePinger, "keepAlivePinger"); in KeepAliveManager()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java47 @Mock private KeepAlivePinger keepAlivePinger; field in KeepAliveManagerTest
65 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, false); in setUp()
87 verify(keepAlivePinger).ping(); in sendKeepAlivePings()
137 keepAlivePinger = new ClientKeepAlivePinger(transport); in clientKeepAlivePinger_pingTimeout()
139 keepAlivePinger.onPingTimeout(); in clientKeepAlivePinger_pingTimeout()
150 keepAlivePinger = new ClientKeepAlivePinger(transport); in clientKeepAlivePinger_pingFailure()
151 keepAlivePinger.ping(); in clientKeepAlivePinger_pingFailure()
204 verify(keepAlivePinger).ping(); in keepAlivePingTimesOut()
214 verify(keepAlivePinger).onPingTimeout(); in keepAlivePingTimesOut()
253 keepAliveManager = new KeepAliveManager(keepAlivePinger, scheduler, ticker, 1000, 2000, true); in transportGoesIdle_doesntCauseIdleWhenEnabled()
[all …]