From: Radoslaw Zarzynski Date: Sun, 20 Nov 2016 20:49:57 +0000 (+0100) Subject: rgw: seed::get_torrent_file returns errors in the usual way. X-Git-Tag: v12.2.2~150^2~2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=71e37b1a10796ddfe786a2d389b0497ce1dc1bf4;p=ceph.git rgw: seed::get_torrent_file returns errors in the usual way. Signed-off-by: Radoslaw Zarzynski (cherry picked from commit 21ad80a1c237f8d243efaacd8218b29719a0a6b0) --- diff --git a/src/rgw/rgw_op.cc b/src/rgw/rgw_op.cc index cd2e4d682fe1..e7fcecec7a7c 100644 --- a/src/rgw/rgw_op.cc +++ b/src/rgw/rgw_op.cc @@ -1639,7 +1639,7 @@ void RGWGetObj::execute() if (torrent.get_flag()) { torrent.init(s, store); - torrent.get_torrent_file(op_ret, read_op, total_len, bl, obj); + op_ret = torrent.get_torrent_file(read_op, total_len, bl, obj); if (op_ret < 0) { ldout(s->cct, 0) << "ERROR: failed to get_torrent_file ret= " << op_ret diff --git a/src/rgw/rgw_torrent.cc b/src/rgw/rgw_torrent.cc index c1f8aaac0bd0..ad85148b3308 100644 --- a/src/rgw/rgw_torrent.cc +++ b/src/rgw/rgw_torrent.cc @@ -37,8 +37,10 @@ void seed::init(struct req_state *p_req, RGWRados *p_store) store = p_store; } -void seed::get_torrent_file(int &op_ret, RGWRados::Object::Read &read_op, uint64_t &total_len, - bufferlist &bl_data, rgw_obj &obj) +int seed::get_torrent_file(RGWRados::Object::Read &read_op, + uint64_t &total_len, + ceph::bufferlist &bl_data, + rgw_obj &obj) { /* add other field if config is set */ dencode.bencode_dict(bl); @@ -63,11 +65,12 @@ void seed::get_torrent_file(int &op_ret, RGWRados::Object::Read &read_op, uint64 ldout(s->cct, 0) << "NOTICE: head obj oid= " << oid << dendl; obj_key.insert(RGW_OBJ_TORRENT); - op_ret = read_op.state.io_ctx.omap_get_vals_by_keys(oid, obj_key, &m); + const int op_ret = read_op.state.io_ctx.omap_get_vals_by_keys(oid, obj_key, &m); if (op_ret < 0) { - ldout(s->cct, 0) << "ERROR: failed to omap_get_vals_by_keys op_ret = " << op_ret << dendl; - return; + ldout(s->cct, 0) << "ERROR: failed to omap_get_vals_by_keys op_ret = " + << op_ret << dendl; + return op_ret; } map::iterator iter; @@ -81,7 +84,7 @@ void seed::get_torrent_file(int &op_ret, RGWRados::Object::Read &read_op, uint64 bl_data = bl; total_len = bl.length(); - return; + return 0; } bool seed::get_flag() diff --git a/src/rgw/rgw_torrent.h b/src/rgw/rgw_torrent.h index b33aac09b74c..fd6a0d6ed588 100644 --- a/src/rgw/rgw_torrent.h +++ b/src/rgw/rgw_torrent.h @@ -115,8 +115,10 @@ public: int get_params(); void init(struct req_state *p_req, RGWRados *p_store); - void get_torrent_file(int &op_ret, RGWRados::Object::Read &read_op, - uint64_t &total_len, bufferlist &bl_data, rgw_obj &obj); + int get_torrent_file(RGWRados::Object::Read &read_op, + uint64_t &total_len, + ceph::bufferlist &bl_data, + rgw_obj &obj); off_t get_data_len(); bool get_flag();