/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
D | Spdy3Test.java | 78 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()
|
D | Http2Test.java | 579 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()
|
D | BaseTestHandler.java | 53 @Override public void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData) { in goAway() argument
|
D | MockSpdyPeer.java | 288 @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/ |
D | Http2.java | 345 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()
|
D | FrameReader.java | 80 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() argument
|
D | FrameWriter.java | 98 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
|
D | FramedConnection.java | 780 @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/ |
D | Http2.java | 343 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()
|
D | FrameWriter.java | 96 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
|
D | FrameReader.java | 78 void goAway(int lastGoodStreamId, ErrorCode errorCode, ByteString debugData); in goAway() argument
|
D | FramedConnection.java | 775 @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/ |
D | NettyClientHandler.java | 244 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()
|
D | NettyServerHandler.java | 758 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/ |
D | Http2.java | 349 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()
|
D | FrameWriter.java | 100 void goAway(int lastGoodStreamId, ErrorCode errorCode, byte[] debugData) throws IOException; in goAway() argument
|
D | FrameReader.java | 82 …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/ |
D | AsyncFrameWriter.java | 185 final byte[] debugData) { in goAway() argument 189 frameWriter.goAway(lastGoodStreamId, errorCode, debugData); in goAway()
|
D | OkHttpClientTransport.java | 1137 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/ |
D | http2_server.go | 682 …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})
|
D | controlbuf.go | 149 debugData []byte member
|
/external/syzkaller/vendor/golang.org/x/net/http2/ |
D | frame.go | 828 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)
|