Class Net

core/src/main/java/io/questdb/network/Net.java:44–465

import static io.questdb.std.Files.toOsFd;

public final class Net {

    @SuppressWarnings("unused")
    public static final int EOTHERDISCONNECT = -2;
    @SuppressWarnings("unused")
    public static final int EPEERDISCONNECT = -1;
    @SuppressWarnings("unused")
    public static final int ERETRY = 0;
    public static final int EWOULDBLOCK;
    public static final long MMSGHDR_BUFFER_ADDRESS_OFFSET;
    public static final long MMSGHDR_BUFFER_LENGTH_OFFSET;
    public static final long MMSGHDR_SIZE;
    public static final int SHUT_WR = 1;
    private static final AtomicInteger ADDR_INFO_COUNTER = new AtomicInteger();
    private static final Log LOG = LogFactory.getLog(Net.class);
    private static final AtomicInteger SOCK_ADDR_COUNTER = new AtomicInteger();
    // TCP KeepAlive not meant to be configurable. It's a last resort measure to disable/change keepalive if the default
    // value causes problems in some environments. If it does not cause problems then this option should be removed after a few releases.
    // It's not exposed as PropertyKey, because it would become a supported and hard to remove API.
    private static final int TCP_KEEPALIVE_SECONDS = Integer.getInteger("questdb.unsupported.tcp.keepalive.seconds", 30);

    private Net() {
    }

    /**
     * Aborts blocking accept() call. On Darwin and Windows
     * this method simply closes the underlying file descriptor.
     * On Linux this method calls shutdown().
     * <p>
     * Once accept() exists it is by convention liable for
     * closing its own file descriptor.
     *
     * @param fd file descriptor
     * @return 0 when call was successful and -1 otherwise. In case of
     * error errno() would return error code.
     */
    public static int abortAccept(long fd) {
        return abortAccept(toOsFd(fd));
    }

    public static long accept(long serverFd) {
        return Files.createUniqueFd(accept0(toOsFd(serverFd)));
    }

    public static void appendIP4(CharSink<?> sink, long ip) {
        sink.put((ip >> 24) & 0xff).putAscii('.')
                .put((ip >> 16) & 0xff).putAscii('.')
                .put((ip >> 8) & 0xff).putAscii('.')
                .put(ip & 0xff);
    }

    public static boolean bindTcp(long fd, int ipv4address, int port) {
        return bindTcp(toOsFd(fd), ipv4address, port);
    }

    public static boolean bindTcp(long fd, CharSequence ipv4address, int port) {
        return bindTcp(fd, parseIPv4(ipv4address), port);
    }