test/bluefs: add cases for wal v2 envelope header mislocation.

Signed-off-by: Igor Fedotov <igor.fedotov@croit.io>
(cherry picked from commit 46f6ffcd9140bfeda499af4ac2f143a1ae9cf994)
(from https://github.com/ceph/ceph/pull/65275)

diff --git a/src/test/objectstore/test_bluefs.cc b/src/test/objectstore/test_bluefs.cc
index 297892c6655ff5da8017edc91bc23fd97c4ad14c..c19b6c5f5d7d1077c3714100a2ee2c3b53c5a031 100644 (file)
--- a/src/test/objectstore/test_bluefs.cc
+++ b/src/test/objectstore/test_bluefs.cc
@@ -1176,6 +1176,55 @@ TEST_F(BlueFS_wal, wal_v2_check)
   fs.umount();
 }
 
+TEST_F(BlueFS_wal, wal_v2_check_split_header)
+{
+  // Check if wal v2 envelope header is properly located
+  // when FileWrite'r buffer is exhausted.
+  //
+  ConfSaver conf(g_ceph_context->_conf);
+  conf.SetVal("bluefs_min_flush_size", "65536");
+  conf.SetVal("bluefs_wal_envelope_mode", "true");
+  conf.SetVal("bluefs_alloc_size", "8192");
+  conf.ApplyChanges();
+
+  Create(1048576 * 256, 1048576 * 128, 1048576 * 64);
+  ASSERT_EQ(0, fs.mount());
+
+  bufferlist content;
+  many_small_writes("db.wal", "wal1.log", content, 4076 + 4077, 4076, 4077);
+  fs.umount();
+  fs.mount();
+  bufferlist read_content;
+  many_small_reads("db.wal", "wal1.log", read_content, 4076 + 4077, 4076, 4077);
+  ASSERT_EQ(content, read_content);
+  fs.umount();
+}
+
+TEST_F(BlueFS_wal, wal_v2_check_split_header_small_alloc)
+{
+  // Check if wal v2 envelope header is properly located
+  // when FileWrite'r buffer is exhausted.
+  // Case for single 4K page buffer.
+  //
+  ConfSaver conf(g_ceph_context->_conf);
+  conf.SetVal("bluefs_min_flush_size", "65536");
+  conf.SetVal("bluefs_wal_envelope_mode", "true");
+  conf.SetVal("bluefs_alloc_size", "4096");
+  conf.ApplyChanges();
+
+  Create(1048576 * 256, 1048576 * 128, 1048576 * 64);
+  ASSERT_EQ(0, fs.mount());
+
+  bufferlist content;
+  many_small_writes("db.wal", "wal1.log", content, 4076 + 4077, 4076, 4077);
+  fs.umount();
+  fs.mount();
+  bufferlist read_content;
+  many_small_reads("db.wal", "wal1.log", read_content, 4076 + 4077, 4076, 4077);
+  ASSERT_EQ(content, read_content);
+  fs.umount();
+}
+
 TEST_F(BlueFS_wal, wal_v2_check_feature)
 {
   SKIP_JENKINS();