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

ceph_test_keyvaluedb: fixup unit test for keyvaluedb

Browse Source 
Fixes: http://tracker.ceph.com/issues/15435
Signed-off-by: Allen Samuels <allen.samuels@sandisk.com>
This commit is contained in:
Allen Samuels 2016-04-22 14:06:56 -04:00 committed by Sage Weil
parent 4c5370401c
commit 85c14de209
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/test/objectstore/test_kv.cc
View File

@ -35,19 +35,22 @@ public:
KVTest() : db(0) {}
string mydirname() { return "kv_test_temp_dir_" + string(GetParam()); }
void init() {
cout << "Creating " << string(GetParam()) << "\n";
db.reset(KeyValueDB::create(g_ceph_context, string(GetParam()),
string("kv_test_temp_dir")));
mydirname()));
}
void fini() {
db.reset(NULL);
}
virtual void SetUp() {
int r = ::mkdir("kv_test_temp_dir", 0777);
int r = ::mkdir(mydirname().c_str(), 0777);
if (r < 0 && errno != EEXIST) {
r = -errno;
cerr << __func__ << ": unable to create kv_test_temp_dir"
cerr << __func__ << ": unable to create " << mydirname()
<< ": " << cpp_strerror(r) << std::endl;
return;
}
@ -87,11 +90,11 @@ TEST_P(KVTest, PutReopen) {
init();
ASSERT_EQ(0, db->open(cout));
{
bufferlist v;
ASSERT_EQ(0, db->get("prefix", "key", &v));
ASSERT_EQ(v.length(), 5u);
ASSERT_EQ(0, db->get("prefix", "key2", &v));
ASSERT_EQ(v.length(), 5u);
bufferlist v1, v2;
ASSERT_EQ(0, db->get("prefix", "key", &v1));
ASSERT_EQ(v1.length(), 5u);
ASSERT_EQ(0, db->get("prefix", "key2", &v2));
ASSERT_EQ(v2.length(), 5u);
}
{
KeyValueDB::Transaction t = db->get_transaction();
@ -104,11 +107,11 @@ TEST_P(KVTest, PutReopen) {
init();
ASSERT_EQ(0, db->open(cout));
{
bufferlist v;
ASSERT_EQ(-ENOENT, db->get("prefix", "key", &v));
ASSERT_EQ(0, db->get("prefix", "key2", &v));
ASSERT_EQ(v.length(), 5u);
ASSERT_EQ(-ENOENT, db->get("prefix", "key3", &v));
bufferlist v1, v2, v3;
ASSERT_EQ(-ENOENT, db->get("prefix", "key", &v1));
ASSERT_EQ(0, db->get("prefix", "key2", &v2));
ASSERT_EQ(v2.length(), 5u);
ASSERT_EQ(-ENOENT, db->get("prefix", "key3", &v3));
}
fini();
}
@ -144,6 +147,7 @@ TEST_P(KVTest, BenchCommit) {
utime_t dur = end - start;
cout << n << " commits in " << dur << ", avg latency " << (dur / (double)n)
<< std::endl;
fini();
}