src/ceph/src/journal/JournalTrimmer.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_JOURNAL_JOURNAL_TRIMMER_H
   5 #define CEPH_JOURNAL_JOURNAL_TRIMMER_H
   6
   7 #include "include/int_types.h"
   8 #include "include/rados/librados.hpp"
   9 #include "include/Context.h"
  10 #include "common/AsyncOpTracker.h"
  11 #include "common/Mutex.h"
  12 #include "journal/JournalMetadata.h"
  13 #include "cls/journal/cls_journal_types.h"
  14 #include <functional>
  15
  16 struct Context;
  17
  18 namespace journal {
  19
  20 class JournalTrimmer {
  21 public:
  22   typedef cls::journal::ObjectSetPosition ObjectSetPosition;
  23
  24   JournalTrimmer(librados::IoCtx &ioctx, const std::string &object_oid_prefix,
  25                  const JournalMetadataPtr &journal_metadata);
  26   ~JournalTrimmer();
  27
  28   void shut_down(Context *on_finish);
  29
  30   void remove_objects(bool force, Context *on_finish);
  31   void committed(uint64_t commit_tid);
  32
  33 private:
  34   typedef std::function<Context*()> CreateContext;
  35
  36   struct MetadataListener : public JournalMetadataListener {
  37     JournalTrimmer *journal_trimmer;
  38
  39     MetadataListener(JournalTrimmer *journal_trimmer)
  40       : journal_trimmer(journal_trimmer) {
  41     }
  42     void handle_update(JournalMetadata *) override {
  43       journal_trimmer->handle_metadata_updated();
  44     }
  45   };
  46
  47   struct C_CommitPositionSafe : public Context {
  48     JournalTrimmer *journal_trimmer;
  49
  50     C_CommitPositionSafe(JournalTrimmer *_journal_trimmer)
  51       : journal_trimmer(_journal_trimmer) {
  52       journal_trimmer->m_async_op_tracker.start_op();
  53     }
  54     ~C_CommitPositionSafe() override {
  55       journal_trimmer->m_async_op_tracker.finish_op();
  56     }
  57
  58     void finish(int r) override {
  59     }
  60   };
  61
  62   struct C_RemoveSet;
  63
  64   librados::IoCtx m_ioctx;
  65   CephContext *m_cct;
  66   std::string m_object_oid_prefix;
  67
  68   JournalMetadataPtr m_journal_metadata;
  69   MetadataListener m_metadata_listener;
  70
  71   AsyncOpTracker m_async_op_tracker;
  72
  73   Mutex m_lock;
  74
  75   bool m_remove_set_pending;
  76   uint64_t m_remove_set;
  77   Context *m_remove_set_ctx;
  78
  79   bool m_shutdown = false;
  80
  81   CreateContext m_create_commit_position_safe_context = [this]() {
  82       return new C_CommitPositionSafe(this);
  83     };
  84
  85   void trim_objects(uint64_t minimum_set);
  86   void remove_set(uint64_t object_set);
  87
  88   void handle_metadata_updated();
  89   void handle_set_removed(int r, uint64_t object_set);
  90 };
  91
  92 } // namespace journal
  93
  94 #endif // CEPH_JOURNAL_JOURNAL_TRIMMER_H