Watcher::Watcher(librados::IoCtx& ioctx, ContextWQ *work_queue,
const string& oid)
- : m_cct(reinterpret_cast<CephContext *>(ioctx.cct())),
+ : m_ioctx(ioctx), m_work_queue(work_queue), m_oid(oid),
+ m_cct(reinterpret_cast<CephContext *>(ioctx.cct())),
m_watch_lock(util::unique_lock_name("librbd::Watcher::m_watch_lock", this)),
m_watch_handle(0), m_notifier(work_queue, ioctx, oid),
- m_watch_state(WATCH_STATE_UNREGISTERED), m_ioctx(ioctx),
- m_work_queue(work_queue), m_oid(oid), m_watch_ctx(*this)
-{
+ m_watch_state(WATCH_STATE_UNREGISTERED), m_watch_ctx(*this) {
}
-Watcher::~Watcher()
-{
+Watcher::~Watcher() {
RWLock::RLocker l(m_watch_lock);
assert(m_watch_state != WATCH_STATE_REGISTERED);
}
WATCH_STATE_REWATCHING
};
+ librados::IoCtx& m_ioctx;
+ ContextWQ *m_work_queue;
+ std::string m_oid;
CephContext *m_cct;
mutable RWLock m_watch_lock;
uint64_t m_watch_handle;
}
};
- librados::IoCtx& m_ioctx;
- ContextWQ *m_work_queue;
- std::string m_oid;
-
WatchCtx m_watch_ctx;
Context *m_unregister_watch_ctx = nullptr;