doRegister() — netty Function Reference

Architecture documentation for the doRegister() function in LocalServerChannel.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ doRegister() — netty Function Reference

Dependency Diagram

graph TD
  f5b944d8_41ce_9b6b_87c6_8eb0f4c80bfe["doRegister()"]
  1a58c560_dde9_7403_e4d4_f9cf37a89c81["LocalServerChannel"]
  f5b944d8_41ce_9b6b_87c6_8eb0f4c80bfe -->|defined in| 1a58c560_dde9_7403_e4d4_f9cf37a89c81
  322a4f58_cd62_d84a_4589_5e48dfb77af8["registered()"]
  f5b944d8_41ce_9b6b_87c6_8eb0f4c80bfe -->|calls| 322a4f58_cd62_d84a_4589_5e48dfb77af8
  style f5b944d8_41ce_9b6b_87c6_8eb0f4c80bfe fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalServerChannel.java lines 100–122

    @Override
    protected void doRegister(ChannelPromise promise) {
        EventLoop loop = eventLoop();
        if (loop instanceof IoEventLoop) {
            assert registration == null;
            ((IoEventLoop) loop).register((LocalServerUnsafe) unsafe()).addListener(f -> {
                if (f.isSuccess()) {
                    registration = (IoRegistration) f.getNow();
                    promise.setSuccess();
                } else {
                    promise.setFailure(f.cause());
                }
            });
        } else {
            try {
                ((LocalServerUnsafe) unsafe()).registered();
            } catch (Throwable cause) {
                promise.setFailure(cause);
                return;
            }
            promise.setSuccess();
        }
    }