Home
last modified time | relevance | path

Searched refs:onDataReceived (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DKeepAliveManagerTest.java96 keepAliveManager.onDataReceived(); in sendKeepAlivePings()
121 keepAliveManager.onDataReceived(); in keepAlivePingDelayedByIncomingData()
217 keepAliveManager.onDataReceived(); in keepAlivePingTimesOut()
299 keepAliveManager.onDataReceived(); in transportGoesIdleAfterPingSent()
319 keepAliveManager.onDataReceived(); in transportGoesIdleBeforePingSent()
393 keepAliveManager.onDataReceived(); in pingSentThenIdleThenActiveThenAck()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java512 verify(spyKeepAliveManager).onDataReceived(); in keepAliveManagerOnDataReceived_headersRead()
520 verify(spyKeepAliveManager).onDataReceived(); // received headers in keepAliveManagerOnDataReceived_dataRead()
524 verify(spyKeepAliveManager, times(2)).onDataReceived(); in keepAliveManagerOnDataReceived_dataRead()
528 verify(spyKeepAliveManager, times(3)).onDataReceived(); in keepAliveManagerOnDataReceived_dataRead()
536 verify(spyKeepAliveManager).onDataReceived(); // received headers in keepAliveManagerOnDataReceived_rstStreamRead()
540 verify(spyKeepAliveManager, times(2)).onDataReceived(); in keepAliveManagerOnDataReceived_rstStreamRead()
549 verify(spyKeepAliveManager).onDataReceived(); in keepAliveManagerOnDataReceived_pingRead()
558 verify(spyKeepAliveManager).onDataReceived(); in keepAliveManagerOnDataReceived_pingActRead()
582 spyKeepAliveManager.onDataReceived(); in keepAliveManager_pingSent()
DNettyClientHandlerTest.java647 verify(mockKeepAliveManager, times(3)).onDataReceived(); in dataPingAckIsRecognized()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientHandler.java345 keepAliveManager.onDataReceived(); in onHeadersRead()
357 keepAliveManager.onDataReceived(); in onDataRead()
377 keepAliveManager.onDataReceived(); in onRstStreamRead()
795 keepAliveManager.onDataReceived(); in onPingAckRead()
802 keepAliveManager.onDataReceived(); in onPingRead()
DNettyServerHandler.java722 keepAliveManager.onDataReceived(); in onDataRead()
738 keepAliveManager.onDataReceived(); in onHeadersRead()
747 keepAliveManager.onDataReceived(); in onRstStreamRead()
755 keepAliveManager.onDataReceived(); in onPingRead()
773 keepAliveManager.onDataReceived(); in onPingAckRead()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DKeepAliveManager.java155 public synchronized void onDataReceived() { in onDataReceived() method in KeepAliveManager
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/net/
DSocketKeepaliveFacade.java110 public void onDataReceived() { in onDataReceived() method in SocketKeepaliveFacade.SocketKeepaliveReceiver
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java970 keepAliveManager.onDataReceived(); in run()