You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2022/03/05 23:20:15 UTC
[skywalking-java] branch main updated: fix broken cross process (#119)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-java.git
The following commit(s) were added to refs/heads/main by this push:
new f29d1f7 fix broken cross process (#119)
f29d1f7 is described below
commit f29d1f72f89560362b5ac70a2b5203c90d08357a
Author: Brandon Fergerson <bf...@apache.org>
AuthorDate: Sun Mar 6 00:20:07 2022 +0100
fix broken cross process (#119)
---
.../java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java b/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java
index aeb782a..b05c3ea 100644
--- a/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java
+++ b/apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java
@@ -127,12 +127,14 @@ public class SWVertxTracer implements VertxTracer<AbstractSpan, AbstractSpan> {
remotePeer = (String) enhancedInstance.getSkyWalkingDynamicField();
}
}
+
ContextCarrier contextCarrier = new ContextCarrier();
AbstractSpan span = toExitSpan(clientRequest.address(), remotePeer, contextCarrier, context);
SpanLayer.asRPCFramework(span);
return toExitAsyncSpan(context, headers, contextCarrier, span);
}
+
return null;
}
@@ -178,6 +180,7 @@ public class SWVertxTracer implements VertxTracer<AbstractSpan, AbstractSpan> {
private AbstractSpan toExitAsyncSpan(Context context, BiConsumer<String, String> headers,
ContextCarrier contextCarrier, AbstractSpan span) {
+ ContextManager.inject(contextCarrier);
CarrierItem next = contextCarrier.items();
while (next.hasNext()) {
next = next.next();