/ohos5.0/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/ |
H A D | mmi_client.cpp | 59 CHKPV(eventHandler_); in MarkIsEventHandlerChanged() 148 CHKPF(eventHandler_); in AddFdListener() 165 CHKPF(eventHandler_); in DelFdListener() 172 auto runner = eventHandler_->GetEventRunner(); in DelFdListener() 175 eventHandler_->RemoveAllEvents(); in DelFdListener() 211 CHKPV(eventHandler_); in OnReconnect() 246 if (!isExit && eventHandler_ != nullptr) { in OnDisconnected() 291 CHKPP(eventHandler_); in GetEventHandler() 292 return eventHandler_; in GetEventHandler() 299 if (eventHandler_ != nullptr) { in Stop() [all …]
|
/ohos5.0/base/msdp/device_status/frameworks/native/src/ |
H A D | client.cpp | 48 eventHandler_ = eventHandler; in SetEventHandler() 54 CHKPV(eventHandler_); in MarkIsEventHandlerChanged() 55 auto currentRunner = eventHandler_->GetEventRunner(); in MarkIsEventHandlerChanged() 138 CHKPF(eventHandler_); in AddFdListener() 155 CHKPF(eventHandler_); in DelFdListener() 162 auto runner = eventHandler_->GetEventRunner(); in DelFdListener() 165 eventHandler_->RemoveAllEvents(); in DelFdListener() 201 CHKPV(eventHandler_); in OnReconnect() 236 if (hasClient_ && eventHandler_ != nullptr) { in OnDisconnected() 272 if (eventHandler_ != nullptr) { in Stop() [all …]
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/utils/ |
H A D | dh_timer.cpp | 45 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() 95 if (eventHandler_ == nullptr) { in StartTimer() 100 eventHandler_->PostTask(executeFunc, timerId_, delayTimeMs_); in StartTimer() 115 if (eventHandler_ == nullptr) { in Execute() [all …]
|
/ohos5.0/foundation/filemanagement/storage_service/services/storage_daemon/crypto/src/ |
H A D | crypto_delay_handler.cpp | 36 if ((eventHandler_ != nullptr) && (eventHandler_->GetEventRunner() != nullptr)) { in ~DelayHandler() 37 eventHandler_->RemoveAllEvents(); in ~DelayHandler() 38 eventHandler_->GetEventRunner()->Stop(); in ~DelayHandler() 43 eventHandler_ = nullptr; in ~DelayHandler() 58 if (eventHandler_ == nullptr) { in StartDelayTask() 61 return eventHandler_ != nullptr; in StartDelayTask() 66 eventHandler_->PostTask(executeFunc, CLEAR_TASK_NAME, DEFAULT_CHECK_INTERVAL, in StartDelayTask() 81 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartDelayHandler() 91 if (eventHandler_ == nullptr) { in CancelDelayTask() 95 eventHandler_->RemoveTask(CLEAR_TASK_NAME); in CancelDelayTask()
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/adapter/ |
H A D | mmi_adapter.cpp | 40 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() 104 if (eventHandler_ != nullptr) { in PostRawMMIEvent() 105 eventHandler_->PostTask(func); in PostRawMMIEvent() 116 if (eventHandler_ != nullptr) { in PostUnfreezeMMIEvent() 117 eventHandler_->PostTask(func, FREEZE_MMI_EVENT_TASK, FREEZE_MMI_EVENT_INTERVAL); in PostUnfreezeMMIEvent()
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/ |
H A D | softbus_adapter.cpp | 39 if (eventHandler_ != nullptr) { in Init() 46 return eventHandler_ != nullptr; in Init() 71 if (eventHandler_ != nullptr && eventHandler_->GetEventRunner() != nullptr) { in UnInit() 72 eventHandler_->GetEventRunner()->Stop(); in UnInit() 74 eventHandler_ = nullptr; in UnInit() 87 if (eventHandler_ != nullptr) { in SendSoftbusEvent() 88 eventHandler_->PostTask(feedfunc); in SendSoftbusEvent() 98 if (eventHandler_ != nullptr) { in DealSendSoftbusEvent() 99 eventHandler_->RemoveTask(RETRY_SENT_EVENT_TASK); in DealSendSoftbusEvent() 133 if (eventHandler_ != nullptr) { in RetrySendSoftbusEvent() [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/quick_fix/quick_fix_manager_service_test/ |
H A D | quick_fix_manager_apply_task_test.cpp | 112 EXPECT_NE(quickFixMs_->eventHandler_, nullptr); in SetUp() 140 quickFixMs_->eventHandler_, quickFixMs_); 146 WaitUntilTaskDone(quickFixMs_->eventHandler_); 162 quickFixMs_->eventHandler_, quickFixMs_); 167 WaitUntilTaskDone(quickFixMs_->eventHandler_); 183 quickFixMs_->eventHandler_, quickFixMs_); 204 quickFixMs_->eventHandler_, quickFixMs_); 223 quickFixMs_->eventHandler_, quickFixMs_); 242 quickFixMs_->eventHandler_, quickFixMs_); 276 quickFixMs_->eventHandler_, quickFixMs_); [all …]
|
/ohos5.0/base/sensors/sensor/frameworks/native/src/ |
H A D | sensor_data_channel.cpp | 62 if (eventHandler_ == nullptr) { in InnerSensorDataChannel() 65 eventHandler_ = std::make_shared<SensorEventHandler>(myRunner); in InnerSensorDataChannel() 68 auto inResult = eventHandler_->AddFileDescriptorListener(receiveFd, in InnerSensorDataChannel() 99 if (eventHandler_ == nullptr) { in AddFdListener() 102 eventHandler_ = std::make_shared<SensorEventHandler>(myRunner); in AddFdListener() 106 …auto errCode = eventHandler_->AddFileDescriptorListener(fd, AppExecFwk::FILE_DESCRIPTOR_INPUT_EVEN… in AddFdListener() 123 CHKPR(eventHandler_, ERROR); in DelFdListener() 124 eventHandler_->RemoveFileDescriptorListener(fd); in DelFdListener() 131 if (listenedFdSet_.empty() && eventHandler_ != nullptr) { in DelFdListener() 132 eventHandler_ = nullptr; in DelFdListener()
|
/ohos5.0/foundation/ability/ability_runtime/frameworks/native/runtime/ |
H A D | ohos_js_environment_impl.cpp | 76 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), "u… in InitLoop() 157 if (fd >= 0 && eventHandler_ != nullptr) { in DeInitLoop() [all …]
|
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/utils/ |
H A D | event_handler_factory.cpp | 34 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()
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/app_mgr_service_event_handler_test/ |
H A D | app_mgr_service_event_handler_test.cpp | 56 std::shared_ptr<MockAMSEventHandler> eventHandler_; member in OHOS::AppExecFwk::AMSEventHandlerTest 127 EXPECT_FALSE(eventHandler_); 129 eventHandler_ = std::make_shared<MockAMSEventHandler>(runner_, testAms); 130 EXPECT_TRUE(eventHandler_); 147 if (!eventHandler_) { 148 eventHandler_ = std::make_shared<MockAMSEventHandler>(runner_, testAms); 152 eventHandler_->SendEvent(20); 159 eventHandler_->SendEvent(10);
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/app_mgr_service_test/ |
H A D | app_mgr_service_test.cpp | 1417 appMgrService->eventHandler_ = eventHandler_; 1441 appMgrService->eventHandler_ = eventHandler_; 1464 appMgrService->eventHandler_ = eventHandler_; 1485 appMgrService->eventHandler_ = eventHandler_; 1630 appMgrService->eventHandler_ = eventHandler_; 1650 appMgrService->eventHandler_ = eventHandler_; 1665 appMgrService->eventHandler_ = eventHandler_; 1789 appMgrService->eventHandler_ = eventHandler_; 1831 appMgrService->eventHandler_ = eventHandler_; 1851 appMgrService->eventHandler_ = eventHandler_; [all …]
|
/ohos5.0/foundation/communication/nfc/services/src/ |
H A D | nfc_event_handler.cpp | 50 std::weak_ptr<NfcEventHandler> eventHandler_ {}; member in OHOS::NFC::NfcEventHandler::ScreenChangedReceiver 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() 124 std::weak_ptr<AppExecFwk::EventHandler> eventHandler_ {}; member in OHOS::NFC::NfcEventHandler::PackageChangedReceiver 131 eventHandler_(nfcService.lock()->eventHandler_) in PackageChangedReceiver() 164 std::weak_ptr<AppExecFwk::EventHandler> eventHandler_ {}; member in OHOS::NFC::NfcEventHandler::ShutdownEventReceiver 171 eventHandler_(nfcService.lock()->eventHandler_) in ShutdownEventReceiver() 200 std::weak_ptr<AppExecFwk::EventHandler> eventHandler_ {}; member in OHOS::NFC::NfcEventHandler::DataShareChangedReceiver [all …]
|
/ohos5.0/foundation/arkui/napi/test/unittest/ |
H A D | test_napi_threadsafe.cpp | 565 if (eventHandler_ != nullptr) { in AttachEventHandler() 1130 eventHandler_->PostTask(task); 1152 eventHandler_->PostTask(task); 1174 eventHandler_->PostTask(task); 1196 eventHandler_->PostTask(task); 1218 eventHandler_->PostTask(task); 1240 eventHandler_->PostTask(task); 1262 eventHandler_->PostTask(task); 1284 eventHandler_->PostTask(task); 1306 eventHandler_->PostTask(task); [all …]
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/app_mgr_service_dump_ipc_test/ |
H A D | app_mgr_service_dump_ipc_test.cpp | 84 EXPECT_NE(appMgrService->eventHandler_, nullptr); 125 EXPECT_NE(appMgrService->eventHandler_, nullptr); 165 EXPECT_NE(appMgrService->eventHandler_, nullptr); 206 EXPECT_NE(appMgrService->eventHandler_, nullptr); 247 EXPECT_NE(appMgrService->eventHandler_, nullptr); 287 EXPECT_NE(appMgrService->eventHandler_, nullptr); 328 EXPECT_NE(appMgrService->eventHandler_, nullptr); 369 EXPECT_NE(appMgrService->eventHandler_, nullptr); 410 EXPECT_NE(appMgrService->eventHandler_, nullptr); 451 EXPECT_NE(appMgrService->eventHandler_, nullptr); [all …]
|
/ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/ |
H A D | dcamera_sink_data_process.cpp | 31 : 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_ != nullptr) { in SendDataAsync() 159 eventHandler_->PostTask(sendFunc); in SendDataAsync()
|
/ohos5.0/base/web/webview/ohos_adapter/event_handler_adapter/src/ |
H A D | event_handler_adapter_impl.cpp | 37 eventHandler_ = AppExecFwk::EventHandler::Current(); in EventHandlerAdapterImpl() 43 if (!listener || !eventHandler_) { in AddFileDescriptorListener() 48 return eventHandler_->AddFileDescriptorListener(fileDescriptor, events, fileDescriptorListener, in AddFileDescriptorListener() 54 if (eventHandler_) { in RemoveFileDescriptorListener() 55 eventHandler_->RemoveFileDescriptorListener(fileDescriptor); in RemoveFileDescriptorListener()
|
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | dms_continue_send_manager.cpp | 54 if (eventHandler_ != nullptr) { in Init() 84 if (eventHandler_ != nullptr && eventHandler_->GetEventRunner() != nullptr) { in UnInit() 87 eventHandler_ = nullptr; in UnInit() 117 if (eventHandler_ == nullptr) { in PostUnfocusedTaskWithDelay() 163 if (eventHandler_ == nullptr) { in NotifyMissionFocused() 169 eventHandler_->PostTask(feedfunc); in NotifyMissionFocused() 182 if (eventHandler_ != nullptr) { in NotifyMissionUnfocused() 541 if (eventHandler_ != nullptr) { in SetMissionContinueState() 652 if (eventHandler_ == nullptr) { in OnDeviceScreenOff() 656 eventHandler_->PostTask(feedfunc); in OnDeviceScreenOff() [all …]
|
/ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
H A D | socket_client.cpp | 39 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()
|
/ohos5.0/base/msdp/device_status/intention/cooperate/plugin/src/ |
H A D | cooperate_context.cpp | 155 eventHandler_.reset(); in StopEventHandler() 281 CHKPV(eventHandler_); in OnTransitionOut() 284 eventHandler_->PostTask( in OnTransitionOut() 295 CHKPV(eventHandler_); in OnTransitionIn() 298 eventHandler_->PostTask( in OnTransitionIn() 309 CHKPV(eventHandler_); in OnBack() 312 eventHandler_->PostTask( in OnBack() 323 CHKPV(eventHandler_); in OnRelayCooperation() 326 eventHandler_->PostTask( in OnRelayCooperation() 337 CHKPV(eventHandler_); in CloseDistributedFileConnection() [all …]
|
/ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
H A D | socket_client.cpp | 39 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in SocketClient() 69 CHKPF(eventHandler_); in Connect() 70 auto errCode = eventHandler_->AddFileDescriptorListener(socket->GetFd(), in Connect() 114 eventHandler_->RemoveFileDescriptorListener(socket_->GetFd()); in OnDisconnected() 115 eventHandler_->RemoveAllEvents(); in OnDisconnected() 122 if (!eventHandler_->PostTask([this] { this->Reconnect(); }, CLIENT_RECONNECT_COOLING_TIME)) { in OnDisconnected() 133 if (!eventHandler_->PostTask([this] { this->Reconnect(); }, CLIENT_RECONNECT_COOLING_TIME)) { in Reconnect()
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/app_mgr_service_dump_ffrt_test/ |
H A D | app_mgr_service_dump_ffrt_test.cpp | 87 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( 89 EXPECT_NE(appMgrService->eventHandler_, nullptr); 122 appMgrService->eventHandler_ = std::make_shared<AMSEventHandler>( 124 EXPECT_NE(appMgrService->eventHandler_, nullptr); 161 EXPECT_NE(appMgrService->eventHandler_, nullptr); 204 EXPECT_NE(appMgrService->eventHandler_, nullptr); 246 EXPECT_NE(appMgrService->eventHandler_, nullptr); 291 EXPECT_NE(appMgrService->eventHandler_, nullptr); 336 EXPECT_NE(appMgrService->eventHandler_, nullptr); 384 EXPECT_NE(appMgrService->eventHandler_, nullptr); [all …]
|
/ohos5.0/foundation/filemanagement/storage_service/services/storage_manager/storage/src/ |
H A D | storage_monitor_service.cpp | 68 if ((eventHandler_ != nullptr) && (eventHandler_->GetEventRunner() != nullptr)) { in ~StorageMonitorService() 69 eventHandler_->RemoveAllEvents(); in ~StorageMonitorService() 70 eventHandler_->GetEventRunner()->Stop(); in ~StorageMonitorService() 75 eventHandler_ = nullptr; in ~StorageMonitorService() 82 if (eventHandler_ == nullptr) { in StartStorageMonitorTask() 85 return eventHandler_ != nullptr; in StartStorageMonitorTask() 90 eventHandler_->PostTask(executeFunc, DEFAULT_CHECK_INTERVAL); in StartStorageMonitorTask() 103 eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner); in StartEventHandler() 111 if (eventHandler_ == nullptr) { in Execute() 117 eventHandler_->PostTask(executeFunc, DEFAULT_CHECK_INTERVAL); in Execute()
|
/ohos5.0/foundation/window/window_manager/wmserver/src/ |
H A D | window_inner_manager.cpp | 32 WindowInnerManager::WindowInnerManager() : eventHandler_(nullptr), eventLoop_(nullptr), in WM_IMPLEMENT_SINGLE_INSTANCE() 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_ == nullptr) { in StartWindowInfoReportLoop() [all …]
|
/ohos5.0/foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
H A D | cooperate_context.cpp | 167 eventHandler_.reset(); in StopEventHandler() 293 CHKPV(eventHandler_); in OnTransitionOut() 296 eventHandler_->PostTask( in OnTransitionOut() 307 CHKPV(eventHandler_); in OnTransitionIn() 310 eventHandler_->PostTask( in OnTransitionIn() 321 CHKPV(eventHandler_); in OnBack() 324 eventHandler_->PostTask( in OnBack() 335 CHKPV(eventHandler_); in OnRelayCooperation() 338 eventHandler_->PostTask( in OnRelayCooperation() 349 CHKPV(eventHandler_); in CloseDistributedFileConnection() [all …]
|