Environment(): tenant("default_ns"), db(nullptr),
db_type("SQLite"), ret(-1) {}
- Environment(string tenantname, string db_typename):
+ Environment(string tenantname, string db_typename):
tenant(tenantname), db(nullptr),
db_type(db_typename), ret(-1) {}
RGWAccessKey k2("id2", "key2");
params.op.user.uinfo.access_keys["id1"] = k1;
params.op.user.uinfo.access_keys["id2"] = k2;
- params.op.user.user_version.ver = 1;
- params.op.user.user_version.tag = "UserTAG";
+ params.op.user.user_version.ver = 1;
+ params.op.user.user_version.tag = "UserTAG";
ret = db->ProcessOp(dpp, "InsertUser", ¶ms);
ASSERT_EQ(ret, 0);
TEST_F(DBStoreTest, ListBucketObjects) {
struct DBOpParams params = GlobalParams;
int ret = -1;
-
+
int max = 2;
bool is_truncated = false;
rgw_obj_key marker1;
true, &s);
ASSERT_EQ(ret, -ENOENT);
- /* Delete delete marker..should be able to read object now */
+ /* Delete delete marker..should be able to read object now */
params.op.obj.state.obj.key.instance = dm_instance;
DB::Object op_target3(db, params.op.bucket.info, params.op.obj.state.obj);
DB::Object::Delete delete_op2(&op_target3);
ASSERT_EQ(ret, 0);
// get entry index1, entry1
- ret = db->get_entry(index1, ents[0], entry);
+ ret = db->get_entry(index1, ents[0], entry);
ASSERT_EQ(ret, 0);
ASSERT_EQ(entry.status, lc_uninitial);
ASSERT_EQ(entry.start_time, lc_time);
// get next entry index1, entry2
- ret = db->get_next_entry(index1, ents[1], entry);
+ ret = db->get_next_entry(index1, ents[1], entry);
ASSERT_EQ(ret, 0);
ASSERT_EQ(entry.bucket, ents[2]);
ASSERT_EQ(entry.status, lc_uninitial);
entry4.status = lc_complete;
ret = db->set_entry(index2, entry4);
ASSERT_EQ(ret, 0);
- ret = db->get_entry(index2, ents[3], entry);
+ ret = db->get_entry(index2, ents[3], entry);
ASSERT_EQ(ret, 0);
ASSERT_EQ(entry.status, lc_complete);
}
// remove index1, entry3
- ret = db->rm_entry(index1, entry3);
+ ret = db->rm_entry(index1, entry3);
ASSERT_EQ(ret, 0);
// get next entry index1, entry2.. should be empty
params.op.user.uinfo.user_email = "tester@ceph.com";
RGWAccessKey k1("0555b35654ad1656d804", "h7GhxuBLTrlhVUyxSPUKUV8r/2EI4ngqJxD7iBdBYLhwluN30JaT3Q==");
params.op.user.uinfo.access_keys["0555b35654ad1656d804"] = k1;
- params.op.user.user_version.ver = 1;
- params.op.user.user_version.tag = "UserTAG";
+ params.op.user.user_version.ver = 1;
+ params.op.user.user_version.tag = "UserTAG";
ret = db->ProcessOp(dpp, "InsertUser", ¶ms);
ASSERT_EQ(ret, 0);