From: Zhang Shaowen Date: Fri, 17 Nov 2017 02:50:16 +0000 (+0800) Subject: rgw: remove useless func set_bucket_sync. X-Git-Tag: v15.1.0~1490^2~3 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=ae99dcd876d3c3a30b181eeb03404c64d0dfd521;p=ceph.git rgw: remove useless func set_bucket_sync. Signed-off-by: Zhang Shaowen --- diff --git a/src/rgw/rgw_admin.cc b/src/rgw/rgw_admin.cc index 9daf73a2d76..635286d922c 100644 --- a/src/rgw/rgw_admin.cc +++ b/src/rgw/rgw_admin.cc @@ -1650,59 +1650,6 @@ int do_check_object_locator(const string& tenant_name, const string& bucket_name return 0; } -int set_bucket_sync_enabled(rgw::sal::RGWRadosStore *store, int opt_cmd, const string& tenant_name, const string& bucket_name) -{ - RGWBucketInfo bucket_info; - map attrs; - auto obj_ctx = store->svc()->sysobj->init_obj_ctx(); - - int r = store->getRados()->get_bucket_info(obj_ctx, tenant_name, bucket_name, bucket_info, NULL, null_yield, &attrs); - if (r < 0) { - cerr << "could not get bucket info for bucket=" << bucket_name << ": " << cpp_strerror(-r) << std::endl; - return -r; - } - - if (opt_cmd == OPT_BUCKET_SYNC_ENABLE) { - bucket_info.flags &= ~BUCKET_DATASYNC_DISABLED; - } else if (opt_cmd == OPT_BUCKET_SYNC_DISABLE) { - bucket_info.flags |= BUCKET_DATASYNC_DISABLED; - } - - r = store->getRados()->put_bucket_instance_info(bucket_info, false, real_time(), &attrs); - if (r < 0) { - cerr << "ERROR: failed writing bucket instance info: " << cpp_strerror(-r) << std::endl; - return -r; - } - - int shards_num = bucket_info.num_shards? bucket_info.num_shards : 1; - int shard_id = bucket_info.num_shards? 0 : -1; - - if (opt_cmd == OPT_BUCKET_SYNC_DISABLE) { - r = store->svc()->bilog_rados->log_stop(bucket_info, -1); - if (r < 0) { - lderr(store->ctx()) << "ERROR: failed writing stop bilog" << dendl; - return r; - } - } else { - r = store->svc()->bilog_rados->log_start(bucket_info, -1); - if (r < 0) { - lderr(store->ctx()) << "ERROR: failed writing resync bilog" << dendl; - return r; - } - } - - for (int i = 0; i < shards_num; ++i, ++shard_id) { - r = store->svc()->datalog_rados->add_entry(bucket_info.bucket, shard_id); - if (r < 0) { - lderr(store->ctx()) << "ERROR: failed writing data log" << dendl; - return r; - } - } - - return 0; -} - - /// search for a matching zone/zonegroup id and return a connection if found static boost::optional get_remote_conn(rgw::sal::RGWRadosStore *store, const RGWZoneGroup& zonegroup, diff --git a/src/rgw/rgw_bucket.cc b/src/rgw/rgw_bucket.cc index f97275399a7..9f226b2b54d 100644 --- a/src/rgw/rgw_bucket.cc +++ b/src/rgw/rgw_bucket.cc @@ -599,7 +599,7 @@ int RGWBucket::init(RGWRadosStore *storage, RGWBucketAdminOpState& op_state, if (bucket.name.empty() && user_id.empty()) return -EINVAL; - + // split possible tenant/name auto pos = bucket.name.find('/'); if (pos != string::npos) { diff --git a/src/rgw/rgw_rest_bucket.cc b/src/rgw/rgw_rest_bucket.cc index f5526a71f04..25c9ced27f0 100644 --- a/src/rgw/rgw_rest_bucket.cc +++ b/src/rgw/rgw_rest_bucket.cc @@ -301,7 +301,7 @@ public: void execute() override; const char* name() const override { return "sync_bucket"; } -} +}; void RGWOp_Sync_Bucket::execute() {