env->error_logger = error_logger;
}
-int RGWRemoteMetaLog::clone_shards(int num_shards, vector<string>& clone_markers)
-{
- list<RGWCoroutinesStack *> stacks;
- for (int i = 0; i < (int)num_shards; i++) {
- RGWCoroutinesStack *stack = new RGWCoroutinesStack(store->ctx(), this);
- stack->call(new RGWCloneMetaLogCoroutine(&sync_env, i, clone_markers[i], NULL));
-
- stacks.push_back(stack);
- }
-
- return run(stacks);
-}
-
int RGWRemoteMetaLog::fetch(int num_shards, vector<string>& clone_markers)
{
list<RGWCoroutinesStack *> stacks;
int list_shard(int shard_id);
int list_shards(int num_shards);
int get_shard_info(int shard_id);
- int clone_shards(int num_shards, vector<string>& clone_markers);
int fetch(int num_shards, vector<string>& clone_markers);
int read_sync_status(rgw_meta_sync_status *sync_status);
int init_sync_status(int num_shards);
int read_sync_status() { return master_log.read_sync_status(&sync_status); }
int init_sync_status() { return master_log.init_sync_status(num_shards); }
int fetch() { return master_log.fetch(num_shards, clone_markers); }
- int clone_shards() { return master_log.clone_shards(num_shards, clone_markers); }
int run() { return master_log.run_sync(num_shards, sync_status); }