Skip to content

Commit dd0feb9

Browse files
tidy & assert writeChunk
1 parent a7105c4 commit dd0feb9

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

src/java/org/apache/cassandra/io/compress/DirectCompressedSequentialWriter.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525

2626
import javax.annotation.Nullable;
2727

28+
import com.google.common.base.Preconditions;
2829
import com.sun.nio.file.ExtendedOpenOption;
2930

3031
import org.agrona.BitUtil;
@@ -149,13 +150,16 @@ protected void seekToChunkStart()
149150
@Override
150151
protected void writeChunk(ByteBuffer toWrite)
151152
{
153+
Preconditions.checkArgument(toWrite.position() == 0,
154+
"writeChunk requires a flipped buffer (position == 0), got position=%s",
155+
toWrite.position());
156+
152157
int chunkLength = toWrite.remaining();
153158

154-
toWrite.mark();
155159
chunkChecksum.reset();
156160
chunkChecksum.update(toWrite);
157161
int crcValue = (int) chunkChecksum.getValue();
158-
toWrite.reset();
162+
toWrite.rewind();
159163

160164
writeToAlignedBuffer(toWrite);
161165
writeCrcToAlignedBuffer(crcValue);

0 commit comments

Comments
 (0)