Module: sip-router Branch: master Commit: a3aa242c94be4c37f1589422634925c1b60eab05 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=a3aa242… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Sat Apr 18 18:10:13 2009 +0200 mi_datagram: start extra processes using SR mode - datagram listeners started in PROC_MAIN --- modules_k/mi_datagram/mi_datagram.c | 33 ++++++++++++++++++++++++++++++++- 1 files changed, 32 insertions(+), 1 deletions(-) diff --git a/modules_k/mi_datagram/mi_datagram.c b/modules_k/mi_datagram/mi_datagram.c index c186d33..000a0a3 100644 --- a/modules_k/mi_datagram/mi_datagram.c +++ b/modules_k/mi_datagram/mi_datagram.c @@ -55,6 +55,7 @@ #include "../../mem/shm_mem.h" #include "../../lib/kmi/mi.h" #include "../../ip_addr.h" +#include "../../pt.h" #include "mi_datagram.h" #include "datagram_fnc.h" #include "mi_datagram_parser.h" @@ -208,7 +209,7 @@ static int mi_mod_init(void) return -1; } mi_socket_domain = host->h_addrtype; - return 0; + goto done; } /* in case of a Unix socket*/ LM_DBG("we have an UNIX socket\n"); @@ -249,18 +250,48 @@ static int mi_mod_init(void) mi_dtgram_addr.unix_addr.sun_family = AF_LOCAL; memcpy( mi_dtgram_addr.unix_addr.sun_path, mi_socket, strlen(mi_socket)); +done: + /* add space for extra processes */ + register_procs(mi_procs[0].no); + return 0; } static int mi_child_init(int rank) { + int i; + int pid; + if (rank==PROC_TIMER || rank>0 ) { if(mi_datagram_writer_init( DATAGRAM_SOCK_BUF_SIZE , mi_reply_indent )!= 0) { LM_CRIT("failed to initiate mi_datagram_writer\n"); return -1; } } + if (rank==PROC_MAIN) { + if(pre_datagram_process()!=0) + { + LM_ERR("pre-fork function failed\n"); + return -1; + } + for(i=0; i<mi_procs[0].no; i++) + { + pid=fork_process(100, "MI DATAGRAM", 1); + if (pid<0) + return -1; /* error */ + if(pid==0) { + /* child */ + datagram_process(1); + return 0; + } + } + if(post_datagram_process()!=0) + { + LM_ERR("post-fork function failed\n"); + return -1; + } + } return 0; }