Searched refs:keepAlivePinger (Results 1 – 2 of 2) sorted by relevance
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | KeepAliveManager.java | 39 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/ |
D | KeepAliveManagerTest.java | 47 @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 …]
|