kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix broken cross process (#119)

This commit is contained in:
Brandon Fergerson 2022-03-06 00:20:07 +01:00 committed by GitHub
parent 5014529708
commit f29d1f72f8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apm-sniffer/apm-sdk-plugin/vertx-plugins/vertx-core-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/vertx4/SWVertxTracer.java
View File

@ -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();