open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Ensure reactor netty spans are ended in the order they were started (#9203)

This commit is contained in:
Lauri Tulmin 2023-08-16 15:53:10 +03:00 committed by GitHub
parent 31b90b1463
commit 82118868bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
instrumentation/reactor/reactor-netty/reactor-netty-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactornetty/v1_0/InstrumentationContexts.java
View File

@ -52,7 +52,10 @@ final class InstrumentationContexts {
return context; return context;
} }
void endClientSpan(@Nullable HttpClientResponse response, @Nullable Throwable error) { // we are synchronizing here to ensure that spans are ended in the oder they are read from the
// queue
synchronized void endClientSpan(
@Nullable HttpClientResponse response, @Nullable Throwable error) {
RequestAndContext requestAndContext = clientContexts.poll(); RequestAndContext requestAndContext = clientContexts.poll();
if (requestAndContext != null) { if (requestAndContext != null) {
instrumenter().end(requestAndContext.context, requestAndContext.request, response, error); instrumenter().end(requestAndContext.context, requestAndContext.request, response, error);