Home
last modified time | relevance | path

Searched refs:msTimeOut (Results 1 – 25 of 325) sorted by relevance

12345678910>>...13

/dports/www/srt/srt-1.4.4/srtcore/
H A Depoll.cpp491 int CEPoll::uwait(const int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut) in uwait() argument
547 …if ((msTimeOut >= 0) && (count_microseconds(srt::sync::steady_clock::now() - entertime) >= msTimeO… in uwait()
556 …nst int eid, set<SRTSOCKET>* readfds, set<SRTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>*… in wait() argument
559 if (!readfds && !writefds && !lrfds && !lwfds && (msTimeOut < 0)) in wait()
739 …if ((msTimeOut >= 0) && (count_microseconds(srt::sync::steady_clock::now() - entertime) >= msTimeO… in wait()
753 int CEPoll::swait(CEPollDesc& d, map<SRTSOCKET, int>& st, int64_t msTimeOut, bool report_by_excepti… in swait() argument
757 if (!d.flags(SRT_EPOLL_ENABLE_EMPTY) && d.watch_empty() && msTimeOut < 0) in swait()
797 if (!empty || msTimeOut == 0) in swait()
826 …if ((msTimeOut >= 0) && ((steady_clock::now() - entertime) >= microseconds_from(msTimeOut * int64_… in swait()
H A Dsrt_c_api.cpp83 …nd(const SRTSOCKET lsns[], int lsize, int64_t msTimeOut) { return CUDT::accept_bond(lsns, lsize, m… in srt_accept_bond() argument
312 int64_t msTimeOut, in srt_epoll_wait() argument
318 msTimeOut, in srt_epoll_wait()
322 int srt_epoll_uwait(int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut) in srt_epoll_uwait() argument
328 msTimeOut); in srt_epoll_uwait()
H A Dudt.h200 … std::vector<SRTSOCKET>* writefds, std::vector<SRTSOCKET>* exceptfds, int64_t msTimeOut);
209 …epoll_wait(int eid, std::set<SRTSOCKET>* readfds, std::set<SRTSOCKET>* writefds, int64_t msTimeOut,
211 …ll_wait2(int eid, SRTSOCKET* readfds, int* rnum, SRTSOCKET* writefds, int* wnum, int64_t msTimeOut,
213 SRT_API int epoll_uwait(const int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut);
H A Depoll.h419 …d, std::set<SRTSOCKET>* readfds, std::set<SRTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOC…
432 int swait(CEPollDesc& d, fmap_t& st, int64_t msTimeOut, bool report_by_exception = true);
469 int uwait(const int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut);
H A Dapi.h280 SRTSOCKET accept_bond(const SRTSOCKET listeners [], int lsize, int64_t msTimeOut);
293 …* readfds, std::vector<SRTSOCKET>* writefds, std::vector<SRTSOCKET>* exceptfds, int64_t msTimeOut);
308 int epoll_uwait(const int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut);
H A Dapi.cpp1034 m_EPoll.swait(*ed, (st), msTimeOut, true); in accept_bond()
2274 int64_t msTimeOut) in selectEx() argument
2278 const int64_t timeo_us = msTimeOut >= 0 in selectEx()
2279 ? msTimeOut * 1000 in selectEx()
2472 int64_t msTimeOut) in epoll_uwait() argument
3957 int64_t msTimeOut) in selectEx() argument
4135 int64_t msTimeOut, in epoll_wait() argument
4160 int64_t msTimeOut) in epoll_uwait() argument
4493 int64_t msTimeOut) in selectEx() argument
4542 int64_t msTimeOut, in epoll_wait() argument
[all …]
H A Dsrt.h845 SRT_API SRTSOCKET srt_accept_bond (const SRTSOCKET listeners[], int lsize, int64_t msTimeOut);
958 …oll_wait(int eid, SRTSOCKET* readfds, int* rnum, SRTSOCKET* writefds, int* wnum, int64_t msTimeOut,
969 SRT_API int srt_epoll_uwait(int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut);
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException {
59 socket.setSoTimeout(msTimeOut);
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/sun/management/jdp/
H A DClientConnection.java56 public MulticastSocket connectWithTimeout(int msTimeOut) throws IOException { in connectWithTimeout() argument
59 socket.setSoTimeout(msTimeOut); in connectWithTimeout()
/dports/net/udt/udt4/src/
H A Depoll.cpp183 …nst int eid, set<UDTSOCKET>* readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<SYSSOCKET>*…
186 if (!readfds && !writefds && !lrfds && lwfds && (msTimeOut < 0))
209 …ksIn.empty() && p->second.m_sUDTSocksOut.empty() && p->second.m_sLocals.empty() && (msTimeOut < 0))
303 if ((msTimeOut >= 0) && (int64_t(CTimer::getTime() - entertime) >= msTimeOut * 1000LL))
H A Dudt.h337 … std::vector<UDTSOCKET>* writefds, std::vector<UDTSOCKET>* exceptfds, int64_t msTimeOut);
344 …epoll_wait(int eid, std::set<UDTSOCKET>* readfds, std::set<UDTSOCKET>* writefds, int64_t msTimeOut,
346 …ll_wait2(int eid, UDTSOCKET* readfds, int* rnum, UDTSOCKET* writefds, int* wnum, int64_t msTimeOut,
H A Dapi.cpp1026 if (msTimeOut >= 0) in selectEx()
1027 to = msTimeOut * 1000; in selectEx()
1136 return m_EPoll.wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
1960 return s_UDTUnited.selectEx(fds, readfds, writefds, exceptfds, msTimeOut); in selectEx()
2073 return s_UDTUnited.epoll_wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
2277 …<UDTSOCKET>* readfds, vector<UDTSOCKET>* writefds, vector<UDTSOCKET>* exceptfds, int64_t msTimeOut) in selectEx() argument
2279 return CUDT::selectEx(fds, readfds, writefds, exceptfds, msTimeOut); in selectEx()
2307 int epoll_wait(int eid, set<UDTSOCKET>* readfds, set<UDTSOCKET>* writefds, int64_t msTimeOut, set<S… in epoll_wait() argument
2309 return CUDT::epoll_wait(eid, readfds, writefds, msTimeOut, lrfds, lwfds); in epoll_wait()
2325 …ll_wait2(int eid, UDTSOCKET* readfds, int* rnum, UDTSOCKET* writefds, int* wnum, int64_t msTimeOut, in epoll_wait2() argument
[all …]
H A Dapi.h175 …* readfds, std::vector<UDTSOCKET>* writefds, std::vector<UDTSOCKET>* exceptfds, int64_t msTimeOut);
181 …d, std::set<UDTSOCKET>* readfds, std::set<UDTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOC…
H A Depoll.h139 …d, std::set<UDTSOCKET>* readfds, std::set<UDTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOC…
H A Dcore.h99 …* readfds, std::vector<UDTSOCKET>* writefds, std::vector<UDTSOCKET>* exceptfds, int64_t msTimeOut);
105 …d, std::set<UDTSOCKET>* readfds, std::set<UDTSOCKET>* writefds, int64_t msTimeOut, std::set<SYSSOC…
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/util/
H A Dbackground.cpp203 bool BackgroundJob::wait(unsigned msTimeOut) { in wait() argument
205 const auto deadline = Date_t::now() + Milliseconds(msTimeOut); in wait()
208 if (msTimeOut) { in wait()
H A Dbackground.h119 bool wait(unsigned msTimeOut = 0);

12345678910>>...13