IoRegistration() — netty Function Reference

Architecture documentation for the IoRegistration() function in EpollIoHandler.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ IoRegistration() — netty Function Reference

Dependency Diagram

graph TD
  b76e719f_e7f5_86e3_46e6_fb56c280ea70["IoRegistration()"]
  e531fecb_b495_8b97_8d1b_49ff2b5ccdbb["EpollIoHandler"]
  b76e719f_e7f5_86e3_46e6_fb56c280ea70 -->|defined in| e531fecb_b495_8b97_8d1b_49ff2b5ccdbb
  91c558da_4f14_91c3_d40d_83c24a9c6f9f["DefaultEpollIoRegistration()"]
  b76e719f_e7f5_86e3_46e6_fb56c280ea70 -->|calls| 91c558da_4f14_91c3_d40d_83c24a9c6f9f
  0426876f_cf70_aa35_5c7a_378f7b887062["isValid()"]
  b76e719f_e7f5_86e3_46e6_fb56c280ea70 -->|calls| 0426876f_cf70_aa35_5c7a_378f7b887062
  style b76e719f_e7f5_86e3_46e6_fb56c280ea70 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/EpollIoHandler.java lines 321–339

    @Override
    public IoRegistration register(IoHandle handle)
            throws Exception {
        final EpollIoHandle epollHandle = cast(handle);
        DefaultEpollIoRegistration registration = new DefaultEpollIoRegistration(executor, epollHandle);
        int fd = epollHandle.fd().intValue();
        Native.epollCtlAdd(epollFd.intValue(), fd, EpollIoOps.EPOLLERR.value);
        DefaultEpollIoRegistration old = registrations.put(fd, registration);

        // We either expect to have no registration in the map with the same FD or that the FD of the old registration
        // is already closed.
        assert old == null || !old.isValid();

        if (epollHandle instanceof AbstractEpollChannel.AbstractEpollUnsafe) {
            numChannels++;
        }
        handle.registered();
        return registration;
    }