sr-dev April 2009

sr-dev@lists.kamailio.org

13 participants
230 discussions

git:ser_modules: tls: fixed missing TCP_BUF_SIZE
by Andrei Pelinescu-Onciul 23 Apr '09

23 Apr '09

Module: sip-router Branch: ser_modules Commit: 5c0cb12bf52adf2847a1c2e894a8c5e944485c21 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=5c0cb12… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Mon Apr 20 14:16:02 2009 +0000 tls: fixed missing TCP_BUF_SIZE - updated to the dynamic buffers used now for the tcp connections Reported-by: Alfred E. Heggestad, aeh at db org --- modules_s/… [View More]

1 0

git:ser_modules: Merge branch 'cvs-head' of git://git.sip-router.org/ ser_modules into ser_modules
by Andrei Pelinescu-Onciul 23 Apr '09

23 Apr '09

Module: sip-router Branch: ser_modules Commit: 35ce8821dd8065830ac14939fa562ab5e658247a URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=35ce882… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Thu Apr 23 12:48:41 2009 +0200 Merge branch 'cvs-head' of git://git.sip-router.org/ser_modules into ser_modules * 'cvs-head' of git://git.sip-router.org/ser_modules: tls: don't start if tcp is … [View More]

1 0

git:master: * Module: presence
by Juha Heinanen 23 Apr '09

23 Apr '09

Module: sip-router Branch: master Commit: c737bb20f2ce9158bfce6f175c02907acd8b0617 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=c737bb2… Author: Juha Heinanen <jh(a)tutpro.com> Committer: Juha Heinanen <jh(a)tutpro.com> Date: Tue Apr 21 19:30:43 2009 +0300 * Module: presence Introduced a dew function auth_status() that can be used to check from script if a watcher is allowed to subscriber event 'presence' of a presentity. --- modules_k/presence/… [View More]

4 6

