From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/crush/CrushLocation.h | 37 +++++++++++++++++++++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 src/crush/CrushLocation.h (limited to 'src/crush/CrushLocation.h') diff --git a/src/crush/CrushLocation.h b/src/crush/CrushLocation.h new file mode 100644 index 000000000..678135c2e --- /dev/null +++ b/src/crush/CrushLocation.h @@ -0,0 +1,37 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#ifndef CEPH_CRUSH_LOCATION_H +#define CEPH_CRUSH_LOCATION_H + +#include +#include +#include + +#include "common/ceph_mutex.h" +#include "include/common_fwd.h" + +namespace TOPNSPC::crush { + +class CrushLocation { +public: + explicit CrushLocation(CephContext *c) : cct(c) { + init_on_startup(); + } + + int update_from_conf(); ///< refresh from config + int update_from_hook(); ///< call hook, if present + int init_on_startup(); + + std::multimap get_location() const; + +private: + int _parse(const std::string& s); + CephContext *cct; + std::multimap loc; + mutable ceph::mutex lock = ceph::make_mutex("CrushLocation"); +}; + +std::ostream& operator<<(std::ostream& os, const CrushLocation& loc); +} +#endif -- cgit v1.2.3