TEST(WorkQueue, Resize)
{
- ThreadPool tp(g_ceph_context, "bar", "tp_bar", 2, "osd_peering_wq_threads");
+ ThreadPool tp(g_ceph_context, "bar", "tp_bar", 2, "osd_disk_threads");
tp.start();
sleep(1);
ASSERT_EQ(2, tp.get_num_threads());
- g_conf->set_val("osd peering wq threads", "5");
+ g_conf->set_val("osd disk threads", "5");
g_conf->apply_changes(&cout);
sleep(1);
ASSERT_EQ(5, tp.get_num_threads());
- g_conf->set_val("osd peering wq threads", "3");
+ g_conf->set_val("osd disk threads", "3");
g_conf->apply_changes(&cout);
sleep(1);
ASSERT_EQ(3, tp.get_num_threads());
- g_conf->set_val("osd peering wq threads", "0");
+ g_conf->set_val("osd disk threads", "0");
g_conf->apply_changes(&cout);
sleep(1);
ASSERT_EQ(0, tp.get_num_threads());
- g_conf->set_val("osd peering wq threads", "15");
+ g_conf->set_val("osd disk threads", "15");
g_conf->apply_changes(&cout);
sleep(1);
ASSERT_EQ(15, tp.get_num_threads());
- g_conf->set_val("osd peering wq threads", "-1");
+ g_conf->set_val("osd disk threads", "-1");
g_conf->apply_changes(&cout);
sleep(1);
ASSERT_EQ(15, tp.get_num_threads());