Class LogFileWriter

core/src/main/java/io/questdb/log/LogFileWriter.java:37–155

import java.io.Closeable;

public class LogFileWriter extends SynchronizedJob implements Closeable, LogWriter {

    private static final int DEFAULT_BUFFER_SIZE = 1024 * 1024;
    private final int level;
    private final RingQueue<LogRecordUtf8Sink> ring;
    private final SCSequence subSeq;
    private long _wptr;
    private long buf;
    private int bufSize;
    private String bufferSize;
    private long fd = -1;
    private long lim;
    private String location;
    private QueueConsumer<LogRecordUtf8Sink> myConsumer = this::copyToBuffer;
    // can be set via reflection
    @SuppressWarnings("unused")
    private String truncate;

    public LogFileWriter(RingQueue<LogRecordUtf8Sink> ring, SCSequence subSeq, int level) {
        this.ring = ring;
        this.subSeq = subSeq;
        this.level = level;
    }

    @Override
    public void bindProperties(LogFactory factory) {
        if (this.bufferSize != null) {
            try {
                bufSize = Numbers.parseIntSize(this.bufferSize);
            } catch (NumericException e) {
                throw new LogError("Invalid value for bufferSize");
            }
        } else {
            bufSize = DEFAULT_BUFFER_SIZE;
        }
        this.buf = _wptr = Unsafe.malloc(bufSize, MemoryTag.NATIVE_LOGGER);
        this.lim = buf + bufSize;
        try (Path path = new Path()) {
            path.of(location);
            if (truncate != null && Chars.equalsLowerCaseAscii(truncate, "true")) {
                this.fd = Files.openRW(path.$());
                Files.truncate(fd, 0);
            } else {
                this.fd = Files.openAppend(path.$());
            }
        }
        if (this.fd == -1) {
            throw new LogError("Cannot open file for append: " + location + " [errno=" + Os.errno() + ']');
        }
    }

    @Override
    public void close() {
        if (buf != 0) {
            if (_wptr > buf) {
                flush();
            }
            Unsafe.free(buf, bufSize, MemoryTag.NATIVE_LOGGER);