From 39a761498b941932820a70ad179c276c183d6d1f Mon Sep 17 00:00:00 2001
From: Mauro Sardara <msardara@cisco.com>
Date: Mon, 15 Jun 2020 17:35:46 +0200
Subject: [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
---
 apps/http-proxy/src/http_proxy.cc | 32 ++++++++++++++++----------------
 1 file changed, 16 insertions(+), 16 deletions(-)

(limited to 'apps/http-proxy/src')

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;
+    }
   });
 }
 
-- 
cgit 1.2.3-korg