Home
last modified time | relevance | path

Searched refs:test (Results 1 – 25 of 132) sorted by relevance

123456

/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc439 test::KeyStr("b", 40, kTypeValue), test::KeyStr("c", 35, kTypeValue), in TEST_P()
444 test::KeyStr("f", 25, kTypeValue), test::KeyStr("g", 90, kTypeValue), in TEST_P()
489 {test::KeyStr("1", 1, kTypeValue), test::KeyStr("2", 2, kTypeValue), in TEST_P()
490 test::KeyStr("3", 3, kTypeValue), test::KeyStr("4", 4, kTypeValue)}, in TEST_P()
527 {test::KeyStr("1", 1, kTypeValue), test::KeyStr("2", 2, kTypeMerge), in TEST_P()
528 test::KeyStr("3", 3, kTypeMerge), test::KeyStr("4", 4, kTypeValue)}, in TEST_P()
645 test::KeyStr("b", 70, kTypeMerge), test::KeyStr("b", 60, kTypeMerge), in TEST_P()
647 test::KeyStr("c", 90, kTypeMerge), test::KeyStr("c", 80, kTypeValue)}, in TEST_P()
924 {test::KeyStr("a", 2, kTypeValue), test::KeyStr("a", 1, kTypeValue), in TEST_F()
925 test::KeyStr("b", 3, kTypeValue), test::KeyStr("c", 1, kTypeValue)}, in TEST_F()
[all …]
Dcompaction_job_test.cc76 dbname_(test::PerThreadDBPath("compaction_job_test")), in CompactionJobTest()
230 test::CorruptKeyType(&internal_key); in CreateTwoFiles()
231 test::CorruptKeyType(&bottommost_internal_key); in CreateTwoFiles()
547 compaction_filter_.reset(new test::FilterNumber(10U)); in TEST_F()
551 {{KeyStr("a", 5U, kTypeMerge), test::EncodeInt(5U)}, in TEST_F()
557 {KeyStr("b", 2U, kTypeMerge), test::EncodeInt(2U)}, in TEST_F()
573 compaction_filter_.reset(new test::FilterNumber(10U)); in TEST_F()
577 {{KeyStr("a", 5U, kTypeMerge), test::EncodeInt(5U)}, in TEST_F()
579 {KeyStr("a", 3U, kTypeValue), test::EncodeInt(5U)}, in TEST_F()
598 {KeyStr("d", 1U, kTypeValue), test::EncodeInt(6U)} in TEST_F()
[all …]
/rocksdb-6.9/db/
Dmerge_helper_test.cc27 iter_.reset(new test::VectorIterator(ks_, vs_)); in Run()
41 test::CorruptKeyType(&ikey); in AddKeyVal()
48 std::unique_ptr<test::VectorIterator> iter_;
53 std::unique_ptr<test::FilterNumber> filter_;
176 filter_.reset(new test::FilterNumber(5U)); in TEST_F()
189 ASSERT_EQ(test::KeyStr("a", 30, kTypeValue), in TEST_F()
198 filter_.reset(new test::FilterNumber(5U)); in TEST_F()
232 filter_.reset(new test::FilterNumber(5U)); in TEST_F()
249 ASSERT_EQ(test::KeyStr("a", 29, kTypeValue), in TEST_F()
263 filter_.reset(new test::FilterNumber(5U)); in TEST_F()
[all …]
Ddb_table_properties_test.cc157 ASSERT_OK(Put(test::RandomKey(&rnd, 5), RandomString(&rnd, 102))); in TEST_F()
162 ASSERT_OK(Put(test::RandomKey(&rnd, 5), RandomString(&rnd, 102))); in TEST_F()
176 {Range(test::RandomKey(&rnd, 5, test::RandomKeyType::SMALLEST), in TEST_F()
177 test::RandomKey(&rnd, 5, test::RandomKeyType::LARGEST))}, in TEST_F()
183 {Range(test::RandomKey(&rnd, 5, test::RandomKeyType::LARGEST), in TEST_F()
184 test::RandomKey(&rnd, 5, test::RandomKeyType::SMALLEST))}, in TEST_F()
191 {Range(test::RandomKey(&rnd, 5, test::RandomKeyType::MIDDLE), in TEST_F()
192 test::RandomKey(&rnd, 5, test::RandomKeyType::LARGEST))}, in TEST_F()
210 random_keys.push_back(test::RandomKey(&rnd, 5)); in TEST_F()
Ddeletefile_test.cc126 auto test = reinterpret_cast<DeleteFileTest*>(arg); in DoSleep() local
127 test->env_->SleepForMicroseconds(2 * 1000 * 1000); in DoSleep()
243 test::SleepingBackgroundTask sleeping_task_before; in TEST_F()
244 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
247 test::SleepingBackgroundTask sleeping_task_after; in TEST_F()
248 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
290 test::SleepingBackgroundTask sleeping_task_after; in TEST_F()
356 test::SleepingBackgroundTask sleeping_task_after; in TEST_F()
357 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
498 test::RandomKey(&rnd, 10))); in TEST_F()
[all …]
Dtable_properties_collector_test.cc50 std::unique_ptr<WritableFile> wf(new test::StringSink); in MakeBuilder()
289 test::StringSink* fwf = static_cast<test::StringSink*>(file->target()); in TestCustomizedTablePropertiesCollector()
291 test::GetRandomAccessFileReader( in TestCustomizedTablePropertiesCollector()
292 new test::StringSource(fwf->contents()))); in TestCustomizedTablePropertiesCollector()
349 test::PlainInternalKeyComparator ikc(options.comparator); in TEST_P()
395 test::PlainInternalKeyComparator pikc(options.comparator); in TestInternalKeyPropertiesCollector()
408 options.info_log = std::make_shared<test::NullLogger>(); in TestInternalKeyPropertiesCollector()
430 test::StringSink* fwf = static_cast<test::StringSink*>(file->target()); in TestInternalKeyPropertiesCollector()
432 test::GetRandomAccessFileReader( in TestInternalKeyPropertiesCollector()
433 new test::StringSource(fwf->contents()))); in TestInternalKeyPropertiesCollector()
Ddb_log_iter_test.cc98 for (int test = 0; test < LOG_ITERATOR_RACE_TEST_COUNT; ++test) { in TEST_F() local
102 {sync_points[test][0], sync_points[test][1]}, in TEST_F()
103 {sync_points[test][2], sync_points[test][3]}, in TEST_F()
Dfault_injection_test.cc110 options.wal_dir = test::PerThreadDBPath(env_, "fault_test_wal"); in CurrentOptions()
114 test::PerThreadDBPath(env_, "fault_test_data"), 1000000U); in CurrentOptions()
121 options.wal_dir = test::PerThreadDBPath(env_, "/fault_test_wal"); in CurrentOptions()
161 dbname_ = test::PerThreadDBPath("fault_test"); in NewDB()
252 return test::RandomString(&r, kValueSize, storage); in Value()
392 test::SleepingBackgroundTask sleeping_task_low; in TEST_P()
395 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
478 test::SleepingBackgroundTask sleeping_task_low; in TEST_P()
481 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task_low, in TEST_P()
Dcomparator_db_test.cc267 dbname_ = test::PerThreadDBPath("comparator_db_test"); in ComparatorDBTest()
318 testing::Values(test::kDefaultFormatVersion));
320 testing::Values(test::kLatestFormatVersion));
333 SetOwnedComparator(new test::SimpleSuffixReverseComparator()); in TEST_P()
345 source_prefixes.push_back(test::RandomHumanReadableString(&rnd, 8)); in TEST_P()
350 test::RandomHumanReadableString(&rnd, rnd.Uniform(8)); in TEST_P()
359 SetOwnedComparator(test::Uint64Comparator(), false /* owner */); in TEST_P()
419 source_strings.push_back(test::RandomKey(&rnd, 8)); in TEST_P()
443 str.append(test::RandomKey(&rnd, size1)); in TEST_P()
444 str.append(test::RandomKey(&rnd, size2)); in TEST_P()
Dlog_test.cc144 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in dest_contents()
150 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in dest_contents()
174 dest_holder_(test::GetWritableFileWriter( in LogTest()
175 new test::StringSink(&reader_contents_), "" /* don't care */)), in LogTest()
176 source_holder_(test::GetSequentialFileReader( in LogTest()
223 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in ShrinkSize()
691 new test::OverwritingStringSink(get_reader_contents()), in TEST_P()
740 test_dir_(test::PerThreadDBPath("retriable_log_test")), in RetriableLogTest()
747 dest_holder_.reset(test::GetWritableFileWriter( in SetupTestEnv()
748 new test::StringSink(&contents_), "" /* file name */)); in SetupTestEnv()
[all …]
/rocksdb-6.9/build_tools/
Dprecommit_checker.py96 def get_commands(self, test): argument
104 def run_test(self, test): argument
105 self.log.caption("Running test %s locally" % test)
108 status, cmds = self.get_commands(test)
130 % (cmd, test))
148 for test in self.tests:
150 self.print_test(test)
151 result = self.run_test(test)
154 self.log.error("Error running test %s" % test)
177 def print_test(self, test): argument
[all …]
Drun_ci_db_test.ps1148 $test = $l in ExtractTestCases() variable
150 $test = $test -replace '\s+\#.*','' in ExtractTestCases() variable
151 $test = "$Group$test" in ExtractTestCases() variable
153 if($ExcludeCasesSet.Contains($test)) { in ExtractTestCases()
154 Write-Warning "$test case is excluded" in ExtractTestCases() variable
158 $test_log = $test -replace '[\./]','_' in ExtractTestCases()
163 $HashTable.Add($test, $log_path); in ExtractTestCases()
324 param($exe, $test, $log);
325 &$exe --gtest_filter=$test > $log 2>&1
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc170 test::RandomString(&r, num, &random_string); in TEST_F()
251 std::unique_ptr<WritableFileWriter>(test::GetWritableFileWriter( in ResetSourceStr()
256 new test::StringSource(control_contents_)); in ResetSourceStr()
294 for (int test = 1; test <= 100; ++test) { in TEST_P() local
308 test::RandomHumanReadableString(&rng, static_cast<int>(strLen)); in TEST_P()
310 for (int test = 1; test <= 100; ++test) { in TEST_P() local
352 new test::SeqStringSource(str, &seq_read_count_)); in ResetSourceStr()
390 for (int test = 1; test <= 100; ++test) { in TEST_P() local
392 if (s && test % 2) { in TEST_P()
413 for (int test = 1; test <= 100; ++test) { in TEST_P() local
[all …]
Dthread_list_test.cc134 for (int test = 0; test < kSimulatedHighPriThreads; ++test) { in TEST_F() local
138 for (int test = 0; test < kSimulatedLowPriThreads; ++test) { in TEST_F() local
/rocksdb-6.9/utilities/table_properties_collectors/
Dcompact_on_deletion_collector_test.cc35 for (int test = 0; test < 9; ++test) { in main() local
36 window_sizes.emplace_back(kWindowSizes[test]); in main()
37 deletion_triggers.emplace_back(kDeletionTriggers[test]); in main()
52 for (size_t test = 0; test < window_sizes.size(); ++test) { in main() local
54 const int kWindowSize = window_sizes[test]; in main()
56 kBucketSize * ((window_sizes[test] + kBucketSize - 1) / kBucketSize); in main()
57 const int kNumDeletionTrigger = deletion_triggers[test]; in main()
/rocksdb-6.9/utilities/options/
Doptions_util_test.cc33 env_.reset(new test::StringEnv(Env::Default())); in OptionsUtilTest()
35 dbname_ = test::PerThreadDBPath("options_util_test"); in OptionsUtilTest()
39 std::unique_ptr<test::StringEnv> env_;
55 test::RandomInitDBOptions(&db_opt, &rnd_); in TEST_F()
58 : test::RandomName(&rnd_, 10)); in TEST_F()
60 test::RandomInitCFOptions(&cf_opts.back(), db_opt, &rnd_); in TEST_F()
72 test::RandomInitDBOptions(&db_opt, &rnd_); in TEST_F()
84 test::RandomInitCFOptions(&cf_opts[i], db_opt, &rnd_); in TEST_F()
231 i != 0 ? test::RandomSliceTransform(&rnd_) : nullptr); in TEST_F()
233 test::RandomMergeOperator(&rnd_)); in TEST_F()
[all …]
/rocksdb-6.9/buckifier/
Dbuckify_rocksdb.py181 for test in sorted(tests):
182 match_src = [src for src in cc_files if ("/%s.c" % test) in src]
184 print(ColorString.warning("Cannot find .cc file for %s" % test))
187 print(ColorString.warning("Found more than one .cc for %s" % test))
192 is_parallel = tests[test]
194 test if not target_alias else test + "_" + target_alias
202 if test in _EXPORTED_TEST_LIBS:
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader_test.cc228 fname = test::PerThreadDBPath("CuckooReader_WhenKeyExists"); in TEST_F()
265 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
268 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
275 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
278 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
283 fname = test::PerThreadDBPath("CuckooReader_CheckIterator"); in TEST_F()
312 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
313 CheckIterator(test::Uint64Comparator()); in TEST_F()
316 CreateCuckooFileAndCheckReader(test::Uint64Comparator()); in TEST_F()
317 CheckIterator(test::Uint64Comparator()); in TEST_F()
[all …]
/rocksdb-6.9/tools/
Dldb_cmd_test.cc85 std::string dbname = test::TmpDir(); in TEST_F()
265 std::string dbname = test::TmpDir(); in TEST_F()
271 Random rnd(test::RandomSeed()); in TEST_F()
276 test::RandomString(&rnd, 100, &v); in TEST_F()
284 test::RandomString(&rnd, 100, &v); in TEST_F()
292 test::RandomString(&rnd, 100, &v); in TEST_F()
300 test::RandomString(&rnd, 100, &v); in TEST_F()
352 std::string dbname = test::TmpDir(); in TEST_F()
358 Random rnd(test::RandomSeed()); in TEST_F()
363 test::RandomString(&rnd, 100, &v); in TEST_F()
[all …]
/rocksdb-6.9/table/
Dtable_test.cc332 file_writer_.reset(test::GetWritableFileWriter(new test::StringSink(), in FinishImpl()
374 file_reader_.reset(test::GetRandomAccessFileReader(new test::StringSource( in FinishImpl()
412 file_reader_.reset(test::GetRandomAccessFileReader(new test::StringSource( in Reopen()
1248 test::StringSink* ss_rw = in CalculateFileChecksum()
1284 test::StringSink* sink_;
3341 test::StringSink sink; in TEST_F()
3343 test::GetWritableFileWriter(new test::StringSink(), "" /* don't care */)); in TEST_F()
3369 test::StringSink* ss = in TEST_F()
4052 test::StringSink* sink = new test::StringSink(); in TEST_P()
4235 test::StringSink* sink = new test::StringSink(); in TEST_P()
[all …]
/rocksdb-6.9/logging/
Denv_logger_test.cc56 const std::string EnvLoggerTest::kLogFile = test::PerThreadDBPath("log_file");
81 ASSERT_EQ(test::GetLinesCount(kLogFile, kSampleMessage), kNumIter); in TEST_F()
96 ASSERT_EQ(test::GetLinesCount(kLogFile, kSampleMessage), kNumIter); in TEST_F()
123 ASSERT_EQ(test::GetLinesCount(kLogFile, kSampleMessage), kNumIter); in TEST_F()
152 ASSERT_EQ(test::GetLinesCount(kLogFile, kSampleMessage), in TEST_F()
/rocksdb-6.9/options/
Doptions_test.cc835 test::RandomInitDBOptions(&base_options, &rnd); in TEST_F()
855 test::RandomInitDBOptions(&base_db_opts, &rnd); in TEST_F()
873 test::RandomInitCFOptions(&base_opt, options, &rnd); in TEST_F()
1116 env_.reset(new test::StringEnv(Env::Default())); in OptionsParserTest()
1121 std::unique_ptr<test::StringEnv> env_;
1587 test::RandomInitDBOptions(&base_db_opt, &rnd); in TEST_F()
1597 test::RandomInitCFOptions(&cf_opt, base_db_opt, &cf_rnd); in TEST_F()
1856 for (int test = 0; test < 5; ++test) { in TEST_F() local
1879 for (int test = 0; test < 5; ++test) { in TEST_F() local
1895 for (int test = 0; test < 5; ++test) { in TEST_F() local
[all …]
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc494 ConcurrentTest test; in TEST_F() local
495 Random rnd(test::RandomSeed()); in TEST_F()
497 test.ReadStep(&rnd); in TEST_F()
498 test.WriteStep(&rnd); in TEST_F()
503 ConcurrentTest test; in TEST_F() local
504 Random rnd(test::RandomSeed()); in TEST_F()
506 test.ReadStep(&rnd); in TEST_F()
509 test.ConcurrentWriteStep((base + j) % ConcurrentTest::K); in TEST_F()
590 const int seed = test::RandomSeed() + (run * 100); in RunConcurrentRead()
614 const int seed = test::RandomSeed() + (run * 100); in RunConcurrentInsert()
/rocksdb-6.9/env/
Denv_test.cc174 test::PerThreadDBPath(env_, "testfile"), in TEST_F()
175 test::PerThreadDBPath(env_, "testfile1")}; in TEST_F()
210 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_F()
217 test::RandomString(&rnd, kFileBytes, &expected_data); in TEST_F()
293 test::SleepingBackgroundTask sleeping_task, sleeping_task1; in TEST_P()
570 std::vector<test::SleepingBackgroundTask> tasks(10); in TEST_P()
1115 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_P()
1195 test::RandomString(&rnd, kTotalSize, &expected_data); in TEST_F()
1877 test::RandomString(&rnd, 10, &buf); in TEST_P()
2013 dbname1_ = test::PerThreadDBPath("env_fs_test1"); in TEST_P()
[all …]
/rocksdb-6.9/test_util/
Dtestharness.h22 namespace test {
40 ASSERT_PRED_FORMAT1(ROCKSDB_NAMESPACE::test::AssertStatus, s)
43 EXPECT_PRED_FORMAT1(ROCKSDB_NAMESPACE::test::AssertStatus, s)

123456