From: Sage Weil Date: Fri, 12 Feb 2016 19:53:39 +0000 (-0500) Subject: os/filestore/FileJournal: set block size via config option X-Git-Tag: v10.1.0~213^2~3^2~1 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c8048ce4bedf0d1ba5d448795c46668f2724f29d;p=ceph.git os/filestore/FileJournal: set block size via config option We were setting the block_size as the MIN of the min size (4096) and the block size reported for the journal file/device. In reality, file systmes report all kinds of crazy block sizes. Usually it's the page size, but sometimes it is larger (e.g., 128KB for ZFS), and that's not actually what we want. Using a size smaller than the file systems block size is not optimal for performance, but it doesn't affect how the IO happens--as long as it is larger than the hardware sector size, which is either 512 or 4096 bytes. And our min was hard-coded at 4096. So, instead, just set a config option to specify teh block size, and default that to 4096. The other uses of this constant we about *alignment* of memory buffers for the purposes of direct IO. Rename the constant but do not change the logic. That means we continue to use 4k alignment for direct io even if the device has 512 byte sectors, but that's fine--no reason to use a smaller alignment. Signed-off-by: Sage Weil --- diff --git a/src/common/config_opts.h b/src/common/config_opts.h index 04dafac42a85..e940d9eb7062 100644 --- a/src/common/config_opts.h +++ b/src/common/config_opts.h @@ -1050,6 +1050,7 @@ OPTION(filestore_debug_verify_split, OPT_BOOL, false) OPTION(journal_dio, OPT_BOOL, true) OPTION(journal_aio, OPT_BOOL, true) OPTION(journal_force_aio, OPT_BOOL, false) +OPTION(journal_block_size, OPT_INT, 4096) // max bytes to search ahead in journal searching for corruption OPTION(journal_max_corrupt_search, OPT_U64, 10<<20) diff --git a/src/os/filestore/FileJournal.cc b/src/os/filestore/FileJournal.cc index 7763c6f95f4d..b0ae170172ec 100644 --- a/src/os/filestore/FileJournal.cc +++ b/src/os/filestore/FileJournal.cc @@ -44,7 +44,8 @@ #define dout_prefix *_dout << "journal " const static int64_t ONE_MEG(1 << 20); -const static int CEPH_MINIMUM_BLOCK_SIZE(4096); +const static int CEPH_DIRECTIO_ALIGNMENT(4096); + int FileJournal::_open(bool forwrite, bool create) { @@ -148,7 +149,7 @@ int FileJournal::_open_block_device() << dendl; max_size = bdev_sz; - block_size = CEPH_MINIMUM_BLOCK_SIZE; + block_size = g_conf->journal_block_size; if (g_conf->journal_discard) { discard = block_device_support_discard(fn.c_str()); @@ -288,7 +289,7 @@ int FileJournal::_open_file(int64_t oldsize, blksize_t blksize, else { max_size = oldsize; } - block_size = MAX(blksize, (blksize_t)CEPH_MINIMUM_BLOCK_SIZE); + block_size = g_conf->journal_block_size; if (create && g_conf->journal_zero_on_create) { derr << "FileJournal::_open_file : zeroing journal" << dendl; @@ -503,9 +504,11 @@ int FileJournal::open(uint64_t fs_op_seq) << block_size << " (required for direct_io journal mode)" << dendl; return -EINVAL; } - if ((header.alignment % CEPH_MINIMUM_BLOCK_SIZE) && directio) { - dout(0) << "open journal alignment " << header.alignment << " is not multiple of minimum block size " - << CEPH_MINIMUM_BLOCK_SIZE << " (required for direct_io journal mode)" << dendl; + if ((header.alignment % CEPH_DIRECTIO_ALIGNMENT) && directio) { + dout(0) << "open journal alignment " << header.alignment + << " is not multiple of minimum directio alignment " + << CEPH_DIRECTIO_ALIGNMENT << " (required for direct_io journal mode)" + << dendl; return -EINVAL; } @@ -1038,13 +1041,13 @@ void FileJournal::align_bl(off64_t pos, bufferlist& bl) { // make sure list segments are page aligned if (directio && (!bl.is_aligned(block_size) || - !bl.is_n_align_sized(CEPH_MINIMUM_BLOCK_SIZE))) { + !bl.is_n_align_sized(CEPH_DIRECTIO_ALIGNMENT))) { assert(0 == "bl should be align"); - if ((bl.length() & (CEPH_MINIMUM_BLOCK_SIZE - 1)) != 0 || - (pos & (CEPH_MINIMUM_BLOCK_SIZE - 1)) != 0) + if ((bl.length() & (CEPH_DIRECTIO_ALIGNMENT - 1)) != 0 || + (pos & (CEPH_DIRECTIO_ALIGNMENT - 1)) != 0) dout(0) << "rebuild_page_aligned failed, " << bl << dendl; - assert((bl.length() & (CEPH_MINIMUM_BLOCK_SIZE - 1)) == 0); - assert((pos & (CEPH_MINIMUM_BLOCK_SIZE - 1)) == 0); + assert((bl.length() & (CEPH_DIRECTIO_ALIGNMENT - 1)) == 0); + assert((pos & (CEPH_DIRECTIO_ALIGNMENT - 1)) == 0); } } @@ -1631,7 +1634,7 @@ int FileJournal::prepare_entry(vector& tls, bufferlist } // footer ebl.append((const char*)&h, sizeof(h)); - ebl.rebuild_aligned(CEPH_MINIMUM_BLOCK_SIZE); + ebl.rebuild_aligned(CEPH_DIRECTIO_ALIGNMENT); tbl->claim(ebl); return h.len; }