| /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> executors);
42 static void ReportCommFault(int dfxCode, const CommFaultMsg &msg, std::shared_ptr<ExecutorPool> executors);
43 static void ReportVisitStatistic(int dfxCode, const VisitStat &stat, std::shared_ptr<ExecutorPool> executors);
44 static void ReportTrafficStatistic(int dfxCode, const TrafficStat &stat, std::shared_ptr<ExecutorPool> executors);
45 static void 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> executors);
49 static void ReportUdmfBehaviour(int dfxCode, const UdmfBehaviourMsg &msg, std::shared_ptr<ExecutorPool> executors);
50 static void StartTimerThread(std::shared_ptr<ExecutorPool> executors);
[all...] |
| H A D | hiview_adapter.cpp | 90 void HiViewAdapter::ReportFault(int dfxCode, const FaultMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportFault() argument
119 executors->Execute(std::move(task)); in ReportFault()
122 void HiViewAdapter::ReportDBFault(int dfxCode, const DBFaultMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportDBFault() argument
151 executors->Execute(std::move(task)); in ReportDBFault()
154 void HiViewAdapter::ReportCommFault(int dfxCode, const CommFaultMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportCommFault() argument
189 executors->Execute(std::move(task)); in ReportCommFault()
192 void HiViewAdapter::ReportBehaviour(int dfxCode, const BehaviourMsg &msg, std::shared_ptr<ExecutorPool> executors) in ReportBehaviour() argument
224 executors->Execute(std::move(task)); in ReportBehaviour()
227 void HiViewAdapter::ReportDatabaseStatistic(int dfxCode, const DbStat &stat, std::shared_ptr<ExecutorPool> executors) in ReportDatabaseStatistic() argument
235 executors in ReportDatabaseStatistic()
302 ReportTrafficStatistic(int dfxCode, const TrafficStat &stat, std::shared_ptr<ExecutorPool> executors) ReportTrafficStatistic() argument
358 ReportVisitStatistic(int dfxCode, const VisitStat &stat, std::shared_ptr<ExecutorPool> executors) ReportVisitStatistic() argument
406 ReportApiPerformanceStatistic(int dfxCode, const ApiPerformanceStat &stat, std::shared_ptr<ExecutorPool> executors) ReportApiPerformanceStatistic() argument
432 ReportUdmfBehaviour( int dfxCode, const UdmfBehaviourMsg &msg, std::shared_ptr<ExecutorPool> executors) ReportUdmfBehaviour() argument
508 StartTimerThread(std::shared_ptr<ExecutorPool> executors) StartTimerThread() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/dfx/ |
| H A D | reporter.h | 43 void SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
45 executors_ = executors; in SetThreadPool()
46 if (executors != nullptr) { in SetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/fault/ |
| H A D | communication_fault_impl.cpp | 25 void CommunicationFaultImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | service_fault_impl.cpp | 25 void ServiceFaultImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | runtime_fault_impl.cpp | 25 void RuntimeFaultImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | database_fault_impl.cpp | 36 void DatabaseFaultImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
38 executors_ = executors; in SetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/statistic/ |
| H A D | traffic_statistic_impl.cpp | 25 void TrafficStatisticImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | visit_statistic_impl.cpp | 25 void VisitStatisticImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | api_performance_statistic_impl.cpp | 25 void ApiPerformanceStatisticImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | database_statistic_impl.cpp | 25 void DatabaseStatisticImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
27 executors_ = executors; in SetThreadPool()
|
| H A D | traffic_statistic_impl.h | 28 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| H A D | executor_pool_test.cpp | 174 auto executors = std::make_shared<ExecutorPool>(1, 0); in HWTEST_F() local
182 executors->Schedule(std::chrono::milliseconds(SHORT_INTERVAL * 2), delayTask); in HWTEST_F()
184 executors->Execute(task); in HWTEST_F()
200 auto executors = std::make_shared<ExecutorPool>(1, 1); in HWTEST_F() local
203 taskId = executors->Schedule( in HWTEST_F()
204 [executors, &taskId, &flag]() { in HWTEST_F()
206 executors->Remove(taskId, false); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/behaviour/ |
| H A D | behaviour_reporter_impl.cpp | 31 void BehaviourReporterImpl::SetThreadPool(std::shared_ptr<ExecutorPool> executors) in SetThreadPool() argument
33 executors_ = executors; in SetThreadPool()
|
| H A D | behaviour_reporter_impl.h | 29 void SetThreadPool(std::shared_ptr<ExecutorPool> executors);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_account_observer.h | 38 std::shared_ptr<ExecutorPool> executors) in KvStoreAccountObserver()
39 : kvStoreDataService_(kvStoreDataService), executors_(executors) in KvStoreAccountObserver()
37 KvStoreAccountObserver(KvStoreDataService &kvStoreDataService, std::shared_ptr<ExecutorPool> executors) KvStoreAccountObserver() argument
|
| H A D | task_manager.cpp | 18 TaskManager::TaskManager(std::shared_ptr<ExecutorPool> executors) : executors_(executors) in TaskManager() argument
|
| H A D | kvstore_meta_manager.cpp | 244 auto backup = [executors = executors_, queue = std::make_shared<SafeBlockQueue<Backup>>(MAX_TASK_COUNT), fullName]( in GetMetaKvStore()
252 executors->Schedule(std::chrono::hours(RETRY_INTERVAL), GetBackupTask(queue, executors, store)); in GetMetaKvStore()
260 TaskQueue queue, std::shared_ptr<ExecutorPool> executors, const NbDelegate store) in GetBackupTask()
262 return [queue, executors, store]() { in GetBackupTask()
268 executors->Schedule(std::chrono::hours(RETRY_INTERVAL), GetBackupTask(queue, executors, store)); in GetBackupTask()
445 void KvStoreMetaManager::BindExecutor(std::shared_ptr<ExecutorPool> executors)
447 executors_ = executors;
259 GetBackupTask( TaskQueue queue, std::shared_ptr<ExecutorPool> executors, const NbDelegate store) GetBackupTask() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/security/ |
| H A D | security.h | 37 explicit Security(std::shared_ptr<ExecutorPool> executors) : executors_(executors) {}; in Security() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | task_executor.cpp | 68 void TaskExecutor::SetExecutors(std::shared_ptr<ExecutorPool> executors) in SetExecutors() argument
72 pool_ = std::move(executors); in SetExecutors()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| H A D | store_cache.cpp | 90 void StoreCache::SetThreadPool(std::shared_ptr<ExecutorPool> executors)
in SetThreadPool() argument
92 executorPool_ = executors;
in SetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/test/unittest/ |
| H A D | kvstore_data_service_clear_test.cpp | 129 auto executors = std::make_shared<ExecutorPool>(2, 1);
in HWTEST_F() local
131 KvStoreMetaManager::GetInstance().BindExecutor(executors);
in HWTEST_F()
133 DmAdapter::GetInstance().Init(executors);
in HWTEST_F()
|
| H A D | session_manager_test.cpp | 65 auto executors = std::make_shared<ExecutorPool>(12, 5);
in SetUpTestCase() local
69 KvStoreMetaManager::GetInstance().BindExecutor(executors);
in SetUpTestCase()
72 DeviceManagerAdapter::GetInstance().Init(executors);
in SetUpTestCase()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_asset_loader_test.cpp | 104 std::shared_ptr<ExecutorPool> executors = std::make_shared<ExecutorPool>(5, 3); in HWTEST_F() local
105 ASSERT_NE(executors, nullptr); in HWTEST_F()
106 assetLoader->SetThreadPool(executors); in HWTEST_F()
|
| H A D | meta_data_test.cpp | 102 auto executors = std::make_shared<OHOS::ExecutorPool>(max, min); in SetUpTestCase() local
103 DmAdapter::GetInstance().Init(executors); in SetUpTestCase()
104 DistributedKv::KvStoreMetaManager::GetInstance().BindExecutor(executors); in SetUpTestCase()
|