summaryrefslogtreecommitdiffstats
path: root/vespalib
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@broadpark.no>2019-09-30 19:44:01 +0200
committerGitHub <noreply@github.com>2019-09-30 19:44:01 +0200
commitd89b30a53ce10839cbfcbdf39a965be357d73162 (patch)
treeffafcf84b47759242fb8af86a3302309e491a5bb /vespalib
parentfbbf3a917e3b3c3e13919b1056fda72a5704099c (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.cpp19
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)));
}
}