| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 141 batch.Put(Slice("foo"), Slice("bar")); in TEST_F()
144 batch.Put(Slice("baz"), Slice("boo")); in TEST_F()
159 batch.Put(Slice("foo"), Slice("bar")); in TEST_F()
319 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
359 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
360 batch.Put(Slice("k2"), Slice("v2")); in TEST_F()
361 batch.Put(Slice("k3"), Slice("v3")); in TEST_F()
394 batch.Put(Slice("k1"), Slice("v1")); in TEST_F()
395 batch.Put(Slice("k2"), Slice("v2")); in TEST_F()
585 Slice value_slices[2] = { Slice("header"), Slice("payload") }; in TEST_F()
[all …]
|
| D | dbformat.h | 100 Slice user_key;
156 inline Slice ExtractUserKey(const Slice& internal_key) { in ExtractUserKey()
211 virtual int CompareKeySeq(const Slice& a, const Slice& b) const;
352 Slice GetKey() const { return Slice(key_, key_size_); } in GetKey()
403 Slice SetKey(const Slice& key, bool copy = true) {
408 Slice SetUserKey(const Slice& key, bool copy = true) {
413 Slice SetInternalKey(const Slice& key, bool copy = true) {
511 Slice SetKeyImpl(const Slice& key, bool copy) { in SetKeyImpl()
560 virtual Slice Transform(const Slice& src) const override { in Transform()
596 Slice* value, Slice* blob, Slice* xid);
[all …]
|
| D | manual_compaction_test.cc | 65 bool Filter(int level, const Slice& key, const Slice& /*existing_value*/, in Filter() argument
103 db->Put(WriteOptions(), Slice("key1"), Slice("destroy")); in TEST_F()
104 db->Put(WriteOptions(), Slice("key2"), Slice("destroy")); in TEST_F()
105 db->Put(WriteOptions(), Slice("key3"), Slice("value3")); in TEST_F()
106 db->Put(WriteOptions(), Slice("key4"), Slice("destroy")); in TEST_F()
205 Slice start("5"); in TEST_F()
206 Slice end("7"); in TEST_F()
216 Slice end("7"); in TEST_F()
228 Slice end("0"); in TEST_F()
249 Slice end("2"); in TEST_F()
[all …]
|
| D | comparator_db_test.cc | 176 int Compare(const Slice& a, const Slice& b) const override { in Compare()
204 int Compare(const Slice& a, const Slice& b) const override { in Compare()
227 int Compare(const Slice& a, const Slice& b) const override { in Compare()
237 Slice a1 = Slice(a.data() + 2, size_a1); in Compare()
238 Slice b1 = Slice(b.data() + 2, size_b1); in Compare()
239 Slice a2 = Slice(a.data() + 2 + size_a1, size_a2); in Compare()
240 Slice b2 = Slice(b.data() + 2 + size_b1, size_b2); in Compare()
455 Slice s("abcxy"); in TEST_P()
461 Slice t("abcxy"); in TEST_P()
477 Slice s("abcxy"); in TEST_P()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | status.h | 105 static Status NotFound(const Slice& msg, const Slice& msg2 = Slice()) {
111 static Status Corruption(const Slice& msg, const Slice& msg2 = Slice()) {
118 static Status NotSupported(const Slice& msg, const Slice& msg2 = Slice()) {
132 static Status IOError(const Slice& msg, const Slice& msg2 = Slice()) {
144 static Status Incomplete(const Slice& msg, const Slice& msg2 = Slice()) {
159 static Status Aborted(const Slice& msg, const Slice& msg2 = Slice()) {
164 static Status Busy(const Slice& msg, const Slice& msg2 = Slice()) {
169 static Status TimedOut(const Slice& msg, const Slice& msg2 = Slice()) {
174 static Status Expired(const Slice& msg, const Slice& msg2 = Slice()) {
179 static Status TryAgain(const Slice& msg, const Slice& msg2 = Slice()) {
[all …]
|
| D | write_batch.h | 37 class Slice; variable
70 const Slice& value) override;
71 Status Put(const Slice& key, const Slice& value) override { in Put()
113 Status DeleteRange(const Slice& begin_key, const Slice& end_key) override { in DeleteRange()
130 const Slice& value) override;
131 Status Merge(const Slice& key, const Slice& value) override { in Merge()
188 const Slice& value) { in PutCF()
199 virtual void Put(const Slice& /*key*/, const Slice& /*value*/) {} in Put() argument
236 virtual void Merge(const Slice& /*key*/, const Slice& /*value*/) {} in Merge() argument
245 virtual void LogData(const Slice& blob);
[all …]
|
| D | merge_operator.h | 17 class Slice; variable
69 virtual bool FullMerge(const Slice& /*key*/, const Slice* /*existing_value*/, in FullMerge() argument
78 explicit MergeOperationInput(const Slice& _key, in MergeOperationInput()
88 const Slice& key;
91 const Slice* existing_value;
93 const std::vector<Slice>& operand_list;
109 Slice& existing_operand;
163 virtual bool PartialMerge(const Slice& /*key*/, const Slice& /*left_operand*/, in PartialMerge() argument
191 virtual bool PartialMergeMulti(const Slice& key,
243 virtual bool Merge(const Slice& key, const Slice* existing_value,
[all …]
|
| D | io_status.h | 69 static IOStatus NotSupported(const Slice& msg, const Slice& msg2 = Slice()) {
77 static IOStatus NotFound(const Slice& msg, const Slice& msg2 = Slice()) {
85 static IOStatus Corruption(const Slice& msg, const Slice& msg2 = Slice()) {
93 const Slice& msg2 = Slice()) {
100 static IOStatus IOError(const Slice& msg, const Slice& msg2 = Slice()) {
108 static IOStatus Busy(const Slice& msg, const Slice& msg2 = Slice()) {
115 static IOStatus TimedOut(const Slice& msg, const Slice& msg2 = Slice()) {
120 static IOStatus NoSpace(const Slice& msg, const Slice& msg2 = Slice()) {
125 static IOStatus PathNotFound(const Slice& msg, const Slice& msg2 = Slice()) {
146 IOStatus(Code _code, const Slice& msg, const Slice& msg2) in IOStatus()
[all …]
|
| D | slice.h | 35 class Slice {
38 Slice() : data_(""), size_(0) {} in Slice() function
117 int compare(const Slice& b) const;
120 bool starts_with(const Slice& x) const { in starts_with()
124 bool ends_with(const Slice& x) const { in ends_with()
176 inline void PinSelf(const Slice& slice) { in PinSelf()
236 const Slice* parts;
240 inline bool operator==(const Slice& x, const Slice& y) {
245 inline bool operator!=(const Slice& x, const Slice& y) { return !(x == y); }
247 inline int Slice::compare(const Slice& b) const { in compare()
[all …]
|
| D | write_batch_base.h | 17 class Slice; variable
32 const Slice& value) = 0;
33 virtual Status Put(const Slice& key, const Slice& value) = 0;
45 const Slice& value) = 0;
46 virtual Status Merge(const Slice& key, const Slice& value) = 0;
55 const Slice& key) = 0;
56 virtual Status Delete(const Slice& key) = 0;
66 const Slice& key) = 0;
67 virtual Status SingleDelete(const Slice& key) = 0;
77 const Slice& begin_key, const Slice& end_key) = 0;
[all …]
|
| D | comparator.h | 17 class Slice; variable
48 virtual int Compare(const Slice& a, const Slice& b) const = 0;
55 virtual bool Equal(const Slice& a, const Slice& b) const { in Equal()
78 const Slice& limit) const = 0;
90 virtual bool IsSameLengthImmediateSuccessor(const Slice& /*s*/, in IsSameLengthImmediateSuccessor() argument
91 const Slice& /*t*/) const { in IsSameLengthImmediateSuccessor()
103 int CompareWithoutTimestamp(const Slice& a, const Slice& b) const { in CompareWithoutTimestamp()
114 virtual int CompareTimestamp(const Slice& /*ts1*/, in CompareTimestamp() argument
115 const Slice& /*ts2*/) const { in CompareTimestamp()
119 virtual int CompareWithoutTimestamp(const Slice& a, bool /*a_has_ts*/, in CompareWithoutTimestamp()
[all …]
|
| D | db.h | 99 Slice start;
100 Slice limit;
103 Range(const Slice& s, const Slice& l) : start(s), limit(l) {} in Range()
107 const Slice* start;
108 const Slice* limit;
111 RangePtr(const Slice* s, const Slice* l) : start(s), limit(l) {} in RangePtr()
367 const Slice& begin_key, const Slice& end_key);
1074 const Slice* begin, const Slice* end) = 0;
1076 const Slice* begin, const Slice* end) { in CompactRange()
1081 ColumnFamilyHandle* column_family, const Slice* begin, const Slice* end,
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | writebatchhandlerjnicallback.h | 31 const Slice& value);
32 void Put(const Slice& key, const Slice& value);
34 const Slice& value);
35 void Merge(const Slice& key, const Slice& value);
37 void Delete(const Slice& key);
39 void SingleDelete(const Slice& key);
41 const Slice& endKey);
42 void DeleteRange(const Slice& beginKey, const Slice& endKey);
43 void LogData(const Slice& blob);
50 Status MarkCommit(const Slice& xid);
[all …]
|
| D | slice.cc | 46 const auto* slice = new ROCKSDB_NAMESPACE::Slice(buf); in Java_org_rocksdb_AbstractSlice_createNewSliceFromString()
93 reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(otherHandle); in Java_org_rocksdb_AbstractSlice_compare0()
108 reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(otherHandle); in Java_org_rocksdb_AbstractSlice_startsWith0()
120 delete reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_AbstractSlice_disposeInternal()
170 const auto* slice = new ROCKSDB_NAMESPACE::Slice(buf, len - 1); in Java_org_rocksdb_Slice_createNewSlice1()
212 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_Slice_clear0()
227 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_Slice_removePrefix0()
269 const auto* slice = new ROCKSDB_NAMESPACE::Slice(ptrData, length); in Java_org_rocksdb_DirectSlice_createNewDirectSlice0()
292 const auto* slice = new ROCKSDB_NAMESPACE::Slice(ptrData); in Java_org_rocksdb_DirectSlice_createNewDirectSlice1()
327 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_DirectSlice_clear0()
[all …]
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 49 Slice key;
50 Slice value;
64 virtual void Seek(const Slice& key) = 0;
66 virtual void SeekForPrev(const Slice& key) = 0;
108 const Slice& value) override;
110 Status Put(const Slice& key, const Slice& value) override;
114 const Slice& value) override;
116 Status Merge(const Slice& key, const Slice& value) override;
120 Status Delete(const Slice& key) override;
124 const Slice& key) override;
[all …]
|
| D | transaction.h | 331 virtual Status Put(const Slice& key, const Slice& value) = 0;
338 const Slice& value,
340 virtual Status Merge(const Slice& key, const Slice& value) = 0;
344 virtual Status Delete(const Slice& key) = 0;
351 const Slice& key,
353 virtual Status SingleDelete(const Slice& key) = 0;
368 const Slice& key, const Slice& value) = 0;
369 virtual Status PutUntracked(const Slice& key, const Slice& value) = 0;
377 const Slice& key, const Slice& value) = 0;
378 virtual Status MergeUntracked(const Slice& key, const Slice& value) = 0;
[all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | SliceTest.java | 20 try (final Slice slice = new Slice("testSlice")) { in slice()
26 try (final Slice otherSlice = new Slice("otherSlice".getBytes())) { in slice()
30 try (final Slice thirdSlice = new Slice("otherSlice".getBytes(), 5)) { in slice()
37 try (final Slice slice = new Slice("abc")) { in sliceClear()
47 try (final Slice slice = new Slice("abc")) { in sliceRemovePrefix()
56 try (final Slice slice = new Slice("abc"); in sliceEquals()
57 final Slice slice2 = new Slice("abc")) { in sliceEquals()
65 try (final Slice slice = new Slice("matchpoint"); in sliceStartWith()
66 final Slice match = new Slice("mat"); in sliceStartWith()
67 final Slice noMatch = new Slice("nomatch")) { in sliceStartWith()
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.h | 88 const std::vector<Slice>& keys,
107 const std::vector<Slice>& keys,
125 Status Put(const Slice& key, const Slice& value) override { in Put()
138 Status Merge(const Slice& key, const Slice& value) override { in Merge()
151 Status SingleDelete(const Slice& key) override { in SingleDelete()
161 const Slice& value) override;
162 Status PutUntracked(const Slice& key, const Slice& value) override { in PutUntracked()
174 Status MergeUntracked(const Slice& key, const Slice& value) override { in MergeUntracked()
179 const Slice& key) override;
195 void PutLogData(const Slice& blob) override;
[all …]
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_reader.cc | 149 Slice user_key = ExtractUserKey(key); in Get()
189 Slice user_key = ExtractUserKey(key); in Prepare()
209 void Seek(const Slice& target) override;
213 Slice key() const override;
214 Slice value() const override;
222 const Slice& target = Slice()) in BucketComparator()
239 const Slice file_data_;
243 const Slice target_;
254 Slice curr_value_;
278 if (Slice(bucket, reader_->key_length_) != Slice(reader_->unused_key_)) { in InitIfNeeded()
[all …]
|
| /rocksdb-6.9/util/ |
| D | slice.cc | 37 Slice Transform(const Slice& src) const override { in Transform()
39 return Slice(src.data(), prefix_len_); in Transform()
42 bool InDomain(const Slice& src) const override { in InDomain()
46 bool InRange(const Slice& dst) const override { in InRange()
77 Slice Transform(const Slice& src) const override { in Transform()
79 return Slice(src.data(), std::min(cap_len_, src.size())); in Transform()
84 bool InRange(const Slice& dst) const override { in InRange()
104 Slice Transform(const Slice& src) const override { return src; } in Transform()
142 Slice::Slice(const SliceParts& parts, std::string* buf) { in Slice() function in ROCKSDB_NAMESPACE::Slice
157 std::string Slice::ToString(bool hex) const { in ToString()
[all …]
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.cc | 55 Slice next_byte_slice; in DecodeSize()
89 return IOStatus::Corruption(Slice()); in AppendKey()
113 Slice prefix = in AppendKey()
179 Slice* out) { in ReadNonMmap()
212 Slice read_result; in ReadNonMmap()
247 Slice bytes; in ReadVarint32NonMmap()
263 Slice tmp_slice; in ReadInternalKey()
313 Slice decoded_internal_key; in NextPlainEncodingKey()
364 Slice decoded_internal_key; in NextPrefixEncodingKey()
411 Slice tmp_slice; in NextPrefixEncodingKey()
[all …]
|
| D | plain_table_reader.h | 47 Slice file_data;
89 void Prepare(const Slice& target) override;
95 uint64_t ApproximateOffsetOf(const Slice& key,
98 uint64_t ApproximateSize(const Slice& start, const Slice& end,
180 Slice GetPrefix(const Slice& target) const { in GetPrefix()
185 Slice GetPrefix(const ParsedInternalKey& target) const { in GetPrefix()
189 Slice GetUserKey(const Slice& key) const { in GetUserKey()
190 return Slice(key.data(), key.size() - 8); in GetUserKey()
193 Slice GetPrefixFromUserKey(const Slice& user_key) const { in GetPrefixFromUserKey()
201 return Slice(); in GetPrefixFromUserKey()
[all …]
|
| /rocksdb-6.9/table/block_based/ |
| D | full_filter_block.cc | 30 void FullFilterBlockBuilder::Add(const Slice& key) { in Add()
40 Slice last_whole_key = Slice(last_whole_key_str_); in Add()
54 inline void FullFilterBlockBuilder::AddKey(const Slice& key) { in AddKey()
60 void FullFilterBlockBuilder::AddPrefix(const Slice& key) { in AddPrefix()
61 Slice prefix = prefix_extractor_->Transform(key); in AddPrefix()
67 Slice last_prefix = Slice(last_prefix_str_); in AddPrefix()
92 return Slice(); in Finish()
240 std::array<Slice*, MultiGetContext::MAX_BATCH_SIZE> keys; in MayMatch()
285 const Slice* iterate_upper_bound, const Slice& user_key, in RangeMayExist()
294 Slice prefix = prefix_extractor->Transform(user_key); in RangeMayExist()
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db.h | 87 virtual Status Put(const WriteOptions& options, const Slice& key,
88 const Slice& value) override = 0;
91 const Slice& value) override { in Put()
102 const Slice& key) override { in Delete()
112 const Slice& value, uint64_t ttl) = 0;
115 const Slice& value, uint64_t ttl) { in PutWithTTL()
146 virtual Status Get(const ReadOptions& options, const Slice& key, in Get()
154 const std::vector<Slice>& keys,
159 const std::vector<Slice>& keys, in MultiGet()
185 const Slice& /*key*/) override { in SingleDelete() argument
[all …]
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 92 virtual int Compare(const Slice& a, const Slice& b) const override { in Compare()
112 virtual int Compare(const Slice& a, const Slice& b) const override { in Compare()
113 Slice prefix_a = Slice(a.data(), 8); in Compare()
114 Slice prefix_b = Slice(b.data(), 8); in Compare()
119 Slice suffix_a = Slice(a.data() + 8, a.size() - 8); in Compare()
120 Slice suffix_b = Slice(b.data() + 8, b.size() - 8); in Compare()
175 virtual Slice key() const override { return Slice(keys_[current_]); } in key()
176 virtual Slice value() const override { return Slice(values_[current_]); } in value()
221 *reader_contents_ = Slice( in Flush()
244 Slice* reader_contents_;
[all …]
|