RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-10 05:00:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

test/store_test: add simple tests for collection_split

Browse Source 
Signed-off-by: Samuel Just <sam.just@inktank.com>
This commit is contained in:
Samuel Just 2012-09-10 21:47:09 -07:00
parent f2a23916d4
commit bd46386353
1 changed files with 66 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
src/test/filestore/store_test.cc
View File

@ -732,6 +732,72 @@ TEST_F(StoreTest, XattrTest) {
ASSERT_TRUE(bl2 == attrs["attr3"]); ASSERT_TRUE(bl2 == attrs["attr3"]);
} }
void colsplittest(
ObjectStore *store,
unsigned num_objects,
unsigned common_suffix_size
) {
coll_t cid("from");
coll_t tid("to");
int r = 0;
{
ObjectStore::Transaction t;
t.create_collection(cid);
r = store->apply_transaction(t);
ASSERT_EQ(r, 0);
}
{
ObjectStore::Transaction t;
for (uint32_t i = 0; i < 2*num_objects; ++i) {
stringstream objname;
objname << "obj" << i;
t.touch(cid, hobject_t(
objname.str(),
"",
CEPH_NOSNAP,
i<<common_suffix_size,
0));
}
r = store->apply_transaction(t);
ASSERT_EQ(r, 0);
}
{
ObjectStore::Transaction t;
t.split_collection(cid, common_suffix_size+1, 0, tid);
r = store->apply_transaction(t);
ASSERT_EQ(r, 0);
}
vector<hobject_t> objects;
r = store->collection_list(cid, objects);
ASSERT_EQ(r, 0);
ASSERT_EQ(objects.size(), num_objects);
for (vector<hobject_t>::iterator i = objects.begin();
i != objects.end();
++i) {
ASSERT_EQ(!(i->hash & (1<<common_suffix_size)), 0u);
}
objects.clear();
r = store->collection_list(tid, objects);
ASSERT_EQ(r, 0);
ASSERT_EQ(objects.size(), num_objects);
for (vector<hobject_t>::iterator i = objects.begin();
i != objects.end();
++i) {
ASSERT_EQ(i->hash & (1<<common_suffix_size), 0u);
}
}
TEST_F(StoreTest, ColSplitTest1) {
colsplittest(store.get(), 10000, 11);
}
TEST_F(StoreTest, ColSplitTest2) {
colsplittest(store.get(), 100, 7);
}
TEST_F(StoreTest, ColSplitTest3) {
colsplittest(store.get(), 100000, 25);
}
int main(int argc, char **argv) { int main(int argc, char **argv) {
vector<const char*> args; vector<const char*> args;
argv_to_vec(argc, (const char **)argv, args); argv_to_vec(argc, (const char **)argv, args);