| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | KeepAliveManagerTest.java | 77 Runnable sendPing = sendPingCaptor.getValue(); in sendKeepAlivePings() local
86 sendPing.run(); in sendKeepAlivePings()
117 Runnable sendPing = sendPingCaptor.getValue(); in keepAlivePingDelayedByIncomingData() local
123 sendPing.run(); in keepAlivePingDelayedByIncomingData()
174 Runnable sendPing = sendPingCaptor.getValue(); in onTransportTerminationCancelsShutdownFuture() local
181 sendPing.run(); in onTransportTerminationCancelsShutdownFuture()
196 Runnable sendPing = sendPingCaptor.getValue(); in keepAlivePingTimesOut() local
203 sendPing.run(); in keepAlivePingTimesOut()
234 Runnable sendPing = sendPingCaptor.getValue(); in transportGoesIdle() local
238 sendPing.run(); in transportGoesIdle()
[all …]
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocketTest.java | 164 client.sendPing(new Buffer().writeUtf8("Pong?")); in streamingMessageCanInterleavePing()
178 client.sendPing(new Buffer().writeUtf8("Hello!")); in pingWritesPong()
202 client.sendPing(new Buffer().writeUtf8("Pong?")); in clientCloseThenMethodsThrow()
225 client.sendPing(new Buffer().writeUtf8("Ping!")); in socketClosedDuringPingKillsWebSocket()
238 client.sendPing(new Buffer().writeUtf8("Ping!")); in socketClosedDuringPingKillsWebSocket()
262 client.sendPing(new Buffer().writeUtf8("Ping!")); in socketClosedDuringMessageKillsWebSocket()
275 client.sendPing(new Buffer().writeUtf8("Pong?")); in serverCloseThenWritingPingThrows()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | KeepAliveManager.java | 62 private final Runnable sendPing = new LogExceptionRunnable(new Runnable() { field in KeepAliveManager
77 sendPing,
176 pingFuture = scheduler.schedule(sendPing, keepAliveTimeInNanos, TimeUnit.NANOSECONDS); in onDataReceived()
190 sendPing, in onTransportActive()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | AbstractNettyHandler.java | 142 sendPing(ctx()); in onDataRead()
182 private void sendPing(ChannelHandlerContext ctx) { in sendPing() method in AbstractNettyHandler.FlowControlPinger
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 559 sendPing(callback1); in ping()
563 sendPing(callback2); in ping()
595 sendPing(callback1); in ping()
603 sendPing(callback); in ping_failsWhenChannelCloses()
623 sendPing(callback); in oustandingUserPingShouldNotInteractWithDataPing()
674 private ChannelFuture sendPing(PingCallback callback) { in sendPing() method in NettyClientHandlerTest
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocket.java | 49 void sendPing(Buffer payload) throws IOException; in sendPing() method
|
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/third_party/SocketRocket/ |
| D | SRWebSocket.h | 89 - (void)sendPing:(NSData *)data;
|
| D | SRWebSocket.m | 723 - (void)sendPing:(NSData *)data;
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocket.java | 138 @Override public void sendPing(Buffer payload) throws IOException { in sendPing() method in RealWebSocket
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | controlbuf.go | 514 sendPing, err := hdr.initStream(str.id)
526 if sendPing {
|
| D | http2_client.go | 546 var sendPing bool
552 sendPing = true
561 return sendPing, nil
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | WebSocketCallTest.java | 58 webSocket.sendPing(new Buffer().writeUtf8("Hello, WebSockets!")); in clientPingPong()
|