Home
last modified time | relevance | path

Searched refs:Thread (Results 1 – 25 of 65) sorted by relevance

123

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DStatisticsCollector.java71 if(Thread.currentThread().isInterrupted()) { in collectStatistics()
98 Thread.sleep(_statsCollectionInterval); in collectStatistics()
101 Thread.currentThread().interrupt(); in collectStatistics()
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_test.h54 std::list<port::Thread> SpawnThreads(const size_t n, const T& fn) { in SpawnThreads()
55 std::list<port::Thread> threads; in SpawnThreads()
57 port::Thread th(fn); in SpawnThreads()
64 void Join(std::list<port::Thread>&& threads) { in Join()
Dpersistent_cache_bench.cc124 std::list<port::Thread> threads; in CacheTierBenchmark()
260 void Spawn(const size_t n, std::list<port::Thread>* threads, in Spawn()
268 void Join(std::list<port::Thread>* threads) { in Join()
Dblock_cache_tier.h144 ROCKSDB_NAMESPACE::port::Thread insert_th_; // Insert thread
/rocksdb-6.9/db/
Dforward_iterator_bench.cc95 thread_ = port::Thread(&Reader::run, this); in Reader()
195 ROCKSDB_NAMESPACE::port::Thread thread_;
209 void start() { thread_ = port::Thread(&Writer::run, this); } in start()
266 ROCKSDB_NAMESPACE::port::Thread thread_;
316 ROCKSDB_NAMESPACE::port::Thread thread_;
Ddb_write_test.cc46 std::vector<port::Thread> threads; in TEST_P()
143 std::vector<port::Thread> threads; in TEST_P()
161 threads.push_back(port::Thread( in TEST_P()
Ddb_flush_test.cc196 port::Thread t([&]() { in TEST_F()
339 port::Thread drop_cf_thr([&]() { in TEST_F()
424 auto t1 = port::Thread([&]() { in TEST_F()
620 port::Thread user_thread([&]() { in TEST_P()
726 port::Thread drop_cf_thr([&]() { in TEST_P()
Dlog_test.cc827 port::Thread log_writer_thread([&]() { in TEST_P()
841 port::Thread log_reader_thread([&]() { in TEST_P()
870 port::Thread log_writer_thread([&]() { in TEST_P()
885 port::Thread log_reader_thread([&]() { in TEST_P()
Dexternal_sst_file_test.cc1020 std::vector<port::Thread> sst_writer_threads; in TEST_F()
1063 std::vector<port::Thread> add_file_threads; in TEST_F()
1338 ROCKSDB_NAMESPACE::port::Thread bg_compact([&]() { in TEST_F()
1344 ROCKSDB_NAMESPACE::port::Thread bg_addfile([&]() { in TEST_F()
1434 std::vector<port::Thread> threads; in TEST_F()
1720 port::Thread writer([&]() { Put("bar", "v2"); }); in TEST_F()
1980 ROCKSDB_NAMESPACE::port::Thread bg_block_put([&]() { in TEST_F()
2517 port::Thread ingest_thread([&]() { in TEST_P()
2605 port::Thread ingest_thread([&]() { in TEST_P()
2675 port::Thread ingest_thread([&]() { in TEST_P()
[all …]
Dcolumn_family_test.cc605 ROCKSDB_NAMESPACE::port::Thread thread( in TEST_P()
1446 std::vector<port::Thread> threads; in TEST_P()
1558 ROCKSDB_NAMESPACE::port::Thread threads([&] { in TEST_P()
1649 ROCKSDB_NAMESPACE::port::Thread threads([&] { in TEST_P()
1745 ROCKSDB_NAMESPACE::port::Thread threads([&] { in TEST_P()
1765 ROCKSDB_NAMESPACE::port::Thread threads1([&] { in TEST_P()
1846 ROCKSDB_NAMESPACE::port::Thread threads([&] { in TEST_P()
1941 ROCKSDB_NAMESPACE::port::Thread threads([&] { in TEST_P()
2438 std::vector<port::Thread> threads; in TEST_P()
2537 ROCKSDB_NAMESPACE::port::Thread drop_cf_thread(DropSingleColumnFamily, this, in TEST_P()
[all …]
Ddb_memtable_test.cc235 ROCKSDB_NAMESPACE::port::Thread write_thread1([&]() { in TEST_F()
246 ROCKSDB_NAMESPACE::port::Thread write_thread2([&]() { in TEST_F()
Ddb_dynamic_level_test.cc251 ROCKSDB_NAMESPACE::port::Thread thread([this] { in TEST_F()
460 ROCKSDB_NAMESPACE::port::Thread t([&]() { in TEST_F()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_transaction_test.cc160 ROCKSDB_NAMESPACE::port::Thread t[t_cnt + 1]; in TEST()
167 t[0] = ROCKSDB_NAMESPACE::port::Thread([&]() { in TEST()
440 ROCKSDB_NAMESPACE::port::Thread t1( in SnapshotConcurrentAccessTestInternal()
442 ROCKSDB_NAMESPACE::port::Thread t2( in SnapshotConcurrentAccessTestInternal()
469 ROCKSDB_NAMESPACE::port::Thread t1( in SnapshotConcurrentAccessTestInternal()
471 ROCKSDB_NAMESPACE::port::Thread t2( in SnapshotConcurrentAccessTestInternal()
1374 ROCKSDB_NAMESPACE::port::Thread t1([&]() { in TEST_P()
1387 ROCKSDB_NAMESPACE::port::Thread t2([&]() { in TEST_P()
1423 ROCKSDB_NAMESPACE::port::Thread t1([&]() { in TEST_P()
1431 ROCKSDB_NAMESPACE::port::Thread t2([&]() { in TEST_P()
[all …]
/rocksdb-6.9/memtable/
Dmemtablerep_bench.cc417 std::vector<port::Thread> threads; in Run()
448 virtual void RunThreads(std::vector<port::Thread>* threads,
469 void RunThreads(std::vector<port::Thread>* /*threads*/, uint64_t* bytes_written, in RunThreads() argument
485 void RunThreads(std::vector<port::Thread>* threads, uint64_t* bytes_written, in RunThreads()
509 void RunThreads(std::vector<port::Thread>* threads, uint64_t* bytes_written, in RunThreads()
536 void RunThreads(std::vector<port::Thread>* threads, uint64_t* bytes_written, in RunThreads()
/rocksdb-6.9/logging/
Denv_logger_test.cc137 std::vector<port::Thread> threads; in TEST_F()
141 threads.push_back(port::Thread(cb)); in TEST_F()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc440 ROCKSDB_NAMESPACE::port::Thread t([&]() { in TEST_F()
565 ROCKSDB_NAMESPACE::port::Thread t([&]() { in TEST_F()
645 ROCKSDB_NAMESPACE::port::Thread t([&]() { in TEST_F()
716 port::Thread thread([this]() { ASSERT_OK(Put("key2", "val2")); }); in TEST_F()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DStatisticsCollectorTest.java46 Thread.sleep(1000); in statisticsCollector()
/rocksdb-6.9/cmake/modules/
DFindTBB.cmake2 # Find the Thread Building Blocks library and includes
/rocksdb-6.9/util/
Dthreadpool_imp.cc126 std::vector<port::Thread> bgthreads_;
337 port::Thread p_t(&BGThreadWrapper, in StartBGThreads()
Drepeatable_thread.h146 port::Thread thread_;
/rocksdb-6.9/CMakeFiles/
DCMakeConfigureLog.yaml65 Thread model: posix
77 Thread model: posix
89 Thread model: posix
121 Thread model: posix
137 Thread model: posix
182 ignore line: [Thread model: posix]
198 ignore line: [Thread model: posix]
274 Thread model: posix
289 Thread model: posix
332 ignore line: [Thread model: posix]
[all …]
/rocksdb-6.9/file/
Ddelete_scheduler.h130 std::unique_ptr<port::Thread> bg_thread_;
Dsst_file_manager_impl.h177 std::unique_ptr<port::Thread> bg_thread_;
/rocksdb-6.9/port/
Dport_posix.h164 using Thread = std::thread; variable
/rocksdb-6.9/docs/_posts/
D2017-07-25-rocksdb-5-6-1-released.markdown9 … pool to have zero threads. See https://github.com/facebook/rocksdb/wiki/Thread-Pool for more deta…

123