Home
last modified time | relevance | path

Searched refs:revents (Results 1 - 23 of 23) sorted by relevance

/foundation/filemanagement/storage_service/services/storage_daemon/netlink/src/
H A Dnetlink_listener.cpp96 if (ufds[i].revents == 0) { in ReadMsg()
111 if ((static_cast<uint32_t>(ufds[i].revents) & POLLIN)) { in ReadMsg()
115 if ((static_cast<uint32_t>(ufds[i].revents)) & (POLLERR | POLLHUP)) { in ReadMsg()
133 ufds[fdCount].revents = 0; in RunListener()
139 ufds[fdCount].revents = 0; in RunListener()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Depoll_app.c105 epi->revents = 0; in EpollCtlTriggleEvent()
107 epi->revents |= SPUNGE_EPOLLIN; in EpollCtlTriggleEvent()
111 epi->revents |= SPUNGE_EPOLLOUT; in EpollCtlTriggleEvent()
114 epi->revents |= (FILLP_UINT32)sock->errEvent; in EpollCtlTriggleEvent()
115 epi->revents &= epi->event.events; in EpollCtlTriggleEvent()
117 if (epi->revents > 0) { in EpollCtlTriggleEvent()
134 epi->revents = FILLP_NULL_NUM; in EpollMallocEpitem()
206 epi->revents = FILLP_NULL_NUM; in EpUnlink()
296 epi->revents &= epi->event.events; in EpGetEventsAndSignal()
299 if (epi->revents > in EpGetEventsAndSignal()
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dsocket_common.c33 epi->revents = (epi->event.events & (FILLP_UINT32)sock->errEvent); in EpollUpdateEpEvent()
35 epi->revents |= SPUNGE_EPOLLIN; in EpollUpdateEpEvent()
37 epi->revents &= (FILLP_UINT32)(~SPUNGE_EPOLLIN); in EpollUpdateEpEvent()
42 epi->revents |= SPUNGE_EPOLLOUT; in EpollUpdateEpEvent()
44 epi->revents &= (FILLP_UINT32)(~SPUNGE_EPOLLOUT); in EpollUpdateEpEvent()
74 sockEpItem->revents |= (sockEpItem->event.events & upEvent); in EpollEventCallback()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Devent_loop_epoll.cpp111 EventsMask revents = CalEventsMask(revent->events); in Poll() local
112 event->SetRevents(revents); in Poll()
144 std::vector<epoll_event> revents; in Exit() local
145 revents.swap(revents_); in Exit()
H A Devent_impl.cpp305 EventsMask revents = events & genericEvents; in SetRevents() local
306 if (revents) { in SetRevents()
307 revents_ = revents; in SetRevents()
H A Dievent.h26 using EventAction = std::function<int(EventsMask revents)>;
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Depoll.h65 FILLP_UINT32 revents; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Devloop_timer_unit_test.cpp186 errCode = timer->SetAction([](EventsMask revents) -> int { in HWTEST_F()
237 errCode = timer->SetAction([&counter](EventsMask revents) -> int { ++counter; return E_OK; }, nullptr); in HWTEST_F()
292 [&counter](EventsMask revents) -> int { in HWTEST_F()
351 errCode = timer->SetAction([&counter](EventsMask revents) -> int { ++counter; return -E_STALE; }, in HWTEST_F()
409 [timer, &counter, &lastTime](EventsMask revents) -> int { in HWTEST_F()
629 ASSERT_EQ(event->SetAction([](EventsMask revents) -> int { in HWTEST_F()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dclatd.cpp145 if (fds[EVENT_STOP].revents) { in RunLoop()
153 if (fds[READ_V6].revents) { in RunLoop()
156 if (fds[READ_V4].revents) { in RunLoop()
/foundation/multimedia/audio_framework/services/audio_policy/server/src/service/manager/pnp_server/
H A Daudio_pnp_server.cpp162 fd.revents = 0; in OpenAndReadWithSocket()
171 if (((uint32_t)fd.revents & (POLLIN | POLLERR)) != 0) { in OpenAndReadWithSocket()
H A Daudio_input_thread.cpp73 if ((uint32_t)g_fdSets[num].revents & POLLIN) { in AudioPnpInputPollAndRead()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/
H A Dwrapper_listener.cpp116 if (pollFds[0].revents & (POLLIN | POLLERR)) { in Listen()
/foundation/filemanagement/file_api/interfaces/kits/cj/src/
H A Dwatcher_impl.cpp177 if (static_cast<unsigned short>(fds[0].revents) & POLLNVAL) { in GetNotifyEvent()
181 if (static_cast<unsigned short>(fds[1].revents) & POLLIN) { in GetNotifyEvent()
H A Dcopy.cpp537 if (static_cast<unsigned short>(fds[0].revents) & POLLNVAL) { in GetNotifyEvent()
541 if (static_cast<unsigned short>(fds[1].revents) & POLLIN) { in GetNotifyEvent()
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/class_watcher/
H A Dwatcher_entity.cpp198 if (static_cast<unsigned short>(fds[0].revents) & POLLNVAL) { in GetNotifyEvent()
202 if (static_cast<unsigned short>(fds[1].revents) & POLLIN) { in GetNotifyEvent()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/
H A Dkernel_talker.cpp188 fileFd.revents = 0; in PollRun()
/foundation/communication/netstack/frameworks/js/napi/tls/src/
H A Dtls_socket_server.cpp1442 fds_[g_userCounter].revents = 0; in SetTlsConnectionSecureOptions()
1460 fds_[0].revents = 0; in InitPollList()
1504 if ((fds_[i].fd == listenSocketFd_) && (static_cast<uint16_t>(fds_[i].revents) & POLLIN)) { in PollThread()
1507 } else if ((static_cast<uint16_t>(fds_[i].revents) & POLLRDHUP) || in PollThread()
1508 (static_cast<uint16_t>(fds_[i].revents) & POLLERR)) { in PollThread()
1510 } else if ((static_cast<uint16_t>(fds_[i].revents) & POLLERR)) { in PollThread()
1515 } else if (static_cast<uint16_t>(fds_[i].revents) & POLLIN) { in PollThread()
/foundation/graphic/graphic_surface/sync_fence/src/
H A Dsync_fence.cpp85 if (pollfds.revents & (POLLERR | POLLNVAL)) { in Wait()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/pan/
H A Dpan_network.cpp380 if (pfds[0].revents & POLLIN) { in PollEventThread_()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_uhid.cpp334 if (pfds[0].revents & POLLIN) { in PollEventThread_()
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/properties/
H A Dcopy.cpp777 if (static_cast<unsigned short>(fds[0].revents) & POLLNVAL) { in GetNotifyEvent()
781 if (static_cast<unsigned short>(fds[1].revents) & POLLIN) { in GetNotifyEvent()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.cpp195 evTimer->SetAction([this, timerId, action](EventsMask revents) -> int { in SetTimer()
/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/
H A Dlocal_socket_exec.cpp559 if (fds[0].revents & POLLIN) { in LocalSocketServerAccept()

Completed in 18 milliseconds