try

hypertrace · Jan 23, 2024 · b627b67 · b627b67
1 parent d25c176
commit b627b67
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 7 deletions.
diff --git a/...aagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerBlockingRequestHandler.java b/...aagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerBlockingRequestHandler.java
@@ -43,8 +43,10 @@ public class HttpServerBlockingRequestHandler extends ChannelInboundHandlerAdapt
   @Override
   public void channelRead(ChannelHandlerContext ctx, Object msg) {
     Channel channel = ctx.channel();
-    Deque<ServerContext> serverContexts = ctx.channel()
-      .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT).get();
+    Deque<ServerContext> serverContexts =
+        ctx.channel()
+            .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT)
+            .get();
     ServerContext serverContext = serverContexts != null ? serverContexts.peekFirst() : null;
     Context context = serverContext != null ? serverContext.context() : null;
     if (context == null) {

diff --git a/...vaagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerRequestTracingHandler.java b/...vaagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerRequestTracingHandler.java
@@ -50,8 +50,10 @@ public class HttpServerRequestTracingHandler extends ChannelInboundHandlerAdapte
   @Override
   public void channelRead(ChannelHandlerContext ctx, Object msg) {
     Channel channel = ctx.channel();
-    Deque<ServerContext> serverContexts = ctx.channel()
-      .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT).get();
+    Deque<ServerContext> serverContexts =
+        ctx.channel()
+            .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT)
+            .get();
     ServerContext serverContext = serverContexts != null ? serverContexts.peekFirst() : null;
     Context context = serverContext != null ? serverContext.context() : null;
     if (context == null) {

diff --git a/...aagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerResponseTracingHandler.java b/...aagent/instrumentation/hypertrace/netty/v4_1/server/HttpServerResponseTracingHandler.java
@@ -52,11 +52,13 @@ public class HttpServerResponseTracingHandler extends ChannelOutboundHandlerAdap
 
   @Override
   public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise prm) {
-    Deque<ServerContext> serverContexts = ctx.channel()
-      .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT).get();
+    Deque<ServerContext> serverContexts =
+        ctx.channel()
+            .attr(io.opentelemetry.instrumentation.netty.v4_1.internal.AttributeKeys.SERVER_CONTEXT)
+            .get();
     ServerContext serverContext = serverContexts != null ? serverContexts.peekFirst() : null;
     Context context = serverContext != null ? serverContext.context() : null;
-    
+
     if (context == null) {
       ctx.write(msg, prm);
       return;