Skip to content

Commit

Permalink
update dtests
Browse files Browse the repository at this point in the history
  • Loading branch information
tpetracca committed Dec 12, 2024
1 parent 29505d4 commit a690e73
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ public Future<SimpleQueryResult> asyncExecuteWithTracingWithResult(UUID sessionI
return instance.async(() -> {
try
{
Tracing.instance.newSession(sessionId);
Tracing.instance.newSession(sessionId, Collections.EMPTY_MAP);
return executeInternal(query, consistencyLevelOrigin, boundValues);
}
finally
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -369,7 +369,7 @@ public boolean allowOutgoingMessage(MessageOut messageOut, int id, InetAddress t
{
byte[] traceTypeBytes = (byte[]) messageOut.parameters.get(Tracing.TRACE_TYPE);
Tracing.TraceType traceType = traceTypeBytes == null ? Tracing.TraceType.QUERY : Tracing.TraceType.deserialize(traceTypeBytes[0]);
TraceState.mutateWithTracing(ByteBuffer.wrap(sessionBytes), traceMessage, -1, traceType.getTTL());
Tracing.instance.trace(ByteBuffer.wrap(sessionBytes), traceMessage, -1, traceType.getTTL());
}
else
{
Expand Down

0 comments on commit a690e73

Please sign in to comment.