rgw/pubsub: Waiter warns about blocking

Signed-off-by: Casey Bodley <cbodley@redhat.com>

diff --git a/src/rgw/driver/rados/rgw_pubsub_push.cc b/src/rgw/driver/rados/rgw_pubsub_push.cc
index eb7f854cca82a2825c3d6d9c9e61ae0710a3d2ac..4e73eeb770a08c5db73e99f91419ac89f1b88063 100644 (file)
--- a/src/rgw/driver/rados/rgw_pubsub_push.cc
+++ b/src/rgw/driver/rados/rgw_pubsub_push.cc
@@ -9,6 +9,7 @@
 #include "common/Formatter.h"
 #include "common/iso_8601.h"
 #include "common/async/completion.h"
+#include "rgw_asio_thread.h"
 #include "rgw_common.h"
 #include "rgw_data_sync.h"
 #include "rgw_pubsub.h"
@@ -161,6 +162,8 @@ public:
           }, token, yield.get_executor());
       return -ec.value();
     }
+    maybe_warn_about_blocking(dpp);
+
     cond.wait(l, [this]{return (done==true);});
     return ret;
   }