Skip to content

Commit 957c852

Browse files
committed
Migrate dd-trace-core groovy files to java part 12
we migrate 20 tests: - TraceMapperV04PayloadTest - TraceMapperV05PayloadTest - TraceMapperV1PayloadTest - DDEvpProxyApiTest - DDIntakeApiTest - DDIntakeTraceInterceptorTest - DDIntakeTrackTypeResolverTest - DDAgentApiTest - DDAgentWriterCombinedTest - DDAgentWriterTest - DDIntakeWriterCombinedTest - DDIntakeWriterTest - MultiWriterTest - PayloadDispatcherImplTest - PrioritizationTest - SerializationTest - SpanSamplingWorkerTest - TraceMapperTest - TraceProcessingWorkerTest - WriterFactoryTest # Conflicts: # utils/junit-utils/src/main/java/datadog/trace/junit/utils/tabletest/SamplingMechanismConverter.java
1 parent cc96311 commit 957c852

42 files changed

Lines changed: 8731 additions & 7545 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

dd-trace-core/src/main/java/datadog/trace/common/writer/TraceProcessingWorker.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
import datadog.common.queue.Queues;
1010
import datadog.communication.ddagent.DroppingPolicy;
1111
import datadog.trace.api.Config;
12+
import datadog.trace.api.internal.VisibleForTesting;
1213
import datadog.trace.bootstrap.instrumentation.api.SpanPostProcessor;
1314
import datadog.trace.common.sampling.SingleSpanSampler;
1415
import datadog.trace.common.writer.ddagent.FlushEvent;
@@ -122,6 +123,11 @@ public long getRemainingCapacity() {
122123
return primaryQueue.remainingCapacity();
123124
}
124125

126+
@VisibleForTesting
127+
MessagePassingBlockingQueue<Object> getPrimaryQueue() {
128+
return primaryQueue;
129+
}
130+
125131
private static MessagePassingBlockingQueue<Object> createQueue(int capacity) {
126132
return Queues.mpscBlockingConsumerArrayQueue(capacity);
127133
}

0 commit comments

Comments
 (0)