Module: sip-router
Branch: master
Commit: 879aec4c22202d86b1abf75c428221e72e0a85c5
URL:
http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=879aec4…
Author: Daniel-Constantin Mierla <miconda(a)gmail.com>
Committer: Daniel-Constantin Mierla <miconda(a)gmail.com>
Date: Mon Apr 14 15:37:33 2014 +0200
async: allow module to start without internal async timer procs
- async_route() and async_sleep() will return false
- useful when only async_task_route() is used
---
modules/async/async_mod.c | 18 ++++++++++++++++++
1 files changed, 18 insertions(+), 0 deletions(-)
diff --git a/modules/async/async_mod.c b/modules/async/async_mod.c
index cc838f8..89f204d 100644
--- a/modules/async/async_mod.c
+++ b/modules/async/async_mod.c
@@ -100,6 +100,9 @@ static int mod_init(void)
return -1;
}
+ if(async_workers<=0)
+ return 0;
+
if(async_init_timer_list()<0) {
LM_ERR("cannot initialize internal structure\n");
return -1;
@@ -118,6 +121,9 @@ static int child_init(int rank)
if (rank!=PROC_MAIN)
return 0;
+ if(async_workers<=0)
+ return 0;
+
if(fork_dummy_timer(PROC_TIMER, "ASYNC MOD TIMER", 1 /*socks flag*/,
async_timer_exec, NULL, 1 /*sec*/)<0) {
LM_ERR("failed to register timer routine as process\n");
@@ -145,6 +151,12 @@ static int w_async_sleep(struct sip_msg* msg, char* sec, char* str2)
if(msg==NULL)
return -1;
+ if(async_workers<=0)
+ {
+ LM_ERR("no async mod timer wokers\n");
+ return -1;
+ }
+
ap = (async_param_t*)sec;
if(fixup_get_ivalue(msg, ap->pinterval, &s)!=0)
{
@@ -203,6 +215,12 @@ static int w_async_route(struct sip_msg* msg, char* rt, char* sec)
if(msg==NULL)
return -1;
+ if(async_workers<=0)
+ {
+ LM_ERR("no async mod timer wokers\n");
+ return -1;
+ }
+
if(fixup_get_svalue(msg, (gparam_t*)rt, &rn)!=0)
{
LM_ERR("no async route block name\n");