Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
ceph_assert(!conn);
}
-bool Watch::connected() { return !!conn; }
-
Context *Watch::get_delayed_cb()
{
ceph_assert(!cb);
dout(10) << "start_notify " << notif->notify_id << dendl;
in_progress_notifies[notif->notify_id] = notif;
notif->start_watcher(self.lock());
- if (connected())
+ if (is_connected())
send_notify(notif);
}
return last_ping;
}
+ /// True if currently connected
bool is_connected() const {
return conn.get() != NULL;
}
/// Generates context for use if watch timeout is delayed by scrub or recovery
Context *get_delayed_cb();
- /// True if currently connected
- bool connected();
-
/// Transitions Watch to connected, unregister_cb, resends pending Notifies
void connect(
ConnectionRef con, ///< [in] Reference to new connection