processReady() — netty Function Reference

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

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ processReady() — netty Function Reference

Dependency Diagram

graph TD
  5ba14c5c_ef39_cdce_457c_9129f8d99762["processReady()"]
  e531fecb_b495_8b97_8d1b_49ff2b5ccdbb["EpollIoHandler"]
  5ba14c5c_ef39_cdce_457c_9129f8d99762 -->|defined in| e531fecb_b495_8b97_8d1b_49ff2b5ccdbb
  243595e7_7d39_0bf2_9688_f649d92dd080["run()"]
  243595e7_7d39_0bf2_9688_f649d92dd080 -->|calls| 5ba14c5c_ef39_cdce_457c_9129f8d99762
  a8d55529_65e9_1e0a_675a_0a968a279073["handle()"]
  5ba14c5c_ef39_cdce_457c_9129f8d99762 -->|calls| a8d55529_65e9_1e0a_675a_0a968a279073
  style 5ba14c5c_ef39_cdce_457c_9129f8d99762 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/EpollIoHandler.java lines 502–530

    private boolean processReady(EpollEventArray events, int ready) {
        boolean timerFired = false;
        for (int i = 0; i < ready; i ++) {
            final int fd = events.fd(i);
            if (fd == eventFd.intValue()) {
                pendingWakeup = false;
            } else if (fd == timerFd.intValue()) {
                timerFired = true;
            } else {
                final long ev = events.events(i);

                DefaultEpollIoRegistration registration = registrations.get(fd);
                if (registration != null) {
                    registration.handle(ev);
                } else {
                    // We received an event for an fd which we not use anymore. Remove it from the epoll_event set.
                    try {
                        Native.epollCtlDel(epollFd.intValue(), fd);
                    } catch (IOException ignore) {
                        // This can happen but is nothing we need to worry about as we only try to delete
                        // the fd from the epoll set as we not found it in our mappings. So this call to
                        // epollCtlDel(...) is just to ensure we cleanup stuff and so may fail if it was
                        // deleted before or the file descriptor was closed before.
                    }
                }
            }
        }
        return timerFired;
    }