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

readReady() — netty Function Reference

Architecture documentation for the readReady() function in AbstractKQueueServerChannel.java from the netty codebase.

Function java Buffer Search

Entity Profile

Dependency Diagram

graph TD
  efd61915_8689_60a2_6de0_753853743540["readReady()"]
  3f71d1c0_6b81_5e83_48bb_5fe6c9dcd8c1["KQueueServerSocketUnsafe"]
  efd61915_8689_60a2_6de0_753853743540 -->|defined in| 3f71d1c0_6b81_5e83_48bb_5fe6c9dcd8c1
  style efd61915_8689_60a2_6de0_753853743540 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/AbstractKQueueServerChannel.java lines 76–119

        @Override
        void readReady(KQueueRecvByteAllocatorHandle allocHandle) {
            assert eventLoop().inEventLoop();
            final ChannelConfig config = config();
            if (shouldBreakReadReady(config)) {
                clearReadFilter0();
                return;
            }
            final ChannelPipeline pipeline = pipeline();
            allocHandle.reset(config);
            allocHandle.attemptedBytesRead(1);

            Throwable exception = null;
            try {
                try {
                    do {
                        int acceptFd = socket.accept(acceptedAddress);
                        if (acceptFd == -1) {
                            // this means everything was handled for now
                            allocHandle.lastBytesRead(-1);
                            break;
                        }
                        allocHandle.lastBytesRead(1);
                        allocHandle.incMessagesRead(1);

                        readPending = false;
                        pipeline.fireChannelRead(newChildChannel(acceptFd, acceptedAddress, 1,
                                                                 acceptedAddress[0]));
                    } while (allocHandle.continueReading());
                } catch (Throwable t) {
                    exception = t;
                }
                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();

                if (exception != null) {
                    pipeline.fireExceptionCaught(exception);
                }
            } finally {
                if (shouldStopReading(config)) {
                    clearReadFilter0();
                }
            }
        }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does readReady() do?
readReady() is a function in the netty codebase, defined in transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/AbstractKQueueServerChannel.java.
Where is readReady() defined?
readReady() is defined in transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/AbstractKQueueServerChannel.java at line 76.

Analyze Your Own Codebase

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

Try Supermodel Free