| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/ |
| H A 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);
|
| H A D | hiview_adapter.cpp | 92 ExecutorPool::Task task([dfxCode, msg]() { in ReportFault()
124 ExecutorPool::Task task([dfxCode, msg]() { in ReportDBFault()
156 ExecutorPool ::Task task([dfxCode, msg]() { in ReportCommFault()
194 ExecutorPool::Task task([dfxCode, msg]() { in ReportBehaviour()
229 ExecutorPool::Task task([dfxCode, stat]() { in ReportDatabaseStatistic()
303 std::shared_ptr<ExecutorPool> executors) in ReportTrafficStatistic()
305 ExecutorPool::Task task([dfxCode, stat]() { in ReportTrafficStatistic()
360 ExecutorPool::Task task([dfxCode, stat]() { in ReportVisitStatistic()
407 std::shared_ptr<ExecutorPool> executors) in ReportApiPerformanceStatistic()
409 ExecutorPool::Task task([dfxCode, stat]() { in ReportApiPerformanceStatistic()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| H A 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_;
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A 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_;
|
| H A D | delay_notify.h | 33 void SetExecutorPool(std::shared_ptr<ExecutorPool> pool);
47 ExecutorPool::TaskId delaySyncTaskId_ = ExecutorPool::INVALID_TASK_ID;
49 std::shared_ptr<ExecutorPool> pool_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| H A 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;
174 auto executors = std::make_shared<ExecutorPool>(1, 0);
200 auto executors = std::make_shared<ExecutorPool>(1, 1);
201 auto taskId = ExecutorPool::INVALID_TASK_ID;
207 taskId = ExecutorPool::INVALID_TASK_ID; in __anon319724040902()
211 ASSERT_EQ(taskId, ExecutorPool::INVALID_TASK_ID);
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/lifecycle/ |
| H A D | lifecycle_manager.cpp | 46 ExecutorPool::TaskId taskId = executors_->Execute([=] { in OnGot()
49 if (taskId == ExecutorPool::INVALID_TASK_ID) { in OnGot()
82 ExecutorPool::TaskId taskId = executors_->Schedule(GetTask(), LifeCyclePolicy::INTERVAL); in StartLifeCycleTimer()
83 if (taskId == ExecutorPool::INVALID_TASK_ID) { in StartLifeCycleTimer()
91 ExecutorPool::Task LifeCycleManager::GetTask() in GetTask()
113 void LifeCycleManager::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool()
|
| H A D | lifecycle_manager.h | 36 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
39 ExecutorPool::Task GetTask();
42 std::shared_ptr<ExecutorPool> executors_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.h | 60 void BindExecutor(std::shared_ptr<ExecutorPool> executors);
63 using TaskId = ExecutorPool::TaskId;
95 ExecutorPool::Task GetTask(uint32_t retry);
99 static ExecutorPool::Task GetBackupTask(
100 TaskQueue queue, std::shared_ptr<ExecutorPool> executors, const NbDelegate store);
132 std::shared_ptr<ExecutorPool> executors_;
133 TaskId delaySyncTaskId_ = ExecutorPool::INVALID_TASK_ID;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| H A D | store_cache.h | 33 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
47 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
50 std::shared_ptr<ExecutorPool> executorPool_;
|
| H A D | store_cache.cpp | 65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GetStore()
86 taskId_ = ExecutorPool::INVALID_TASK_ID; in GarbageCollect()
90 void StoreCache::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/permission/ |
| H A D | uri_permission_manager.h | 34 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
46 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
48 std::shared_ptr<ExecutorPool> executorPool_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.h | 94 int32_t Bind(std::shared_ptr<ExecutorPool> executor);
102 using Task = ExecutorPool::Task;
103 using TaskId = ExecutorPool::TaskId;
104 using Duration = ExecutorPool::Duration;
115 static constexpr ExecutorPool::Duration RETRY_INTERVAL = std::chrono::seconds(10); // second
116 static constexpr ExecutorPool::Duration LOCKED_INTERVAL = std::chrono::seconds(30); // second
117 static constexpr ExecutorPool::Duration BUSY_INTERVAL = std::chrono::seconds(180); // second
125 static ExecutorPool::Duration GetInterval(int32_t code);
161 std::shared_ptr<ExecutorPool> executor_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | kv_delegate.h | 29 KvDelegate(const std::string &path, const std::shared_ptr<ExecutorPool> &executors);
55 std::shared_ptr<ExecutorPool> executors_ = nullptr;
56 ExecutorPool::TaskId taskId_ = ExecutorPool::INVALID_TASK_ID;
|
| H A D | db_delegate.cpp | 23 ExecutorPool::TaskId DBDelegate::taskId_ = ExecutorPool::INVALID_TASK_ID;
25 std::shared_ptr<ExecutorPool> DBDelegate::executor_ = nullptr;
55 void DBDelegate::SetExecutorPool(std::shared_ptr<ExecutorPool> executor) in SetExecutorPool()
109 bool reInit, const std::string &dir, const std::shared_ptr<ExecutorPool> &executors) in GetInstance()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A 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()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| H A D | upgrade_manager.h | 33 void Init(std::shared_ptr<ExecutorPool> executors);
39 ExecutorPool::Task GetTask();
41 std::shared_ptr<ExecutorPool> executors_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| H A D | account_delegate_normal_impl.h | 37 void BindExecutor(std::shared_ptr<ExecutorPool> executors) override;
45 ExecutorPool::Task GetTask(uint32_t retry);
50 std::shared_ptr<ExecutorPool> executors_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
| H A D | task_executor.h | 21 using TaskId = ExecutorPool::TaskId;
34 void SetExecutors(std::shared_ptr<ExecutorPool> executors);
43 std::shared_ptr<ExecutorPool> pool_ = nullptr;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| H A D | communicator_context.h | 35 API_EXPORT void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
36 std::shared_ptr<ExecutorPool> GetThreadPool();
54 std::shared_ptr<ExecutorPool> executors_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/installer/ |
| H A D | installer_impl.h | 48 …Status Init(KvStoreDataService *kvStoreDataService, std::shared_ptr<ExecutorPool> executors) overr…
56 ExecutorPool::Task GetTask();
58 std::shared_ptr<ExecutorPool> executors_ {};
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A 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_;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/matrix/include/ |
| H A D | device_matrix.h | 79 void SetExecutor(std::shared_ptr<ExecutorPool> executors);
132 using TaskId = ExecutorPool::TaskId;
133 using Task = ExecutorPool::Task;
149 std::shared_ptr<ExecutorPool> executors_;
150 TaskId task_ = ExecutorPool::INVALID_TASK_ID;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/statistic/ |
| H A D | api_performance_statistic_impl.h | 29 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
32 std::shared_ptr<ExecutorPool> executors_;
|
| H A D | database_statistic_impl.h | 28 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
31 std::shared_ptr<ExecutorPool> executors_;
|