udpLargeByteBufPayload() — netty Function Reference

Source Code

handler/src/test/java/io/netty/handler/pcap/PcapWriteHandlerTest.java lines 219–248

    @Test
    public void udpLargeByteBufPayload() {
        final ByteBuf pcapBuffer = Unpooled.buffer();
        //Create payload 1 byte larger than maximum
        String payloadString = new String(new char[65507 + 1]).replace('\0', 'X');
        final ByteBuf payload = Unpooled.wrappedBuffer(payloadString.getBytes());

        try {
            InetSocketAddress serverAddr = new InetSocketAddress("1.1.1.1", 1234);
            InetSocketAddress clientAddr = new InetSocketAddress("2.2.2.2", 3456);

            // We fake a client
            EmbeddedChannel embeddedChannel = new EmbeddedDatagramChannel(clientAddr, serverAddr);
            embeddedChannel.pipeline().addLast(PcapWriteHandler.builder()
                    .build(new ByteBufOutputStream(pcapBuffer)));

            assertTrue(embeddedChannel.writeOutbound(payload.retainedDuplicate()));
            ByteBuf read = embeddedChannel.readOutbound();
            assertEquals(payload, read);
            read.release();

            // Verify only the PCAP global header was written. Large UDP payload should be discarded
            assertEquals(24, pcapBuffer.readableBytes());

            assertFalse(embeddedChannel.finishAndReleaseAll());
        } finally {
            pcapBuffer.release();
            payload.release();
        }
    }