| /rocksdb-6.9/tools/ |
| D | ldb_test.py | 50 return "--db=%s" % os.path.join(self.TMP_DIR, dbName)
260 dumpFilePath = os.path.join(self.TMP_DIR, "dump1")
269 dumpFilePath = os.path.join(self.TMP_DIR, "dump2")
278 dumpFilePath = os.path.join(self.TMP_DIR, "dump3")
287 dumpFilePath = os.path.join(self.TMP_DIR, "dump4")
394 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
418 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
442 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
479 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
499 dbPath = os.path.join(self.TMP_DIR, self.DB_NAME)
[all …]
|
| D | db_crashtest.py | 307 % (child.pid, ' '.join(cmd)))
425 print("Running:" + ' '.join(cmd) + "\n") # noqa: E999 T25377293 Grandfathered in
|
| /rocksdb-6.9/tools/advisor/test/ |
| D | test_rule_parser.py | 45 ini_path = os.path.join(this_path, 'input_files/triggered_rules.ini')
50 log_path = os.path.join(this_path, 'input_files/LOG-0')
51 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
102 ini_path = os.path.join(this_path, 'input_files/test_rules.ini')
107 log_path = os.path.join(this_path, 'input_files/LOG-1')
108 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
164 ini_path = os.path.join(this_path, 'input_files/rules_err1.ini')
212 ini_path = os.path.join(self.this_path, 'input_files/rules_err2.ini')
219 ini_path = os.path.join(self.this_path, 'input_files/rules_err3.ini')
226 ini_path = os.path.join(self.this_path, 'input_files/rules_err4.ini')
|
| D | test_db_options_parser.py | 16 self.og_options = os.path.join(
25 self.generated_options = os.path.join(
|
| D | test_db_bench_runner.py | 23 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
114 options_path = os.path.join(this_path, 'input_files/OPTIONS-000005')
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/test/ |
| D | DistributedMutexTest.cpp | 62 thread.join(); in basicNThreads()
128 thread.join(); in lockWithTryAndTimedNThreads()
172 thread.join(); in combineNThreads()
227 thread.join(); in combineWithLockNThreads()
297 thread.join(); in combineWithTryLockNThreads()
398 thread.join(); in combineWithLockTryAndTimedNThreads()
637 thread.join(); in TEST()
655 thread.join(); in TEST()
687 thread.join(); in stressTryLockWithConcurrentLocks()
879 thread.join(); in TEST()
[all …]
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_options_parser.py | 25 section_type = '.'.join(section_path.split('/'))
42 section_type = '/'.join(section_type.strip().split('.'))
220 sec_type = '.'.join(option.split('.')[:-1])
255 sec_name = '.'.join(option.split('.')[:-1])
274 file_path = os.path.join(this_path, file_name)
|
| D | db_stats_fetcher.py | 265 self._get_string_in_quotes(','.join(statistics)),
278 self._get_string_in_quotes(','.join(statistics))
318 self._get_string_in_quotes(','.join(entities)),
319 self._get_string_in_quotes(','.join(keys)),
331 self._get_string_in_quotes(','.join(keys)) + ' ' +
|
| D | ini_parser.py | 65 value = "=".join(line.split('=')[1:])
|
| /rocksdb-6.9/buckifier/ |
| D | buckify_rocksdb.py | 66 cc_files.append(os.path.join(root, filename))
68 cc_files.append(os.path.join(root, filename))
219 os.path.join(script_dir, "../"))
|
| D | util.py | 31 return "".join(
34 return "".join(
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_transaction_test.cc | 192 t[i].join(); in TEST()
444 t1.join(); in SnapshotConcurrentAccessTestInternal()
445 t2.join(); in SnapshotConcurrentAccessTestInternal()
473 t1.join(); in SnapshotConcurrentAccessTestInternal()
474 t2.join(); in SnapshotConcurrentAccessTestInternal()
1403 t1.join(); in TEST_P()
1404 t2.join(); in TEST_P()
1461 t1.join(); in TEST_P()
1462 t2.join(); in TEST_P()
1641 read_thread.join(); in TEST_P()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_write_test.cc | 130 t.join(); in TEST_P()
181 threads[i].join(); in TEST_P()
310 t.join(); in TEST_P()
|
| D | db_flush_test.cc | 212 t.join(); in TEST_F()
351 drop_cf_thr.join(); in TEST_F()
438 t1.join(); in TEST_F()
628 user_thread.join(); in TEST_P()
739 drop_cf_thr.join(); in TEST_P()
|
| D | forward_iterator_bench.cc | 188 thread_.join(); in ~Reader()
260 ~Writer() { thread_.join(); } in ~Writer()
309 thread_.join(); in ~StatsThread()
|
| D | log_test.cc | 846 log_reader_thread.join(); in TEST_P()
847 log_writer_thread.join(); in TEST_P()
890 log_reader_thread.join(); in TEST_P()
891 log_writer_thread.join(); in TEST_P()
|
| D | external_sst_file_test.cc | 1026 t.join(); in TEST_F()
1070 t.join(); in TEST_F()
1364 bg_addfile.join(); in TEST_F()
1365 bg_compact.join(); in TEST_F()
1453 t.join(); in TEST_F()
1727 writer.join(); in TEST_F()
2010 bg_block_put.join(); in TEST_F()
2539 ingest_thread.join(); in TEST_P()
2617 ingest_thread.join(); in TEST_P()
2687 ingest_thread.join(); in TEST_P()
[all …]
|
| D | column_family_test.cc | 613 thread.join(); in TEST_P()
1472 t.join(); in TEST_P()
1567 threads.join(); in TEST_P()
1666 threads.join(); in TEST_P()
1774 threads.join(); in TEST_P()
1775 threads1.join(); in TEST_P()
1868 threads.join(); in TEST_P()
1961 threads.join(); in TEST_P()
2464 t.join(); in TEST_P()
2542 drop_cf_thread.join(); in TEST_P()
[all …]
|
| D | db_memtable_test.cc | 257 write_thread1.join(); in TEST_F()
258 write_thread2.join(); in TEST_F()
|
| /rocksdb-6.9/util/ |
| D | dynamic_bloom_test.cc | 252 threads.back().join(); in TEST_F()
276 threads.back().join(); in TEST_F()
303 threads.back().join(); in TEST_F()
|
| D | repeatable_thread.h | 50 thread_.join(); in cancel()
|
| /rocksdb-6.9/build_tools/ |
| D | amalgamate.py | 40 samedir = path.join(path.dirname(abs_path), name)
44 include_path = path.join(include_path, name)
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_test.cc | 454 t.join(); in TEST_F()
575 t.join(); in TEST_F()
657 t.join(); in TEST_F()
721 thread.join(); in TEST_F()
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 494 thread.join(); in RunThreads()
518 thread.join(); in RunThreads()
550 thread.join(); in RunThreads()
|
| /rocksdb-6.9/port/win/ |
| D | win_thread.h | 107 void join();
|