jbus/include/jbus/Listener.hpp

#pragma once

#include <memory>
#include <mutex>
#include <queue>
#include <thread>

#include "jbus/Socket.hpp"

namespace jbus {
class Endpoint;

/** Server interface for accepting incoming connections from GBA emulator instances. */
class Listener {
  net::Socket m_dataServer{false};
  net::Socket m_clockServer{false};
  std::thread m_listenerThread;
  std::mutex m_queueLock;
  std::queue<std::unique_ptr<Endpoint>> m_endpointQueue;
  bool m_running = false;

  void listenerProc();

public:
  /** @brief Start listener thread. */
  void start();

  /** @brief Request stop of listener thread and block until joined. */
  void stop();

  /** @brief Pop jbus::Endpoint off Listener's queue.
   *  @return Endpoint instance, ready to issue commands. */
  std::unique_ptr<Endpoint> accept();

  Listener();
  ~Listener();
};

} // namespace jbus