testUnixEncodeProxyV2() — netty Function Reference

Source Code

codec-haproxy/src/test/java/io/netty/handler/codec/haproxy/HaProxyMessageEncoderTest.java lines 188–229

    @Test
    public void testUnixEncodeProxyV2() {
        EmbeddedChannel ch = new EmbeddedChannel(INSTANCE);

        HAProxyMessage message = new HAProxyMessage(
                HAProxyProtocolVersion.V2, HAProxyCommand.PROXY, HAProxyProxiedProtocol.UNIX_STREAM,
                "/var/run/src.sock", "/var/run/dst.sock", 0, 0);
        assertTrue(ch.writeOutbound(message));

        ByteBuf byteBuf = ch.readOutbound();

        // header
        byte[] headerBytes = ByteBufUtil.getBytes(byteBuf, 0, 12);
        assertArrayEquals(BINARY_PREFIX, headerBytes);

        // command
        byte commandByte = byteBuf.getByte(12);
        assertEquals(0x02, (commandByte & 0xf0) >> 4);
        assertEquals(0x01, commandByte & 0x0f);

        // transport protocol, address family
        byte transportByte = byteBuf.getByte(13);
        assertEquals(0x03, (transportByte & 0xf0) >> 4);
        assertEquals(0x01, transportByte & 0x0f);

        // address length
        int addrLength = byteBuf.getUnsignedShort(14);
        assertEquals(TOTAL_UNIX_ADDRESS_BYTES_LENGTH, addrLength);

        // source address
        int srcAddrEnd = byteBuf.forEachByte(16, 108, ByteProcessor.FIND_NUL);
        assertEquals("/var/run/src.sock",
                     byteBuf.slice(16, srcAddrEnd - 16).toString(CharsetUtil.US_ASCII));

        // destination address
        int dstAddrEnd = byteBuf.forEachByte(124, 108, ByteProcessor.FIND_NUL);
        assertEquals("/var/run/dst.sock",
                     byteBuf.slice(124, dstAddrEnd - 124).toString(CharsetUtil.US_ASCII));

        byteBuf.release();
        assertFalse(ch.finish());
    }