Home
last modified time | relevance | path

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

12

/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientTransport.java66 private boolean goAway; field in CronetClientTransport
129 if (goAway) { in newStream()
176 if (goAway) {
220 goAway = true;
243 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()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java184 public void goAway(final int lastGoodStreamId, final ErrorCode errorCode, in goAway() method in AsyncFrameWriter
189 frameWriter.goAway(lastGoodStreamId, errorCode, debugData); in goAway()
DOkHttpClientTransport.java756 frameWriter.goAway(0, errorCode, new byte[0]); in startGoAway()
853 frameWriter.goAway(0, ErrorCode.NO_ERROR, new byte[0]); in stopIfNecessary()
1137 public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() method in OkHttpClientTransport.ClientFrameHandler
/external/syzkaller/vendor/google.golang.org/grpc/transport/
Dcontrolbuf.go147 type goAway struct { struct
352 ssGoAwayHandler func(*goAway) (bool, error)
634 func (l *loopyWriter) goAwayHandler(g *goAway) error {
668 case *goAway:
Dhttp2_client.go61 goAway chan struct{} member
219 goAway: make(chan struct{}),
606 case <-t.goAway:
993 case <-t.goAway: // t.goAway has been closed (i.e.,multiple GoAways).
1002 close(t.goAway)
1244 return t.goAway
Dhttp2_server.go682 …t.controlBuf.put(&goAway{code: http2.ErrCodeEnhanceYourCalm, debugData: []byte("too_many_pings"), …
1021 t.controlBuf.put(&goAway{code: code, debugData: debugData, headsUp: true})
1028 func (t *http2Server) outgoingGoAwayHandler(g *goAway) (bool, error) {
1076 t.controlBuf.put(&goAway{code: g.code, debugData: g.debugData})
/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
/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
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
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
/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
/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/syzkaller/vendor/golang.org/x/net/http2/
Dtransport.go164 goAway *GoAwayFrame // if non-nil, the GoAwayFrame we received member
604 old := cc.goAway
605 cc.goAway = f
612 cc.goAway.ErrCode = old.ErrCode
637 return cc.goAway == nil && !cc.closed &&
1456 if cc.goAway != nil && isEOFOrNetReadError(err) {
1458 LastStreamID: cc.goAway.LastStreamID,
1459 ErrCode: cc.goAway.ErrCode,
Dserver.go844 sc.goAway(ErrCodeNo)
1250 sc.goAway(ErrCodeNo)
1253 func (sc *serverConn) goAway(code ErrCode) { func
1285 sc.goAway(ErrCodeFrameSize)
1316 sc.goAway(ErrCodeFlowControl)
1320 sc.goAway(ErrCode(ev))
/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()

12