testFrameEncodedAndDecoded() — netty Function Reference

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/Http3FrameCodecTest.java lines 608–668

    private void testFrameEncodedAndDecoded(
            boolean fragmented, int maxBlockedStreams, boolean delayQpackStreams, Http3Frame frame) throws Exception {
        final boolean isDataFrame = frame instanceof Http3DataFrame;
        final boolean isHeaderFrame = frameContainsHeaders(frame);

        encodeFrame(delayQpackStreams, frame, isHeaderFrame);

        if (isWriteBuffered(delayQpackStreams, isHeaderFrame)) {
            setQpackStreams();
            codecChannel.checkException();
        }
        ByteBuf buffer = codecChannel.readOutbound();

        if (fragmented) {
            try {
                do {
                    ByteBuf slice = buffer.readRetainedSlice(
                            ThreadLocalRandom.current().nextInt(buffer.readableBytes() + 1));
                    boolean producedData = codecChannel.writeInbound(slice);
                    if (!isDataFrame) {
                        if (buffer.isReadable() || (isHeaderFrame && maxBlockedStreams > 0)) {
                            assertFalse(producedData);
                        } else {
                            assertTrue(producedData);
                        }
                    }
                } while (buffer.isReadable());
            } catch (Exception e) {
                if (isDataFrame) {
                    ReferenceCountUtil.release(frame);
                }
                throw e;
            } finally {
                buffer.release();
            }
        } else {
            if (maxBlockedStreams > 0 && isHeaderFrame) {
                assertFalse(codecChannel.writeInbound(buffer));
            } else {
                assertTrue(codecChannel.writeInbound(buffer));
            }
        }

        relayQPACKEncoderInstructions();

        final Http3Frame actualFrame;
        if (isDataFrame) {
            CompositeByteBuf composite = Unpooled.compositeBuffer();
            for (;;) {
                Http3DataFrame dataFrame = codecChannel.readInbound();
                if (dataFrame == null) {
                    break;
                }
                composite.addComponent(true, dataFrame.content());
            }
            actualFrame = new DefaultHttp3DataFrame(composite);
        } else {
            actualFrame = codecChannel.readInbound();
        }
        Http3TestUtils.assertFrameEquals(frame, actualFrame);
    }