test_filejournal: test journaling bl with >IOV_MAX segments

Signed-off-by: Sage Weil <sage@inktank.com>

diff --git a/src/test/test_filejournal.cc b/src/test/test_filejournal.cc
index c3af26bc3e4acb0c540e875a168a848a25ac398d..975233fd22a3d05ddce47d587caac7300e67e01c 100644 (file)
--- a/src/test/test_filejournal.cc
+++ b/src/test/test_filejournal.cc
@@ -1,5 +1,6 @@
 #include <gtest/gtest.h>
 #include <stdlib.h>
+#include <limits.h>
 
 #include "common/ceph_argparse.h"
 #include "common/common_init.h"
@@ -160,6 +161,43 @@ TEST(TestFileJournal, WriteMany) {
   j.close();
 }
 
+TEST(TestFileJournal, WriteManyVecs) {
+  fsid.generate_random();
+  FileJournal j(fsid, finisher, &sync_cond, path, directio, aio);
+  ASSERT_EQ(0, j.create());
+  j.make_writeable();
+
+  C_GatherBuilder gb(g_ceph_context, new C_SafeCond(&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);