| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/ |
| D | hiview_adapter.h | 40 …static void ReportFault(int dfxCode, const FaultMsg &msg, std::shared_ptr<ExecutorPool> executors);
41 …static void ReportDBFault(int dfxCode, const DBFaultMsg &msg, std::shared_ptr<ExecutorPool> execut…
42 …static void ReportCommFault(int dfxCode, const CommFaultMsg &msg, std::shared_ptr<ExecutorPool> ex…
43 … ReportVisitStatistic(int dfxCode, const VisitStat &stat, std::shared_ptr<ExecutorPool> executors);
44 …ortTrafficStatistic(int dfxCode, const TrafficStat &stat, std::shared_ptr<ExecutorPool> executors);
45 … ReportDatabaseStatistic(int dfxCode, const DbStat &stat, std::shared_ptr<ExecutorPool> executors);
47 std::shared_ptr<ExecutorPool> executors);
48 …static void ReportBehaviour(int dfxCode, const BehaviourMsg &msg, std::shared_ptr<ExecutorPool> ex…
49 …rtUdmfBehaviour(int dfxCode, const UdmfBehaviourMsg &msg, std::shared_ptr<ExecutorPool> executors);
50 static void StartTimerThread(std::shared_ptr<ExecutorPool> executors);
|
| D | hiview_adapter.cpp | 90 void HiViewAdapter::ReportFault(int dfxCode, const FaultMsg &msg, std::shared_ptr<ExecutorPool> exe… in ReportFault()
92 ExecutorPool::Task task([dfxCode, msg]() { in ReportFault()
104 void HiViewAdapter::ReportDBFault(int dfxCode, const DBFaultMsg &msg, std::shared_ptr<ExecutorPool>… in ReportDBFault()
106 ExecutorPool::Task task([dfxCode, msg]() { in ReportDBFault()
118 …ter::ReportCommFault(int dfxCode, const CommFaultMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportCommFault()
120 ExecutorPool ::Task task([dfxCode, msg]() { in ReportCommFault()
138 …ter::ReportBehaviour(int dfxCode, const BehaviourMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportBehaviour()
140 ExecutorPool::Task task([dfxCode, msg]() { in ReportBehaviour()
155 …::ReportDatabaseStatistic(int dfxCode, const DbStat &stat, std::shared_ptr<ExecutorPool> executors) in ReportDatabaseStatistic()
157 ExecutorPool::Task task([dfxCode, stat]() { in ReportDatabaseStatistic()
[all …]
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| D | task_executor.h | 21 using TaskId = ExecutorPool::TaskId;
24 static constexpr TaskId INVALID_TASK_ID = ExecutorPool::INVALID_TASK_ID;
27 std::shared_ptr<ExecutorPool> GetExecutor();
28 void SetExecutor(std::shared_ptr<ExecutorPool> executor);
36 std::shared_ptr<ExecutorPool> pool_;
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| D | task_executor.h | 29 class ExecutorPool {
31 ExecutorPool(size_t max, size_t min) in ExecutorPool() function
34 ~ExecutorPool() in ~ExecutorPool()
74 std::shared_ptr<ExecutorPool> GetExecutor();
75 void SetExecutor(std::shared_ptr<ExecutorPool> executor);
80 std::shared_ptr<ExecutorPool> pool_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| D | store_cache.h | 38 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
41 static std::shared_ptr<ExecutorPool> executorPool_;
|
| D | store_cache.cpp | 26 std::shared_ptr<ExecutorPool> StoreCache::executorPool_ = std::make_shared<ExecutorPool>(2, 1);
51 if (taskId_ == ExecutorPool::INVALID_TASK_ID) { in GetStore()
72 taskId_ = ExecutorPool::INVALID_TASK_ID; in GarbageCollect()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| D | communicator_context.h | 26 API_EXPORT void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
27 std::shared_ptr<ExecutorPool> GetThreadPool();
37 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| D | task_executor.cpp | 21 pool_ = std::make_shared<ExecutorPool>(MAX_THREADS, MIN_THREADS); in TaskExecutor()
35 std::shared_ptr<ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor()
41 void TaskExecutor::SetExecutor(std::shared_ptr<ExecutorPool> executor) in SetExecutor()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| D | sync_manager.h | 66 int32_t Bind(std::shared_ptr<ExecutorPool> executor);
72 using Task = ExecutorPool::Task;
73 using TaskId = ExecutorPool::TaskId;
74 using Duration = ExecutorPool::Duration;
77 static constexpr ExecutorPool::Duration RETRY_INTERVAL = std::chrono::seconds(10); // second
78 static constexpr ExecutorPool::Duration LOCKED_INTERVAL = std::chrono::seconds(30); // second
94 std::shared_ptr<ExecutorPool> executor_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| D | upgrade_manager.h | 33 void Init(std::shared_ptr<ExecutorPool> executors);
42 ExecutorPool::Task GetTask();
44 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| D | account_delegate_normal_impl.h | 35 void BindExecutor(std::shared_ptr<ExecutorPool> executors) override;
40 ExecutorPool::Task GetTask(uint32_t retry);
44 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| D | kv_delegate.h | 29 KvDelegate(const std::string &path, const std::shared_ptr<ExecutorPool> &executors);
49 std::shared_ptr<ExecutorPool> executors_ = nullptr;
50 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/lifecycle/ |
| D | lifecycle_manager.cpp | 26 std::shared_ptr<ExecutorPool> LifeCycleManager::executorPool_ = std::make_shared<ExecutorPool>(2, 1…
62 ExecutorPool::TaskId taskId = in DeleteOnSchedule()
64 if (taskId == ExecutorPool::INVALID_TASK_ID) { in DeleteOnSchedule()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| D | communicator_context.cpp | 25 void CommunicatorContext::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool()
30 std::shared_ptr<ExecutorPool> CommunicatorContext::GetThreadPool() in GetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/uninstaller/ |
| D | uninstaller_impl.h | 47 …Status Init(KvStoreDataService *kvStoreDataService, std::shared_ptr<ExecutorPool> executors) overr…
55 ExecutorPool::Task GetTask();
57 std::shared_ptr<ExecutorPool> executors_ {};
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/statistic/ |
| D | visit_statistic_impl.h | 28 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
31 std::shared_ptr<ExecutorPool> executors_;
|
| D | traffic_statistic_impl.h | 28 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
31 std::shared_ptr<ExecutorPool> executors_;
|
| D | database_statistic_impl.h | 28 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
31 std::shared_ptr<ExecutorPool> executors_;
|
| D | api_performance_statistic_impl.h | 29 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
32 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| D | executor_pool_test.cpp | 37 static std::shared_ptr<ExecutorPool> executorPool_;
46 std::shared_ptr<ExecutorPool> ExecutorPoolTest::executorPool_ = std::make_shared<ExecutorPool>(12, …
90 ASSERT_NE(taskId, ExecutorPool::INVALID_TASK_ID);
109 std::set<ExecutorPool::TaskId> ids;
175 auto executors = std::make_shared<ExecutorPool>(1, 0);
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/ |
| D | task_executor.cpp | 34 std::shared_ptr<TaskExecutor::ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor()
39 void TaskExecutor::SetExecutor(std::shared_ptr<TaskExecutor::ExecutorPool> executor) in SetExecutor()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/behaviour/ |
| D | behaviour_reporter_impl.h | 29 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
32 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| D | user_delegate.h | 38 API_EXPORT void Init(const std::shared_ptr<ExecutorPool>& executors);
63 ExecutorPool::Task GeTask();
66 std::shared_ptr<ExecutorPool> executors_;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/fault/ |
| D | communication_fault_impl.h | 37 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
40 std::shared_ptr<ExecutorPool> executors_;
|
| D | database_fault_impl.h | 36 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
39 std::shared_ptr<ExecutorPool> executors_;
|