Home
last modified time | relevance | path

Searched refs:op_type (Results 1 – 7 of 7) sorted by relevance

/rocksdb-6.9/monitoring/
Dthread_status_impl.cc35 ThreadStatus::OperationType op_type) { in GetOperationName() argument
36 if (op_type < 0 || op_type >= NUM_OP_TYPES) { in GetOperationName()
39 return global_operation_table[op_type].name; in GetOperationName()
69 ThreadStatus::OperationType op_type, int i) { in GetOperationPropertyName() argument
71 switch (op_type) { in GetOperationPropertyName()
88 ThreadStatus::OperationType op_type, const uint64_t* op_properties) { in InterpretOperationProperties() argument
90 switch (op_type) { in InterpretOperationProperties()
103 if (op_type == OP_COMPACTION && i == COMPACTION_INPUT_OUTPUT_LEVEL) { in InterpretOperationProperties()
107 } else if (op_type == OP_COMPACTION && i == COMPACTION_PROP_FLAGS) { in InterpretOperationProperties()
113 {GetOperationPropertyName(op_type, i), op_properties[i]}); in InterpretOperationProperties()
Dthread_status_updater.cc174 ThreadStatus::OperationType op_type = ThreadStatus::OP_UNKNOWN; in GetThreadList() local
182 op_type = thread_data->operation_type.load(std::memory_order_acquire); in GetThreadList()
184 if (op_type != ThreadStatus::OP_UNKNOWN) { in GetThreadList()
199 iter != cf_info_map_.end() ? iter->second.cf_name : "", op_type, in GetThreadList()
/rocksdb-6.9/include/rocksdb/
Drate_limiter.h67 Statistics* stats, OpType op_type) { in Request() argument
68 if (IsRateLimited(op_type)) { in Request()
79 RateLimiter::OpType op_type);
94 virtual bool IsRateLimited(OpType op_type) { in IsRateLimited() argument
96 op_type == RateLimiter::OpType::kRead) || in IsRateLimited()
98 op_type == RateLimiter::OpType::kWrite)) { in IsRateLimited()
Dthread_status.h167 static const std::string& GetOperationName(OperationType op_type);
176 static const std::string& GetOperationPropertyName(OperationType op_type,
182 OperationType op_type, const uint64_t* op_properties);
/rocksdb-6.9/util/
Drate_limiter.cc21 RateLimiter::OpType op_type) { in RequestToken() argument
22 if (io_priority < Env::IO_TOTAL && IsRateLimited(op_type)) { in RequestToken()
31 Request(bytes, io_priority, stats, op_type); in RequestToken()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc1968 enum OperationType op_type = kOthers) { in FinishedOps() argument
1976 if (hist_.find(op_type) == hist_.end()) in FinishedOps()
1979 hist_.insert({op_type, std::move(hist_temp)}); in FinishedOps()
1981 hist_[op_type]->Add(micros); in FinishedOps()
/rocksdb-6.9/db/
Ddb_test.cc4074 void VerifyOperationCount(Env* env, ThreadStatus::OperationType op_type, in VerifyOperationCount() argument
4080 if (thread.operation_type == op_type) { in VerifyOperationCount()