this.sections = sections;
this.limiter = StreamManager.getRateLimiter(session.peer);
}
public void write(DataOutputStreamPlus output) throws IOException
{
<BUG>long totalSize = totalSize();
try(RandomAccessReader file = sstable.openDataReader();</BUG>
ChecksumValidator validator = new File(sstable.descriptor.filenameFor(Component.CRC)).exists()
? DataIntegrityMetadata.checksumValidator(sstable.descriptor)
: null;)

this.sections = sections;
this.limiter = StreamManager.getRateLimiter(session.peer);
}
public void write(DataOutputStreamPlus output) throws IOException
{
long totalSize = totalSize();
logger.debug("[Stream #{}] Start streaming file {} to {}, repairedAt = {}, totalSize = {}", session.planId(),
sstable.getFilename(), session.peer, sstable.getSSTableMetadata().repairedAt, totalSize);
try(RandomAccessReader file = sstable.openDataReader();
ChecksumValidator validator = new File(sstable.descriptor.filenameFor(Component.CRC)).exists()
? DataIntegrityMetadata.checksumValidator(sstable.descriptor)
: null;)
