public void open()

in gflog-core/src/main/java/com/epam/deltix/gflog/core/appender/TcpAppender.java [65:89]

• 20 lines of code
• 7 McCabe index (conditional complexity)

    public void open() {
        if (connectTimeout > 0) {
            final long deadline = System.currentTimeMillis() + connectTimeout;

            do {
                if (state == STATE_DISCONNECTED) {
                    initiateConnect();
                }

                if (state == STATE_CONNECTING) {
                    finishConnect();
                }

                if (state == STATE_CONNECTED) {
                    break;
                }

                LockSupport.parkNanos(16_000_000);
            } while (System.currentTimeMillis() < deadline);

            if (state != STATE_CONNECTED) {
                LogDebug.warn("can't connect to: " + host + ":" + port + " in specified connect timeout: " + connectTimeout);
            }
        }
    }