summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBenny Prijono <bennylp@teluu.com>2007-08-01 11:38:14 +0000
committerBenny Prijono <bennylp@teluu.com>2007-08-01 11:38:14 +0000
commitc479ca464b0a7717a5579d0fd9d295502ff146ce (patch)
tree7fcc15222bac4518acbbf3f17d38b509e58f34fe
parent483a106bd1476d3eb0a2168854318cfef4716b35 (diff)
Fixed ticket #359: Wrong Via branch generation in proxy causing the same branch value to be generated for RFC 2543 clients (thanks Helmut Wolf)
git-svn-id: http://svn.pjsip.org/repos/pjproject/trunk@1411 74dad513-b988-da41-8d7b-12977e46ad98
-rw-r--r--pjsip-apps/src/samples/proxy.h24
-rw-r--r--pjsip/src/pjsip/sip_util_proxy.c39
2 files changed, 55 insertions, 8 deletions
diff --git a/pjsip-apps/src/samples/proxy.h b/pjsip-apps/src/samples/proxy.h
index 8eef92ba..65ccd198 100644
--- a/pjsip-apps/src/samples/proxy.h
+++ b/pjsip-apps/src/samples/proxy.h
@@ -235,7 +235,9 @@ static pj_status_t init_stack(void)
static pj_status_t init_proxy(void)
{
- pj_in_addr addr;
+ pj_in_addr pri_addr;
+ pj_in_addr addr_list[16];
+ unsigned addr_cnt = PJ_ARRAY_SIZE(addr_list);
unsigned i;
/* List all names matching local endpoint.
@@ -248,16 +250,32 @@ static pj_status_t init_proxy(void)
/* The first address is important since this would be the one
* to be added in Record-Route.
*/
- if (pj_gethostip(&addr) == PJ_SUCCESS) {
+ if (pj_gethostip(&pri_addr)==PJ_SUCCESS) {
pj_strdup2(global.pool, &global.name[global.name_cnt].host,
- pj_inet_ntoa(addr));
+ pj_inet_ntoa(pri_addr));
global.name[global.name_cnt].port = global.port;
global.name_cnt++;
}
+ /* Get the rest of IP interfaces */
+ if (pj_enum_ip_interface(&addr_cnt, addr_list) == PJ_SUCCESS) {
+ for (i=0; i<addr_cnt; ++i) {
+
+ if (addr_list[i].s_addr == pri_addr.s_addr)
+ continue;
+
+ pj_strdup2(global.pool, &global.name[global.name_cnt].host,
+ pj_inet_ntoa(addr_list[i]));
+ global.name[global.name_cnt].port = global.port;
+ global.name_cnt++;
+ }
+ }
+
+ /* No need to add this, this should have been added above.
global.name[global.name_cnt].host = pj_str("127.0.0.1");
global.name[global.name_cnt].port = global.port;
global.name_cnt++;
+ */
global.name[global.name_cnt].host = *pj_gethostname();
global.name[global.name_cnt].port = global.port;
diff --git a/pjsip/src/pjsip/sip_util_proxy.c b/pjsip/src/pjsip/sip_util_proxy.c
index 47b64995..6cf44d44 100644
--- a/pjsip/src/pjsip/sip_util_proxy.c
+++ b/pjsip/src/pjsip/sip_util_proxy.c
@@ -23,6 +23,7 @@
#include <pj/assert.h>
#include <pj/ctype.h>
#include <pj/except.h>
+#include <pj/guid.h>
#include <pj/pool.h>
#include <pj/string.h>
#include <pjlib-util/md5.h>
@@ -42,6 +43,7 @@
*
* @return PJ_SUCCESS on success.
*/
+/*
PJ_DEF(pj_status_t) pjsip_endpt_clone_msg( pjsip_endpoint *endpt,
const pjsip_rx_data *rdata,
pjsip_tx_data **p_tdata)
@@ -61,6 +63,7 @@ PJ_DEF(pj_status_t) pjsip_endpt_clone_msg( pjsip_endpoint *endpt,
return PJ_SUCCESS;
}
+*/
/*
@@ -335,6 +338,31 @@ PJ_DEF(pj_str_t) pjsip_calculate_branch_id( pjsip_rx_data *rdata )
pj_md5_context ctx;
pj_uint8_t digest[16];
pj_str_t branch;
+ pj_str_t rfc3261_branch = {PJSIP_RFC3261_BRANCH_ID,
+ PJSIP_RFC3261_BRANCH_LEN};
+
+ /* If incoming request does not have RFC 3261 branch value, create
+ * a branch value from GUID .
+ */
+ if (pj_strncmp(&rdata->msg_info.via->branch_param,
+ &rfc3261_branch, PJSIP_RFC3261_BRANCH_LEN) != 0 )
+ {
+ pj_str_t tmp;
+
+ branch.ptr = (char*)
+ pj_pool_alloc(rdata->tp_info.pool, PJSIP_MAX_BRANCH_LEN);
+ branch.slen = PJSIP_RFC3261_BRANCH_LEN;
+ pj_memcpy(branch.ptr, PJSIP_RFC3261_BRANCH_ID,
+ PJSIP_RFC3261_BRANCH_LEN);
+
+ tmp.ptr = branch.ptr + PJSIP_RFC3261_BRANCH_LEN + 2;
+ *(tmp.ptr-2) = (pj_int8_t)(branch.slen+73);
+ *(tmp.ptr-1) = (pj_int8_t)(branch.slen+99);
+ pj_generate_unique_string( &tmp );
+
+ branch.slen = PJSIP_MAX_BRANCH_LEN;
+ return branch;
+ }
/* Create branch ID for new request by calculating MD5 hash
* of the branch parameter in top-most Via header.
@@ -346,12 +374,13 @@ PJ_DEF(pj_str_t) pjsip_calculate_branch_id( pjsip_rx_data *rdata )
branch.ptr = (char*)
pj_pool_alloc(rdata->tp_info.pool,
- 32 + PJSIP_RFC3261_BRANCH_LEN);
+ 34 + PJSIP_RFC3261_BRANCH_LEN);
pj_memcpy(branch.ptr, PJSIP_RFC3261_BRANCH_ID, PJSIP_RFC3261_BRANCH_LEN);
-
- digest2str(digest, branch.ptr+PJSIP_RFC3261_BRANCH_LEN);
-
- branch.slen = 32 + PJSIP_RFC3261_BRANCH_LEN;
+ branch.slen = PJSIP_RFC3261_BRANCH_LEN;
+ *(branch.ptr+PJSIP_RFC3261_BRANCH_LEN) = (pj_int8_t)(branch.slen+73);
+ *(branch.ptr+PJSIP_RFC3261_BRANCH_LEN+1) = (pj_int8_t)(branch.slen+99);
+ digest2str(digest, branch.ptr+PJSIP_RFC3261_BRANCH_LEN+2);
+ branch.slen = 34 + PJSIP_RFC3261_BRANCH_LEN;
return branch;
}