stop();
}
-int RGWRemoteDataLog::get_shard_info(int shard_id)
-{
- char buf[32];
- snprintf(buf, sizeof(buf), "%d", shard_id);
-
- rgw_http_param_pair pairs[] = { { "type", "data" },
- { "id", buf },
- { "info", NULL },
- { NULL, NULL } };
-
- RGWDataChangesLogInfo info;
- int ret = sync_env.conn->get_json_resource("/admin/log", pairs, info);
- if (ret < 0) {
- ldout(store->ctx(), 0) << "ERROR: failed to fetch datalog info" << dendl;
- return ret;
- }
-
- ldout(store->ctx(), 20) << "remote datalog, shard_id=" << shard_id << " marker=" << info.marker << dendl;
-
- return 0;
-}
-
int RGWRemoteDataLog::read_sync_status(rgw_data_sync_status *sync_status)
{
// cannot run concurrently with run_sync(), so run in a separate manager
int read_log_info(rgw_datalog_info *log_info);
int read_source_log_shards_info(map<int, RGWDataChangesLogInfo> *shards_info);
int read_source_log_shards_next(map<int, string> shard_markers, map<int, rgw_datalog_shard_data> *result);
- int get_shard_info(int shard_id);
int read_sync_status(rgw_data_sync_status *sync_status);
int init_sync_status(int num_shards);
int run_sync(int num_shards);