processReady() — netty Function Reference

Architecture documentation for the processReady() function in KQueueIoHandler.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
  7640e0e3_85f5_efbd_4f2c_d9c5ed5c87a0["processReady()"]
  75a3ba71_0590_fec0_e352_8a91c916c5af["KQueueIoHandler"]
  7640e0e3_85f5_efbd_4f2c_d9c5ed5c87a0 -->|defined in| 75a3ba71_0590_fec0_e352_8a91c916c5af
  fa6e02de_7726_4944_12b6_ecd3e40bbdcb["run()"]
  fa6e02de_7726_4944_12b6_ecd3e40bbdcb -->|calls| 7640e0e3_85f5_efbd_4f2c_d9c5ed5c87a0
  7ce17382_ba1a_c3fd_715c_71ef04f26d10["handle()"]
  7640e0e3_85f5_efbd_4f2c_d9c5ed5c87a0 -->|calls| 7ce17382_ba1a_c3fd_715c_71ef04f26d10
  style 7640e0e3_85f5_efbd_4f2c_d9c5ed5c87a0 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/KQueueIoHandler.java lines 192–216

    private void processReady(int ready) {
        for (int i = 0; i < ready; ++i) {
            final short filter = eventList.filter(i);
            final short flags = eventList.flags(i);
            final int ident = eventList.ident(i);
            if (filter == Native.EVFILT_USER || (flags & Native.EV_ERROR) != 0) {
                // EV_ERROR is returned if the FD is closed synchronously (which removes from kqueue) and then
                // we later attempt to delete the filters from kqueue.
                assert filter != Native.EVFILT_USER ||
                        (filter == Native.EVFILT_USER && ident == KQUEUE_WAKE_UP_IDENT);
                continue;
            }

            long id = eventList.udata(i);
            DefaultKqueueIoRegistration registration = registrations.get(id);
            if (registration == null) {
                // This may happen if the channel has already been closed, and it will be removed from kqueue anyways.
                // We also handle EV_ERROR above to skip this even early if it is a result of a referencing a closed and
                // thus removed from kqueue FD.
                logger.warn("events[{}]=[{}, {}, {}] had no registration!", i, ident, id, filter);
                continue;
            }
            registration.handle(ident, filter, flags, eventList.fflags(i), eventList.data(i), id);
        }
    }