|
9 | 9 | import com.datadog.debugger.instrumentation.InstrumentationResult;
|
10 | 10 | import com.datadog.debugger.probe.ProbeDefinition;
|
11 | 11 | import java.util.ArrayList;
|
| 12 | +import java.util.Arrays; |
12 | 13 | import java.util.List;
|
13 | 14 | import java.util.concurrent.ConcurrentHashMap;
|
14 | 15 | import java.util.concurrent.ConcurrentMap;
|
| 16 | +import java.util.regex.Pattern; |
15 | 17 | import java.util.stream.Collectors;
|
16 | 18 | import java.util.stream.Stream;
|
17 | 19 | import org.slf4j.Logger;
|
18 | 20 | import org.slf4j.LoggerFactory;
|
19 | 21 |
|
20 | 22 | public class ClassesToRetransformFinder {
|
21 | 23 | private static final Logger LOGGER = LoggerFactory.getLogger(ClassesToRetransformFinder.class);
|
| 24 | + private static final Pattern COMMA_PATTERN = Pattern.compile(","); |
22 | 25 |
|
23 |
| - private final ConcurrentMap<String, List<String>> classNamesBySourceFile = |
24 |
| - new ConcurrentHashMap<>(); |
| 26 | + private final ConcurrentMap<String, String> classNamesBySourceFile = new ConcurrentHashMap<>(); |
25 | 27 |
|
26 | 28 | public void register(String sourceFile, String className) {
|
27 | 29 | // store only the class name that are different from SourceFile name
|
28 | 30 | // (Inner or non-public Top-Level classes)
|
29 | 31 | classNamesBySourceFile.compute(
|
30 | 32 | sourceFile,
|
31 |
| - (key, list) -> { |
32 |
| - if (list == null) { |
33 |
| - list = new ArrayList<>(); |
| 33 | + (key, classNames) -> { |
| 34 | + if (classNames == null) { |
| 35 | + return className; |
34 | 36 | }
|
35 |
| - list.add(className); |
36 |
| - return list; |
| 37 | + return classNames + "," + className; |
37 | 38 | });
|
38 | 39 | }
|
39 | 40 |
|
@@ -89,13 +90,11 @@ Trie getAllChangedClasses(ConfigurationComparer comparer) {
|
89 | 90 |
|
90 | 91 | private void processAdditionalClasses(String sourceFile, Trie changedClasses) {
|
91 | 92 | sourceFile = stripPackagePath(sourceFile);
|
92 |
| - // need to clone the list to avoid concurrent modification during iteration |
93 |
| - List<String> additionalClasses = |
94 |
| - classNamesBySourceFile.computeIfPresent( |
95 |
| - sourceFile, (k, classNames) -> new ArrayList<>(classNames)); |
96 |
| - if (additionalClasses == null) { |
| 93 | + String classNames = classNamesBySourceFile.get(sourceFile); |
| 94 | + if (classNames == null) { |
97 | 95 | return;
|
98 | 96 | }
|
| 97 | + List<String> additionalClasses = Arrays.asList(COMMA_PATTERN.split(classNames)); |
99 | 98 | for (String additionalClass : additionalClasses) {
|
100 | 99 | additionalClass = normalizeFilePath(additionalClass);
|
101 | 100 | changedClasses.insert(reverseStr(additionalClass));
|
|
0 commit comments