aboutsummaryrefslogtreecommitdiffstats
path: root/apps/http-proxy/src/http_proxy.cc
diff options
context:
space:
mode:
authorMauro Sardara <msardara@cisco.com>2020-06-15 17:35:46 +0200
committerMauro Sardara <msardara@cisco.com>2020-06-15 17:35:46 +0200
commit39a761498b941932820a70ad179c276c183d6d1f (patch)
tree9efddd149f51f6687fb6f5538c733ebbaa980d19 /apps/http-proxy/src/http_proxy.cc
parent658de14e6d5b1d2e0282dbba74bf41f08928f479 (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/src/http_proxy.cc')
-rw-r--r--apps/http-proxy/src/http_proxy.cc32
1 files changed, 16 insertions, 16 deletions
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;
+ }
});
}