| /external/pigweed/pw_grpc/ |
| D | connection.cc | 58 enum class Http2Error : uint32_t { enum
81 using internal::Http2Error;
218 SendGoAway(Http2Error::PROTOCOL_ERROR); in ProcessFrame()
222 SendGoAway(Http2Error::INTERNAL_ERROR); in ProcessFrame()
390 Http2Error code) { in SendRstStream()
675 SendGoAway(Http2Error::PROTOCOL_ERROR); in ProcessDataFrame()
719 PW_TRY(SendRstStreamAndClose(state, stream, Http2Error::STREAM_CLOSED)); in ProcessDataFrame()
732 SendGoAway(Http2Error::FRAME_SIZE_ERROR); in ProcessDataFrame()
741 SendGoAway(Http2Error::PROTOCOL_ERROR); in ProcessDataFrame()
781 SendRstStreamAndClose(state, stream, Http2Error::INTERNAL_ERROR)); in ProcessDataFrame()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | GrpcUtilTest.java | 39 import io.grpc.internal.GrpcUtil.Http2Error;
71 assertNull(Http2Error.forCode(-1)); in http2ErrorForCode()
72 assertSame(Http2Error.NO_ERROR, Http2Error.forCode(0)); in http2ErrorForCode()
73 assertSame(Http2Error.HTTP_1_1_REQUIRED, Http2Error.forCode(0xD)); in http2ErrorForCode()
74 assertNull(Http2Error.forCode(0xD + 1)); in http2ErrorForCode()
79 for (Http2Error error : Http2Error.values()) { in http2ErrorRoundTrip()
80 assertSame(error, Http2Error.forCode(error.code())); in http2ErrorRoundTrip()
87 assertSame(Status.Code.CANCELLED, Http2Error.CANCEL.status().getCode()); in http2ErrorStatus()
92 assertSame(Status.Code.INTERNAL, Http2Error.statusForCode(-1).getCode()); in http2ErrorStatusForCode()
93 assertSame(Http2Error.NO_ERROR.status(), Http2Error.statusForCode(0)); in http2ErrorStatusForCode()
[all …]
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 81 import io.netty.handler.codec.http2.Http2Error;
299 channelRead(rstStreamFrame(STREAM_ID, (int) Http2Error.CANCEL.code())); in clientCancelShouldForwardToStreamListener()
338 verifyWrite().writeGoAway(eq(ctx()), eq(Integer.MAX_VALUE), eq(Http2Error.NO_ERROR.code()), in closeShouldGracefullyCloseChannel()
347 verifyWrite().writeGoAway(eq(ctx()), eq(0), eq(Http2Error.NO_ERROR.code()), in closeShouldGracefullyCloseChannel()
360 verifyWrite().writeGoAway(eq(ctx()), eq(Integer.MAX_VALUE), eq(Http2Error.NO_ERROR.code()), in gracefulCloseShouldGracefullyCloseChannel()
369 verifyWrite().writeGoAway(eq(ctx()), eq(0), eq(Http2Error.NO_ERROR.code()), in gracefulCloseShouldGracefullyCloseChannel()
381 verifyWrite().writeGoAway(eq(ctx()), eq(Integer.MAX_VALUE), eq(Http2Error.NO_ERROR.code()), in secondGracefulCloseIsSafe()
399 verifyWrite().writeGoAway(eq(ctx()), eq(0), eq(Http2Error.NO_ERROR.code()), in secondGracefulCloseIsSafe()
469 eq(Http2Error.CANCEL.code()), any(ChannelPromise.class)); in cancelShouldSendRstStream()
606 eq(Http2Error.PROTOCOL_ERROR.code()), in headersWithConnectionHeaderShouldFail()
[all …]
|
| D | NettyClientHandlerTest.java | 84 import io.netty.handler.codec.http2.Http2Error;
247 verifyWrite().writeRstStream(eq(ctx()), eq(STREAM_ID), eq(Http2Error.CANCEL.code()), in cancelShouldSucceed()
259 verifyWrite().writeRstStream(eq(ctx()), eq(STREAM_ID), eq(Http2Error.CANCEL.code()), in cancelDeadlineExceededShouldSucceed()
289 eq(Http2Error.CANCEL.code()), any(ChannelPromise.class)); in cancelTwiceShouldSucceed()
301 verifyWrite().writeRstStream(eq(ctx()), eq(STREAM_ID), eq(Http2Error.CANCEL.code()), in cancelTwiceDifferentReasons()
369 goAwayFrame(streamId - 1, (int) Http2Error.PROTOCOL_ERROR.code(), Unpooled.EMPTY_BUFFER)); in receivedGoAwayErrorShouldRefuseLaterStreamId()
450 channelRead(rstStreamFrame(streamId, (int) Http2Error.REFUSED_STREAM.code() )); in receivedResetWithRefuseCode()
458 channelRead(rstStreamFrame(streamId, (int) Http2Error.CANCEL.code())); in receivedResetWithCanceCode()
|
| D | UtilsTest.java | 41 import io.netty.handler.codec.http2.Http2Error;
67 t = new Http2Exception(Http2Error.INTERNAL_ERROR, "msg"); in testStatusFromThrowable()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | GrpcUtil.java | 327 public enum Http2Error { enum in GrpcUtil
350 private static final Http2Error[] codeMap = buildHttp2CodeMap();
352 private static Http2Error[] buildHttp2CodeMap() { in buildHttp2CodeMap()
353 Http2Error[] errors = Http2Error.values(); in buildHttp2CodeMap()
355 Http2Error[] http2CodeMap = new Http2Error[size]; in buildHttp2CodeMap()
356 for (Http2Error error : errors) { in buildHttp2CodeMap()
369 Http2Error(int code, Status status) { in Http2Error() method in GrpcUtil.Http2Error
398 public static Http2Error forCode(long code) { in forCode()
416 Http2Error error = forCode(code); in statusForCode()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2ResetSendingSubscription.java | 20 import io.netty.handler.codec.http2.Http2Error;
40 ctx.write(new DefaultHttp2ResetFrame(Http2Error.CANCEL)); in cancel()
|
| D | Http2ToHttpInboundAdapter.java | 27 import io.netty.handler.codec.http2.Http2Error;
98 …super(String.format("Connection reset. Error - %s(%d)", Http2Error.valueOf(errorCode).name(), erro… in Http2ResetException()
|
| /external/pigweed/pw_grpc/public/pw_grpc/ |
| D | connection.h | 38 enum class Http2Error : uint32_t;
262 Status SendRstStream(StreamId stream_id, internal::Http2Error code);
335 void SendGoAway(internal::Http2Error code);
338 internal::Http2Error code);
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | Http2ControlFrameLimitEncoder.java | 23 import io.netty.handler.codec.http2.Http2Error;
101 … Http2Exception exception = Http2Exception.connectionError(Http2Error.ENHANCE_YOUR_CALM, in handleOutstandingControlFrames()
|
| D | NettyServerHandler.java | 76 import io.netty.handler.codec.http2.Http2Error;
398 resetStream(ctx, streamId, Http2Error.PROTOCOL_ERROR.code(), ctx.newPromise()); in onHeadersRead()
557 if (serverStream == null && http2Ex.error() == Http2Error.STREAM_CLOSED) { in onStreamError()
719 resetStream(ctx, streamId, Http2Error.CANCEL.code(), promise); in sendResponseHeaders()
737 encoder().writeRstStream(ctx, cmd.stream().id(), Http2Error.CANCEL.code(), promise); in cancelStream()
768 resetStream(ctx, stream.id(), Http2Error.CANCEL.code(), ctx.newPromise()); in forcefulClose()
813 streamId, Http2Error.INTERNAL_ERROR, cause, Strings.nullToEmpty(cause.getMessage())); in newStreamException()
873 goAway(ctx, connection().remote().lastStreamCreated(), Http2Error.ENHANCE_YOUR_CALM.code(), in onPingRead()
977 Http2Error.NO_ERROR.code(), in start()
1007 Http2Error.NO_ERROR.code(), in secondGoAwayAndClose()
|
| D | NettyClientHandler.java | 64 import io.netty.handler.codec.http2.Http2Error;
286 if (errorCode == Http2Error.ENHANCE_YOUR_CALM.code()) { in NettyClientHandler()
410 errorCode == Http2Error.REFUSED_STREAM.code() in onRstStreamRead()
680 encoder().writeRstStream(ctx, stream.id(), Http2Error.CANCEL.code(), promise); in cancelStream()
788 resetStream(ctx, stream.id(), Http2Error.CANCEL.code(), ctx.newPromise()); in forcefulClose()
816 final boolean mayBeHittingNettyBug = errorCode != Http2Error.NO_ERROR.code(); in goingAway()
870 Status status = GrpcUtil.Http2Error.statusForCode(errorCode); in statusFromH2Error()
|
| D | GrpcHttp2HeadersUtils.java | 37 import static io.netty.handler.codec.http2.Http2Error.PROTOCOL_ERROR;
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpServerTransport.java | 882 Status status = GrpcUtil.Http2Error.statusForCode(errorCode.httpCode) in rstStream()
956 Status status = GrpcUtil.Http2Error.statusForCode(errorCode.httpCode) in goAway()
1013 Status status = GrpcUtil.Http2Error.statusForCode(errorCode.httpCode) in connectionError()
|
| D | OkHttpClientTransport.java | 1349 Status status = GrpcUtil.Http2Error.statusForCode(errorCode.httpCode) in goAway()
|