tcpLargePayload() — netty Function Reference

Source Code

handler/src/test/java/io/netty/handler/pcap/PcapWriteHandlerTest.java lines 700–739

    @Test
    public void tcpLargePayload() {
        final ByteBuf pcapBuffer = Unpooled.buffer();
        String payloadString = new String(new char[65495 + 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);

            EmbeddedChannel embeddedChannel = new EmbeddedChannel(
                    PcapWriteHandler.builder()
                            .forceTcpChannel(serverAddr, clientAddr, false)
                            .build(new ByteBufOutputStream(pcapBuffer))
            );

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

            assertFalse(embeddedChannel.finishAndReleaseAll());

            // Verify the capture data
            verifyTcpHandshakeCapture(true, pcapBuffer, serverAddr, clientAddr);
            //Verify client write
            verifyTcpCapture(pcapBuffer, payload.slice(0, 65495),
                    serverAddr, clientAddr,
                    1, 1);
            //Verify client write
            verifyTcpCapture(pcapBuffer, payload.slice(65495, 1),
                    serverAddr, clientAddr,
                    65496, 1);

            verifyTcpCloseCapture(pcapBuffer, serverAddr, clientAddr,
                    65497, 1); //Client has received 4 bytes and sent 5 bytes
        } finally {
            pcapBuffer.release();
            payload.release();
        }
    }