acceptor.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "irsol/server/client/session.hpp"
#include "irsol/types.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
 
namespace irsol {
namespace server {
namespace internal {
 
using OnNewClientCallback_t =
  std::function<void(irsol::types::client_id_t, irsol::types::socket_t&&)>;
 
class ClientSessionAcceptor
{
public:
  ClientSessionAcceptor(irsol::types::port_t port, OnNewClientCallback_t onNewClientCallback);
 
  void run();
 
  void stop();
 
  std::string error() const;
 
  bool isOpen() const;
 
private:
  std::atomic<bool> m_running{false};
 
  const irsol::types::port_t m_port;
 
  OnNewClientCallback_t m_onNewClientCallback;
 
  irsol::types::acceptor_t m_acceptor;
 
  irsol::types::connection_result_t m_isOpen{};
};
 
}  // namespace internal
}  // namespace server
}  // namespace irsol