| 47 | import static io.questdb.ParanoiaState.*; |
| 48 | |
| 49 | abstract 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) { |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…