Jelajahi Sumber

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

(cherry picked from commit b66df87adde282c3eaa7ab793c598bfe67f8f9a1)

Ovidiu Sas 8 tahun lalu
induk
melakukan
453e3bb987
1 mengubah file dengan 1 tambahan dan 1 penghapusan
  1. 1 1
      src/modules/kazoo/kazoo.c

+ 1 - 1
src/modules/kazoo/kazoo.c

@@ -369,7 +369,7 @@ static int mod_child_init(int rank)
 		*/
 		*/
 
 
 		for(i=0; i < dbk_consumer_workers; i++) {
 		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)
 			if (pid<0)
 				return -1; /* error */
 				return -1; /* error */
 			if(pid==0){
 			if(pid==0){