Method ReadRangeDataRecord

lib/mdflib/mdflib/src/cg3block.cpp:267–309

}

uint64_t Cg3Block::ReadRangeDataRecord(std::streambuf& buffer,
                                const IDataGroup &notifier,
                                     DgRange& range) const {
  uint64_t count;
  const uint64_t sample = Sample();
  const uint64_t next_sample = sample + 1;
  const size_t record_size = size_of_data_record_;
  CgRange* cg_range = range.GetCgRange(RecordId());
  if (cg_range == nullptr) {
    return 0;
  }

  if (!cg_range->IsUsed() ||
      next_sample < range.MinSample() ||
      next_sample > range.MaxSample()) {
    count = StepFilePosition(buffer, record_size);

    if (sample < NofSamples()) {
      IncrementSample();
    }
    if (next_sample > range.MaxSample()) {
      cg_range->IsUsed(false);
    }
  } else {
    // Normal fixed length records

    std::vector<uint8_t> record(record_size, 0);

    count = buffer.sgetn(
        reinterpret_cast<char*>(record.data()), record.size());

    if (sample < NofSamples()) {
      const bool continue_reading =
          notifier.NotifySampleObservers(sample, RecordId(), record);
      IncrementSample();
      if (!continue_reading) {
        return 0;  // Indicating no more reading
      }
    }
  }

  return count;
}
IChannel *Cg3Block::CreateChannel() {
  auto cn3 = std::make_unique<detail::Cn3Block>();
  cn3->Init(*this);