Update the pointer of Continuation's headerBuffer after copying the payload.

CoolTomatos · CoolTomatos · commit cf825f16a889 · 2024-11-26T16:30:35.000+01:00
diff --git a/httpcore5-h2/src/main/java/org/apache/hc/core5/http2/impl/nio/AbstractH2StreamMultiplexer.java b/httpcore5-h2/src/main/java/org/apache/hc/core5/http2/impl/nio/AbstractH2StreamMultiplexer.java
@@ -1342,8 +1342,11 @@ void copyPayload(final ByteBuffer payload) {
             if (payload == null) {
                 return;
             }
-            headerBuffer.ensureCapacity(payload.remaining());
-            payload.get(headerBuffer.array(), headerBuffer.length(), payload.remaining());
+            int originalLength = headerBuffer.length();
+            int toCopy = payload.remaining();
+            headerBuffer.ensureCapacity(toCopy);
+            payload.get(headerBuffer.array(), originalLength, toCopy);
+            headerBuffer.setLength(originalLength + toCopy);
         }
 
         ByteBuffer getContent() {

Original file line number	Diff line number	Diff line change
`@@ -1342,8 +1342,11 @@ void copyPayload(final ByteBuffer payload) {`
`1342`	`1342`	`if (payload == null) {`
`1343`	`1343`	`return;`
`1344`	`1344`	`}`
`1345`		`- headerBuffer.ensureCapacity(payload.remaining());`
`1346`		`- payload.get(headerBuffer.array(), headerBuffer.length(), payload.remaining());`
	`1345`	`+ int originalLength = headerBuffer.length();`
	`1346`	`+ int toCopy = payload.remaining();`
	`1347`	`+ headerBuffer.ensureCapacity(toCopy);`
	`1348`	`+ payload.get(headerBuffer.array(), originalLength, toCopy);`
	`1349`	`+ headerBuffer.setLength(originalLength + toCopy);`
`1347`	`1350`	`}`
`1348`	`1351`
`1349`	`1352`	`ByteBuffer getContent() {`