Home
last modified time | relevance | path

Searched refs:item (Results 1 – 13 of 13) sorted by relevance

/rocksdb-6.9/util/
Dtimer_queue.h75 WorkItem item; in add() local
79 item.period = milliseconds; in add()
84 item.id = id; in add()
85 m_items.push(std::move(item)); in add()
105 if (item.id == id && item.handler) { in cancel()
131 if (item.id && item.handler) { in cancelAll()
133 item.id = 0; in cancelAll()
188 WorkItem item(m_items.top()); in checkWork()
191 if (item.handler) { in checkWork()
193 auto reschedule_pair = item.handler(item.id == 0); in checkWork()
[all …]
Dautovector.h181 for (const T& item : init_list) {
182 push_back(item);
266 void push_back(T&& item) {
269 values_[num_stack_items_++] = std::move(item);
271 vect_.push_back(item);
275 void push_back(const T& item) {
278 values_[num_stack_items_++] = item;
280 vect_.push_back(item);
Dautovector_test.cc159 for (const auto& item : vec) { in TEST_F() local
160 ASSERT_EQ(vec[index++], item); in TEST_F()
171 for (const auto& item : cvec) { in TEST_F() local
172 ASSERT_EQ(cvec[index++], item); in TEST_F()
241 for (const auto& item : GetTestKeys(elem_size)) { in BenchmarkSequenceAccess() local
242 v.push_back(item); in BenchmarkSequenceAccess()
Dthreadpool_imp.cc372 auto& item = queue_.back(); in Submit() local
373 item.tag = tag; in Submit()
374 item.function = std::move(schedule); in Submit()
375 item.unschedFunction = std::move(unschedule); in Submit()
Dstring_util.cc30 std::string item; in StringSplit() local
31 while (std::getline(ss, item, delim)) { in StringSplit()
32 splits.push_back(item); in StringSplit()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc917 for (auto& item : backup_items_to_finish) { in CreateNewBackupWithMetadata() local
918 item.result.wait(); in CreateNewBackupWithMetadata()
919 auto result = item.result.get(); in CreateNewBackupWithMetadata()
921 if (item_status.ok() && item.shared && item.needed_to_copy) { in CreateNewBackupWithMetadata()
922 item_status = item.backup_env->RenameFile(item.dst_path_tmp, in CreateNewBackupWithMetadata()
923 item.dst_path); in CreateNewBackupWithMetadata()
927 std::make_shared<FileInfo>(item.dst_relative, in CreateNewBackupWithMetadata()
1237 for (auto& item : restore_items_to_finish) { in RestoreDBFromBackup() local
1238 item.result.wait(); in RestoreDBFromBackup()
1239 auto result = item.result.get(); in RestoreDBFromBackup()
[all …]
/rocksdb-6.9/db/
Ddb_table_properties_test.cc38 for (const auto& item : props) { in VerifyTableProperties() local
39 unique_entries.insert(item.second->num_entries); in VerifyTableProperties()
40 sum += item.second->num_entries; in VerifyTableProperties()
Ddb_properties_test.cc1192 for (const auto& item : props) { in TEST_F() local
1193 auto& user_collected = item.second->user_collected_properties; in TEST_F()
Dversion_set.cc1394 for (const auto& item : props) { in GetAggregatedTableProperties() local
1395 new_tp->Add(*item.second); in GetAggregatedTableProperties()
/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc885 for (const auto& item : index_blocks.meta_blocks) { in WriteIndexBlock() local
887 WriteBlock(item.second, &block_handle, false /* is_data_block */); in WriteIndexBlock()
891 meta_index_builder->Add(item.first, block_handle); in WriteIndexBlock()
/rocksdb-6.9/docs/
DREADME.md44 …- On first runs or for structural changes to the documentation (e.g., new sidebar menu item), do a…
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim.py1325 item = self.od.popitem(last=False) if self.od else None
1326 if item is not None:
1327 return item[0]
/rocksdb-6.9/table/
Dtable_test.cc1379 for (const auto& item : kvmap) { in TEST_P() local
1380 block_builder.Add(item.first, item.second); in TEST_P()
1959 for (const auto& item : kvmap) { in IndexTest() local
1960 auto ukey = ExtractUserKey(item.first).ToString(); in IndexTest()
1969 ASSERT_EQ(item.first, index_iter->key().ToString()); in IndexTest()
1970 ASSERT_EQ(item.second, index_iter->value().ToString()); in IndexTest()