netty Architecture Docs
Home / Function/ epollInReadFd() — netty Function Reference

epollInReadFd() — netty Function Reference

Architecture documentation for the epollInReadFd() function in EpollDomainSocketChannel.java from the netty codebase.

Function java Buffer Search called by 1

Entity Profile

Dependency Diagram

graph TD
  4c0d9ed1_84da_87d1_a80e_6113c2fde7e3["epollInReadFd()"]
  84db7f91_bd76_2d86_db56_3c4ee63848b2["EpollDomainUnsafe"]
  4c0d9ed1_84da_87d1_a80e_6113c2fde7e3 -->|defined in| 84db7f91_bd76_2d86_db56_3c4ee63848b2
  8afbdf19_902e_f963_7c70_1aba7dfac97f["epollInReady()"]
  8afbdf19_902e_f963_7c70_1aba7dfac97f -->|calls| 4c0d9ed1_84da_87d1_a80e_6113c2fde7e3
  style 4c0d9ed1_84da_87d1_a80e_6113c2fde7e3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/EpollDomainSocketChannel.java lines 148–190

        private void epollInReadFd() {
            if (socket.isInputShutdown()) {
                clearEpollIn0();
                return;
            }
            final ChannelConfig config = config();
            final EpollRecvByteAllocatorHandle allocHandle = recvBufAllocHandle();

            final ChannelPipeline pipeline = pipeline();
            allocHandle.reset(config);

            try {
                readLoop: do {
                    // lastBytesRead represents the fd. We use lastBytesRead because it must be set so that the
                    // EpollRecvByteAllocatorHandle knows if it should try to read again or not when autoRead is
                    // enabled.
                    allocHandle.lastBytesRead(socket.recvFd());
                    switch(allocHandle.lastBytesRead()) {
                    case 0:
                        break readLoop;
                    case -1:
                        close(voidPromise());
                        return;
                    default:
                        allocHandle.incMessagesRead(1);
                        readPending = false;
                        pipeline.fireChannelRead(new FileDescriptor(allocHandle.lastBytesRead()));
                        break;
                    }
                } while (allocHandle.continueReading());

                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();
            } catch (Throwable t) {
                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();
                pipeline.fireExceptionCaught(t);
            } finally {
                if (shouldStopReading(config)) {
                    clearEpollIn();
                }
            }
        }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does epollInReadFd() do?
epollInReadFd() is a function in the netty codebase, defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/EpollDomainSocketChannel.java.
Where is epollInReadFd() defined?
epollInReadFd() is defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/EpollDomainSocketChannel.java at line 148.
What calls epollInReadFd()?
epollInReadFd() is called by 1 function(s): epollInReady.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free