From: Greg Farnum Date: Wed, 28 Sep 2011 21:26:17 +0000 (-0700) Subject: rgw: remove get_bucket_info and convert users. X-Git-Tag: v0.37~103^2~14 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=47e5958f68e07959ed82218ab23f21aa288a9b7b;p=ceph.git rgw: remove get_bucket_info and convert users. This just lives in struct rgw_bucket now. Signed-off-by: Greg Farnum --- diff --git a/src/rgw/rgw_access.h b/src/rgw/rgw_access.h index 632b9da9cf12..ee219228cbf9 100644 --- a/src/rgw/rgw_access.h +++ b/src/rgw/rgw_access.h @@ -221,8 +221,6 @@ public: */ virtual int set_attr(void *ctx, rgw_obj& obj, const char *name, bufferlist& bl) = 0; - virtual int get_bucket_id(rgw_bucket& bucket, uint64_t *bucket_id) { return -ENOTSUP; } - /** * stat an object */ diff --git a/src/rgw/rgw_admin.cc b/src/rgw/rgw_admin.cc index 7112be1f2831..718dbed8bd39 100644 --- a/src/rgw/rgw_admin.cc +++ b/src/rgw/rgw_admin.cc @@ -1223,15 +1223,9 @@ int main(int argc, char **argv) info.bucket = bucket; info.owner = policy.get_owner().get_id(); - uint64_t bucket_id; - ret = rgwstore->get_bucket_id(bucket, &bucket_id); + ret = rgw_store_bucket_info_id(bucket.bucket_id, info); if (ret < 0) { - RGW_LOG(0) << "get_bucket_id returned " << ret << dendl; - return ret; - } - ret = rgw_store_bucket_info_id(bucket_id, info); - if (ret < 0) { - RGW_LOG(0) << "can't store pool info: bucket_id=" << bucket_id << " ret=" << ret << dendl; + RGW_LOG(0) << "can't store pool info: bucket_id=" << bucket.bucket_id << " ret=" << ret << dendl; return ret; } } diff --git a/src/rgw/rgw_op.cc b/src/rgw/rgw_op.cc index 1faa4d326ba1..c13078f96c97 100644 --- a/src/rgw/rgw_op.cc +++ b/src/rgw/rgw_op.cc @@ -444,7 +444,6 @@ void RGWCreateBucket::execute() bufferlist aclbl; bool existed; bool pol_ret; - uint64_t bucket_id; RGWBucketInfo info; rgw_obj obj(rgw_root_bucket, s->bucket_name_str); @@ -487,13 +486,9 @@ void RGWCreateBucket::execute() if (ret == -EEXIST) ret = 0; - ret = rgwstore->get_bucket_id(s->bucket, &bucket_id); - if (ret < 0) - goto done; - info.owner = s->user.user_id; info.bucket = s->bucket; - rgw_store_bucket_info_id(bucket_id, info); + rgw_store_bucket_info_id(info.bucket.bucket_id, info); done: send_response(); diff --git a/src/rgw/rgw_rados.cc b/src/rgw/rgw_rados.cc index 6cd8f64a52f2..8ae1c8252da3 100644 --- a/src/rgw/rgw_rados.cc +++ b/src/rgw/rgw_rados.cc @@ -1562,19 +1562,6 @@ int RGWRados::obj_stat(void *ctx, rgw_obj& obj, uint64_t *psize, time_t *pmtime) return r; } -int RGWRados::get_bucket_id(rgw_bucket& bucket, uint64_t *bucket_id) -{ - librados::IoCtx io_ctx; - int r = open_bucket_ctx(bucket, io_ctx); - if (r == -ENOENT) - r = -ERR_NO_SUCH_BUCKET; - if (r < 0) - return r; - - *bucket_id = io_ctx.get_id(); - return 0; -} - int RGWRados::get_bucket_stats(rgw_bucket& bucket, map& stats) { rgw_bucket_dir_header header; diff --git a/src/rgw/rgw_rados.h b/src/rgw/rgw_rados.h index 3d01208145fb..ff9dc58b0917 100644 --- a/src/rgw/rgw_rados.h +++ b/src/rgw/rgw_rados.h @@ -244,8 +244,6 @@ public: virtual int obj_stat(void *ctx, rgw_obj& obj, uint64_t *psize, time_t *pmtime); - virtual int get_bucket_id(rgw_bucket& bucket, uint64_t *bucket_id); - virtual bool supports_tmap() { return true; } virtual int tmap_get(rgw_obj& obj, bufferlist& header, std::map& m); virtual int tmap_set(rgw_obj& obj, std::string& key, bufferlist& bl);