netty Architecture Docs
Home / Function/ testBytesInArrayMultipleThreads() — netty Function Reference

testBytesInArrayMultipleThreads() — netty Function Reference

Architecture documentation for the testBytesInArrayMultipleThreads() function in AbstractByteBufTest.java from the netty codebase.

Function java Buffer Search called by 2

Entity Profile

Dependency Diagram

graph TD
  bcd0acec_15f2_8a24_2e29_66b8b64286f9["testBytesInArrayMultipleThreads()"]
  6540f2d1_cdad_6705_dd1d_9a24e2e53242["AbstractByteBufTest"]
  bcd0acec_15f2_8a24_2e29_66b8b64286f9 -->|defined in| 6540f2d1_cdad_6705_dd1d_9a24e2e53242
  dca2fc22_fdff_0894_50b4_9f85e5dd7d81["testDuplicateBytesInArrayMultipleThreads()"]
  dca2fc22_fdff_0894_50b4_9f85e5dd7d81 -->|calls| bcd0acec_15f2_8a24_2e29_66b8b64286f9
  447bfc15_42a2_7a1e_11aa_5bdab4d10470["testSliceBytesInArrayMultipleThreads()"]
  447bfc15_42a2_7a1e_11aa_5bdab4d10470 -->|calls| bcd0acec_15f2_8a24_2e29_66b8b64286f9
  style bcd0acec_15f2_8a24_2e29_66b8b64286f9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/test/java/io/netty/buffer/AbstractByteBufTest.java lines 2882–2921

    static void testBytesInArrayMultipleThreads(
            final ByteBuf buffer, final byte[] expectedBytes, final boolean slice) throws Exception {
        final AtomicReference<Throwable> cause = new AtomicReference<Throwable>();
        final CountDownLatch latch = new CountDownLatch(60000);
        final CyclicBarrier barrier = new CyclicBarrier(11);
        for (int i = 0; i < 10; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    while (cause.get() == null && latch.getCount() > 0) {
                        ByteBuf buf;
                        if (slice) {
                            buf = buffer.slice();
                        } else {
                            buf = buffer.duplicate();
                        }

                        byte[] array = new byte[8];
                        buf.readBytes(array);

                        assertArrayEquals(expectedBytes, array);

                        Arrays.fill(array, (byte) 0);
                        buf.getBytes(0, array);
                        assertArrayEquals(expectedBytes, array);

                        latch.countDown();
                    }
                    try {
                        barrier.await();
                    } catch (Exception e) {
                        // ignore
                    }
                }
            }).start();
        }
        latch.await(10, TimeUnit.SECONDS);
        barrier.await(5, TimeUnit.SECONDS);
        assertNull(cause.get());
    }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does testBytesInArrayMultipleThreads() do?
testBytesInArrayMultipleThreads() is a function in the netty codebase, defined in buffer/src/test/java/io/netty/buffer/AbstractByteBufTest.java.
Where is testBytesInArrayMultipleThreads() defined?
testBytesInArrayMultipleThreads() is defined in buffer/src/test/java/io/netty/buffer/AbstractByteBufTest.java at line 2882.
What calls testBytesInArrayMultipleThreads()?
testBytesInArrayMultipleThreads() is called by 2 function(s): testDuplicateBytesInArrayMultipleThreads, testSliceBytesInArrayMultipleThreads.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free