Home
last modified time | relevance | path

Searched refs:val (Results 1 – 25 of 69) sorted by relevance

123

/rocksdb-6.9/utilities/persistent_cache/
Dhash_table_test.cc28 : key_(key), val_(val) {} in Node()
59 : key_(key), val_(val) {} in Node()
93 Node val; in TEST_F() local
95 assert(map_.Find(Node(k), &val, &rlock)); in TEST_F()
97 assert(val.val_ == std::string(1000, k % 255)); in TEST_F()
122 Node val; in TEST_F() local
124 bool status = map_.Find(Node(k), &val, &rlock); in TEST_F()
145 Node* val = map_.Evict(); in TEST_F() local
148 assert(val); in TEST_F()
149 assert(val->val_ == std::string(1000, val->key_ % 255)); in TEST_F()
[all …]
Dhash_table_bench.cc46 virtual bool Insert(const Key& key, const Value& val) = 0;
48 virtual bool Lookup(const Key& key, Value* val) = 0;
192 bool Insert(const size_t& key, const string& val) override { in Insert() argument
194 map_.insert(make_pair(key, val)); in Insert()
208 bool Lookup(const size_t& key, string* val) override { in Lookup() argument
212 *val = it->second; in Lookup()
228 bool Insert(const size_t& key, const string& val) override { in Insert() argument
229 Node n(key, val); in Insert()
238 bool Lookup(const size_t& key, string* val) override { in Lookup() argument
244 *val = n.val_; in Lookup()
[all …]
Dblock_cache_tier_file.cc84 CacheRecord(const Slice& key, const Slice& val) in CacheRecord()
86 static_cast<uint32_t>(val.size())), in CacheRecord()
88 val_(val) { in CacheRecord()
96 static uint32_t CalcSize(const Slice& key, const Slice& val) { in CalcSize()
98 val.size()); in CalcSize()
227 bool RandomAccessCacheFile::Read(const LBA& lba, Slice* key, Slice* val, in Read() argument
247 return ParseRec(lba, key, val, scratch); in Read()
250 bool RandomAccessCacheFile::ParseRec(const LBA& lba, Slice* key, Slice* val, in ParseRec() argument
263 *val = Slice(rec.val_); in ParseRec()
326 uint32_t rec_size = CacheRecord::CalcSize(key, val); in Append()
[all …]
Dpersistent_cache_bench.cc224 void ReadKey(const uint64_t val) { in ReadKey() argument
227 Slice key = FillKey(k, val); in ReadKey()
247 auto expected_block = NewBlock(val); in ReadKey()
253 std::unique_ptr<char[]> NewBlock(const uint64_t val) { in NewBlock() argument
255 memset(data.get(), val % 255, FLAGS_iosize); in NewBlock()
275 Slice FillKey(uint64_t (&k)[3], const uint64_t val) { in FillKey() argument
277 k[2] = val; in FillKey()
Dpersistent_cache_test.cc28 int* val = static_cast<int*>(arg); in OnOpenForRead() local
29 *val &= ~O_DIRECT; in OnOpenForRead()
36 int* val = static_cast<int*>(arg); in OnOpenForWrite() local
37 *val &= ~O_DIRECT; in OnOpenForWrite()
/rocksdb-6.9/utilities/blob_db/
Dblob_log_writer.cc79 Status Writer::AddRecord(const Slice& key, const Slice& val, in AddRecord() argument
86 ConstructBlobHeader(&buf, key, val, expiration); in AddRecord()
88 Status s = EmitPhysicalRecord(buf, key, val, key_offset, blob_offset); in AddRecord()
92 Status Writer::AddRecord(const Slice& key, const Slice& val, in AddRecord() argument
98 ConstructBlobHeader(&buf, key, val, 0); in AddRecord()
100 Status s = EmitPhysicalRecord(buf, key, val, key_offset, blob_offset); in AddRecord()
108 record.value = val; in ConstructBlobHeader()
114 const Slice& key, const Slice& val, in EmitPhysicalRecord() argument
122 s = dest_->Append(val); in EmitPhysicalRecord()
130 block_offset_ = *blob_offset + val.size(); in EmitPhysicalRecord()
[all …]
Dblob_log_writer.h49 const Slice& val, uint64_t expiration);
51 Status AddRecord(const Slice& key, const Slice& val, uint64_t* key_offset,
54 Status AddRecord(const Slice& key, const Slice& val, uint64_t expiration,
58 const Slice& val, uint64_t* key_offset,
/rocksdb-6.9/db/
Dfault_injection_test.cc210 std::string val; in Verify() local
215 s = ReadValue(i, &val); in Verify()
419 std::string val; in TEST_P() local
421 ASSERT_OK(ReadValue(2, &val)); in TEST_P()
422 ASSERT_EQ(value_space, val); in TEST_P()
426 ASSERT_EQ(value_space, val); in TEST_P()
504 std::string val; in TEST_P() local
507 ASSERT_EQ(value_space, val); in TEST_P()
511 ASSERT_EQ(value_space, val); in TEST_P()
532 std::string val; in TEST_P() local
[all …]
Dc_test.c120 char* val; in CheckGet() local
124 Free(&val); in CheckGet()
135 char* val; in CheckGetCF() local
139 Free(&val); in CheckGetCF()
146 const char* val; in CheckPinGet() local
160 const char* val; in CheckPinGetCF() local
378 char* val; in CheckTxnGet() local
391 char* val; in CheckTxnGetCF() local
396 Free(&val); in CheckTxnGetCF()
419 char* val; in CheckTxnDBGetCF() local
[all …]
Drange_del_aggregator_bench.cc155 static std::string Key(int64_t val) { in Key() argument
158 PutFixed64(&little_endian_key, val); in Key()
159 assert(little_endian_key.size() == sizeof(val)); in Key()
160 big_endian_key.resize(sizeof(val)); in Key()
161 for (size_t i = 0; i < sizeof(val); ++i) { in Key()
162 big_endian_key[i] = little_endian_key[sizeof(val) - 1 - i]; in Key()
Dc.cc815 const char* val, size_t vallen, in rocksdb_put() argument
826 const char* val, size_t vallen, in rocksdb_put_cf() argument
866 const char* val, size_t vallen, in rocksdb_merge() argument
877 const char* val, size_t vallen, in rocksdb_merge_cf() argument
1362 const char* val, size_t vlen) { in rocksdb_writebatch_put() argument
1370 const char* val, size_t vlen) { in rocksdb_writebatch_put_cf() argument
1414 const char* val, size_t vlen) { in rocksdb_writebatch_merge() argument
1422 const char* val, size_t vlen) { in rocksdb_writebatch_merge_cf() argument
1619 const char* val, size_t vlen) { in rocksdb_writebatch_wi_put() argument
1627 const char* val, size_t vlen) { in rocksdb_writebatch_wi_put_cf() argument
[all …]
Dtable_properties_collector.cc25 uint64_t val = 0; in GetUint64Property() local
27 return GetVarint64(&raw, &val) ? val : 0; in GetUint64Property()
Ddb_compaction_filter_test.cc785 std::string val; in TEST_F() local
786 Status s = db_->Get(ReadOptions(), key, &val); in TEST_F()
791 ASSERT_EQ(expected, val); in TEST_F()
820 std::string val; in TEST_F() local
822 s = db_->Get(ReadOptions(), "0000000010", &val); in TEST_F()
824 EXPECT_EQ("v10", val); in TEST_F()
826 s = db_->Get(ReadOptions(), "0000000020", &val); in TEST_F()
829 s = db_->Get(ReadOptions(), "0000000050", &val); in TEST_F()
831 EXPECT_EQ("v50", val); in TEST_F()
/rocksdb-6.9/logging/
Devent_logger.h105 JSONWriter& operator<<(const char* val) {
107 AddKey(val);
109 AddValue(val);
114 JSONWriter& operator<<(const std::string& val) {
115 return *this << val.c_str();
119 JSONWriter& operator<<(const T& val) {
121 AddValue(val);
141 EventLoggerStream& operator<<(const T& val) {
143 *json_writer_ << val;
/rocksdb-6.9/util/
Dheap_test.cc66 HeapTestValue val = value_dist(rng); in TEST_P() local
67 heap.push(val); in TEST_P()
68 ref.push(val); in TEST_P()
76 HeapTestValue val = value_dist(rng); in TEST_P() local
77 heap.replace_top(val); in TEST_P()
79 ref.push(val); in TEST_P()
Dxxhash.cc212 xxh_u32 val; in XXH_read32() local
213 memcpy(&val, memPtr, sizeof(val)); in XXH_read32()
214 return val; in XXH_read32()
723 xxh_u64 val; in XXH_read64() local
724 memcpy(&val, memPtr, sizeof(val)); in XXH_read64()
725 return val; in XXH_read64()
784 static xxh_u64 XXH64_mergeRound(xxh_u64 acc, xxh_u64 val) in XXH64_mergeRound() argument
786 val = XXH64_round(0, val); in XXH64_mergeRound()
787 acc ^= val; in XXH64_mergeRound()
Dgflags_compat.h17 #define DEFINE_uint32(name, val, txt) \ argument
18 DEFINE_VARIABLE(GFLAGS_NAMESPACE::uint32, U, name, val, txt)
Ddynamic_bloom.h186 uint64_t val = data_[byte_offset ^ i].load(std::memory_order_relaxed); in DoubleProbe() local
188 return (val & mask) == mask; in DoubleProbe()
189 } else if ((val & mask) != mask) { in DoubleProbe()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_common.h364 extern inline std::string GetStringFromInt(int64_t val) { in GetStringFromInt() argument
367 PutFixed64(&little_endian_key, val); in GetStringFromInt()
368 assert(little_endian_key.size() == sizeof(val)); in GetStringFromInt()
369 big_endian_key.resize(sizeof(val)); in GetStringFromInt()
370 for (size_t i = 0; i < sizeof(val); ++i) { in GetStringFromInt()
371 big_endian_key[i] = little_endian_key[sizeof(val) - 1 - i]; in GetStringFromInt()
395 extern inline std::string Key(int64_t val) { in Key() argument
402 uint64_t offset = static_cast<uint64_t>(val) % window; in Key()
403 uint64_t mult = static_cast<uint64_t>(val) / window; in Key()
417 val = offset - weight; in Key()
Ddb_stress_tool.cc217 uint64_t val = std::stoull(weight); in db_stress_tool() local
218 key_gen_ctx.weights.emplace_back(val * scale_factor); in db_stress_tool()
219 total_weight += val; in db_stress_tool()
/rocksdb-6.9/include/rocksdb/
Dc.h254 size_t keylen, const char* val, size_t vallen, char** errptr);
259 size_t keylen, const char* val, size_t vallen, char** errptr);
468 const char* key, size_t klen, const char* val, size_t vlen);
485 const char* key, size_t klen, const char* val, size_t vlen);
556 const char* key, size_t klen, const char* val, size_t vlen);
573 const char* key, size_t klen, const char* val, size_t vlen);
863 rocksdb_options_t* opt, unsigned char val);
1372 const char* val, size_t vallen, char** errptr);
1375 const char* val, size_t vallen, char** errptr);
1378 const char* val, size_t vallen, char** errptr);
[all …]
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc143 Status DBWithTTLImpl::AppendTS(const Slice& val, std::string* val_with_ts, in AppendTS() argument
145 val_with_ts->reserve(kTSLength + val.size()); in AppendTS()
153 val_with_ts->append(val.data(), val.size()); in AppendTS()
211 const Slice& val) { in Put() argument
213 batch.Put(column_family, key, val); in Put()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim_test.py107 val = cache.table.lookup("b{}".format(expeceted_k), expeceted_k)
109 val = cache.table["b{}".format(expeceted_k)]
110 assert val is not None, "Expected {} Actual: Not Exist {}, Table: {}".format(
113 assert val.value_size == expected_value_size
116 val = cache.table.lookup("g0-{}".format(expeceted_k), expeceted_k)
118 val = cache.table["g0-{}".format(expeceted_k)]
119 assert val is not None
120 assert val.value_size == expected_value_size
/rocksdb-6.9/table/
Dmeta_blocks.cc50 const std::string& val) { in Add() argument
51 props_.insert({name, val}); in Add()
54 void PropertyBlockBuilder::Add(const std::string& name, uint64_t val) { in Add() argument
58 PutVarint64(&dst, val); in Add()
304 uint64_t val; in ReadProperties() local
305 if (!GetVarint64(&raw_val, &val)) { in ReadProperties()
313 *(pos->second) = val; in ReadProperties()
/rocksdb-6.9/utilities/cassandra/
Dcassandra_functional_test.cc33 bool Append(const std::string& key, const RowValue& val){ in Append() argument
35 val.Serialize(&result); in Append()
47 bool Put(const std::string& key, const RowValue& val) { in Put() argument
49 val.Serialize(&result); in Put()

123