yuzu/cpp-httplib
1
0
Fork 0
mirror of https://github.com/yhirose/cpp-httplib synced 2024-11-21 14:29:10 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix #566

Browse source
This commit is contained in:
yhirose 2020-07-12 20:41:02 -04:00
parent 3dff60eb16
commit 6ad25b6cf0
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
httplib.h
View file

@ -1729,7 +1729,7 @@ inline ssize_t select_read(socket_t sock, time_t sec, time_t usec) {
pfd_read.fd = sock; pfd_read.fd = sock;
pfd_read.events = POLLIN; pfd_read.events = POLLIN;
auto timeout = static_cast<int>(sec * 1000 + usec); auto timeout = static_cast<int>(sec * 1000 + usec / 1000);
return handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); }); return handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); });
#else #else
@ -1753,7 +1753,7 @@ inline ssize_t select_write(socket_t sock, time_t sec, time_t usec) {
pfd_read.fd = sock; pfd_read.fd = sock;
pfd_read.events = POLLOUT; pfd_read.events = POLLOUT;
auto timeout = static_cast<int>(sec * 1000 + usec); auto timeout = static_cast<int>(sec * 1000 + usec / 1000);
return handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); }); return handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); });
#else #else
@ -1777,7 +1777,7 @@ inline bool wait_until_socket_is_ready(socket_t sock, time_t sec, time_t usec) {
pfd_read.fd = sock; pfd_read.fd = sock;
pfd_read.events = POLLIN | POLLOUT; pfd_read.events = POLLIN | POLLOUT;
auto timeout = static_cast<int>(sec * 1000 + usec); auto timeout = static_cast<int>(sec * 1000 + usec / 1000);
auto poll_res = handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); }); auto poll_res = handle_EINTR([&]() { return poll(&pfd_read, 1, timeout); });
@ -1888,8 +1888,8 @@ inline bool keep_alive(socket_t sock) {
} else if (val == 0) { } else if (val == 0) {
auto current = steady_clock::now(); auto current = steady_clock::now();
auto duration = duration_cast<milliseconds>(current - start); auto duration = duration_cast<milliseconds>(current - start);
auto timeout = CPPHTTPLIB_KEEPALIVE_TIMEOUT_SECOND * 100 + auto timeout = CPPHTTPLIB_KEEPALIVE_TIMEOUT_SECOND * 1000 +
CPPHTTPLIB_KEEPALIVE_TIMEOUT_SECOND; CPPHTTPLIB_KEEPALIVE_TIMEOUT_USECOND / 1000;
if (duration.count() > timeout) { return false; } if (duration.count() > timeout) { return false; }
std::this_thread::sleep_for(std::chrono::milliseconds(1)); std::this_thread::sleep_for(std::chrono::milliseconds(1));
} else { } else {