| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_epoll.c | 75 int32_t i, nfds; in EpollLoop() local
79 nfds = epoll_wait(epollfd, events, MAX_EPOLL_SIZE, timeout); in EpollLoop()
80 if (nfds < 0) { in EpollLoop()
85 LOGE(TAG, "epoll_wait returned n=%d, error: %d", nfds, errno); in EpollLoop()
89 for (i = 0; i < nfds; i++) { in EpollLoop()
108 return ((nfds > 0) ? nfds : NSTACKX_ETIMEOUT); in EpollLoop()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/liteos/dfile/ |
| H A D | sys_dfile_session.c | 24 int32_t nfds = fd + 1; in WaitSocketEvent() local
54 if (nfds < pipe + 1) { in WaitSocketEvent()
55 nfds = pipe + 1; in WaitSocketEvent()
63 int32_t ret = select(nfds, &readFds, &writeFds, NULL, &tv); in WaitSocketEvent()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/unix/dfile/ |
| H A D | sys_dfile_session.c | 24 int32_t nfds = fd + 1; in WaitSocketEvent() local
54 if (nfds < pipe + 1) { in WaitSocketEvent()
55 nfds = pipe + 1; in WaitSocketEvent()
63 int32_t ret = select(nfds, &readFds, &writeFds, NULL, &tv); in WaitSocketEvent()
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| H A D | poller.cpp | 154 int nfds = FetchCachedEventAndDoUnmask(syncTaskIter->second, eventsVec); variable
156 return nfds;
171 int nfds = 0; variable
192 m_waitTaskMap[task] = {static_cast<void*>(eventsVec), maxevents, &nfds, currTime};
199 FFRT_LOGD("task[%s] id[%d] has [%d] events", task->label.c_str(), task->gid, nfds);
200 return nfds;
210 nfds = cachedNfds;
220 m_waitTaskMap[task] = {static_cast<void*>(eventsVec), maxevents, &nfds, currTime};
229 FFRT_LOGD("task[%s] id[%d] has [%d] events", task->label.c_str(), task->gid, nfds);
230 return nfds;
279 int nfds = cachedEventsVec.size(); global() variable
380 int nfds = epoll_wait(m_epFd, waitedEvents.data(), waitedEvents.size(), realTimeout); global() variable
[all...] |
| H A D | delayed_worker.cpp | 73 int nfds = epoll_wait(epollfd_, waitedEvents.data(), waitedEvents.size(), -1); in ThreadInit()
74 if (nfds < 0) { in ThreadInit()
79 for (int i = 0; i < nfds; i++) { in ThreadInit()
|
| H A D | poller.h | 121 void ProcessWaitedFds(int nfds, std::unordered_map<CPUEUTask*, EventVec>& syncTaskEvents,
|
| /foundation/CastEngine/castengine_wifi_display/tests/demo/network/ |
| H A D | udp_server_demo.cpp | 71 int listener, kdpfd, nfds, n; in main() local
126 nfds = epoll_wait(kdpfd, events, 10000, -1); in main()
127 if (nfds == -1) { in main()
132 for (n = 0; n < nfds; ++n) { in main()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket_listener.cpp | 118 int nfds; in OnListenEvents() local
119 CHECK_EXCEPT_INTR(nfds = epoll_wait(epollFd_, events, MAX_EPOLL, -1)); in OnListenEvents()
120 if (nfds == -1) { in OnListenEvents()
124 for (int i = 0; i < nfds; ++i) { in OnListenEvents()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/util/internal/ |
| H A D | timer_linux.cpp | 135 int nfds; in OnTimer() local
136 CHECK_EXCEPT_INTR(nfds = epoll_wait(epollFd_, events, MAXEPOLLEVENTS, -1)); in OnTimer()
137 if (nfds == -1) { in OnTimer()
141 for (int i = 0; i < nfds; ++i) { in OnTimer()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | reactor_linux.c | 131 int nfds; in ReactorStart() local
132 CHECK_EXCEPT_INTR(nfds = epoll_wait(reactor->epollFd, events, MAXEPOLLEVENTS, -1)); in ReactorStart()
133 if (nfds == -1) { in ReactorStart()
139 for (int i = 0; i < nfds; ++i) { in ReactorStart()
|
| /foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
| H A D | mock_system_func.cpp | 146 int __real_select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout);
147 int __wrap_select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout) in __wrap_select() argument
151 int nRet = MockSystemFunc::GetInstance().select(nfds, readfds, writefds, exceptfds, timeout); in __wrap_select()
162 return __real_select(nfds, readfds, writefds, exceptfds, timeout); in __wrap_select()
|
| H A D | mock_system_func.h | 43 MOCK_METHOD5(select, int(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout));
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
| H A D | dns_proxy_listen.cpp | 219 int32_t nfds = in StartListen() local
222 if (nfds < 0) { in StartListen()
226 if (nfds == 0) { in StartListen()
231 for (int i = 0; i < nfds; ++i) { in StartListen()
|
| /foundation/communication/dhcp/test/unittest/services/dhcp_server/unittest/ |
| H A D | system_func_mock.h | 42 MOCK_METHOD5(select, int(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout));
|
| /foundation/communication/netmanager_ext/services/mdnsmanager/src/ |
| H A D | mdns_socket_listener.cpp | 387 int nfds = ctrlPair_[0] + 1; in Run() local
390 nfds = std::max(nfds, socks_[i] + 1); in Run()
393 int res = select(nfds, &rfds, 0, 0, &timeout); in Run()
|
| /foundation/filemanagement/file_api/interfaces/kits/cj/src/ |
| H A D | watcher_impl.cpp | 168 nfds_t nfds = 2; in GetNotifyEvent()
175 int ret = poll(fds, nfds, -1); in GetNotifyEvent()
|
| H A D | copy.cpp | 528 nfds_t nfds = 2; in GetNotifyEvent() local
535 auto ret = poll(fds, nfds, -1); in GetNotifyEvent()
|
| /foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/class_watcher/ |
| H A D | watcher_entity.cpp | 188 nfds_t nfds = 2; in GetNotifyEvent() local
196 ret = poll(fds, nfds, -1); in GetNotifyEvent()
|
| /foundation/communication/dsoftbus/adapter/common/kernel/posix/ |
| H A D | softbus_adapter_socket.c | 305 int32_t nfds, SoftBusFdSet *readFds, SoftBusFdSet *writeFds, SoftBusFdSet *exceptFds, SoftBusSockTimeOut *timeout) in SoftBusSocketSelect()
334 int32_t ret = select(nfds, tempReadSet, tempWriteSet, tempExceptSet, timeoutPtr); in SoftBusSocketSelect()
304 SoftBusSocketSelect( int32_t nfds, SoftBusFdSet *readFds, SoftBusFdSet *writeFds, SoftBusFdSet *exceptFds, SoftBusSockTimeOut *timeout) SoftBusSocketSelect() argument
|
| /foundation/communication/dsoftbus/adapter/common/include/ |
| H A D | softbus_adapter_socket.h | 155 int32_t SoftBusSocketSelect(int32_t nfds, SoftBusFdSet *readFds, SoftBusFdSet *writeFds, SoftBusFdSet *exceptFds,
|
| /foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/properties/ |
| H A D | copy.cpp | 768 nfds_t nfds = 2; in GetNotifyEvent() local
775 auto ret = poll(fds, nfds, -1); in GetNotifyEvent()
|