From 75e83e1b946e95546ce80c169b9c8527e35fca2b Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 12 Aug 2026 04:44:31 +0000 Subject: [PATCH 1/2] Initial plan From 8a128fcedfddd77f3b15bd759a6d5a64c109544f Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 12 Aug 2026 04:52:29 +0000 Subject: [PATCH 2/2] Use concurrent queue for NettyClient response parts Co-authored-by: beijxu <2525594+beijxu@users.noreply.github.com> --- .../src/main/java/com/github/ambry/rest/NettyClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ambry-test-utils/src/main/java/com/github/ambry/rest/NettyClient.java b/ambry-test-utils/src/main/java/com/github/ambry/rest/NettyClient.java index 13ba5b2c70..0a2a578ef9 100644 --- a/ambry-test-utils/src/main/java/com/github/ambry/rest/NettyClient.java +++ b/ambry-test-utils/src/main/java/com/github/ambry/rest/NettyClient.java @@ -40,8 +40,8 @@ import io.netty.util.ReferenceCountUtil; import io.netty.util.concurrent.GenericFutureListener; import java.io.Closeable; -import java.util.LinkedList; import java.util.Queue; +import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; @@ -57,7 +57,7 @@ public class NettyClient implements Closeable { private final EventLoopGroup group = new NioEventLoopGroup(); private final Bootstrap b = new Bootstrap(); - private final Queue responseParts = new LinkedList(); + private final Queue responseParts = new ConcurrentLinkedQueue(); private final AtomicBoolean callbackInvoked = new AtomicBoolean(false); private final RequestSender requestSender = new RequestSender(); private final WriteResultListener writeResultListener = new WriteResultListener();