| /rocksdb-6.9/db/ |
| D | write_batch.cc | 765 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Put() 778 b->rep_.append(b->timestamp_size_, '\0'); in Put() 821 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Put() 904 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Delete() 926 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Delete() 950 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in SingleDelete() 974 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in SingleDelete() 998 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in DeleteRange() 1023 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in DeleteRange() 1055 WriteBatchInternal::SetCount(b, WriteBatchInternal::Count(b) + 1); in Merge() [all …]
|
| D | c.cc | 1199 Slice a, b; in rocksdb_compact_range() local 1212 Slice a, b; in rocksdb_compact_range_cf() local 1223 Slice a, b; in rocksdb_compact_range_opt() local 1236 Slice a, b; in rocksdb_compact_range_cf_opt() local 1344 return b; in rocksdb_writebatch_create_from() 1348 delete b; in rocksdb_writebatch_destroy() 1598 return b; in rocksdb_writebatch_wi_create() 1602 if (b->rep) { in rocksdb_writebatch_wi_destroy() 1605 delete b; in rocksdb_writebatch_wi_destroy() 3731 Slice a, b; in rocksdb_delete_file_in_range() local [all …]
|
| D | range_tombstone_fragmenter.h | 190 const RangeTombstoneStack& b) const { in operator() 191 return cmp->Compare(a.start_key, b.start_key) < 0; in operator() 194 bool operator()(const RangeTombstoneStack& a, const Slice& b) const { in operator() 195 return cmp->Compare(a.start_key, b) < 0; in operator() 198 bool operator()(const Slice& a, const RangeTombstoneStack& b) const { in operator() 199 return cmp->Compare(a, b.start_key) < 0; in operator() 209 const RangeTombstoneStack& b) const { in operator() 210 return cmp->Compare(a.end_key, b.end_key) < 0; in operator() 213 bool operator()(const RangeTombstoneStack& a, const Slice& b) const { in operator() 214 return cmp->Compare(a.end_key, b) < 0; in operator() [all …]
|
| D | file_indexer.cc | 111 [this](const FileMetaData* a, const FileMetaData* b) -> int { in UpdateIndex() argument 113 b->largest.user_key()); in UpdateIndex() 118 [this](const FileMetaData* a, const FileMetaData* b) -> int { in UpdateIndex() argument 120 b->largest.user_key()); in UpdateIndex() 125 [this](const FileMetaData* a, const FileMetaData* b) -> int { in UpdateIndex() argument 127 b->smallest.user_key()); in UpdateIndex() 132 [this](const FileMetaData* a, const FileMetaData* b) -> int { in UpdateIndex() argument 134 b->smallest.user_key()); in UpdateIndex()
|
| D | range_del_aggregator.h | 95 const TruncatedRangeDelIterator* b) const { in operator() 96 return a->seq() > b->seq(); in operator() 104 const TruncatedRangeDelIterator* b) const { in operator() 105 return icmp->Compare(a->start_key(), b->start_key()) > 0; in operator() 136 const ActiveSeqSet::const_iterator& b) const { in operator() 137 return icmp->Compare((*a)->end_key(), (*b)->end_key()) > 0; in operator() 213 const TruncatedRangeDelIterator* b) const { in operator() 214 return icmp->Compare(a->end_key(), b->end_key()) < 0; in operator() 223 const ActiveSeqSet::const_iterator& b) const { in operator() 224 return icmp->Compare((*a)->start_key(), (*b)->start_key()) < 0; in operator()
|
| D | comparator_db_test.cc | 176 int Compare(const Slice& a, const Slice& b) const override { in Compare() 179 double db = std::stod(b.ToString()); in Compare() 185 return a.compare(b); in Compare() 206 uint32_t hb = Hash(b.data(), b.size(), 66); in Compare() 208 return a.compare(b); in Compare() 229 assert(b.size() >= 2); in Compare() 231 size_t size_b1 = static_cast<size_t>(b[0]); in Compare() 233 size_t size_b2 = static_cast<size_t>(b[1]); in Compare() 235 assert(size_b1 + size_b2 + 2 == b.size()); in Compare() 238 Slice b1 = Slice(b.data() + 2, size_b1); in Compare() [all …]
|
| D | dbformat.cc | 117 const ParsedInternalKey& b) const { in Compare() 122 int r = user_comparator_.Compare(a.user_key, b.user_key); in Compare() 124 if (a.sequence > b.sequence) { in Compare() 126 } else if (a.sequence < b.sequence) { in Compare() 128 } else if (a.type > b.type) { in Compare() 130 } else if (a.type < b.type) { in Compare()
|
| /rocksdb-6.9/util/ |
| D | ppc-opcode.h | 11 #define __PPC_RB(b) (((b)&0x1f) << 11) argument 13 #define __PPC_XB(b) ((((b)&0x1f) << 11) | (((b)&0x20) >> 4)) argument 16 #define VSX_XX3(t, a, b) (__PPC_XT(t) | __PPC_XA(a) | __PPC_XB(b)) argument 17 #define VSX_XX1(s, a, b) (__PPC_XS(s) | __PPC_RA(a) | __PPC_RB(b)) argument 24 #define VPMSUMW(t, a, b) .long PPC_INST_VPMSUMW | VSX_XX3((t), a, b) argument 25 #define VPMSUMD(t, a, b) .long PPC_INST_VPMSUMD | VSX_XX3((t), a, b) argument
|
| D | comparator.cc | 27 int Compare(const Slice& a, const Slice& b) const override { in Compare() 28 return a.compare(b); in Compare() 31 bool Equal(const Slice& a, const Slice& b) const override { return a == b; } in Equal() 129 int CompareWithoutTimestamp(const Slice& a, bool /*a_has_ts*/, const Slice& b, in CompareWithoutTimestamp() argument 131 return a.compare(b); in CompareWithoutTimestamp() 143 int Compare(const Slice& a, const Slice& b) const override { in Compare() 144 return -a.compare(b); in Compare() 203 int CompareWithoutTimestamp(const Slice& a, bool /*a_has_ts*/, const Slice& b, in CompareWithoutTimestamp() argument 205 return -a.compare(b); in CompareWithoutTimestamp()
|
| D | user_comparator_wrapper.h | 27 int Compare(const Slice& a, const Slice& b) const override { in Compare() argument 29 return user_comparator_->Compare(a, b); in Compare() 32 bool Equal(const Slice& a, const Slice& b) const override { in Equal() argument 34 return user_comparator_->Equal(a, b); in Equal() 66 int CompareWithoutTimestamp(const Slice& a, bool a_has_ts, const Slice& b, in CompareWithoutTimestamp() argument 69 return user_comparator_->CompareWithoutTimestamp(a, a_has_ts, b, b_has_ts); in CompareWithoutTimestamp()
|
| D | vector_iterator.h | 78 bool operator()(size_t a, size_t b) const { in operator() 79 return cmp->Compare((*keys)[a], (*keys)[b]) < 0; in operator() 82 bool operator()(size_t a, const Slice& b) const { in operator() 83 return cmp->Compare((*keys)[a], b) < 0; in operator() 86 bool operator()(const Slice& a, size_t b) const { in operator() 87 return cmp->Compare(a, (*keys)[b]) < 0; in operator()
|
| D | kv_map.h | 21 bool operator()(const std::string& a, const std::string& b) const { in operator() 22 return cmp->Compare(Slice(a), Slice(b)) < 0; in operator() 24 bool operator()(const Slice& a, const Slice& b) const { in operator() 25 return cmp->Compare(a, b) < 0; in operator()
|
| /rocksdb-6.9/monitoring/ |
| D | histogram.cc | 76 for (unsigned int b = 0; b < num_buckets_; b++) { in Clear() local 77 buckets_[b].store(0, std::memory_order_relaxed); in Clear() 128 for (unsigned int b = 0; b < num_buckets_; b++) { in Merge() local 129 buckets_[b].fetch_add(other.bucket_at(b), std::memory_order_relaxed); in Merge() 140 for (unsigned int b = 0; b < num_buckets_; b++) { in Percentile() local 141 uint64_t bucket_value = bucket_at(b); in Percentile() 145 uint64_t left_point = (b == 0) ? 0 : bucketMapper.BucketLimit(b-1); in Percentile() 204 for (unsigned int b = 0; b < num_buckets_; b++) { in ToString() local 205 uint64_t bucket_value = bucket_at(b); in ToString() 210 (b == 0) ? '[' : '(', in ToString() [all …]
|
| /rocksdb-6.9/third-party/folly/folly/ |
| D | Optional.h | 418 void swap(Optional<T>& a, Optional<T>& b) noexcept(noexcept(a.swap(b))) { in swap() argument 419 a.swap(b); in swap() 453 return !(a == b); 458 return b.hasValue() && b.value() == a; 463 return !(a == b); 472 return a.value() == b.value(); 479 return !(a == b); 488 return a.value() < b.value(); 495 return b < a; 500 return !(b < a); [all …]
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend_test.cc | 277 std::string a, b, c; in TEST_F() local 286 ASSERT_EQ(b, "y\n2"); in TEST_F() 407 std::string a, b, c; in TEST_F() local 409 slists.Get("b", &b); in TEST_F() 433 std::string a, b, c; in TEST_F() local 435 slists.Get("b", &b); in TEST_F() 449 std::string a, b, c; in TEST_F() local 451 slists.Get("b", &b); in TEST_F() 465 std::string a, b, c; in TEST_F() local 499 slists.Get("b", &b); in TEST_F() [all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | slice.h | 117 int compare(const Slice& b) const; 130 size_t difference_offset(const Slice& b) const; 247 inline int Slice::compare(const Slice& b) const { in compare() argument 248 assert(data_ != nullptr && b.data_ != nullptr); in compare() 249 const size_t min_len = (size_ < b.size_) ? size_ : b.size_; in compare() 250 int r = memcmp(data_, b.data_, min_len); in compare() 252 if (size_ < b.size_) in compare() 254 else if (size_ > b.size_) in compare() 260 inline size_t Slice::difference_offset(const Slice& b) const { in difference_offset() argument 262 const size_t len = (size_ < b.size_) ? size_ : b.size_; in difference_offset() [all …]
|
| D | comparator.h | 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() argument 56 return Compare(a, b) == 0; in Equal() 103 int CompareWithoutTimestamp(const Slice& a, const Slice& b) const { in CompareWithoutTimestamp() argument 104 return CompareWithoutTimestamp(a, /*a_has_ts=*/true, b, /*b_has_ts=*/true); in CompareWithoutTimestamp() 120 const Slice& b, bool /*b_has_ts*/) const { in CompareWithoutTimestamp() argument 121 return Compare(a, b); in CompareWithoutTimestamp()
|
| D | c.h | 470 rocksdb_writebatch_t* b, int num_keys, const char* const* keys_list, 474 rocksdb_writebatch_t* b, rocksdb_column_family_handle_t* column_family, 487 rocksdb_writebatch_t* b, int num_keys, const char* const* keys_list, 491 rocksdb_writebatch_t* b, rocksdb_column_family_handle_t* column_family, 502 rocksdb_writebatch_t* b, int num_keys, const char* const* keys_list, 505 rocksdb_writebatch_t* b, rocksdb_column_family_handle_t* column_family, 508 rocksdb_writebatch_t* b, const char* start_key, size_t start_key_len, 511 rocksdb_writebatch_t* b, rocksdb_column_family_handle_t* column_family, 618 rocksdb_writebatch_wi_t* b, 623 rocksdb_writebatch_wi_t* b, [all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/util/ |
| D | BytewiseComparator.java | 36 public int compare(final ByteBuffer a, final ByteBuffer b) { in compare() argument 37 return _compare(a, b); in compare() 40 static int _compare(final ByteBuffer a, final ByteBuffer b) { in _compare() argument 41 assert(a != null && b != null); in _compare() 42 final int minLen = a.remaining() < b.remaining() ? in _compare() 43 a.remaining() : b.remaining(); in _compare() 44 int r = memcmp(a, b, minLen); in _compare() 46 if (a.remaining() < b.remaining()) { in _compare() 48 } else if (a.remaining() > b.remaining()) { in _compare()
|
| D | IntComparator.java | 38 public int compare(final ByteBuffer a, final ByteBuffer b) { in compare() argument 39 return compareIntKeys(a, b); in compare() 51 private final int compareIntKeys(final ByteBuffer a, final ByteBuffer b) { in compareIntKeys() argument 53 final int iB = b.getInt(); in compareIntKeys()
|
| /rocksdb-6.9/memory/ |
| D | arena_test.cc | 163 for (unsigned int b = 0; b < s; b++) { in SimpleTest() local 165 r[b] = i % 256; in SimpleTest() 177 for (unsigned int b = 0; b < num_bytes; b++) { in SimpleTest() local 179 ASSERT_EQ(int(p[b]) & 0xff, (int)(i % 256)); in SimpleTest()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | AbstractComparatorJniBridge.java | 44 final ByteBuffer b, final int bLen) { in compareInternal() argument 50 b.mark(); in compareInternal() 51 b.limit(bLen); in compareInternal() 54 final int c = comparator.compare(a, b); in compareInternal() 60 b.reset(); in compareInternal()
|
| /rocksdb-6.9/table/ |
| D | iter_heap.h | 21 bool operator()(IteratorWrapper* a, IteratorWrapper* b) const { in operator() 22 return comparator_->Compare(a->key(), b->key()) < 0; in operator() 35 bool operator()(IteratorWrapper* a, IteratorWrapper* b) const { in operator() 36 return comparator_->Compare(a->key(), b->key()) > 0; in operator()
|
| D | merger_test.cc | 36 auto b = single_iterator_.get(); in AssertEquivalence() local 38 ASSERT_TRUE(!b->Valid()); in AssertEquivalence() 40 ASSERT_TRUE(b->Valid()); in AssertEquivalence() 41 ASSERT_EQ(b->key().ToString(), a->key().ToString()); in AssertEquivalence() 42 ASSERT_EQ(b->value().ToString(), a->value().ToString()); in AssertEquivalence()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_test.cc | 36 auto* b = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTest_getContents() local 37 assert(b != nullptr); in Java_org_rocksdb_WriteBatchTest_getContents() 57 ROCKSDB_NAMESPACE::WriteBatchInternal::InsertInto(b, &cf_mems_default, in Java_org_rocksdb_WriteBatchTest_getContents() 126 } else if (ROCKSDB_NAMESPACE::WriteBatchInternal::Count(b) != count) { in Java_org_rocksdb_WriteBatchTest_getContents() 129 std::to_string(ROCKSDB_NAMESPACE::WriteBatchInternal::Count(b))); in Java_org_rocksdb_WriteBatchTest_getContents()
|