Home
last modified time | relevance | path

Searched refs:insert (Results 1 – 25 of 102) sorted by relevance

12345

/rocksdb-6.9/utilities/persistent_cache/
Dvolatile_tier_impl.cc23 stat.insert({"persistent_cache.volatile_cache.hits", in Stats()
25 stat.insert({"persistent_cache.volatile_cache.misses", in Stats()
27 stat.insert({"persistent_cache.volatile_cache.inserts", in Stats()
29 stat.insert({"persistent_cache.volatile_cache.evicts", in Stats()
31 stat.insert({"persistent_cache.volatile_cache.hit_pct", in Stats()
33 stat.insert({"persistent_cache.volatile_cache.miss_pct", in Stats()
/rocksdb-6.9/monitoring/
Dthread_status_impl.cc104 property_map.insert({"BaseInputLevel", op_properties[i] >> 32}); in InterpretOperationProperties()
105 property_map.insert( in InterpretOperationProperties()
108 property_map.insert({"IsManual", ((op_properties[i] & 2) >> 1)}); in InterpretOperationProperties()
109 property_map.insert({"IsDeletion", ((op_properties[i] & 4) >> 2)}); in InterpretOperationProperties()
110 property_map.insert({"IsTrivialMove", ((op_properties[i] & 8) >> 3)}); in InterpretOperationProperties()
112 property_map.insert( in InterpretOperationProperties()
Dthread_status_updater.cc25 thread_data_set_.insert(thread_status_data_); in RegisterThread()
228 db_key_map_[db_key].insert(cf_key); in NewColumnFamilyInfo()
/rocksdb-6.9/test_util/
Dfault_injection_test_fs.cc233 open_files_.insert(fname); in NewWritableFile()
236 list.insert(dir_and_name.second); in NewWritableFile()
254 open_files_.insert(fname); in ReopenWritableFile()
257 list.insert(dir_and_name.second); in ReopenWritableFile()
275 open_files_.insert(fname); in NewRandomRWFile()
278 list.insert(dir_and_name.second); in NewRandomRWFile()
330 tlist.insert(tdn.second); in RenameFile()
349 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileSynced()
360 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileAppended()
399 map_copy.insert(dir_to_new_files_since_last_sync_.begin(), in DeleteFilesCreatedAfterLastDirSync()
Dfault_injection_test_env.cc244 open_files_.insert(fname); in NewWritableFile()
247 list.insert(dir_and_name.second); in NewWritableFile()
265 open_files_.insert(fname); in ReopenWritableFile()
268 list.insert(dir_and_name.second); in ReopenWritableFile()
286 open_files_.insert(fname); in NewRandomRWFile()
289 list.insert(dir_and_name.second); in NewRandomRWFile()
337 tlist.insert(tdn.second); in RenameFile()
356 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileSynced()
367 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileAppended()
408 map_copy.insert(dir_to_new_files_since_last_sync_.begin(), in DeleteFilesCreatedAfterLastDirSync()
/rocksdb-6.9/docs/_posts/
D2014-09-12-cuckoo.markdown50 …insert any new key _k_, we compute hashes of the key _h1(k), ..., __hn__(k)_. We insert the key in…
71 The solution is to insert more keys near first location. In case of collision in the first hash loc…
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration_test.cc80 keys.insert(it->key().ToString()); in TEST_P()
148 keys.insert(it->key().ToString()); in TEST_P()
223 keys.insert(it->key().ToString()); in TEST_P()
297 keys.insert(it->key().ToString()); in TEST_P()
387 keys.insert(it->key().ToString()); in TEST_F()
/rocksdb-6.9/utilities/memory/
Dmemory_test.cc50 cache_set->insert(bbt_opts.block_cache.get()); in GetCachePointersFromTableFactory()
51 cache_set->insert(bbt_opts.block_cache_compressed.get()); in GetCachePointersFromTableFactory()
66 cache_set->insert(db_impl->TEST_table_cache()); in GetCachePointers()
70 cache_set->insert(db->GetDBOptions().row_cache.get()); in GetCachePointers()
/rocksdb-6.9/util/
Dduplicate_detector.h30 auto it = cf_keys.insert(key); in IsDuplicateKeySeq()
34 keys_[cf].insert(key); in IsDuplicateKeySeq()
/rocksdb-6.9/table/
Dsst_file_writer_collectors.h50 properties->insert({ExternalSstFilePropertyNames::kVersion, version_val}); in Finish()
55 properties->insert({ExternalSstFilePropertyNames::kGlobalSeqno, seqno_val}); in Finish()
Dmeta_blocks.cc32 meta_block_handles_.insert({key, handle_encoding}); in Add()
51 props_.insert({name, val}); in Add()
293 new_table_properties->properties_offsets.insert( in ReadProperties()
300 new_table_properties->user_collected_properties.insert( in ReadProperties()
332 new_table_properties->user_collected_properties.insert( in ReadProperties()
Dmock_table.h136 table_.insert({key.ToString(), value.ToString()}); in Add()
147 file_system_->files.insert({id_, table_}); in Finish()
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc70 keys_.insert(key); in Insert()
77 keys_.insert(key); in InsertWithHint()
136 if (keys.insert(key).second) { in TEST_F()
284 if (used.insert(s).second) { in TEST_F()
293 if (used.insert(s).second) { in TEST_F()
/rocksdb-6.9/db/
Doptions_file_test.cc34 filename_history->insert(filename); in UpdateOptionsFiles()
50 current_filenames.insert(filename); in VerifyOptionsFileName()
Drange_del_aggregator.h159 auto seq_pos = active_seqnums_.insert(iter); in PushActiveIter()
243 auto seq_pos = active_seqnums_.insert(iter); in PushActiveIter()
299 return files_seen_.insert(file_number).second; in AddFile()
Dflush_job_test.cc170 inserted_keys.insert({internal_key.Encode().ToString(), value}); in TEST_F()
177 inserted_keys.insert({internal_key.Encode().ToString(), "9999a"}); in TEST_F()
438 snapshots_set.insert(rnd.Uniform(keys * (max_inserts_per_keys / 2)) + 1); in TEST_F()
461 inserted_keys.insert({internal_key.Encode().ToString(), value}); in TEST_F()
Drange_tombstone_fragmenter.cc134 seq_set_.insert(seq); in FragmentTombstones()
149 tombstone_seqs_.insert(tombstone_seqs_.end(), seqnums_to_flush.begin(), in FragmentTombstones()
151 seq_set_.insert(seqnums_to_flush.begin(), seqnums_to_flush.end()); in FragmentTombstones()
Ddb_iter_stress_test.cc141 data->recently_touched_keys.insert(e.key); in MaybeMutate()
160 data->recently_touched_keys.insert(e.key); in MaybeMutate()
415 s.insert(0, len - (int)s.size(), '0'); in TEST_F()
Dlogs_with_prep_tracker.cc39 logs_with_prep_.insert(rit.base(), {log, 1}); in MarkLogAsContainingPrepSection()
Dflush_scheduler.cc19 checking_set_.insert(cfd); in ScheduleWork()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc114 paths.insert(immutable_db_options_.db_paths[path_id].path); in FindObsoleteFiles()
128 paths.insert(path); in FindObsoleteFiles()
419 files_to_del.insert(number); in PurgeObsoleteFiles()
700 files_to_delete.insert(normalized_fpath); in CleanupFilesAfterRecovery()
Ddb_impl_secondary.cc163 log_readers_.insert(std::make_pair( in MaybeInitLogReader()
223 cfds_changed->insert(cfd); in RecoverLogFiles()
279 cfd_to_current_log_.insert({cfd, log_number}); in RecoverLogFiles()
/rocksdb-6.9/table/block_based/
Dindex_builder.h311 index_blocks->meta_blocks.insert( in Finish()
313 index_blocks->meta_blocks.insert( in Finish()
/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc910 input_files->insert(TableFileNameToNumber(current_files[f].name)); in SanitizeCompactionInputFilesForAllLevels()
955 input_files->insert(TableFileNameToNumber(next_lv_file.name)); in SanitizeCompactionInputFilesForAllLevels()
1043 level0_compactions_in_progress_.insert(c); in RegisterCompaction()
1045 compactions_in_progress_.insert(c); in RegisterCompaction()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.cc430 delayed_prepared_.insert(to_be_popped); in CheckPreparedAgainstMax()
960 vec.insert(std::upper_bound(vec.begin(), vec.end(), prep_seq), prep_seq); in MaybeUpdateOldCommitMap()
988 auto it = cf_keys.insert(key); in AddKey()
993 keys_[cf].insert(key); in AddKey()

12345