testRunNow() — netty Function Reference

Architecture documentation for the testRunNow() function in ManualIoEventLoopTest.java from the netty codebase.

Function java Buffer Search calls 2

Entity Profile

Buffer→ Search→ testRunNow() — netty Function Reference

Dependency Diagram

graph TD
  a22b613f_a735_8b38_cbf9_df7cb518daa3["testRunNow()"]
  7f1091cc_a8b6_0293_92ad_d94222ae6482["ManualIoEventLoopTest"]
  a22b613f_a735_8b38_cbf9_df7cb518daa3 -->|defined in| 7f1091cc_a8b6_0293_92ad_d94222ae6482
  3bf16ebe_cf8d_923f_9559_397075f9b2a1["TestIoHandler()"]
  a22b613f_a735_8b38_cbf9_df7cb518daa3 -->|calls| 3bf16ebe_cf8d_923f_9559_397075f9b2a1
  a3e5c62f_e788_a2c4_0d6f_61347ddb0c79["isDone()"]
  a22b613f_a735_8b38_cbf9_df7cb518daa3 -->|calls| a3e5c62f_e788_a2c4_0d6f_61347ddb0c79
  style a22b613f_a735_8b38_cbf9_df7cb518daa3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ManualIoEventLoopTest.java lines 49–69

    @Test
    public void testRunNow() throws Exception {
        Thread currentThread = Thread.currentThread();
        Semaphore semaphore = new Semaphore(0);
        ManualIoEventLoop eventLoop = new ManualIoEventLoop(currentThread, executor ->
                new TestIoHandler(semaphore));
        assertEquals(0, eventLoop.runNow());

        TestRunnable runnable = new TestRunnable();
        eventLoop.execute(runnable);
        assertFalse(runnable.isDone());

        assertEquals(1, eventLoop.runNow());
        assertTrue(runnable.isDone());
        eventLoop.shutdown();
        while (!eventLoop.isTerminated()) {
            eventLoop.runNow();
        }

        eventLoop.terminationFuture().sync();
    }