utime_t trim_time = get_time(start_time, i, true);
utime_t zero_time;
+ string start_marker, end_marker;
- ASSERT_EQ(0, cls_log_trim(ioctx, oid, zero_time, trim_time));
+ ASSERT_EQ(0, cls_log_trim(ioctx, oid, zero_time, trim_time, start_marker, end_marker));
string marker;
void index_prepare(OpMgr& mgr, librados::IoCtx& ioctx, string& oid, RGWModifyOp index_op, string& tag, string& obj, string& loc)
{
ObjectWriteOperation *op = mgr.write_op();
- cls_rgw_bucket_prepare_op(*op, index_op, tag, obj, loc);
+ cls_rgw_bucket_prepare_op(*op, index_op, tag, obj, loc, true);
ASSERT_EQ(0, ioctx.operate(oid, op));
}
rgw_bucket_entry_ver ver;
ver.pool = ioctx.get_id();
ver.epoch = epoch;
- cls_rgw_bucket_complete_op(*op, index_op, tag, ver, obj, meta, NULL);
+ cls_rgw_bucket_complete_op(*op, index_op, tag, ver, obj, meta, NULL, true);
ASSERT_EQ(0, ioctx.operate(oid, op));
}