| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | task_manager.cpp | 18 TaskManager::TaskManager(std::shared_ptr<ExecutorPool> executors) : executors_(executors) in TaskManager()
24 executors_ = nullptr; in ~TaskManager()
28 return executors_->Execute(task); in Execute()
32 return executors_->Schedule(delay, task); in Execute()
36 return executors_->Schedule(task, interval); in Schedule()
40 return executors_->Schedule(task, delay, interval); in Schedule()
44 return executors_->Schedule(task, delay, interval, times); in Schedule()
48 return executors_->Remove(taskId, wait); in Remove()
52 return executors_->Reset(taskId, interval); in Reset()
|
| H A D | kvstore_account_observer.h | 39 : kvStoreDataService_(kvStoreDataService), executors_(executors) in KvStoreAccountObserver()
58 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedKv::KvStoreAccountObserver
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/ |
| H A D | reporter.cpp | 40 communicationFault.SetThreadPool(executors_); in CommunicationFault()
47 databaseFault.SetThreadPool(executors_); in DatabaseFault()
54 runtimeFault.SetThreadPool(executors_); in RuntimeFault()
61 serviceFault.SetThreadPool(executors_); in ServiceFault()
68 trafficStatistic.SetThreadPool(executors_); in TrafficStatistic()
75 visitStatistic.SetThreadPool(executors_); in VisitStatistic()
82 databaseStatistic.SetThreadPool(executors_); in DatabaseStatistic()
89 apiPerformanceStat.SetThreadPool(executors_); in ApiPerformanceStatistic()
96 behaviourReporterImpl.SetThreadPool(executors_); in BehaviourReporter()
|
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/multiThread/ |
| H A D | rdb_connection_rd_test.cpp | 50 std::shared_ptr<ExecutorPool> executors_;
member in Test::RdbMultiThreadConnectionRdTest
75 executors_ = std::make_shared<ExecutorPool>(MAX_THREAD, MIN_THREAD);
in RdbMultiThreadConnectionRdTest()
102 executors_ = nullptr;
in TearDown()
117 auto taskId1 = executors_->Execute([store = store_]() {
in HWTEST_F()
128 auto taskId2 = executors_->Execute([store = store_]() {
in HWTEST_F()
138 executors_->Remove(taskId1, true);
in HWTEST_F()
139 executors_->Remove(taskId2, true);
in HWTEST_F()
153 auto taskId1 = executors_->Execute([store = store_]() {
in HWTEST_F()
164 auto taskId2 = executors_->Execute([store = store_]() {
in HWTEST_F()
174 executors_ in HWTEST_F()
[all...] |
| H A D | rdb_connection_test.cpp | 57 std::shared_ptr<ExecutorPool> executors_; member in RdbMultiThreadConnectionTest
80 executors_ = std::make_shared<ExecutorPool>(MAX_THREAD, MIN_THREAD); in SetUp()
96 executors_ = nullptr; in TearDown()
134 auto taskId1 = executors_->Execute([store = store_, block1]() { in HWTEST_F()
150 auto taskId2 = executors_->Execute([store = store_, block2]() { in HWTEST_F()
181 auto taskId1 = executors_->Execute([store = store_, block1]() { in HWTEST_F()
197 auto taskId2 = executors_->Execute([store = store_, block2]() { in HWTEST_F()
|
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/ |
| H A D | wifi_direct_scheduler.h | 52 auto it = executors_.find(remoteDeviceId); in ProcessNegotiateData()
53 if (it != executors_.end()) { in ProcessNegotiateData()
66 if (executors_.size() == MAX_EXECUTOR) { in ProcessNegotiateData()
82 executors_.insert({ remoteDeviceId, executor }); in ProcessNegotiateData()
92 auto it = executors_.find(remoteDeviceId); in ProcessEvent()
93 if (it == executors_.end()) { in ProcessEvent()
125 auto eit = executors_.find(remoteDeviceId); in FetchAndDispatchCommand()
126 if (eit == executors_.end()) { in FetchAndDispatchCommand()
158 auto iterator = executors_.find(remoteDeviceId); in CheckExecutorRunning()
159 return iterator != executors_ in CheckExecutorRunning()
169 std::map<std::string, std::shared_ptr<WifiDirectExecutor>> executors_; global() member in OHOS::SoftBus::WifiDirectScheduler
[all...] |
| H A D | wifi_direct_scheduler.cpp | 115 auto ite = executors_.find(executorDeviceId); in ProcessNextCommand()
116 if (ite == executors_.end()) { in ProcessNextCommand()
123 executors_.erase(ite); in ProcessNextCommand()
130 if (commandDeviceId == executorDeviceId || executors_.find(commandDeviceId) == executors_.end()) { in ProcessNextCommand()
135 executors_.insert({commandDeviceId, executorCopy}); in ProcessNextCommand()
169 auto it = executors_.find(remoteDeviceId); in ScheduleActiveCommand()
170 if (it != executors_.end() || executors_.size() == MAX_EXECUTOR) { in ScheduleActiveCommand()
188 executors_ in ScheduleActiveCommand()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/behaviour/ |
| H A D | behaviour_reporter_impl.cpp | 21 HiViewAdapter::ReportBehaviour(DfxCodeConstant::DATABASE_BEHAVIOUR, msg, executors_); in Report()
27 HiViewAdapter::ReportUdmfBehaviour(DfxCodeConstant::UDMF_DATA_BEHAVIOR, msg, executors_); in UDMFReport()
33 executors_ = executors; in SetThreadPool()
|
| H A D | behaviour_reporter_impl.h | 32 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedDataDfx::BehaviourReporterImpl
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/fault/ |
| H A D | communication_fault_impl.cpp | 22 HiViewAdapter::ReportCommFault(DfxCodeConstant::DATABASE_SYNC_FAILED, msg, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | service_fault_impl.cpp | 22 HiViewAdapter::ReportFault(DfxCodeConstant::SERVICE_FAULT, msg, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | runtime_fault_impl.cpp | 22 HiViewAdapter::ReportFault(DfxCodeConstant::RUNTIME_FAULT, msg, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | database_fault_impl.cpp | 33 HiViewAdapter::ReportDBFault(eventID, msg, executors_); in Report()
38 executors_ = executors; in SetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/statistic/ |
| H A D | traffic_statistic_impl.cpp | 22 HiViewAdapter::ReportTrafficStatistic(DfxCodeConstant::TRAFFIC_STATISTIC, stat, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | visit_statistic_impl.cpp | 22 HiViewAdapter::ReportVisitStatistic(DfxCodeConstant::VISIT_STATISTIC, stat, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | api_performance_statistic_impl.cpp | 22 HiViewAdapter::ReportApiPerformanceStatistic(DfxCodeConstant::API_PERFORMANCE_INTERFACE, stat, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | database_statistic_impl.cpp | 22 HiViewAdapter::ReportDatabaseStatistic(DfxCodeConstant::DATABASE_STATISTIC, stat, executors_); in Report()
27 executors_ = executors; in SetThreadPool()
|
| H A D | traffic_statistic_impl.h | 31 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedDataDfx::TrafficStatisticImpl
|
| H A D | visit_statistic_impl.h | 31 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedDataDfx::VisitStatisticImpl
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/lifecycle/ |
| H A D | lifecycle_manager.cpp | 46 ExecutorPool::TaskId taskId = executors_->Execute([=] { in OnGot()
78 if (executors_ == nullptr) { in StartLifeCycleTimer()
82 ExecutorPool::TaskId taskId = executors_->Schedule(GetTask(), LifeCyclePolicy::INTERVAL); in StartLifeCycleTimer()
115 executors_ = executors; in SetThreadPool()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/dfx/ |
| H A D | reporter.h | 45 executors_ = executors; in SetThreadPool()
60 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedDataDfx::Reporter
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| H A D | upgrade_manager.cpp | 39 if (executors_) {
in Init()
42 executors_ = std::move(executors);
in Init()
43 executors_->Execute(GetTask());
in Init()
53 executors_->Schedule(std::chrono::milliseconds(RETRY_INTERVAL), GetTask());
in GetTask()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | user_delegate.cpp | 176 if (!executors_) { in Init()
177 executors_ = executors; in Init()
179 executors_->Execute(GeTask()); in Init()
190 executors_->Schedule(std::chrono::milliseconds(RETRY_INTERVAL), GeTask()); in GeTask()
|
| /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()
84 std::shared_ptr<ExecutorPool> executors_; member in OHOS::DistributedKv::Security
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | kv_delegate.cpp | 182 if (executors_ != nullptr) {
in Init()
183 executors_->Reset(taskId_, std::chrono::seconds(WAIT_TIME));
in Init()
194 if (executors_ != nullptr) {
in Init()
195 taskId_ = executors_->Schedule(std::chrono::seconds(WAIT_TIME), [this]() {
in Init()
359 : path_(path), executors_(executors)
in KvDelegate()
|