Object() — netty Function Reference

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

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ Object() — netty Function Reference

Dependency Diagram

graph TD
  63d54e5c_8064_9dcf_9a16_aeff4a5d3f1b["Object()"]
  d655085f_28d0_2ab1_6880_68b2da4e27e4["KQueueDatagramChannel"]
  63d54e5c_8064_9dcf_9a16_aeff4a5d3f1b -->|defined in| d655085f_28d0_2ab1_6880_68b2da4e27e4
  623b3f88_9545_b403_8293_ba68d0f81237["checkUnresolved()"]
  63d54e5c_8064_9dcf_9a16_aeff4a5d3f1b -->|calls| 623b3f88_9545_b403_8293_ba68d0f81237
  style 63d54e5c_8064_9dcf_9a16_aeff4a5d3f1b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/KQueueDatagramChannel.java lines 330–362

    @Override
    protected Object filterOutboundMessage(Object msg) {
        if (msg instanceof DatagramPacket) {
            DatagramPacket packet = (DatagramPacket) msg;
            checkUnresolved(packet);
            ByteBuf content = packet.content();
            return UnixChannelUtil.isBufferCopyNeededForWrite(content) ?
                    new DatagramPacket(newDirectBuffer(packet, content), packet.recipient()) : msg;
        }

        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) msg;
            return UnixChannelUtil.isBufferCopyNeededForWrite(buf) ? newDirectBuffer(buf) : buf;
        }

        if (msg instanceof AddressedEnvelope) {
            @SuppressWarnings("unchecked")
            AddressedEnvelope<Object, SocketAddress> e = (AddressedEnvelope<Object, SocketAddress>) msg;
            checkUnresolved(e);

            if (e.content() instanceof ByteBuf &&
                    (e.recipient() == null || e.recipient() instanceof InetSocketAddress)) {

                ByteBuf content = (ByteBuf) e.content();
                return UnixChannelUtil.isBufferCopyNeededForWrite(content) ?
                        new DefaultAddressedEnvelope<ByteBuf, InetSocketAddress>(
                                newDirectBuffer(e, content), (InetSocketAddress) e.recipient()) : e;
            }
        }

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