diff options
author | Tor Egge <Tor.Egge@broadpark.no> | 2019-09-30 19:44:01 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-09-30 19:44:01 +0200 |
commit | d89b30a53ce10839cbfcbdf39a965be357d73162 (patch) | |
tree | ffafcf84b47759242fb8af86a3302309e491a5bb /vespalib | |
parent | fbbf3a917e3b3c3e13919b1056fda72a5704099c (diff) |
Revert "Avoid hang in vepalib::ws::Acceptor::accept_main on systems where"
Diffstat (limited to 'vespalib')
-rw-r--r-- | vespalib/src/vespa/vespalib/websocket/acceptor.cpp | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/vespalib/src/vespa/vespalib/websocket/acceptor.cpp b/vespalib/src/vespa/vespalib/websocket/acceptor.cpp index d99035e0be7..4ba1bf3b908 100644 --- a/vespalib/src/vespa/vespalib/websocket/acceptor.cpp +++ b/vespalib/src/vespa/vespalib/websocket/acceptor.cpp @@ -3,34 +3,15 @@ #include "acceptor.h" #include <vespa/vespalib/net/socket_spec.h> #include <functional> -#ifdef __APPLE__ -#include <poll.h> -#endif namespace vespalib::ws { void Acceptor::accept_main(Handler<Socket> &socket_handler) { -#ifdef __APPLE__ - _server_socket.set_blocking(false); -#endif while (!_is_closed) { -#ifdef __APPLE__ - pollfd fds; - fds.fd = _server_socket.get_fd(); - fds.events = POLLIN; - fds.revents = 0; - int res = poll(&fds, 1, 10); - if (res < 1 || fds.revents == 0 || _is_closed) { - continue; - } -#endif SocketHandle handle = _server_socket.accept(); if (handle.valid()) { -#ifdef __APPLE__ - handle.set_blocking(true); -#endif socket_handler.handle(std::make_unique<SimpleSocket>(std::move(handle))); } } |