Module: sip-router Branch: master Commit: 1f63d8d3e619ec1e9a0d15f45c507547a72dc715 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=1f63d8d… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Thu Nov 3 11:48:30 2011 +0100 dispatcher(k): fixed copy&paste typo of maintaining inactive state - instead of setting the inactive state, it was resetting it - restructured the usage of fake msg for running event routes for keepalive replies, so that it is generated only if event routes are defined --- modules_k/dispatcher/dispatch.c | 57 ++++++++++++++++++++------------------- 1 files changed, 29 insertions(+), 28 deletions(-) diff --git a/modules_k/dispatcher/dispatch.c b/modules_k/dispatcher/dispatch.c index 11c3523..7aa33fd 100644 --- a/modules_k/dispatcher/dispatch.c +++ b/modules_k/dispatcher/dispatch.c @@ -103,7 +103,7 @@ int *next_idx = NULL; #define _ds_list (ds_lists[*crt_idx]) #define _ds_list_nr (*ds_list_nr) -static void ds_run_route(struct sip_msg *msg, char *route); +static void ds_run_route(struct sip_msg *msg, str *uri, char *route); void destroy_list(int); @@ -2020,8 +2020,8 @@ int ds_update_state(sip_msg_t *msg, int group, str *address, int state) { /* old state is inactive, new state is trying => keep it inactive * - it has to go first to active state and then to trying */ - state &= ~ DS_TRYING_DST; - state |= ~ DS_INACTIVE_DST; + state &= ~(DS_TRYING_DST); + state |= DS_INACTIVE_DST; } /* set the new states */ @@ -2047,11 +2047,11 @@ int ds_update_state(sip_msg_t *msg, int group, str *address, int state) if (!ds_skip_dst(old_state) && ds_skip_dst(idx->dlist[i].flags)) { - ds_run_route(msg, "dispatcher:dst-down"); + ds_run_route(msg, address, "dispatcher:dst-down"); } else { if(ds_skip_dst(old_state) && !ds_skip_dst(idx->dlist[i].flags)) - ds_run_route(msg, "dispatcher:dst-up"); + ds_run_route(msg, address, "dispatcher:dst-up"); } return 0; @@ -2062,12 +2062,11 @@ int ds_update_state(sip_msg_t *msg, int group, str *address, int state) return -1; } -static void ds_run_route(struct sip_msg *msg, char *route) +static void ds_run_route(sip_msg_t *msg, str *uri, char *route) { - int rt, backup_rt = get_route_type(); + int rt, backup_rt; struct run_act_ctx ctx; - - LM_DBG("ds_run_route\n"); + sip_msg_t *fmsg; if (route == NULL) { @@ -2075,6 +2074,8 @@ static void ds_run_route(struct sip_msg *msg, char *route) return; } + LM_DBG("ds_run_route\n"); + rt = route_get(&event_rt, route); if (rt < 0 || event_rt.rlist[rt] == NULL) { @@ -2082,6 +2083,21 @@ static void ds_run_route(struct sip_msg *msg, char *route) return; } + if(msg==NULL) + { + if (faked_msg_init() < 0) + { + LM_ERR("faked_msg_init() failed\n"); + return; + } + fmsg = faked_msg_next(); + fmsg->parsed_orig_ruri_ok = 0; + fmsg->new_uri = *uri; + } else { + fmsg = msg; + } + + backup_rt = get_route_type(); set_route_type(REQUEST_ROUTE); init_run_actions_ctx(&ctx); run_top_route(event_rt.rlist[rt], msg, 0); @@ -2303,7 +2319,7 @@ static void ds_options_callback( struct cell *t, int type, { int group = 0; str uri = {0, 0}; - struct sip_msg *fmsg; + sip_msg_t *fmsg; int state; /* The Param does contain the group, in which the failed host @@ -2314,6 +2330,9 @@ static void ds_options_callback( struct cell *t, int type, " with code %d\n", ps->code); return; } + + fmsg = NULL; + /* The param is a (void*) Pointer, so we need to dereference it and * cast it to an int. */ group = (int)(long)(*ps->param); @@ -2329,15 +2348,6 @@ static void ds_options_callback( struct cell *t, int type, * We accept both a "200 OK" or the configured reply as a valid response */ if((ps->code>=200 && ps->code<=299) || ds_ping_check_rplcode(ps->code)) { - if (faked_msg_init() < 0) - { - LM_ERR("faked_msg_init() failed\n"); - return; - } - fmsg = faked_msg_next(); - fmsg->parsed_orig_ruri_ok = 0; - fmsg->new_uri = uri; - /* Set the according entry back to "Active" */ state = 0; if (ds_probing_mode==DS_PROBE_ALL) @@ -2352,15 +2362,6 @@ static void ds_options_callback( struct cell *t, int type, if (ds_probing_mode!=DS_PROBE_NONE) state |= DS_PROBING_DST; - if (faked_msg_init() < 0) - { - LM_ERR("faked_msg_init() failed\n"); - return; - } - fmsg = faked_msg_next(); - fmsg->parsed_orig_ruri_ok = 0; - fmsg->new_uri = uri; - if (ds_update_state(fmsg, group, &uri, state) != 0) { LM_ERR("Setting the probing state failed (%.*s, group %d)\n",