Signed-off-by: Adam C. Emerson <aemerson@redhat.com>
http_manager(store->ctx(), cr_mgr.get_completion_mgr()),
source_zone(_source_zone), source_bucket(_source_bucket),
conn(NULL), error_logger(NULL),
- dest_bucket(_dest_bucket),
- num_shards(0)
+ dest_bucket(_dest_bucket)
{
}
int num_pipes() {
return sync_pairs.size();
}
-
- void wakeup();
};
class BucketIndexShardsManager;
std::vector<RGWRemoteBucketManager *> source_mgrs;
- std::string source_status_oid;
- std::string source_shard_status_oid_prefix;
-
std::map<int, rgw_bucket_shard_sync_info> sync_status;
- rgw_raw_obj status_obj;
-
- int num_shards;
public:
RGWBucketPipeSyncStatusManager(rgw::sal::RadosStore* _store,