mds: make max file recovers configurable

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

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index 21c93d5b720d5bc78390e4bedbc81119c32b1bf6..e09ce3b800e5063e1f5c7c66184c1b4280c01e1b 100644 (file)
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -299,6 +299,7 @@ OPTION(mds_data, OPT_STR, "/var/lib/ceph/mds/$cluster-$id")
 OPTION(mds_max_file_size, OPT_U64, 1ULL << 40)
 OPTION(mds_cache_size, OPT_INT, 100000)
 OPTION(mds_cache_mid, OPT_FLOAT, .7)
+OPTION(mds_max_file_recover, OPT_INT, 5)
 OPTION(mds_mem_max, OPT_INT, 1048576)        // KB
 OPTION(mds_dir_max_commit_size, OPT_INT, 10) // MB
 OPTION(mds_decay_halflife, OPT_FLOAT, 5)

diff --git a/src/mds/RecoveryQueue.cc b/src/mds/RecoveryQueue.cc
index b5392c4c06adbe79102fb9132dcdcbbd562c5d40..d4a5b264086eeeb1372c80479ec8cd2bce5d3d2c 100644 (file)
--- a/src/mds/RecoveryQueue.cc
+++ b/src/mds/RecoveryQueue.cc
@@ -55,7 +55,7 @@ void RecoveryQueue::advance()
   dout(10) << "RecoveryQueue::advance " << file_recover_queue.size() << " queued, "
           << file_recovering.size() << " recovering" << dendl;
 
-  while (file_recovering.size() < 5 &&
+  while (file_recovering.size() < g_conf->mds_max_file_recover &&
         !file_recover_queue.empty()) {
     CInode *in = *file_recover_queue.begin();
     file_recover_queue.erase(in);