EpollQuicUtils Class — netty Architecture

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/EpollQuicUtils.java lines 28–65

public final class EpollQuicUtils {

    private EpollQuicUtils() { }

    /**
     * Return a new {@link SegmentedDatagramPacketAllocator} that can be used while using
     * {@link io.netty.channel.epoll.EpollDatagramChannel}.
     *
     * @param maxNumSegments the maximum number of segments that we try to send in one packet.
     * @return a allocator.
     */
    public static SegmentedDatagramPacketAllocator newSegmentedAllocator(int maxNumSegments) {
        ObjectUtil.checkInRange(maxNumSegments, 1, 64, "maxNumSegments");
        if (SegmentedDatagramPacket.isSupported()) {
            return new EpollSegmentedDatagramPacketAllocator(maxNumSegments);
        }
        return SegmentedDatagramPacketAllocator.NONE;
    }

    private static final class EpollSegmentedDatagramPacketAllocator implements SegmentedDatagramPacketAllocator {

        private final int maxNumSegments;

        EpollSegmentedDatagramPacketAllocator(int maxNumSegments) {
            this.maxNumSegments = maxNumSegments;
        }

        @Override
        public int maxNumSegments() {
            return maxNumSegments;
        }

        @Override
        public DatagramPacket newPacket(ByteBuf buffer, int segmentSize, InetSocketAddress remoteAddress) {
            return new io.netty.channel.unix.SegmentedDatagramPacket(buffer, segmentSize, remoteAddress);
        }
    }
}