[sr-dev] git:master:770c914d: nsq: initialize all workers with rank PROC_XWORKER

[Ovidiu Sas]

Module: kamailio
Branch: master
Commit: 770c914d3636cfafccc4931f18aa804efcacbd73
URL: https://github.com/kamailio/kamailio/commit/770c914d3636cfafccc4931f18aa804efcacbd73

Author: Ovidiu Sas <osas at voipembedded.com>
Committer: Ovidiu Sas <osas at 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/770c914d3636cfafccc4931f18aa804efcacbd73.diff
Patch: https://github.com/kamailio/kamailio/commit/770c914d3636cfafccc4931f18aa804efcacbd73.patch

---

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){