Home
last modified time | relevance | path

Searched refs:end_key (Results 1 – 25 of 41) sorted by relevance

12

/rocksdb-6.9/db/
Drange_tombstone_fragmenter.h31 end_key(end), in RangeTombstoneStack()
36 Slice end_key; member
138 Slice value() const override { return pos_->end_key; } in value()
152 return RangeTombstone(start_key(), end_key(), seq()); in Tombstone()
155 Slice end_key() const { return pos_->end_key; } in end_key() function
162 return ParsedInternalKey(pos_->end_key, kMaxSequenceNumber, in parsed_end_key()
210 return cmp->Compare(a.end_key, b.end_key) < 0; in operator()
214 return cmp->Compare(a.end_key, b) < 0; in operator()
218 return cmp->Compare(a, b.end_key) < 0; in operator()
Drange_del_aggregator_bench.cc100 std::string end_key; member
105 : start_key(std::move(start)), end_key(std::move(end)) { in PersistentRangeTombstone()
106 tombstone = RangeTombstone(start_key, end_key, seq); in PersistentRangeTombstone()
115 end_key = t.end_key; in operator =()
116 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
125 end_key = std::move(t.end_key); in operator =()
126 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
Drange_del_aggregator.cc167 icmp_->Compare((*active_iters_.top())->end_key(), parsed) <= 0) { in ShouldDelete()
171 } while (iter->Valid() && icmp_->Compare(iter->end_key(), parsed) <= 0); in ShouldDelete()
180 while (iter->Valid() && icmp_->Compare(iter->end_key(), parsed) <= 0) { in ShouldDelete()
221 icmp_->Compare(parsed, inactive_iters_.top()->end_key()) < 0) { in ShouldDelete()
294 if (icmp_->Compare(start_ikey, iter->end_key()) < 0 && in IsRangeOverlapped()
305 if (iter->Valid() && icmp_->Compare(start_ikey, iter->end_key()) < 0 && in IsRangeOverlapped()
432 assert(top->end_key().sequence == kMaxSequenceNumber); in value()
433 return top->end_key().user_key; in value()
Dwrite_batch_base.cc62 const SliceParts& end_key) { in DeleteRange() argument
65 Slice end_key_slice(end_key, &end_key_buf); in DeleteRange()
70 const SliceParts& end_key) { in DeleteRange() argument
73 Slice end_key_slice(end_key, &end_key_buf); in DeleteRange()
Drange_del_aggregator.h66 ParsedInternalKey end_key() const { in end_key() function
137 return icmp->Compare((*a)->end_key(), (*b)->end_key()) > 0; in operator()
214 return icmp->Compare(a->end_key(), b->end_key()) < 0; in operator()
235 } else if (icmp_->Compare(iter->end_key(), parsed) <= 0) { in PushIter()
Dwrite_batch.cc170 const Slice& end_key) override { in DeleteRangeCF() argument
172 AssignTimestamp(end_key); in DeleteRangeCF()
1006 PutLengthPrefixedSlice(&b->rep_, end_key); in DeleteRange()
1016 begin_key, end_key); in DeleteRange()
1031 PutLengthPrefixedSliceParts(&b->rep_, end_key); in DeleteRange()
1040 const SliceParts& end_key) { in DeleteRange() argument
1042 begin_key, end_key); in DeleteRange()
1596 const Slice& end_key) override { in DeleteRangeCF() argument
1600 begin_key, end_key); in DeleteRangeCF()
1613 begin_key, end_key); in DeleteRangeCF()
[all …]
Dmanual_compaction_test.cc158 std::string end_key = Key1(kNumKeys - 1); in TEST_F() local
160 Slice greatest(end_key.data(), end_key.size()); in TEST_F()
Drange_del_aggregator_test.cc90 EXPECT_EQ(0, icmp.Compare(iter->end_key(), expected_range_dels[i].end)); in VerifyIterator()
105 0, icmp.Compare(iter->end_key(), reverse_expected_range_dels[i].end)); in VerifyIterator()
121 EXPECT_EQ(0, icmp.Compare(iter->end_key(), test_case.end)); in VerifySeek()
137 EXPECT_EQ(0, icmp.Compare(iter->end_key(), test_case.end)); in VerifySeekForPrev()
178 EXPECT_EQ(tombstone.end_key_, iter->end_key()); in CheckIterPosition()
Dwrite_batch_internal.h92 const Slice& begin_key, const Slice& end_key);
96 const SliceParts& end_key);
Dexternal_sst_file_ingestion_job.cc509 InternalKey end_key = tombstone.SerializeEndKey(); in GetIngestedFileInfo() local
511 sstableKeyCompare(ucmp, end_key, in GetIngestedFileInfo()
513 file_to_ingest->largest_internal_key = end_key; in GetIngestedFileInfo()
Dexternal_sst_file_basic_test.cc65 std::string end_key = Key(range_deletions[i].second); in GenerateAndAddExternalFile() local
66 s = sst_file_writer.DeleteRange(start_key, end_key); in GenerateAndAddExternalFile()
75 auto end_key_it = true_data->find(end_key); in GenerateAndAddExternalFile()
77 end_key_it = true_data->upper_bound(end_key); in GenerateAndAddExternalFile()
Dwrite_batch_test.cc270 const Slice& end_key) override { in DeleteRangeCF()
273 end_key.ToString() + ")"; in DeleteRangeCF()
276 begin_key.ToString() + ", " + end_key.ToString() + ")"; in DeleteRangeCF()
Dc.cc855 const char* end_key, size_t end_key_len, in rocksdb_delete_range_cf() argument
859 Slice(end_key, end_key_len))); in rocksdb_delete_range_cf()
1501 size_t start_key_len, const char* end_key, in rocksdb_writebatch_delete_range() argument
1504 Slice(end_key, end_key_len)); in rocksdb_writebatch_delete_range()
1509 const char* start_key, size_t start_key_len, const char* end_key, in rocksdb_writebatch_delete_range_cf() argument
1512 Slice(end_key, end_key_len)); in rocksdb_writebatch_delete_range_cf()
1758 size_t start_key_len, const char* end_key, in rocksdb_writebatch_wi_delete_range() argument
1761 Slice(end_key, end_key_len)); in rocksdb_writebatch_wi_delete_range()
1766 const char* start_key, size_t start_key_len, const char* end_key, in rocksdb_writebatch_wi_delete_range_cf() argument
1769 Slice(end_key, end_key_len)); in rocksdb_writebatch_wi_delete_range_cf()
/rocksdb-6.9/utilities/
Ddebug.cc14 Status GetAllKeyVersions(DB* db, Slice begin_key, Slice end_key, in GetAllKeyVersions() argument
20 return GetAllKeyVersions(db, db->DefaultColumnFamily(), begin_key, end_key, in GetAllKeyVersions()
25 Slice end_key, size_t max_num_ikeys, in GetAllKeyVersions() argument
62 if (!end_key.empty() && in GetAllKeyVersions()
63 icmp.user_comparator()->Compare(ikey.user_key, end_key) > 0) { in GetAllKeyVersions()
/rocksdb-6.9/include/rocksdb/
Dwrite_batch_base.h77 const Slice& begin_key, const Slice& end_key) = 0;
78 virtual Status DeleteRange(const Slice& begin_key, const Slice& end_key) = 0;
83 const SliceParts& end_key);
85 const SliceParts& end_key);
Dwrite_batch.h112 const Slice& end_key) override;
113 Status DeleteRange(const Slice& begin_key, const Slice& end_key) override { in DeleteRange() argument
114 return DeleteRange(nullptr, begin_key, end_key); in DeleteRange()
120 const SliceParts& end_key) override;
122 const SliceParts& end_key) override { in DeleteRange() argument
123 return DeleteRange(nullptr, begin_key, end_key); in DeleteRange()
Dsst_file_writer.h121 Status DeleteRange(const Slice& begin_key, const Slice& end_key);
Dc.h273 size_t start_key_len, const char* end_key, size_t end_key_len,
509 const char* end_key, size_t end_key_len);
512 const char* start_key, size_t start_key_len, const char* end_key,
598 const char* end_key, size_t end_key_len);
602 const char* start_key, size_t start_key_len, const char* end_key,
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc87 Slice end_key = end_key_str; in TestDeleteRange() local
91 batch.DeleteRange(cfh, key, end_key); in TestDeleteRange()
457 Slice end_key; in VerifyDb() local
460 end_key = iters[i]->key(); in VerifyDb()
463 end_key = key; in VerifyDb()
468 Status s = GetAllKeyVersions(db_, cfh, begin_key, end_key, in VerifyDb()
480 end_key.ToString(true /* hex */).c_str(), kMaxNumIKeys); in VerifyDb()
Ddb_stress_shared_state.h281 int DeleteRange(int cf, int64_t begin_key, int64_t end_key, bool pending) { in DeleteRange() argument
283 for (int64_t key = begin_key; key < end_key; ++key) { in DeleteRange()
Ddb_stress_test_base.cc1548 Slice end_key(end_key_buf); in TestCompactRange() local
1571 GetRangeHash(thread, pre_snapshot, column_family, start_key, end_key); in TestCompactRange()
1574 Status status = db_->CompactRange(cro, column_family, &start_key, &end_key); in TestCompactRange()
1583 GetRangeHash(thread, pre_snapshot, column_family, start_key, end_key); in TestCompactRange()
1588 start_key.ToString(true).c_str(), end_key.ToString(true).c_str()); in TestCompactRange()
1600 const Slice& end_key) { in GetRangeHash() argument
1608 it->Valid() && options_.comparator->Compare(it->key(), end_key) <= 0; in GetRangeHash()
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc27 InternalKey start_key, end_key; in SuggestCompactRange() local
32 end_key.SetMaxPossibleForUserKey(*end); in SuggestCompactRange()
41 end == nullptr ? nullptr : &end_key, &inputs); in SuggestCompactRange()
/rocksdb-6.9/include/rocksdb/utilities/
Ddebug.h39 Status GetAllKeyVersions(DB* db, Slice begin_key, Slice end_key,
44 Slice end_key, size_t max_num_ikeys,
/rocksdb-6.9/table/
Dsst_file_writer.cc107 Status DeleteRange(const Slice& begin_key, const Slice& end_key) { in DeleteRange()
112 RangeTombstone tombstone(begin_key, end_key, 0 /* Sequence Number */); in DeleteRange()
278 const Slice& end_key) { in DeleteRange() argument
279 return rep_->DeleteRange(begin_key, end_key); in DeleteRange()
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.h191 const Slice& end_key);
276 const Slice& end_key) override { in DeleteRangeCF() argument
277 return ta_ptr->HandleDeleteRange(column_family_id, begin_key, end_key); in DeleteRangeCF()

12