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

ceph_test_rados: IsDirty on random snaps

Browse Source 
Signed-off-by: Sage Weil <sage@inktank.com>
This commit is contained in:
Sage Weil 2013-12-27 17:12:54 -08:00
parent 6f4f651357
commit ac635513d3
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/test/osd/RadosModel.h
View File

@ -1688,6 +1688,7 @@ public:
string oid;
bool dirty;
ObjectDesc old_value;
int snap;
IsDirtyOp(int n,
RadosTestContext *context,
@ -1704,6 +1705,13 @@ public:
{
context->state_lock.Lock();
if (!(rand() % 4) && !context->snaps.empty()) {
snap = rand_choose(context->snaps)->first;
} else {
snap = -1;
}
std::cout << num << ": snap " << snap << std::endl;
pair<TestOp*, TestOp::CallbackInfo*> *cb_arg =
new pair<TestOp*, TestOp::CallbackInfo*>(this,
new TestOp::CallbackInfo(0));
@ -1714,10 +1722,18 @@ public:
context->oid_not_in_use.erase(oid);
context->state_lock.Unlock();
if (snap >= 0) {
context->io_ctx.snap_set_read(context->snaps[snap]);
}
op.is_dirty(&dirty, NULL);
int r = context->io_ctx.aio_operate(context->prefix+oid, completion,
&op, 0);
assert(!r);
if (snap >= 0) {
context->io_ctx.snap_set_read(0);
}
}
void _finish(CallbackInfo *info)
@ -1728,7 +1744,7 @@ public:
context->oid_in_use.erase(oid);
context->oid_not_in_use.insert(oid);
assert(context->find_object(oid, &old_value)); // FIXME snap?
assert(context->find_object(oid, &old_value, snap));
int r = completion->get_return_value();
if (r == 0) {