Method flushJobs

core/src/main/java/io/questdb/log/LogFactory.java:319–334

()

    }

    @TestOnly
    public void flushJobs() {
        pauseThread();
        for (int i = 0, n = jobs.size(); i < n; i++) {
            LogWriter job = jobs.get(i);
            if (job != null) {
                try {
                    job.drain(0);
                } catch (Exception th) {
                    // Exception means we cannot log anymore. Perhaps network is down or disk is full.
                    // Switch to the next job.
                }
            }
        }
        startThread();
    }

    @TestOnly
    public ObjHashSet<LogWriter> getJobs() {