Class PlainSocket

core/src/main/java/io/questdb/network/PlainSocket.java:29–112

import io.questdb.log.Log;

public class PlainSocket implements Socket {
    private final Log log;
    private final NetworkFacade nf;
    private long fd = -1;

    public PlainSocket(NetworkFacade nf, Log log) {
        this.nf = nf;
        this.log = log;
    }

    @Override
    public void close() {
        if (fd != -1) {
            nf.close(fd, log);
            fd = -1;
        }
    }

    @Override
    public long getFd() {
        return fd;
    }

    @Override
    public boolean isClosed() {
        return fd == -1;
    }

    @Override
    public boolean isMorePlaintextBuffered() {
        return false;
    }

    @Override
    public boolean isTlsSessionStarted() {
        return false;
    }

    @Override
    public void of(long fd) {
        assert this.fd == -1;
        this.fd = fd;
    }

    @Override
    public int recv(long bufferPtr, int bufferLen) {
        return nf.recvRaw(fd, bufferPtr, bufferLen);
    }

    @Override
    public int send(long bufferPtr, int bufferLen) {
        return nf.sendRaw(fd, bufferPtr, bufferLen);
    }

    @Override
    public int shutdown(int how) {
        return nf.shutdown(fd, how);
    }