IoHandler() — netty Function Reference

Architecture documentation for the IoHandler() function in MultiThreadIoEventLoopGroupTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ IoHandler() — netty Function Reference

Dependency Diagram

graph TD
  bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf["IoHandler()"]
  31aeea14_2a69_571c_11d5_791022d5d05f["TestIoHandlerFactory"]
  bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf -->|defined in| 31aeea14_2a69_571c_11d5_791022d5d05f
  9830fcb8_e5b5_cc90_d277_35c9a3443446["run()"]
  bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf -->|calls| 9830fcb8_e5b5_cc90_d277_35c9a3443446
  style bf26b1d1_cf9e_11e8_61db_9c1f32fbbcbf fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/MultiThreadIoEventLoopGroupTest.java lines 50–82

        @Override
        public IoHandler newHandler(ThreadAwareExecutor ioExecutor) {
            return new IoHandler() {
                @Override public int run(IoHandlerContext context) {
                    return 0;
                }

                @Override public void wakeup() {
                }

                @Override
                public IoRegistration register(IoHandle handle) {
                    return new IoRegistration() {
                        private final AtomicBoolean valid = new AtomicBoolean(true);
                        @Override public <T> T attachment() {
                            return (T) handle;
                        }
                        @Override public long submit(IoOps ops) {
                            return 0;
                        }
                        @Override public boolean isValid() {
                            return valid.get();
                        }
                        @Override public boolean cancel() {
                            return valid.compareAndSet(true, false);
                        }
                    };
                }
                @Override public boolean isCompatible(Class<? extends IoHandle> handleType) {
                    return true;
                }
            };
        }