This patch enables us to use signal in cluster drivers.

Signed-off-by: MORITA Kazutaka <[email protected]>
---
 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

-- 
sheepdog mailing list
[email protected]
http://lists.wpkg.org/mailman/listinfo/sheepdog

Reply via email to