git:master: tm: t_check() split into t_check() and t_check_msg()
by Andrei Pelinescu-Onciul 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 85529b2064727b60bddd0eeaecea12f949c0bfad URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=85529b2… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Wed Apr 22 22:47:05 2009 +0200 tm: t_check() split into t_check() and t_check_msg() - split t_check() into t_check() and t_check_msg() (new version, e2e ack detection and different return … [View More]convention) - w_t_check() updated to use t_check_nmsg() --- modules/tm/t_lookup.c | 118 +++++++++++++++++++++++++++++++------------------ modules/tm/t_lookup.h | 10 ++-- modules/tm/tm.c | 2 +- 3 files changed, 81 insertions(+), 49 deletions(-) diff --git a/modules/tm/t_lookup.c b/modules/tm/t_lookup.c index 2528846..8f59e8a 100644 --- a/modules/tm/t_lookup.c +++ b/modules/tm/t_lookup.c @@ -468,11 +468,12 @@ e2eack_found: } -/* function returns: - * negative - transaction wasn't found - * (-2 = possibly e2e ACK matched ) - * positive - transaction found - * It also sets *cancel if there is already a cancel transaction +/** find the transaction corresponding to a request. + * @return - negative - transaction wasn't found (-1) or + * possible e2eACK match (-2). + * 1 - transaction found + * 0 - parse error + * It also sets *cancel if there is already a cancel transaction. */ int t_lookup_request( struct sip_msg* p_msg , int leave_new_locked, @@ -846,8 +847,8 @@ found: -/* Returns 0 - nothing found - * 1 - T found +/** get the transaction corresponding to a reply. + * @return -1 - nothing found, 1 - T found */ int t_reply_matching( struct sip_msg *p_msg , int *p_branch ) { @@ -1037,19 +1038,22 @@ nomatch2: -/* Determine current transaction +/** Determine current transaction (w/ e2eack support). * - * Found Not Found Error (e.g. parsing) - * Return Value 1 0 -1 - * T ptr 0 T_UNDEFINED + * script/t_lookup_request return convention: + * Found Not Found Error (e.g. parsing) E2E ACK + * @return 1 -1 0 -2 + * T ptr 0 T_UNDEFINED| 0 0 */ -int t_check( struct sip_msg* p_msg , int *param_branch ) +int t_check_msg( struct sip_msg* p_msg , int *param_branch ) { int local_branch; int canceled; - + int ret; + + ret=0; /* is T still up-to-date ? */ - DBG("DEBUG: t_check: msg id=%d global id=%d T start=%p\n", + DBG("DEBUG: t_check_msg: msg id=%d global id=%d T start=%p\n", p_msg->id,global_msg_id,T); if ( p_msg->id != global_msg_id || T==T_UNDEFINED ) { @@ -1060,8 +1064,8 @@ int t_check( struct sip_msg* p_msg , int *param_branch ) /* force parsing all the needed headers*/ prefetch_loc_r(p_msg->unparsed+64, 1); if (parse_headers(p_msg, HDR_EOH_F, 0 )==-1) { - LOG(L_ERR, "ERROR: t_check: parsing error\n"); - return -1; + LOG(L_ERR, "ERROR: t_check_msg: parsing error\n"); + goto error; } /* in case, we act as UAS for INVITE and reply with 200, * we will need to run dialog-matching for subsequent @@ -1070,11 +1074,11 @@ int t_check( struct sip_msg* p_msg , int *param_branch ) */ if (p_msg->REQ_METHOD==METHOD_INVITE && parse_from_header(p_msg)==-1) { - LOG(L_ERR, "ERROR: t_check: from parsing failed\n"); - return -1; + LOG(L_ERR, "ERROR: t_check_msg: from parsing failed\n"); + goto error; } - t_lookup_request( p_msg , 0 /* unlock before returning */, - &canceled); + ret=t_lookup_request( p_msg , 0 /* unlock before returning */, + &canceled); } else { /* we need Via for branch and Cseq method to distinguish replies with the same branch/cseqNr (CANCEL) @@ -1090,47 +1094,75 @@ int t_check( struct sip_msg* p_msg , int *param_branch ) } }else if ( parse_headers(p_msg, HDR_VIA1_F|HDR_CSEQ_F, 0 )==-1) { LOG(L_ERR, "ERROR: reply cannot be parsed\n"); - return -1; + goto error; } if ((p_msg->via1==0) || (p_msg->cseq==0)){ - LOG(L_ERR, "ERROR: reply doesn't have a via or cseq header\n"); - return -1; + LOG(L_ERR, "ERROR: reply doesn't have a via or cseq" + " header\n"); + goto error; } /* if that is an INVITE, we will also need to-tag for later ACK matching */ - if ( get_cseq(p_msg)->method.len==INVITE_LEN - && memcmp( get_cseq(p_msg)->method.s, INVITE, INVITE_LEN )==0 ) { - if (parse_headers(p_msg, HDR_TO_F, 0)==-1 - || !p_msg->to) { - LOG(L_ERR, "ERROR: INVITE reply cannot be parsed\n"); - return -1; - } + if ( get_cseq(p_msg)->method.len==INVITE_LEN + && memcmp( get_cseq(p_msg)->method.s, INVITE, INVITE_LEN )==0) + { + if (parse_headers(p_msg, HDR_TO_F, 0)==-1 || !p_msg->to) { + LOG(L_ERR, "ERROR: INVITE reply cannot be parsed\n"); + goto error; + } } - - t_reply_matching( p_msg , - param_branch!=0?param_branch:&local_branch ); - + ret=t_reply_matching( p_msg , + param_branch!=0?param_branch:&local_branch ); } #ifdef EXTRA_DEBUG if ( T && T!=T_UNDEFINED && T->flags & (T_IN_AGONY)) { LOG( L_WARN, "WARNING: transaction %p scheduled for deletion " - "and called from t_check (flags=%x) (but it might be ok)\n", - T, T->flags); + "and called from t_check_msg (flags=%x) (but it might be ok)" + "\n", T, T->flags); } #endif - DBG("DEBUG: t_check: msg id=%d global id=%d T end=%p\n", + DBG("DEBUG: t_check_msg: msg id=%d global id=%d T end=%p\n", p_msg->id,global_msg_id,T); - } else { - if (T) - DBG("DEBUG: t_check: T already found!\n"); - else - DBG("DEBUG: t_check: T previously sought and not found\n"); + } else { /* ( p_msg->id == global_msg_id && T!=T_UNDEFINED ) */ + if (T){ + DBG("DEBUG: t_check_msg: T already found!\n"); + ret=1; + }else{ + DBG("DEBUG: t_check_msg: T previously sought and not found\n"); + ret=-1; + } } + return ret; +error: + return 0; +} + + - return T ? (T==T_UNDEFINED ? -1 : 1 ) : 0; +/** Determine current transaction (old version). + * + * Found Not Found Error (e.g. parsing) + * @return 1 0 -1 + * T ptr 0 T_UNDEFINED | 0 + */ +int t_check( struct sip_msg* p_msg , int *param_branch ) +{ + int ret; + + ret=t_check_msg(p_msg, param_branch); + /* fix t_check_msg return */ + switch(ret){ + case -2: /* e2e ack */ return 0; /* => not found */ + case -1: /* not found */ return 0; /* => not found */ + case 0: /* parse error */ return -1; /* => error */ + case 1: /* found */ return ret; /* => found */ + }; + return ret; } + + int init_rb( struct retr_buf *rb, struct sip_msg *msg) { /*struct socket_info* send_sock;*/ diff --git a/modules/tm/t_lookup.h b/modules/tm/t_lookup.h index 3ac599d..8994999 100644 --- a/modules/tm/t_lookup.h +++ b/modules/tm/t_lookup.h @@ -68,11 +68,11 @@ int add_branch_label( struct cell *trans, int t_unref( struct sip_msg *p_msg); typedef int (*tunref_f)( struct sip_msg *p_msg); -/* function returns: - * -1 - transaction wasn't found - * 1 - transaction found - */ -int t_check( struct sip_msg* , int *branch ); + +/* old t_check version (no e2eack support) */ +int t_check(struct sip_msg* , int *branch ); +/* new version, e2eack and different return convention */ +int t_check_msg(struct sip_msg* , int *branch ); typedef struct cell * (*tgett_f)(void); struct cell *get_t(); diff --git a/modules/tm/tm.c b/modules/tm/tm.c index 538e683..116a363 100644 --- a/modules/tm/tm.c +++ b/modules/tm/tm.c @@ -900,7 +900,7 @@ static int t_check_status(struct sip_msg* msg, char *p1, char *foo) inline static int w_t_check(struct sip_msg* msg, char* str, char* str2) { - return t_check( msg , 0 ) ? 1 : -1; + return (t_check_msg( msg , 0 )==1) ? 1 : -1; } inline static int w_t_lookup_cancel(struct sip_msg* msg, char* str, char* str2) [View Less]

1 0

git:master: tm: added t_check_trans() script function
by Andrei Pelinescu-Onciul 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 51f0810da46d1afe962d2478964fce1afedadd0e URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=51f0810… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Wed Apr 22 23:29:24 2009 +0200 tm: added t_check_trans() script function Added t_check_trans() for compatibility with kamailio scripts. For replies it's equivalent with ser/sr t_lookup_reply(). For … [View More]CANCELs it's equivalent with t_lookup_cancel(). For normal request and ACK to negatives replies is equivalent to the following script snippet: route["t_check_req"]{ if (t_lookup_request()){ if (method=="ACK") # catch ACK to neg. repl. return 1; t_retransmit_reply(); drop; } return 0; } There is no equivalent for e2e ACK matching, but note that this is not safe anyway (a delayed e2e ACK might arrive after the transaction wait time elapses => it will not be matched). Note also that tm matches e2e ACK to proxied transaction only in special cases. It's only safe for e2e ACKs to local transaction. In cooperation with: Daniel-Constantin Mierla <miconda(a)gmail.com>. --- modules/tm/tm.c | 41 +++++++++++++++++++++++++++++++++++++++++ 1 files changed, 41 insertions(+), 0 deletions(-) diff --git a/modules/tm/tm.c b/modules/tm/tm.c index 116a363..ce333a6 100644 --- a/modules/tm/tm.c +++ b/modules/tm/tm.c @@ -235,6 +235,7 @@ static int t_is_expired(struct sip_msg* msg, char*, char*); static int t_grep_status(struct sip_msg* msg, char*, char*); static int w_t_drop_replies(struct sip_msg* msg, char* foo, char* bar); static int w_t_save_lumps(struct sip_msg* msg, char* foo, char* bar); +static int t_check_trans(struct sip_msg* msg, char* foo, char* bar); /* by default the fr timers avps are not set, so that the avps won't be @@ -373,6 +374,8 @@ static cmd_export_t cmds[]={ FAILURE_ROUTE}, {"t_save_lumps", w_t_save_lumps, 0, 0, REQUEST_ROUTE}, + {"t_check_trans", t_check_trans, 0, 0, + REQUEST_ROUTE|ONREPLY_ROUTE|BRANCH_ROUTE }, /* not applicable from the script */ @@ -1725,3 +1728,41 @@ int w_t_reply_wrp(struct sip_msg *m, unsigned int code, char *txt) return w_t_reply(m, (char *)&c, (char*)&r); } + + +/** script function, check if a msg is assoc. to a transaction. + * @return -1 (not), 1 (reply, ack or cancel for an existing transaction), + * 0 (request retransmission) + * Note: the e2e ack matching works only for local e2e acks or for + * transactions with E2EACK* callbacks installed (but even in this + * case matching E2EACKs on proxied transaction is not entirely + * reliable: if the ACK is delayed the proxied transaction might + * be already deleted when it reaches the proxy (wait_timeout)) + */ +static int t_check_trans(struct sip_msg* msg, char* foo, char* bar) +{ + struct cell* t; + + if (msg->first_line.type==SIP_REPLY) + return w_t_check(msg, 0 ,0); + else if (msg->REQ_METHOD==METHOD_CANCEL) + return w_t_lookup_cancel(msg, 0, 0); + else{ + switch(t_check_msg(msg, 0)){ + case -2: /* possible e2e ack */ + return 1; + case 1: /* found */ + if (msg->REQ_METHOD==METHOD_ACK) + /* ack to neg. reply */ + return 1; + /* else retransmission */ + t=get_t(); + t_retransmit_reply(t); + UNREF(t); + set_t(0); + return 0; + } + /* not found or error */ + } + return -1; +} [View Less]

1 0

git:master: libkcore: use atomic_add instead of atomic_sub
by Daniel-Constantin Mierla 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 37b96e540e1c9d96db1659504ffe5cbd5d3fc5c1 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=37b96e5… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Wed Apr 22 18:26:11 2009 +0200 libkcore: use atomic_add instead of atomic_sub - swap parameters of atomic_add to match SR prototype --- lib/kcore/statistics.h | 5 +---- 1 files changed, 1 … [View More]

1 0

git:master: core: print 'udp' in process description for UDP listeners
by Daniel-Constantin Mierla 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 5b905363fcdef865b70b80eea237ffa1f7087ba6 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=5b90536… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Wed Apr 22 18:28:31 2009 +0200 core: print 'udp' in process description for UDP listeners - transport protocol is already printed for tcp, sctp --- main.c | 5 +++-- 1 files changed, 3 … [View More]

1 0

git:master: kex: enable MI command 'ps'
by Daniel-Constantin Mierla 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 84cad0184db30583c428503a5b8a2d83c6378aa8 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=84cad01… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Wed Apr 22 18:27:22 2009 +0200 kex: enable MI command 'ps' - 'ps' prints SR process table --- modules_k/kex/mi_core.c | 6 ++---- 1 files changed, 2 insertions(+), 4 deletions(-) diff --… [View More]

1 0

git:master: perlvdb(k): makefile fix
by Andrei Pelinescu-Onciul 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: 4330d7116162d4ad7389f4bab18e7b52f8fce116 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=4330d71… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Wed Apr 22 17:52:24 2009 +0200 perlvdb(k): makefile fix --- modules_k/perlvdb/Makefile | 6 ++++-- 1 files changed, 4 insertions(+), 2 deletions(-) diff --git a/modules_k/perlvdb/Makefile b/… [View More]

1 0

git:master: perl(k): fixed makefile
by Andrei Pelinescu-Onciul 22 Apr '09

22 Apr '09

Module: sip-router Branch: master Commit: bd3e028334907c3622e1537d337a9938ed355060 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=bd3e028… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Wed Apr 22 17:42:47 2009 +0200 perl(k): fixed makefile --- modules_k/perl/Makefile | 14 ++++---------- 1 files changed, 4 insertions(+), 10 deletions(-) diff --git a/modules_k/perl/Makefile b/… [View More]

1 0

← Newer
1
...
8
9
10
11
12
13
14
...
23
Older →

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev April 2009