BytesReadTracker in = new BytesReadTracker(new DataInputStream(cis));
<BUG>SSTableWriter writer = null;
try</BUG>
{
<BUG>writer = createWriter(cfs, totalSize, repairedAt, format);
for (Pair<Long, Long> section : sections)</BUG>
{
assert cis.getTotalCompressedBytesRead() <= totalSize;
<BUG>int sectionLength = (int) (section.right - section.left);

cis.position(section.left);</BUG>
in.reset(0);

BytesReadTracker in = new BytesReadTracker(new DataInputStream(cis));
SSTableWriter writer = null;
DecoratedKey key = null;
try
{
writer = createWriter(cfs, totalSize, repairedAt, format);
int sectionIdx = 0;
for (Pair<Long, Long> section : sections)
{
assert cis.getTotalCompressedBytesRead() <= totalSize;
long sectionLength = section.right - section.left;
logger.trace("[Stream #{}] Reading section {} with length {} from stream.", session.planId(), sectionIdx++, sectionLength);
cis.position(section.left);
in.reset(0);
