[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

2 files changed, 24 insertions, 19 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:
diff --git a/apps/http-proxy/src/http_proxy.cc b/apps/http-proxy/src/http_proxy.cc
index 4484b5a1a..c252afe88 100644
--- a/apps/http-proxy/src/http_proxy.cc
+++ b/apps/http-proxy/src/http_proxy.cc
@@ -15,13 +15,11 @@
 
 #include <hicn/http-proxy/http_proxy.h>
 #include <hicn/http-proxy/http_session.h>
-
+#include <hicn/http-proxy/utils.h>
 #include <hicn/transport/core/interest.h>
 #include <hicn/transport/utils/log.h>
 #include <hicn/transport/utils/string_utils.h>
 
-#include <hicn/http-proxy/utils.h>
-
 namespace transport {
 
 using core::Interest;
@@ -266,21 +264,23 @@ TcpReceiver::TcpReceiver(std::uint16_t port, const std::string& prefix,
       prefix_(prefix),
       ipv6_first_word_(ipv6_first_word),
       prefix_hash_(generatePrefix(prefix_, ipv6_first_word_)),
-      forwarder_config_(thread_.getIoService(), [this](std::error_code ec) {
-        if (!ec) {
-          listener_.doAccept();
-          for (int i = 0; i < 10; i++) {
-            http_clients_.emplace_back(
-                new HTTPClientConnectionCallback(*this, thread_));
-          }
-        }
-      }),
+      forwarder_config_(
+          thread_.getIoService(),
+          [this](std::error_code ec) {
+            if (!ec) {
+              listener_.doAccept();
+              for (int i = 0; i < 10; i++) {
+                http_clients_.emplace_back(
+                    new HTTPClientConnectionCallback(*this, thread_));
+              }
+            }
+          }),
       stopped_(false) {
   forwarder_config_.tryToConnectToForwarder();
 }
 
 void TcpReceiver::stop() {
-  thread_.add([this](){
+  thread_.add([this]() {
     stopped_ = true;
 
     /* Stop the listener */
@@ -295,9 +295,9 @@ void TcpReceiver::stop() {
     }
 
     /* Delete unused clients */
-     for (auto& client : http_clients_) {
-       delete client;
-     }
+    for (auto& client : http_clients_) {
+      delete client;
+    }
   });
 }