rgw: add drain_all() before exiting a cr

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>

diff --git a/src/rgw/rgw_sync.cc b/src/rgw/rgw_sync.cc
index fbf3e56889b956cf5bab8ae46caa21ea9c7208a5..bcb6d02b65f1d12114d9dc0640ba479e97cff49f 100644 (file)
--- a/src/rgw/rgw_sync.cc
+++ b/src/rgw/rgw_sync.cc
@@ -1566,6 +1566,7 @@ public:
         // wait for each shard to complete
         collect(&ret);
         if (ret < 0) {
+          drain_all();
           return set_cr_error(ret);
         }
         drain_all();