Home
last modified time | relevance | path

Searched refs:debugData (Results 1 – 22 of 22) sorted by relevance

/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DSpdy3Test.java78 int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAwayRoundTrip()
81 assertEquals(0, debugData.size()); in goAwayRoundTrip()
95 private Buffer sendGoAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) in sendGoAway() argument
98 new Spdy3.Writer(out, true).goAway(lastGoodStreamId, errorCode, debugData); in sendGoAway()
DHttp2Test.java579 int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAwayWithoutDebugDataRoundTrip()
582 assertEquals(0, debugData.size()); in goAwayWithoutDebugDataRoundTrip()
605 int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAwayWithDebugDataRoundTrip()
608 assertEquals(expectedData, debugData); in goAwayWithDebugDataRoundTrip()
673 private Buffer sendGoAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) in sendGoAway() argument
676 new Http2.Writer(out, true).goAway(lastGoodStreamId, errorCode, debugData); in sendGoAway()
DBaseTestHandler.java53 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
DMockSpdyPeer.java288 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
293 this.data = debugData.toByteArray(); in goAway()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DHttp2.java345 ByteString debugData = EMPTY; in readGoAway() local
347 debugData = source.readByteString(opaqueDataLength); in readGoAway()
349 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
532 byte[] debugData) throws IOException { in goAway() argument
535 int length = 8 + debugData.length; in goAway()
542 if (debugData.length > 0) { in goAway()
543 sink.write(debugData); in goAway()
DFrameReader.java80 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() argument
DFrameWriter.java98 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
DFramedConnection.java780 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
781 if (debugData.size() > 0) { // TODO: log the debugData in goAway()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DHttp2.java343 ByteString debugData = EMPTY; in readGoAway() local
345 debugData = source.readByteString(opaqueDataLength); in readGoAway()
347 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
530 byte[] debugData) throws IOException { in goAway() argument
533 int length = 8 + debugData.length; in goAway()
540 if (debugData.length > 0) { in goAway()
541 sink.write(debugData); in goAway()
DFrameWriter.java96 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
DFrameReader.java78 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() argument
DFramedConnection.java775 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
776 if (debugData.size() > 0) { // TODO: log the debugData in goAway()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyClientHandler.java244 public void onGoAwayReceived(int lastStreamId, long errorCode, ByteBuf debugData) { in NettyClientHandler()
245 byte[] debugDataBytes = ByteBufUtil.getBytes(debugData); in NettyClientHandler()
548 lifecycleManager.notifyShutdown(statusFromGoAway(e.errorCode(), e.debugData())); in createStream()
701 private Status statusFromGoAway(long errorCode, byte[] debugData) { in statusFromGoAway() argument
704 if (debugData != null && debugData.length > 0) { in statusFromGoAway()
706 String msg = new String(debugData, UTF_8); in statusFromGoAway()
DNettyServerHandler.java758 ByteBuf debugData = ByteBufUtil.writeAscii(ctx.alloc(), "too_many_pings"); in onPingRead() local
760 debugData, ctx.newPromise()); in onPingRead()
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DHttp2.java349 ByteString debugData = EMPTY; in readGoAway() local
351 debugData = source.readByteString(opaqueDataLength); in readGoAway()
353 handler.goAway(lastStreamId, errorCode, debugData); in readGoAway()
536 byte[] debugData) throws IOException { in goAway() argument
539 int length = 8 + debugData.length; in goAway()
546 if (debugData.length > 0) { in goAway()
547 sink.write(debugData); in goAway()
DFrameWriter.java100 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
DFrameReader.java82 …ay(int lastGoodStreamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode, ByteString debugData); in goAway() argument
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java185 final byte[] debugData) { in goAway() argument
189 frameWriter.goAway(lastGoodStreamId, errorCode, debugData); in goAway()
DOkHttpClientTransport.java1137 public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
1139 String data = debugData.utf8(); in goAway()
1148 if (debugData.size() > 0) { in goAway()
1150 status = status.augmentDescription(debugData.utf8()); in goAway()
/external/syzkaller/vendor/google.golang.org/grpc/transport/
Dhttp2_server.go682 …t.controlBuf.put(&goAway{code: http2.ErrCodeEnhanceYourCalm, debugData: []byte("too_many_pings"), …
1014 func (t *http2Server) drain(code http2.ErrCode, debugData []byte) {
1021 t.controlBuf.put(&goAway{code: code, debugData: debugData, headsUp: true})
1043 if err := t.framer.fr.WriteGoAway(sid, g.code, g.debugData); err != nil {
1076 t.controlBuf.put(&goAway{code: g.code, debugData: g.debugData})
Dcontrolbuf.go149 debugData []byte member
/external/syzkaller/vendor/golang.org/x/net/http2/
Dframe.go828 debugData []byte member
837 return f.debugData
851 debugData: p[8:],
855 func (f *Framer) WriteGoAway(maxStreamID uint32, code ErrCode, debugData []byte) error {
859 f.writeBytes(debugData)
1574 f.LastStreamID, f.ErrCode, f.debugData)