Home
last modified time | relevance | path

Searched refs:move (Results 1 – 25 of 729) sorted by relevance

12345678910>>...30

/rocksdb-6.9/util/
Dheap.h44 explicit BinaryHeap(Compare cmp) : cmp_(std::move(cmp)) { } in BinaryHeap()
52 data_.push_back(std::move(value)); in push()
69 data_.front() = std::move(value); in replace_top()
75 data_.front() = std::move(data_.back()); in pop()
108 T v = std::move(data_[index]); in upheap()
114 data_[index] = std::move(data_[parent]); in upheap()
117 data_[index] = std::move(v); in upheap()
122 T v = std::move(data_[index]); in downheap()
142 data_[index] = std::move(data_[picked_child]); in downheap()
157 data_[index] = std::move(v); in downheap()
Dslice_test.cc38 PinnableSlice v2(std::move(v1)); in TEST_F()
43 v3 = std::move(v2); in TEST_F()
61 PinnableSlice v2(std::move(v1)); in TEST_F()
77 PinnableSlice v2(std::move(v1)); in TEST_F()
90 v2 = std::move(v1); in TEST_F()
113 v2 = std::move(v1); in TEST_F()
132 v2 = std::move(v1); in TEST_F()
145 v2 = std::move(v1); in TEST_F()
Daligned_buffer.h73 *this = std::move(o); in AlignedBuffer()
77 alignment_ = std::move(o.alignment_);
78 buf_ = std::move(o.buf_);
79 capacity_ = std::move(o.capacity_);
80 cursize_ = std::move(o.cursize_);
81 bufstart_ = std::move(o.bufstart_);
Dtimer_queue.h80 item.handler = std::move(handler); in add()
85 m_items.push(std::move(item)); in add()
111 newItem.handler = std::move(item.handler); in cancel()
112 m_items.push(std::move(newItem)); in cancel()
202 m_items.push(std::move(item)); in checkWork()
Dthreadpool_imp.cc223 auto func = std::move(queue_.front().function); in BGThread()
354 bgthreads_.push_back(std::move(p_t)); in StartBGThreads()
374 item.function = std::move(schedule); in Submit()
375 item.unschedFunction = std::move(unschedule); in Submit()
402 candidates.push_back(std::move(it->unschedFunction)); in UnSchedule()
465 impl_->Submit(std::move(copy), std::function<void()>(), nullptr); in SubmitJob()
470 impl_->Submit(std::move(job), std::function<void()>(), nullptr); in SubmitJob()
/rocksdb-6.9/db/
Drange_del_aggregator_test.cc44 std::move(range_del_iter), bytewise_icmp)); in MakeFragmentedTombstoneLists()
197 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
355 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
380 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
412 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
529 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
563 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
604 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
622 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
647 range_del_agg.AddTombstones(std::move(input_iter)); in TEST_F()
[all …]
Drange_tombstone_fragmenter_test.cc118 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
132 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
148 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
164 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
179 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
202 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
229 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
305 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
374 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
400 FragmentedRangeTombstoneList fragment_list(std::move(range_del_iter), in TEST_F()
[all …]
Djob_context.h40 : superversions_to_free(std::move(other.superversions_to_free)), in SuperVersionContext()
42 write_stall_notifications(std::move(other.write_stall_notifications)), in SuperVersionContext()
44 new_superversion(std::move(other.new_superversion)) { in SuperVersionContext()
126 : file_name(std::move(name)), file_path(std::move(path)) {} in CandidateFileInfo()
Drange_del_aggregator_bench.cc105 : start_key(std::move(start)), end_key(std::move(end)) { in PersistentRangeTombstone()
124 start_key = std::move(t.start_key); in operator =()
125 end_key = std::move(t.end_key); in operator =()
224 range_del_agg.AddTombstones(std::move(fragmented_range_del_iter)); in main()
/rocksdb-6.9/file/
Drandom_access_file_reader.h69 : file_(std::move(raf)), in file_()
70 file_name_(std::move(_file_name)), in file_()
90 *this = std::move(o); in RandomAccessFileReader()
95 file_ = std::move(o.file_);
96 env_ = std::move(o.env_);
97 stats_ = std::move(o.stats_);
98 hist_type_ = std::move(o.hist_type_);
99 file_read_hist_ = std::move(o.file_read_hist_);
100 rate_limiter_ = std::move(o.rate_limiter_);
Drandom_access_file_reader_test.cc64 (*reader).reset(new RandomAccessFileReader(std::move(f), fpath, env_)); in Read()
137 reqs.push_back(std::move(r0)); in TEST_F()
138 reqs.push_back(std::move(r1)); in TEST_F()
173 reqs.push_back(std::move(r0)); in TEST_F()
174 reqs.push_back(std::move(r1)); in TEST_F()
175 reqs.push_back(std::move(r2)); in TEST_F()
210 reqs.push_back(std::move(r0)); in TEST_F()
211 reqs.push_back(std::move(r1)); in TEST_F()
212 reqs.push_back(std::move(r2)); in TEST_F()
240 reqs.push_back(std::move(r0)); in TEST_F()
[all …]
Dsequence_file_reader.h31 : file_(std::move(_file)), file_name_(_file_name) {} in SequentialFileReader()
36 : file_(NewReadaheadSequentialFile(std::move(_file), _readahead_size)), in SequentialFileReader()
40 *this = std::move(o); in SequentialFileReader()
44 file_ = std::move(o.file_);
/rocksdb-6.9/third-party/folly/folly/synchronization/detail/
DProxyLockable-inl.h63 *this = std::move(a); in ProxyLockableUniqueLock()
69 proxy_ = std::move(other.proxy_);
87 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
98 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
109 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
126 mutex_->unlock(std::move(*proxy_)); in unlock()
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/table/cuckoo/
Dcuckoo_table_builder_test.cc170 NewLegacyWritableFileWrapper(std::move(writable_file)), fname, in TEST_F()
200 hash_map = std::move(hm); in TEST_F()
250 hash_map = std::move(hm); in TEST_F()
299 hash_map = std::move(hm); in TEST_F()
354 hash_map = std::move(hm); in TEST_F()
405 hash_map = std::move(hm); in TEST_F()
453 hash_map = std::move(hm); in TEST_F()
498 hash_map = std::move(hm); in TEST_F()
545 hash_map = std::move(hm); in TEST_F()
594 hash_map = std::move(hm); in TEST_F()
[all …]
/rocksdb-6.9/third-party/folly/folly/
DOptional.h108 construct(std::move(src.value())); in noexcept()
117 construct(std::move(newValue)); in noexcept()
154 assign(std::move(src.value())); in assign()
174 construct(std::move(newValue)); in assign()
199 assign(std::move(other)); in noexcept()
239 that.emplace(std::move(value())); in swap()
242 emplace(std::move(that.value())); in swap()
259 return std::move(storage_.value); in value()
264 return std::move(storage_.value); in value()
294 return std::move(value());
[all …]
/rocksdb-6.9/env/
Dcomposite_env_wrapper.h27 : target_(std::move(target)) {} in CompositeSequentialFileWrapper()
57 : target_(std::move(target)) {} in CompositeRandomAccessFileWrapper()
111 : target_(std::move(t)) {} in CompositeWritableFileWrapper()
214 : target_(std::move(target)) {} in CompositeRandomRWFileWrapper()
259 : target_(std::move(target)) {} in CompositeDirectoryWrapper()
618 : target_(std::move(_target)) {} in LegacySequentialFileWrapper()
650 : target_(std::move(target)) {} in LegacyRandomAccessFileWrapper()
707 : target_(std::move(_target)) {} in LegacyWritableFileWrapper()
801 : target_(std::move(target)) {} in LegacyRandomRWFileWrapper()
841 : target_(std::move(target)) {} in LegacyDirectoryWrapper()
[all …]
/rocksdb-6.9/trace_replay/
Dblock_cache_tracer_test.cc176 BlockCacheTraceReader reader(std::move(trace_reader)); in TEST_F()
190 ASSERT_OK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
200 BlockCacheTraceReader reader(std::move(trace_reader)); in TEST_F()
216 ASSERT_OK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
217 ASSERT_NOK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
229 ASSERT_OK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
244 BlockCacheTraceReader reader(std::move(trace_reader)); in TEST_F()
264 ASSERT_OK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
278 ASSERT_OK(writer.StartTrace(env_, trace_opt, std::move(trace_writer))); in TEST_F()
290 BlockCacheTraceWriter writer(env_, trace_opt, std::move(trace_writer)); in TEST_F()
[all …]
/rocksdb-6.9/utilities/cassandra/
Dformat.cc214 columns_(std::move(columns)), last_modified_time_(last_modified_time) {} in RowValue()
261 return RowValue(std::move(new_columns), last_modified_time_); in RemoveExpiredColumns()
281 return RowValue(std::move(new_columns), last_modified_time_); in ConvertExpiredColumnsToTombstones()
298 return RowValue(std::move(new_columns), last_modified_time_); in RemoveTombstones()
327 columns.push_back(std::move(c)); in Deserialize()
330 return RowValue(std::move(columns), last_modified_time); in Deserialize()
341 return std::move(values[0]); in Merge()
357 return std::move(value); in Merge()
384 columns.push_back(std::move(pair.second)); in Merge()
386 return RowValue(std::move(columns), last_modified_time); in Merge()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc364 *this = std::move(o); in CopyOrCreateWorkItem()
368 src_path = std::move(o.src_path); in operator =()
369 dst_path = std::move(o.dst_path); in operator =()
370 contents = std::move(o.contents); in operator =()
377 result = std::move(o.result); in operator =()
417 *this = std::move(o); in BackupAfterCopyOrCreateWorkItem()
422 result = std::move(o.result); in operator =()
427 dst_path = std::move(o.dst_path); in operator =()
437 : result(std::move(_result)), in BackupAfterCopyOrCreateWorkItem()
456 *this = std::move(o); in RestoreAfterCopyOrCreateWorkItem()
[all …]
/rocksdb-6.9/include/rocksdb/
Dtransaction_log.h72 : sequence(std::move(bResult.sequence)), in BatchResult()
73 writeBatchPtr(std::move(bResult.writeBatchPtr)) {} in BatchResult()
76 sequence = std::move(bResult.sequence);
77 writeBatchPtr = std::move(bResult.writeBatchPtr);
/rocksdb-6.9/third-party/folly/folly/synchronization/
DDistributedMutex-inl.h394 return std::move(value_); in get()
472 : func_{std::move(func)}, waiter_(waiter) {} in TaskWithCoalesce()
526 : func_{std::move(func)} {} in TaskWithBigReturnValue()
531 new (storage_) ReturnType(std::move(value)); in operator()
646 auto copy = std::move(*exc);
648 std::rethrow_exception(std::move(copy));
683 new (&request.value_) ReturnType(std::move(val));
758 *this = std::move(other);
1068 unlock(std::move(state));
1085 return std::move(task).get();
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc178 compaction = std::move(o.compaction); in operator =()
179 start = std::move(o.start); in operator =()
180 end = std::move(o.end); in operator =()
181 status = std::move(o.status); in operator =()
182 outputs = std::move(o.outputs); in operator =()
183 outfile = std::move(o.outfile); in operator =()
184 builder = std::move(o.builder); in operator =()
186 total_bytes = std::move(o.total_bytes); in operator =()
189 approx_size = std::move(o.approx_size); in operator =()
192 seen_key = std::move(o.seen_key); in operator =()
[all …]
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc20 : file_reader_(std::move(reader)), in FileTraceReader()
103 trace_reader->reset(new FileTraceReader(std::move(file_reader))); in NewFileTraceReader()
118 NewLegacyWritableFileWrapper(std::move(trace_file)), trace_filename, in NewFileTraceWriter()
120 trace_writer->reset(new FileTraceWriter(std::move(file_writer))); in NewFileTraceWriter()
/rocksdb-6.9/port/win/
Dwin_thread.cc29 func_(std::move(func)), in Data()
42 data_ = std::make_shared<Data>(std::move(func)); in Init()
85 *this = std::move(o); in WindowsThread()
95 data_ = std::move(o.data_); in operator =()
/rocksdb-6.9/table/
Dformat.cc364 *contents = BlockContents(std::move(ubuf), ulength); in UncompressBlockContentsForCompressionType()
377 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
389 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
401 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
413 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
425 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
436 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()

12345678910>>...30