Object() — netty Function Reference

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

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ Object() — netty Function Reference

Dependency Diagram

graph TD
  77636a97_89f5_006d_0546_243b77ddef75["Object()"]
  15b83cff_6ad6_b58a_64e5_7942764a0d6c["IoUringDatagramChannel"]
  77636a97_89f5_006d_0546_243b77ddef75 -->|defined in| 15b83cff_6ad6_b58a_64e5_7942764a0d6c
  ee90403c_c72a_8c20_2098_0e7523cfd5b3["checkUnresolved()"]
  77636a97_89f5_006d_0546_243b77ddef75 -->|calls| ee90403c_c72a_8c20_2098_0e7523cfd5b3
  style 77636a97_89f5_006d_0546_243b77ddef75 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringDatagramChannel.java lines 324–355

    @Override
    protected Object filterOutboundMessage(Object msg) {
        if (msg instanceof DatagramPacket) {
            DatagramPacket packet = (DatagramPacket) msg;
            checkUnresolved(packet);
            ByteBuf content = packet.content();
            return !content.hasMemoryAddress() ?
                    packet.replace(newDirectBuffer(packet, content)) : msg;
        }

        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) msg;
            return !buf.hasMemoryAddress()? 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 !content.hasMemoryAddress()?
                        new DefaultAddressedEnvelope<>(
                            newDirectBuffer(e, content), (InetSocketAddress) e.recipient()) : e;
            }
        }

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