diff options
Diffstat (limited to 'apps/http-proxy/src')
| -rw-r--r-- | apps/http-proxy/src/http_proxy.cc | 32 |
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; + } }); } |