diff options
| author |   Mauro Sardara <msardara@cisco.com> | 2020-06-15 17:35:46 +0200 |
|---|---|---|
| committer | Mauro Sardara <msardara@cisco.com> | 2020-06-15 17:35:46 +0200 |
| commit | 39a761498b941932820a70ad179c276c183d6d1f (patch) | |
| tree | 9efddd149f51f6687fb6f5538c733ebbaa980d19 /apps/http-proxy/includes | |
| parent | 658de14e6d5b1d2e0282dbba74bf41f08928f479 (diff) | |
[HICN-629] Add multithreading feature to hicn-http-proxy with SO_REUSEPORT socket option.
Signed-off-by: Mauro Sardara <msardara@cisco.com>
Change-Id: I8930178ba09ca23bd593f2a4008cf0d75f502684
Diffstat (limited to 'apps/http-proxy/includes')
| -rw-r--r-- | apps/http-proxy/includes/hicn/http-proxy/http_proxy.h | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/apps/http-proxy/includes/hicn/http-proxy/http_proxy.h b/apps/http-proxy/includes/hicn/http-proxy/http_proxy.h index 15a468842..a4139a620 100644 --- a/apps/http-proxy/includes/hicn/http-proxy/http_proxy.h +++ b/apps/http-proxy/includes/hicn/http-proxy/http_proxy.h @@ -32,13 +32,18 @@ class TcpListener { using AcceptCallback = std::function<void(asio::ip::tcp::socket&&)>; TcpListener(asio::io_service& io_service, short port, AcceptCallback callback) - : acceptor_(io_service, - asio::ip::tcp::endpoint( - asio::ip::address::from_string("127.0.0.1"), port)), + : acceptor_(io_service), #if ((ASIO_VERSION / 100 % 1000) < 12) socket_(io_service), #endif callback_(callback) { + acceptor_.open(asio::ip::tcp::v4()); + typedef asio::detail::socket_option::boolean<SOL_SOCKET, SO_REUSEPORT> + reuse_port; + acceptor_.set_option(reuse_port(true)); + acceptor_.bind(asio::ip::tcp::endpoint( + asio::ip::address::from_string("127.0.0.1"), port)); + acceptor_.listen(); } public: |