Skip to content

Commit b1f6bd2

Browse files
remove debuglogs
Signed-off-by: Aparajita Pandey <aparajita31pandey@gmail.com>
1 parent 13a82b7 commit b1f6bd2

File tree

2 files changed

+0
-5
lines changed

2 files changed

+0
-5
lines changed

modules/transport-grpc/src/main/java/org/opensearch/transport/grpc/GrpcPlugin.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,6 @@ public Collection<Object> createComponents(
342342
List<OrderedGrpcInterceptor> orderedList = new ArrayList<>();
343343

344344
// Then add plugin-provided interceptors
345-
// Similar to how ActionPlugin.getRestHandlerWrapper receives ThreadContext
346345
if (!interceptorProviders.isEmpty()) {
347346
for (GrpcInterceptorProvider provider : interceptorProviders) {
348347
orderedList.addAll(provider.getOrderedGrpcInterceptors(threadPool.getThreadContext()));

modules/transport-grpc/src/main/java/org/opensearch/transport/grpc/interceptor/GrpcInterceptorChain.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,8 +85,6 @@ public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
8585
Metadata headers,
8686
ServerCallHandler<ReqT, RespT> next
8787
) {
88-
logger.debug("GrpcInterceptorChain.interceptCall() executing on thread: {}", Thread.currentThread().getName());
89-
9088
ServerCallHandler<ReqT, RespT> currentHandler = next;
9189

9290
for (int i = interceptors.size() - 1; i >= 0; i--) {
@@ -124,12 +122,10 @@ public ServerCall.Listener<ReqT> startCall(ServerCall<ReqT, RespT> call, Metadat
124122
// This follows the same pattern as ContextPreservingActionListener.
125123
// Interceptors may have added transients/headers that need to propagate across thread switches.
126124
final Supplier<ThreadContext.StoredContext> contextSupplier = threadContext.newRestorableContext(false);
127-
logger.debug("Captured ThreadContext after interceptors on thread: {}", Thread.currentThread().getName());
128125

129126
// Wrap the listener to restore ThreadContext in all callbacks
130127
return new ForwardingServerCallListener.SimpleForwardingServerCallListener<>(delegate) {
131128
private void runWithThreadContext(Runnable r) {
132-
logger.debug("Restoring ThreadContext on thread: {}", Thread.currentThread().getName());
133129
try (ThreadContext.StoredContext ignored = contextSupplier.get()) {
134130
r.run();
135131
}

0 commit comments

Comments
 (0)