| 685 | } |
| 686 | |
| 687 | inline size_t WaitD(TEvent* events, size_t len, TInstant deadLine, TInstant now = TInstant::Now()) noexcept { |
| 688 | if (!len) { |
| 689 | return 0; |
| 690 | } |
| 691 | |
| 692 | size_t ret; |
| 693 | |
| 694 | do { |
| 695 | ret = this->Wait(events, len, (int)PollStep(deadLine, now).MicroSeconds()); |
| 696 | } while (!ret && ((now = TInstant::Now()) < deadLine)); |
| 697 | |
| 698 | return ret; |
| 699 | } |
| 700 | }; |
| 701 | |
| 702 | #if defined(HAVE_KQUEUE_POLLER) |
nothing calls this directly
no test coverage detected