Lines Matching refs:timeout

867 void MtFrame::WaitNotify(utime64_t timeout)  in WaitNotify()  argument
871 thread->SetWakeupTime(timeout + this->GetLastClock()); in WaitNotify()
912 bool MtFrame::KqueueSchedule(KqObjList* fdlist, KqueuerObj* fd, int timeout) in KqueueSchedule() argument
931 thread->SetWakeupTime(timeout + this->GetLastClock()); in KqueueSchedule()
961 …from(int fd, void *buf, int len, int flags, struct sockaddr *from, socklen_t *fromlen, int timeout) in recvfrom() argument
975 if (timeout <= -1) in recvfrom()
977 timeout = 0x7fffffff; in recvfrom()
983 if ((int)(now - start) > timeout) in recvfrom()
993 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in recvfrom()
1021 …dto(int fd, const void *msg, int len, int flags, const struct sockaddr *to, int tolen, int timeout) in sendto() argument
1040 if ((int)(now - start) > timeout) in sendto()
1059 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in sendto()
1067 int MtFrame::connect(int fd, const struct sockaddr *addr, int addrlen, int timeout) in connect() argument
1086 if ((int)(now - start) > timeout) in connect()
1110 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in connect()
1118 int MtFrame::accept(int fd, struct sockaddr *addr, socklen_t *addrlen, int timeout) in accept() argument
1137 if ((int)(now - start) > timeout) in accept()
1156 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in accept()
1164 ssize_t MtFrame::read(int fd, void *buf, size_t nbyte, int timeout) in read() argument
1183 if ((int)(now - start) > timeout) in read()
1202 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in read()
1210 ssize_t MtFrame::write(int fd, const void *buf, size_t nbyte, int timeout) in write() argument
1229 if ((int)(now - start) > timeout) in write()
1260 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in write()
1268 int MtFrame::recv(int fd, void *buf, int len, int flags, int timeout) in recv() argument
1282 if (timeout <= -1) in recv()
1284 timeout = 0x7fffffff; in recv()
1290 if ((int)(now - start) > timeout) in recv()
1300 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in recv()
1328 ssize_t MtFrame::send(int fd, const void *buf, size_t nbyte, int flags, int timeout) in send() argument
1347 if ((int)(now - start) > timeout) in send()
1378 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in send()
1396 int MtFrame::WaitEvents(int fd, int events, int timeout) in WaitEvents() argument
1403 if (timeout <= -1) in WaitEvents()
1405 timeout = 0x7fffffff; in WaitEvents()
1411 if ((int)(now - start) > timeout) in WaitEvents()
1429 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in WaitEvents()