|
6 | 6 | import com.datadog.debugger.util.ClassFileHelper;
|
7 | 7 | import com.datadog.debugger.util.ClassNameFiltering;
|
8 | 8 | import datadog.trace.api.Config;
|
9 |
| -import datadog.trace.relocate.api.RatelimitedLogger; |
10 | 9 | import datadog.trace.util.AgentTaskScheduler;
|
11 | 10 | import datadog.trace.util.Strings;
|
12 | 11 | import java.lang.instrument.ClassFileTransformer;
|
|
26 | 25 | */
|
27 | 26 | public class SourceFileTrackingTransformer implements ClassFileTransformer {
|
28 | 27 | private static final Logger LOGGER = LoggerFactory.getLogger(SourceFileTrackingTransformer.class);
|
29 |
| - private static final int MINUTES_BETWEEN_ERROR_LOG = 5; |
30 |
| - static final int MAX_QUEUE_SIZE = 4096; |
| 28 | + static final int MAX_QUEUE_SIZE = 16 * 1024; |
31 | 29 |
|
32 |
| - private final RatelimitedLogger ratelimitedLogger = |
33 |
| - new RatelimitedLogger(LOGGER, MINUTES_BETWEEN_ERROR_LOG, TimeUnit.MINUTES); |
34 | 30 | private final ClassesToRetransformFinder finder;
|
35 | 31 | private final Queue<SourceFileItem> queue = new ConcurrentLinkedQueue<>();
|
36 | 32 | private final AgentTaskScheduler scheduler = AgentTaskScheduler.INSTANCE;
|
@@ -93,7 +89,7 @@ public byte[] transform(
|
93 | 89 | return null;
|
94 | 90 | }
|
95 | 91 | if (queueSize.get() >= MAX_QUEUE_SIZE) {
|
96 |
| - ratelimitedLogger.warn("SourceFile Tracking queue full, dropping class: {}", className); |
| 92 | + LOGGER.debug("SourceFile Tracking queue full, dropping class: {}", className); |
97 | 93 | return null;
|
98 | 94 | }
|
99 | 95 | queue.add(new SourceFileItem(className, classfileBuffer));
|
|
0 commit comments