secondary_tcp_server.h

#ifndef AKTUALIZR_SECONDARY_TCP_SERVER_H_
#define AKTUALIZR_SECONDARY_TCP_SERVER_H_
 
#include "utilities/utils.h"
 
#include <atomic>
 
namespace Uptane {
class SecondaryInterface;
}  // namespace Uptane
/**
 * Listens on a socket, decodes calls (ASN.1) and forwards them to an Uptane Secondary
 * implementation
 */
class SecondaryTcpServer {
 public:
  SecondaryTcpServer(Uptane::SecondaryInterface& secondary, const std::string& primary_ip, in_port_t primary_port,
                     in_port_t port = 0);
 
  SecondaryTcpServer(Uptane::SecondaryInterface& secondary, in_port_t port = 0)
      : keep_running_(true), impl_(secondary), listen_socket_(port) {}
 
  SecondaryTcpServer(const SecondaryTcpServer&) = delete;
  SecondaryTcpServer& operator=(const SecondaryTcpServer&) = delete;
 
 public:
  /**
   * Accept connections on the socket, decode requests and respond using the secondary implementation
   */
  void run();
  void stop();
 
  in_port_t port() const;
 
 private:
  void HandleOneConnection(int socket);
 
 private:
  std::atomic<bool> keep_running_;
  Uptane::SecondaryInterface& impl_;
  ListenSocket listen_socket_;
};
 
#endif  // AKTUALIZR_SECONDARY_TCP_SERVER_H_