RgrUpdate.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_manager_Protocol_mngr_params_RgrUpdate_h
#define swcdb_manager_Protocol_mngr_params_RgrUpdate_h
 
#include "swcdb/core/comm/Serializable.h"
 
namespace SWC { namespace Comm { namespace Protocol {
namespace Mngr { namespace Params {
 
 
class RgrUpdate final : public Serializable {
  public:
 
  SWC_CAN_INLINE
  RgrUpdate() noexcept : hosts(), sync_all() { }
 
  SWC_CAN_INLINE
  RgrUpdate(const Manager::RangerList& a_hosts, bool a_sync_all)
            : hosts(a_hosts), sync_all(a_sync_all) {
  }
 
  SWC_CAN_INLINE
  RgrUpdate(RgrUpdate&& other) noexcept
            : hosts(std::move(other.hosts)), sync_all(other.sync_all) {
  }
 
  RgrUpdate(const RgrUpdate&) = delete;
  RgrUpdate& operator=(RgrUpdate&&) = delete;
  RgrUpdate& operator=(const RgrUpdate&) = delete;
 
  ~RgrUpdate() noexcept { }
 
  void print(std::ostream& out) const {
    out << "Rangers-params:";
    for(auto& h : hosts)
      h->print(out << "\n ");
  }
 
  Manager::RangerList hosts;
  bool                sync_all;
 
  private:
 
  size_t internal_encoded_length() const override {
    size_t len = 1 + Serialization::encoded_length_vi32(hosts.size());
    for(auto& h : hosts)
      len += h->encoded_length();
    return len;
  }
 
  void internal_encode(uint8_t** bufp) const override {
    Serialization::encode_bool(bufp, sync_all);
    Serialization::encode_vi32(bufp, hosts.size());
    for(auto& h : hosts)
      h->encode(bufp);
  }
 
  void internal_decode(const uint8_t** bufp, size_t* remainp) override {
    sync_all = Serialization::decode_bool(bufp, remainp);
    hosts.clear();
    if(size_t sz = Serialization::decode_vi32(bufp, remainp)) {
      hosts.reserve(sz);
      for(size_t i=0; i<sz; ++i)
        hosts.emplace_back(new Manager::Ranger(bufp, remainp));
    }
  }
 
};
 
 
}}}}}
 
#endif // swcdb_manager_Protocol_mngr_params_RgrUpdate_h