Remove channel attributes that are request specific

Signed-off-by: Craig Perkins <[email protected]>
cwperks · Oct 4, 2023 · aec3ad3 · aec3ad3
1 parent a83c64f
commit aec3ad3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...s/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpRequestHandler.java b/...s/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpRequestHandler.java
@@ -56,6 +56,8 @@ protected void channelRead0(ChannelHandlerContext ctx, HttpPipelinedRequest http
         final Netty4HttpChannel channel = ctx.channel().attr(Netty4HttpServerTransport.HTTP_CHANNEL_KEY).get();
         final RestResponse earlyResponse = ctx.channel().attr(Netty4HttpServerTransport.EARLY_RESPONSE).get();
         final ThreadContext.StoredContext contextToRestore = ctx.channel().attr(Netty4HttpServerTransport.CONTEXT_TO_RESTORE).get();
+        ctx.channel().attr(Netty4HttpServerTransport.CONTEXT_TO_RESTORE).set(null);
+        ctx.channel().attr(Netty4HttpServerTransport.EARLY_RESPONSE).set(null);
         final RestHandlerContext requestContext = new RestHandlerContext(earlyResponse, contextToRestore);
         boolean success = false;
         try {