mi_datagram: update cfg framework structures in extra MI processes

modules_k/mi_datagram/datagram_fnc.c

@@ -48,6 +48,7 @@
 #include <signal.h>
 
 #include "../../resolve.h"
+#include "../../cfg/cfg_struct.h"
 #include "mi_datagram.h"
 #include "datagram_fnc.h"
 #include "mi_datagram_parser.h"
@@ -435,6 +436,9 @@ void mi_datagram_server(int rx_sock, int tx_sock)
 	f = 0;
 
 	while(1) { /*read the datagram*/
+		/* update the local config framework structures */
+		cfg_update();
+
 		memset(mi_buf, 0, DATAGRAM_SOCK_BUF_SIZE);
 		reply_addr_len = sizeof(reply_addr);
 

modules_k/mi_datagram/mi_datagram.c

@@ -56,6 +56,7 @@
 #include "../../lib/kmi/mi.h"
 #include "../../ip_addr.h"
 #include "../../pt.h"
+#include "../../cfg/cfg_struct.h"
 #include "mi_datagram.h"
 #include "datagram_fnc.h"
 #include "mi_datagram_parser.h"
@@ -253,6 +254,8 @@ static int mi_mod_init(void)
 done:
 	/* add space for extra processes */
 	register_procs(mi_procs[0].no);
+	/* add child to update local config framework structures */
+	cfg_register_child(mi_procs[0].no);
 
 	return 0;
 }
@@ -282,6 +285,11 @@ static int mi_child_init(int rank)
 				return -1; /* error */
 			if(pid==0) {
 				/* child */
+
+				/* initialize the config framework */
+				if (cfg_child_init())
+					return -1;
+
 				datagram_process(i);
 				return 0;
 			}