testLeakBrokenHint() — netty Function Reference

Source Code

common/src/test/java/io/netty/util/ResourceLeakDetectorTest.java lines 130–164

    @Timeout(10)
    @Test
    public void testLeakBrokenHint() throws Throwable {
        DefaultResource.detectorWithSetupHint.initialise();

        DefaultResource.detectorWithSetupHint.failOnUntraced = false;
        DefaultResource.detectorWithSetupHint.initialHint = new ResourceLeakHint() {
            @Override
            public String toHintString() {
                throw new RuntimeException("expected failure");
            }
        };
        try {
            leakResource();
            fail("expected failure");
        } catch (RuntimeException e) {
            assertThat(e.getMessage()).isEqualTo("expected failure");
        }
        DefaultResource.detectorWithSetupHint.initialHint = DefaultResource.detectorWithSetupHint.canaryString;

        do {
            // Trigger GC.
            System.gc();
            // Track another resource to trigger refqueue visiting.
            Resource resource2 = new DefaultResource();
            DefaultResource.detectorWithSetupHint.track(resource2).close(resource2);
            // Give the GC something to work on.
            for (int i = 0; i < 1000; i++) {
                sink = System.identityHashCode(new byte[10000]);
            }
        } while (DefaultResource.detectorWithSetupHint.getLeaksFound() < 1 && !Thread.interrupted());

        assertThat(DefaultResource.detectorWithSetupHint.getLeaksFound()).isOne();
        DefaultResource.detectorWithSetupHint.assertNoErrors();
    }