[Sheepdog] [PATCH 1/4] sheep: initialize workqueues just before event_loop()

[MORITA Kazutaka]

This patch enables us to use signal in cluster drivers.

Signed-off-by: MORITA Kazutaka <morita.kazutaka at lab.ntt.co.jp>
---
 sheep/sheep.c |   18 +++++++++---------
 1 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/sheep/sheep.c b/sheep/sheep.c
index 833a5cb..ad2e515 100644
--- a/sheep/sheep.c
+++ b/sheep/sheep.c
@@ -194,15 +194,6 @@ int main(int argc, char **argv)
 	if (ret)
 		exit(1);
 
-	sys->cpg_wqueue = init_work_queue(1);
-	sys->gateway_wqueue = init_work_queue(NR_GW_WORKER_THREAD);
-	sys->io_wqueue = init_work_queue(NR_IO_WORKER_THREAD);
-	sys->recovery_wqueue = init_work_queue(1);
-	sys->deletion_wqueue = init_work_queue(1);
-	if (!sys->cpg_wqueue || !sys->gateway_wqueue || !sys->io_wqueue ||
-	    !sys->recovery_wqueue || !sys->deletion_wqueue)
-		exit(1);
-
 	ret = create_listen_port(port, sys);
 	if (ret)
 		exit(1);
@@ -213,6 +204,15 @@ int main(int argc, char **argv)
 		exit(1);
 	}
 
+	sys->cpg_wqueue = init_work_queue(1);
+	sys->gateway_wqueue = init_work_queue(NR_GW_WORKER_THREAD);
+	sys->io_wqueue = init_work_queue(NR_IO_WORKER_THREAD);
+	sys->recovery_wqueue = init_work_queue(1);
+	sys->deletion_wqueue = init_work_queue(1);
+	if (!sys->cpg_wqueue || !sys->gateway_wqueue || !sys->io_wqueue ||
+	    !sys->recovery_wqueue || !sys->deletion_wqueue)
+		exit(1);
+
 	vprintf(SDOG_NOTICE, "Sheepdog daemon (version %s) started\n", PACKAGE_VERSION);
 
 	while (sys->status != SD_STATUS_SHUTDOWN || sys->nr_outstanding_reqs != 0)
-- 
1.7.2.5