testRemoveAllFromFTLThread() — netty Function Reference

Architecture documentation for the testRemoveAllFromFTLThread() function in FastThreadLocalTest.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ testRemoveAllFromFTLThread() — netty Function Reference

Dependency Diagram

graph TD
  3f581515_c12c_d16f_0df0_8c5ca7e9a218["testRemoveAllFromFTLThread()"]
  c9cb652b_4141_8af2_1f8b_c47765bb30f9["FastThreadLocalTest"]
  3f581515_c12c_d16f_0df0_8c5ca7e9a218 -->|defined in| c9cb652b_4141_8af2_1f8b_c47765bb30f9
  7fb6cd58_f112_73b3_6216_2819f285c975["run()"]
  3f581515_c12c_d16f_0df0_8c5ca7e9a218 -->|calls| 7fb6cd58_f112_73b3_6216_2819f285c975
  fca80ece_95ff_ff9f_ebc8_978fc1aab436["testRemoveAll()"]
  3f581515_c12c_d16f_0df0_8c5ca7e9a218 -->|calls| fca80ece_95ff_ff9f_ebc8_978fc1aab436
  style 3f581515_c12c_d16f_0df0_8c5ca7e9a218 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/FastThreadLocalTest.java lines 107–129

    @Test
    @Timeout(value = 10000, unit = TimeUnit.MILLISECONDS)
    public void testRemoveAllFromFTLThread() throws Throwable {
        final AtomicReference<Throwable> throwable = new AtomicReference<Throwable>();
        final Thread thread = new FastThreadLocalThread() {
            @Override
            public void run() {
                try {
                    testRemoveAll();
                } catch (Throwable t) {
                    throwable.set(t);
                }
            }
        };

        thread.start();
        thread.join();

        Throwable t = throwable.get();
        if (t != null) {
            throw t;
        }
    }