// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab

#ifndef CEPH_RBD_MIRROR_MIRROR_STATUS_WATCHER_H
#define CEPH_RBD_MIRROR_MIRROR_STATUS_WATCHER_H

#include "librbd/Watcher.h"

namespace librbd { class ImageCtx; }

namespace rbd {
namespace mirror {

template <typename ImageCtxT = librbd::ImageCtx>
class MirrorStatusWatcher : protected librbd::Watcher {
public:
  static MirrorStatusWatcher *create(librados::IoCtx &io_ctx,
                                     ContextWQ *work_queue) {
    return new MirrorStatusWatcher(io_ctx, work_queue);
  }
  void destroy() {
    delete this;
  }

  MirrorStatusWatcher(librados::IoCtx &io_ctx, ContextWQ *work_queue);
  ~MirrorStatusWatcher() override;

  void init(Context *on_finish);
  void shut_down(Context *on_finish);

protected:
  void handle_notify(uint64_t notify_id, uint64_t handle,
                     uint64_t notifier_id, bufferlist &bl) override;
};

} // namespace mirror
} // namespace rbd

#endif // CEPH_RBD_MIRROR_MIRROR_STATUS_WATCHER_H