Lines Matching refs:ev
435 struct epoll_event ev {};
436 ev.events = EPOLLIN;
437 ev.data.ptr = eventData;
438 if (EpollCtl(fd, EPOLL_CTL_ADD, ev) != RET_OK) {
441 ev.data.ptr = nullptr;
458 struct epoll_event ev {};
459 if (EpollCtl(fd, EPOLL_CTL_DEL, ev) != RET_OK) {
511 struct epoll_event ev[MAX_EVENT_SIZE] {};
512 int32_t count = EpollWait(MAX_EVENT_SIZE, -1, ev[0]);
514 auto epollEvent = reinterpret_cast<device_status_epoll_event*>(ev[i].data.ptr);
517 OnSocketEvent(ev[i]);
519 OnDelegateTask(ev[i]);
521 OnTimeout(ev[i]);
523 OnDeviceMgr(ev[i]);
532 void DeviceStatusService::OnSocketEvent(const struct epoll_event &ev)
535 if ((ev.events & EPOLLIN) == EPOLLIN) {
536 socketSessionMgr_.Dispatch(ev);
537 } else if ((ev.events & (EPOLLHUP | EPOLLERR)) != 0) {
542 void DeviceStatusService::OnDelegateTask(const struct epoll_event &ev)
544 if ((ev.events & EPOLLIN) == 0) {
558 void DeviceStatusService::OnTimeout(const struct epoll_event &ev)
561 if ((ev.events & EPOLLIN) == EPOLLIN) {
568 } else if ((ev.events & (EPOLLHUP | EPOLLERR)) != 0) {
573 void DeviceStatusService::OnDeviceMgr(const struct epoll_event &ev)
576 if ((ev.events & EPOLLIN) == EPOLLIN) {
577 devMgr_.Dispatch(ev);
578 } else if ((ev.events & (EPOLLHUP | EPOLLERR)) != 0) {