MCPcopy
hub / github.com/questdb/questdb / AbstractLogRecord

Class AbstractLogRecord

core/src/main/java/io/questdb/log/AbstractLogRecord.java:49–622  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

47import static io.questdb.ParanoiaState.*;
48
49abstract class AbstractLogRecord implements LogRecord, Log {
50 private static final ThreadLocal<ObjHashSet<Throwable>> tlSet = ThreadLocal.withInitial(ObjHashSet::new);
51 protected final RingQueue<LogRecordUtf8Sink> advisoryRing;
52 protected final Sequence advisorySeq;
53 protected final RingQueue<LogRecordUtf8Sink> criticalRing;
54 protected final Sequence criticalSeq;
55 protected final RingQueue<LogRecordUtf8Sink> debugRing;
56 protected final Sequence debugSeq;
57 protected final RingQueue<LogRecordUtf8Sink> errorRing;
58 protected final Sequence errorSeq;
59 protected final RingQueue<LogRecordUtf8Sink> infoRing;
60 protected final Sequence infoSeq;
61 protected final ThreadLocal<CursorHolder> tl = ThreadLocal.withInitial(CursorHolder::new);
62 private final Clock clock;
63 private final CharSequence name;
64
65 AbstractLogRecord(
66 Clock clock,
67 CharSequence name,
68 RingQueue<LogRecordUtf8Sink> debugRing,
69 Sequence debugSeq,
70 RingQueue<LogRecordUtf8Sink> infoRing,
71 Sequence infoSeq,
72 RingQueue<LogRecordUtf8Sink> errorRing,
73 Sequence errorSeq,
74 RingQueue<LogRecordUtf8Sink> criticalRing,
75 Sequence criticalSeq,
76 RingQueue<LogRecordUtf8Sink> advisoryRing,
77 Sequence advisorySeq
78 ) {
79 this.name = name;
80 this.clock = clock;
81 this.debugRing = debugRing;
82 this.debugSeq = debugSeq;
83 this.infoRing = infoRing;
84 this.infoSeq = infoSeq;
85 this.errorRing = errorRing;
86 this.errorSeq = errorSeq;
87 this.criticalRing = criticalRing;
88 this.criticalSeq = criticalSeq;
89 this.advisoryRing = advisoryRing;
90 this.advisorySeq = advisorySeq;
91 }
92
93 @Override
94 public LogRecord $(int x) {
95 sink().put(x);
96 return this;
97 }
98
99 @Override
100 public LogRecord $(double x) {
101 sink().put(x);
102 return this;
103 }
104
105 @Override
106 public LogRecord $(@Nullable Utf8Sequence sequence) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…