Module: kamailio Branch: master Commit: 7bcf8732b2863e0ee572493e3a18bd6a2f6c4a48 URL: https://github.com/kamailio/kamailio/commit/7bcf8732b2863e0ee572493e3a18bd6a...
Author: Andrey Rybkin rybkin.a@bks.tv Committer: Andrey Rybkin rybkin.a@bks.tv Date: 2015-02-03T09:24:22+03:00
dmq: checking already parsed msg
---
Modified: modules/dmq/worker.c
---
Diff: https://github.com/kamailio/kamailio/commit/7bcf8732b2863e0ee572493e3a18bd6a... Patch: https://github.com/kamailio/kamailio/commit/7bcf8732b2863e0ee572493e3a18bd6a...
---
diff --git a/modules/dmq/worker.c b/modules/dmq/worker.c index 0d25968..1f4b37d 100644 --- a/modules/dmq/worker.c +++ b/modules/dmq/worker.c @@ -76,6 +76,7 @@ void worker_loop(int id) dmq_job_t* current_job; peer_reponse_t peer_response; int ret_value; + int not_parsed; dmq_node_t *dmq_node = NULL;
worker = &workers[id]; @@ -92,6 +93,11 @@ void worker_loop(int id) /* job_queue_pop might return NULL if queue is empty */ if(current_job) { /* extract the from uri */ + if (current_job->msg->from->parsed) { + not_parsed = 0; + } else { + not_parsed = 1; + } if (parse_from_header(current_job->msg) < 0) { LM_ERR("bad sip message or missing From hdr\n"); } else { @@ -123,7 +129,7 @@ void worker_loop(int id) del_nonshm_lump_rpl(¤t_job->msg->reply_lump); pkg_free(peer_response.body.s); } - if(current_job->msg->from->parsed){ + if((current_job->msg->from->parsed)&&(not_parsed)){ free_to(current_job->msg->from->parsed); }
-
Andrey Rybkin