Home
last modified time | relevance | path

Searched refs:taskMap_ (Results 1 - 25 of 26) sorted by relevance

12

/foundation/systemabilitymgr/samgr/services/samgr/native/source/
H A Dffrt_handler.cpp36 for (auto iter = taskMap_.begin(); iter != taskMap_.end(); ++iter) { in CleanFfrt()
37 HILOGI("CleanFfrt taskMap_ %{public}s", iter->first.c_str()); in CleanFfrt()
46 taskMap_.clear(); in CleanFfrt()
93 taskMap_[name] = std::move(handler); in PostTask()
100 auto item = taskMap_.find(name); in RemoveTask()
101 if (item == taskMap_.end()) { in RemoveTask()
111 taskMap_.erase(name); in RemoveTask()
117 auto item = taskMap_.find(name); in DelTask()
118 if (item == taskMap_ in DelTask()
[all...]
/foundation/ability/form_fwk/test/unittest/frs_form_render_serial_queue_test/
H A Dfrs_form_render_serial_queue_test.cpp126 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
127 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
143 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
144 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
160 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
161 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
198 EXPECT_EQ(1, static_cast<int>(serialQueueTask.taskMap_.size())); in HWTEST_F()
203 EXPECT_EQ(1, static_cast<int>(serialQueueTask.taskMap_.size())); in HWTEST_F()
220 EXPECT_EQ(1, static_cast<int>(serialQueueTask.taskMap_.size())); in HWTEST_F()
225 EXPECT_EQ(0, static_cast<int>(serialQueueTask.taskMap_ in HWTEST_F()
[all...]
/foundation/window/window_manager/window_scene/session/host/src/
H A Dws_ffrt_helper.cpp49 taskMap_[taskName] = std::move(handle); in SaveTask()
55 if (auto iter = taskMap_.find(taskName); iter != taskMap_.end()) { in RemoveTask()
62 taskMap_.erase(iter); in RemoveTask()
71 auto iter = taskMap_.find(taskName); in IsTaskExisted()
72 return iter != taskMap_.end() && iter->second != nullptr; in IsTaskExisted()
78 return taskMap_.size(); in CountTask()
82 std::unordered_map<std::string, ffrt::task_handle> taskMap_; member in OHOS::Rosen::TaskHandleMap
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/offscreen_render/
H A Drs_offscreen_render_thread.cpp78 taskMap_[nodeId] = task; in InSertCaptureTask()
84 if (!taskMap_.empty()) { in GetCaptureTask()
85 auto iter = taskMap_.find(nodeId); in GetCaptureTask()
86 if (iter != taskMap_.end()) { in GetCaptureTask()
87 auto task = taskMap_[nodeId]; in GetCaptureTask()
88 taskMap_.erase(nodeId); in GetCaptureTask()
/foundation/CastEngine/castengine_cast_framework/common/include/private/
H A Dcast_stub_helper.h31 std::map<uint32_t, className##Func> taskMap_
33 #define FILL_SINGLE_STUB_TASK(id, func) taskMap_[id] = (func)
44 if (taskMap_.count(code) == 0) { \
50 #define EXECUTE_SINGLE_STUB_TASK(code, data, reply) (this->*taskMap_[code])(data, reply)
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/common/
H A Dserial_queue.cpp51 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
59 auto item = taskMap_.find(taskName); in CancelDelayTask()
60 if (item == taskMap_.end()) { in CancelDelayTask()
70 taskMap_.erase(taskName); in CancelDelayTask()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor.cpp364 while (taskMap_.find(sessionId) != taskMap_.end()) { // LCOV_EXCL_BR_LINE in GenerateSessionId()
395 if (taskMap_.find(sessionId) != taskMap_.end()) { in RemoteQueryInner()
399 taskMap_[sessionId] = task; in RemoteQueryInner()
400 taskMap_[sessionId].taskId = GenerateTaskId(); in RemoteQueryInner()
402 taskMap_[sessionId].taskId, task.target.c_str()); in RemoteQueryInner()
431 if (taskMap_.find(sessionId) == taskMap_.end()) { in TryExecuteTaskInLock()
436 taskMap_[sessionI in TryExecuteTaskInLock()
[all...]
H A Dremote_executor.h153 std::map<uint32_t, Task> taskMap_; // key is sessionId member in DistributedDB::RemoteExecutor
/foundation/ability/form_fwk/services/src/
H A Dform_serial_queue.cpp65 taskMap_[eventMsg] = std::move(task_handle); in ScheduleDelayTask()
73 auto item = taskMap_.find(eventMsg); in CancelDelayTask()
74 if (item == taskMap_.end()) { in CancelDelayTask()
84 taskMap_.erase(eventMsg); in CancelDelayTask()
/foundation/ability/form_fwk/services/form_render_service/src/
H A Dform_render_serial_queue.cpp66 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
74 auto item = taskMap_.find(taskName); in CancelDelayTask()
75 if (item == taskMap_.end()) { in CancelDelayTask()
85 taskMap_.erase(taskName); in CancelDelayTask()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/unittest/bms_bundle_common_test/
H A Dbms_bundle_common_test.cpp84 EXPECT_EQ(serialQueue.taskMap_.size(), 0); in HWTEST_F()
103 EXPECT_EQ(serialQueue.taskMap_.size(), 0); in HWTEST_F()
122 EXPECT_EQ(serialQueue.taskMap_.size(), 1); in HWTEST_F()
141 EXPECT_EQ(serialQueue.taskMap_.size(), 1); in HWTEST_F()
162 EXPECT_EQ(serialQueue.taskMap_.size(), 1); in HWTEST_F()
/foundation/communication/wifi/wifi/utils/src/
H A Dwifi_event_handler.cpp129 for (auto iter = taskMap_.begin(); iter != taskMap_.end();) { in ~WifiEventHandlerImpl()
137 iter = taskMap_.erase(iter); in ~WifiEventHandlerImpl()
184 taskMap_[name] = std::move(handle); in PostAsyncTask()
191 auto iter = taskMap_.find(name); in RemoveAsyncTask()
192 if (iter != taskMap_.end() && iter->second != nullptr && eventQueue != nullptr) { in RemoveAsyncTask()
197 taskMap_.erase(iter); in RemoveAsyncTask()
203 std::map<std::string, ffrt::task_handle> taskMap_; member in OHOS::Wifi::WifiEventHandler::WifiEventHandlerImpl
/foundation/communication/dhcp/services/dhcp_client/src/
H A Ddhcp_thread.cpp56 for (auto iter = taskMap_.begin(); iter != taskMap_.end();) { in ~DhcpThreadImpl()
58 iter = taskMap_.erase(iter); in ~DhcpThreadImpl()
102 taskMap_[name] = std::move(handle); in PostAsyncTask()
109 auto item = taskMap_.find(name); in RemoveAsyncTask()
110 if (item == taskMap_.end()) { in RemoveAsyncTask()
120 taskMap_.erase(name); in RemoveAsyncTask()
125 std::map<std::string, ffrt::task_handle> taskMap_; member in OHOS::DHCP::DhcpThread::DhcpThreadImpl
/foundation/multimedia/av_codec/services/media_engine/modules/demuxer/
H A Dmedia_demuxer.cpp324 auto task = taskMap_.find(trackId); in AccelerateTrackTask()
325 if (task == taskMap_.end()) { in AccelerateTrackTask()
527 taskMap_[trackId] = std::move(task); in AddDemuxerCopyTask()
528 taskMap_[trackId]->RegisterJob([this, trackId] { return ReadLoop(trackId); }); in AddDemuxerCopyTask()
772 auto iter = taskMap_.find(trackId); in StartTask()
773 if (iter == taskMap_.end()) { in StartTask()
782 if (taskMap_.find(trackId) != taskMap_.end() && taskMap_[trackId] != nullptr) { in StartTask()
783 taskMap_[trackI in StartTask()
[all...]
H A Dmedia_demuxer.h229 std::map<uint32_t, std::unique_ptr<Task>> taskMap_; member in OHOS::Media::MediaDemuxer
/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Dapp_domain_verify_task_mgr.cpp116 return [taskMap = &taskMap_, httpTask]() { in GetTaskWrapper()
173 taskMap_.EnsureInsert(task->GetTaskId(), task); in AddTask()
181 return taskMap_.IsEmpty(); in IsIdle()
/foundation/ability/form_fwk/services/form_render_service/include/
H A Dform_render_serial_queue.h37 std::map<std::string, ffrt::task_handle> taskMap_; member in OHOS::AppExecFwk::FormRender::final
/foundation/ability/form_fwk/services/include/
H A Dform_serial_queue.h36 std::map<std::pair<int64_t, int64_t>, ffrt::task_handle> taskMap_; member in OHOS::AppExecFwk::final
/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/common/
H A Dserial_queue.h35 std::map<std::string, ffrt::task_handle> taskMap_; member in OHOS::AppExecFwk::final
/foundation/bundlemanager/app_domain_verify/frameworks/common/include/httpsession/
H A Dapp_domain_verify_task_mgr.h52 SafeMap<uint32_t, std::shared_ptr<IHttpTask>> taskMap_; member in OHOS::AppDomainVerify::AppDomainVerifyTaskMgr
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/offscreen_render/
H A Drs_offscreen_render_thread.h55 std::map<NodeId, std::function<void()>> taskMap_; member in OHOS::Rosen::RSOffscreenRenderThread
/foundation/systemabilitymgr/samgr/services/samgr/native/include/
H A Dffrt_handler.h41 std::map<std::string, ffrt::task_handle> taskMap_; member in OHOS::FFRTHandler
/foundation/resourceschedule/device_usage_statistics/services/common/src/
H A Dbundle_active_core.cpp337 if (taskMap_.find(uid) == taskMap_.end()) { in OnBundleInstalled()
340 ffrt::skip(taskMap_[uid]); in OnBundleInstalled()
341 taskMap_.erase(uid); in OnBundleInstalled()
356 if (bundleActiveCore->taskMap_.find(uid) == bundleActiveCore->taskMap_.end()) { in DelayRemoveBundleUninstalledUid()
359 bundleActiveCore->taskMap_.erase(uid); in DelayRemoveBundleUninstalledUid()
361 taskMap_[uid] = std::move(task); in DelayRemoveBundleUninstalledUid()
/foundation/resourceschedule/device_usage_statistics/services/common/include/
H A Dbundle_active_core.h270 std::map<int32_t, ffrt::task_handle> taskMap_; member in OHOS::DeviceUsageStats::BundleActiveCore
/foundation/ability/form_fwk/test/unittest/fms_form_render_impl_test/
H A Dfms_form_render_impl_test.cpp451 EXPECT_EQ(0, formRenderImpl.serialQueue_->taskMap_.size()); in HWTEST_F()
454 EXPECT_EQ(1, formRenderImpl.serialQueue_->taskMap_.size()); in HWTEST_F()
473 EXPECT_EQ(0, formRenderImpl.serialQueue_->taskMap_.size()); in HWTEST_F()

Completed in 16 milliseconds

12