Skip to content

Commit 4fb3661

Browse files
committed
review
1 parent 0e1d36a commit 4fb3661

File tree

3 files changed

+11
-12
lines changed

3 files changed

+11
-12
lines changed

dd-java-agent/agent-tooling/src/main/java/datadog/trace/agent/tooling/log/UnionMap.java

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,24 +18,23 @@ public final class UnionMap<K, V> extends AbstractMap<K, V> implements Serializa
1818
private Map<K, V> secondaryMap;
1919
private transient Set<Map.Entry<K, V>> entrySet;
2020
private transient volatile boolean deduped;
21-
private static final ThreadLocal<UnionMap<?, ?>> TL = new ThreadLocal<>();
21+
private static final ThreadLocal<UnionMap<?, ?>> TL = ThreadLocal.withInitial(UnionMap::new);
22+
23+
private UnionMap() {
24+
this(null, null);
25+
}
2226

2327
public UnionMap(Map<K, V> primaryMap, Map<K, V> secondaryMap) {
2428
this.primaryMap = primaryMap;
2529
this.secondaryMap = secondaryMap;
2630
}
2731

2832
@SuppressWarnings({"unchecked"})
29-
public static <K, V> UnionMap<K, V> create(Map<K, V> primaryMap, Map<K, V> secondaryMap) {
33+
public static <K, V> UnionMap<K, V> obtain(Map<K, V> primaryMap, Map<K, V> secondaryMap) {
3034
UnionMap ret = TL.get();
31-
if (ret == null) {
32-
ret = new UnionMap(primaryMap, secondaryMap);
33-
TL.set(ret);
34-
} else {
35-
ret.primaryMap = primaryMap;
36-
ret.secondaryMap = secondaryMap;
37-
ret.deduped = false;
38-
}
35+
ret.primaryMap = primaryMap;
36+
ret.secondaryMap = secondaryMap;
37+
ret.deduped = false;
3938
return ret;
4039
}
4140

dd-java-agent/instrumentation/logback-1.0/src/main/java/datadog/trace/instrumentation/logback/LoggingEventInstrumentation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public static void onExit(
110110
correlationValues.put(Tags.DD_VERSION, version);
111111
}
112112

113-
mdc = null != mdc ? UnionMap.create(mdc, correlationValues) : correlationValues;
113+
mdc = null != mdc ? UnionMap.obtain(mdc, correlationValues) : correlationValues;
114114
}
115115
}
116116
}

dd-java-agent/instrumentation/tinylog-2.0/src/main/java/datadog/trace/instrumentation/tinylog2/LogEntryInstrumentation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public static void onExit(
103103
correlationValues.put(Tags.DD_VERSION, version);
104104
}
105105

106-
mdc = null != mdc ? UnionMap.create(mdc, correlationValues) : correlationValues;
106+
mdc = null != mdc ? UnionMap.obtain(mdc, correlationValues) : correlationValues;
107107
}
108108
}
109109
}

0 commit comments

Comments
 (0)