Home
last modified time | relevance | path

Searched refs:tp (Results 1 – 16 of 16) sorted by relevance

/rocksdb-6.9/table/
Dtable_properties.cc175 data_size += tp.data_size; in Add()
176 index_size += tp.index_size; in Add()
177 index_partitions += tp.index_partitions; in Add()
181 filter_size += tp.filter_size; in Add()
182 raw_key_size += tp.raw_key_size; in Add()
183 raw_value_size += tp.raw_value_size; in Add()
184 num_data_blocks += tp.num_data_blocks; in Add()
185 num_entries += tp.num_entries; in Add()
186 num_deletions += tp.num_deletions; in Add()
187 num_merge_operands += tp.num_merge_operands; in Add()
[all …]
/rocksdb-6.9/db/
Ddb_properties_test.cc166 tp->data_size = 0; in ResetTableProperties()
167 tp->index_size = 0; in ResetTableProperties()
168 tp->filter_size = 0; in ResetTableProperties()
169 tp->raw_key_size = 0; in ResetTableProperties()
172 tp->num_entries = 0; in ResetTableProperties()
173 tp->num_deletions = 0; in ResetTableProperties()
192 &tp->num_data_blocks, &tp->num_entries, &tp->num_deletions, in ParseTablePropertiesString()
193 &tp->num_merge_operands, &tp->num_range_deletions, &tp->raw_key_size, in ParseTablePropertiesString()
194 &dummy_double, &tp->raw_value_size, &dummy_double, &tp->data_size, in ParseTablePropertiesString()
195 &tp->index_key_is_user_key, &tp->index_value_is_delta_encoded, in ParseTablePropertiesString()
[all …]
Dbuilder.cc109 TableProperties tp; in BuildTable() local
129 job_id, meta->fd, kInvalidBlobFileNumber, tp, reason, s); in BuildTable()
186 tp = builder->GetTableProperties(); in BuildTable()
187 bool empty = builder->NumEntries() == 0 && tp.num_range_deletions == 0; in BuildTable()
202 tp = builder->GetTableProperties(); // refresh now that builder is finished in BuildTable()
204 *table_properties = tp; in BuildTable()
269 job_id, meta->fd, meta->oldest_blob_file_number, tp, reason, s); in BuildTable()
Dplain_table_db_test.cc515 auto tp = row->second; in TEST_P() local
534 (tp->user_collected_properties) in TEST_P()
536 ASSERT_EQ("0", (tp->user_collected_properties) in TEST_P()
539 ASSERT_EQ("0", (tp->user_collected_properties) in TEST_P()
541 ASSERT_EQ("0", (tp->user_collected_properties) in TEST_P()
Dinternal_stats.cc625 std::shared_ptr<const TableProperties> tp; in HandleAggregatedTableProperties() local
626 auto s = cfd_->current()->GetAggregatedTableProperties(&tp); in HandleAggregatedTableProperties()
630 *value = tp->ToString(); in HandleAggregatedTableProperties()
641 std::shared_ptr<const TableProperties> tp; in HandleAggregatedTablePropertiesAtLevel() local
643 &tp, static_cast<int>(level)); in HandleAggregatedTablePropertiesAtLevel()
647 *value = tp->ToString(); in HandleAggregatedTablePropertiesAtLevel()
Dlistener_test.cc142 auto tp = it->second; in OnCompactionCompleted() local
143 ASSERT_TRUE(tp != nullptr); in OnCompactionCompleted()
144 ASSERT_EQ(tp->user_collected_properties.find("0")->second, "1"); in OnCompactionCompleted()
Dversion_set.cc1212 file_options_, cfd_->internal_comparator(), file_meta->fd, tp, in GetTableProperties()
1258 *tp = std::shared_ptr<const TableProperties>(raw_table_properties); in GetTableProperties()
1381 std::shared_ptr<const TableProperties>* tp, int level) { in GetAggregatedTableProperties() argument
1397 tp->reset(new_tp); in GetAggregatedTableProperties()
2092 std::shared_ptr<const TableProperties> tp; in MaybeInitializeFileMetaData() local
2093 Status s = GetTableProperties(&tp, file_meta); in MaybeInitializeFileMetaData()
2102 if (tp.get() == nullptr) return false; in MaybeInitializeFileMetaData()
2103 file_meta->num_entries = tp->num_entries; in MaybeInitializeFileMetaData()
2104 file_meta->num_deletions = tp->num_deletions; in MaybeInitializeFileMetaData()
2105 file_meta->raw_value_size = tp->raw_value_size; in MaybeInitializeFileMetaData()
[all …]
Dversion_set.h644 Status GetTableProperties(std::shared_ptr<const TableProperties>* tp,
666 std::shared_ptr<const TableProperties>* tp, int level = -1);
/rocksdb-6.9/util/
Dthreadpool_imp.cc281 ThreadPoolImpl::Impl* tp = meta->thread_pool_; in BGThreadWrapper() local
286 switch (tp->GetThreadPriority()) { in BGThreadWrapper()
304 ThreadStatusUtil::RegisterThread(tp->GetHostEnv(), thread_type); in BGThreadWrapper()
307 tp->BGThread(thread_id); in BGThreadWrapper()
Dtimer_queue.h76 Clock::time_point tp = Clock::now(); in add() local
77 item.end = tp + std::chrono::milliseconds(milliseconds); in add()
/rocksdb-6.9/java/rocksjni/
Dsst_file_readerjni.cc110 std::shared_ptr<const ROCKSDB_NAMESPACE::TableProperties> tp = in Java_org_rocksdb_SstFileReader_getTableProperties() local
114 env, *(tp.get())); in Java_org_rocksdb_SstFileReader_getTableProperties()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc690 TablePropertiesCollection tp; in Run() local
696 tp[fn] = output.table_properties; in Run()
699 compact_->compaction->SetOutputTableProperties(std::move(tp)); in Run()
1338 TableProperties tp; in FinishCompactionOutputFile() local
1340 tp = sub_compact->builder->GetTableProperties(); in FinishCompactionOutputFile()
1343 if (s.ok() && current_entries == 0 && tp.num_range_deletions == 0) { in FinishCompactionOutputFile()
1359 if (s.ok() && (current_entries > 0 || tp.num_range_deletions > 0)) { in FinishCompactionOutputFile()
1362 std::make_shared<TableProperties>(tp); in FinishCompactionOutputFile()
1384 job_id_, output_fd, oldest_blob_file_number, tp, in FinishCompactionOutputFile()
Dcompaction.h274 void SetOutputTableProperties(TablePropertiesCollection tp) { in SetOutputTableProperties() argument
275 output_table_properties_ = std::move(tp); in SetOutputTableProperties()
/rocksdb-6.9/include/rocksdb/
Dtable_properties.h235 void Add(const TableProperties& tp);
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1187 std::shared_ptr<const TableProperties> tp; in NotifyOnCompactionBegin() local
1188 auto s = current->GetTableProperties(&tp, fmd, &fn); in NotifyOnCompactionBegin()
1190 info.table_properties[fn] = tp; in NotifyOnCompactionBegin()
3066 std::shared_ptr<const TableProperties> tp; in BuildCompactionJobInfo() local
3067 auto s = current->GetTableProperties(&tp, fmd, &fn); in BuildCompactionJobInfo()
3069 compaction_job_info->table_properties[fn] = tp; in BuildCompactionJobInfo()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc1930 std::chrono::steady_clock::time_point *tp = in TEST_F() local
1932 *tp = in TEST_F()