ClientConnQueues.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_core_comm_ClientConnQueues_h
#define swcdb_core_comm_ClientConnQueues_h
 
#include "swcdb/core/comm/SerializedClient.h"
#include "swcdb/core/comm/ClientConnQueue.h"
 
namespace SWC { namespace Comm { namespace client {
 
class ConnQueues;
typedef std::shared_ptr<ConnQueues> ConnQueuesPtr;
 
class Host final : public ConnQueue  {
  public:
  typedef std::shared_ptr<Host> Ptr;
 
  const EndPoints   endpoints;
 
  Host(const ConnQueuesPtr queues, const EndPoints& endpoints,
       const Config::Property::Value_int32_g::Ptr keepalive_ms,
       const Config::Property::Value_int32_g::Ptr again_delay_ms);
 
  virtual ~Host();
 
  bool connect() override;
 
  void close_issued() override;
 
  protected:
  const ConnQueuesPtr queues;
};
 
 
class ConnQueues final :
    private Core::Vector<Host::Ptr>,
    public std::enable_shared_from_this<ConnQueues> {
 
  public:
 
  const Serialized::Ptr                         service;
  const Config::Property::Value_int32_g::Ptr    cfg_conn_timeout;
  const Config::Property::Value_uint16_g::Ptr   cfg_conn_probes;
  const Config::Property::Value_int32_g::Ptr    cfg_keepalive_ms;
  const Config::Property::Value_int32_g::Ptr    cfg_again_delay_ms;
 
  SWC_CAN_INLINE
  ConnQueues(const Serialized::Ptr a_service,
             const Config::Property::Value_int32_g::Ptr timeout,
             const Config::Property::Value_uint16_g::Ptr probes,
             const Config::Property::Value_int32_g::Ptr keepalive_ms,
             const Config::Property::Value_int32_g::Ptr again_delay_ms) noexcept
            : service(a_service),
              cfg_conn_timeout(timeout),
              cfg_conn_probes(probes),
              cfg_keepalive_ms(keepalive_ms),
              cfg_again_delay_ms(again_delay_ms),
              m_mutex() {
  }
 
  ConnQueues(ConnQueues&&)                 = delete;
  ConnQueues(const ConnQueues&)            = delete;
  ConnQueues& operator=(ConnQueues&&)      = delete;
  ConnQueues& operator=(const ConnQueues&) = delete;
 
  ~ConnQueues() noexcept;
 
  void print(std::ostream& out);
 
  Host::Ptr get(const EndPoints& endpoints);
 
  void remove(const EndPoints& endpoints);
 
  void stop();
 
  private:
 
  Core::MutexSptd m_mutex;
 
};
 
 
 
SWC_CAN_INLINE
Host::Host(const ConnQueuesPtr a_queues, const EndPoints& a_endpoints,
           const Config::Property::Value_int32_g::Ptr keepalive_ms,
           const Config::Property::Value_int32_g::Ptr again_delay_ms)
          : ConnQueue(a_queues->service->io(), keepalive_ms, again_delay_ms),
            endpoints(a_endpoints), queues(a_queues) {
}
 
 
 
}}} //namespace SWC::Comm::client
 
 
#ifdef SWC_IMPL_SOURCE
#include "swcdb/core/comm/ClientConnQueues.cc"
#endif
 
 
//
#endif // swcdb_core_comm_ClientConnQueues_h