sheep: create correct work queues

Signed-off-by: Hitoshi Mitake <mitake.hitoshi@lab.ntt.co.jp> (cherry picked from commit 4f967e9)
sheepdog · Jan 24, 2017 · d7d692e · d7d692e
1 parent d2b2cbd
commit d7d692e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sheep/sheep.c b/sheep/sheep.c
@@ -539,14 +539,14 @@ static int create_work_queues(void)
 		sys->io_wqueue = create_fixed_work_queue("io", wq_io_threads);
 	} else {
 		sd_info("io workqueue is created as unlimited, it is not recommended!");
-		sys->io_wqueue = create_fixed_work_queue("io", WQ_UNLIMITED);
+		sys->io_wqueue = create_work_queue("io", WQ_UNLIMITED);
 	}
 	if (wq_recovery_threads) {
 		sd_info("# of threads in rw workqueue: %d", wq_recovery_threads);
 		sys->recovery_wqueue = create_fixed_work_queue("rw", wq_recovery_threads);
 	} else {
 		sd_info("recovery workqueue is created as unlimited, it is not recommended!");
-		sys->recovery_wqueue = create_fixed_work_queue("rw", WQ_UNLIMITED);
+		sys->recovery_wqueue = create_work_queue("rw", WQ_UNLIMITED);
 	}
 	sys->deletion_wqueue = create_ordered_work_queue("deletion");
 	sys->block_wqueue = create_ordered_work_queue("block");
@@ -556,7 +556,7 @@ static int create_work_queues(void)
 		sys->areq_wqueue = create_fixed_work_queue("async_req", wq_async_threads);
 	} else {
 		sd_info("async_req workqueue is created as unlimited, it is not recommended!");
-		sys->areq_wqueue = create_fixed_work_queue("async_req", WQ_UNLIMITED);
+		sys->areq_wqueue = create_work_queue("async_req", WQ_UNLIMITED);
 	}
 	if (sys->enable_object_cache) {
 		sys->oc_reclaim_wqueue =