Class LogConsoleWriter

core/src/main/java/io/questdb/log/LogConsoleWriter.java:41–157

import static io.questdb.ParanoiaState.*;

public class LogConsoleWriter extends SynchronizedJob implements Closeable, LogWriter {
    private static final int DEBUG_LOG_HISTORY_LENGTH = 25;
    private final long fd = Files.getStdOutFdInternal();
    private final int level;
    private final LogHistory logHistory;
    private final RingQueue<LogRecordUtf8Sink> ring;
    private final SCSequence subSeq;
    private LogInterceptor interceptor;
    private final QueueConsumer<LogRecordUtf8Sink> myConsumer = this::toStdOut;

    public LogConsoleWriter(RingQueue<LogRecordUtf8Sink> ring, SCSequence subSeq, int level) {
        this.ring = ring;
        this.subSeq = subSeq;
        this.level = level;
        if (LOG_PARANOIA_MODE == LOG_PARANOIA_MODE_BASIC) {
            System.out.println("BASIC LOG PARANOIA MODE ACTIVE");
            logHistory = null;
        } else if (LOG_PARANOIA_MODE == LOG_PARANOIA_MODE_AGGRESSIVE) {
            System.out.println("AGGRESSIVE LOG PARANOIA MODE ACTIVE");
            logHistory = new LogHistory();
        } else {
            logHistory = null;
        }
    }

    @Override
    public void bindProperties(LogFactory factory) {
    }

    @Override
    public void close() {
    }

    @Override
    public boolean runSerially() {
        return subSeq.consumeAll(ring, myConsumer);
    }

    public void setInterceptor(LogInterceptor interceptor) {
        this.interceptor = interceptor;
    }

    private void toStdOut(LogRecordUtf8Sink sink) {
        try {
            if ((sink.getLevel() & this.level) != 0) {
                if (interceptor != null) {
                    interceptor.onLog(sink);
                }
                if (LOG_PARANOIA_MODE != LOG_PARANOIA_MODE_NONE) {
                    toStdOutWithErrorDetection(sink);
                } else {
                    Files.append(fd, sink.ptr(), sink.size());
                }
            }
        } catch (Throwable th) {
            System.out.println("Exception while writing a log line");
            th.printStackTrace(System.out);
        }