| /rocksdb-6.9/util/ |
| D | threadpool_imp.cc | 66 void BGThread(size_t thread_id);
86 bool IsLastExcessiveThread(size_t thread_id) const { in IsLastExcessiveThread()
87 return HasExcessiveThread() && thread_id == bgthreads_.size() - 1; in IsLastExcessiveThread()
90 bool IsExcessiveThread(size_t thread_id) const { in IsExcessiveThread()
91 return static_cast<int>(thread_id) >= total_threads_limit_; in IsExcessiveThread()
187 void ThreadPoolImpl::Impl::BGThread(size_t thread_id) { in BGThread() argument
196 (queue_.empty() || IsExcessiveThread(thread_id))) { in BGThread()
208 if (IsLastExcessiveThread(thread_id)) { in BGThread()
275 : thread_pool_(thread_pool), thread_id_(thread_id) {} in BGThreadMetadata()
280 size_t thread_id = meta->thread_id_; in BGThreadWrapper() local
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_updater.h | 68 thread_id.store(0); in ThreadStatusData()
85 std::atomic<uint64_t> thread_id; member
119 void SetThreadID(uint64_t thread_id);
122 void RegisterThread(ThreadStatus::ThreadType ttype, uint64_t thread_id);
|
| D | thread_status_updater.cc | 19 uint64_t thread_id) { in RegisterThread() argument
23 thread_status_data_->thread_id = thread_id; in RegisterThread()
167 auto thread_id = thread_data->thread_id.load(std::memory_order_relaxed); in GetThreadList() local
197 thread_id, thread_type, in GetThreadList()
|
| /rocksdb-6.9/test_util/ |
| D | sync_point_impl.cc | 97 auto thread_id = std::this_thread::get_id(); in Process() local
102 marked_thread_id_.emplace(marked_point, thread_id); in Process()
106 if (DisabledByMarker(point, thread_id)) { in Process()
112 if (DisabledByMarker(point, thread_id)) { in Process()
|
| D | sync_point_impl.h | 66 std::thread::id thread_id) { in DisabledByMarker()
69 thread_id != marked_point_iter->second; in DisabledByMarker()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | thread_status.h | 113 : thread_id(_id), in ThreadStatus()
127 const uint64_t thread_id; member
|
| D | listener.h | 178 uint64_t thread_id; member
220 uint64_t thread_id; member
|
| /rocksdb-6.9/env/ |
| D | env_posix.cc | 247 uint64_t thread_id = 0; in gettid() local
248 memcpy(&thread_id, &tid, std::min(sizeof(thread_id), sizeof(tid))); in gettid()
249 return thread_id; in gettid()
|
| D | env_hdfs.cc | 316 const uint64_t thread_id = (*gettid_)(); in Logv() local
348 static_cast<long long unsigned int>(thread_id)); in Logv()
|
| /rocksdb-6.9/logging/ |
| D | posix_logger.h | 88 const uint64_t thread_id = (*gettid_)(); in Logv() local
120 static_cast<long long unsigned int>(thread_id)); in Logv()
|
| D | env_logger.h | 84 const uint64_t thread_id = env_->GetThreadID(); in Logv() local
110 static_cast<long long unsigned int>(thread_id)); in Logv()
|
| /rocksdb-6.9/port/win/ |
| D | win_logger.cc | 100 const uint64_t thread_id = (*gettid_)(); in Logv() local
129 static_cast<long long unsigned int>(thread_id)); in Logv()
|
| D | env_win.cc | 1270 uint64_t thread_id = GetCurrentThreadId(); in gettid() local
1271 return thread_id; in gettid()
|
| /rocksdb-6.9/db/ |
| D | listener_test.cc | 135 ASSERT_EQ(db->GetEnv()->GetThreadID(), ci.thread_id); in OnCompactionCompleted()
136 ASSERT_GT(ci.thread_id, 0U); in OnCompactionCompleted()
234 uint64_t thread_id = env_->GetThreadID(); in OnTableFileCreated() local
241 if (thread_id == thread_status.thread_id) { in OnTableFileCreated()
287 ASSERT_EQ(db->GetEnv()->GetThreadID(), info.thread_id); in OnFlushCompleted()
288 ASSERT_GT(info.thread_id, 0U); in OnFlushCompleted()
|
| D | flush_job.cc | 460 info->thread_id = db_options_.env->GetThreadID(); in GetFlushJobInfo()
|
| D | external_sst_file_test.cc | 1044 int thread_id = thread_num.fetch_add(1); in TEST_F() local
1045 int file_idx = (thread_id / 2) * 2; in TEST_F()
1047 bool move_file = (thread_id % 3 == 0); in TEST_F()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | compaction_job_info.cc | 71 return static_cast<jlong>(compact_job_info->thread_id); in Java_org_rocksdb_CompactionJobInfo_threadId()
|
| D | portal.h | 6687 static_cast<jlong>(thread_status->thread_id), in construct()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-10-27-getthreadlist.markdown | 158 const uint64_t thread_id;
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 9793 DWORD thread_id; in CreateThread() local
9801 &thread_id); // Need a valid pointer for the call to work under Win98. in CreateThread()
9917 static void OnThreadExit(DWORD thread_id) { in OnThreadExit() argument
9918 GTEST_CHECK_(thread_id != 0) << ::GetLastError(); in OnThreadExit()
9927 thread_to_thread_locals->find(thread_id); in OnThreadExit()
9955 static void StartWatcherThreadFor(DWORD thread_id) { in StartWatcherThreadFor() argument
9960 thread_id); in StartWatcherThreadFor()
9969 reinterpret_cast<LPVOID>(new ThreadIdAndHandle(thread_id, thread)), in StartWatcherThreadFor()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 616 info.thread_id = env_->GetThreadID(); in NotifyOnFlushBegin()
1169 info.thread_id = env_->GetThreadID(); in NotifyOnCompactionBegin()
3048 compaction_job_info->thread_id = env_->GetThreadID(); in BuildCompactionJobInfo()
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 1932 ts.thread_id, in PrintThreadStatus()
|