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

Author: Daniel-Constantin Mierla <[email protected]>
Committer: Daniel-Constantin Mierla <[email protected]>
Date: 2016-01-21T14:36:45+01:00

core: start wtimer

---

Modified: main.c

---

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

---

diff --git a/main.c b/main.c
index da30f12..bc1e07c 100644
--- a/main.c
+++ b/main.c
@@ -132,6 +132,7 @@
 #include "sock_ut.h"
 #include "async_task.h"
 #include "dset.h"
+#include "timer_proc.h"
 
 #ifdef DEBUG_DMALLOC
 #include <dmalloc.h>
@@ -1302,6 +1303,7 @@ int main_loop(void)
                cfg_register_child(
                                1   /* main = udp listener */
                                + 1 /* timer */
+                               + 1 /* wtimer */
 #ifdef USE_SLOW_TIMER
                                + 1 /* slow timer */
 #endif
@@ -1371,6 +1373,10 @@ int main_loop(void)
                                }else{
                                }
 
+               if(sr_wtimer_start()<0) {
+                       LM_CRIT("Cannot start wtimer\n");
+                       goto error;
+               }
                /* main process, receive loop */
                process_no=0; /*main process number*/
                pt[process_no].pid=getpid();
@@ -1402,6 +1408,7 @@ int main_loop(void)
                 * will be added later.) */
                cfg_register_child(
                                1   /* timer */
+                               + 1   /* wtimer */
 #ifdef USE_SLOW_TIMER
                                + 1 /* slow timer */
 #endif
@@ -1664,6 +1671,10 @@ int main_loop(void)
                        if (arm_timer()<0) goto error;
                        timer_main();
                }
+               if(sr_wtimer_start()<0) {
+                       LM_CRIT("Cannot start wtimer\n");
+                       goto error;
+               }
 
        /* init childs with rank==MAIN before starting tcp main (in case they 
want
         * to fork  a tcp capable process, the corresponding tcp. comm. fds in
@@ -1788,6 +1799,7 @@ static int calc_proc_no(void)
 #ifdef USE_SLOW_TIMER
                + 1 /* slow timer process */
 #endif
+               + 1 /* wtimer process */
 #ifdef USE_TCP
                +((!tcp_disable)?( 1/* tcp main */ + tcp_listeners ):0)
 #endif
@@ -1911,6 +1923,7 @@ int main(int argc, char** argv)
 #ifdef USE_TCP
        init_tcp_options(); /* set the defaults before the config */
 #endif
+
        /* process command line (cfg. file path etc) */
        optind = 1;  /* reset getopt */
        /* switches required before script processing */
@@ -2449,6 +2462,12 @@ int main(int argc, char** argv)
                LM_CRIT("could not initialize timer, exiting...\n");
                goto error;
        }
+       /* init wtimer */
+       if(sr_wtimer_init()<0) {
+               LM_CRIT("could not initialize wtimer, exiting...\n");
+               goto error;
+       }
+
 #ifdef USE_DNS_CACHE
        if (init_dns_cache()<0){
                LM_CRIT("could not initialize the dns cache, exiting...\n");


_______________________________________________
sr-dev mailing list
[email protected]
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev

Reply via email to