Cache.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_rgr_Cache_h
#define swcdb_db_client_rgr_Cache_h
 
 
#include "swcdb/db/Types/Identifiers.h"
#include "swcdb/db/client/Settings.h"
#include "swcdb/core/comm/Resolver.h"
 
#include "swcdb/db/client/service/rgr/ContextRanger.h"
 
 
namespace SWC { namespace client {
 
 
struct RangeEndPoints final {
  int64_t          ts;
  Comm::EndPoints  endpoints;
  SWC_CAN_INLINE
  RangeEndPoints() noexcept: ts(), endpoints() { }
  SWC_CAN_INLINE
  RangeEndPoints(RangeEndPoints&& other) noexcept
                : ts(other.ts), endpoints(std::move(other.endpoints)) {
  }
  SWC_CAN_INLINE
  RangeEndPoints& operator=(RangeEndPoints&& other) noexcept {
    ts = other.ts;
    endpoints = std::move(other.endpoints);
    return *this;
  }
  SWC_CAN_INLINE
  ~RangeEndPoints() noexcept { }
};
 
 
class CachedRangers final
    : private std::unordered_map<
        cid_t, std::unordered_map<rid_t, RangeEndPoints>> {
 
  typedef std::unordered_map<
    cid_t, std::unordered_map<rid_t, RangeEndPoints>> Map;
 
  public:
 
  SWC_CAN_INLINE
  CachedRangers(const Config::Property::Value_int32_g::Ptr expiry_ms) noexcept
                : m_mutex(), m_expiry_ms(expiry_ms) {
  }
 
  CachedRangers(const CachedRangers&) = delete;
  
  CachedRangers& operator=(const CachedRangers&) = delete;
 
  SWC_CAN_INLINE
  ~CachedRangers() noexcept { }
 
  void clear();
 
  void clear_expired();
 
  void remove(const cid_t cid, const rid_t rid);
 
  bool get(const cid_t cid, const rid_t rid, Comm::EndPoints& endpoints);
 
  void set(const cid_t cid, const rid_t rid,
           const Comm::EndPoints& endpoints);
 
  private:
 
  Core::MutexSptd                       m_mutex;
  Config::Property::Value_int32_g::Ptr  m_expiry_ms;
 
};
 
 
 
}}
 
#ifdef SWC_IMPL_SOURCE
#include "swcdb/db/client/service/rgr/Cache.cc"
#endif
 
#endif // swcdb_db_client_rgr_Cache_h