RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-13 14:33:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5185 from yuyuyu101/wip-store-test-zero

Browse Source 
StoreTest: Add zero test for SyntheticTest
This commit is contained in:
Haomai Wang 2015-07-10 09:50:36 +08:00
commit b3002dd0d9
1 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/test/objectstore/store_test.cc
View File

@ -961,6 +961,34 @@ public:
return store->queue_transaction(osr, t, new C_SyntheticOnReadable(this, t, to_remove));
}
int zero() {
Mutex::Locker locker(lock);
if (!can_unlink())
return -ENOENT;
wait_for_ready();
ghobject_t new_obj = get_uniform_random_object();
available_objects.erase(new_obj);
ObjectStore::Transaction *t = new ObjectStore::Transaction;
boost::uniform_int<> u1(0, max_object_len/2);
boost::uniform_int<> u2(0, max_object_len/10);
uint64_t offset = u1(*rng);
uint64_t len = u2(*rng);
if (offset > len)
swap(offset, len);
if (contents[new_obj].data.length() < offset + len) {
contents[new_obj].data.append_zero(offset+len-contents[new_obj].data.length());
}
contents[new_obj].data.zero(offset, len);
t->zero(cid, new_obj, offset, len);
++in_flight;
in_flight_objects.insert(new_obj);
return store->queue_transaction(osr, t, new C_SyntheticOnReadable(this, t, new_obj));
}
void print_internal_state() {
Mutex::Locker locker(lock);
cerr << "available_objects: " << available_objects.size()
@ -991,9 +1019,11 @@ TEST_P(StoreTest, Synthetic) {
int val = true_false(rng);
if (val > 97) {
test_obj.scan();
} else if (val > 90) {
} else if (val > 95) {
test_obj.stat();
} else if (val > 85) {
test_obj.zero();
} else if (val > 80) {
test_obj.unlink();
} else if (val > 55) {
test_obj.write();