ceph/src/os/bluestore/BitmapFreelistManager.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #ifndef CEPH_OS_BLUESTORE_BITMAPFREELISTMANAGER_H
   5 #define CEPH_OS_BLUESTORE_BITMAPFREELISTMANAGER_H
   6
   7 #include "FreelistManager.h"
   8
   9 #include <string>
  10 #include <mutex>
  11
  12 #include "common/ceph_mutex.h"
  13 #include "include/buffer.h"
  14 #include "kv/KeyValueDB.h"
  15
  16 class BitmapFreelistManager : public FreelistManager {
  17   std::string meta_prefix, bitmap_prefix;
  18   std::shared_ptr<KeyValueDB::MergeOperator> merge_op;
  19   ceph::mutex lock = ceph::make_mutex("BitmapFreelistManager::lock");
  20
  21   uint64_t size;            ///< size of device (bytes)
  22   uint64_t bytes_per_block; ///< bytes per block (bdev_block_size)
  23   uint64_t blocks_per_key;  ///< blocks (bits) per key/value pair
  24   uint64_t bytes_per_key;   ///< bytes per key/value pair
  25   uint64_t blocks;          ///< size of device (blocks, size rounded up)
  26
  27   uint64_t block_mask;  ///< mask to convert byte offset to block offset
  28   uint64_t key_mask;    ///< mask to convert offset to key offset
  29
  30   bufferlist all_set_bl;
  31
  32   KeyValueDB::Iterator enumerate_p;
  33   uint64_t enumerate_offset; ///< logical offset; position
  34   bufferlist enumerate_bl;   ///< current key at enumerate_offset
  35   int enumerate_bl_pos;      ///< bit position in enumerate_bl
  36
  37   uint64_t _get_offset(uint64_t key_off, int bit) {
  38     return key_off + bit * bytes_per_block;
  39   }
  40
  41   void _init_misc();
  42
  43   void _verify_range(KeyValueDB *kvdb,
  44     uint64_t offset, uint64_t length, int val);
  45   void _xor(
  46     uint64_t offset, uint64_t length,
  47     KeyValueDB::Transaction txn);
  48
  49   int _init_from_label(const bluestore_bdev_label_t& label);
  50
  51   int _expand(uint64_t new_size, KeyValueDB* db);
  52
  53   uint64_t size_2_block_count(uint64_t target_size) const;
  54
  55   int read_size_meta_from_db(KeyValueDB* kvdb, uint64_t* res);
  56   void _sync(KeyValueDB* kvdb, bool read_only);
  57
  58   void _load_from_db(KeyValueDB* kvdb);
  59
  60 public:
  61   BitmapFreelistManager(CephContext* cct, string meta_prefix,
  62                         string bitmap_prefix);
  63
  64   static void setup_merge_operator(KeyValueDB *db, string prefix);
  65
  66   int create(uint64_t size, uint64_t granularity,
  67              KeyValueDB::Transaction txn) override;
  68
  69   int init(const bluestore_bdev_label_t& l,
  70     KeyValueDB *kvdb,
  71     bool db_in_read_only) override;
  72
  73   void shutdown() override;
  74   void sync(KeyValueDB* kvdb) override;
  75
  76   void dump(KeyValueDB *kvdb) override;
  77
  78   void enumerate_reset() override;
  79   bool enumerate_next(KeyValueDB *kvdb, uint64_t *offset, uint64_t *length) override;
  80
  81   void allocate(
  82     uint64_t offset, uint64_t length,
  83     KeyValueDB::Transaction txn) override;
  84   void release(
  85     uint64_t offset, uint64_t length,
  86     KeyValueDB::Transaction txn) override;
  87
  88   inline uint64_t get_size() const override {
  89     return size;
  90   }
  91   inline uint64_t get_alloc_units() const override {
  92     return size / bytes_per_block;
  93   }
  94   inline uint64_t get_alloc_size() const override {
  95     return bytes_per_block;
  96   }
  97   void get_meta(uint64_t target_size,
  98     std::vector<std::pair<string, string>>*) const override;
  99 };
 100
 101 #endif