Home
last modified time | relevance | path

Searched refs:onTransportActive (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java72 keepAliveManager.onTransportActive(); in sendKeepAlivePings()
113 keepAliveManager.onTransportActive(); in keepAlivePingDelayedByIncomingData()
170 keepAliveManager.onTransportActive(); in onTransportTerminationCancelsShutdownFuture()
192 keepAliveManager.onTransportActive(); in keepAlivePingTimesOut()
230 keepAliveManager.onTransportActive(); in transportGoesIdle()
245 keepAliveManager.onTransportActive(); in transportGoesIdle()
262 keepAliveManager.onTransportActive(); in transportGoesIdle_doesntCauseIdleWhenEnabled()
280 keepAliveManager.onTransportActive(); in transportGoesIdleAfterPingSent()
305 keepAliveManager.onTransportActive(); in transportGoesIdleAfterPingSent()
315 keepAliveManager.onTransportActive(); in transportGoesIdleBeforePingSent()
[all …]
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DKeepAliveEnforcerTest.java49 enforcer.onTransportActive(); in permitLimitless()
85 enforcer.onTransportActive(); in strikeOutBecauseRateTooHighWhileActive()
105 enforcer.onTransportActive(); in permitInRateWhileActive()
137 enforcer.onTransportActive(); in implicitOverridesWhileActive()
159 enforcer.onTransportActive(); in permitsWhenTimeOverflows()
171 enforcer.onTransportActive(); in resetCounters_resetsStrikes()
186 enforcer.onTransportActive(); in resetCounters_resetsPingTime()
DMaxConnectionIdleManagerTest.java75 maxConnectionIdleManager.onTransportActive(); in maxIdleNotReachedAndReached()
79 maxConnectionIdleManager.onTransportActive(); in maxIdleNotReachedAndReached()
DNettyClientHandlerTest.java219 verify(mockKeepAliveManager, times(1)).onTransportActive(); // onStreamActive in cancelShouldSucceed()
289 verify(mockKeepAliveManager, times(1)).onTransportActive(); // onStreamActive in sendFrameShouldSucceed()
531 verify(mockKeepAliveManager, times(1)).onTransportActive(); // onStreamActive in createIncrementsIdsForActualAndBufferdStreams()
645 verify(mockKeepAliveManager, times(1)).onTransportActive(); // onStreamActive in dataPingAckIsRecognized()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DKeepAliveManager.java148 onTransportActive(); in onTransportStarted()
183 public synchronized void onTransportActive() { in onTransportActive() method in KeepAliveManager
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DKeepAliveEnforcer.java84 public void onTransportActive() { in onTransportActive() method in KeepAliveEnforcer
DMaxConnectionIdleManager.java98 void onTransportActive() { in onTransportActive() method in MaxConnectionIdleManager
DNettyServerHandler.java273 keepAliveEnforcer.onTransportActive(); in NettyServerHandler()
275 maxConnectionIdleManager.onTransportActive(); in NettyServerHandler()
DNettyClientHandler.java266 NettyClientHandler.this.keepAliveManager.onTransportActive(); in NettyClientHandler()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java887 keepAliveManager.onTransportActive(); in setInUse()