Class Os

core/src/main/java/io/questdb/std/Os.java:44–404

import java.util.concurrent.locks.LockSupport;

public final class Os {
    public static final int ARCH_AARCH64 = 1;
    public static final int ARCH_X86_64 = 2;
    public static final int DARWIN = 1;
    public static final int FREEBSD = 4;
    public static final int LINUX = 2;
    public static final long PARK_NANOS_MAX = 5 * 1_000_000_000L;
    public static final int WINDOWS = 3;
    public static final int _32Bit = -2;
    public static final int arch;
    public static final String archName;
    public static final String name;
    public static final int type;

    private Os() {
    }

    public static native long compareAndSwap(long mem, long oldValue, long newValue);

    public static native long currentTimeMicros();

    public static native long currentTimeNanos();

    public static native int errno();

    public static long forkExec(CharSequence args) {
        ObjList<Path> paths = Chars.splitLpsz(args);
        int n = paths.size();
        try {
            long argv = Unsafe.malloc((n + 1) * 8L, MemoryTag.NATIVE_DEFAULT);
            try {
                long p = argv;
                for (int i = 0; i < n; i++) {
                    Unsafe.putLong(p, paths.getQuick(i).ptr());
                    p += 8;
                }
                Unsafe.putLong(p, 0);
                return forkExec(argv);
            } finally {
                Unsafe.free(argv, n + 1, MemoryTag.NATIVE_DEFAULT);
            }
        } finally {
            for (int i = 0; i < n; i++) {
                paths.getQuick(i).close();
            }
        }
    }

    public static int forkExecPid(long forkExecT) {
        return Unsafe.getInt(forkExecT + 8);
    }

    public static int forkExecReadFd(long forkExecT) {
        return Unsafe.getInt(forkExecT);
    }

    public static int forkExecWriteFd(long forkExecT) {
        return Unsafe.getInt(forkExecT + 4);