testIpFilterRuleHandler() — netty Function Reference

Architecture documentation for the testIpFilterRuleHandler() function in IpSubnetFilterTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ testIpFilterRuleHandler() — netty Function Reference

Dependency Diagram

graph TD
  6f2ed5ea_ccb8_c96d_f929_ec086cb30f00["testIpFilterRuleHandler()"]
  a29baed8_7220_9a86_5676_d9b84ff398ba["IpSubnetFilterTest"]
  6f2ed5ea_ccb8_c96d_f929_ec086cb30f00 -->|defined in| a29baed8_7220_9a86_5676_d9b84ff398ba
  style 6f2ed5ea_ccb8_c96d_f929_ec086cb30f00 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ipfilter/IpSubnetFilterTest.java lines 92–137

    @Test
    public void testIpFilterRuleHandler() throws Exception {
        IpFilterRule filter0 = new IpFilterRule() {
            @Override
            public boolean matches(InetSocketAddress remoteAddress) {
                return "192.168.57.1".equals(remoteAddress.getHostName());
            }

            @Override
            public IpFilterRuleType ruleType() {
                return IpFilterRuleType.REJECT;
            }
        };

        RuleBasedIpFilter denyHandler = new RuleBasedIpFilter(filter0) {
            private final byte[] message = {1, 2, 3, 4, 5, 6, 7};

            @Override
            protected ChannelFuture channelRejected(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) {
                assertTrue(ctx.channel().isActive());
                assertTrue(ctx.channel().isWritable());
                assertEquals("192.168.57.1", remoteAddress.getHostName());

                return ctx.writeAndFlush(Unpooled.wrappedBuffer(message));
            }
        };
        EmbeddedChannel chDeny = newEmbeddedInetChannel("192.168.57.1", denyHandler);
        ByteBuf out = chDeny.readOutbound();
        assertEquals(7, out.readableBytes());
        for (byte i = 1; i <= 7; i++) {
            assertEquals(i, out.readByte());
        }
        assertFalse(chDeny.isActive());
        assertFalse(chDeny.isOpen());

        RuleBasedIpFilter allowHandler = new RuleBasedIpFilter(filter0) {
            @Override
            protected ChannelFuture channelRejected(ChannelHandlerContext ctx, InetSocketAddress remoteAddress) {
                fail();
                return null;
            }
        };
        EmbeddedChannel chAllow = newEmbeddedInetChannel("192.168.57.2", allowHandler);
        assertTrue(chAllow.isActive());
        assertTrue(chAllow.isOpen());
    }