Module: sip-router
Branch: master
Commit: 9e6af79d0cf1b0e10694880147a28966313fb5a4
URL:    
http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=9e6af79d0cf1b0e10694880147a28966313fb5a4

Author: Richard Fuchs <[email protected]>
Committer: Richard Fuchs <[email protected]>
Date:   Wed Mar 27 13:30:05 2013 -0400

rtpproxy: add missing wrapper function for unforce_rtp_proxy

---

 modules/rtpproxy/rtpproxy.c |   40 +++++++++++++++++++++++++---------------
 1 files changed, 25 insertions(+), 15 deletions(-)

diff --git a/modules/rtpproxy/rtpproxy.c b/modules/rtpproxy/rtpproxy.c
index 3169fbc..169bca9 100644
--- a/modules/rtpproxy/rtpproxy.c
+++ b/modules/rtpproxy/rtpproxy.c
@@ -283,7 +283,8 @@ static int alter_mediaport(struct sip_msg *, str *, str *, 
str *, int);
 static int alter_rtcp(struct sip_msg *msg, str *body, str *oldport, str 
*newport);
 static char *gencookie();
 static int rtpp_test(struct rtpp_node*, int, int);
-static int unforce_rtp_proxy_f(struct sip_msg *, char *, char *);
+static int unforce_rtp_proxy1_f(struct sip_msg *, char *, char *);
+static int unforce_rtp_proxy(struct sip_msg *, char *);
 static int force_rtp_proxy(struct sip_msg *, char *, char *, int, int);
 static int start_recording_f(struct sip_msg *, char *, char *);
 static int rtpproxy_answer1_f(struct sip_msg *, char *, char *);
@@ -359,16 +360,16 @@ static cmd_export_t cmds[] = {
        {"set_rtp_proxy_set",  (cmd_function)set_rtp_proxy_set_f,    1,
                fixup_set_id, 0,
                ANY_ROUTE},
-       {"unforce_rtp_proxy",  (cmd_function)unforce_rtp_proxy_f,    0,
+       {"unforce_rtp_proxy",  (cmd_function)unforce_rtp_proxy1_f,   0,
                0, 0,
                ANY_ROUTE},
-       {"rtpproxy_destroy",   (cmd_function)unforce_rtp_proxy_f,    0,
+       {"rtpproxy_destroy",   (cmd_function)unforce_rtp_proxy1_f,   0,
                0, 0,
                ANY_ROUTE},
-       {"unforce_rtp_proxy",  (cmd_function)unforce_rtp_proxy_f,    1,
+       {"unforce_rtp_proxy",  (cmd_function)unforce_rtp_proxy1_f,   1,
                fixup_spve_null, 0,
                ANY_ROUTE},
-       {"rtpproxy_destroy",   (cmd_function)unforce_rtp_proxy_f,    1,
+       {"rtpproxy_destroy",   (cmd_function)unforce_rtp_proxy1_f,   1,
                fixup_spve_null, 0,
                ANY_ROUTE},
        {"start_recording",    (cmd_function)start_recording_f,      0,
@@ -1800,7 +1801,21 @@ get_extra_id(struct sip_msg* msg, str *id_str) {
 
 
 static int
-unforce_rtp_proxy_f(struct sip_msg* msg, char* str1, char* str2)
+unforce_rtp_proxy1_f(struct sip_msg* msg, char* str1, char* str2)
+{
+       str flags;
+
+       if (str1)
+               get_str_fparam(&flags, msg, (fparam_t *) str1);
+       else
+               flags.s = NULL;
+
+       return unforce_rtp_proxy(msg, flags.s);
+}
+
+
+static int
+unforce_rtp_proxy(struct sip_msg* msg, char* flags)
 {
        str callid, from_tag, to_tag, viabranch;
        char *cp;
@@ -1810,16 +1825,11 @@ unforce_rtp_proxy_f(struct sip_msg* msg, char* str1, 
char* str2)
        str extra_id;
        int ret;
        struct rtpp_node *node;
-       str flags;
        struct iovec v[1 + 4 + 3 + 2] = {{NULL, 0}, {"D", 1}, {" ", 1}, {NULL, 
0}, {NULL, 0}, {NULL, 0}, {" ", 1}, {NULL, 0}, {" ", 1}, {NULL, 0}};
                                                    /* 1 */   /* 2 */   /* 3 */ 
   /* 4 */    /* 5 */    /* 6 */   /* 7 */    /* 8 */   /* 9 */
 
-       if (str1)
-               get_str_fparam(&flags, msg, (fparam_t *) str1);
-       else
-               flags.s = NULL;
 
-       for (cp = flags.s; cp && *cp; cp++) {
+       for (cp = flags; cp && *cp; cp++) {
                switch (*cp) {
                        case '1':
                                via = 1;
@@ -1982,7 +1992,7 @@ rtpproxy_manage(struct sip_msg *msg, char *flags, char 
*ip)
                return -1;
 
        if(method==METHOD_CANCEL || method==METHOD_BYE)
-               return unforce_rtp_proxy_f(msg, flags, 0);
+               return unforce_rtp_proxy(msg, flags);
 
        if(ip==NULL)
        {
@@ -2008,13 +2018,13 @@ rtpproxy_manage(struct sip_msg *msg, char *flags, char 
*ip)
                                        && tmb.t_gett()!=T_UNDEFINED)
                                tmb.t_gett()->uas.request->msg_flags |= 
FL_SDP_BODY;
                        if(route_type==FAILURE_ROUTE)
-                               return unforce_rtp_proxy_f(msg, flags, 0);
+                               return unforce_rtp_proxy(msg, flags);
                        return force_rtp_proxy(msg, flags, (cp!=NULL)?newip:ip, 
1,
                                        (ip!=NULL)?1:0);
                }
        } else if(msg->first_line.type == SIP_REPLY) {
                if(msg->first_line.u.reply.statuscode>=300)
-                       return unforce_rtp_proxy_f(msg, flags, 0);
+                       return unforce_rtp_proxy(msg, flags);
                if(nosdp==0) {
                        if(method==METHOD_UPDATE)
                                return force_rtp_proxy(msg, flags, 
(cp!=NULL)?newip:ip, 0,


_______________________________________________
sr-dev mailing list
[email protected]
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev

Reply via email to