| /rocksdb-6.9/trace_replay/ |
| D | trace_replay.cc | 24 PutFixed32(dst, cf_id); in EncodeCFAndKey()
30 GetFixed32(&buf, cf_id); in DecodeCFAndKey()
230 if (cf_id > 0 && cf_map_.find(cf_id) == cf_map_.end()) { in Replay()
245 if (cf_id > 0 && cf_map_.find(cf_id) == cf_map_.end()) { in Replay()
262 if (cf_id > 0 && cf_map_.find(cf_id) == cf_map_.end()) { in Replay()
415 if (cf_id > 0 && cf_map->find(cf_id) == cf_map->end()) { in BGWorkGet()
420 if (cf_id == 0) { in BGWorkGet()
445 if (cf_id > 0 && cf_map->find(cf_id) == cf_map->end()) { in BGWorkIterSeek()
451 if (cf_id == 0) { in BGWorkIterSeek()
469 if (cf_id > 0 && cf_map->find(cf_id) == cf_map->end()) { in BGWorkIterSeekForPrev()
[all …]
|
| D | trace_replay.h | 94 Status IteratorSeek(const uint32_t& cf_id, const Slice& key);
95 Status IteratorSeekForPrev(const uint32_t& cf_id, const Slice& key);
|
| D | block_cache_tracer_test.cc | 67 record.cf_id = kCFId; in WriteBlockAccess()
97 record.cf_id = kCFId; in GenerateAccessRecord()
120 ASSERT_EQ(kCFId, record.cf_id); in VerifyAccess()
351 ASSERT_EQ(kCFId, read_record.cf_id); in TEST_F()
|
| D | block_cache_tracer.cc | 123 PutFixed64(&trace.payload, record.cf_id); in WriteBlockAccess()
230 if (!GetFixed64(&enc_slice, &record->cf_id)) { in ReadAccess()
337 access.cf_id, access.cf_name.c_str(), access.level, access.sst_fd_number, in WriteHumanReadableTraceRecord()
389 record->cf_id = ParseUint64(record_strs[4]); in ReadAccess()
|
| D | block_cache_tracer.h | 112 uint64_t cf_id = 0; member
144 cf_id(_cf_id), in access_timestamp()
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.cc | 196 GetFixed32(&buf, cf_id); in DecodeCFAndKeyFromString()
255 cf_id = 0; in TraceStats()
485 uint32_t cf_id = 0; in StartProcessing() local
497 uint32_t cf_id = 0; in StartProcessing() local
1059 cf_id); in ReProcessing()
1187 unit.cf_id = cf_id; in KeyStatsInsertion()
1220 ta_[type].stats[cf_id].cf_id = cf_id; in KeyStatsInsertion()
1221 ta_[type].stats[cf_id].cf_name = std::to_string(cf_id); in KeyStatsInsertion()
1308 cf_unit.cf_id = cf_id; in KeyStatsInsertion()
1311 cfs_[cf_id] = cf_unit; in KeyStatsInsertion()
[all …]
|
| D | trace_analyzer_tool.h | 41 uint32_t cf_id; member
56 uint32_t cf_id; member
81 uint32_t cf_id; member
157 uint32_t cf_id; member
231 Status KeyStatsInsertion(const uint32_t& type, const uint32_t& cf_id,
246 Status WriteTraceSequence(const uint32_t& type, const uint32_t& cf_id,
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_pysim_test.py | 134 cf_id=0,
158 cf_id=0,
182 cf_id=0,
206 cf_id=0,
313 cf_id=0,
364 cf_id = random.randint(0, ncfs)
373 access_record += "{},".format(cf_id)
374 access_record += "cf_{},".format(cf_id)
440 cf_id=0,
547 cf_id=0,
[all …]
|
| D | block_cache_pysim.py | 34 cf_id, argument
57 self.cf_id = cf_id
92 cf_id, argument
103 self.cf_id = 0
116 self.cf_id,
923 cf_id=value.cf_id,
977 trace_record.cf_id,
1081 x_i[2] = trace_record.cf_id
1439 trace_record.cf_id,
1488 trace_record.cf_id,
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_flush_test.cc | 542 int cf_id = static_cast<int>(i); in TEST_P() local
543 ASSERT_OK(Put(cf_id, "key", "value", wopts)); in TEST_P()
582 int cf_id = static_cast<int>(i); in TEST_P() local
583 ASSERT_OK(Put(cf_id, "key", "value", wopts)); in TEST_P()
584 cf_ids.push_back(cf_id); in TEST_P()
617 int cf_id = static_cast<int>(i); in TEST_P() local
618 ASSERT_OK(Put(cf_id, "key", "value", wopts)); in TEST_P()
630 int cf_id = static_cast<int>(i); in TEST_P() local
631 ASSERT_EQ("value", Get(cf_id, "key")); in TEST_P()
638 int cf_id = static_cast<int>(i); in TEST_P() local
[all …]
|
| D | version_set_test.cc | 699 uint32_t cf_id = 1; in PrepareManifest() local
703 new_cf.SetColumnFamily(cf_id++); in PrepareManifest()
818 EXPECT_EQ(0u, *cf_id); in TEST_F()
1522 uint32_t cf_id = 1; in TEST_P() local
1527 new_cf.SetColumnFamily(cf_id++); in TEST_P()
1568 uint32_t cf_id = 1; in TEST_P() local
1573 new_cf.SetColumnFamily(cf_id++); in TEST_P()
1625 uint32_t cf_id = 1; in TEST_P() local
1630 new_cf.SetColumnFamily(cf_id++); in TEST_P()
1761 new_cf.SetColumnFamily(cf_id); in PrepareManifest()
[all …]
|
| D | external_sst_file_ingestion_job.cc | 45 if (f.cf_id != in Prepare()
47 f.cf_id != cfd_->GetID()) { in Prepare()
519 file_to_ingest->cf_id = static_cast<uint32_t>(props->column_family_id); in GetIngestedFileInfo()
|
| D | repair.cc | 141 Status AddColumnFamily(const std::string& cf_name, uint32_t cf_id) { in AddColumnFamily() argument
145 cf_name + ", id=" + ToString(cf_id)); in AddColumnFamily()
153 edit.SetColumnFamily(cf_id); in AddColumnFamily()
|
| D | external_sst_file_ingestion_job.h | 45 uint32_t cf_id; member
|
| D | flush_job_test.cc | 78 uint32_t cf_id = 1; in NewDB() local
82 new_cf.SetColumnFamily(cf_id++); in NewDB()
|
| D | memtable_list_test.cc | 808 uint32_t cf_id = 0; in TEST_F() local
815 kMaxSequenceNumber, cf_id); in TEST_F()
829 cf_ids.push_back(cf_id++); in TEST_F()
|
| D | import_column_family_job.cc | 267 file_to_import->cf_id = static_cast<uint32_t>(props->column_family_id); in GetIngestedFileInfo()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.cc | 144 uint32_t cf_id = key_map_iter.first; in CheckKeysForConflicts() local
147 SuperVersion* sv = db_impl->GetAndRefSuperVersion(cf_id); in CheckKeysForConflicts()
150 ToString(cf_id)); in CheckKeysForConflicts()
170 db_impl->ReturnAndCleanupSuperVersion(cf_id, sv); in CheckKeysForConflicts()
|
| D | transaction_lock_mgr.h | 149 const std::string& key, const uint32_t& cf_id,
|
| D | transaction_lock_mgr.cc | 440 const uint32_t& cf_id, const bool& exclusive, Env* const env) { in IncrementWaiters() argument
447 wait_txn_map_.Insert(id, {wait_ids, cf_id, exclusive, key}); in IncrementWaiters()
|
| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 228 uint32_t cf_id; in Open() local
233 cf_id = r->cfh->GetID(); in Open()
237 cf_id = TablePropertiesCollectorFactory::Context::kUnknownColumnFamily; in Open()
253 table_builder_options, cf_id, r->file_writer.get())); in Open()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.cc | 159 uint32_t cf_id = GetColumnFamilyID(column_family); in GetFromBatch() local
173 if (cmp->CompareKey(cf_id, entry.key, key) != 0) { in GetFromBatch()
194 if (cmp->CompareKey(cf_id, entry.key, key) != 0) { in GetFromBatch()
|
| D | write_batch_with_index.cc | 487 uint32_t cf_id = GetColumnFamilyID(column_family); in UpdateExistingEntry() local
488 return UpdateExistingEntryWithCfId(cf_id, key); in UpdateExistingEntry()
518 uint32_t cf_id = GetColumnFamilyID(column_family); in AddOrUpdateIndex() local
521 comparator.SetComparatorForCF(cf_id, cf_cmp); in AddOrUpdateIndex()
523 AddNewEntry(cf_id); in AddOrUpdateIndex()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | listener.h | 168 uint32_t cf_id; member
214 uint32_t cf_id; member
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | cache_simulator_test.cc | 38 record.cf_id = 0; in GenerateGetRecord()
60 record.cf_id = 0; in GenerateCompactionRecord()
|