Home
last modified time | relevance | path

Searched refs:ThreadStatus (Results 1 – 25 of 35) sorted by relevance

12

/rocksdb-6.9/util/
Dthread_operation.h26 const ThreadStatus::OperationType type;
39 {ThreadStatus::OP_UNKNOWN, ""},
41 {ThreadStatus::OP_FLUSH, "Flush"}
53 {ThreadStatus::STAGE_UNKNOWN, ""},
54 {ThreadStatus::STAGE_FLUSH_RUN,
56 {ThreadStatus::STAGE_FLUSH_WRITE_L0,
60 {ThreadStatus::STAGE_COMPACTION_RUN,
70 {ThreadStatus::STAGE_MEMTABLE_ROLLBACK,
78 const ThreadStatus::StateType type;
88 {ThreadStatus::STATE_UNKNOWN, ""},
[all …]
Dthread_list_test.cc23 ThreadStatus::OP_UNKNOWN, in SimulatedBackgroundTask()
24 const ThreadStatus::StateType state_type = in SimulatedBackgroundTask()
25 ThreadStatus::STATE_UNKNOWN) in SimulatedBackgroundTask()
84 const ThreadStatus::StateType state_type_;
109 ThreadStatus::GetStateName( in TEST_F()
145 std::vector<ThreadStatus> thread_list; in TEST_F()
222 ThreadStatus::OP_FLUSH); in TEST_F()
228 ThreadStatus::OP_COMPACTION); in TEST_F()
234 ThreadStatus::OP_COMPACTION); in TEST_F()
240 ThreadStatus::OP_COMPACTION); in TEST_F()
[all …]
Dthreadpool_imp.cc285 ThreadStatus::ThreadType thread_type = ThreadStatus::NUM_THREAD_TYPES; in BGThreadWrapper()
288 thread_type = ThreadStatus::HIGH_PRIORITY; in BGThreadWrapper()
291 thread_type = ThreadStatus::LOW_PRIORITY; in BGThreadWrapper()
294 thread_type = ThreadStatus::BOTTOM_PRIORITY; in BGThreadWrapper()
297 thread_type = ThreadStatus::USER; in BGThreadWrapper()
303 assert(thread_type != ThreadStatus::NUM_THREAD_TYPES); in BGThreadWrapper()
/rocksdb-6.9/monitoring/
Dthread_status_impl.cc17 std::string ThreadStatus::GetThreadTypeName( in GetThreadTypeName()
18 ThreadStatus::ThreadType thread_type) { in GetThreadTypeName()
22 case ThreadStatus::ThreadType::LOW_PRIORITY: in GetThreadTypeName()
24 case ThreadStatus::ThreadType::USER: in GetThreadTypeName()
35 ThreadStatus::OperationType op_type) { in GetOperationName()
43 ThreadStatus::OperationStage stage) { in GetOperationStageName()
50 const std::string& ThreadStatus::GetStateName( in GetStateName()
51 ThreadStatus::StateType state_type) { in GetStateName()
72 case ThreadStatus::OP_COMPACTION: in GetOperationPropertyName()
77 case ThreadStatus::OP_FLUSH: in GetOperationPropertyName()
[all …]
Dthread_status_updater.cc67 const ThreadStatus::OperationType type) { in SetThreadOperation()
78 if (type == ThreadStatus::OP_UNKNOWN) { in SetThreadOperation()
133 ThreadStatus::OperationStage stage) { in SetThreadOperationStage()
136 return ThreadStatus::STAGE_UNKNOWN; in SetThreadOperationStage()
159 std::vector<ThreadStatus>* thread_list) { in GetThreadList()
174 ThreadStatus::OperationType op_type = ThreadStatus::OP_UNKNOWN; in GetThreadList()
175 ThreadStatus::OperationStage op_stage = ThreadStatus::STAGE_UNKNOWN; in GetThreadList()
176 ThreadStatus::StateType state_type = ThreadStatus::STATE_UNKNOWN; in GetThreadList()
184 if (op_type != ThreadStatus::OP_UNKNOWN) { in GetThreadList()
288 const ThreadStatus::StateType /*type*/) {}
[all …]
Dthread_status_updater.h69 thread_type.store(ThreadStatus::USER); in ThreadStatusData()
71 operation_type.store(ThreadStatus::OP_UNKNOWN); in ThreadStatusData()
73 state_type.store(ThreadStatus::STATE_UNKNOWN); in ThreadStatusData()
86 std::atomic<ThreadStatus::ThreadType> thread_type;
88 std::atomic<ThreadStatus::OperationType> operation_type;
90 std::atomic<ThreadStatus::OperationStage> operation_stage;
92 std::atomic<ThreadStatus::StateType> state_type;
154 ThreadStatus::OperationStage SetThreadOperationStage(
155 const ThreadStatus::OperationStage stage);
164 void SetThreadState(const ThreadStatus::StateType type);
[all …]
Dthread_status_util.h34 const Env* env, ThreadStatus::ThreadType thread_type);
60 static void SetThreadOperation(ThreadStatus::OperationType type);
62 static ThreadStatus::OperationStage SetThreadOperationStage(
63 ThreadStatus::OperationStage stage);
71 static void SetThreadState(ThreadStatus::StateType type);
77 const ThreadStatus::StateType state, int micro);
78 static void TEST_StateDelay(const ThreadStatus::StateType state);
125 ThreadStatus::OperationStage stage);
130 ThreadStatus::OperationStage prev_stage_;
Dthread_status_util.cc19 ThreadStatus::ThreadType thread_type) { in RegisterThread()
52 void ThreadStatusUtil::SetThreadOperation(ThreadStatus::OperationType op) { in SetThreadOperation()
59 if (op != ThreadStatus::OP_UNKNOWN) { in SetThreadOperation()
70 ThreadStatus::OperationStage ThreadStatusUtil::SetThreadOperationStage( in SetThreadOperationStage()
71 ThreadStatus::OperationStage stage) { in SetThreadOperationStage()
75 return ThreadStatus::STAGE_UNKNOWN; in SetThreadOperationStage()
102 void ThreadStatusUtil::SetThreadState(ThreadStatus::StateType state) { in SetThreadState()
157 ThreadStatus::OperationStage stage) { in AutoThreadOperationStageUpdater()
178 void ThreadStatusUtil::SetThreadOperation(ThreadStatus::OperationType /*op*/) {}
186 void ThreadStatusUtil::SetThreadState(ThreadStatus::StateType /*state*/) {}
[all …]
Dthread_status_util_debug.cc16 static std::atomic<int> states_delay[ThreadStatus::NUM_STATE_TYPES];
19 const ThreadStatus::StateType state, int micro) { in TEST_SetStateDelay()
23 void ThreadStatusUtil::TEST_StateDelay(const ThreadStatus::StateType state) { in TEST_StateDelay()
Dinstrumented_mutex.cc32 ThreadStatusUtil::TEST_StateDelay(ThreadStatus::STATE_MUTEX_WAIT); in LockInternal()
46 ThreadStatusUtil::TEST_StateDelay(ThreadStatus::STATE_MUTEX_WAIT); in WaitInternal()
60 ThreadStatusUtil::TEST_StateDelay(ThreadStatus::STATE_MUTEX_WAIT); in TimedWaitInternal()
/rocksdb-6.9/java/rocksjni/
Dthread_status.cc22 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetThreadTypeName( in Java_org_rocksdb_ThreadStatus_getThreadTypeName()
34 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationName( in Java_org_rocksdb_ThreadStatus_getOperationName()
47 auto str = ROCKSDB_NAMESPACE::ThreadStatus::MicrosToString( in Java_org_rocksdb_ThreadStatus_microsToStringNative()
59 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationStageName( in Java_org_rocksdb_ThreadStatus_getOperationStageName()
72 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetOperationPropertyName( in Java_org_rocksdb_ThreadStatus_getOperationPropertyName()
102 auto result = ROCKSDB_NAMESPACE::ThreadStatus::InterpretOperationProperties( in Java_org_rocksdb_ThreadStatus_interpretOperationProperties()
122 auto name = ROCKSDB_NAMESPACE::ThreadStatus::GetStateName( in Java_org_rocksdb_ThreadStatus_getStateName()
Dportal.h6420 case ROCKSDB_NAMESPACE::ThreadStatus::ThreadType::USER: in toJavaThreadType()
6439 return ThreadStatus::ThreadType::USER; in toCppThreadType()
6498 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6501 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6504 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6507 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6510 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6513 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6516 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
6519 case ROCKSDB_NAMESPACE::ThreadStatus::OperationStage:: in toJavaOperationStage()
[all …]
Denv.cc126 std::vector<ROCKSDB_NAMESPACE::ThreadStatus> thread_status; in Java_org_rocksdb_Env_getThreadList()
/rocksdb-6.9/db/
Ddb_statistics_test.cc97 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, in TEST_F()
101 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, 0); in TEST_F()
111 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, in TEST_F()
115 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, 0); in TEST_F()
Dflush_job.cc139 ThreadStatusUtil::SetThreadOperation(ThreadStatus::OP_FLUSH); in ReportStartedFlush()
141 ThreadStatus::COMPACTION_JOB_ID, in ReportStartedFlush()
152 ThreadStatus::FLUSH_BYTES_MEMTABLES, in ReportFlushInputSize()
159 ThreadStatus::FLUSH_BYTES_WRITTEN, IOSTATS(bytes_written)); in RecordFlushIOStats()
199 ThreadStatus::STAGE_FLUSH_RUN); in Run()
298 ThreadStatus::STAGE_FLUSH_WRITE_L0); in WriteLevel0Table()
Ddb_test.cc4077 std::vector<ThreadStatus> thread_list; in VerifyOperationCount()
4094 std::vector<ThreadStatus> thread_list; in TEST_F()
4184 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 0); in TEST_F()
4188 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 0); in TEST_F()
4200 VerifyOperationCount(env_, ThreadStatus::OP_FLUSH, 1); in TEST_F()
4371 std::vector<ThreadStatus> thread_list; in TEST_P()
4401 if (operation_count[ThreadStatus::OP_FLUSH] > 1 && in TEST_P()
4402 operation_count[ThreadStatus::OP_COMPACTION] > in TEST_P()
4460 std::vector<ThreadStatus> thread_list; in TEST_P()
4488 if (operation_count[ThreadStatus::OP_FLUSH] > 1 && in TEST_P()
[all …]
Dmemtable_list.cc339 ThreadStatus::STAGE_PICK_MEMTABLES_TO_FLUSH); in PickMemtablesToFlush()
368 ThreadStatus::STAGE_MEMTABLE_ROLLBACK); in RollbackMemtableFlush()
396 ThreadStatus::STAGE_MEMTABLE_INSTALL_FLUSH_RESULTS); in TryInstallMemtableFlushResults()
651 ThreadStatus::STAGE_MEMTABLE_INSTALL_FLUSH_RESULTS); in InstallMemtableAtomicFlushResults()
Dperf_context_test.cc257 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, 1U); in ProfileQueries()
276 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, 0U); in ProfileQueries()
292 ThreadStatusUtil::TEST_SetStateDelay(ThreadStatus::STATE_MUTEX_WAIT, 0U); in ProfileQueries()
Dlistener_test.cc235 std::vector<ThreadStatus> thread_list; in OnTableFileCreated()
239 if (thread_status.operation_type == ThreadStatus::OP_FLUSH || in OnTableFileCreated()
240 thread_status.operation_type == ThreadStatus::OP_COMPACTION) { in OnTableFileCreated()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc362 ThreadStatus::COMPACTION_INPUT_OUTPUT_LEVEL, in ReportStartedCompaction()
372 ThreadStatus::COMPACTION_PROP_FLAGS, in ReportStartedCompaction()
377 ThreadStatus::COMPACTION_TOTAL_INPUT_BYTES, in ReportStartedCompaction()
383 ThreadStatus::COMPACTION_BYTES_WRITTEN, 0); in ReportStartedCompaction()
385 ThreadStatus::COMPACTION_BYTES_READ, 0); in ReportStartedCompaction()
399 ThreadStatus::STAGE_COMPACTION_PREPARE); in Prepare()
568 ThreadStatus::STAGE_COMPACTION_RUN); in Run()
714 ThreadStatus::STAGE_COMPACTION_INSTALL); in Install()
846 ThreadStatus::STAGE_COMPACTION_PROCESS_KV); in ProcessKeyValueCompaction()
1122 ThreadStatus::STAGE_COMPACTION_SYNC_FILE); in FinishCompactionOutputFile()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DEnv.java144 public List<ThreadStatus> getThreadList() throws RocksDBException { in getThreadList()
165 private native ThreadStatus[] getThreadList(final long handle) in getThreadList()
DThreadStatus.java10 public class ThreadStatus { class
24 private ThreadStatus(final long threadId, in ThreadStatus() method in ThreadStatus
/rocksdb-6.9/include/rocksdb/
Dthread_status.h41 struct ThreadStatus { struct
107 ThreadStatus(const uint64_t _id, const ThreadType _thread_type, in ThreadStatus() argument
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DDefaultEnvTest.java92 final Collection<ThreadStatus> threadList = defaultEnv.getThreadList(); in threadList()
108 final List<ThreadStatus> threadList = env.getThreadList(); in threadList_integration()
/rocksdb-6.9/docs/_posts/
D2015-10-27-getthreadlist.markdown152 The `GetThreadList()` API simply returns a vector of `ThreadStatus`, each describes
153 the current status of a thread. The `ThreadStatus` structure, defined in

12