if (!marker_tracker.start(entry->key, total_entries, real_time())) {
tn->log(0, SSTR("ERROR: cannot start syncing " << entry->key << ". Duplicate entry?"));
} else {
-#warning look in here
using SyncCR = RGWBucketSyncSingleEntryCR<rgw_obj_key, rgw_obj_key>;
yield spawn(new SyncCR(sc, sync_pipe, entry->key,
false, /* versioned, only matters for object removal */
}
}
-#if 0
- lease_cr->go_down();
-#endif
drain_all();
return set_cr_done();
}
int RGWSI_BucketIndex_RADOS::handle_overwrite(const RGWBucketInfo& info,
const RGWBucketInfo& orig_info)
{
-#warning needs to be done differently
bool new_sync_enabled = info.datasync_flag_enabled();
bool old_sync_enabled = orig_info.datasync_flag_enabled();
&ci, refresh_version, y);
*info = e.info;
-#warning FIXME: use unique_ptr and implement RGWBucketInfo copy constructor, or other better solution
if (info->sync_policy) { /* fork policy off cache */
auto policy = make_shared<rgw_sync_policy_info>(*info->sync_policy);
info->sync_policy = std::const_pointer_cast<const rgw_sync_policy_info>(policy);