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

readComplete0() — netty Function Reference

Architecture documentation for the readComplete0() function in IoUringDomainSocketChannel.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Dependency Diagram

graph TD
  e219aa9f_5053_2a4e_ea19_ccd705287183["readComplete0()"]
  dc99258d_71a6_9064_ca08_361c0964e22e["IoUringDomainSocketUnsafe"]
  e219aa9f_5053_2a4e_ea19_ccd705287183 -->|defined in| dc99258d_71a6_9064_ca08_361c0964e22e
  style e219aa9f_5053_2a4e_ea19_ccd705287183 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringDomainSocketChannel.java lines 195–219

        @Override
        protected void readComplete0(byte op, int res, int flags, short data, int outstanding) {
            if (op == Native.IORING_OP_RECVMSG) {
                readId = 0;
                if (res == Native.ERRNO_ECANCELED_NEGATIVE) {
                    return;
                }
                final IoUringRecvByteAllocatorHandle allocHandle = recvBufAllocHandle();
                final ChannelPipeline pipeline = pipeline();
                try {
                    int nativeCallResult = res >= 0 ? res : Errors.ioResult("io_uring recvmsg", res);
                    int nativeFd = readMsgHdrMemory.getScmRightsFd();
                    allocHandle.lastBytesRead(nativeFd);
                    allocHandle.incMessagesRead(1);
                    pipeline.fireChannelRead(new FileDescriptor(nativeFd));
                } catch (Throwable throwable) {
                    handleReadException(pipeline, null, throwable, false, allocHandle);
                } finally {
                    allocHandle.readComplete();
                    pipeline.fireChannelReadComplete();
                }
                return;
            }
            super.readComplete0(op, res, flags, data, outstanding);
        }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does readComplete0() do?
readComplete0() is a function in the netty codebase, defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringDomainSocketChannel.java.
Where is readComplete0() defined?
readComplete0() is defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringDomainSocketChannel.java at line 195.

Analyze Your Own Codebase

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

Try Supermodel Free