testPinExecutor() — netty Function Reference

Architecture documentation for the testPinExecutor() function in DefaultChannelPipelineTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testPinExecutor() — netty Function Reference

Dependency Diagram

graph TD
  49930036_e90f_29ea_b481_7c0d78aee751["testPinExecutor()"]
  666d912b_4166_a807_ed10_ba12f328a7b2["DefaultChannelPipelineTest"]
  49930036_e90f_29ea_b481_7c0d78aee751 -->|defined in| 666d912b_4166_a807_ed10_ba12f328a7b2
  19bd3906_4c8c_ae23_6c05_b7a84d367379["shutdownGracefully()"]
  49930036_e90f_29ea_b481_7c0d78aee751 -->|calls| 19bd3906_4c8c_ae23_6c05_b7a84d367379
  style 49930036_e90f_29ea_b481_7c0d78aee751 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 1575–1594

    @Test
    public void testPinExecutor() {
        EventExecutorGroup group = new MultiThreadIoEventLoopGroup(LocalIoHandler.newFactory());
        ChannelPipeline pipeline = new LocalChannel().pipeline();
        ChannelPipeline pipeline2 = new LocalChannel().pipeline();

        pipeline.addLast(group, "h1", new ChannelInboundHandlerAdapter());
        pipeline.addLast(group, "h2", new ChannelInboundHandlerAdapter());
        pipeline2.addLast(group, "h3", new ChannelInboundHandlerAdapter());

        EventExecutor executor1 = pipeline.context("h1").executor();
        EventExecutor executor2 = pipeline.context("h2").executor();
        assertNotNull(executor1);
        assertNotNull(executor2);
        assertSame(executor1, executor2);
        EventExecutor executor3 = pipeline2.context("h3").executor();
        assertNotNull(executor3);
        assertNotSame(executor3, executor2);
        group.shutdownGracefully(0, 0, TimeUnit.SECONDS);
    }