Home
last modified time | relevance | path

Searched refs:eventHandler_ (Results 1 - 25 of 222) sorted by relevance

123456789

/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/utils/
H A Ddh_timer.cpp45 if (eventHandler_ == nullptr) { in InitTimer()
47 timerCond_.wait(lock, [this] { return eventHandler_ != nullptr; }); in InitTimer()
56 if (eventHandler_ != nullptr) { in ReleaseTimer()
57 eventHandler_->RemoveTask(timerId_); in ReleaseTimer()
58 if (eventHandler_->GetEventRunner() != nullptr) { in ReleaseTimer()
59 eventHandler_->GetEventRunner()->Stop(); in ReleaseTimer()
65 eventHandler_ = nullptr; in ReleaseTimer()
83 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(busRunner); in StartEventRunner()
95 if (eventHandler_ == nullptr) { in StartTimer()
100 eventHandler_ in StartTimer()
[all...]
/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/
H A Dmmi_client.cpp57 CHKPV(eventHandler_); in MarkIsEventHandlerChanged()
58 auto currentRunner = eventHandler_->GetEventRunner(); in MarkIsEventHandlerChanged()
116 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartEventRunner()
117 eventHandler_->PostTask([this] { this->SetScheduler(); }); in StartEventRunner()
130 if (!eventHandler_->PostTask([this] { return this->OnReconnect(); }, CLIENT_RECONNECT_COOLING_TIME)) { in StartEventRunner()
145 CHKPF(eventHandler_); in AddFdListener()
147 auto errCode = eventHandler_->AddFileDescriptorListener(fd, FILE_DESCRIPTOR_INPUT_EVENT, fdListener, "MMITask", in AddFdListener()
162 CHKPF(eventHandler_); in DelFdListener()
164 eventHandler_->RemoveFileDescriptorListener(fd); in DelFdListener()
169 auto runner = eventHandler_ in DelFdListener()
[all...]
/foundation/filemanagement/storage_service/services/storage_daemon/crypto/src/
H A Dcrypto_delay_handler.cpp33 if ((eventHandler_ != nullptr) && (eventHandler_->GetEventRunner() != nullptr)) { in ~DelayHandler()
34 eventHandler_->RemoveAllEvents(); in ~DelayHandler()
35 eventHandler_->GetEventRunner()->Stop(); in ~DelayHandler()
40 eventHandler_ = nullptr; in ~DelayHandler()
55 if (eventHandler_ == nullptr) { in StartDelayTask()
58 return eventHandler_ != nullptr; in StartDelayTask()
63 eventHandler_->PostTask(executeFunc, CLEAR_TASK_NAME, DEFAULT_CHECK_INTERVAL, in StartDelayTask()
78 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartDelayHandler()
88 if (eventHandler_ in CancelDelayTask()
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/utils/
H A Devent_handler_factory.cpp34 if (eventHandler_ != nullptr) { in Init()
38 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in Init()
46 if (eventHandler_ != nullptr) { in UnInit()
47 eventHandler_->RemoveAllEvents(); in UnInit()
48 eventHandler_ = nullptr; in UnInit()
57 return eventHandler_; in GetEventHandler()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/adapter/
H A Dmmi_adapter.cpp40 if (eventHandler_ != nullptr) { in Init()
48 return eventHandler_ != nullptr; in Init()
63 eventHandler_ = std::make_shared<OHOS::AppExecFwk::EventHandler>(runner); in StartEvent()
73 if (eventHandler_ != nullptr && eventHandler_->GetEventRunner() != nullptr) { in UnInit()
74 eventHandler_->GetEventRunner()->Stop(); in UnInit()
76 eventHandler_ = nullptr; in UnInit()
78 HILOGE("eventHandler_ or eventRunner is nullptr"); in UnInit()
104 if (eventHandler_ != nullptr) { in PostRawMMIEvent()
105 eventHandler_ in PostRawMMIEvent()
[all...]
/foundation/ability/ability_runtime/test/unittest/app_exit_reason_helper_test/
H A Dapp_exit_reason_helper_test.cpp66 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; in HWTEST_F() local
67 eventHandler_ = std::make_shared<AAFwk::AbilityEventHandler>(taskHandler_, service); in HWTEST_F()
69 subManagersHelper_ = std::make_shared<AAFwk::SubManagersHelper>(taskHandler_, eventHandler_); in HWTEST_F()
93 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; in HWTEST_F() local
94 eventHandler_ = std::make_shared<AAFwk::AbilityEventHandler>(taskHandler_, service); in HWTEST_F()
96 subManagersHelper_ = std::make_shared<AAFwk::SubManagersHelper>(taskHandler_, eventHandler_); in HWTEST_F()
118 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; in HWTEST_F() local
119 eventHandler_ = std::make_shared<AAFwk::AbilityEventHandler>(taskHandler_, service); in HWTEST_F()
121 subManagersHelper_ = std::make_shared<AAFwk::SubManagersHelper>(taskHandler_, eventHandler_); in HWTEST_F()
145 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; in HWTEST_F() local
173 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; HWTEST_F() local
199 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; HWTEST_F() local
225 std::shared_ptr<AAFwk::AbilityEventHandler> eventHandler_; HWTEST_F() local
[all...]
/foundation/ability/ability_runtime/frameworks/native/runtime/
H A Dohos_js_environment_impl.cpp76 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(eventRunner); in OHOSJsEnvironmentImpl()
91 if (eventHandler_ != nullptr) { in PostTask()
92 eventHandler_->PostTask(task, name, delayTime); in PostTask()
99 if (eventHandler_ != nullptr) { in PostSyncTask()
100 eventHandler_->PostSyncTask(task, name); in PostSyncTask()
107 if (eventHandler_ != nullptr) { in RemoveTask()
108 eventHandler_->RemoveTask(name); in RemoveTask()
140 if (eventHandler_ != nullptr) { in InitLoop()
142 eventHandler_->AddFileDescriptorListener(fd, events, std::make_shared<OHOSLoopHandler>(uvLoop), "uvLoopTask"); in InitLoop()
144 if (isStage && (eventHandler_ in InitLoop()
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/
H A Dsoftbus_adapter.cpp39 if (eventHandler_ != nullptr) { in Init()
46 return eventHandler_ != nullptr; in Init()
57 eventHandler_ = std::make_shared<OHOS::AppExecFwk::EventHandler>(runner); in StartEvent()
71 if (eventHandler_ != nullptr && eventHandler_->GetEventRunner() != nullptr) { in UnInit()
72 eventHandler_->GetEventRunner()->Stop(); in UnInit()
74 eventHandler_ = nullptr; in UnInit()
76 HILOGE("eventHandler_ or eventRunner is nullptr"); in UnInit()
87 if (eventHandler_ != nullptr) { in SendSoftbusEvent()
88 eventHandler_ in SendSoftbusEvent()
[all...]
/foundation/ability/ability_runtime/test/unittest/quick_fix/quick_fix_manager_service_test/
H A Dquick_fix_manager_apply_task_test.cpp113 EXPECT_NE(quickFixMs_->eventHandler_, nullptr); in SetUp()
141 quickFixMs_->eventHandler_, quickFixMs_); in HWTEST_F()
147 WaitUntilTaskDone(quickFixMs_->eventHandler_); in HWTEST_F()
163 quickFixMs_->eventHandler_, quickFixMs_); in HWTEST_F()
168 WaitUntilTaskDone(quickFixMs_->eventHandler_); in HWTEST_F()
184 quickFixMs_->eventHandler_, quickFixMs_); in HWTEST_F()
189 WaitUntilTaskDone(quickFixMs_->eventHandler_); in HWTEST_F()
205 quickFixMs_->eventHandler_, quickFixMs_); in HWTEST_F()
209 WaitUntilTaskDone(quickFixMs_->eventHandler_); in HWTEST_F()
224 quickFixMs_->eventHandler_, quickFixMs in HWTEST_F()
[all...]
/foundation/ability/ability_runtime/test/unittest/app_mgr_service_event_handler_test/
H A Dapp_mgr_service_event_handler_test.cpp56 std::shared_ptr<MockAMSEventHandler> eventHandler_; member in OHOS::AppExecFwk::AMSEventHandlerTest
127 EXPECT_FALSE(eventHandler_); in HWTEST_F()
129 eventHandler_ = std::make_shared<MockAMSEventHandler>(runner_, testAms); in HWTEST_F()
130 EXPECT_TRUE(eventHandler_); in HWTEST_F()
147 if (!eventHandler_) { in HWTEST_F()
148 eventHandler_ = std::make_shared<MockAMSEventHandler>(runner_, testAms); in HWTEST_F()
152 eventHandler_->SendEvent(20); in HWTEST_F()
159 eventHandler_->SendEvent(10); in HWTEST_F()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/
H A Ddcamera_sink_data_process.cpp31 : dhId_(dhId), channel_(channel), eventHandler_(nullptr) in DCameraSinkDataProcess()
40 if ((eventHandler_ != nullptr) && (eventHandler_->GetEventRunner() != nullptr)) { in ~DCameraSinkDataProcess()
41 eventHandler_->GetEventRunner()->Stop(); in ~DCameraSinkDataProcess()
46 eventHandler_ = nullptr; in ~DCameraSinkDataProcess()
55 return eventHandler_ != nullptr; in Init()
65 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartEventHandler()
116 if (eventHandler_ != nullptr) { in StopCapture()
118 eventHandler_->RemoveAllEvents(); in StopCapture()
158 if (eventHandler_ ! in SendDataAsync()
[all...]
/foundation/filemanagement/storage_service/services/storage_manager/storage/src/
H A Dstorage_monitor_service.cpp59 if ((eventHandler_ != nullptr) && (eventHandler_->GetEventRunner() != nullptr)) { in ~StorageMonitorService()
60 eventHandler_->RemoveAllEvents(); in ~StorageMonitorService()
61 eventHandler_->GetEventRunner()->Stop(); in ~StorageMonitorService()
66 eventHandler_ = nullptr; in ~StorageMonitorService()
73 if (eventHandler_ == nullptr) { in StartStorageMonitorTask()
76 return eventHandler_ != nullptr; in StartStorageMonitorTask()
81 eventHandler_->PostTask(executeFunc, DEFAULT_CHECK_INTERVAL); in StartStorageMonitorTask()
94 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartEventHandler()
102 if (eventHandler_ in Execute()
[all...]
/foundation/resourceschedule/ffrt/src/queue/
H A Deventhandler_interactive_queue.h48 int ret = EventHandlerAdapter::Instance()->RemoveTask(eventHandler_, taskId);
60 eventHandler_ = eventHandler; in SetEventHandler()
65 return eventHandler_; in GetEventHandler()
69 void* eventHandler_ = nullptr; member in ffrt::EventHandlerInteractiveQueue
/foundation/window/window_manager/wmserver/include/
H A Dwindow_common_event.h41 : EventFwk::CommonEventSubscriber(subscriberInfo), eventHandler_(eventHandler) {}; in EventSubscriber()
45 eventHandler_->OnReceiveEvent(data);
49 std::shared_ptr<WindowCommonEvent> eventHandler_; member in OHOS::Rosen::WindowCommonEvent::EventSubscriber
55 std::shared_ptr<AppExecFwk::EventHandler> eventHandler_; member in OHOS::Rosen::WindowCommonEvent
/foundation/multimodalinput/input/intention/ipc/socket/src/
H A Dsocket_client.cpp39 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in SocketClient()
69 CHKPF(eventHandler_); in Connect()
70 auto errCode = eventHandler_->AddFileDescriptorListener(socket->GetFd(), in Connect()
110 eventHandler_->RemoveFileDescriptorListener(socket_->GetFd()); in OnDisconnected()
111 eventHandler_->RemoveAllEvents(); in OnDisconnected()
114 if (!eventHandler_->PostTask([this] { this->Reconnect(); }, CLIENT_RECONNECT_COOLING_TIME)) { in OnDisconnected()
125 if (!eventHandler_->PostTask([this] { this->Reconnect(); }, CLIENT_RECONNECT_COOLING_TIME)) { in Reconnect()
/foundation/communication/nfc/services/src/
H A Dnfc_event_handler.cpp50 std::weak_ptr<NfcEventHandler> eventHandler_ {};
57 eventHandler_(nfcService.lock()->eventHandler_) in ScreenChangedReceiver()
97 screenState = eventHandler_.lock()->IsScreenLocked() ? in OnReceiveEvent()
100 screenState = eventHandler_.lock()->IsScreenLocked() ? in OnReceiveEvent()
103 screenState = eventHandler_.lock()->IsScreenOn() ? in OnReceiveEvent()
109 eventHandler_.lock()->SendEvent(static_cast<uint32_t>(NfcCommonEvent::MSG_SCREEN_CHANGED), in OnReceiveEvent()
124 std::weak_ptr<AppExecFwk::EventHandler> eventHandler_ {};
131 eventHandler_(nfcService.lock()->eventHandler_) in PackageChangedReceiver()
[all...]
/foundation/arkui/napi/test/unittest/
H A Dtest_napi_threadsafe.cpp561 if (eventHandler_ != nullptr) { in AttachEventHandler()
570 eventHandler_ = std::make_shared<OHOS::AppExecFwk::EventHandler>(runner); in AttachEventHandler()
571 EXPECT_NE(eventHandler_, nullptr); in AttachEventHandler()
573 eventHandler_->AddFileDescriptorListener(fd, events, std::make_shared<UnitLoopHandler>(uvLoop), "uvLoopTask"); in AttachEventHandler()
1125 EXPECT_NE(eventHandler_, nullptr); in HWTEST_F()
1126 eventHandler_->PostTask(task); in HWTEST_F()
1127 auto runner = eventHandler_->GetEventRunner(); in HWTEST_F()
1147 EXPECT_NE(eventHandler_, nullptr); in HWTEST_F()
1148 eventHandler_->PostTask(task); in HWTEST_F()
1149 auto runner = eventHandler_ in HWTEST_F()
[all...]
/foundation/arkui/ace_engine/frameworks/core/common/
H A Dtask_runner_adapter_impl.cpp28 eventHandler_ = std::make_shared<OHOS::AppExecFwk::EventHandler>(eventRunner_); in Initialize()
33 eventHandler_->PostTask(std::move(task), name, 0, ConvertPriority(priorityType)); in PostTask()
38 eventHandler_->PostTimingTask(std::move(task), targetTime, ""); in PostTaskForTime()
44 eventHandler_->PostTask(std::move(task), name, delay, ConvertPriority(priorityType)); in PostDelayedTask()
54 eventHandler_->RemoveTask(name); in RemoveTask()
/foundation/ability/ability_runtime/test/unittest/app_mgr_service_test/
H A Dapp_mgr_service_test.cpp45 std::shared_ptr<AMSEventHandler> eventHandler_; member in OHOS::AppExecFwk::AppMgrServiceTest
65 eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, mockAppMgrServiceInner_); in SetUp()
72 eventHandler_.reset(); in TearDown()
156 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
240 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
275 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
292 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
328 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
382 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>(taskHandler_, appMgrService->appMgrServiceInner_); in HWTEST_F()
418 appMgrService->eventHandler_ in HWTEST_F()
[all...]
/foundation/ability/ability_runtime/test/unittest/app_mgr_service_dump_ipc_test/
H A Dapp_mgr_service_dump_ipc_test.cpp82 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( in HWTEST_F()
84 EXPECT_NE(appMgrService->eventHandler_, nullptr); in HWTEST_F()
123 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( in HWTEST_F()
125 EXPECT_NE(appMgrService->eventHandler_, nullptr); in HWTEST_F()
163 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( in HWTEST_F()
165 EXPECT_NE(appMgrService->eventHandler_, nullptr); in HWTEST_F()
204 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( in HWTEST_F()
206 EXPECT_NE(appMgrService->eventHandler_, nullptr); in HWTEST_F()
245 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( in HWTEST_F()
247 EXPECT_NE(appMgrService->eventHandler_, nullpt in HWTEST_F()
[all...]
/foundation/ability/ability_lite/frameworks/ability_lite/src/
H A Dability_scheduler.cpp30 : eventHandler_(eventHandler), scheduler_(scheduler) in AbilityScheduler()
138 eventHandler_.PostTask(task); in PerformAppInit()
147 eventHandler_.PostTask(task); in PerformTransactAbilityState()
156 eventHandler_.PostTask(task); in PerformConnectAbility()
165 eventHandler_.PostTask(task); in PerformDisconnectAbility()
173 eventHandler_.PostTask(task); in PerformAppExit()
186 eventHandler_.PostTask(task); in PerformDumpAbility()
/foundation/window/window_manager/wmserver/src/
H A Dwindow_inner_manager.cpp32 WindowInnerManager::WindowInnerManager() : eventHandler_(nullptr), eventLoop_(nullptr), in WindowInnerManager()
49 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(eventLoop_); in Init()
50 if (eventHandler_ == nullptr) { in Init()
53 int ret = HiviewDFX::Watchdog::GetInstance().AddThread(INNER_WM_THREAD_NAME, eventHandler_); in Init()
57 eventHandler_->PostTask([]() { MemoryGuard cacheGuard; }, "wms:Init:cacheGuard", in Init()
93 if (eventHandler_ != nullptr) { in Stop()
94 eventHandler_.reset(); in Stop()
252 if (eventHandler_ == nullptr) { in PostTask()
256 bool ret = eventHandler_->PostTask(task, "wms:" + name, 0, priority); // 0 is task delay time in PostTask()
329 if (isReportTaskStart_ || eventHandler_ in StartWindowInfoReportLoop()
[all...]
/foundation/arkui/ace_engine/interfaces/inner_api/form_render/src/
H A Dform_renderer_dispatcher_impl.cpp32 : uiContent_(uiContent), formRenderer_(formRenderer), eventHandler_(eventHandler) in FormRendererDispatcherImpl()
39 auto handler = eventHandler_.lock(); in DispatchPointerEvent()
100 auto handler = eventHandler_.lock(); in DispatchSurfaceChangeEvent()
159 auto handler = eventHandler_.lock(); in SetObscured()
178 auto handler = eventHandler_.lock(); in OnAccessibilityChildTreeRegister()
205 auto handler = eventHandler_.lock(); in OnAccessibilityChildTreeDeregister()
224 auto handler = eventHandler_.lock(); in OnAccessibilityDumpChildInfo()
243 auto handler = eventHandler_.lock(); in OnAccessibilityTransferHoverEvent()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddms_continue_send_manager.cpp55 if (eventHandler_ != nullptr) { in Init()
67 return eventHandler_ != nullptr; in Init()
85 if (eventHandler_ != nullptr && eventHandler_->GetEventRunner() != nullptr) { in UnInit()
86 eventHandler_->GetEventRunner()->Stop(); in UnInit()
88 eventHandler_ = nullptr; in UnInit()
90 HILOGE("eventHandler_ is nullptr"); in UnInit()
118 if (eventHandler_ == nullptr) { in PostUnfocusedTaskWithDelay()
119 HILOGE("eventHandler_ is nullptr"); in PostUnfocusedTaskWithDelay()
127 eventHandler_ in PostUnfocusedTaskWithDelay()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/session/
H A Dtcp_session.cpp41 eventHandler_ = std::make_shared<TcpSessionEventHandler>(); in Start()
42 eventHandler_->SetSession(shared_from_this()); in Start()
43 eventHandler_->SetEventRunner(eventRunner); in Start()
49 return eventListener_->AddFdListener(socket_->GetPeerFd(), eventListener_, eventHandler_); in Start()

Completed in 13 milliseconds

123456789