src/ceph/src/tools/rbd_mirror/image_replayer/ReplayStatusFormatter.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 RBD_MIRROR_IMAGE_REPLAYER_REPLAY_STATUS_FORMATTER_H
   5 #define RBD_MIRROR_IMAGE_REPLAYER_REPLAY_STATUS_FORMATTER_H
   6
   7 #include "include/Context.h"
   8 #include "common/Mutex.h"
   9 #include "cls/journal/cls_journal_types.h"
  10 #include "librbd/journal/Types.h"
  11 #include "librbd/journal/TypeTraits.h"
  12
  13 namespace journal { class Journaler; }
  14 namespace librbd { class ImageCtx; }
  15
  16 namespace rbd {
  17 namespace mirror {
  18 namespace image_replayer {
  19
  20 template <typename ImageCtxT = librbd::ImageCtx>
  21 class ReplayStatusFormatter {
  22 public:
  23   typedef typename librbd::journal::TypeTraits<ImageCtxT>::Journaler Journaler;
  24
  25   static ReplayStatusFormatter* create(Journaler *journaler,
  26                                        const std::string &mirror_uuid) {
  27     return new ReplayStatusFormatter(journaler, mirror_uuid);
  28   }
  29
  30   static void destroy(ReplayStatusFormatter* formatter) {
  31     delete formatter;
  32   }
  33
  34   ReplayStatusFormatter(Journaler *journaler, const std::string &mirror_uuid);
  35
  36   bool get_or_send_update(std::string *description, Context *on_finish);
  37
  38 private:
  39   Journaler *m_journaler;
  40   std::string m_mirror_uuid;
  41   Mutex m_lock;
  42   Context *m_on_finish = nullptr;
  43   cls::journal::ObjectPosition m_master_position;
  44   cls::journal::ObjectPosition m_mirror_position;
  45   int m_entries_behind_master = 0;
  46   cls::journal::Tag m_tag;
  47   std::map<uint64_t, librbd::journal::TagData> m_tag_cache;
  48
  49   bool calculate_behind_master_or_send_update();
  50   void send_update_tag_cache(uint64_t master_tag_tid, uint64_t mirror_tag_tid);
  51   void handle_update_tag_cache(uint64_t master_tag_tid, uint64_t mirror_tag_tid,
  52                                int r);
  53   void format(std::string *description);
  54 };
  55
  56 } // namespace image_replayer
  57 } // namespace mirror
  58 } // namespace rbd
  59
  60 #endif // RBD_MIRROR_IMAGE_REPLAYER_REPLAY_STATUS_FORMATTER_H