testBindDeadLock() — netty Function Reference

Architecture documentation for the testBindDeadLock() function in BootstrapTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testBindDeadLock() — netty Function Reference

Dependency Diagram

graph TD
  ec02620b_b2da_3122_a397_bf5696c4602c["testBindDeadLock()"]
  7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42["BootstrapTest"]
  ec02620b_b2da_3122_a397_bf5696c4602c -->|defined in| 7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42
  style ec02620b_b2da_3122_a397_bf5696c4602c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/bootstrap/BootstrapTest.java lines 157–192

    @Test
    @Timeout(value = 10000, unit = TimeUnit.MILLISECONDS)
    public void testBindDeadLock() throws Exception {
        final Bootstrap bootstrapA = new Bootstrap();
        bootstrapA.group(groupA);
        bootstrapA.channel(LocalChannel.class);
        bootstrapA.handler(dummyHandler);

        final Bootstrap bootstrapB = new Bootstrap();
        bootstrapB.group(groupB);
        bootstrapB.channel(LocalChannel.class);
        bootstrapB.handler(dummyHandler);

        List<Future<?>> bindFutures = new ArrayList<Future<?>>();

        // Try to bind from each other.
        for (int i = 0; i < 1024; i ++) {
            bindFutures.add(groupA.next().submit(new Runnable() {
                @Override
                public void run() {
                    bootstrapB.bind(LocalAddress.ANY);
                }
            }));

            bindFutures.add(groupB.next().submit(new Runnable() {
                @Override
                public void run() {
                    bootstrapA.bind(LocalAddress.ANY);
                }
            }));
        }

        for (Future<?> f: bindFutures) {
            f.sync();
        }
    }