Fix nonforking fast path in InboundHandler (elastic#100389) (elastic#…

…100398) Fixes an equality check missed in elastic#98854.
davidkyle · Oct 6, 2023 · 83f1c1f · 83f1c1f
1 parent a3d9e72
commit 83f1c1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/elasticsearch/transport/InboundHandler.java b/server/src/main/java/org/elasticsearch/transport/InboundHandler.java
@@ -268,7 +268,7 @@ private <T extends TransportRequest> void handleRequest(TcpChannel channel, Inbo
                 assert requestId > 0;
                 request.setRequestId(requestId);
                 verifyRequestReadFully(stream, requestId, action);
-                if (ThreadPool.Names.SAME.equals(reg.getExecutor())) {
+                if (reg.getExecutor() == EsExecutors.DIRECT_EXECUTOR_SERVICE) {
                     try (var ignored = threadPool.getThreadContext().newTraceContext()) {
                         doHandleRequest(reg, request, transportChannel);
                     }