Class SockIO

cdb2jdbc/src/main/java/com/bloomberg/comdb2/jdbc/SockIO.java:22–195

import java.util.logging.Logger;

public class SockIO implements IO {
    private static Logger logger = Logger.getLogger(SockIO.class.getName());

    protected Socket sock;
    protected BufferedOutputStream out;
    protected BufferedInputStream in;

    protected String host;
    protected int port;
    protected int tcpbufsz;
    protected String pmuxrtedb = null;
    protected int soTimeout;
    protected int connectTimeout;

    protected boolean opened = false;

    @Override
    public void close() throws IOException {
        if (in != null) {
            in.close();
            in = null;
        }
        if (out != null) {
            out.close();
            out = null;
        }
        if (sock != null) {
            sock.close();
            sock = null;
        }
        opened = false;
    }

    public SockIO(String host, int port, int tcpbufsz, String pmuxrtedb, int soTimeout, int connectTimeout) {
        this.host = host;
        this.port = port;
        this.tcpbufsz = tcpbufsz;
        this.pmuxrtedb = pmuxrtedb;
        this.soTimeout = soTimeout;
        this.connectTimeout = connectTimeout;
    }

    public SockIO(String host, int port) {
        this(host, port, 0, null, 0, 0);
    }

    public SockIO(String host, int port, String pmuxrtedb) {
        this(host, port, 0, pmuxrtedb, 0, 0);
    }

    public SockIO(String host, int port, String pmuxrtedb, int soTimeout, int connectTimeout) {
        this(host, port, 0, pmuxrtedb, soTimeout, connectTimeout);
    }

    public SockIO() {
    }

    public void write(byte[] bytes) throws IOException {