/ohos5.0/foundation/window/window_manager/window_scene/intention_event/framework/anr_handler/src/ |
H A D | anr_handler.cpp | 54 auto task = [this, eventId, sessionStage]() { in SetSessionStage() 70 auto task = [this, eventId, actionTime]() { in HandleEventConsumed() 74 UpdateLatestEventId(eventId); in HandleEventConsumed() 86 SendEvent(eventId, 0); in HandleEventConsumed() 140 ClearExpiredEvents(eventId); in SetAnrHandleState() 154 eventId, GetPersistentIdOfEvent(eventId)); in MarkProcessed() 165 SetAnrHandleState(eventId, false); in MarkProcessed() 171 SetAnrHandleState(eventId, true); in SendEvent() 180 SetAnrHandleState(eventId, false); in SendEvent() 190 if (iter->first < eventId && in ClearExpiredEvents() [all …]
|
/ohos5.0/base/notification/eventhandler/frameworks/cj/src/ |
H A D | emitter.cpp | 34 InnerEvent::EventId eventId; member 132 OutPutEventIdLog(eventId); in OnOrOnce() 157 InnerEvent::EventId id = eventId; in On() 169 InnerEvent::EventId id = eventId; in Once() 199 void Emitter::Off(uint32_t eventId) in Off() argument 201 InnerEvent::EventId id = eventId; in Off() 205 void Emitter::Off(char* eventId) in Off() argument 213 InnerEvent::EventId id = eventId; in Off() 225 InnerEvent::EventId id = eventId; in Emit() 252 InnerEvent::EventId id = eventId; in GetListenerCount() [all …]
|
H A D | emitter_ffi.cpp | 44 return Emitter::On(eventId, callback); in CJ_OnWithId() 53 return Emitter::On(eventId, callback); in CJ_OnWithStringId() 62 return Emitter::Once(eventId, callback); in CJ_OnceWithId() 74 void CJ_OffWithId(uint32_t eventId) in CJ_OffWithId() argument 76 Emitter::Off(eventId); in CJ_OffWithId() 79 void CJ_OffWithString(char* eventId) in CJ_OffWithString() argument 81 Emitter::Off(eventId); in CJ_OffWithString() 90 Emitter::Off(eventId, callback); in CJ_OffWithIdCallback() 101 Emitter::Off(eventId, callback); in CJ_OffWithStringCallback() 108 Emitter::Emit(eventId, priority, data); in CJ_EmitWithId() [all …]
|
H A D | emitter_ffi.h | 32 FFI_EXPORT int32_t CJ_OnWithId(uint32_t eventId, CEventCallback callbackInfo); 33 FFI_EXPORT int32_t CJ_OnWithStringId(char* eventId, CEventCallback callbackInfo); 34 FFI_EXPORT int32_t CJ_OnceWithId(uint32_t eventId, CEventCallback callbackInfo); 35 FFI_EXPORT int32_t CJ_OnceWithStringId(char* eventId, CEventCallback callbackInfo); 36 FFI_EXPORT void CJ_OffWithId(uint32_t eventId); 37 FFI_EXPORT void CJ_OffWithString(char* eventId); 38 FFI_EXPORT int32_t CJ_OffWithIdCallback(uint32_t eventId, CEventCallback callbackInfo); 40 FFI_EXPORT void CJ_EmitWithId(uint32_t eventId, uint32_t priority, CEventData data); 41 FFI_EXPORT void CJ_EmitWithString(char* eventId, uint32_t priority, CEventData data); 42 FFI_EXPORT uint32_t CJ_GetListenerCountById(uint32_t eventId); [all …]
|
H A D | emitter.h | 41 static int32_t On(uint32_t eventId, CallbackImpl *callback); 43 static int32_t On(char* eventId, CallbackImpl *callback); 45 static int32_t Once(uint32_t eventId, CallbackImpl *callback); 47 static int32_t Once(char* eventId, CallbackImpl *callback); 49 static void Off(uint32_t eventId); 51 static void Off(char* eventId); 53 static void Off(uint32_t eventId, CallbackImpl *callback); 55 static void Off(char* eventId, CallbackImpl *callback); 59 static void Emit(char* eventId, uint32_t priority, CEventData data); 61 static uint32_t GetListenerCount(uint32_t eventId); [all …]
|
/ohos5.0/docs/zh-cn/application-dev/reference/apis-basic-services-kit/ |
H A D | js-apis-emitter.md | 40 eventId: 1 43 // 收到eventId为1的事件后执行回调函数 69 // 收到eventId为"eventId"的事件后执行回调函数 110 // 收到eventId为"eventId"的事件后执行回调函数 135 eventId: 1 138 // 收到eventId为1的事件后执行该回调函数 164 // 收到eventId为"eventId"的事件后执行该回调函数 205 // 收到eventId为"eventId"的事件后执行回调函数 252 emitter.off("eventId"); 377 eventId: 1, [all …]
|
/ohos5.0/base/telephony/core_service/test/unittest/tel_ril_gtest/ |
H A D | tel_ril_test_util.cpp | 306 auto event = AppExecFwk::InnerEvent::Get(eventId); in CallGetCurrentCallsStatusTest() 326 auto event = AppExecFwk::InnerEvent::Get(eventId); in SimGetSimStatusTest() 345 auto event = AppExecFwk::InnerEvent::Get(eventId); in SimIccIoTest() 373 auto event = AppExecFwk::InnerEvent::Get(eventId); in SimGetImsiTest() 392 auto event = AppExecFwk::InnerEvent::Get(eventId); in GetSimLockStatusTest() 412 auto event = AppExecFwk::InnerEvent::Get(eventId); in SetSimLockTest() 435 auto event = AppExecFwk::InnerEvent::Get(eventId); in UnSetSimLockTest() 458 auto event = AppExecFwk::InnerEvent::Get(eventId); in ChangeSimPasswordTest() 2374 eventId, eventId_); in GetBoolResult() 2379 if (eventId_ != eventId) { in GetBoolResult() [all …]
|
/ohos5.0/base/security/security_guard/services/security_collector/src/ |
H A D | data_collection.cpp | 42 for (int64_t eventId : eventIds) { in StartCollectors() local 44 if (IsCollectorStarted(eventId)) { in StartCollectors() 61 loadedEventIds_.push_back(eventId); in StartCollectors() 71 for (int64_t eventId : eventIds) { in SecurityGuardSubscribeCollector() local 73 if (IsCollectorStarted(eventId)) { in SecurityGuardSubscribeCollector() 88 loadedEventIds_.push_back(eventId); in SecurityGuardSubscribeCollector() 97 auto it = eventIdToLoaderMap_.find(eventId); in IsCollectorStarted() 110 for (int64_t eventId : eventIds) { in StopCollectors() local 156 result = collector->Subscribe(eventId); in LoadCollector() 198 auto ifIt = std::find(module.eventId.begin(), module.eventId.end(), eventId); in GetCollectorPath() [all …]
|
H A D | security_collector_subscriber_manager.cpp | 47 const auto it = eventToSubscribers_.find(event.eventId); in NotifySubscriber() 73 const auto &subscribers = eventToSubscribers_[eventId]; in GetAppSubscribeCount() 123 int64_t eventId = subscriber->GetSecurityCollectorSubscribeInfo().GetEvent().eventId; in SubscribeCollector() local 129 if (GetAppSubscribeCount(appName, eventId) > 0) { in SubscribeCollector() 133 if (eventToListenner_.count(eventId) == 0) { in SubscribeCollector() 144 eventToSubscribers_[eventId].emplace(subscriber); in SubscribeCollector() 146 eventId, static_cast<uint32_t>(eventToSubscribers_[eventId].size())); in SubscribeCollector() 161 for (int64_t eventId : eventIds) { in UnsubscribeCollector() local 163 if (eventId == -1) { in UnsubscribeCollector() 177 eventToSubscribers_.erase(eventId); in UnsubscribeCollector() [all …]
|
H A D | security_collector_run_manager.cpp | 51 int64_t eventId = subscriber->GetSecurityCollectorSubscribeInfo().GetEvent().eventId; in StartCollector() local 52 LOGI("appName:%{public}s, eventId:%{public}" PRId64 "", appName.c_str(), eventId); in StartCollector() 53 if (collectorRunManager_.find(eventId) != collectorRunManager_.end()) { in StartCollector() 59 LOGI("start collector, eventId:%{public}" PRId64 "", eventId); in StartCollector() 64 collectorRunManager_.emplace(eventId, subscriber); in StartCollector() 76 int64_t eventId = subscriber->GetSecurityCollectorSubscribeInfo().GetEvent().eventId; in StopCollector() local 78 if (collectorRunManager_.find(eventId) == collectorRunManager_.end()) { in StopCollector() 83 if (collectorRunManager_[eventId]->GetAppName() != appName) { in StopCollector() 85 collectorRunManager_[eventId]->GetAppName().c_str(), appName.c_str()); in StopCollector() 88 LOGI("Scheduling stop collector, eventId:%{public}" PRId64 "", eventId); in StopCollector() [all …]
|
/ohos5.0/base/security/security_guard/services/data_collect/store/src/ |
H A D | database_manager.cpp | 46 SGLOGE("not found event, id=%{public}" PRId64 "", event.eventId); in InsertEvent() 159 int64_t DatabaseManager::CountEventByEventId(int64_t eventId) in CountEventByEventId() argument 177 int DatabaseManager::DeleteAllEventByEventId(int64_t eventId) in DeleteAllEventByEventId() argument 193 for (int64_t eventId : eventIds) { in SubscribeDb() local 194 SGLOGI("SubscribeDb EVENTID %{public}" PRId64 "", eventId); in SubscribeDb() 195 listenerMap_[eventId].insert(listener); in SubscribeDb() 206 for (int64_t eventId : eventIds) { in UnSubscribeDb() local 207 listenerMap_[eventId].erase(listener); in UnSubscribeDb() 209 if (listenerMap_[eventId].size() == 0) { in UnSubscribeDb() 210 listenerMap_.erase(eventId); in UnSubscribeDb() [all …]
|
/ohos5.0/base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
H A D | lib_event_handler_event_test.cpp | 105 uint32_t eventId = 0; variable 125 uint32_t eventId = 0; variable 149 uint32_t eventId = 0; variable 175 uint32_t eventId = 0; variable 200 uint32_t eventId = 0; variable 241 uint32_t eventId = 0; variable 266 uint32_t eventId = 0; variable 378 ++eventId; 381 ++eventId; 420 ++eventId; [all …]
|
H A D | lib_event_handler_event_queue_test.cpp | 246 for (uint32_t eventId = 0; eventId < NUM; eventId++) { in InsertPriorityEvent() local 258 for (uint32_t eventId = NUM; eventId < NUM * length + NUM; eventId++) { in InsertPriorityEvent() local 275 for (uint32_t eventId = 0; eventId < LOW_PRIORITY_COUNT; eventId++) { in InsertAllPriorityEvent() local 287 for (uint32_t eventId = LOW_PRIORITY_COUNT; eventId < HIGH_PRIORITY_COUNT; eventId++) { in InsertAllPriorityEvent() local 299 for (uint32_t eventId = HIGH_PRIORITY_COUNT; eventId < IMMEDIATE_PRIORITY_COUNT; eventId++) { in InsertAllPriorityEvent() local 598 for (uint32_t eventId = 0; eventId < MAX_HIGH_PRIORITY_COUNT + 1; eventId++) { variable 619 for (uint32_t eventId = 0; eventId < MAX_HIGH_PRIORITY_COUNT + num; eventId++) { variable 646 for (uint32_t eventId = 2; eventId < MAX_HIGH_PRIORITY_COUNT + NUM; eventId++) { variable 703 … for (uint32_t eventId = 0; eventId < IMMEDIATE_PRIORITY_COUNT - HIGH_PRIORITY_COUNT; eventId++) { variable 1888 for (uint32_t eventId = 0; eventId < MAX_HIGH_PRIORITY_COUNT + 1; eventId++) { variable [all …]
|
/ohos5.0/base/security/security_guard/services/data_collect/sa/ |
H A D | acquire_data_subscribe_manager.cpp | 47 int64_t event = subscribeInfo.GetEvent().eventId; in InsertSubscribeRecord() 70 int AcquireDataSubscribeManager::SubscribeSc(int64_t eventId) in SubscribeSc() argument 72 if (scSubscribeMap_.count(eventId)) { in SubscribeSc() 83 scEvent.eventId = eventId; in SubscribeSc() 99 scSubscribeMap_[scEvent.eventId] = subscriber; in SubscribeSc() 105 int AcquireDataSubscribeManager::UnSubscribeSc(int64_t eventId) in UnSubscribeSc() argument 114 auto it = scSubscribeMap_.find(eventId); in UnSubscribeSc() 175 auto iter = eventIdToSubscriberMap_.find(events.eventId); in Publish() 186 .eventId = events.eventId, in Publish() 194 if (event.eventId == SecurityCollector::FILE_EVENTID || in Publish() [all …]
|
/ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packageusage/src/ |
H A D | bundle_active_report_handler.cpp | 42 void BundleActiveReportHandler::SendEvent(const int32_t& eventId, in SendEvent() argument 52 if (taskHandlerMap_.find(eventId) == taskHandlerMap_.end()) { in SendEvent() 56 reportHandler->ProcessEvent(eventId, handlerobj); in SendEvent() 61 if (!reportHandler->taskHandlerMap_[eventId].empty()) { in SendEvent() 62 reportHandler->taskHandlerMap_[eventId].pop(); in SendEvent() 65 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent() 78 while (!taskHandlerMap_[eventId].empty()) { in RemoveEvent() 79 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent() 80 taskHandlerMap_[eventId].pop(); in RemoveEvent() 82 taskHandlerMap_.erase(eventId); in RemoveEvent() [all …]
|
/ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packagegroup/src/ |
H A D | bundle_active_group_handler.cpp | 86 groupHandler->ProcessEvent(eventId, handlerobj); in SendCheckBundleMsg() 120 void BundleActiveGroupHandler::SendEvent(const int32_t& eventId, in SendEvent() argument 134 groupHandler->ProcessEvent(eventId, handlerobj); in SendEvent() 139 if (!groupHandler->taskHandlerMap_[eventId].empty()) { in SendEvent() 140 groupHandler->taskHandlerMap_[eventId].pop(); in SendEvent() 143 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent() 156 while (!taskHandlerMap_[eventId].empty()) { in RemoveEvent() 157 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent() 158 taskHandlerMap_[eventId].pop(); in RemoveEvent() 160 taskHandlerMap_.erase(eventId); in RemoveEvent() [all …]
|
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/video/ |
H A D | video_component.h | 162 preparedEventId_ = eventId; in SetPreparedEventId() 172 startEventId_ = eventId; in SetStartEventId() 182 pauseEventId_ = eventId; in SetPauseEventId() 190 void SetStopEventId(const EventMarker& eventId) in SetStopEventId() argument 192 stopEventId_ = eventId; in SetStopEventId() 202 finishEventId_ = eventId; in SetFinishEventId() 212 errorEventId_ = eventId; in SetErrorEventId() 222 seekingEventId_ = eventId; in SetSeekingEventId() 232 seekedEventId_ = eventId; in SetSeekedEventId() 242 timeUpdateEventId_ = eventId; in SetTimeUpdateEventId() [all …]
|
/ohos5.0/foundation/multimodalinput/input/frameworks/proxy/event_handler/src/ |
H A D | anr_handler.cpp | 47 void ANRHandler::SetLastProcessedEventId(int32_t eventType, int32_t eventId, int64_t actionTime) in SetLastProcessedEventId() argument 56 lastEventId_ = eventId; in SetLastProcessedEventId() 58 SendEvent(eventType, eventId); in SetLastProcessedEventId() 61 void ANRHandler::MarkProcessed(int32_t eventType, int32_t eventId) in MarkProcessed() argument 64 BytraceAdapter::StartMarkedTracker(eventId); in MarkProcessed() 65 MMI_HILOGD("Processed event type:%{public}d, id:%{public}d", eventType, eventId); in MarkProcessed() 68 idList_.push_back(eventId); in MarkProcessed() 75 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->MarkProcessed(eventType, eventId); in MarkProcessed() 82 void ANRHandler::SendEvent(int32_t eventType, int32_t eventId) in SendEvent() argument 85 auto task = [this, eventType, eventId] { in SendEvent() [all …]
|
/ohos5.0/base/telephony/core_service/interfaces/innerkits/include/ |
H A D | core_manager_inner.h | 61 int32_t Dial(int32_t slotId, int32_t eventId, std::string address, int clirMode, 96 int32_t SetDataPermitted(int32_t slotId, int32_t eventId, int32_t dataPermitted, 98 int32_t SetInitApnInfo(int32_t slotId, int32_t eventId, const DataProfile &dataProfile, 117 int32_t StartDTMF(int32_t slotId, int32_t eventId, char cDTMFCode, int32_t index, 119 int32_t SendDTMF(int32_t slotId, int32_t eventId, char cDTMFCode, int32_t index, 121 int32_t SendDTMF(int32_t slotId, int32_t eventId, const DtmfParam &dtmfParam, 134 int32_t SetUssd(int32_t slotId, int32_t eventId, const std::string str, 154 int32_t SendGsmSms(int32_t slotId, int32_t eventId, GsmSimMessageParam &gsmMessage, 156 int32_t SendCdmaSms(int32_t slotId, int32_t eventId, std::string pdu, int64_t refId, 169 int32_t SendSmsAck(int32_t slotId, int32_t eventId, bool success, int32_t cause, [all …]
|
/ohos5.0/base/security/security_guard/oem_property/hos/ |
H A D | security_audit.cfg | 5 "eventId":["1011015002"], 13 "eventId":["1011015003"], 21 "eventId":["1011015007"], 29 "eventId":["1011015006"], 37 "eventId":["1011015005"], 45 "eventId":["1011015010"], 53 "eventId":["1011015009"], 61 "eventId":["1011015012"], 69 "eventId":["1011015011"], 85 "eventId":["1064001001"], [all …]
|
/ohos5.0/foundation/resourceschedule/device_usage_statistics/interfaces/innerkits/src/ |
H A D | bundle_active_package_stats.cpp | 94 …if (eventId != BundleActiveEvent::ABILITY_FOREGROUND && eventId != BundleActiveEvent::ABILITY_BACK… in UpdateAbility() 95 eventId != BundleActiveEvent::ABILITY_STOP) { in UpdateAbility() 120 switch (eventId) { in UpdateAbility() 125 abilities_[abilityId] = eventId; in UpdateAbility() 128 abilities_[abilityId] = eventId; in UpdateAbility() 139 const int32_t eventId) in UpdateLongTimeTask() argument 141 …if (eventId != BundleActiveEvent::LONG_TIME_TASK_STARTTED && eventId != BundleActiveEvent::LONG_TI… in UpdateLongTimeTask() 158 switch (eventId) { in UpdateLongTimeTask() 163 longTimeTasks_[longTimeTaskName] = eventId; in UpdateLongTimeTask() 176 switch (eventId) { in Update() [all …]
|
/ohos5.0/base/security/security_guard/services/risk_classify/model_manager/src/ |
H A D | db_operate.cpp | 32 int DbOperate::QueryRecentEventByEventId(int64_t eventId, SecEvent &event) in QueryRecentEventByEventId() argument 34 return DatabaseManager::GetInstance().QueryRecentEventByEventId(eventId, event); in QueryRecentEventByEventId() 39 return DatabaseManager::GetInstance().QueryRecentEventByEventId(table_, eventId, event); in QueryRecentEventByEventId() 42 int DbOperate::QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) in QueryEventByEventId() argument 44 return DatabaseManager::GetInstance().QueryEventByEventId(eventId, events); in QueryEventByEventId() 72 int64_t DbOperate::CountEventByEventId(int64_t eventId) in CountEventByEventId() argument 74 return DatabaseManager::GetInstance().CountEventByEventId(eventId); in CountEventByEventId() 77 int DbOperate::DeleteOldEventByEventId(int64_t eventId, int64_t count) in DeleteOldEventByEventId() argument 79 return DatabaseManager::GetInstance().DeleteOldEventByEventId(eventId, count); in DeleteOldEventByEventId() 82 int DbOperate::DeleteAllEventByEventId(int64_t eventId) in DeleteAllEventByEventId() argument [all …]
|
/ohos5.0/foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/ |
H A D | device_status_collect_manager.cpp | 159 return (ev1.eventId == ev2.eventId && ev1.name == ev2.name && in IsSameEvent() 165 if (ev1.eventId != TIMED_EVENT) { in IsSameEventName() 166 if (ev1.eventId == ev2.eventId && ev1.name == ev2.name) { in IsSameEventName() 170 if (ev1.eventId == ev2.eventId && ev1.name == ev2.name && ev1.value == ev2.value && in IsSameEventName() 204 HILOGD("CheckExtraMessages begin evt1:%{public}d, evt2:%{public}d", ev1.eventId, ev2.eventId); in CheckExtraMessages() 205 if (collectPluginMap_.count(ev1.eventId) == 0) { in CheckExtraMessages() 209 if (collectPluginMap_[ev1.eventId] == nullptr) { in CheckExtraMessages() 284 if (event.eventId == DEVICE_ONLINE) { in ReportEvent() 306 if (collectPluginMap_.count(eventId) == 0) { in IsExistInPluginMap() 310 if (collectPluginMap_[eventId] == nullptr) { in IsExistInPluginMap() [all …]
|
/ohos5.0/base/security/security_guard/interfaces/inner_api/collect/test/unittest/src/ |
H A D | data_collect_kit_test.cpp | 90 static int64_t eventId = 1011009000; variable 94 info.eventId = eventId; 112 static int64_t eventId = 1011009000; variable 116 info.eventId = eventId; 134 static int64_t eventId = 1011009000; variable 138 info.eventId = eventId; 156 static int64_t eventId = 1011009000; variable 160 info.eventId = eventId; 178 static int64_t eventId = 0; variable 182 info.eventId = eventId; [all …]
|
/ohos5.0/base/startup/init/services/loopevent/task/ |
H A D | le_asynctask.c | 37 uint64_t eventId = *(uint64_t*)(buffer->data); in DoAsyncEvent_() local 39 asyncTask->processAsyncEvent((TaskHandle)asyncTask, eventId, in DoAsyncEvent_() 74 uint64_t eventId = 0; in HandleAsyncEvent_() local 75 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_() 83 static uint64_t eventId = 0; in HandleAsyncEvent_() local 84 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_() 86 eventId++; in HandleAsyncEvent_() 136 BufferHandle handle = LE_CreateBuffer(loopHandle, buffLen + 1 + sizeof(eventId)); in LE_StartAsyncEvent() 139 int ret = memcpy_s(buff, sizeof(eventId), &eventId, sizeof(eventId)); in LE_StartAsyncEvent() 142 ret = memcpy_s(buff + sizeof(eventId), buffLen, data, buffLen); in LE_StartAsyncEvent() [all …]
|