Lines Matching refs:super_version
878 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in TablesRangeTombstoneSummary() local
879 Version* version = super_version->current; in TablesRangeTombstoneSummary()
884 CleanupSuperVersion(super_version); in TablesRangeTombstoneSummary()
1326 SuperVersion* super_version = cfd->GetSuperVersion()->Ref(); in NewInternalIterator() local
1329 return NewInternalIterator(roptions, cfd, super_version, arena, range_del_agg, in NewInternalIterator()
1398 super_version(_super_version), in IterState()
1403 SuperVersion* super_version; member
1410 if (state->super_version->Unref()) { in CleanupIteratorState()
1416 state->super_version->Cleanup(); in CleanupIteratorState()
1420 state->db->AddSuperVersionsToFreeQueue(state->super_version); in CleanupIteratorState()
1426 delete state->super_version; in CleanupIteratorState()
1450 SuperVersion* super_version, in NewInternalIterator() argument
1461 super_version->mutable_cf_options.prefix_extractor != nullptr); in NewInternalIterator()
1464 super_version->mem->NewIterator(read_options, arena)); in NewInternalIterator()
1469 super_version->mem->NewRangeTombstoneIterator(read_options, sequence)); in NewInternalIterator()
1474 super_version->imm->AddIterators(read_options, &merge_iter_builder); in NewInternalIterator()
1476 s = super_version->imm->AddRangeTombstoneIterators(read_options, arena, in NewInternalIterator()
1484 super_version->current->AddIterators(read_options, file_options_, in NewInternalIterator()
1489 new IterState(this, &mutex_, super_version, in NewInternalIterator()
1496 CleanupSuperVersion(super_version); in NewInternalIterator()
1773 auto super_version = mgd.super_version; in MultiGet() local
1779 if (super_version->mem->Get(lkey, value, timestamp, &s, &merge_context, in MultiGet()
1783 } else if (super_version->imm->Get( in MultiGet()
1793 super_version->current->Get(read_options, lkey, &pinnable_val, timestamp, in MultiGet()
1813 ReturnAndCleanupSuperVersion(mgd.cfd, mgd.super_version); in MultiGet()
1843 node->super_version = GetAndRefSuperVersion(node->cfd); in MultiCFSnapshot()
1887 SuperVersion* super_version = node->super_version; in MultiCFSnapshot() local
1889 if (super_version != nullptr) { in MultiCFSnapshot()
1890 ReturnAndCleanupSuperVersion(cfd, super_version); in MultiCFSnapshot()
1892 node->super_version = nullptr; in MultiCFSnapshot()
1913 node->super_version = GetAndRefSuperVersion(node->cfd); in MultiCFSnapshot()
1915 node->super_version = node->cfd->GetSuperVersion()->Ref(); in MultiCFSnapshot()
1931 node->super_version->mem->GetEarliestSequenceNumber(); in MultiCFSnapshot()
2016 cf_iter->super_version, consistent_seqnum, nullptr, nullptr); in MultiGet()
2018 ReturnAndCleanupSuperVersion(cf_iter->cfd, cf_iter->super_version); in MultiGet()
2162 multiget_cf_data[0].super_version, consistent_seqnum, nullptr, in MultiGetWithCallback()
2165 multiget_cf_data[0].super_version); in MultiGetWithCallback()
2171 SuperVersion* super_version, SequenceNumber snapshot, in MultiGetImpl() argument
2201 super_version->mem->MultiGet(read_options, &range, callback, in MultiGetImpl()
2204 super_version->imm->MultiGet(read_options, &range, callback, in MultiGetImpl()
2215 super_version->current->MultiGet(read_options, &range, callback, in MultiGetImpl()
4047 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in IngestExternalFiles() local
4049 args[i].external_files, start_file_number, super_version); in IngestExternalFiles()
4051 CleanupSuperVersion(super_version); in IngestExternalFiles()
4058 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in IngestExternalFiles() local
4060 args[0].external_files, next_file_number, super_version); in IngestExternalFiles()
4062 CleanupSuperVersion(super_version); in IngestExternalFiles()