template <typename I>
Threads<I>::Threads(CephContext *cct) : timer_lock("Threads::timer_lock") {
thread_pool = new ThreadPool(cct, "Journaler::thread_pool", "tp_journal",
- cct->_conf->rbd_op_threads, "rbd_op_threads");
+ cct->_conf->get_val<int64_t>("rbd_op_threads"),
+ "rbd_op_threads");
thread_pool->start();
work_queue = new ContextWQ("Journaler::work_queue",
- cct->_conf->rbd_op_thread_timeout, thread_pool);
+ cct->_conf->get_val<int64_t>("rbd_op_thread_timeout"),
+ thread_pool);
timer = new SafeTimer(cct, timer_lock, true);
timer->init();