Home
last modified time | relevance | path

Searched refs:snapshots (Results 1 – 25 of 26) sorted by relevance

12

/rocksdb-6.9/db/
Drange_tombstone_fragmenter.cc24 const std::vector<SequenceNumber>& snapshots) { in FragmentedRangeTombstoneList() argument
48 snapshots); in FragmentedRangeTombstoneList()
66 FragmentTombstones(std::move(iter), icmp, for_compaction, snapshots); in FragmentedRangeTombstoneList()
72 const std::vector<SequenceNumber>& snapshots) { in FragmentTombstones() argument
136 std::lower_bound(snapshots.begin(), snapshots.end(), seq); in FragmentTombstones()
137 if (upper_bound_it == snapshots.begin()) { in FragmentTombstones()
418 const std::vector<SequenceNumber>& snapshots) { in SplitBySnapshot() argument
423 for (size_t i = 0; i <= snapshots.size(); i++) { in SplitBySnapshot()
424 if (i >= snapshots.size()) { in SplitBySnapshot()
427 upper = snapshots[i]; in SplitBySnapshot()
Drange_del_aggregator_test.cc523 std::vector<SequenceNumber> snapshots; in TEST_F() local
524 CompactionRangeDelAggregator range_del_agg(&bytewise_icmp, snapshots); in TEST_F()
557 std::vector<SequenceNumber> snapshots{9, 19}; in TEST_F() local
558 CompactionRangeDelAggregator range_del_agg(&bytewise_icmp, snapshots); in TEST_F()
598 std::vector<SequenceNumber> snapshots{9, 19}; in TEST_F() local
599 CompactionRangeDelAggregator range_del_agg(&bytewise_icmp, snapshots); in TEST_F()
616 std::vector<SequenceNumber> snapshots{9, 19}; in TEST_F() local
617 CompactionRangeDelAggregator range_del_agg(&bytewise_icmp, snapshots); in TEST_F()
641 std::vector<SequenceNumber> snapshots{9, 19}; in TEST_F() local
642 CompactionRangeDelAggregator range_del_agg(&bytewise_icmp, snapshots); in TEST_F()
[all …]
Dbuilder.cc79 std::vector<SequenceNumber> snapshots, in BuildTable() argument
98 new CompactionRangeDelAggregator(&internal_comparator, snapshots)); in BuildTable()
151 snapshots.empty() ? 0 : snapshots.back(), in BuildTable()
156 &snapshots, earliest_write_conflict_snapshot, snapshot_checker, env, in BuildTable()
Drange_tombstone_fragmenter.h43 const std::vector<SequenceNumber>& snapshots = {});
78 const std::vector<SequenceNumber>& snapshots);
178 SplitBySnapshot(const std::vector<SequenceNumber>& snapshots);
Drange_del_aggregator.h76 SplitBySnapshot(const std::vector<SequenceNumber>& snapshots);
392 const std::vector<SequenceNumber>& snapshots) in CompactionRangeDelAggregator() argument
393 : RangeDelAggregator(icmp), snapshots_(&snapshots) {} in CompactionRangeDelAggregator()
Ddb_test2.cc1438 std::vector<const Snapshot*> snapshots; in TEST_F() local
1443 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1444 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1446 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1462 for (auto s : snapshots) { in TEST_F()
2954 std::vector<const Snapshot*> snapshots; in TEST_F() local
2968 snapshots.push_back(snapshot); in TEST_F()
2975 snapshots.push_back(snapshot); in TEST_F()
2985 snapshots.push_back(snapshot); in TEST_F()
2995 snapshots.push_back(snapshot); in TEST_F()
[all …]
Dbuilder.h75 std::vector<SequenceNumber> snapshots,
Drange_del_aggregator.cc136 const std::vector<SequenceNumber>& snapshots) { in SplitBySnapshot() argument
141 auto split_untruncated_iters = iter_->SplitBySnapshot(snapshots); in SplitBySnapshot()
Ddb_range_del_test.cc1267 const Snapshot* snapshots[] = {nullptr, nullptr}; in TEST_F() local
1280 snapshots[0] = db_->GetSnapshot(); in TEST_F()
1283 snapshots[1] = db_->GetSnapshot(); in TEST_F()
1326 db_->ReleaseSnapshot(snapshots[0]); in TEST_F()
1327 db_->ReleaseSnapshot(snapshots[1]); in TEST_F()
Dflush_job_test.cc441 std::vector<SequenceNumber> snapshots(snapshots_set.begin(), in TEST_F() local
477 &mutex_, &shutting_down_, snapshots, kMaxSequenceNumber, in TEST_F()
Dinternal_stats.cc770 *value = db->snapshots().count(); in HandleNumSnapshots()
776 *value = static_cast<uint64_t>(db->snapshots().GetOldestSnapshotTime()); in HandleOldestSnapshotTime()
782 *value = static_cast<uint64_t>(db->snapshots().GetOldestSnapshotSequence()); in HandleOldestSnapshotSequence()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.cc630 std::vector<SequenceNumber> snapshots; in AdvanceMaxEvictedSeq() local
637 snapshots = GetSnapshotListFromDB(new_max); in AdvanceMaxEvictedSeq()
640 UpdateSnapshots(snapshots, new_snapshots_version); in AdvanceMaxEvictedSeq()
641 if (!snapshots.empty()) { in AdvanceMaxEvictedSeq()
643 for (auto snap : snapshots) { in AdvanceMaxEvictedSeq()
752 return db_impl_->snapshots().GetAll(nullptr, max); in GetSnapshotListFromDB()
813 const std::vector<SequenceNumber>& snapshots, in UpdateSnapshots() argument
837 auto it = snapshots.begin(); in UpdateSnapshots()
852 for (; it != snapshots.end(); ++it) { in UpdateSnapshots()
863 CleanupReleasedSnapshots(snapshots, snapshots_all_); in UpdateSnapshots()
[all …]
Dwrite_prepared_transaction_test.cc342 snapshots_ = snapshots; in SetDBSnapshots()
1146 CommitEntry commit_entry = {snapshots.front() - 1, snapshots.back() + 1}; in TEST_P()
1155 CommitEntry commit_entry = {snapshots.front() + 1, snapshots.back() + 1}; in TEST_P()
1201 snapshots.begin(), snapshots.begin() + old_size); in TEST_P()
2381 std::vector<const Snapshot*> snapshots; in TEST_P() local
2392 snapshots.push_back(db->GetSnapshot()); in TEST_P()
2421 for (auto* s : snapshots) { in TEST_P()
2793 std::vector<const Snapshot*> snapshots; in TEST_P() local
2829 snapshots.push_back(snapshot); in TEST_P()
2836 snapshots.push_back(db->GetSnapshot()); in TEST_P()
[all …]
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc328 std::vector<const Snapshot*> snapshots; in TEST_F() local
358 snapshots.push_back(dbfull()->GetSnapshot()); in TEST_F()
362 snapshots.push_back(dbfull()->GetSnapshot()); in TEST_F()
424 for (auto* snapshot : snapshots) { in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.h64 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
79 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots,
Dcompaction_iterator.cc35 SequenceNumber last_sequence, std::vector<SequenceNumber>* snapshots, in CompactionIterator() argument
46 input, cmp, merge_helper, last_sequence, snapshots, in CompactionIterator()
56 SequenceNumber /*last_sequence*/, std::vector<SequenceNumber>* snapshots, in CompactionIterator() argument
70 snapshots_(snapshots), in CompactionIterator()
Dcompaction_iterator_test.cc187 const std::unordered_map<SequenceNumber, SequenceNumber>& snapshots = {{}}) in TestSnapshotChecker() argument
189 snapshots_(snapshots) {}
Dcompaction_job_test.cc299 const std::vector<SequenceNumber>& snapshots = {}, in RunCompaction() argument
332 nullptr, nullptr, &mutex_, &error_handler_, snapshots,
/rocksdb-6.9/docs/_posts/
D2015-11-10-use-checkpoints-for-efficient-snapshots.markdown7 - /blog/2609/use-checkpoints-for-efficient-snapshots/
D2019-08-15-unordered-write.markdown19 …owever, RocksDB users could still get read-your-own-write and immutable snapshots when using this …
D2016-04-26-rocksdb-4-5-1-released.markdown53 …eSnapshots which allows CompactionFilter to be called even if there are snapshots later than the k…
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSnapshotTest.java24 public void snapshots() throws RocksDBException { in snapshots() method in SnapshotTest
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc1776 auto& snapshots = db_impl_->snapshots(); in VisibleToActiveSnapshot() local
1777 if (!snapshots.empty()) { in VisibleToActiveSnapshot()
1778 oldest_snapshot = snapshots.oldest()->GetSequenceNumber(); in VisibleToActiveSnapshot()
/rocksdb-6.9/
DHISTORY.md203 * Improve performance of row_cache: make reads with newer snapshots than data in an SST file share …
226 …borted() error when there is unreleased snapshot. Users can retry after all snapshots are released.
319 …story which periodically saves Statistics snapshots and added `GetStatsHistory` API to retrieve th…
373 …lush/compaction when DB contains many snapshots. The problem became noticeable to us in DBs with 1…
376 * Fix a bug in WritePrepared txns where if the number of old snapshots goes beyond the snapshot cac…
571 … could not be dropped due to the snapshot. This alleviates space-amp caused by long-held snapshots.
573 * Support for differential snapshots (via iterator emitting the sequence of key-values representing…
821 …eSnapshots which allows CompactionFilter to be called even if there are snapshots later than the k…
/rocksdb-6.9/db/db_impl/
Ddb_impl.h638 const SnapshotList& snapshots() const { return snapshots_; } in snapshots() function
648 snapshots().GetAll(snap_vector, oldest_write_conflict_snapshot, max_seq); in LoadSnapshots()

12