testInternalThreadLocalMapExpand() — netty Function Reference

Source Code

common/src/test/java/io/netty/util/concurrent/FastThreadLocalTest.java lines 370–395

    @EnabledIfEnvironmentVariable(named = "CI", matches = "true", disabledReason = "" +
            "This deliberately causes OutOfMemoryErrors, for which heap dumps are automatically generated. " +
            "To avoid confusion, wasted time investigating heap dumps, and to avoid heap dumps accidentally " +
            "getting committed to the Git repository, we should only enable this test when running in a CI " +
            "environment. We make this check by assuming a 'CI' environment variable. " +
            "This matches what Github Actions is doing for us currently.")
    @Test
    public void testInternalThreadLocalMapExpand() throws Exception {
        final AtomicReference<Throwable> throwable = new AtomicReference<Throwable>();
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                int expand_threshold = 1 << 30;
                try {
                    InternalThreadLocalMap.get().setIndexedVariable(expand_threshold, null);
                } catch (Throwable t) {
                    throwable.set(t);
                }
            }
        };
        FastThreadLocalThread fastThreadLocalThread = new FastThreadLocalThread(runnable);
        fastThreadLocalThread.start();
        fastThreadLocalThread.join();
        // assert the expanded size is not overflowed to negative value
        assertThat(throwable.get()).isNotInstanceOf(NegativeArraySizeException.class);
    }