Home
last modified time | relevance | path

Searched refs:cf_name (Results 1 – 25 of 66) sorted by relevance

123

/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc38 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickTTLCompaction() argument
52 cf_name.c_str(), status.ToString().c_str()); in PickTTLCompaction()
62 cf_name.c_str()); in PickTTLCompaction()
98 cf_name.c_str(), f->fd.GetNumber(), in PickTTLCompaction()
111 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickSizeCompaction() argument
157 cf_name.c_str(), total_size, in PickSizeCompaction()
167 cf_name.c_str()); in PickSizeCompaction()
184 cf_name.c_str(), f->fd.GetNumber(), tmp_fsize); in PickSizeCompaction()
200 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickCompaction() argument
217 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in CompactRange() argument
[all …]
Dcompaction_picker_fifo.h23 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
28 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
42 Compaction* PickTTLCompaction(const std::string& cf_name,
47 Compaction* PickSizeCompaction(const std::string& cf_name,
Dcompaction_picker.h58 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
74 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
168 bool ExpandInputsToCleanCut(const std::string& cf_name,
183 bool SetupOtherInputs(const std::string& cf_name,
195 void PickFilesMarkedForCompaction(const std::string& cf_name,
Dcompaction_picker.cc442 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in SetupOtherInputs() argument
475 if (!ExpandInputsToCleanCut(cf_name, vstorage, output_level_inputs)) { in SetupOtherInputs()
502 if (!ExpandInputsToCleanCut(cf_name, vstorage, &expanded_inputs)) { in SetupOtherInputs()
517 ExpandInputsToCleanCut(cf_name, vstorage, in SetupOtherInputs()
539 cf_name.c_str(), input_level, inputs->size(), in SetupOtherInputs()
565 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in CompactRange() argument
724 if (ExpandInputsToCleanCut(cf_name, vstorage, &inputs, &next_smallest) == in CompactRange()
748 if (!SetupOtherInputs(cf_name, mutable_cf_options, vstorage, &inputs, in CompactRange()
1060 const std::string& cf_name, VersionStorageInfo* vstorage, int* start_level, in PickFilesMarkedForCompaction() argument
1066 auto continuation = [&, cf_name](std::pair<int, FileMetaData*> level_file) { in PickFilesMarkedForCompaction()
[all …]
Dcompaction_picker_level.cc46 LevelCompactionBuilder(const std::string& cf_name, in LevelCompactionBuilder() argument
53 : cf_name_(cf_name), in LevelCompactionBuilder()
551 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickCompaction() argument
554 LevelCompactionBuilder builder(cf_name, vstorage, earliest_mem_seqno, this, in PickCompaction()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h27 assert(IsValidColumnFamilyName(info.cf_name)); in OnFlushCompleted()
47 assert(IsValidColumnFamilyName(ci.cf_name)); in OnCompactionCompleted()
66 assert(IsValidColumnFamilyName(info.cf_name)); in OnTableFileCreated()
145 bool IsValidColumnFamilyName(const std::string& cf_name) const { in IsValidColumnFamilyName() argument
146 if (cf_name == kDefaultColumnFamilyName) { in IsValidColumnFamilyName()
150 for (size_t i = 0; i < cf_name.size(); ++i) { in IsValidColumnFamilyName()
151 if (cf_name[i] < '0' || cf_name[i] > '9') { in IsValidColumnFamilyName()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer.cc568 labels, cf_name, fd, level, type, in WriteSkewness()
738 label_value_map[kGroupbyColumnFamily] = cf_name; in BuildLabel()
960 labels, cf_name, fd, level, type, in WriteReuseDistance()
1107 labels, cf_name, fd, level, type, in WriteReuseInterval()
1157 labels, cf_name, fd, level, type, in WriteReuseLifetime()
1305 for (auto const& cf_name : cf_aggregates_map_) { in WritePercentAccessSummaryStats() local
1307 header += cf_name.first; in WritePercentAccessSummaryStats()
1351 header += cf_name.first; in WriteDetailedPercentAccessSummaryStats()
1374 header += cf_name.first; in WriteDetailedPercentAccessSummaryStats()
1662 cf_bt_stats_map[cf_name][type].Add(naccesses); in PrintAccessCountStats()
[all …]
Dblock_cache_pysim.sh37 for cf_name in "all"
54 output="log-ml-$cache_type-$cache_size-$cf_name"
55 …echo "Running simulation for $cache_type, cache size $cache_size, and cf_name $cf_name. Number of …
56 …warmup_seconds" "$trace_file" "$ml_tmp_result_dir" "$max_num_accesses" "$cf_name" >& "$ml_tmp_resu…
Dblock_cache_pysim_test.py135 cf_name="",
159 cf_name="",
183 cf_name="",
207 cf_name="",
314 cf_name="",
441 cf_name="",
548 cf_name="",
653 cf_name="",
/rocksdb-6.9/db/
Devent_helpers.cc27 const std::string& db_name, const std::string& cf_name, in NotifyTableFileCreationStarted() argument
31 info.cf_name = cf_name; in NotifyTableFileCreationStarted()
71 const std::string& db_name, const std::string& cf_name, in LogAndNotifyTableFileCreationFinished() argument
78 jwriter << "cf_name" << cf_name << "job" << job_id << "event" in LogAndNotifyTableFileCreationFinished()
148 info.cf_name = cf_name; in LogAndNotifyTableFileCreationFinished()
161 (void)cf_name; in LogAndNotifyTableFileCreationFinished()
Dversion_set_test.cc733 for (const auto& cf_name : cf_names) { in PrepareManifest() local
1280 auto cfd = (cf_name != cf_to_drop_name) in TEST_P()
1455 for (const auto& cf_name : cf_names) { in TEST_P() local
1497 for (const auto& cf_name : cf_names) { in TEST_P() local
1543 for (const auto& cf_name : cf_names) { in TEST_P() local
1600 for (const auto& cf_name : cf_names) { in TEST_P() local
1656 for (const auto& cf_name : cf_names) { in TEST_P() local
1754 for (const auto& cf_name : cf_names) { in PrepareManifest() local
1756 if (cf_name == kDefaultColumnFamilyName) { in PrepareManifest()
1760 new_cf.AddColumnFamily(cf_name); in PrepareManifest()
[all …]
Drepair.cc129 const std::string& cf_name) { in GetColumnFamilyOptions() argument
130 if (cf_name_to_opts_.find(cf_name) == cf_name_to_opts_.end()) { in GetColumnFamilyOptions()
136 return &cf_name_to_opts_[cf_name]; in GetColumnFamilyOptions()
141 Status AddColumnFamily(const std::string& cf_name, uint32_t cf_id) { in AddColumnFamily() argument
142 const auto* cf_opts = GetColumnFamilyOptions(cf_name); in AddColumnFamily()
145 cf_name + ", id=" + ToString(cf_id)); in AddColumnFamily()
156 edit.AddColumnFamily(cf_name); in AddColumnFamily()
/rocksdb-6.9/include/rocksdb/
Dlistener.h40 std::string cf_name; member
130 std::string cf_name; member
170 std::string cf_name; member
216 std::string cf_name; member
263 std::string cf_name; member
280 std::string cf_name; member
/rocksdb-6.9/examples/
Dmulti_processes_example.cc161 for (const auto& cf_name : GetColumnFamilyNames()) { in CreateDB() local
162 if (ROCKSDB_NAMESPACE::kDefaultColumnFamilyName != cf_name) { in CreateDB()
164 s = db->CreateColumnFamily(cf_opts, cf_name, &handle); in CreateDB()
167 cf_name.c_str(), s.ToString().c_str()); in CreateDB()
190 for (const auto& cf_name : GetColumnFamilyNames()) { in RunPrimary() local
191 column_families.push_back(ColumnFamilyDescriptor(cf_name, options)); in RunPrimary()
345 for (const auto& cf_name : GetColumnFamilyNames()) { in RunSecondary() local
346 column_families.push_back(ColumnFamilyDescriptor(cf_name, options)); in RunSecondary()
Dcompact_files_example.cc29 DB* db, const std::string& cf_name) = 0;
75 CompactionTask* task = PickCompaction(db, info.cf_name); in OnFlushCompleted()
87 DB* db, const std::string& cf_name) override { in PickCompaction() argument
101 db, this, cf_name, input_file_names, in PickCompaction()
/rocksdb-6.9/trace_replay/
Dblock_cache_tracer.cc113 const Slice& cf_name, const Slice& referenced_key) { in WriteBlockAccess() argument
124 PutLengthPrefixedSlice(&trace.payload, cf_name); in WriteBlockAccess()
234 Slice cf_name; in ReadAccess() local
235 if (!GetLengthPrefixedSlice(&enc_slice, &cf_name)) { in ReadAccess()
239 record->cf_name = cf_name.ToString(); in ReadAccess()
337 access.cf_id, access.cf_name.c_str(), access.level, access.sst_fd_number, in WriteHumanReadableTraceRecord()
390 record->cf_name = record_strs[5]; in ReadAccess()
472 const Slice& cf_name, in WriteBlockAccess() argument
481 return writer_.load()->WriteBlockAccess(record, block_key, cf_name, in WriteBlockAccess()
Dblock_cache_tracer_test.cc68 record.cf_name = kDefaultColumnFamilyName; in WriteBlockAccess()
86 record, record.block_key, record.cf_name, record.referenced_key)); in WriteBlockAccess()
98 record.cf_name = kDefaultColumnFamilyName; in GenerateAccessRecord()
121 ASSERT_EQ(kDefaultColumnFamilyName, record.cf_name); in VerifyAccess()
167 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
191 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
230 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
235 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
352 ASSERT_EQ(kDefaultColumnFamilyName, read_record.cf_name); in TEST_F()
Dblock_cache_tracer.h113 std::string cf_name; member
145 cf_name(_cf_name), in access_timestamp()
186 const Slice& block_key, const Slice& cf_name,
280 const Slice& block_key, const Slice& cf_name,
/rocksdb-6.9/monitoring/
Dthread_status_updater.h56 db_key(_db_key), db_name(_db_name), cf_name(_cf_name) {} in ConstantColumnFamilyInfo()
59 const std::string cf_name; member
178 const void* cf_key, const std::string& cf_name);
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc344 const auto cf_name = cfh->GetName(); in ExportColumnFamily() local
363 cf_name.c_str(), export_dir.c_str()); in ExportColumnFamily()
385 cf_name.c_str(), fname.c_str()); in ExportColumnFamily()
391 cf_name.c_str(), fname.c_str()); in ExportColumnFamily()
443 cf_name.c_str()); in ExportColumnFamily()
447 cf_name.c_str(), s.ToString().c_str()); in ExportColumnFamily()
/rocksdb-6.9/util/
Dthread_list_test.cc21 const void* cf_key, const std::string& cf_name, in SimulatedBackgroundTask() argument
27 cf_key_(cf_key), cf_name_(cf_name), in SimulatedBackgroundTask()
151 if (thread_status.cf_name == "pikachu" && in TEST_F()
175 if (thread_status.cf_name == "pikachu" && in TEST_F()
/rocksdb-6.9/tools/advisor/test/input_files/
DLOG-110 2018/05/25-14:30:09.398302 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527283809398276, "cf_name": "…
15 2018/05/25-14:30:27.288181 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527283827288158, "cf_name": "…
20 2018/05/25-14:34:21.047206 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527284061047181, "cf_name": "…
DLOG-010 2018/05/25-14:30:09.398302 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527283809398276, "cf_name": "…
15 2018/05/25-14:30:27.288181 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527283827288158, "cf_name": "…
20 2018/05/25-14:34:21.047206 7f82ba72e700 EVENT_LOG_v1 {"time_micros": 1527284061047181, "cf_name": "…
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc256 cf_name = "0"; in TraceStats()
1221 ta_[type].stats[cf_id].cf_name = std::to_string(cf_id); in KeyStatsInsertion()
1380 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1384 s = CreateOutputFile(type, new_stats.cf_name, "whole_key_stats.txt", in OpenStatsOutputFiles()
1390 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1404 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1411 s = CreateOutputFile(type, new_stats.cf_name, "time_series.txt", in OpenStatsOutputFiles()
1416 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1422 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1428 s = CreateOutputFile(type, new_stats.cf_name, "qps_stats.txt", in OpenStatsOutputFiles()
[all …]
/rocksdb-6.9/java/rocksjni/
Dcolumnfamilyhandle.cc25 std::string cf_name = cfh->GetName(); in Java_org_rocksdb_ColumnFamilyHandle_getName() local
26 return ROCKSDB_NAMESPACE::JniUtil::copyBytes(env, cf_name); in Java_org_rocksdb_ColumnFamilyHandle_getName()

123