| /base/startup/init_lite/services/loopevent/task/ |
| D | le_watchtask.c | 28 uint32_t events = oper; in HandleWatcherEvent_() local
31 watcher->processEvent(taskHandle, fd, &events, (void *)userData); in HandleWatcherEvent_()
38 loop->delEvent(loop, fd, watcher->events); in HandleWatcherEvent_()
41 if (events == 0) { in HandleWatcherEvent_()
42 loop->delEvent(loop, fd, watcher->events); in HandleWatcherEvent_()
45 if (events != watcher->events) { in HandleWatcherEvent_()
46 watcher->events = events; in HandleWatcherEvent_()
47 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events); in HandleWatcherEvent_()
69 task->events = info->events; in LE_StartWatcher()
73 loop->addEvent(loop, (const BaseTask *)task, info->events); in LE_StartWatcher()
|
| /base/hiviewdfx/hiview/plugins/eventservice/service/ |
| D | sys_event_stat.cpp | 52 std::map<std::string, int64_t> events; in AddValidEvent() local
53 events[eventName] = 1; in AddValidEvent()
54 d2es_[domain] = events; in AddValidEvent()
58 std::map<std::string, int64_t> &events = it->second; in AddValidEvent() local
59 auto eIt = events.find(eventName); in AddValidEvent()
60 if (eIt == events.end()) { in AddValidEvent()
61 events[eventName] = 1; in AddValidEvent()
65 events[eventName] = events[eventName] + 1; in AddValidEvent()
168 int64_t SysEventSummaryStat::GetEventCount(std::map<std::string, int64_t> &events) const in GetEventCount()
171 for (auto it = events.begin(); it != events.end(); it++) { in GetEventCount()
[all …]
|
| /base/notification/ces_standard/services/ces/src/ |
| D | common_event_subscriber_manager.cpp | 50 std::vector<std::string> events = eventSubscribeInfo->GetMatchingSkills().GetEvents(); in InsertSubscriber() local
51 if (events.size() <= 0) { in InsertSubscriber()
71 if (!InsertSubscriberRecordLocked(events, record)) { in InsertSubscriber()
133 std::string events = format + "\tEvent: "; in DumpDetailed() local
141 … events = events + separator + record->eventSubscribeInfo->GetMatchingSkills().GetEvent(eventNum); in DumpDetailed()
143 events = events + "\n"; in DumpDetailed()
167 std::string matchingSkills = format + "MatchingSkills:\n" + events + entities + scheme; in DumpDetailed()
214 const std::vector<std::string> &events, const SubscriberRecordPtr &record) in InsertSubscriberRecordLocked() argument
216 if (events.size() == 0) { in InsertSubscriberRecordLocked()
228 for (auto event : events) { in InsertSubscriberRecordLocked()
[all …]
|
| D | common_event_sticky_manager.cpp | 34 auto events = subscribeInfo->GetMatchingSkills().GetEvents(); in FindStickyEvents() local
35 if (events.size() == 0) { in FindStickyEvents()
40 FindStickyEventsLocked(events, commonEventRecords); in FindStickyEvents()
173 const std::vector<std::string> &events, std::vector<CommonEventRecordPtr> &commonEventRecords) in FindStickyEventsLocked() argument
177 for (auto event : events) { in FindStickyEventsLocked()
|
| /base/powermgr/thermal_manager/application/protector/src/ |
| D | thermal_protector_timer.cpp | 75 ev.events = EPOLLIN; in RegisterCallback()
77 ev.events |= EPOLLWAKEUP; in RegisterCallback()
145 struct epoll_event events[eventct]; in LoopingThreadEntry() local
151 nevents = epoll_wait(epfd, events, eventct, -1); in LoopingThreadEntry()
156 if (events[n].data.ptr) { in LoopingThreadEntry()
158 (callbackHandler_.find(events[n].data.fd)->second)(func, arg); in LoopingThreadEntry()
|
| D | thermal_sensor_provider.cpp | 182 ev.events = EPOLLIN; in RegisterCallback()
184 ev.events |= EPOLLWAKEUP; in RegisterCallback()
201 struct epoll_event events[eventct]; in LoopingThreadEntry() local
204 nevents = epoll_wait(epfd, events, eventct, -1); in LoopingThreadEntry()
209 if (events[n].data.ptr) { in LoopingThreadEntry()
211 (callbackHandler_.find(events[n].data.fd)->second)(func, arg); in LoopingThreadEntry()
|
| /base/hiviewdfx/hisysevent/adapter/native/idl/include/ |
| D | sys_event_query_rule.h | 29 SysEventQueryRule(const std::string& domain, const std::vector<std::string>& events,
31 : domain(domain), eventList(events), ruleType(ruleType) {}; in domain()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/ |
| D | sys_event_query_rule.h | 29 SysEventQueryRule(const std::string& domain, const std::vector<std::string>& events,
31 : domain(domain), eventList(events), ruleType(ruleType) {}; in domain()
|
| /base/notification/ces_standard/tools/test/mock/ |
| D | mock_common_event_stub.cpp | 46 auto events = matchingSkills.GetEvents(); in DumpState() local
48 for (auto it : events) { in DumpState()
|
| /base/hiviewdfx/hiview/plugins/eventservice/include/ |
| D | sys_event_stat.h | 83 virtual void StatDomainEvent(int fd, std::map<std::string, int64_t> &events) const;
90 int64_t GetEventCount(std::map<std::string, int64_t> &events) const;
100 void StatDomainEvent(int fd, std::map<std::string, int64_t> &events) const override;
103 …void GetEventNames(std::map<std::string, int64_t> &events, std::vector<std::string> &eventNames) c…
|
| /base/miscservices/time/services/timer/src/ |
| D | timer_handler.cpp | 71 event.events = EPOLLIN | EPOLLWAKEUP; in Create()
121 epoll_event events[N_TIMER_FDS]; in WaitForAlarm() local
123 int nevents = epoll_wait(epollFd_, events, N_TIMER_FDS, -1); in WaitForAlarm()
130 uint32_t alarm_idx = events[i].data.u32; in WaitForAlarm()
|
| /base/sensors/sensor/frameworks/native/sensor/include/ |
| D | sensor_data_channel.h | 28 typedef void (*DataChannelCB)(struct SensorEvent *events, int32_t num, void *data);
33 static int32_t HandleEvent(int32_t fd, int32_t events, void *data);
|
| D | sensor_agent_proxy.h | 31 typedef int32_t (*SensorDataCallback)(struct SensorNativeData *events, uint32_t num);
50 static void HandleSensorData(SensorEvent *events, int32_t num, void *data);
|
| /base/telephony/ril_adapter/services/hril/include/ |
| D | hril_timer_callback.h | 43 void FdTriggerCallback(int32_t fd, int16_t events, std::shared_ptr<void> param);
44 void TimerCallback(int32_t fd, int16_t events, std::shared_ptr<void> param);
|
| /base/notification/ans_standard/frameworks/ans/test/moduletest/ |
| D | ans_fw_module_test.cpp | 475 void Parse(std::list<std::shared_ptr<SubscriberEvent>> events) in Parse() argument
477 GTEST_LOG_(INFO) << "TestAnsSubscriber::Parse event size=" << events.size(); in Parse()
478 for (auto event : events) { in Parse()
668 std::list<std::shared_ptr<SubscriberEvent>> events = subscriber.GetEvents(); variable
670 eventParser.Parse(events);
725 std::list<std::shared_ptr<SubscriberEvent>> events = subscriber.GetEvents(); variable
727 eventParser.Parse(events);
770 std::list<std::shared_ptr<SubscriberEvent>> events = subscriber.GetEvents(); variable
772 eventParser.Parse(events);
776 events = subscriber.GetEvents();
[all …]
|
| /base/startup/init_lite/services/loopevent/loop/ |
| D | le_epoll.c | 28 event->events = EPOLLIN; in GetEpollEvent_()
31 event->events = EPOLLOUT; in GetEpollEvent_()
99 if ((epoll->waitEvents[index].events & EPOLLIN) == EPOLLIN) { in RunLoop_()
102 if ((epoll->waitEvents[index].events & EPOLLOUT) == EPOLLOUT) { in RunLoop_()
|
| /base/msdp/device_status/libs/src/ |
| D | devicestatus_msdp_rdb.cpp | 285 ev.events = EPOLLIN; in RegisterTimerCallback()
287 ev.events |= EPOLLWAKEUP; in RegisterTimerCallback()
309 struct epoll_event events[cbct]; in LoopingThreadEntry() local
314 int32_t nevents = epoll_wait(epFd_, events, cbct, timeout); in LoopingThreadEntry()
319 if (events[n].data.ptr) { in LoopingThreadEntry()
321 (callbacks_.find(events[n].data.fd)->second)(func); in LoopingThreadEntry()
|
| D | devicestatus_sensor_rdb.cpp | 347 ev.events = EPOLLIN; in RegisterTimerCallback()
349 ev.events |= EPOLLWAKEUP; in RegisterTimerCallback()
371 struct epoll_event events[cbct]; in LoopingThreadEntry() local
376 int32_t nevents = epoll_wait(epFd_, events, cbct, timeout); in LoopingThreadEntry()
381 if (events[n].data.ptr) { in LoopingThreadEntry()
383 (callbacks_.find(events[n].data.fd)->second)(func); in LoopingThreadEntry()
|
| /base/notification/ces_standard/interfaces/kits/js/commonEvent/ |
| D | commonEventSubscribeInfo.d.ts | 31 events: Array<string>; property
|
| /base/hiviewdfx/hisysevent/adapter/native/idl/src/ |
| D | hisysevent_delegate.cpp | 49 std::vector<std::string> events; in ConvertQueryRule() local
52 events.push_back(event); in ConvertQueryRule()
55 sysRules.emplace_back(rule.GetDomain(), events, rule.GetRuleType()); in ConvertQueryRule()
|
| /base/telephony/state_registry/ |
| D | README.md | 17 …gister an observer that listens for various callback events of the telephony subsystem. Such event…
42 …ly when SIM cards are in position. If SIM cards are removed, no callback events will be received. …
62 Different subscription events are distinguished by the **type** parameter. The following table li…
78 The function of registering an observer for call status change events is used as an example. The pr…
80 …thod with the **type** parameter specified to register an observer for different types of events.
|
| /base/hiviewdfx/hiview/ |
| D | README.md | 34 Formatted events are reported to Hiview through the **HiSysEvent** API for processing. Figure 2 s…
40 1. The application framework and system services report system events using the **HiSysEvent** AP…
42 2. HiSysEventSource reads events and prints the events to logs.
|
| /base/notification/ces_standard/services/test/unittest/ |
| D | common_event_subscribe_unit_test.cpp | 408 std::vector<std::string> events = subscribeInfo.GetMatchingSkills().GetEvents(); variable
422 int result = commonEventSubscriberManager.InsertSubscriberRecordLocked(events, record);
445 std::vector<std::string> events = subscribeInfo.GetMatchingSkills().GetEvents(); variable
459 int result = commonEventSubscriberManager.InsertSubscriberRecordLocked(events, record);
475 std::vector<std::string> events = subscribeInfo.GetMatchingSkills().GetEvents(); variable
479 int result = commonEventSubscriberManager.InsertSubscriberRecordLocked(events, nullptr);
|
| /base/startup/init_lite/services/init/standard/ |
| D | fd_holder_service.c | 222 static void ProcessFdHoldEvent(const WatcherHandle taskHandle, int fd, uint32_t *events, const void… in ProcessFdHoldEvent() argument
225 *events = Event_Read; in ProcessFdHoldEvent()
239 info.events = Event_Read; in RegisterFdHoldWatcher()
|
| /base/telephony/ril_adapter/services/hril/src/ |
| D | hril_timer_callback.cpp | 31 void HRilTimerCallback::FdTriggerCallback(int32_t fd, int16_t events, std::shared_ptr<void> param) in FdTriggerCallback() argument
41 void HRilTimerCallback::TimerCallback(int32_t fd, int16_t events, std::shared_ptr<void> param) in TimerCallback() argument
|