[sr-dev] git:5.0:453e3bb9: kazoo: initialize all workers with rank PROC_XWORKER

Ovidiu Sas osas at voipembedded.com
Sat Feb 11 03:01:58 CET 2017


Module: kamailio
Branch: 5.0
Commit: 453e3bb987d9e72f2ecc814e603bd1dc1bda78ed
URL: https://github.com/kamailio/kamailio/commit/453e3bb987d9e72f2ecc814e603bd1dc1bda78ed

Author: Ovidiu Sas <osas at voipembedded.com>
Committer: Ovidiu Sas <osas at voipembedded.com>
Date: 2017-02-10T21:01:33-05:00

kazoo: initialize all workers with rank PROC_XWORKER
 - closes GH #972

(cherry picked from commit b66df87adde282c3eaa7ab793c598bfe67f8f9a1)

---

Modified: src/modules/kazoo/kazoo.c

---

Diff:  https://github.com/kamailio/kamailio/commit/453e3bb987d9e72f2ecc814e603bd1dc1bda78ed.diff
Patch: https://github.com/kamailio/kamailio/commit/453e3bb987d9e72f2ecc814e603bd1dc1bda78ed.patch

---

diff --git a/src/modules/kazoo/kazoo.c b/src/modules/kazoo/kazoo.c
index 8c44391..ee4213f 100644
--- a/src/modules/kazoo/kazoo.c
+++ b/src/modules/kazoo/kazoo.c
@@ -369,7 +369,7 @@ static int mod_child_init(int rank)
 		*/
 
 		for(i=0; i < dbk_consumer_workers; i++) {
-			pid=fork_process(i+1, "AMQP Consumer Worker", 1);
+			pid=fork_process(PROC_XWORKER, "AMQP Consumer Worker", 1);
 			if (pid<0)
 				return -1; /* error */
 			if(pid==0){




More information about the sr-dev mailing list