]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: include notif pointer in notify debug output
authorSage Weil <sage@inktank.com>
Fri, 24 Aug 2012 00:08:20 +0000 (17:08 -0700)
committerSage Weil <sage@inktank.com>
Mon, 27 Aug 2012 21:57:39 +0000 (14:57 -0700)
Signed-off-by: Sage Weil <sage@inktank.com>
src/osd/OSD.cc
src/osd/ReplicatedPG.cc

index 161cf1196a405242d54f7cfabd8ce19c145ed499..56ff8869c0048105eccc765ec8ec7a17b2db210c 100644 (file)
@@ -2214,7 +2214,7 @@ void OSD::complete_notify(void *_notif, void *_obc)
 {
   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();
@@ -2233,6 +2233,7 @@ void OSD::ack_notification(entity_name_t& name, void *_notif, void *_obc, Replic
   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));
@@ -2315,7 +2316,7 @@ void OSD::handle_notify_timeout(void *_notif)
 {
   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;
 
index d9f868539829f5a935a40d829d96d4787c2ba82d..5fef2bf2d488efae86ec36bbc4d1b8e04944852b 100644 (file)
@@ -3148,6 +3148,7 @@ void ReplicatedPG::do_osd_op_effects(OpContext *ctx)
       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();