ObjectState& os,
ceph::os::Transaction& txn)
{
+ logger().debug("{}", __func__);
struct connect_ctx_t {
ObjectContext::watch_key_t key;
crimson::net::ConnectionRef conn;
namespace crimson::osd {
+Watch::~Watch()
+{
+ logger().debug("{} gid={} cookie={}", __func__, get_watcher_gid(), get_cookie());
+}
+
seastar::future<> Watch::connect(crimson::net::ConnectionRef conn, bool)
{
if (this->conn == conn) {
// to avoid use-after-free we bump up the ref counter with `guard_ptr`.
[[maybe_unused]] auto guard_ptr = shared_from_this();
for (auto& watcher : watchers) {
+ logger().debug("canceling watcher cookie={} gid={} use_count={}",
+ watcher->get_cookie(),
+ watcher->get_watcher_gid(),
+ watcher->use_count());
watcher->cancel_notify(ninfo.notify_id);
}
std::ignore = send_completion(std::move(watchers));