| /rocksdb-6.9/third-party/folly/folly/synchronization/detail/ |
| D | ProxyLockable-inl.h | 56 proxy_.emplace(mtx.lock()); in ProxyLockableUniqueLock()
87 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
98 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
109 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
118 proxy_.emplace(mutex_->lock()); in lock()
136 proxy_.emplace(std::move(state)); in try_lock()
151 proxy_.emplace(std::move(state)); in try_lock_for()
166 proxy_.emplace(std::move(state)); in try_lock_until()
|
| /rocksdb-6.9/db/ |
| D | version_edit_handler.cc | 86 name_to_options_.emplace(cf_desc.name, cf_desc.options); in Initialize()
147 column_families_not_found_.emplace(edit.column_family_, in OnColumnFamilyAdd()
346 builders_.emplace(edit.column_family_, in CreateCfAndInit()
349 cf_to_missing_files_.emplace(edit.column_family_, in CreateCfAndInit()
570 versions_.emplace(cfd->GetID(), version); in MaybeCreateVersion()
|
| D | range_tombstone_fragmenter.cc | 198 cur_end_keys.emplace(tombstone_end_key, tombstone_seq, kTypeRangeDeletion); in FragmentTombstones()
430 splits.emplace(upper, std::unique_ptr<FragmentedRangeTombstoneIterator>( in SplitBySnapshot()
|
| D | range_del_aggregator.cc | 150 split_truncated_iters.emplace(iter_pair.first, in SplitBySnapshot()
354 std::tie(it, inserted) = reps_.emplace( in AddTombstones()
|
| D | version_edit.h | 313 deleted_files_.emplace(level, file); in DeleteFile()
|
| D | version_builder.cc | 402 changed_blob_files_.emplace(blob_file_number, std::move(new_meta)); in ApplyBlobFileAddition()
|
| D | version_set.cc | 4440 cf_name_to_options.emplace(cf.name, cf.options); in Recover()
|
| /rocksdb-6.9/third-party/folly/folly/ |
| D | Optional.h | 210 Value& emplace(Args&&... args) { in emplace() function
220 emplace(std::initializer_list<U> ilist, Args&&... args) { in emplace() function
239 that.emplace(std::move(value())); in swap()
242 emplace(std::move(that.value())); in swap()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_base.cc | 125 save_points_->emplace(snapshot_, snapshot_needed_, snapshot_notifier_, in SetSavePoint()
218 prev_cf_key_map.emplace(curr_cf_key_iter); in PopSavePoint()
229 prev_keys.emplace(key_iter); in PopSavePoint()
649 auto result = cf_key_map.emplace(key, TransactionKeyMapInfo(seq)); in TrackKey()
|
| D | transaction_lock_mgr.cc | 189 lock_maps_.emplace(column_family_id, in AddColumnFamily()
575 stripe->keys.emplace(key, std::move(txn_lock_info)); in AcquireLocked()
|
| /rocksdb-6.9/util/ |
| D | channel.h | 42 buffer_.emplace(std::forward<T>(elem)); in write()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 102 marked_thread_id_.emplace(marked_point, thread_id); in Process()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | statistics.cc | 79 histograms.emplace(histogram); in Java_org_rocksdb_Statistics_newStatistics___3BJ()
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_updater.cc | 226 cf_info_map_.emplace(std::piecewise_construct, std::make_tuple(cf_key), in NewColumnFamilyInfo()
|
| /rocksdb-6.9/file/ |
| D | delete_scheduler.cc | 94 queue_.emplace(trash_file, dir_to_sync); in DeleteFile()
|
| /rocksdb-6.9/table/block_based/ |
| D | block_test.cc | 226 marked_ranges_.emplace(end_offset, start_offset); in Mark()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | file_system.h | 125 counters.emplace(name, value); in AddCounter()
|
| /rocksdb-6.9/env/ |
| D | io_posix.cc | 397 dir_sizes.emplace(dir, 0); in RefAndCacheLogicalBlockSize()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db.cc | 1584 result->emplace(dir + (slash_needed ? "/" : "") + file_attrs.name, in InsertPathnameToSizeBytes()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.cc | 1516 thread->snapshot_queue.emplace(release_at, snap_state); in TestAcquireSnapshot()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1725 multiget_cf_data.emplace(cfd->GetID(), in MultiGet()
|