Module: kamailio Branch: master Commit: 770c914d3636cfafccc4931f18aa804efcacbd73 URL: https://github.com/kamailio/kamailio/commit/770c914d3636cfafccc4931f18aa804e...
Author: Ovidiu Sas osas@voipembedded.com Committer: Ovidiu Sas osas@voipembedded.com Date: 2017-02-09T15:24:07-05:00
nsq: initialize all workers with rank PROC_XWORKER - closes GH #975
---
Modified: src/modules/nsq/nsq_mod.c
---
Diff: https://github.com/kamailio/kamailio/commit/770c914d3636cfafccc4931f18aa804e... Patch: https://github.com/kamailio/kamailio/commit/770c914d3636cfafccc4931f18aa804e...
---
diff --git a/src/modules/nsq/nsq_mod.c b/src/modules/nsq/nsq_mod.c index 33db67a..cf6c978 100644 --- a/src/modules/nsq/nsq_mod.c +++ b/src/modules/nsq/nsq_mod.c @@ -314,7 +314,7 @@ static int mod_child_init(int rank) if (tc == NULL) { LM_ERR("topic and channel not set, using defaults\n"); for(i = 0; i < workers; i++) { - pid=fork_process(i+1, "NSQ Consumer Worker", 1); + pid=fork_process(PROC_XWORKER, "NSQ Consumer Worker", 1); if (pid<0) return -1; /* error */ if (pid==0){ @@ -325,7 +325,7 @@ static int mod_child_init(int rank) } else { while (tc) { for(i = 0; i < workers; i++) { - pid=fork_process(i+1, "NSQ Consumer Worker", 1); + pid=fork_process(PROC_XWORKER, "NSQ Consumer Worker", 1); if (pid<0) return -1; /* error */ if (pid==0){
-
Ovidiu Sas