os/bluestore: instantiate a Checksummer

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

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index 142d456fe28725592e39fe72b752be13293e0a40..a3ee4647d858710c2604fb027a0b86d9b1538ff8 100644 (file)
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -949,6 +949,10 @@ OPTION(bluestore_block_wal_path, OPT_STR, "")
 OPTION(bluestore_block_wal_size, OPT_U64, 96 * 1024*1024) // rocksdb wal
 OPTION(bluestore_block_wal_create, OPT_BOOL, false)
 OPTION(bluestore_block_preallocate_file, OPT_BOOL, false) //whether preallocate space if block/db_path/wal_path is file rather that block device.
+OPTION(bluestore_csum, OPT_BOOL, true)
+OPTION(bluestore_csum_type, OPT_STR, "crc32c")
+OPTION(bluestore_min_csum_block, OPT_U32, 4096)
+OPTION(bluestore_max_csum_block, OPT_U32, 64*1024)
 OPTION(bluestore_min_alloc_size, OPT_U32, 64*1024)
 OPTION(bluestore_onode_map_size, OPT_U32, 1024)   // onodes per collection
 OPTION(bluestore_cache_tails, OPT_BOOL, true)   // cache tail blocks in Onode

diff --git a/src/os/bluestore/BlueStore.cc b/src/os/bluestore/BlueStore.cc
index 139c42d152e02ae6d2fde69b4b8fcabf1d78f751..b59d2411a738b41c36408ae75426b61397c0e567 100644 (file)
--- a/src/os/bluestore/BlueStore.cc
+++ b/src/os/bluestore/BlueStore.cc
@@ -769,7 +769,8 @@ BlueStore::BlueStore(CephContext *cct, const string& path)
     finisher(cct),
     kv_sync_thread(this),
     kv_stop(false),
-    logger(NULL)
+    logger(NULL),
+    checksummer(new Checksummer)
 {
   _init_logger();
 }
@@ -781,6 +782,7 @@ BlueStore::~BlueStore()
   assert(db == NULL);
   assert(bluefs == NULL);
   assert(fsid_fd < 0);
+  delete checksummer;
 }
 
 void BlueStore::_init_logger()

diff --git a/src/os/bluestore/BlueStore.h b/src/os/bluestore/BlueStore.h
index e28e103ceaeb485d92338e5541e5f2e64e0acadb..5a827d4084ecaa7c5d84bc404aa7bba5339ab0e7 100644 (file)
--- a/src/os/bluestore/BlueStore.h
+++ b/src/os/bluestore/BlueStore.h
@@ -38,6 +38,7 @@
 class Allocator;
 class FreelistManager;
 class BlueFS;
+class Checksummer;
 
 enum {
   l_bluestore_first = 732430,
@@ -584,6 +585,7 @@ private:
   std::mutex reap_lock;
   list<CollectionRef> removed_collections;
 
+  Checksummer *checksummer;
 
   // --------------------------------------------------------
   // private methods