From 9d6de8484b53d5b68edc75b4e07d851428e45875 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Fri, 18 Mar 2016 12:21:32 -0700 Subject: [PATCH] store_test: apply an appended transaction half the time Signed-off-by: Samuel Just --- src/test/objectstore/store_test.cc | 336 +++++++++++++++-------------- 1 file changed, 175 insertions(+), 161 deletions(-) diff --git a/src/test/objectstore/store_test.cc b/src/test/objectstore/store_test.cc index 79c6b3f51f26..4d88561a1a4a 100644 --- a/src/test/objectstore/store_test.cc +++ b/src/test/objectstore/store_test.cc @@ -37,6 +37,20 @@ typedef boost::mt11213b gen_type; #if GTEST_HAS_PARAM_TEST +template +int apply_transaction( + T &store, + ObjectStore::Sequencer *osr, + ObjectStore::Transaction &&t) { + if (rand() % 2) { + ObjectStore::Transaction t2; + t2.append(t); + return store->apply_transaction(osr, std::move(t2)); + } else { + return store->apply_transaction(osr, std::move(t)); + } +} + class StoreTest : public ::testing::TestWithParam { public: boost::scoped_ptr store; @@ -129,7 +143,7 @@ TEST_P(StoreTest, SimpleRemount) { ObjectStore::Transaction t; t.create_collection(cid, 0); t.write(cid, hoid, 0, bl.length(), bl); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } store->umount(); @@ -138,7 +152,7 @@ TEST_P(StoreTest, SimpleRemount) { { ObjectStore::Transaction t; t.write(cid, hoid2, 0, bl.length(), bl); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -147,7 +161,7 @@ TEST_P(StoreTest, SimpleRemount) { t.remove(cid, hoid2); t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } store->umount(); @@ -156,7 +170,7 @@ TEST_P(StoreTest, SimpleRemount) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bool exists = store->exists(cid, hoid); ASSERT_TRUE(!exists); @@ -165,7 +179,7 @@ TEST_P(StoreTest, SimpleRemount) { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -184,7 +198,7 @@ TEST_P(StoreTest, IORemount) { ghobject_t hoid(hobject_t(sobject_t("Object " + stringify(n), CEPH_NOSNAP))); t.write(cid, hoid, 0, bl.length(), bl); } - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // overwrites @@ -194,7 +208,7 @@ TEST_P(StoreTest, IORemount) { ObjectStore::Transaction t; ghobject_t hoid(hobject_t(sobject_t("Object " + stringify(n), CEPH_NOSNAP))); t.write(cid, hoid, 1, bl.length(), bl); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -208,7 +222,7 @@ TEST_P(StoreTest, IORemount) { t.remove(cid, hoid); } t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -223,7 +237,7 @@ TEST_P(StoreTest, FiemapEmpty) { t.create_collection(cid, 0); t.touch(cid, oid); t.truncate(cid, oid, 100000); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -241,7 +255,7 @@ TEST_P(StoreTest, FiemapEmpty) { t.remove(cid, oid); t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -260,7 +274,7 @@ TEST_P(StoreTest, FiemapHoles) { t.write(cid, oid, 0, 3, bl); t.write(cid, oid, 1048576, 3, bl); t.write(cid, oid, 4194304, 3, bl); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -284,7 +298,7 @@ TEST_P(StoreTest, FiemapHoles) { t.remove(cid, oid); t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -297,28 +311,28 @@ TEST_P(StoreTest, SimpleMetaColTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "create collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "add collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -331,28 +345,28 @@ TEST_P(StoreTest, SimplePGColTest) { ObjectStore::Transaction t; t.create_collection(cid, 4); cerr << "create collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.create_collection(cid, 4); cerr << "add collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -390,7 +404,7 @@ TEST_P(StoreTest, SimpleColPreHashTest) { ::encode(expected_num_objs, hint); t.collection_hint(cid, ObjectStore::Transaction::COLL_HINT_EXPECTED_NUM_OBJECTS, hint); cerr << "collection hint" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -398,7 +412,7 @@ TEST_P(StoreTest, SimpleColPreHashTest) { ObjectStore::Transaction t; t.remove_collection(cid); cerr << "remove collection" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // Revert the config change so that it does not affect the split/merge tests @@ -423,7 +437,7 @@ TEST_P(StoreTest, SimpleObjectTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -433,7 +447,7 @@ TEST_P(StoreTest, SimpleObjectTest) { ObjectStore::Transaction t; t.touch(cid, hoid); cerr << "Creating object " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); exists = store->exists(cid, hoid); @@ -444,7 +458,7 @@ TEST_P(StoreTest, SimpleObjectTest) { t.remove(cid, hoid); t.touch(cid, hoid); cerr << "Remove then create" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -455,7 +469,7 @@ TEST_P(StoreTest, SimpleObjectTest) { t.remove(cid, hoid); t.write(cid, hoid, 0, 5, bl); cerr << "Remove then create" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist in; @@ -471,7 +485,7 @@ TEST_P(StoreTest, SimpleObjectTest) { exp.append(bl); t.write(cid, hoid, 5, 5, bl); cerr << "Append" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist in; @@ -486,7 +500,7 @@ TEST_P(StoreTest, SimpleObjectTest) { exp = bl; t.write(cid, hoid, 0, 10, bl); cerr << "Full overwrite" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist in; @@ -500,7 +514,7 @@ TEST_P(StoreTest, SimpleObjectTest) { bl.append("abcde"); t.write(cid, hoid, 3, 5, bl); cerr << "Partial overwrite" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist in, exp; @@ -516,7 +530,7 @@ TEST_P(StoreTest, SimpleObjectTest) { bl.append("abcde01234012340123401234abcde01234012340123401234abcde01234012340123401234abcde01234012340123401234"); t.write(cid, hoid, 0, bl.length(), bl); cerr << "larger overwrite" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist in; @@ -541,7 +555,7 @@ TEST_P(StoreTest, SimpleObjectTest) { t.remove(cid, hoid); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -556,7 +570,7 @@ TEST_P(StoreTest, ManySmallWrite) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } bufferlist bl; @@ -566,13 +580,13 @@ TEST_P(StoreTest, ManySmallWrite) { for (int i=0; i<100; ++i) { ObjectStore::Transaction t; t.write(cid, a, i*4096, 4096, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } for (int i=0; i<100; ++i) { ObjectStore::Transaction t; t.write(cid, b, (rand() % 1024)*4096, 4096, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -581,7 +595,7 @@ TEST_P(StoreTest, ManySmallWrite) { t.remove(cid, b); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -595,14 +609,14 @@ TEST_P(StoreTest, SmallSkipFront) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.touch(cid, a); t.truncate(cid, a, 3000); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -612,7 +626,7 @@ TEST_P(StoreTest, SmallSkipFront) { bl.append(bp); ObjectStore::Transaction t; t.write(cid, a, 4096, 4096, bl); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -628,7 +642,7 @@ TEST_P(StoreTest, SmallSkipFront) { t.remove(cid, a); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -642,7 +656,7 @@ TEST_P(StoreTest, SmallSequentialUnaligned) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } bufferlist bl; @@ -653,7 +667,7 @@ TEST_P(StoreTest, SmallSequentialUnaligned) { for (int i=0; i<1000; ++i) { ObjectStore::Transaction t; t.write(cid, a, i*len, len, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -661,7 +675,7 @@ TEST_P(StoreTest, SmallSequentialUnaligned) { t.remove(cid, a); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -676,7 +690,7 @@ TEST_P(StoreTest, ManyBigWrite) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } bufferlist bl; @@ -686,28 +700,28 @@ TEST_P(StoreTest, ManyBigWrite) { for (int i=0; i<10; ++i) { ObjectStore::Transaction t; t.write(cid, a, i*4*1048586, 4*1048576, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // aligned for (int i=0; i<10; ++i) { ObjectStore::Transaction t; t.write(cid, b, (rand() % 256)*4*1048576, 4*1048576, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // unaligned for (int i=0; i<10; ++i) { ObjectStore::Transaction t; t.write(cid, b, (rand() % (256*4096))*1024, 4*1048576, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // do some zeros for (int i=0; i<10; ++i) { ObjectStore::Transaction t; t.zero(cid, b, (rand() % (256*4096))*1024, 16*1048576); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -716,7 +730,7 @@ TEST_P(StoreTest, ManyBigWrite) { t.remove(cid, b); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -730,7 +744,7 @@ TEST_P(StoreTest, MiscFragmentTests) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } bufferlist bl; @@ -740,13 +754,13 @@ TEST_P(StoreTest, MiscFragmentTests) { { ObjectStore::Transaction t; t.write(cid, a, 0, 524288, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.write(cid, a, 1048576, 524288, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -759,7 +773,7 @@ TEST_P(StoreTest, MiscFragmentTests) { { ObjectStore::Transaction t; t.write(cid, a, 1048576 - 4096, 524288, bl, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -767,7 +781,7 @@ TEST_P(StoreTest, MiscFragmentTests) { t.remove(cid, a); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -792,7 +806,7 @@ TEST_P(StoreTest, SimpleAttrTest) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -809,7 +823,7 @@ TEST_P(StoreTest, SimpleAttrTest) { t.touch(cid, hoid); t.setattr(cid, hoid, "foo", val); t.setattr(cid, hoid, "bar", val2); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -836,7 +850,7 @@ TEST_P(StoreTest, SimpleAttrTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -849,7 +863,7 @@ TEST_P(StoreTest, SimpleListTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } set all; @@ -865,7 +879,7 @@ TEST_P(StoreTest, SimpleListTest) { t.touch(cid, hoid); cerr << "Creating object " << hoid << std::endl; } - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } for (int bitwise=0; bitwise<2; ++bitwise) { @@ -904,7 +918,7 @@ TEST_P(StoreTest, SimpleListTest) { t.remove(cid, *p); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -946,7 +960,7 @@ TEST_P(StoreTest, MultipoolListTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } set all, saw; @@ -964,7 +978,7 @@ TEST_P(StoreTest, MultipoolListTest) { t.touch(cid, hoid); cerr << "Creating object " << hoid << std::endl; } - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -991,7 +1005,7 @@ TEST_P(StoreTest, MultipoolListTest) { t.remove(cid, *p); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1004,7 +1018,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid(hobject_t(sobject_t("Object 1", CEPH_NOSNAP), @@ -1022,7 +1036,7 @@ TEST_P(StoreTest, SimpleCloneTest) { t.write(cid, hoid, 0, small.length(), small); t.write(cid, hoid, 10, small.length(), small); cerr << "Creating object and set attr " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid2(hobject_t(sobject_t("Object 2", CEPH_NOSNAP), @@ -1036,7 +1050,7 @@ TEST_P(StoreTest, SimpleCloneTest) { t.setattr(cid, hoid, "attr1", large); t.setattr(cid, hoid, "attr2", small); cerr << "Clone object and rm attr" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); r = store->read(cid, hoid, 10, 5, newdata); @@ -1071,7 +1085,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferlist final; @@ -1089,7 +1103,7 @@ TEST_P(StoreTest, SimpleCloneTest) { al.append(a); final.append(a); t.write(cid, hoid, pl.length(), a.length(), al); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist rl; ASSERT_EQ((int)final.length(), @@ -1100,7 +1114,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferlist final; @@ -1121,7 +1135,7 @@ TEST_P(StoreTest, SimpleCloneTest) { al.append(a); final.append(a); t.write(cid, hoid, pl.length() + z.length(), a.length(), al); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); bufferlist rl; ASSERT_EQ((int)final.length(), @@ -1132,7 +1146,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferlist final; @@ -1153,7 +1167,7 @@ TEST_P(StoreTest, SimpleCloneTest) { al.append(a); final.append(a); t.write(cid, hoid, 17000, a.length(), al); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); bufferlist rl; ASSERT_EQ((int)final.length(), store->read(cid, hoid, 0, final.length(), rl)); @@ -1167,7 +1181,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferptr p(1048576); @@ -1182,7 +1196,7 @@ TEST_P(StoreTest, SimpleCloneTest) { bufferlist al; al.append(a); t.write(cid, hoid, a.length(), a.length(), al); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); bufferlist rl; bufferlist final; final.substr_of(pl, 0, al.length()); @@ -1202,7 +1216,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferptr p(65536); @@ -1217,7 +1231,7 @@ TEST_P(StoreTest, SimpleCloneTest) { bufferlist al; al.append(a); t.write(cid, hoid, 32768, a.length(), al); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); bufferlist rl; bufferlist final; final.substr_of(pl, 0, 32768); @@ -1237,7 +1251,7 @@ TEST_P(StoreTest, SimpleCloneTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove(cid, hoid2); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); } { bufferptr p(65536); @@ -1252,7 +1266,7 @@ TEST_P(StoreTest, SimpleCloneTest) { bufferlist al; al.append(a); t.write(cid, hoid, 33768, a.length(), al); - ASSERT_EQ(0u, store->apply_transaction(&osr, std::move(t))); + ASSERT_EQ(0u, apply_transaction(store, &osr, std::move(t))); bufferlist rl; bufferlist final; final.substr_of(pl, 0, 33768); @@ -1274,7 +1288,7 @@ TEST_P(StoreTest, SimpleCloneTest) { t.remove(cid, hoid2); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1287,7 +1301,7 @@ TEST_P(StoreTest, OmapSimple) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid(hobject_t(sobject_t("omap_obj", CEPH_NOSNAP), @@ -1305,7 +1319,7 @@ TEST_P(StoreTest, OmapSimple) { t.omap_setkeys(cid, hoid, km); t.omap_setheader(cid, hoid, header); cerr << "Creating object and set omap " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } // get header, keys @@ -1342,7 +1356,7 @@ TEST_P(StoreTest, OmapSimple) { t.remove(cid, hoid); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1355,7 +1369,7 @@ TEST_P(StoreTest, OmapCloneTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid(hobject_t(sobject_t("Object 1", CEPH_NOSNAP), @@ -1373,7 +1387,7 @@ TEST_P(StoreTest, OmapCloneTest) { t.omap_setkeys(cid, hoid, km); t.omap_setheader(cid, hoid, header); cerr << "Creating object and set omap " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid2(hobject_t(sobject_t("Object 2", CEPH_NOSNAP), @@ -1382,7 +1396,7 @@ TEST_P(StoreTest, OmapCloneTest) { ObjectStore::Transaction t; t.clone(cid, hoid, hoid2); cerr << "Clone object" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -1398,7 +1412,7 @@ TEST_P(StoreTest, OmapCloneTest) { t.remove(cid, hoid2); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1411,7 +1425,7 @@ TEST_P(StoreTest, SimpleCloneRangeTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid(hobject_t(sobject_t("Object 1", CEPH_NOSNAP))); @@ -1422,7 +1436,7 @@ TEST_P(StoreTest, SimpleCloneRangeTest) { ObjectStore::Transaction t; t.write(cid, hoid, 10, 5, small); cerr << "Creating object and write bl " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid2(hobject_t(sobject_t("Object 2", CEPH_NOSNAP))); @@ -1431,7 +1445,7 @@ TEST_P(StoreTest, SimpleCloneRangeTest) { ObjectStore::Transaction t; t.clone_range(cid, hoid, hoid2, 10, 5, 0); cerr << "Clone range object" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); r = store->read(cid, hoid2, 0, 5, newdata); ASSERT_EQ(r, 5); @@ -1442,7 +1456,7 @@ TEST_P(StoreTest, SimpleCloneRangeTest) { t.truncate(cid, hoid, 1024*1024); t.clone_range(cid, hoid, hoid2, 0, 1024*1024, 0); cerr << "Clone range object" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); struct stat stat, stat2; r = store->stat(cid, hoid, &stat); @@ -1456,7 +1470,7 @@ TEST_P(StoreTest, SimpleCloneRangeTest) { t.remove(cid, hoid2); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1470,7 +1484,7 @@ TEST_P(StoreTest, SimpleObjectLongnameTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ghobject_t hoid(hobject_t(sobject_t("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaObjectaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa 1", CEPH_NOSNAP))); @@ -1478,7 +1492,7 @@ TEST_P(StoreTest, SimpleObjectLongnameTest) { ObjectStore::Transaction t; t.touch(cid, hoid); cerr << "Creating object " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -1486,7 +1500,7 @@ TEST_P(StoreTest, SimpleObjectLongnameTest) { t.remove(cid, hoid); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1509,7 +1523,7 @@ TEST_P(StoreTest, LongnameSplitTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); cerr << "Creating collection " << cid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } for (unsigned i = 0; i < 320; ++i) { @@ -1517,7 +1531,7 @@ TEST_P(StoreTest, LongnameSplitTest) { ghobject_t hoid = generate_long_name(i); t.touch(cid, hoid); cerr << "Creating object " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); } ghobject_t test_obj = generate_long_name(319); @@ -1529,7 +1543,7 @@ TEST_P(StoreTest, LongnameSplitTest) { t.collection_move_rename( cid, test_obj, cid, test_obj_2); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); } for (unsigned i = 0; i < 319; ++i) { @@ -1537,14 +1551,14 @@ TEST_P(StoreTest, LongnameSplitTest) { ghobject_t hoid = generate_long_name(i); t.remove(cid, hoid); cerr << "Removing object " << hoid << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); } { ObjectStore::Transaction t; t.remove(cid, test_obj_2); t.remove_collection(cid); cerr << "Cleaning" << std::endl; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -1561,7 +1575,7 @@ TEST_P(StoreTest, ManyObjectTest) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } for (int i = 0; i < NUM_OBJS; ++i) { @@ -1574,7 +1588,7 @@ TEST_P(StoreTest, ManyObjectTest) { ghobject_t hoid(hobject_t(sobject_t(string(buf) + base, CEPH_NOSNAP))); t.touch(cid, hoid); created.insert(hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -1664,14 +1678,14 @@ TEST_P(StoreTest, ManyObjectTest) { ++i) { ObjectStore::Transaction t; t.remove(cid, *i); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } cerr << "cleaning up" << std::endl; { ObjectStore::Transaction t; t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -1880,7 +1894,7 @@ public: int init() { ObjectStore::Transaction t; t.create_collection(cid, 0); - return store->apply_transaction(osr, std::move(t)); + return apply_transaction(store, osr, std::move(t)); } void shutdown() { while (1) { @@ -1895,11 +1909,11 @@ public: p != objects.end(); ++p) { t.remove(cid, *p); } - store->apply_transaction(osr, std::move(t)); + apply_transaction(store, osr, std::move(t)); } ObjectStore::Transaction t; t.remove_collection(cid); - store->apply_transaction(osr, std::move(t)); + apply_transaction(store, osr, std::move(t)); } ghobject_t get_uniform_random_object() { @@ -2534,7 +2548,7 @@ TEST_P(StoreTest, HashCollisionTest) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } string base = ""; @@ -2553,7 +2567,7 @@ TEST_P(StoreTest, HashCollisionTest) { { ObjectStore::Transaction t; t.touch(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } created.insert(hoid); @@ -2600,12 +2614,12 @@ TEST_P(StoreTest, HashCollisionTest) { ++i) { ObjectStore::Transaction t; t.remove(cid, *i); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ObjectStore::Transaction t; t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -2617,7 +2631,7 @@ TEST_P(StoreTest, ScrubTest) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } string base = "aaaaa"; @@ -2634,7 +2648,7 @@ TEST_P(StoreTest, ScrubTest) { { ObjectStore::Transaction t; t.touch(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } created.insert(hoid); @@ -2650,7 +2664,7 @@ TEST_P(StoreTest, ScrubTest) { t.touch(cid, hoid1); t.touch(cid, hoid2); t.touch(cid, hoid3); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); created.insert(hoid1); created.insert(hoid2); created.insert(hoid3); @@ -2698,12 +2712,12 @@ TEST_P(StoreTest, ScrubTest) { ++i) { ObjectStore::Transaction t; t.remove(cid, *i); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ObjectStore::Transaction t; t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -2716,7 +2730,7 @@ TEST_P(StoreTest, OMapTest) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -2727,7 +2741,7 @@ TEST_P(StoreTest, OMapTest) { t.omap_clear(cid, hoid); map start_set; t.omap_setkeys(cid, hoid, start_set); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } for (int i = 0; i < 100; i++) { @@ -2762,7 +2776,7 @@ TEST_P(StoreTest, OMapTest) { to_add.insert(pair("key-" + string(buf), bl)); attrs.insert(pair("key-" + string(buf), bl)); t.omap_setkeys(cid, hoid, to_add); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } int i = 0; @@ -2792,7 +2806,7 @@ TEST_P(StoreTest, OMapTest) { set keys_to_remove; keys_to_remove.insert(to_remove); t.omap_rmkeys(cid, hoid, keys_to_remove); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); attrs.erase(to_remove); @@ -2804,7 +2818,7 @@ TEST_P(StoreTest, OMapTest) { bl1.append("omap_header"); ObjectStore::Transaction t; t.omap_setheader(cid, hoid, bl1); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); t = ObjectStore::Transaction(); bufferlist bl2; @@ -2812,7 +2826,7 @@ TEST_P(StoreTest, OMapTest) { map to_add; to_add.insert(pair("key", bl2)); t.omap_setkeys(cid, hoid, to_add); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); bufferlist bl3; map cur_attrs; @@ -2841,12 +2855,12 @@ TEST_P(StoreTest, OMapTest) { t.touch(cid, hoid); t.omap_setheader(cid, hoid, h); t.omap_setkeys(cid, hoid, to_set); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } { ObjectStore::Transaction t; t.omap_rmkeyrange(cid, hoid, "3", "7"); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } { bufferlist hdr; @@ -2864,7 +2878,7 @@ TEST_P(StoreTest, OMapTest) { { ObjectStore::Transaction t; t.omap_clear(cid, hoid); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } { bufferlist hdr; @@ -2878,7 +2892,7 @@ TEST_P(StoreTest, OMapTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -2891,7 +2905,7 @@ TEST_P(StoreTest, OMapIterator) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -2902,7 +2916,7 @@ TEST_P(StoreTest, OMapIterator) { t.omap_clear(cid, hoid); map start_set; t.omap_setkeys(cid, hoid, start_set); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } ObjectMap::ObjectMapIterator iter; bool correct; @@ -2945,7 +2959,7 @@ TEST_P(StoreTest, OMapIterator) { attrs.insert(pair("key-" + string(buf), bl)); ObjectStore::Transaction t; t.omap_setkeys(cid, hoid, to_add); - store->apply_transaction(&osr, std::move(t)); + apply_transaction(store, &osr, std::move(t)); } iter = store->get_omap_iterator(cid, hoid); @@ -2971,7 +2985,7 @@ TEST_P(StoreTest, OMapIterator) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -2993,7 +3007,7 @@ TEST_P(StoreTest, XattrTest) { ObjectStore::Transaction t; t.create_collection(cid, 0); t.touch(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3012,7 +3026,7 @@ TEST_P(StoreTest, XattrTest) { attrs["attr4"] = big; t.setattr(cid, hoid, "attr3", big); attrs["attr3"] = big; - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3031,7 +3045,7 @@ TEST_P(StoreTest, XattrTest) { ObjectStore::Transaction t; t.rmattr(cid, hoid, "attr2"); attrs.erase("attr2"); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3059,7 +3073,7 @@ TEST_P(StoreTest, XattrTest) { ObjectStore::Transaction t; t.remove(cid, hoid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3075,7 +3089,7 @@ void colsplittest( { ObjectStore::Transaction t; t.create_collection(cid, common_suffix_size); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { @@ -3090,14 +3104,14 @@ void colsplittest( i<apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.create_collection(tid, common_suffix_size + 1); t.split_collection(cid, common_suffix_size+1, 1<apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3128,7 +3142,7 @@ void colsplittest( t.remove_collection(cid); t.remove_collection(tid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3159,7 +3173,7 @@ TEST_P(StoreTest, TwoHash) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } std::cout << "Making objects" << std::endl; @@ -3173,7 +3187,7 @@ TEST_P(StoreTest, TwoHash) { } o.hobj.set_hash((i << 16) | 0xB1); t.touch(cid, o); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } std::cout << "Removing half" << std::endl; @@ -3183,7 +3197,7 @@ TEST_P(StoreTest, TwoHash) { o.hobj.pool = -1; o.hobj.set_hash((i << 16) | 0xA1); t.remove(cid, o); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } std::cout << "Checking" << std::endl; @@ -3211,12 +3225,12 @@ TEST_P(StoreTest, TwoHash) { t.remove(cid, o); o.hobj.set_hash((i << 16) | 0xB1); t.remove(cid, o); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ObjectStore::Transaction t; t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3233,7 +3247,7 @@ TEST_P(StoreTest, Rename) { ObjectStore::Transaction t; t.create_collection(cid, 0); t.write(cid, srcoid, 0, a.length(), a); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, srcoid)); @@ -3243,7 +3257,7 @@ TEST_P(StoreTest, Rename) { t.remove(cid, srcoid); t.write(cid, srcoid, 0, b.length(), b); t.setattr(cid, srcoid, "attr", b); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, srcoid)); @@ -3261,7 +3275,7 @@ TEST_P(StoreTest, Rename) { t.collection_move_rename(cid, srcoid, cid, dstoid); t.remove(cid, srcoid); t.setattr(cid, srcoid, "attr", a); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, dstoid)); @@ -3275,7 +3289,7 @@ TEST_P(StoreTest, Rename) { t.remove(cid, dstoid); t.remove(cid, srcoid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -3290,7 +3304,7 @@ TEST_P(StoreTest, MoveRename) { ObjectStore::Transaction t; t.create_collection(cid, 0); t.touch(cid, oid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, oid)); @@ -3305,7 +3319,7 @@ TEST_P(StoreTest, MoveRename) { t.write(cid, temp_oid, 0, data.length(), data); t.setattr(cid, temp_oid, "attr", attr); t.omap_setkeys(cid, temp_oid, omap); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, temp_oid)); @@ -3313,7 +3327,7 @@ TEST_P(StoreTest, MoveRename) { ObjectStore::Transaction t; t.remove(cid, oid); t.collection_move_rename(cid, temp_oid, cid, oid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } ASSERT_TRUE(store->exists(cid, oid)); @@ -3340,7 +3354,7 @@ TEST_P(StoreTest, MoveRename) { ObjectStore::Transaction t; t.remove(cid, oid); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -3371,14 +3385,14 @@ TEST_P(StoreTest, BigRGWObjectName) { t.collection_move_rename(cid, oidhead, cid, oid); t.touch(cid, oidhead); t.collection_move_rename(cid, oidhead, cid, oid2); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove(cid, oid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3397,7 +3411,7 @@ TEST_P(StoreTest, BigRGWObjectName) { ObjectStore::Transaction t; t.remove(cid, oid2); t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } @@ -3412,31 +3426,31 @@ TEST_P(StoreTest, SetAllocHint) { ObjectStore::Transaction t; t.create_collection(cid, 0); t.touch(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.set_alloc_hint(cid, hoid, 4*1024*1024, 1024*4); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.set_alloc_hint(cid, hoid, 4*1024*1024, 1024*4); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.remove_collection(cid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } } @@ -3450,25 +3464,25 @@ TEST_P(StoreTest, TryMoveRename) { { ObjectStore::Transaction t; t.create_collection(cid, 0); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.try_rename(cid, hoid, hoid2); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.touch(cid, hoid); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } { ObjectStore::Transaction t; t.try_rename(cid, hoid, hoid2); - r = store->apply_transaction(&osr, std::move(t)); + r = apply_transaction(store, &osr, std::move(t)); ASSERT_EQ(r, 0); } struct stat st; -- 2.47.3