FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
vector<ObjectStore::Transaction> tls;
bufferlist bl;
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
bufferlist bl;
while (bl.length() < size_mb*1000/2) {
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_EQ(true, j.read_entry(inbl, seq));
ASSERT_EQ(seq, 2ull);
ASSERT_TRUE(inbl.contents_equal(origbl));
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
}
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_TRUE(!j.read_entry(inbl, seq));
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
}
}
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_FALSE(j.read_entry(inbl, seq, &corrupt));
ASSERT_TRUE(corrupt);
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
}
}
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
list<C_Sync*> ls;
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
list<C_Sync*> ls;
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_FALSE(result);
ASSERT_TRUE(corrupt);
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
::close(fd);
}
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_FALSE(result);
ASSERT_TRUE(corrupt);
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
::close(fd);
}
FileJournal j(g_ceph_context, fsid, finisher, &sync_cond, path,
subtests[i].directio, subtests[i].aio, subtests[i].faio);
ASSERT_EQ(0, j.create());
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
ASSERT_FALSE(result);
ASSERT_TRUE(corrupt);
- j.make_writeable();
+ ASSERT_EQ(0, j.make_writeable());
j.close();
::close(fd);
}