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

processMessage() — netty Function Reference

Architecture documentation for the processMessage() function in NativeDatagramPacketArray.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Dependency Diagram

graph TD
  9eecdd2f_216f_e7dc_b481_6ba488dff4af["processMessage()"]
  29eec517_22bd_4136_2a86_329d0d4bea68["MyMessageProcessor"]
  9eecdd2f_216f_e7dc_b481_6ba488dff4af -->|defined in| 29eec517_22bd_4136_2a86_329d0d4bea68
  3f127df8_c158_c9df_275e_c99e90486d95["add0()"]
  9eecdd2f_216f_e7dc_b481_6ba488dff4af -->|calls| 3f127df8_c158_c9df_275e_c99e90486d95
  style 9eecdd2f_216f_e7dc_b481_6ba488dff4af fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/NativeDatagramPacketArray.java lines 117–144

        @Override
        public boolean processMessage(Object msg) {
            final boolean added;
            if (msg instanceof DatagramPacket) {
                DatagramPacket packet = (DatagramPacket) msg;
                ByteBuf buf = packet.content();
                int segmentSize = 0;
                if (packet instanceof io.netty.channel.unix.SegmentedDatagramPacket) {
                    int seg = ((io.netty.channel.unix.SegmentedDatagramPacket) packet).segmentSize();
                    // We only need to tell the kernel that we want to use UDP_SEGMENT if there are multiple
                    // segments in the packet.
                    if (buf.readableBytes() > seg) {
                        segmentSize = seg;
                    }
                }
                added = add0(buf, buf.readerIndex(), buf.readableBytes(), segmentSize, packet.recipient());
            } else if (msg instanceof ByteBuf && connected) {
                ByteBuf buf = (ByteBuf) msg;
                added = add0(buf, buf.readerIndex(), buf.readableBytes(), 0, null);
            } else {
                added = false;
            }
            if (added) {
                maxMessagesPerWrite--;
                return maxMessagesPerWrite > 0;
            }
            return false;
        }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does processMessage() do?
processMessage() is a function in the netty codebase, defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/NativeDatagramPacketArray.java.
Where is processMessage() defined?
processMessage() is defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/NativeDatagramPacketArray.java at line 117.
What does processMessage() call?
processMessage() calls 1 function(s): add0.

Analyze Your Own Codebase

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

Try Supermodel Free