unknownFrameOnMissingStreamFirstPacket() — netty Function Reference

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/Http2FrameCodecTest.java lines 426–461

    @Test
    public void unknownFrameOnMissingStreamFirstPacket() throws Exception {
        setUp(Http2FrameCodecBuilder.forClient(), new Http2Settings(), false);

        // SETTINGS and UNKNOWN must come in on the same packet to trigger the bug
        channel.pipeline().addFirst("combine", new ChannelInboundHandlerAdapter() {
            CompositeByteBuf accumulate;

            @Override
            public void channelRead(ChannelHandlerContext ctx, Object msg) {
                if (accumulate == null) {
                    accumulate = ctx.alloc().compositeBuffer();
                }
                accumulate.addComponent(true, (ByteBuf) msg);
            }

            @Override
            public void handlerRemoved(ChannelHandlerContext ctx) {
                if (accumulate != null) {
                    ctx.fireChannelRead(accumulate);
                    ctx.fireChannelReadComplete();
                }
            }
        });

        frameInboundWriter.writeInboundSettings(new Http2Settings());

        ByteBuf debugData = bb("debug");
        frameInboundWriter.writeInboundFrame((byte) 0xb, 101, new Http2Flags(), debugData);

        channel.pipeline().remove("combine");
        channel.flushInbound();

        assertEquals(0, debugData.refCnt());
        assertTrue(channel.isActive());
    }