static int write_entry(cls_method_context_t hctx, const string& key, const cls_user_bucket_entry& entry)
{
bufferlist bl;
- ::encode(entry, bl);
+ encode(entry, bl);
int ret = cls_cxx_map_set_val(hctx, key, &bl);
if (ret < 0)
return rc;
}
try {
- bufferlist::iterator iter = bl.begin();
- ::decode(entry, iter);
+ auto iter = bl.cbegin();
+ decode(entry, iter);
} catch (buffer::error& err) {
CLS_LOG(0, "ERROR: failed to decode entry %s", key.c_str());
return -EIO;
}
try {
- ::decode(*header, bl);
+ decode(*header, bl);
} catch (buffer::error& err) {
CLS_LOG(0, "ERROR: failed to decode user header");
return -EIO;
static int cls_user_set_buckets_info(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
- bufferlist::iterator in_iter = in->begin();
+ auto in_iter = in->cbegin();
cls_user_set_buckets_op op;
try {
- ::decode(op, in_iter);
+ decode(op, in_iter);
} catch (buffer::error& err) {
CLS_LOG(1, "ERROR: cls_user_add_op(): failed to decode op");
return -EINVAL;
if (header.last_stats_update < op.time)
header.last_stats_update = op.time;
- ::encode(header, bl);
+ encode(header, bl);
ret = cls_cxx_map_write_header(hctx, &bl);
if (ret < 0)
static int cls_user_complete_stats_sync(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
- bufferlist::iterator in_iter = in->begin();
+ auto in_iter = in->cbegin();
cls_user_complete_stats_sync_op op;
try {
- ::decode(op, in_iter);
+ decode(op, in_iter);
} catch (buffer::error& err) {
CLS_LOG(1, "ERROR: cls_user_add_op(): failed to decode op");
return -EINVAL;
bufferlist bl;
- ::encode(header, bl);
+ encode(header, bl);
ret = cls_cxx_map_write_header(hctx, &bl);
if (ret < 0)
static int cls_user_remove_bucket(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
- bufferlist::iterator in_iter = in->begin();
+ auto in_iter = in->cbegin();
cls_user_remove_bucket_op op;
try {
- ::decode(op, in_iter);
+ decode(op, in_iter);
} catch (buffer::error& err) {
CLS_LOG(1, "ERROR: cls_user_add_op(): failed to decode op");
return -EINVAL;
static int cls_user_list_buckets(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
- bufferlist::iterator in_iter = in->begin();
+ auto in_iter = in->cbegin();
cls_user_list_buckets_op op;
try {
- ::decode(op, in_iter);
+ decode(op, in_iter);
} catch (buffer::error& err) {
CLS_LOG(1, "ERROR: cls_user_list_op(): failed to decode op");
return -EINVAL;
}
bufferlist& bl = iter->second;
- bufferlist::iterator biter = bl.begin();
+ auto biter = bl.cbegin();
try {
cls_user_bucket_entry e;
- ::decode(e, biter);
+ decode(e, biter);
entries.push_back(e);
} catch (buffer::error& err) {
CLS_LOG(0, "ERROR: cls_user_list: could not decode entry, index=%s", index.c_str());
ret.marker = marker;
}
- ::encode(ret, *out);
+ encode(ret, *out);
return 0;
}
static int cls_user_get_header(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
- bufferlist::iterator in_iter = in->begin();
+ auto in_iter = in->cbegin();
cls_user_get_header_op op;
try {
- ::decode(op, in_iter);
+ decode(op, in_iter);
} catch (buffer::error& err) {
CLS_LOG(1, "ERROR: cls_user_get_header_op(): failed to decode op");
return -EINVAL;
if (ret < 0)
return ret;
- ::encode(op_ret, *out);
+ encode(op_ret, *out);
return 0;
}
cls_user_reset_stats_op op;
try {
- auto bliter = in->begin();
- ::decode(op, bliter);
+ auto bliter = in->cbegin();
+ decode(op, bliter);
} catch (buffer::error& err) {
CLS_LOG(0, "ERROR: cls_user_reset_op(): failed to decode op");
return -EINVAL;
cls_user_bucket_entry e;
try {
auto bl = kv.second;
- auto bliter = bl.begin();
+ auto bliter = bl.cbegin();
decode(e, bliter);
} catch (buffer::error& err) {
CLS_LOG(0, "ERROR: failed to decode bucket entry for %s", kv.first.c_str());
bufferlist bl;
header.last_stats_update = op.time;
- ::encode(header, bl);
+ encode(header, bl);
return cls_cxx_map_write_header(hctx, &bl);
}