error_retry_time = ceph::real_clock::now() + make_timespan(retry_backoff_secs);
error_marker.clear();
}
+ omapkeys.reset();
- yield call(new RGWReadRemoteDataLogShardInfoCR(sync_env, shard_id, &shard_info));
+#define INCREMENTAL_MAX_ENTRIES 100
+ tn->log(20, SSTR("shard_id=" << shard_id << " sync_marker=" << sync_marker.marker));
+ spawned_keys.clear();
+ yield call(new RGWReadRemoteDataLogShardCR(sync_env, shard_id, &sync_marker.marker, &log_entries, &truncated));
if (retcode < 0) {
- tn->log(0, SSTR("ERROR: failed to fetch remote data log info: ret=" << retcode));
+ tn->log(0, SSTR("ERROR: failed to read remote data log info: ret=" << retcode));
stop_spawned_services();
drain_all();
return set_cr_error(retcode);