Brokers.h

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
#ifndef swcdb_db_client_brk_Brokers_h
#define swcdb_db_client_brk_Brokers_h
 
 
#include "swcdb/db/client/service/bkr/ContextBroker.h"
#include "swcdb/core/comm/ClientConnQueues.h"
 
 
namespace SWC { namespace client {
 
 
 
class Brokers {
  public:
 
  typedef Core::Vector<Comm::EndPoints> BrokersEndPoints;
 
  struct BrokerIdx {
    size_t  pos;
    SWC_CAN_INLINE
    BrokerIdx() noexcept : pos(0) { }
    bool turn_around(Brokers& brks) noexcept;
  };
 
  SWC_CAN_INLINE
  Brokers() noexcept
    : queues(nullptr), cfg_hosts(nullptr), cfg_port(0),
      m_mutex(), m_brokers() {
  }
 
  Brokers(const Config::Settings& settings,
          Comm::IoContextPtr ioctx,
          const ContextBroker::Ptr& bkr_ctx);
 
  Brokers(const Brokers&) = delete;
  
  Brokers& operator=(const Brokers&) = delete;
 
  ~Brokers() noexcept { }
 
  void on_cfg_update() noexcept;
 
  size_t size() noexcept;
 
  bool get(BrokerIdx& idx, Comm::EndPoints& endpoints);
 
  bool has_endpoints() noexcept;
 
  void set(BrokersEndPoints&& endpoints);
 
  void set(const BrokersEndPoints& endpoints);
 
  bool put(const Comm::client::ConnQueue::ReqBase::Ptr& req, BrokerIdx& idx);
 
  const Comm::client::ConnQueuesPtr             queues;
  const Config::Property::Value_strings_g::Ptr  cfg_hosts;
  const uint16_t                                cfg_port;
 
  private:
  Core::MutexSptd  m_mutex;
  BrokersEndPoints m_brokers;
};
 
 
 
}} // namespace SWC::client
 
 
 
 
#ifdef SWC_IMPL_SOURCE
#include "swcdb/db/client/service/bkr/Brokers.cc"
#endif
 
 
#endif // swcdb_db_client_brk_Brokers_h