| 2417 | } |
| 2418 | |
| 2419 | inline ssize_t select_write(socket_t sock, time_t sec, time_t usec) { |
| 2420 | #ifdef CPPHTTPLIB_USE_POLL |
| 2421 | struct pollfd pfd_read; |
| 2422 | pfd_read.fd = sock; |
| 2423 | pfd_read.events = POLLOUT; |
| 2424 | |
| 2425 | auto timeout = static_cast<int>(sec * 1000 + usec / 1000); |
| 2426 | |
| 2427 | return handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); }); |
| 2428 | #else |
| 2429 | #ifndef _WIN32 |
| 2430 | if (sock >= FD_SETSIZE) { return 1; } |
| 2431 | #endif |
| 2432 | |
| 2433 | fd_set fds; |
| 2434 | FD_ZERO(&fds); |
| 2435 | FD_SET(sock, &fds); |
| 2436 | |
| 2437 | timeval tv; |
| 2438 | tv.tv_sec = static_cast<long>(sec); |
| 2439 | tv.tv_usec = static_cast<decltype(tv.tv_usec)>(usec); |
| 2440 | |
| 2441 | return handle_EINTR([&]() { |
| 2442 | return select(static_cast<int>(sock + 1), nullptr, &fds, nullptr, &tv); |
| 2443 | }); |
| 2444 | #endif |
| 2445 | } |
| 2446 | |
| 2447 | inline Error wait_until_socket_is_ready(socket_t sock, time_t sec, |
| 2448 | time_t usec) { |
no test coverage detected