Class LogFactory

core/src/main/java/io/questdb/log/LogFactory.java:74–1231

import java.util.concurrent.atomic.AtomicBoolean;

public class LogFactory implements Closeable {

    public static final String CONFIG_SYSTEM_PROPERTY = "out";
    public static final String DEBUG_TRIGGER = "ebug";
    public static final String DEBUG_TRIGGER_ENV = "QDB_DEBUG";
    // name of default logging configuration file (in jar and in $root/conf/ dir)
    public static final String DEFAULT_CONFIG_NAME = "log.conf";
    // placeholder that can be used in log.conf to point to $root/log/ dir
    public static final String LOG_DIR_VAR = "${log.dir}";
    private static final String DEFAULT_CONFIG = "/io/questdb/site/conf/" + DEFAULT_CONFIG_NAME;
    private static final int DEFAULT_LOG_LEVEL = LogLevel.INFO | LogLevel.ERROR | LogLevel.CRITICAL | LogLevel.ADVISORY;
    private static final int DEFAULT_MSG_SIZE = 4 * 1024;
    private static final int DEFAULT_QUEUE_DEPTH = 1024;
    private static final String EMPTY_STR = "";
    private static final LengthDescendingComparator LDC = new LengthDescendingComparator();
    private static final CharSequenceHashSet reserved = new CharSequenceHashSet();
    private static LogFactory INSTANCE;
    private static boolean envEnabled = true;
    private static boolean guaranteedLogging = false;
    private static String rootDir;
    private final Clock clock;
    private final AtomicBoolean closed = new AtomicBoolean();
    private final ObjList<DeferredLogger> deferredLoggers = new ObjList<>();
    private final ObjHashSet<LogWriter> jobs = new ObjHashSet<>();
    private final AtomicBoolean running = new AtomicBoolean();
    private final CharSequenceObjHashMap<ScopeConfiguration> scopeConfigMap = new CharSequenceObjHashMap<>();
    private final ObjList<ScopeConfiguration> scopeConfigs = new ObjList<>();
    private final StringSink sink = new StringSink();
    private final WorkerPool loggingWorkerPool;
    private boolean configured = false;
    private int queueDepth = DEFAULT_QUEUE_DEPTH;
    private int recordLength = DEFAULT_MSG_SIZE;

    public LogFactory() {
        this(MicrosecondClockImpl.INSTANCE);
    }

    private LogFactory(Clock clock) {
        this.clock = clock;
        loggingWorkerPool = new WorkerPool(new WorkerPoolConfiguration() {
            @Override
            public Metrics getMetrics() {
                return Metrics.DISABLED;
            }

            @Override
            public String getPoolName() {
                return "logging";
            }

            @Override
            public int getWorkerCount() {
                return 1;
            }

            @Override
            public boolean isDaemonPool() {
                return true;