UnixChannelUtil Class — netty Architecture

Source Code

transport-native-unix-common/src/main/java/io/netty/channel/unix/UnixChannelUtil.java lines 26–59

public final class UnixChannelUtil {

    private UnixChannelUtil() {
    }

    /**
     * Checks if the specified buffer has memory address or is composed of n(n <= IOV_MAX) NIO direct buffers.
     * (We check this because otherwise we need to make it a new direct buffer.)
     */
    public static boolean isBufferCopyNeededForWrite(ByteBuf byteBuf) {
        return isBufferCopyNeededForWrite(byteBuf, IOV_MAX);
    }

    static boolean isBufferCopyNeededForWrite(ByteBuf byteBuf, int iovMax) {
        return !byteBuf.hasMemoryAddress() && (!byteBuf.isDirect() || byteBuf.nioBufferCount() > iovMax);
    }

    public static InetSocketAddress computeRemoteAddr(InetSocketAddress remoteAddr, InetSocketAddress osRemoteAddr) {
        if (osRemoteAddr != null) {
            try {
                // Only try to construct a new InetSocketAddress if we using java >= 7 as getHostString() does not
                // exists in earlier releases and so the retrieval of the hostname could block the EventLoop if a
                // reverse lookup would be needed.
                return new InetSocketAddress(InetAddress.getByAddress(remoteAddr.getHostString(),
                        osRemoteAddr.getAddress().getAddress()),
                        osRemoteAddr.getPort());
            } catch (UnknownHostException ignore) {
                // Should never happen but fallback to osRemoteAddr anyway.
            }
            return osRemoteAddr;
        }
        return remoteAddr;
    }
}