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
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);
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<string, bufferlist>::iterator iter;
bl_data = bl;
total_len = bl.length();
- return;
+ return 0;
}
bool seed::get_flag()
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();