Skip to content

Commit 5c27b2d

Browse files
committed
fixed tracing bug.
1 parent 8f39cc4 commit 5c27b2d

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

txlcn-tracing/src/main/java/com/codingapi/txlcn/tracing/TracingContext.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ public static TracingContext tracing() {
5656

5757
private Map<String, String> fields;
5858

59+
private boolean destroy;
60+
5961
public void beginTransactionGroup() {
6062
if (hasGroup()) {
6163
return;
@@ -73,6 +75,7 @@ public static void init(Map<String, String> initFields) {
7375
TracingContext tracingContext = tracing();
7476
if (Objects.isNull(tracingContext.fields)) {
7577
tracingContext.fields = new HashMap<>();
78+
tracingContext.destroy = true;
7679
}
7780
tracingContext.fields.putAll(initFields);
7881
}
@@ -157,7 +160,9 @@ public String appMapString() {
157160
*/
158161
public void destroy() {
159162
if (Objects.nonNull(tracingContextThreadLocal.get())) {
160-
tracingContextThreadLocal.remove();
163+
if (tracingContextThreadLocal.get().destroy) {
164+
tracingContextThreadLocal.remove();
165+
}
161166
}
162167
}
163168

0 commit comments

Comments
 (0)