Home
last modified time | relevance | path

Searched refs:goAway (Results 1 – 25 of 25) sorted by relevance

/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientTransport.java66 private boolean goAway; field in CronetClientTransport
128 if (goAway) { in newStream()
175 if (goAway) {
219 goAway = true;
242 if (goAway && !stopped && streams.size() == 0) {
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3Test.java77 @Override public void goAway( in goAwayRoundTrip()
98 new Spdy3.Writer(out, true).goAway(lastGoodStreamId, errorCode, debugData); in sendGoAway()
DBaseTestHandler.java53 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in BaseTestHandler
DHttp2Test.java578 @Override public void goAway( in goAwayWithoutDebugDataRoundTrip()
604 @Override public void goAway( in goAwayWithDebugDataRoundTrip()
676 new Http2.Writer(out, true).goAway(lastGoodStreamId, errorCode, debugData); in sendGoAway()
DMockSpdyPeer.java297 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in MockSpdyPeer.InFrame
DHttp2ConnectionTest.java184 peer.sendFrame().goAway(3, PROTOCOL_ERROR, Util.EMPTY_BYTE_ARRAY);
DSpdy3ConnectionTest.java782 peer.sendFrame().goAway(1, PROTOCOL_ERROR, Util.EMPTY_BYTE_ARRAY);
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java192 public void goAway(final int lastGoodStreamId, final ErrorCode errorCode, in goAway() method in AsyncFrameWriter
197 frameWriter.goAway(lastGoodStreamId, errorCode, debugData); in goAway()
DOkHttpClientTransport.java757 frameWriter.goAway(0, errorCode, new byte[0]); in startGoAway()
854 frameWriter.goAway(0, ErrorCode.NO_ERROR, new byte[0]); in stopIfNecessary()
1138 public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in OkHttpClientTransport.ClientFrameHandler
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFrameWriter.java96 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() method
DFrameReader.java78 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() method
DSpdy3.java257 handler.goAway(lastGoodStreamId, errorCode, ByteString.EMPTY); in readGoAway()
453 @Override public synchronized void goAway(int lastGoodStreamId, ErrorCode errorCode, in goAway() method in Spdy3.Writer
DHttp2.java347 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
529 @Override public synchronized void goAway(int lastGoodStreamId, ErrorCode errorCode, in goAway() method in Http2.Writer
DFramedConnection.java440 frameWriter.goAway(lastGoodStreamId, statusCode, Util.EMPTY_BYTE_ARRAY); in shutdown()
775 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in FramedConnection.Reader
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DFrameWriter.java100 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() method
DFrameReader.java82 …void goAway(int lastGoodStreamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode, ByteString d… in goAway() method
DHttp2.java353 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
535 …@Override public synchronized void goAway(int lastGoodStreamId, io.grpc.okhttp.internal.framed.Err… in goAway() method in Http2.Writer
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFrameReader.java80 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() method
DFrameWriter.java98 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() method
DSpdy3.java259 handler.goAway(lastGoodStreamId, errorCode, ByteString.EMPTY); in readGoAway()
455 @Override public synchronized void goAway(int lastGoodStreamId, ErrorCode errorCode, in goAway() method in Spdy3.Writer
DHttp2.java349 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
531 @Override public synchronized void goAway(int lastGoodStreamId, ErrorCode errorCode, in goAway() method in Http2.Writer
DFramedConnection.java442 frameWriter.goAway(lastGoodStreamId, statusCode, Util.EMPTY_BYTE_ARRAY); in shutdown()
780 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in FramedConnection.Reader
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DHttp2Client.java188 tester.goAway(); in runTest()
258 private void goAway() throws Exception { in goAway() method in Http2Client.Tester
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java378 .goAway(eq(0), eq(ErrorCode.PROTOCOL_ERROR), any(byte[].class)); in receivedHeadersForInvalidStreamShouldKillConnection()
389 .goAway(eq(0), eq(ErrorCode.PROTOCOL_ERROR), any(byte[].class)); in receivedDataForInvalidStreamShouldKillConnection()
821 verify(frameWriter, timeout(TIME_OUT_MS)).goAway(eq(0), eq(ErrorCode.NO_ERROR), (byte[]) any()); in stopNormally()
843 frameHandler().goAway(3, ErrorCode.CANCEL, ByteString.EMPTY); in receiveGoAway()
998 frameHandler().goAway(99, ErrorCode.CANCEL, ByteString.EMPTY); in pendingStreamFailedByGoAway()
1223 .goAway(eq(0), eq(ErrorCode.PROTOCOL_ERROR), any(byte[].class)); in receiveDataForUnknownStreamUpdateConnectionWindow()
1243 .goAway(eq(0), eq(ErrorCode.PROTOCOL_ERROR), any(byte[].class)); in receiveWindowUpdateForUnknownStream()
1669 frameHandler().goAway( in goAway_notUtf8()
1685 frameHandler().goAway(0, ErrorCode.ENHANCE_YOUR_CALM, ByteString.encodeUtf8("not_many_pings")); in goAway_notTooManyPings()
1701 frameHandler().goAway(0, ErrorCode.ENHANCE_YOUR_CALM, ByteString.encodeUtf8("too_many_pings")); in goAway_tooManyPings()
[all …]
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerHandler.java759 goAway(ctx, connection().remote().lastStreamCreated(), Http2Error.ENHANCE_YOUR_CALM.code(), in onPingRead()
864 goAway( in start()
894 goAway( in secondGoAwayAndClose()