/foundation/multimodalinput/input/tools/event_inject/test/ |
H A D | device_base_test.cpp | 67 EXPECT_GT(inputEventArray.events.size(), 0); in HWTEST_F() 68 if (inputEventArray.events.size() <= 0) { in HWTEST_F() 71 EXPECT_EQ(inputEventArray.events[0].event.type, EV_SYN); in HWTEST_F() 72 EXPECT_EQ(inputEventArray.events[0].event.code, SYN_REPORT); in HWTEST_F() 73 EXPECT_EQ(inputEventArray.events[0].event.value, SYN_CONFIG); in HWTEST_F() 74 EXPECT_EQ(inputEventArray.events[0].blockTime, blockTime); in HWTEST_F() 90 EXPECT_GT(inputEventArray.events.size(), 0); in HWTEST_F() 91 if (inputEventArray.events.size() <= 0) { in HWTEST_F() 94 EXPECT_EQ(inputEventArray.events[0].event.type, EV_KEY); in HWTEST_F() 95 EXPECT_EQ(inputEventArray.events[ in HWTEST_F() [all...] |
/foundation/arkui/ace_engine/frameworks/core/event/ |
H A D | event_convertor.cpp | 21 TouchEvent& point, std::vector<TouchEvent>& events, std::vector<TouchEvent>& allEvents) in SetTouchEventType() 28 events.push_back(point); in SetTouchEventType() 39 events.push_back(point); in SetTouchEventType() 46 events.push_back(point); in SetTouchEventType() 53 events.push_back(point); in SetTouchEventType() 62 void UpdateTouchEvent(std::vector<TouchEvent>& events, std::vector<TouchEvent>& allEvents) in UpdateTouchEvent() argument 64 if (allEvents.empty() || events.empty()) { in UpdateTouchEvent() 81 for (auto& event : events) { in UpdateTouchEvent() 86 void ConvertMouseEvent(const std::vector<uint8_t>& data, MouseEvent& events) in ConvertMouseEvent() argument 94 events in ConvertMouseEvent() 20 SetTouchEventType(AceActionData::ActionType actionType, int8_t actionPoint, TouchEvent& point, std::vector<TouchEvent>& events, std::vector<TouchEvent>& allEvents) SetTouchEventType() argument [all...] |
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
H A D | sys_epoll.c | 23 int32_t RefreshEpollTask(EpollTask *task, uint32_t events) in RefreshEpollTask() argument 30 event.events = events; in RefreshEpollTask() 40 int32_t RegisterEpollTask(EpollTask *task, uint32_t events) in RegisterEpollTask() argument 47 event.events = events; in RegisterEpollTask() 77 struct epoll_event events[MAX_EPOLL_SIZE]; in EpollLoop() local 79 nfds = epoll_wait(epollfd, events, MAX_EPOLL_SIZE, timeout); in EpollLoop() 90 task = events[i].data.ptr; in EpollLoop() 95 if (events[ in EpollLoop() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
H A D | event_impl.cpp | 47 EventImpl::EventImpl(const EventFd &fd, EventsMask events, EventTime timeout) in EventImpl() argument 49 events_(events), in EventImpl() 56 if (!(events & ET_TIMEOUT) || (timeout_ < 0)) { in EventImpl() 101 int EventImpl::AddEvents(EventsMask events) in AddEvents() argument 103 if (!IsValidArg(events)) { in AddEvents() 108 if ((genericEvents & events) && !IsValidFd()) { in AddEvents() 109 LOGE("ev add events failed, fd is invalid."); in AddEvents() 117 events_ |= events; in AddEvents() 124 int errCode = loop->Modify(this, true, events); in AddEvents() 127 LOGE("ev add events faile in AddEvents() 132 RemoveEvents(EventsMask events) RemoveEvents() argument 293 SetEvents(bool isAdd, EventsMask events) SetEvents() argument 302 SetRevents(EventsMask events) SetRevents() argument [all...] |
H A D | event_loop_epoll.cpp | 63 event.events = EPOLLIN; in Initialize() 111 EventsMask revents = CalEventsMask(revent->events); in Poll() 171 uint32_t EventLoopEpoll::CalEpollEvents(EventsMask events) const in CalEpollEvents() 174 if ((events & static_cast<uint32_t>(IEvent::ET_READ)) != 0) { // LCOV_EXCL_BR_LINE in CalEpollEvents() 177 if ((events & static_cast<uint32_t>(IEvent::ET_WRITE)) != 0) { // LCOV_EXCL_BR_LINE in CalEpollEvents() 180 if ((events & static_cast<uint32_t>(IEvent::ET_ERROR)) != 0) { // LCOV_EXCL_BR_LINE in CalEpollEvents() 188 EventsMask events = 0; in CalEventsMask() local 190 events |= IEvent::ET_READ; in CalEventsMask() 193 events |= IEvent::ET_WRITE; in CalEventsMask() 196 events | in CalEventsMask() 201 EpollCtl(int operation, EventImpl *event, EventsMask events) EpollCtl() argument 236 EventsMask events = event->GetEvents(); AddEvent() local 253 EventsMask events = event->GetEvents(); RemoveEvent() local 264 ModifyEvent(EventImpl *event, bool isAdd, EventsMask events) ModifyEvent() argument [all...] |
H A D | ievent.cpp | 38 IEvent *IEvent::CreateEvent(EventFd fd, EventsMask events, in CreateEvent() argument 42 if (!events) { in CreateEvent() 45 if ((events & ET_TIMEOUT) && (timeout < 0)) { in CreateEvent() 48 if (!(events & ET_TIMEOUT) && !fd.IsValid()) { in CreateEvent() 52 IEvent *event = new (std::nothrow) EventImpl(fd, events, timeout); in CreateEvent()
|
H A D | event_impl.h | 29 EventImpl(const EventFd &fd, EventsMask events, EventTime timeout); 33 int AddEvents(EventsMask events) override; 34 int RemoveEvents(EventsMask events) override; 47 void SetEvents(bool isAdd, EventsMask events); 48 void SetRevents(EventsMask events); 54 bool IsValidArg(EventsMask events) const;
|
/applications/standard/calendardata/calendarmanager/test/unittest/src/ |
H A D | event_filter_test.cpp | 67 auto events = calendar->GetEvents(FilterByTitle(title), {}); in HWTEST_F() local 68 ASSERT_FALSE(events.empty()); in HWTEST_F() 69 EXPECT_EQ(events.at(0).title.value(), title); in HWTEST_F() 79 auto events = calendar->GetEvents(FilterByTitle(title + "event"), {}); in HWTEST_F() local 80 ASSERT_TRUE(events.empty()); in HWTEST_F() 90 auto events = calendar->GetEvents(FilterByTitle("partialMatch"), {}); in HWTEST_F() local 91 ASSERT_FALSE(events.empty()); in HWTEST_F() 92 EXPECT_EQ(events.at(0).title.value(), title); in HWTEST_F() 102 auto events = calendar->GetEvents(FilterByTitle("中文测试"), {}); in HWTEST_F() local 103 ASSERT_FALSE(events in HWTEST_F() 114 auto events = calendar->GetEvents(FilterById({eventId}), {}); HWTEST_F() local 127 auto events = calendar->GetEvents(FilterById({eventId}), {}); HWTEST_F() local 139 auto events = calendar->GetEvents(FilterById({eventId + 1}), {}); HWTEST_F() local 153 auto events = calendar->GetEvents(FilterById({eventId1, eventId2}), {}); HWTEST_F() local 178 auto events = calendar->GetEvents(FilterByTime(event.startTime, event.endTime), {}); HWTEST_F() local 195 auto events = calendar->GetEvents(FilterByTime(event.startTime - interval * 2, event.startTime - interval), {}); HWTEST_F() local 218 auto events = calendar->GetEvents(FilterByTime(timeNow, event2.endTime), {}); HWTEST_F() local [all...] |
H A D | event_attendee_test.cpp | 76 auto events = calendar->GetEvents(FilterByTitle("AddEventWithOneAttendee"), {}); in HWTEST_F() local 77 ASSERT_EQ(events.size(), 1); in HWTEST_F() 78 auto resultEvent = events.at(0); in HWTEST_F() 104 auto events = calendar->GetEvents(FilterById({eventId2}), {}); in HWTEST_F() local 105 ASSERT_EQ(events.size(), 1); in HWTEST_F() 106 auto resultEvent = events.at(0); in HWTEST_F() 122 auto events = calendar->GetEvents(FilterById({eventId}), {}); in HWTEST_F() local 123 ASSERT_EQ(events.size(), 1); in HWTEST_F() 124 auto resultEvent = events.at(0); in HWTEST_F() 133 events in HWTEST_F() [all...] |
H A D | event_reminder_test.cpp | 62 auto events = calendar->GetEvents(FilterByTitle(title), eventKey); in HWTEST_F() local 63 ASSERT_EQ(events.size(), 1); in HWTEST_F() 64 auto resultEvent = events.at(0); in HWTEST_F() 79 auto events = calendar->GetEvents(FilterByTitle(title), eventKey); in HWTEST_F() local 80 ASSERT_EQ(events.size(), 1); in HWTEST_F() 81 auto resultEvent = events.at(0); in HWTEST_F() 100 auto events = calendar->GetEvents(FilterByTitle(title), eventKey); in HWTEST_F() local 101 ASSERT_EQ(events.size(), 1); in HWTEST_F() 102 auto resultEvent = events.at(0); in HWTEST_F() 109 events in HWTEST_F() [all...] |
H A D | event_service_test.cpp | 63 auto events = calendar->GetEvents(FilterByTitle(title), {}); in HWTEST_F() local 64 ASSERT_EQ(events.size(), 1); in HWTEST_F() 65 auto resultEvent = events.at(0); in HWTEST_F() 81 auto events = calendar->GetEvents(FilterByTitle(title), {}); in HWTEST_F() local 82 ASSERT_EQ(events.size(), 1); in HWTEST_F() 83 auto resultEvent = events.at(0); in HWTEST_F()
|
/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
H A D | socket_listener.cpp | 43 event.events = EPOLLIN; in Initialize() 96 event.events = EPOLLRDHUP | EPOLLERR | EPOLLIN | EPOLLOUT | EPOLLONESHOT; in AddSocket() 100 event.events = EPOLLRDHUP | EPOLLERR | EPOLLIN; in AddSocket() 115 struct epoll_event events[MAX_EPOLL]; in OnListenEvents() local 119 CHECK_EXCEPT_INTR(nfds = epoll_wait(epollFd_, events, MAX_EPOLL, -1)); in OnListenEvents() 125 if (events[i].data.ptr == nullptr) { in OnListenEvents() 131 Socket &sock = *(Socket *)events[i].data.ptr; in OnListenEvents() 132 if (events[i].events & EPOLLIN) { in OnListenEvents() 137 if (events[ in OnListenEvents() [all...] |
/foundation/multimodalinput/input/tools/event_inject/src/ |
H A D | device_base.cpp | 45 inputEventArray.events.push_back(injectEvent); in SetSynConfigReport() 56 inputEventArray.events.push_back(injectEvent); in SetKeyLongPressEvent() 67 inputEventArray.events.push_back(injectEvent); in SetSynReport() 78 inputEventArray.events.push_back(injectEvent); in SetKeyPressEvent() 89 inputEventArray.events.push_back(injectEvent); in SetKeyReleaseEvent() 100 inputEventArray.events.push_back(injectEvent); in SetMtSlot() 112 inputEventArray.events.push_back(injectEvent); in SetTrackingId() 123 inputEventArray.events.push_back(injectEvent); in SetPositionX() 134 inputEventArray.events.push_back(injectEvent); in SetPositionY() 145 inputEventArray.events in SetMtTouchMajor() [all...] |
H A D | input_parse.cpp | 153 bool ParseData(cJSON* events, std::vector<DeviceEvent>& eventData) in ParseData() argument 155 if (!cJSON_IsArray(events)) { in ParseData() 156 MMI_HILOGE("The events is not array"); in ParseData() 159 int32_t eventsSize = cJSON_GetArraySize(events); in ParseData() 161 cJSON* eventInfo = cJSON_GetArrayItem(events, i); in ParseData() 165 MMI_HILOGE("Failed to parse events"); in ParseData() 224 << ",events:["; in ToString() 225 for (const auto &item : events) { in ToString() 257 cJSON *events = nullptr; in DataInit() local 258 if (cJSON_HasObjectItem(deviceInfo, "events")) { in DataInit() [all...] |
/foundation/multimodalinput/input/intention/common/epoll/src/ |
H A D | epoll_manager.cpp | 64 ev.events = source.GetEvents(); in Add() 88 ev.events = source.GetEvents(); in Update() 99 int32_t EpollManager::Wait(struct epoll_event *events, int32_t maxevents) in Wait() argument 101 return WaitTimeout(events, maxevents, -1); in Wait() 104 int32_t EpollManager::WaitTimeout(struct epoll_event *events, int32_t maxevents, int32_t timeout) in WaitTimeout() argument 106 int32_t ret = ::epoll_wait(epollFd_, events, maxevents, timeout); in WaitTimeout() 118 if ((ev.events & EPOLLIN) == EPOLLIN) { in Dispatch() 120 } else if ((ev.events & (EPOLLHUP | EPOLLERR)) != 0) { in Dispatch() 133 if ((evs[index].events & EPOLLIN) == EPOLLIN) { in DispatchOne() 135 } else if ((evs[index].events in DispatchOne() [all...] |
/foundation/communication/wifi/wifi/relation_services/wifi_hal_service/ |
H A D | wifi_hal_crpc_common.c | 41 int *events = ReadIntArray(context, num); in RpcRegisterEventCallback() local 42 if (events == NULL) { in RpcRegisterEventCallback() 46 RegisterCallback(server, events[i], context); in RpcRegisterEventCallback() 51 free(events); in RpcRegisterEventCallback() 52 events = NULL; in RpcRegisterEventCallback() 68 int *events = ReadIntArray(context, num); in RpcUnRegisterEventCallback() local 69 if (events == NULL) { in RpcUnRegisterEventCallback() 73 UnRegisterCallback(server, events[i], context); in RpcUnRegisterEventCallback() 78 free(events); in RpcUnRegisterEventCallback() 79 events in RpcUnRegisterEventCallback() [all...] |
/foundation/distributedhardware/distributed_input/services/state/src/ |
H A D | touchpad_event_fragment.cpp | 26 return events.size() == MIN_EVENT_FRAG_SIZE; in IsShouldDrop() 32 for (const auto &ev : events) { in IsTouchPadOptFinish() 45 for (const auto &ev : events) { in IsTouchPadOptStart() 57 this->events.push_back(event); in PushEvent() 62 return this->events; in GetEvents()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
H A D | sys_epoll.c | 68 typedef void (*EpollEventCtrlFunc)(EpollSet *epollSetPtr, uint32_t events, EpollTask *task); 79 static void EpollFdEventAdd(EpollSet *epollSetPtr, uint32_t events, EpollTask *task); 80 static void EpollFdEventDel(EpollSet *epollSetPtr, uint32_t events, EpollTask *task); 81 static void EpollFdEventMod(EpollSet *epollSetPtr, uint32_t events, EpollTask *task); 83 static int32_t CtlEpollDesc(EpollTask *task, int op, uint32_t events) in CtlEpollDesc() argument 97 event.events = events; in CtlEpollDesc() 111 static int32_t CtlEpollDescSync(EpollTask *task, EpollEventCtrlFunc func, uint32_t events) in CtlEpollDescSync() argument 124 func(epollSetPtr, events, task); in CtlEpollDescSync() 132 int32_t RunEpollTask(void *task, uint32_t events) in RunEpollTask() argument 137 RefreshEpollTask(EpollTask *task, uint32_t events) RefreshEpollTask() argument 142 RegisterEpollTask(EpollTask *task, uint32_t events) RegisterEpollTask() argument 493 EpollTaskEventHandle(uint32_t events, EpollTask *task) EpollTaskEventHandle() argument 536 EpollFdEventAdd(EpollSet *epollSetPtr, uint32_t events, EpollTask *task) EpollFdEventAdd() argument 625 EpollFdEventDel(EpollSet *epollSetPtr, uint32_t events, EpollTask *task) global() argument 652 EpollFdEventMod(EpollSet *epollSetPtr, uint32_t events, EpollTask *task) global() argument 681 EpollFdEventRun(EpollSet *epollSetPtr, uint32_t events, EpollTask *task) global() argument 687 EpollFdEventOpHandle(EpollSet *epollSetPtr, int op, uint32_t events, EpollTask *task) global() argument 730 uint32_t events = 0; global() local [all...] |
/foundation/communication/netmanager_base/utils/napi_utils/src/ |
H A D | module_template.cpp | 28 napi_value On(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, in On() argument 43 if (std::find(events.begin(), events.end(), event) == events.end()) { in On() 56 napi_value Once(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, in Once() argument 71 if (std::find(events.begin(), events.end(), event) == events.end()) { in Once() 84 napi_value Off(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events) in Off() argument 103 if (std::find(events in Off() [all...] |
/foundation/multimodalinput/input/util/socket/test/ |
H A D | uds_socket_test.cpp | 98 struct epoll_event events[MAX_EVENT_SIZE] = {}; in HWTEST_F() local 102 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F() 108 struct epoll_event events[MAX_EVENT_SIZE] = {}; in HWTEST_F() local 112 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F() 118 struct epoll_event events[MAX_EVENT_SIZE] = {}; in HWTEST_F() local 122 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F() 128 struct epoll_event events[MAX_EVENT_SIZE] = {}; in HWTEST_F() local 132 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F()
|
/foundation/communication/netmanager_base/frameworks/js/napi/netstats/src/ |
H A D | statistics_observer_wrapper.cpp | 38 const std::initializer_list<std::string> &events, bool asyncCallback) in On() 52 if (std::find(events.begin(), events.end(), event) == events.end()) { in On() 73 const std::initializer_list<std::string> &events, bool asyncCallback) in Off() 94 if (std::find(events.begin(), events.end(), event) == events.end()) { in Off() 37 On(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) On() argument 72 Off(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) Off() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | evloop_timer_unit_test.cpp | 470 EventsMask events = 1u; in HWTEST_F() local 471 EXPECT_EQ(loopImpl->Modify(nullptr, true, events), -E_INVALID_ARGS); in HWTEST_F() 499 EventsMask events = 0u; in HWTEST_F() local 500 event = IEvent::CreateEvent(eventFd, events, eventTime, errCode); in HWTEST_F() 517 events |= ET_TIMEOUT; in HWTEST_F() 518 event = IEvent::CreateEvent(eventFd, events, eventTime, errCode); in HWTEST_F() 528 event = IEvent::CreateEvent(eventFd, events, eventTime, errCode); in HWTEST_F() 579 * @tc.steps:step2. AddEvents and RemoveEvents with events is 0 in HWTEST_F() 582 EventsMask events = 0u; in HWTEST_F() local 583 EXPECT_EQ(event->AddEvents(events), in HWTEST_F() 610 EventsMask events = 1u; // 1 means ET_READ HWTEST_F() local 659 EventsMask events = 1u; // 1 means ET_READ HWTEST_F() local 708 EventsMask events = 1u; // 1 means ET_READ HWTEST_F() local [all...] |
/foundation/communication/netstack/utils/napi_utils/src/ |
H A D | module_template.cpp | 35 napi_value OnManagerWrapper(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, in OnManagerWrapper() argument 51 if (std::find(events.begin(), events.end(), event) == events.end()) { in OnManagerWrapper() 77 napi_value OnceManagerWrapper(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, in OnceManagerWrapper() argument 92 if (std::find(events.begin(), events.end(), event) == events.end()) { in OnceManagerWrapper() 114 napi_value OffManagerWrapper(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events) in OffManagerWrapper() argument 135 if (std::find(events in OffManagerWrapper() 165 OnSharedManager(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) OnSharedManager() argument 207 OnceSharedManager(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) OnceSharedManager() argument 244 OffSharedManager(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events) OffSharedManager() argument 295 On(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) On() argument 324 Once(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events, bool asyncCallback) Once() argument 352 Off(napi_env env, napi_callback_info info, const std::initializer_list<std::string> &events) Off() argument [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
H A D | reactor_linux.c | 81 event.events = EPOLLIN; in ReactorCreate() 125 struct epoll_event events[MAXEPOLLEVENTS]; in ReactorStart() local 132 CHECK_EXCEPT_INTR(nfds = epoll_wait(reactor->epollFd, events, MAXEPOLLEVENTS, -1)); in ReactorStart() 140 if (events[i].data.ptr == NULL) { in ReactorStart() 147 ReactorItem *item = (ReactorItem *)events[i].data.ptr; in ReactorStart() 158 if ((events[i].events & (EPOLLIN | EPOLLRDHUP)) && (item->onReadReady != NULL)) { in ReactorStart() 161 if ((events[i].events & EPOLLOUT) && (item->onWriteReady != NULL) && (!reactor->itemRemoved)) { in ReactorStart() 202 event.events | in ReactorRegister() [all...] |
/foundation/resourceschedule/memmgr/services/memmgrservice/src/event/ |
H A D | kswapd_observer.cpp | 46 epollfd_ = epoll_create(6); // 6 : max epoll events
in Init() 77 epollEvent.events = EPOLLPRI;
in RegisterKswapdListener() 96 struct epoll_event events[1];
in MainLoop() local 98 int nevents = epoll_wait(epollfd_, events, 1, -1);
in MainLoop() 99 HILOGD("receive events, num=%{public}d!", nevents);
in MainLoop() 108 for (i = 0, curEpollEvent = &events[0]; i < nevents; ++i, curEpollEvent++) {
in MainLoop() 109 if (curEpollEvent->events & EPOLLHUP) {
in MainLoop() 110 HILOGE("EPOLLHUP in events[%{public}d]", i);
in MainLoop() 114 if (curEpollEvent->events & EPOLLERR) {
in MainLoop() 115 HILOGE("epoll err in events[ in MainLoop() [all...] |