rgw/multisite: capture retcode from RGWDataFullSyncSingleEntryCR()

Signed-off-by: Shilpa Jagannath <smanjara@redhat.com>

diff --git a/src/rgw/driver/rados/rgw_data_sync.cc b/src/rgw/driver/rados/rgw_data_sync.cc
index 8c6fee7c9541175b023f181cb3b5f75f8d2a13b1..090e7a4ff449c088eeb1652501b7f5c54f46ccf4 100644 (file)
--- a/src/rgw/driver/rados/rgw_data_sync.cc
+++ b/src/rgw/driver/rados/rgw_data_sync.cc
@@ -1838,13 +1838,21 @@ public:
                                 error_repo, entry_timestamp, lease_cr,
                                 bucket_shard_cache, &*marker_tracker, tn),
                               sc->lcc.adj_concurrency(cct->_conf->rgw_data_sync_spawn_window),
-                              std::nullopt);
+                              [&](uint64_t stack_id, int ret) {
+                                if (ret < 0) {
+                                  retcode = ret;
+                                }
+                                return retcode;
+                                });
           }
-         sync_marker.marker = iter->first;
+          sync_marker.marker = iter->first;
         }
+
       } while (omapvals->more);
       omapvals.reset();
 
+      drain_all();
+
       tn->unset_flag(RGW_SNS_FLAG_ACTIVE);
 
       if (lost_bid) {