| /rocksdb-6.9/utilities/persistent_cache/ |
| D | hash_table_test.cc | 28 : key_(key), val_(val) {} in Node()
30 uint64_t key_ = 0; member
36 return lhs.key_ == rhs.key_; in operator ()()
42 return std::hash<uint64_t>()(node.key_); in operator ()()
59 : key_(key), val_(val) {} in Node()
61 uint64_t key_ = 0; member
68 return lhs->key_ == rhs->key_; in operator ()()
74 return std::hash<uint64_t>()(node->key_); in operator ()()
149 assert(val->val_ == std::string(1000, val->key_ % 255)); in TEST_F()
|
| D | block_cache_tier_metadata.h | 42 : key_(key.ToString()), lba_(lba) {}
44 std::string key_; member
107 return std::hash<std::string>()(node->key_); in operator()
113 return lhs->key_ == rhs->key_; in operator()
|
| D | block_cache_tier_file.cc | 87 key_(key), in CacheRecord()
107 Slice key_; member
118 crc = crc32c::Extend(crc, reinterpret_cast<const char*>(key_.data()), in ComputeCRC()
119 key_.size()); in ComputeCRC()
130 Append(bufs, woff, reinterpret_cast<const char*>(key_.data()), in Serialize()
131 key_.size()) && in Serialize()
180 key_ = Slice(data.data_ + sizeof(hdr_), hdr_.key_size_); in Deserialize()
181 val_ = Slice(key_.data_ + hdr_.key_size_, hdr_.val_size_); in Deserialize()
187 fprintf(stderr, "** key %s ** \n", key_.ToString().c_str()); in Deserialize()
262 *key = Slice(rec.key_); in ParseRec()
|
| D | hash_table_bench.cc | 251 explicit Node(const size_t key, const string& val) : key_(key), val_(val) {} in Node()
253 size_t key_ = 0; member
259 return std::hash<uint64_t>()(node.key_); in operator ()()
265 return lhs.key_ == rhs.key_; in operator ()()
|
| D | persistent_cache_test.h | 73 key_ = 0; in Insert()
88 key_ = 0;
127 size_t i = key_++; in InsertImpl()
151 size_t i = key_++;
215 std::atomic<size_t> key_{0};
|
| D | block_cache_tier.h | 91 : key_(std::move(key)), data_(data) {} in InsertOp()
99 size_t Size() { return data_.size() + key_.size(); } in Size()
101 std::string key_; member
|
| D | block_cache_tier_metadata.cc | 56 assert(block->key_ == key.ToString()); in Lookup()
|
| D | block_cache_tier.cc | 201 while ((s = InsertImpl(Slice(op.key_), Slice(op.data_))).IsTryAgain()) { in InsertMain()
|
| /rocksdb-6.9/db/ |
| D | dbformat.h | 338 key_(buf_), in IterKey()
356 return Slice(key_, key_size_); in GetInternalKey()
388 memcpy(p, key_, shared_len); in TrimAppend()
399 key_ = buf_; in TrimAppend()
425 return Slice(key_, key_n); in SetInternalKey()
434 key_ = buf_; in OwnKey()
466 key_ = buf_;
497 key_ = buf_; in EncodeLengthPrefixedKey()
505 const char* key_; variable
517 key_ = buf_; in SetKeyImpl()
[all …]
|
| /rocksdb-6.9/table/block_based/ |
| D | block.cc | 191 key_.SetKey(current_key, false /* copy */); in Prev()
222 if (key_.IsKeyPinned()) { in Prev()
439 while (Valid() && Compare(key_, seek_key) > 0) { in SeekForPrev()
496 key_.Clear(); in CorruptionError()
518 if (p == nullptr || key_.Size() < shared) { in ParseNextDataKey()
529 key_.TrimAppend(shared, p, non_shared); in ParseNextDataKey()
551 key_.OwnKey(); in ParseNextDataKey()
555 key_.UpdateInternalKey(global_seqno_, value_type); in ParseNextDataKey()
590 if (p == nullptr || key_.Size() < shared) { in ParseNextIndexKey()
597 key_.SetKey(Slice(p, non_shared), false /* copy */); in ParseNextIndexKey()
[all …]
|
| D | block.h | 270 return key_.GetKey(); in key()
313 IterKey key_; variable
344 key_.Clear(); in SeekToRestartPoint()
384 key_.SetIsUserKey(false); in Initialize()
488 return key_.GetKey(); in key()
504 key_.SetIsUserKey(!key_includes_seq_); in Initialize()
552 key_.Clear(); in SeekForPrev()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.cc | 143 key_ = merge_out_iter_.key(); in Next()
146 valid_key = ParseInternalKey(key_, &ikey_); in Next()
152 key_.ToString(true).c_str()); in Next()
157 key_ = current_key_.GetInternalKey(); in Next()
244 key_ = input_->key(); in NextFromInput()
248 if (!ParseInternalKey(key_, &ikey_)) { in NextFromInput()
257 key_ = current_key_.SetInternalKey(key_); in NextFromInput()
288 key_ = current_key_.SetInternalKey(key_, &ikey_); in NextFromInput()
308 key_ = current_key_.GetInternalKey(); in NextFromInput()
586 key_ = merge_out_iter_.key(); in NextFromInput()
[all …]
|
| D | compaction_iterator.h | 106 const Slice& key() const { return key_; } in key()
180 Slice key_; variable
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | ParkingLot.h | 21 const uint64_t key_; member
32 : key_(key), lotid_(lotid), signaled_(false) {} in WaitNodeBase()
301 if (node->key_ == key && node->lotid_ == lotid_) { in unpark()
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_reader.cc | 89 Slice key_; member in ROCKSDB_NAMESPACE::PlainTableIterator
750 table_->Next(&decoder_, &next_offset_, &parsed_key, &key_, &value_); in Next()
763 return key_; in key()
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd_impl.h | 333 std::string key_;
408 std::string key_;
443 std::string key_;
|
| D | ldb_cmd.cc | 2323 key_ = params.at(0);
2327 key_ = HexToString(key_);
2345 Status st = db_->Get(ReadOptions(), GetCfHandle(), key_, &value); in DoCommand()
2635 key_ = params.at(0);
2637 key_ = HexToString(key_);
2653 Status st = db_->Delete(WriteOptions(), GetCfHandle(), key_); in DoCommand()
2710 key_ = params.at(0);
2715 key_ = HexToString(key_);
2737 Status st = db_->Put(WriteOptions(), GetCfHandle(), key_, value_); in DoCommand()
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 752 explicit TestPropertyKeyIs(const std::string& key) : key_(key) {} in TestPropertyKeyIs()
756 return test_property.key() == key_; in operator ()()
760 std::string key_; member in testing::internal::TestPropertyKeyIs
|
| D | gtest.h | 3423 : key_(CreateKey()), default_factory_(new DefaultValueHolderFactory()) {}
3425 : key_(CreateKey()),
3430 DeleteThreadLocalValue(pthread_getspecific(key_));
3434 GTEST_CHECK_POSIX_SUCCESS_(pthread_key_delete(key_));
3467 static_cast<ThreadLocalValueHolderBase*>(pthread_getspecific(key_));
3474 GTEST_CHECK_POSIX_SUCCESS_(pthread_setspecific(key_, holder_base));
3511 const pthread_key_t key_;
20293 key_(a_key), value_(a_value) {
20298 return key_.c_str();
20313 std::string key_;
|