Cond sync_cond;
char path[200];
uuid_d fsid;
-bool directio = false;
-bool aio = false;
-bool faio = false;
+struct test_info {
+ bool directio, aio, faio;
+ const char *description;
+} subtests[3] = {
+ { false, false, false, "DIRECTIO OFF AIO OFF" },
+ { true, false, false, "DIRECTIO ON AIO OFF" },
+ { true, true, true, "DIRECTIO ON AIO ON"}
+};
// ----
Cond cond;
finisher->start();
- cout << "DIRECTIO OFF AIO OFF" << std::endl;
- directio = false;
- aio = false;
int r = RUN_ALL_TESTS();
- if (r >= 0) {
- cout << "DIRECTIO ON AIO OFF" << std::endl;
- directio = true;
- r = RUN_ALL_TESTS();
-
- if (r >= 0) {
- cout << "DIRECTIO ON AIO ON" << std::endl;
- aio = true;
- faio = true;
- r = RUN_ALL_TESTS();
- }
- }
finisher->stop();
}
TEST(TestFileJournal, Create) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ }
}
TEST(TestFileJournal, WriteSmall) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
- bufferlist bl;
- bl.append("small");
- j.submit_entry(1, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
- wait();
+ bufferlist bl;
+ bl.append("small");
+ j.submit_entry(1, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
+ wait();
- j.close();
+ j.close();
+ }
}
TEST(TestFileJournal, WriteBig) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
- bufferlist bl;
- while (bl.length() < size_mb*1000/2) {
- char foo[1024*1024];
- memset(foo, 1, sizeof(foo));
- bl.append(foo, sizeof(foo));
- }
- j.submit_entry(1, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
- wait();
+ bufferlist bl;
+ while (bl.length() < size_mb*1000/2) {
+ char foo[1024*1024];
+ memset(foo, 1, sizeof(foo));
+ bl.append(foo, sizeof(foo));
+ }
+ j.submit_entry(1, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
+ wait();
- j.close();
+ j.close();
+ }
}
TEST(TestFileJournal, WriteMany) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
-
- bufferlist bl;
- bl.append("small");
- uint64_t seq = 1;
- for (int i=0; i<100; i++) {
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ bufferlist bl;
bl.append("small");
- j.submit_entry(seq++, bl, 0, gb.new_sub());
- }
+ uint64_t seq = 1;
+ for (int i=0; i<100; i++) {
+ bl.append("small");
+ j.submit_entry(seq++, bl, 0, gb.new_sub());
+ }
- gb.activate();
+ gb.activate();
- wait();
+ wait();
- j.close();
+ j.close();
+ }
}
TEST(TestFileJournal, WriteManyVecs) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
-
- bufferlist first;
- first.append("small");
- j.submit_entry(1, first, 0, gb.new_sub());
-
- bufferlist bl;
- for (int i=0; i<IOV_MAX * 2; i++) {
- bufferptr bp = buffer::create_page_aligned(4096);
- memset(bp.c_str(), (char)i, 4096);
- bl.append(bp);
- }
- bufferlist origbl = bl;
- j.submit_entry(2, bl, 0, gb.new_sub());
- gb.activate();
- wait();
-
- j.close();
-
- j.open(1);
- bufferlist inbl;
- string v;
- uint64_t seq = 0;
- ASSERT_EQ(true, j.read_entry(inbl, seq));
- ASSERT_EQ(seq, 2ull);
- ASSERT_TRUE(inbl.contents_equal(origbl));
- j.make_writeable();
- j.close();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ bufferlist first;
+ first.append("small");
+ j.submit_entry(1, first, 0, gb.new_sub());
+ bufferlist bl;
+ for (int i=0; i<IOV_MAX * 2; i++) {
+ bufferptr bp = buffer::create_page_aligned(4096);
+ memset(bp.c_str(), (char)i, 4096);
+ bl.append(bp);
+ }
+ bufferlist origbl = bl;
+ j.submit_entry(2, bl, 0, gb.new_sub());
+ gb.activate();
+ wait();
+
+ j.close();
+
+ j.open(1);
+ bufferlist inbl;
+ string v;
+ uint64_t seq = 0;
+ ASSERT_EQ(true, j.read_entry(inbl, seq));
+ ASSERT_EQ(seq, 2ull);
+ ASSERT_TRUE(inbl.contents_equal(origbl));
+ j.make_writeable();
+ j.close();
+
+ }
}
TEST(TestFileJournal, ReplaySmall) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
-
- bufferlist bl;
- bl.append("small");
- j.submit_entry(1, bl, 0, gb.new_sub());
- bl.append("small");
- j.submit_entry(2, bl, 0, gb.new_sub());
- bl.append("small");
- j.submit_entry(3, bl, 0, gb.new_sub());
- gb.activate();
- wait();
-
- j.close();
-
- j.open(1);
-
- bufferlist inbl;
- string v;
- uint64_t seq = 0;
- ASSERT_EQ(true, j.read_entry(inbl, seq));
- ASSERT_EQ(seq, 2ull);
- inbl.copy(0, inbl.length(), v);
- ASSERT_EQ("small", v);
- inbl.clear();
- v.clear();
-
- ASSERT_EQ(true, j.read_entry(inbl, seq));
- ASSERT_EQ(seq, 3ull);
- inbl.copy(0, inbl.length(), v);
- ASSERT_EQ("small", v);
- inbl.clear();
- v.clear();
-
- ASSERT_TRUE(!j.read_entry(inbl, seq));
-
- j.make_writeable();
- j.close();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ bufferlist bl;
+ bl.append("small");
+ j.submit_entry(1, bl, 0, gb.new_sub());
+ bl.append("small");
+ j.submit_entry(2, bl, 0, gb.new_sub());
+ bl.append("small");
+ j.submit_entry(3, bl, 0, gb.new_sub());
+ gb.activate();
+ wait();
+
+ j.close();
+
+ j.open(1);
+
+ bufferlist inbl;
+ string v;
+ uint64_t seq = 0;
+ ASSERT_EQ(true, j.read_entry(inbl, seq));
+ ASSERT_EQ(seq, 2ull);
+ inbl.copy(0, inbl.length(), v);
+ ASSERT_EQ("small", v);
+ inbl.clear();
+ v.clear();
+
+ ASSERT_EQ(true, j.read_entry(inbl, seq));
+ ASSERT_EQ(seq, 3ull);
+ inbl.copy(0, inbl.length(), v);
+ ASSERT_EQ("small", v);
+ inbl.clear();
+ v.clear();
+
+ ASSERT_TRUE(!j.read_entry(inbl, seq));
+
+ j.make_writeable();
+ j.close();
+ }
}
TEST(TestFileJournal, ReplayCorrupt) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
-
- const char *needle = "i am a needle";
- const char *newneedle = "in a haystack";
- bufferlist bl;
- bl.append(needle);
- j.submit_entry(1, bl, 0, gb.new_sub());
- bl.append(needle);
- j.submit_entry(2, bl, 0, gb.new_sub());
- bl.append(needle);
- j.submit_entry(3, bl, 0, gb.new_sub());
- bl.append(needle);
- j.submit_entry(4, bl, 0, gb.new_sub());
- gb.activate();
- wait();
-
- j.close();
-
- cout << "corrupting journal" << std::endl;
- char buf[1024*128];
- int fd = open(path, O_RDONLY);
- ASSERT_GE(fd, 0);
- int r = safe_read_exact(fd, buf, sizeof(buf));
- ASSERT_EQ(0, r);
- int n = 0;
- for (unsigned o=0; o < sizeof(buf) - strlen(needle); o++) {
- if (memcmp(buf+o, needle, strlen(needle)) == 0) {
- if (n >= 2) {
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ const char *needle = "i am a needle";
+ const char *newneedle = "in a haystack";
+ bufferlist bl;
+ bl.append(needle);
+ j.submit_entry(1, bl, 0, gb.new_sub());
+ bl.append(needle);
+ j.submit_entry(2, bl, 0, gb.new_sub());
+ bl.append(needle);
+ j.submit_entry(3, bl, 0, gb.new_sub());
+ bl.append(needle);
+ j.submit_entry(4, bl, 0, gb.new_sub());
+ gb.activate();
+ wait();
+
+ j.close();
+
+ cout << "corrupting journal" << std::endl;
+ char buf[1024*128];
+ int fd = open(path, O_RDONLY);
+ ASSERT_GE(fd, 0);
+ int r = safe_read_exact(fd, buf, sizeof(buf));
+ ASSERT_EQ(0, r);
+ int n = 0;
+ for (unsigned o=0; o < sizeof(buf) - strlen(needle); o++) {
+ if (memcmp(buf+o, needle, strlen(needle)) == 0) {
+ if (n >= 2) {
cout << "replacing at offset " << o << std::endl;
memcpy(buf+o, newneedle, strlen(newneedle));
- } else {
+ } else {
cout << "leaving at offset " << o << std::endl;
+ }
+ n++;
}
- n++;
}
+ ASSERT_EQ(n, 4);
+ close(fd);
+ fd = open(path, O_WRONLY);
+ ASSERT_GE(fd, 0);
+ r = safe_write(fd, buf, sizeof(buf));
+ ASSERT_EQ(r, 0);
+ close(fd);
+
+ j.open(1);
+
+ bufferlist inbl;
+ string v;
+ uint64_t seq = 0;
+ ASSERT_EQ(true, j.read_entry(inbl, seq));
+ ASSERT_EQ(seq, 2ull);
+ inbl.copy(0, inbl.length(), v);
+ ASSERT_EQ(needle, v);
+ inbl.clear();
+ v.clear();
+ ASSERT_TRUE(!j.read_entry(inbl, seq));
+
+ j.make_writeable();
+ j.close();
}
- ASSERT_EQ(n, 4);
- close(fd);
- fd = open(path, O_WRONLY);
- ASSERT_GE(fd, 0);
- r = safe_write(fd, buf, sizeof(buf));
- ASSERT_EQ(r, 0);
- close(fd);
-
- j.open(1);
-
- bufferlist inbl;
- string v;
- uint64_t seq = 0;
- ASSERT_EQ(true, j.read_entry(inbl, seq));
- ASSERT_EQ(seq, 2ull);
- inbl.copy(0, inbl.length(), v);
- ASSERT_EQ(needle, v);
- inbl.clear();
- v.clear();
- ASSERT_TRUE(!j.read_entry(inbl, seq));
-
- j.make_writeable();
- j.close();
}
TEST(TestFileJournal, WriteTrim) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
- list<C_Sync*> ls;
-
- bufferlist bl;
- char foo[1024*1024];
- memset(foo, 1, sizeof(foo));
+ list<C_Sync*> ls;
- uint64_t seq = 1, committed = 0;
+ bufferlist bl;
+ char foo[1024*1024];
+ memset(foo, 1, sizeof(foo));
- for (unsigned i=0; i<size_mb*2; i++) {
- bl.clear();
- bl.push_back(buffer::copy(foo, sizeof(foo)));
- bl.zero();
- ls.push_back(new C_Sync);
- j.submit_entry(seq++, bl, 0, ls.back()->c);
+ uint64_t seq = 1, committed = 0;
+
+ for (unsigned i=0; i<size_mb*2; i++) {
+ bl.clear();
+ bl.push_back(buffer::copy(foo, sizeof(foo)));
+ bl.zero();
+ ls.push_back(new C_Sync);
+ j.submit_entry(seq++, bl, 0, ls.back()->c);
- while (ls.size() > size_mb/2) {
+ while (ls.size() > size_mb/2) {
+ delete ls.front();
+ ls.pop_front();
+ committed++;
+ j.committed_thru(committed);
+ }
+ }
+
+ while (ls.size()) {
delete ls.front();
ls.pop_front();
- committed++;
- j.committed_thru(committed);
+ j.committed_thru(++committed);
}
- }
-
- while (ls.size()) {
- delete ls.front();
- ls.pop_front();
- j.committed_thru(++committed);
- }
- ASSERT_TRUE(j.journalq_empty());
+ ASSERT_TRUE(j.journalq_empty());
- j.close();
+ j.close();
+ }
}
TEST(TestFileJournal, WriteTrimSmall) {
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
- list<C_Sync*> ls;
-
- bufferlist bl;
- char foo[1024*1024];
- memset(foo, 1, sizeof(foo));
+ list<C_Sync*> ls;
- uint64_t seq = 1, committed = 0;
+ bufferlist bl;
+ char foo[1024*1024];
+ memset(foo, 1, sizeof(foo));
- for (unsigned i=0; i<size_mb*2; i++) {
- bl.clear();
- for (int k=0; k<128; k++)
- bl.push_back(buffer::copy(foo, sizeof(foo) / 128));
- bl.zero();
- ls.push_back(new C_Sync);
- j.submit_entry(seq++, bl, 0, ls.back()->c);
+ uint64_t seq = 1, committed = 0;
+
+ for (unsigned i=0; i<size_mb*2; i++) {
+ bl.clear();
+ for (int k=0; k<128; k++)
+ bl.push_back(buffer::copy(foo, sizeof(foo) / 128));
+ bl.zero();
+ ls.push_back(new C_Sync);
+ j.submit_entry(seq++, bl, 0, ls.back()->c);
+
+ while (ls.size() > size_mb/2) {
+ delete ls.front();
+ ls.pop_front();
+ committed++;
+ j.committed_thru(committed);
+ }
+ }
- while (ls.size() > size_mb/2) {
+ while (ls.size()) {
delete ls.front();
ls.pop_front();
- committed++;
j.committed_thru(committed);
}
- }
- while (ls.size()) {
- delete ls.front();
- ls.pop_front();
- j.committed_thru(committed);
+ j.close();
}
-
- j.close();
}
TEST(TestFileJournal, ReplayDetectCorruptFooterMagic) {
g_ceph_context->_conf->set_val("journal_write_header_frequency", "1");
g_ceph_context->_conf->apply_changes(NULL);
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ const char *needle = "i am a needle";
+ for (unsigned i = 1; i <= 4; ++i) {
+ bufferlist bl;
+ bl.append(needle);
+ j.submit_entry(i, bl, 0, gb.new_sub());
+ }
+ gb.activate();
+ wait();
- const char *needle = "i am a needle";
- for (unsigned i = 1; i <= 4; ++i) {
bufferlist bl;
- bl.append(needle);
- j.submit_entry(i, bl, 0, gb.new_sub());
+ bl.append("needle");
+ j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
+ wait();
+
+ j.close();
+ int fd = open(path, O_WRONLY);
+
+ cout << "corrupting journal" << std::endl;
+ j.open(0);
+ j.corrupt_footer_magic(fd, 2);
+
+ uint64_t seq = 0;
+ bl.clear();
+ bool corrupt = false;
+ bool result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_TRUE(result);
+ ASSERT_EQ(seq, 1UL);
+ ASSERT_FALSE(corrupt);
+
+ result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_FALSE(result);
+ ASSERT_TRUE(corrupt);
+
+ j.make_writeable();
+ j.close();
+ ::close(fd);
}
- gb.activate();
- wait();
-
- bufferlist bl;
- bl.append("needle");
- j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
- wait();
-
- j.close();
- int fd = open(path, O_WRONLY);
-
- cout << "corrupting journal" << std::endl;
- j.open(0);
- j.corrupt_footer_magic(fd, 2);
-
- uint64_t seq = 0;
- bl.clear();
- bool corrupt = false;
- bool result = j.read_entry(bl, seq, &corrupt);
- ASSERT_TRUE(result);
- ASSERT_EQ(seq, 1UL);
- ASSERT_FALSE(corrupt);
-
- result = j.read_entry(bl, seq, &corrupt);
- ASSERT_FALSE(result);
- ASSERT_TRUE(corrupt);
-
- j.make_writeable();
- j.close();
- ::close(fd);
}
TEST(TestFileJournal, ReplayDetectCorruptPayload) {
g_ceph_context->_conf->set_val("journal_write_header_frequency", "1");
g_ceph_context->_conf->apply_changes(NULL);
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ const char *needle = "i am a needle";
+ for (unsigned i = 1; i <= 4; ++i) {
+ bufferlist bl;
+ bl.append(needle);
+ j.submit_entry(i, bl, 0, gb.new_sub());
+ }
+ gb.activate();
+ wait();
- const char *needle = "i am a needle";
- for (unsigned i = 1; i <= 4; ++i) {
bufferlist bl;
- bl.append(needle);
- j.submit_entry(i, bl, 0, gb.new_sub());
+ bl.append("needle");
+ j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
+ wait();
+
+ j.close();
+ int fd = open(path, O_WRONLY);
+
+ cout << "corrupting journal" << std::endl;
+ j.open(0);
+ j.corrupt_payload(fd, 2);
+
+ uint64_t seq = 0;
+ bl.clear();
+ bool corrupt = false;
+ bool result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_TRUE(result);
+ ASSERT_EQ(seq, 1UL);
+ ASSERT_FALSE(corrupt);
+
+ result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_FALSE(result);
+ ASSERT_TRUE(corrupt);
+
+ j.make_writeable();
+ j.close();
+ ::close(fd);
}
- gb.activate();
- wait();
-
- bufferlist bl;
- bl.append("needle");
- j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
- wait();
-
- j.close();
- int fd = open(path, O_WRONLY);
-
- cout << "corrupting journal" << std::endl;
- j.open(0);
- j.corrupt_payload(fd, 2);
-
- uint64_t seq = 0;
- bl.clear();
- bool corrupt = false;
- bool result = j.read_entry(bl, seq, &corrupt);
- ASSERT_TRUE(result);
- ASSERT_EQ(seq, 1UL);
- ASSERT_FALSE(corrupt);
-
- result = j.read_entry(bl, seq, &corrupt);
- ASSERT_FALSE(result);
- ASSERT_TRUE(corrupt);
-
- j.make_writeable();
- j.close();
- ::close(fd);
}
TEST(TestFileJournal, ReplayDetectCorruptHeader) {
g_ceph_context->_conf->set_val("journal_write_header_frequency", "1");
g_ceph_context->_conf->apply_changes(NULL);
- fsid.generate_random();
- FileJournal j(fsid, finisher, &sync_cond, path, directio, aio, faio);
- ASSERT_EQ(0, j.create());
- j.make_writeable();
-
- C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+ for (unsigned i = 0 ; i < 3; ++i) {
+ SCOPED_TRACE(subtests[i].description);
+ fsid.generate_random();
+ FileJournal j(fsid, finisher, &sync_cond, path, subtests[i].directio,
+ subtests[i].aio, subtests[i].faio);
+ ASSERT_EQ(0, j.create());
+ j.make_writeable();
+
+ C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&wait_lock, &cond, &done));
+
+ const char *needle = "i am a needle";
+ for (unsigned i = 1; i <= 4; ++i) {
+ bufferlist bl;
+ bl.append(needle);
+ j.submit_entry(i, bl, 0, gb.new_sub());
+ }
+ gb.activate();
+ wait();
- const char *needle = "i am a needle";
- for (unsigned i = 1; i <= 4; ++i) {
bufferlist bl;
- bl.append(needle);
- j.submit_entry(i, bl, 0, gb.new_sub());
+ bl.append("needle");
+ j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
+ wait();
+
+ j.close();
+ int fd = open(path, O_WRONLY);
+
+ cout << "corrupting journal" << std::endl;
+ j.open(0);
+ j.corrupt_header_magic(fd, 2);
+
+ uint64_t seq = 0;
+ bl.clear();
+ bool corrupt = false;
+ bool result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_TRUE(result);
+ ASSERT_EQ(seq, 1UL);
+ ASSERT_FALSE(corrupt);
+
+ result = j.read_entry(bl, seq, &corrupt);
+ ASSERT_FALSE(result);
+ ASSERT_TRUE(corrupt);
+
+ j.make_writeable();
+ j.close();
+ ::close(fd);
}
- gb.activate();
- wait();
-
- bufferlist bl;
- bl.append("needle");
- j.submit_entry(5, bl, 0, new C_SafeCond(&wait_lock, &cond, &done));
- wait();
-
- j.close();
- int fd = open(path, O_WRONLY);
-
- cout << "corrupting journal" << std::endl;
- j.open(0);
- j.corrupt_header_magic(fd, 2);
-
- uint64_t seq = 0;
- bl.clear();
- bool corrupt = false;
- bool result = j.read_entry(bl, seq, &corrupt);
- ASSERT_TRUE(result);
- ASSERT_EQ(seq, 1UL);
- ASSERT_FALSE(corrupt);
-
- result = j.read_entry(bl, seq, &corrupt);
- ASSERT_FALSE(result);
- ASSERT_TRUE(corrupt);
-
- j.make_writeable();
- j.close();
- ::close(fd);
}
projects / ceph.git / commitdiff