onHttp2GoAwayFrame() — netty Function Reference

Architecture documentation for the onHttp2GoAwayFrame() function in Http2MultiplexCodec.java from the netty codebase.

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ onHttp2GoAwayFrame() — netty Function Reference

Dependency Diagram

graph TD
  7a9be5dc_4230_32da_7f05_59f39e1e3d2c["onHttp2GoAwayFrame()"]
  a7ac469b_ce05_746a_3b73_34450541872b["Http2MultiplexCodec"]
  7a9be5dc_4230_32da_7f05_59f39e1e3d2c -->|defined in| a7ac469b_ce05_746a_3b73_34450541872b
  32b10e6c_b784_372e_860b_7e037423e94b["onHttp2Frame()"]
  32b10e6c_b784_372e_860b_7e037423e94b -->|calls| 7a9be5dc_4230_32da_7f05_59f39e1e3d2c
  style 7a9be5dc_4230_32da_7f05_59f39e1e3d2c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/Http2MultiplexCodec.java lines 220–243

    private void onHttp2GoAwayFrame(ChannelHandlerContext ctx, final Http2GoAwayFrame goAwayFrame) {
        if (goAwayFrame.lastStreamId() == Integer.MAX_VALUE) {
            // None of the streams can have an id greater than Integer.MAX_VALUE
            return;
        }
        // Notify which streams were not processed by the remote peer and are safe to retry on another connection:
        try {
            forEachActiveStream(new Http2FrameStreamVisitor() {
                @Override
                public boolean visit(Http2FrameStream stream) {
                    final int streamId = stream.id();
                    AbstractHttp2StreamChannel channel = (AbstractHttp2StreamChannel)
                            ((DefaultHttp2FrameStream) stream).attachment;
                    if (streamId > goAwayFrame.lastStreamId() && connection().local().isValidStreamId(streamId)) {
                        channel.pipeline().fireUserEventTriggered(goAwayFrame.retainedDuplicate());
                    }
                    return true;
                }
            });
        } catch (Http2Exception e) {
            ctx.fireExceptionCaught(e);
            ctx.close();
        }
    }