/base/msdp/device_status/rust/subsystem/device_profile/binding/src/ |
H A D | fusion_device_profile.cpp | 115 CIProfileEvents* events = new (std::nothrow) CIProfileEvents; in SubscribeProfileEvents() local 116 CHKPR(events, RET_ERR); in SubscribeProfileEvents() 117 events->numOfProfileEvents = fails.size(); in SubscribeProfileEvents() 118 events->profileEvents = new (std::nothrow) uint32_t[fails.size()]; in SubscribeProfileEvents() 119 if (events->profileEvents == nullptr) { in SubscribeProfileEvents() 120 delete events; in SubscribeProfileEvents() 124 events->clone = nullptr; in SubscribeProfileEvents() 125 events->destruct = &Destruct; in SubscribeProfileEvents() 129 events->profileEvents[index++] = profile_event; in SubscribeProfileEvents() 131 *failedEvents = events; in SubscribeProfileEvents() 163 CIProfileEvents* events = new (std::nothrow) CIProfileEvents; UnsubscribeProfileEvents() local [all...] |
/base/startup/init/test/unittest/modules/ |
H A D | sysevent_unittest.cpp | 31 extern void ReportBootEventComplete(ListNode *events); 34 static void AddBootEvent(ListNode *events, const char *name, int32_t type) in AddBootEvent() argument 49 OH_ListAddTail(events, (ListNode *)&item->node); in AddBootEvent() 80 ListNode events = { &events, &events }; in HWTEST_F() local 82 ReportBootEventComplete(&events); in HWTEST_F() 87 ListNode events = { &events, &events }; in HWTEST_F() local [all...] |
/base/hiviewdfx/hiview/plugins/usage_event_report/test/unittest/ |
H A D | usage_event_report_cache_test.cpp | 49 std::vector<std::shared_ptr<LoggerEvent>> events;
in HWTEST_F() local 51 cacher.GetPluginStatsEvents(events);
in HWTEST_F() 52 EXPECT_TRUE(events.empty());
in HWTEST_F() 54 events.emplace_back(pluginStatEvent);
in HWTEST_F() 55 cacher.SavePluginStatsEventsToDb(events);
in HWTEST_F() 56 events.clear();
in HWTEST_F() 57 cacher.GetPluginStatsEvents(events);
in HWTEST_F() 58 EXPECT_TRUE(!events.empty());
in HWTEST_F() 60 events.clear();
in HWTEST_F() 61 cacher.GetPluginStatsEvents(events);
in HWTEST_F() [all...] |
/base/security/security_guard/test/unittest/mock/data_collect/ |
H A D | risk_event_rdb_helper.h | 31 virtual int QueryAllEvent(std::vector<SecEvent> &events) = 0; 34 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) = 0; 35 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) = 0; 36 virtual int QueryEventByEventIdAndDate(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events, 38 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) = 0; 39 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) = 0; 40 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) = 0; 58 MOCK_METHOD1(QueryAllEvent, int(std::vector<SecEvent> &events)); 61 MOCK_METHOD2(QueryEventByEventId, int(int64_t eventId, std::vector<SecEvent> &events)); 62 MOCK_METHOD2(QueryEventByEventId, int(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events)); [all...] |
/base/hiviewdfx/hiappevent/test/unittest/common/native/ |
H A D | hiappevent_cache_test.cpp | 73 std::vector<std::shared_ptr<AppEventPack>> events;
in HWTEST_F() local 74 result = AppEventStore::GetInstance().QueryEvents(events, observerSeq);
in HWTEST_F() 76 ASSERT_GT(events.size(), 0);
in HWTEST_F() 77 ASSERT_EQ(events[0]->GetDomain(), TEST_EVENT_DOMAIN);
in HWTEST_F() 78 ASSERT_EQ(events[0]->GetName(), TEST_EVENT_NAME);
in HWTEST_F() 79 ASSERT_EQ(events[0]->GetType(), TEST_EVENT_TYPE);
in HWTEST_F() 114 std::vector<std::shared_ptr<AppEventPack>> events;
in HWTEST_F() local 115 result = AppEventStore::GetInstance().TakeEvents(events, observerSeq);
in HWTEST_F() 117 ASSERT_GT(events.size(), 0);
in HWTEST_F() 118 ASSERT_EQ(events[ in HWTEST_F() 163 std::vector<std::shared_ptr<AppEventPack>> events; HWTEST_F() local 195 std::vector<std::shared_ptr<AppEventPack>> events; HWTEST_F() local 269 std::vector<std::shared_ptr<AppEventPack>> events; HWTEST_F() local [all...] |
H A D | hiappevent_watcher_test.cpp | 84 void OnEvents(const std::vector<std::shared_ptr<AppEventPack>>& events) override
86 std::cout << GetName() << " OnEvents size=" << events.size() << std::endl;
87 for (const auto& event : events) {
191 std::vector<std::shared_ptr<AppEventPack>> events;
in HWTEST_F() local 192 events.emplace_back(CreateAppEventPack());
in HWTEST_F() 193 AppEventObserverMgr::GetInstance().HandleEvents(events);
in HWTEST_F() 199 events.clear();
in HWTEST_F() 200 events.emplace_back(CreateAppEventPack("invalid_domain"));
in HWTEST_F() 201 AppEventObserverMgr::GetInstance().HandleEvents(events);
in HWTEST_F() 236 std::vector<std::shared_ptr<AppEventPack>> events;
in HWTEST_F() local 264 std::vector<std::shared_ptr<AppEventPack>> events; HWTEST_F() local 291 std::vector<std::shared_ptr<AppEventPack>> events; HWTEST_F() local [all...] |
/base/sensors/miscdevice/utils/common/src/ |
H A D | vibrator_infos.cpp | 32 int32_t size = static_cast<int32_t>(events.size()); in Dump() 35 std::string tag = (events[i].tag == EVENT_TAG_CONTINUOUS) ? "continuous" : "transient"; in Dump() 36 int32_t pointSize = static_cast<int32_t>(events[i].points.size()); in Dump() 39 tag.c_str(), events[i].time, events[i].duration, events[i].intensity, in Dump() 40 events[i].frequency, events[i].index, pointSize); in Dump() 43 events[i].points[j].time, events[ in Dump() [all...] |
/base/security/security_guard/services/risk_classify/model_manager/src/ |
H A D | db_operate.cpp | 27 int DbOperate::QueryAllEvent(std::vector<SecEvent> &events) in QueryAllEvent() argument 29 return DatabaseManager::GetInstance().QueryAllEvent(table_, events); in QueryAllEvent() 42 int DbOperate::QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) in QueryEventByEventId() argument 44 return DatabaseManager::GetInstance().QueryEventByEventId(eventId, events); in QueryEventByEventId() 47 int DbOperate::QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) in QueryEventByEventId() argument 49 return DatabaseManager::GetInstance().QueryEventByEventId(table_, eventIds, events); in QueryEventByEventId() 52 int DbOperate::QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) in QueryEventByEventType() argument 54 return DatabaseManager::GetInstance().QueryEventByEventType(table_, eventType, events); in QueryEventByEventType() 57 int DbOperate::QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) in QueryEventByLevel() argument 59 return DatabaseManager::GetInstance().QueryEventByLevel(table_, level, events); in QueryEventByLevel() 62 QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) QueryEventByOwner() argument [all...] |
/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
H A D | scheduler.rs | 58 /// Dispatch epoll events to this epoll handler. 59 fn dispatch(&self, events: u32); in dispatch() 64 events: u32, 71 events: u32, 81 events: Default::default(), in new() 106 let events = self.events; in take_events() 107 self.events = Default::default(); in take_events() 108 events in take_events() 181 events in epoll_add() 220 let mut events: Vec<libc::epoll_event> = Vec::with_capacity(MAX_EPOLL_EVENTS as usize); epoll_wait() variables [all...] |
/base/startup/init/services/loopevent/task/ |
H A D | le_watchtask.c | 31 uint32_t events = oper;
in HandleWatcherEvent_() local 34 watcher->processEvent(taskHandle, fd, &events, (void *)userData);
in HandleWatcherEvent_() 42 if (events == 0) {
in HandleWatcherEvent_() 46 if (events != watcher->events) {
in HandleWatcherEvent_() 47 watcher->events = events;
in HandleWatcherEvent_() 48 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events);
in HandleWatcherEvent_() 76 task->events = info->events;
in LE_StartWatcher() [all...] |
/base/security/security_guard/services/data_collect/store/include/ |
H A D | database_helper.h | 30 virtual int QueryAllEvent(std::vector<SecEvent> &events); 33 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events); 34 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events); 35 virtual int QueryEventByEventIdAndDate(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events, 37 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events); 38 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events); 39 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events); 47 int QueryEventBase(const NativeRdb::RdbPredicates &predicates, std::vector<SecEvent> &events);
|
/base/security/security_guard/test/unittest/data_collect/include/ |
H A D | database_helper.h | 30 virtual int QueryAllEvent(std::vector<SecEvent> &events); 33 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events); 34 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events); 35 virtual int QueryEventByEventIdAndDate(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events, 37 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events); 38 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events); 39 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events); 47 int QueryEventBase(const NativeRdb::RdbPredicates &predicates, std::vector<SecEvent> &events);
|
/base/hiviewdfx/hiview/plugins/sysevent_source/ |
H A 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) cons 185 auto events = d2es_.at(*it); CalcStat() local 198 GetEventNames(std::map<std::string, int64_t> &events, std::vector<std::string> &eventNames) const GetEventNames() argument [all...] |
/base/notification/eventhandler/frameworks/eventhandler/src/ |
H A D | deamon_io_waiter.cpp | 41 .events = epollEvents, in EpollCtrl() 150 void DeamonIoWaiter::HandleFileDescriptorEvent(int32_t fileDescriptor, uint32_t events) in HandleFileDescriptorEvent() argument 162 auto f = [fileDescriptor, events, wp]() { in HandleFileDescriptorEvent() 169 if ((events & FILE_DESCRIPTOR_INPUT_EVENT) != 0) { in HandleFileDescriptorEvent() 173 if ((events & FILE_DESCRIPTOR_OUTPUT_EVENT) != 0) { in HandleFileDescriptorEvent() 177 if ((events & FILE_DESCRIPTOR_SHUTDOWN_EVENT) != 0) { in HandleFileDescriptorEvent() 181 if ((events & FILE_DESCRIPTOR_EXCEPTION_EVENT) != 0) { in HandleFileDescriptorEvent() 188 // Post a high priority task to handle file descriptor events. in HandleFileDescriptorEvent() 202 // Transform epoll events into file descriptor listener events in HandleEpollEvents() 203 uint32_t events = 0; HandleEpollEvents() local 297 AddFileDescriptor(int32_t fileDescriptor, uint32_t events, const std::string &taskName, const std::shared_ptr<FileDescriptorListener>& listener, EventQueue::Priority priority) AddFileDescriptor() argument [all...] |
H A D | epoll_io_waiter.cpp | 38 .events = epollEvents, in EpollCtrl() 152 // Transform epoll events into file descriptor listener events. in WaitFor() 153 uint32_t events = 0; in WaitFor() local 154 if ((epollEvents[i].events & EPOLLIN) != 0) { in WaitFor() 155 events |= FILE_DESCRIPTOR_INPUT_EVENT; in WaitFor() 158 if ((epollEvents[i].events & EPOLLOUT) != 0) { in WaitFor() 159 events |= FILE_DESCRIPTOR_OUTPUT_EVENT; in WaitFor() 162 if ((epollEvents[i].events & (EPOLLHUP)) != 0) { in WaitFor() 163 events | in WaitFor() 213 AddFileDescriptor(int32_t fileDescriptor, uint32_t events, const std::string &taskName, const std::shared_ptr<FileDescriptorListener>& listener, EventQueue::Priority priority) AddFileDescriptor() argument [all...] |
/base/hiviewdfx/hiview/plugins/usage_event_report/cache/ |
H A D | usage_event_cacher.cpp | 28 void UsageEventCacher::GetPluginStatsEvents(std::vector<std::shared_ptr<LoggerEvent>>& events) const
in GetPluginStatsEvents() 30 if (dbHelper_->QueryPluginStatsEvent(events) < 0) {
in GetPluginStatsEvents() 31 HIVIEW_LOGI("failed to query plugin stats events from db");
in GetPluginStatsEvents() 48 std::vector<std::shared_ptr<LoggerEvent>> events;
in DeletePluginStatsEventsFromDb() local 49 if (dbHelper_->QueryPluginStatsEvent(events) >= 0) {
in DeletePluginStatsEventsFromDb() 62 void UsageEventCacher::SavePluginStatsEventsToDb(const std::vector<std::shared_ptr<LoggerEvent>>& events) const
in SavePluginStatsEventsToDb() 65 for (auto event : events) {
in SavePluginStatsEventsToDb()
|
/base/security/security_guard/test/unittest/risk_classify/include/ |
H A D | i_db_operate.h | 27 virtual int QueryAllEvent(std::vector<SecEvent> &events) = 0; 31 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) = 0; 32 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) = 0; 33 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) = 0; 34 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) = 0; 35 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) = 0;
|
/base/security/security_guard/test/unittest/model_manager/include/ |
H A D | db_operate.h | 28 int QueryAllEvent(std::vector<SecEvent> &events) override; 31 int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) override; 32 int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) override; 33 int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) override; 34 int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) override; 35 int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) override;
|
H A D | i_db_operate.h | 27 virtual int QueryAllEvent(std::vector<SecEvent> &events) = 0; 31 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) = 0; 32 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) = 0; 33 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) = 0; 34 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) = 0; 35 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) = 0;
|
/base/security/security_guard/interfaces/inner_api/classify/include/ |
H A D | i_db_operate.h | 27 virtual int QueryAllEvent(std::vector<SecEvent> &events) = 0; 31 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) = 0; 32 virtual int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) = 0; 33 virtual int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) = 0; 34 virtual int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) = 0; 35 virtual int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) = 0;
|
/base/security/security_guard/services/risk_classify/model_manager/include/ |
H A D | db_operate.h | 28 int QueryAllEvent(std::vector<SecEvent> &events) override; 31 int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) override; 32 int QueryEventByEventId(std::vector<int64_t> &eventIds, std::vector<SecEvent> &events) override; 33 int QueryEventByEventType(int32_t eventType, std::vector<SecEvent> &events) override; 34 int QueryEventByLevel(int32_t level, std::vector<SecEvent> &events) override; 35 int QueryEventByOwner(std::string owner, std::vector<SecEvent> &events) override;
|
/base/notification/eventhandler/frameworks/eventhandler/include/ |
H A D | ffrt_descriptor_listener.h | 31 FfrtDescriptorListener(uint32_t events, void *data, std::function<void(void *, uint32_t)> cbVal) in FfrtDescriptorListener() argument 32 : events_(events), data_(data), cb_(cbVal) {} in FfrtDescriptorListener() 44 static uint32_t ConvertEvents(uint32_t events); 46 void InvokePollCb(uint32_t events) in InvokePollCb() argument 49 cb_(data_, events); in InvokePollCb()
|
/base/sensors/miscdevice/frameworks/native/vibrator/src/ |
H A D | vibrator_service_client.cpp | 396 if (pattern.events == nullptr) { in InitPlayPattern() 397 MISC_HILOGE("VibratorPattern's events is null"); in InitPlayPattern() 401 event.tag = static_cast<VibrateTag>(pattern.events[i].type); in InitPlayPattern() 402 event.time = pattern.events[i].time; in InitPlayPattern() 403 event.duration = pattern.events[i].duration; in InitPlayPattern() 404 event.intensity = pattern.events[i].intensity; in InitPlayPattern() 405 event.frequency = pattern.events[i].frequency; in InitPlayPattern() 406 event.index = pattern.events[i].index; in InitPlayPattern() 407 for (int32_t j = 0; j < pattern.events[i].pointNum; ++j) { in InitPlayPattern() 408 if (pattern.events[ in InitPlayPattern() 466 VibratorEvent *events = (VibratorEvent *)malloc(sizeof(VibratorEvent) * eventSize); ConvertVibratePackage() local 519 auto events = patterns[i].events; FreeVibratorPackage() local [all...] |
/base/security/security_guard/test/unittest/mock/database_manager/ |
H A D | database_manager.h | 34 virtual int QueryAllEvent(std::string table, std::vector<SecEvent> &events) = 0; 39 std::vector<SecEvent> &events, std::string beginTime, std::string endTime) = 0; 40 virtual int QueryEventByEventId(int64_t eventId, std::vector<SecEvent> &events) = 0; 42 std::vector<SecEvent> &events) = 0; 43 virtual int QueryEventByEventType(std::string table, int32_t eventType, std::vector<SecEvent> &events) = 0; 44 virtual int QueryEventByLevel(std::string table, int32_t level, std::vector<SecEvent> &events) = 0; 45 virtual int QueryEventByOwner(std::string table, std::string owner, std::vector<SecEvent> &events) = 0; 65 MOCK_METHOD2(QueryAllEvent, int(std::string table, std::vector<SecEvent> &events)); 70 std::vector<SecEvent> &events, std::string beginTime, std::string endTime)); 71 MOCK_METHOD2(QueryEventByEventId, int(int64_t eventId, std::vector<SecEvent> &events)); [all...] |
/base/msdp/device_status/intention/common/epoll/src/ |
H A D | epoll_manager.cpp | 69 ev.events = source->GetEvents(); in Add() 107 ev.events = source->GetEvents(); in Update() 119 int32_t EpollManager::Wait(struct epoll_event *events, int32_t maxevents) in Wait() argument 121 return WaitTimeout(events, maxevents, -1); in Wait() 124 int32_t EpollManager::WaitTimeout(struct epoll_event *events, int32_t maxevents, int32_t timeout) in WaitTimeout() argument 126 int32_t ret = ::epoll_wait(epollFd_, events, maxevents, timeout); in WaitTimeout() 138 if ((ev.events & EPOLLIN) == EPOLLIN) { in Dispatch() 140 } else if ((ev.events & (EPOLLHUP | EPOLLERR)) != 0) { in Dispatch() 153 if ((evs[index].events & EPOLLIN) == EPOLLIN) { in DispatchOne() 155 } else if ((evs[index].events in DispatchOne() [all...] |