{
ReplicatedPG::ObjectContext *obc = (ReplicatedPG::ObjectContext *)_obc;
Watch::Notification *notif = (Watch::Notification *)_notif;
- dout(10) << "got the last reply from pending watchers, can send response now" << dendl;
+ dout(10) << "complete_notify " << notif << " got the last reply from pending watchers, can send response now" << dendl;
MWatchNotify *reply = notif->reply;
client_messenger->send_message(reply, notif->session->con);
notif->session->put();
assert(service.watch_lock.is_locked());
pg->assert_locked();
Watch::Notification *notif = (Watch::Notification *)_notif;
+ dout(10) << "ack_notification " << name << " notif " << notif << " id " << notif->id << dendl;
if (service.watch->ack_notification(name, notif)) {
complete_notify(notif, _obc);
pg->put_object_context(static_cast<ReplicatedPG::ObjectContext *>(_obc));
{
assert(service.watch_lock.is_locked());
Watch::Notification *notif = (Watch::Notification *)_notif;
- dout(10) << "OSD::handle_notify_timeout notif " << notif->id << dendl;
+ dout(10) << "OSD::handle_notify_timeout notif " << notif << " id " << notif->id << dendl;
ReplicatedPG::ObjectContext *obc = (ReplicatedPG::ObjectContext *)notif->obc;
notif->pgid = get_osdmap()->object_locator_to_pg(soid.oid, obc->obs.oi.oloc);
osd->watch->add_notification(notif);
+ dout(20) << " notify id " << notif->id << dendl;
// connected
for (map<entity_name_t, watch_info_t>::iterator i = obc->obs.oi.watchers.begin();