]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
rgw: some added logging
authorYehuda Sadeh <yehuda@redhat.com>
Fri, 19 Oct 2018 22:18:12 +0000 (15:18 -0700)
committerYehuda Sadeh <yehuda@redhat.com>
Tue, 11 Dec 2018 09:00:21 +0000 (01:00 -0800)
Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
src/rgw/rgw_sync_module_pubsub.cc

index 7a7bcf05b5f5740839b43b6ce6c509a02bb56ba8..c0dba42455a8a886ee18f215544b6561cf888e8f 100644 (file)
@@ -1171,7 +1171,8 @@ public:
   int operate() override {
     reenter(this) {
       ldout(sync_env->cct, 10) << ": handle event: obj: z=" << sync_env->source_zone
-                               << " event=" << json_str("event", *event, false) << dendl;
+                               << " event=" << json_str("event", *event, false)
+                               << " owner=" << owner << dendl;
 
       ldout(sync_env->cct, 20) << "pubsub: " << topics->size() << " topics found for path" << dendl;
 
@@ -1187,10 +1188,11 @@ public:
              */
             yield PSManager::call_get_subscription_cr(sync_env, env->manager, this, *oiter, *siter, &sub);
             if (retcode < 0) {
-              ldout(sync_env->cct, 10) << "ERROR: failed to find subscription config for subscription=" << *siter << " ret=" << retcode << dendl;
+              ldout(sync_env->cct, 10) << "ERROR: failed to find subscription config for subscription=" << *siter << " owner=" << *oiter << " ret=" << retcode << dendl;
               continue;
             }
 
+            ldout(sync_env->cct, 20) << "storing event for subscription=" << *siter << " owner=" << *oiter << " ret=" << retcode << dendl;
             yield call(PSSubscription::store_event_cr(sync_env, sub, event));
             if (retcode < 0) {
               ldout(sync_env->cct, 10) << "ERROR: failed to store event for subscription=" << *siter << " ret=" << retcode << dendl;