The fix

grpc · Jul 14, 2022 · 7b40bb0 · 7b40bb0
1 parent b82a888
commit 7b40bb0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/netty/src/main/java/io/grpc/netty/NettyAdaptiveCumulator.java b/netty/src/main/java/io/grpc/netty/NettyAdaptiveCumulator.java
@@ -143,7 +143,7 @@ static void mergeWithCompositeTail(ByteBufAllocator alloc, CompositeByteBuf comp
       if (tail.refCnt() == 1 && !tail.isReadOnly() && totalBytes <= tail.maxCapacity()) {
         // Ideal case: the tail isn't shared, and can be expanded to the required capacity.
         // Take ownership of the tail.
-        merged = tail.retain();
+        merged = composite.internalComponent(tailIndex).retainedDuplicate();
         /*
          * The tail is a readable non-composite buffer, so writeBytes() handles everything for us.
          *