[HICN-622] Add stop() functionality to http proxy.

Signed-off-by: Mauro Sardara <msardara@cisco.com>
Change-Id: I9091cd8ef0f9da869b886541a0116adf3f30e6b9
Signed-off-by: Angelo Mantellini <angelo.mantellini@cisco.com>

1 files changed, 0 insertions, 188 deletions

diff --git a/apps/http-proxy/src/http_proxy.h b/apps/http-proxy/src/http_proxy.h
deleted file mode 100644
index c3f183af2..000000000
--- a/apps/http-proxy/src/http_proxy.h
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * Copyright (c) 2020 Cisco and/or its affiliates.
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at:
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#pragma once
-
-#include <hicn/transport/interfaces/socket_consumer.h>
-#include <hicn/transport/utils/event_thread.h>
-
-#include "forwarder_config.h"
-#include "http_session.h"
-#include "icn_receiver.h"
-
-#define ASIO_STANDALONE
-#include <asio.hpp>
-#include <asio/version.hpp>
-#include <unordered_set>
-
-class TcpListener {
- public:
-  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::tcp::v4(), port)),
-#if ((ASIO_VERSION / 100 % 1000) < 12)
-        socket_(io_service),
-#endif
-        callback_(callback) {
-  }
-
- public:
-  void doAccept() {
-#if ((ASIO_VERSION / 100 % 1000) >= 12)
-    acceptor_.async_accept(
-        [this](std::error_code ec, asio::ip::tcp::socket socket) {
-#else
-    acceptor_.async_accept(socket_, [this](std::error_code ec) {
-      auto socket = std::move(socket_);
-#endif
-          if (!ec) {
-            callback_(std::move(socket));
-          }
-
-          doAccept();
-        });
-  }
-
-  asio::ip::tcp::acceptor acceptor_;
-#if ((ASIO_VERSION / 100 % 1000) < 12)
-  asio::ip::tcp::socket socket_;
-#endif
-  AcceptCallback callback_;
-};
-
-namespace transport {
-
-class HTTPClientConnectionCallback;
-
-class Receiver {
- public:
-  Receiver() : thread_() {}
-
- protected:
-  utils::EventThread thread_;
-};
-
-class TcpReceiver : public Receiver {
-  friend class HTTPClientConnectionCallback;
-
- public:
-  TcpReceiver(std::uint16_t port, const std::string& prefix,
-              const std::string& ipv6_first_word);
-
- private:
-  void onNewConnection(asio::ip::tcp::socket&& socket);
-  void onClientDisconnect(HTTPClientConnectionCallback* client);
-
-  template <typename Callback>
-  void parseHicnHeader(std::string& hicn_header, Callback&& callback) {
-    forwarder_config_.parseHicnHeader(hicn_header,
-                                      std::forward<Callback>(callback));
-  }
-
-  TcpListener listener_;
-  std::string prefix_;
-  std::string ipv6_first_word_;
-  std::string prefix_hash_;
-  std::deque<HTTPClientConnectionCallback*> http_clients_;
-  std::unordered_set<HTTPClientConnectionCallback*> used_http_clients_;
-  ForwarderConfig forwarder_config_;
-};
-
-class IcnReceiver : public Receiver {
- public:
-  template <typename... Args>
-  IcnReceiver(Args&&... args)
-      : Receiver(),
-        icn_consum_producer_(thread_.getIoService(),
-                             std::forward<Args>(args)...) {
-    icn_consum_producer_.run();
-  }
-
- private:
-  AsyncConsumerProducer icn_consum_producer_;
-};
-
-class HTTPProxy {
- public:
-  enum Server { CREATE };
-  enum Client { WRAP_BUFFER };
-
-  struct CommonParams {
-    std::string prefix;
-    std::string first_ipv6_word;
-
-    virtual void printParams() { std::cout << "Parameters: " << std::endl; };
-  };
-
-  struct ClientParams : virtual CommonParams {
-    short tcp_listen_port;
-    void printParams() override {
-      std::cout << "Running HTTP/TCP -> HTTP/hICN proxy." << std::endl;
-      CommonParams::printParams();
-      std::cout << "\t"
-                << "HTTP listen port: " << tcp_listen_port << std::endl;
-      std::cout << "\t"
-                << "Consumer Prefix: " << prefix << std::endl;
-      std::cout << "\t"
-                << "Prefix first word: " << first_ipv6_word << std::endl;
-    }
-  };
-
-  struct ServerParams : virtual CommonParams {
-    std::string origin_address;
-    std::string origin_port;
-    std::string cache_size;
-    std::string mtu;
-    std::string content_lifetime;
-    bool manifest;
-
-    void printParams() override {
-      std::cout << "Running HTTP/hICN -> HTTP/TCP proxy." << std::endl;
-      CommonParams::printParams();
-      std::cout << "\t"
-                << "Origin address: " << origin_address << std::endl;
-      std::cout << "\t"
-                << "Origin port: " << origin_port << std::endl;
-      std::cout << "\t"
-                << "Producer cache size: " << cache_size << std::endl;
-      std::cout << "\t"
-                << "hICN MTU: " << mtu << std::endl;
-      std::cout << "\t"
-                << "Default content lifetime: " << content_lifetime
-                << std::endl;
-      std::cout << "\t"
-                << "Producer Prefix: " << prefix << std::endl;
-      std::cout << "\t"
-                << "Prefix first word: " << first_ipv6_word << std::endl;
-      std::cout << "\t"
-                << "Use manifest: " << manifest << std::endl;
-    }
-  };
-
-  HTTPProxy(ClientParams& icn_params, std::size_t n_thread = 1);
-  HTTPProxy(ServerParams& icn_params, std::size_t n_thread = 1);
-
-  void run() { sleep(1000000); }
-
- private:
-  void acceptTCPClient(asio::ip::tcp::socket&& socket);
-
- private:
-  std::vector<std::unique_ptr<Receiver>> receivers_;
-};
-
-}  // namespace transport
\ No newline at end of file