diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
commit | 19fcec84d8d7d21e796c7624e521b60d28ee21ed (patch) | |
tree | 42d26aa27d1e3f7c0b8bd3fd14e7d7082f5008dc /src/os/bluestore/Allocator.h | |
parent | Initial commit. (diff) | |
download | ceph-upstream.tar.xz ceph-upstream.zip |
Adding upstream version 16.2.11+ds.upstream/16.2.11+dsupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r-- | src/os/bluestore/Allocator.h | 98 |
1 files changed, 98 insertions, 0 deletions
diff --git a/src/os/bluestore/Allocator.h b/src/os/bluestore/Allocator.h new file mode 100644 index 000000000..38ea4f997 --- /dev/null +++ b/src/os/bluestore/Allocator.h @@ -0,0 +1,98 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +/* + * Ceph - scalable distributed file system + * + * This is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software + * Foundation. See file COPYING. + * + */ +#ifndef CEPH_OS_BLUESTORE_ALLOCATOR_H +#define CEPH_OS_BLUESTORE_ALLOCATOR_H + +#include <functional> +#include <ostream> +#include "include/ceph_assert.h" +#include "bluestore_types.h" +#include "zoned_types.h" + +class Allocator { +public: + explicit Allocator(const std::string& name, + int64_t _capacity, + int64_t _block_size); + virtual ~Allocator(); + + /* + * returns allocator type name as per names in config + */ + virtual const char* get_type() const = 0; + + /* + * Allocate required number of blocks in n number of extents. + * Min and Max number of extents are limited by: + * a. alloc unit + * b. max_alloc_size. + * as no extent can be lesser than block_size and greater than max_alloc size. + * Apart from that extents can vary between these lower and higher limits according + * to free block search algorithm and availability of contiguous space. + */ + virtual int64_t allocate(uint64_t want_size, uint64_t block_size, + uint64_t max_alloc_size, int64_t hint, + PExtentVector *extents) = 0; + + int64_t allocate(uint64_t want_size, uint64_t block_size, + int64_t hint, PExtentVector *extents) { + return allocate(want_size, block_size, want_size, hint, extents); + } + + /* Bulk release. Implementations may override this method to handle the whole + * set at once. This could save e.g. unnecessary mutex dance. */ + virtual void release(const interval_set<uint64_t>& release_set) = 0; + void release(const PExtentVector& release_set); + + virtual void dump() = 0; + virtual void foreach( + std::function<void(uint64_t offset, uint64_t length)> notify) = 0; + + virtual void zoned_set_zone_states(std::vector<zone_state_t> &&_zone_states) {} + virtual bool zoned_get_zones_to_clean(std::deque<uint64_t> *zones_to_clean) { + return false; + } + + virtual void init_add_free(uint64_t offset, uint64_t length) = 0; + virtual void init_rm_free(uint64_t offset, uint64_t length) = 0; + + virtual uint64_t get_free() = 0; + virtual double get_fragmentation() + { + return 0.0; + } + virtual double get_fragmentation_score(); + virtual void shutdown() = 0; + + static Allocator *create(CephContext* cct, std::string type, int64_t size, + int64_t block_size, const std::string& name = ""); + + + const string& get_name() const; + int64_t get_capacity() const + { + return capacity; + } + int64_t get_block_size() const + { + return block_size; + } + +private: + class SocketHook; + SocketHook* asok_hook = nullptr; + + int64_t capacity = 0; + int64_t block_size = 0; +}; + +#endif |