Object() — netty Function Reference

Architecture documentation for the Object() function in NioDatagramChannel.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ Object() — netty Function Reference

Dependency Diagram

graph TD
  63e99c73_eb87_b497_9f24_bd1f61ac5647["Object()"]
  62bb7cb5_86a2_a73b_659d_4f8936fbd7b8["NioDatagramChannel"]
  63e99c73_eb87_b497_9f24_bd1f61ac5647 -->|defined in| 62bb7cb5_86a2_a73b_659d_4f8936fbd7b8
  e80f6ba3_2081_0a10_da42_87c8815b92ce["checkUnresolved()"]
  63e99c73_eb87_b497_9f24_bd1f61ac5647 -->|calls| e80f6ba3_2081_0a10_da42_87c8815b92ce
  30b9c5a7_c561_7a13_a2db_83ace5c3539c["isSingleDirectBuffer()"]
  63e99c73_eb87_b497_9f24_bd1f61ac5647 -->|calls| 30b9c5a7_c561_7a13_a2db_83ace5c3539c
  style 63e99c73_eb87_b497_9f24_bd1f61ac5647 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java lines 321–356

    @Override
    protected Object filterOutboundMessage(Object msg) {
        if (msg instanceof DatagramPacket) {
            DatagramPacket p = (DatagramPacket) msg;
            checkUnresolved(p);
            ByteBuf content = p.content();
            if (isSingleDirectBuffer(content)) {
                return p;
            }
            return new DatagramPacket(newDirectBuffer(p, content), p.recipient());
        }

        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) msg;
            if (isSingleDirectBuffer(buf)) {
                return buf;
            }
            return newDirectBuffer(buf);
        }

        if (msg instanceof AddressedEnvelope) {
            @SuppressWarnings("unchecked")
            AddressedEnvelope<Object, SocketAddress> e = (AddressedEnvelope<Object, SocketAddress>) msg;
            checkUnresolved(e);
            if (e.content() instanceof ByteBuf) {
                ByteBuf content = (ByteBuf) e.content();
                if (isSingleDirectBuffer(content)) {
                    return e;
                }
                return new DefaultAddressedEnvelope<ByteBuf, SocketAddress>(newDirectBuffer(e, content), e.recipient());
            }
        }

        throw new UnsupportedOperationException(
                "unsupported message type: " + StringUtil.simpleClassName(msg) + EXPECTED_TYPES);
    }