Skip to content
Snippets Groups Projects
Commit 4724b931 authored by Florian Fittkau's avatar Florian Fittkau
Browse files

dont send out empty traces

parent eba68f4e
No related branches found
No related tags found
No related merge requests found
......@@ -79,6 +79,10 @@ class TraceReconstructionBuffer {
}
public final Trace toTrace(final boolean valid) {
if (events.isEmpty()) {
return null;
}
final Stack<AbstractBeforeEventRecord> stack = new Stack<AbstractBeforeEventRecord>();
for (final AbstractEventRecord event : events) {
if (event instanceof AbstractBeforeEventRecord) {
......
......@@ -44,7 +44,10 @@ public final class TraceReconstructionFilter extends AbstractFilter implements I
traceId2trace.remove(traceId);
traceBuffer.clear();
freeBufferCache.addLast(traceBuffer);
deliver(traceBuffer.toTrace(true));
final Trace trace = traceBuffer.toTrace(true);
if (trace != null) {
deliver(trace);
}
}
} else if (record instanceof Trace) {
final Trace trace = (Trace) record;
......@@ -90,7 +93,10 @@ public final class TraceReconstructionFilter extends AbstractFilter implements I
traceBuffer.updateLastBufferInsert();
if ((timestamp - traceBuffer.getLastBufferInsert()) <= traceTimeout) {
deliver(traceBuffer.toTrace(false));
final Trace trace = traceBuffer.toTrace(false);
if (trace != null) {
deliver(trace);
}
traceIdsToRemove.add(entry.getKey());
traceBuffer.clear();
freeBufferCache.addLast(traceBuffer);
......@@ -105,7 +111,10 @@ public final class TraceReconstructionFilter extends AbstractFilter implements I
private void terminate() {
for (final TraceReconstructionBuffer entry : traceId2trace.values()) {
deliver(entry.toTrace(false));
final Trace trace = entry.toTrace(false);
if (trace != null) {
deliver(trace);
}
}
traceId2trace.clear();
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment