Merge branch '6.0.x'
This commit is contained in:
@@ -313,7 +313,7 @@ public class NettyDataBuffer implements PooledDataBuffer {
|
|||||||
Assert.notNull(dest, "Dest must not be null");
|
Assert.notNull(dest, "Dest must not be null");
|
||||||
|
|
||||||
dest = dest.duplicate().clear();
|
dest = dest.duplicate().clear();
|
||||||
dest.put(destPos, this.byteBuf.nioBuffer(), srcPos, length);
|
dest.put(destPos, this.byteBuf.nioBuffer(srcPos, length), 0, length);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -796,10 +796,6 @@ class DataBufferTests extends AbstractDataBufferAllocatingTests {
|
|||||||
if (!(bufferFactory instanceof Netty5DataBufferFactory)) {
|
if (!(bufferFactory instanceof Netty5DataBufferFactory)) {
|
||||||
assertThat(result).isEqualTo(new byte[]{'b', 'c'});
|
assertThat(result).isEqualTo(new byte[]{'b', 'c'});
|
||||||
}
|
}
|
||||||
else {
|
|
||||||
assertThat(result).isEqualTo(new byte[]{'b', 0});
|
|
||||||
release(slice);
|
|
||||||
}
|
|
||||||
release(buffer);
|
release(buffer);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -938,4 +934,15 @@ class DataBufferTests extends AbstractDataBufferAllocatingTests {
|
|||||||
release(buffer);
|
release(buffer);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ParameterizedDataBufferAllocatingTest // gh-31605
|
||||||
|
void shouldHonorSourceBuffersReadPosition(DataBufferFactory bufferFactory) {
|
||||||
|
DataBuffer dataBuffer = bufferFactory.wrap("ab".getBytes(StandardCharsets.UTF_8));
|
||||||
|
dataBuffer.readPosition(1);
|
||||||
|
|
||||||
|
ByteBuffer byteBuffer = ByteBuffer.allocate(dataBuffer.readableByteCount());
|
||||||
|
dataBuffer.toByteBuffer(byteBuffer);
|
||||||
|
|
||||||
|
assertThat(StandardCharsets.UTF_8.decode(byteBuffer).toString()).isEqualTo("b");
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user