| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_row_merge_test.cc | 16 row_values.push_back( in TEST() 24 row_values.push_back( in TEST() 33 row_values.push_back( in TEST() 56 row_values.push_back( in TEST() 61 row_values.push_back( in TEST() 69 row_values.push_back( in TEST() 77 row_values.push_back( in TEST() 93 row_values.push_back( in TEST() 97 row_values.push_back( in TEST()
|
| D | merge_operator.cc | 27 row_values.push_back( in FullMergeV2() 33 row_values.push_back(RowValue::Deserialize(operand.data(), operand.size())); in FullMergeV2() 53 row_values.push_back(RowValue::Deserialize(operand.data(), operand.size())); in PartialMergeMulti()
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_test.cc | 141 result.push_back(get_line); in CheckFileContent() 170 paras.push_back(para); in AnalyzeTrace() 192 paras.push_back("-output_dir=" + output_path); in TEST_F() 193 paras.push_back("-trace_path=" + trace_path); in TEST_F() 258 paras.push_back("-output_dir=" + output_path); in TEST_F() 259 paras.push_back("-trace_path=" + trace_path); in TEST_F() 329 paras.push_back("-output_dir=" + output_path); in TEST_F() 330 paras.push_back("-trace_path=" + trace_path); in TEST_F() 396 paras.push_back("-trace_path=" + trace_path); in TEST_F() 468 paras.push_back("-trace_path=" + trace_path); in TEST_F() [all …]
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader_test.cc | 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() 241 reqs.push_back(std::move(r1)); in TEST_F()
|
| D | delete_scheduler_test.cc | 127 [&](void* arg) { penalties.push_back(*(static_cast<uint64_t*>(arg))); }); in TEST_F() 154 generated_files.push_back(NewDummyFile(file_name, file_size)); in TEST_F() 203 generated_files.push_back(NewDummyFile("file", kFileSize, i)); in TEST_F() 241 [&](void* arg) { penalties.push_back(*(static_cast<uint64_t*>(arg))); }); in TEST_F() 261 generated_files.push_back(NewDummyFile(file_name, file_size)); in TEST_F() 554 [&](void* arg) { penalties.push_back(*(static_cast<int*>(arg))); }); in TEST_F() 585 generated_files.push_back(NewDummyFile(file_name, file_size)); in TEST_F() 646 generated_files.push_back(NewDummyFile(file_name, file_size)); in TEST_F()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 39 successors_[dependency.predecessor].push_back(dependency.successor); in LoadDependency() 40 predecessors_[dependency.successor].push_back(dependency.predecessor); in LoadDependency() 55 successors_[dependency.predecessor].push_back(dependency.successor); in LoadDependencyAndMarkers() 56 predecessors_[dependency.successor].push_back(dependency.predecessor); in LoadDependencyAndMarkers() 59 successors_[marker.predecessor].push_back(marker.successor); in LoadDependencyAndMarkers() 60 predecessors_[marker.successor].push_back(marker.predecessor); in LoadDependencyAndMarkers() 61 markers_[marker.predecessor].push_back(marker.successor); in LoadDependencyAndMarkers()
|
| /rocksdb-6.9/db/ |
| D | import_column_family_test.cc | 95 metadata.files.push_back( in TEST_F() 116 metadata.files.push_back( in TEST_F() 194 metadata.files.push_back( in TEST_F() 196 metadata.files.push_back( in TEST_F() 198 metadata.files.push_back( in TEST_F() 200 metadata.files.push_back( in TEST_F() 202 metadata.files.push_back( in TEST_F() 204 metadata.files.push_back( in TEST_F() 476 metadata.files.push_back( in TEST_F() 478 metadata.files.push_back( in TEST_F() [all …]
|
| D | db_test2.cc | 545 batch_keys[0].push_back("key1"); in TEST_F() 546 batch_keys[0].push_back("key2"); in TEST_F() 547 batch_keys[1].push_back("key3"); in TEST_F() 548 batch_keys[1].push_back("key4"); in TEST_F() 549 batch_keys[2].push_back("key5"); in TEST_F() 1993 values.push_back(str); in TEST_F() 3209 column_families.push_back( in TEST_F() 3284 column_families.push_back( in TEST_F() 3352 column_families.push_back( in TEST_F() 3452 column_families.push_back( in TEST_F() [all …]
|
| D | listener_test.cc | 98 compacted_dbs_.push_back(db); in OnCompactionCompleted() 174 options.table_properties_collector_factories.push_back( in TEST_F() 253 flushed_dbs_.push_back(db); in OnFlushCompleted() 422 handles.push_back(handle); in TEST_F() 425 vec_handles.push_back(std::move(handles)); in TEST_F() 426 dbs.push_back(db); in TEST_F() 777 options.listeners.push_back(listener); in TEST_F() 835 options.listeners.push_back(listener); in TEST_F() 873 options.listeners.push_back(listener); in TEST_F() 911 options.listeners.push_back(listener); in TEST_F() [all …]
|
| D | write_batch.cc | 767 b->rep_.push_back(static_cast<char>(kTypeValue)); in Put() 823 b->rep_.push_back(static_cast<char>(kTypeValue)); in Put() 847 b->rep_.push_back(static_cast<char>(kTypeNoop)); in InsertNoop() 884 b->rep_.push_back(static_cast<char>(kTypeCommitXID)); in MarkCommit() 893 b->rep_.push_back(static_cast<char>(kTypeRollbackXID)); in MarkRollback() 906 b->rep_.push_back(static_cast<char>(kTypeDeletion)); in Delete() 928 b->rep_.push_back(static_cast<char>(kTypeDeletion)); in Delete() 1057 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge() 1087 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge() 1112 b->rep_.push_back(static_cast<char>(kTypeBlobIndex)); in PutBlobIndex() [all …]
|
| D | merge_context.h | 37 operand_list_->push_back(operand_slice); 42 operand_list_->push_back(*copied_operands_->back()); 53 operand_list_->push_back(operand_slice); 58 operand_list_->push_back(*copied_operands_->back());
|
| D | external_sst_file_test.cc | 2413 data.push_back( in TEST_P() 2415 data.push_back( in TEST_P() 2417 data.push_back( in TEST_P() 2488 data.push_back( in TEST_P() 2490 data.push_back( in TEST_P() 2492 data.push_back( in TEST_P() 2595 data.push_back( in TEST_P() 2597 data.push_back( in TEST_P() 2599 data.push_back( in TEST_P() 2666 data.push_back( in TEST_P() [all …]
|
| D | db_filesnapshot.cc | 136 ret.push_back(MakeTableFileName("", live_file.GetNumber())); in GetLiveFiles() 139 ret.push_back(CurrentFileName("")); in GetLiveFiles() 140 ret.push_back(DescriptorFileName("", versions_->manifest_file_number())); in GetLiveFiles() 141 ret.push_back(OptionsFileName("", versions_->options_file_number())); in GetLiveFiles()
|
| D | flush_job_test.cc | 264 memtable_ids.push_back(mem->GetID()); in TEST_F() 320 all_cfds.push_back(cfd); in TEST_F() 333 smallest_seqs.push_back(curr_seqno); in TEST_F() 348 largest_seqs.push_back(curr_seqno - 1); in TEST_F() 349 memtable_ids.push_back(num_memtables[k++] - 1); in TEST_F() 384 file_meta_ptrs.push_back(&meta); in TEST_F() 389 mems_list.push_back(&mems); in TEST_F() 393 mutable_cf_options_list.push_back(cfd->GetLatestMutableCFOptions()); in TEST_F()
|
| D | db_with_timestamp_basic_test.cc | 257 write_ts_list.push_back(Timestamp(2 * t, /*do not care*/ 17)); in TEST_F() 272 start_seqs.push_back(db_->GetLatestSequenceNumber()); in TEST_F() 472 write_ts_list.push_back(Timestamp(i * 2, 0)); in TEST_P() 473 read_ts_list.push_back(Timestamp(1 + i * 2, 0)); in TEST_P() 514 flushed_files_.push_back(info.file_path); in OnFlushCompleted() 602 write_ts_list.push_back(Timestamp(i * 2, 0)); in TEST_P() 603 read_ts_list.push_back(Timestamp(1 + i * 2, 0)); in TEST_P() 683 key_vals.push_back(Key1(j)); in TEST_F() 686 keys.push_back(key_vals[j]); in TEST_F() 707 write_ts_list.push_back(Timestamp(i * 2, 0)); in TEST_F() [all …]
|
| /rocksdb-6.9/utilities/merge_operators/ |
| D | sortlist.cc | 61 operand.push_back(std::stoi(std::string(begin, slice.data_))); in MakeVector() 75 result.push_back(left[left_it]); in Merge() 78 result.push_back(right[right_it]); in Merge() 85 result.push_back(left[left_it]); in Merge() 90 result.push_back(right[right_it]); in Merge()
|
| D | bytesxor.cc | 44 new_value->push_back(existing_value_data[i] ^ value_data[i]); in XOR() 49 new_value->push_back(existing_value_data[i]); in XOR() 54 new_value->push_back(value_data[i]); in XOR()
|
| /rocksdb-6.9/util/ |
| D | coding_test.cc | 120 values.push_back(0); in TEST() 121 values.push_back(100); in TEST() 122 values.push_back(~static_cast<uint64_t>(0)); in TEST() 123 values.push_back(~static_cast<uint64_t>(0) - 1); in TEST() 127 values.push_back(power); in TEST() 128 values.push_back(power-1); in TEST() 129 values.push_back(power+1); in TEST()
|
| D | autovector.h | 182 push_back(item); 266 void push_back(T&& item) { 271 vect_.push_back(item); 275 void push_back(const T& item) { 280 vect_.push_back(item);
|
| D | file_checksum_helper.cc | 27 file_numbers->push_back(i.first); in GetAllFileChecksums() 28 checksums->push_back(i.second.first); in GetAllFileChecksums() 29 checksum_func_names->push_back(i.second.second); in GetAllFileChecksums()
|
| D | autovector_test.cc | 43 vec.push_back(i); in TEST_F() 130 vec.push_back(i); in TEST_F() 149 vec.push_back(ToString(i)); in TEST_F() 229 v.push_back(items[index++]); in BenchmarkVectorCreationAndInsertion() 242 v.push_back(item); in BenchmarkSequenceAccess()
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 52 result.push_back(id); in basicNThreads() 59 threads.push_back(std::thread(function(i))); in basicNThreads() 118 threads.push_back(std::thread(tryLockFunction)); in lockWithTryAndTimedNThreads() 165 threads.push_back(std::thread(function())); in combineNThreads() 217 threads.push_back(std::thread(combineFunction)); in combineWithLockNThreads() 287 threads.push_back(std::thread(combineFunction)); in combineWithTryLockNThreads() 668 threads.push_back(std::thread([&] { in stressTryLockWithConcurrentLocks() 719 threads.push_back(std::thread([&] { in concurrentTryLocks() 893 threads.push_back(std::thread([&] { in concurrentLocksManyMutexes() 998 threads.push_back(std::thread([&]() { in concurrentExceptionPropagationStress() [all …]
|
| /rocksdb-6.9/db/blob/ |
| D | blob_index.h | 136 dst->push_back(static_cast<char>(Type::kInlinedTTL)); in EncodeInlinedTTL() 147 dst->push_back(static_cast<char>(Type::kBlob)); in EncodeBlob() 151 dst->push_back(static_cast<char>(compression)); in EncodeBlob() 160 dst->push_back(static_cast<char>(Type::kBlobTTL)); in EncodeBlobTTL() 165 dst->push_back(static_cast<char>(compression)); in EncodeBlobTTL()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 57 cf_names.push_back(i == 0 ? kDefaultColumnFamilyName in TEST_F() 109 cf_opts.push_back(default_column_family_opt); in TEST_F() 113 cf_opts.push_back(cf_opt_sample); in TEST_F() 117 cf_opts.push_back(cf_opt_plain_table_opt); in TEST_F() 120 cf_names.push_back(kDefaultColumnFamilyName); in TEST_F() 121 cf_names.push_back("cf_sample"); in TEST_F() 122 cf_names.push_back("cf_plain_table_sample"); in TEST_F()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer.h | 28 access_sequence_number_timeline.push_back(access_sequnce_number); in AddAccess() 29 access_timeline.push_back(access.access_timestamp); in AddAccess() 89 access_sequence_number_timeline.push_back(access_sequnce_number); in AddAccess() 90 caller_access_sequence__number_timeline[access.caller].push_back( in AddAccess() 92 access_timeline.push_back(access.access_timestamp); in AddAccess() 93 caller_access_timeline[access.caller].push_back(access.access_timestamp); in AddAccess()
|