| /dports/net/udt/udt4/src/ |
| H A D | epoll.cpp | 183 …readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>* lrfds, set<SYSSOCKET>* lwfds)
186 if (!readfds && !writefds && !lrfds && lwfds && (msTimeOut < 0))
193 if (lwfds) lwfds->clear();
232 if (lrfds || lwfds)
246 if ((NULL != lwfds) && (ev[i].events & EPOLLOUT))
248 lwfds->insert(ev[i].data.fd);
270 if (lwfds)
288 if (lwfds && FD_ISSET(*i, &writefds))
290 lwfds->insert(*i);
|
| H A D | epoll.h | 139 …t<UDTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOCKET>* lrfds, std::set<SYSSOCKET>* lwfds);
|
| H A D | api.cpp | 1134 …readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>* lrfds, set<SYSSOCKET>* lwfds) in epoll_wait() argument
1136 return m_EPoll.wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
2069 …readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>* lrfds, set<SYSSOCKET>* lwfds) in epoll_wait() argument
2073 return s_UDTUnited.epoll_wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
2307 …readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>* lrfds, set<SYSSOCKET>* lwfds) in epoll_wait() argument
2309 return CUDT::epoll_wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
2326 SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum) in epoll_wait2() argument
2346 if ((lwfds != NULL) && (lwnum != NULL)) in epoll_wait2()
2357 SET_RESULT(lwval, lwnum, lwfds, j); in epoll_wait2()
|
| H A D | api.h | 181 …writefds, int64_t msTimeOut, std::set<SYSSOCKET>* lrfds = NULL, std::set<SYSSOCKET>* lwfds = NULL);
|
| H A D | udt.h | 347 … SYSSOCKET* lrfds = NULL, int* lrnum = NULL, SYSSOCKET* lwfds = NULL, int* lwnum = NULL);
|
| /dports/www/srt/srt-1.4.4/srtcore/ |
| H A D | epoll.cpp | 559 if (!readfds && !writefds && !lrfds && !lwfds && (msTimeOut < 0)) in wait()
566 if (lwfds) lwfds->clear(); in wait()
596 if (!ed.m_sLocals.empty() && (!lrfds || !lwfds)) in wait()
636 if ((lrfds || lwfds) && !ed.m_sLocals.empty()) in wait()
652 if ((NULL != lwfds) && (ev[i].events & EPOLLOUT)) in wait()
654 lwfds->insert(ev[i].data.fd); in wait()
676 if ((NULL != lwfds) && (ke[i].filter == EVFILT_WRITE)) in wait()
678 lwfds->insert(ke[i].ident); in wait()
701 if (lwfds) in wait()
720 if (lwfds && FD_ISSET(*i, &rqwritefds)) in wait()
[all …]
|
| H A D | srt_c_api.cpp | 313 SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum) in srt_epoll_wait() argument
319 lrfds, lrnum, lwfds, lwnum); in srt_epoll_wait()
|
| H A D | epoll.h | 419 …t<SRTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOCKET>* lrfds, std::set<SYSSOCKET>* lwfds);
|
| H A D | udt.h | 212 … SYSSOCKET* lrfds = NULL, int* lrnum = NULL, SYSSOCKET* lwfds = NULL, int* lwnum = NULL);
|
| H A D | api.cpp | 4137 set<SYSSOCKET>* lwfds) in epoll_wait() argument
4142 eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
4544 set<SYSSOCKET>* lwfds) in epoll_wait() argument
4546 return srt::CUDT::epoll_wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
4575 SYSSOCKET* lwfds, in epoll_wait2() argument
4598 if ((lwfds != NULL) && (lwnum != NULL)) in epoll_wait2()
4614 set_result(lwval, lwnum, lwfds); in epoll_wait2()
|
| H A D | srt.h | 959 SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum);
|
| /dports/www/srt/srt-1.4.4/docs/API/ |
| H A D | API.md | 324 SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum);
371 - `writefds` and `lwfds`: subscribed for `OUT` and `ERR`
376 - `lrfds` and `lwfds` report system sockets
|
| H A D | API-functions.md | 2226 SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum);
2247 * `lwfds` and `lwnum`: A pointer and length of an array to write system sockets that are read-ready
2248 * `lwfds` and `lwnum`: A pointer and length of an array to write system sockets that are write-ready
|