[sr-dev] git:master: sdpops: added functions to test the presence of codecs

Module: sip-router Branch: master Commit: 0331f328d1dcdfc7f95fbe1181ec669421184ced URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=0331f32… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Wed Dec 21 13:56:15 2011 +0100 sdpops: added functions to test the presence of codecs - sdp_with_codecs_by_id(idlist) - sdp_with_codecs_by_name(namelist) --- modules/sdpops/sdpops_mod.c | 149 +++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 149 insertions(+), 0 deletions(-) diff --git a/modules/sdpops/sdpops_mod.c b/modules/sdpops/sdpops_mod.c index cfd4ae0..6806c4b 100644 --- a/modules/sdpops/sdpops_mod.c +++ b/modules/sdpops/sdpops_mod.c @@ -44,6 +44,8 @@ static int w_sdp_remove_codecs_by_name(sip_msg_t* msg, char* codecs, char *bar); static int w_sdp_keep_codecs_by_id(sip_msg_t* msg, char* codecs, char *bar); static int w_sdp_keep_codecs_by_name(sip_msg_t* msg, char* codecs, char *bar); static int w_sdp_with_media(sip_msg_t* msg, char* media, char *bar); +static int w_sdp_with_codecs_by_id(sip_msg_t* msg, char* codec, char *bar); +static int w_sdp_with_codecs_by_name(sip_msg_t* msg, char* codec, char *bar); static int w_sdp_print(sip_msg_t* msg, char* level, char *bar); static int mod_init(void); @@ -59,6 +61,10 @@ static cmd_export_t cmds[] = { 1, fixup_spve_null, 0, ANY_ROUTE}, {"sdp_with_media", (cmd_function)w_sdp_with_media, 1, fixup_spve_null, 0, ANY_ROUTE}, + {"sdp_with_codecs_by_id", (cmd_function)w_sdp_with_codecs_by_id, + 1, fixup_spve_null, 0, ANY_ROUTE}, + {"sdp_with_codecs_by_name", (cmd_function)w_sdp_with_codecs_by_name, + 1, fixup_spve_null, 0, ANY_ROUTE}, {"sdp_print", (cmd_function)w_sdp_print, 1, fixup_igp_null, 0, ANY_ROUTE}, {"bind_sdpops", (cmd_function)bind_sdpops, @@ -623,6 +629,149 @@ static int w_sdp_with_media(sip_msg_t* msg, char* media, char *bar) return 1; } +/** + * + */ +int sdp_with_codecs_by_id(sip_msg_t* msg, str* codecs) +{ + sdp_info_t *sdp = NULL; + int sdp_session_num; + int sdp_stream_num; + sdp_session_cell_t* sdp_session; + sdp_stream_cell_t* sdp_stream; + str sdp_codecs; + str tmp_codecs; + str fnd_codec; + int foundone = 0; + int notfound = 0; + + if(parse_sdp(msg) < 0) { + LM_ERR("Unable to parse sdp\n"); + return -1; + } + + sdp = (sdp_info_t*)msg->body; + + if(sdp==NULL) { + LM_DBG("No sdp body\n"); + return -1; + } + + LM_DBG("attempting to search codecs in sdp: [%.*s]\n", + codecs->len, codecs->s); + + sdp_session_num = 0; + for(;;) + { + sdp_session = get_sdp_session(msg, sdp_session_num); + if(!sdp_session) break; + sdp_stream_num = 0; + for(;;) + { + sdp_stream = get_sdp_stream(msg, sdp_session_num, sdp_stream_num); + if(!sdp_stream) break; + + LM_DBG("stream %d of %d - payloads [%.*s]\n", + sdp_stream_num, sdp_session_num, + sdp_stream->payloads.len, sdp_stream->payloads.s); + sdp_codecs = sdp_stream->payloads; + tmp_codecs = *codecs; + while(str_find_token(&tmp_codecs, &fnd_codec, ',')==0 + && fnd_codec.len>0) + { + tmp_codecs.len -=(int)(&fnd_codec.s[fnd_codec.len]-tmp_codecs.s); + tmp_codecs.s = fnd_codec.s + fnd_codec.len; + + if(sdp_codec_in_str(&sdp_codecs, &fnd_codec, ' ')==0) { + LM_DBG("codecs [%.*s] - not found [%.*s]\n", + sdp_codecs.len, sdp_codecs.s, + fnd_codec.len, fnd_codec.s); + notfound = 1; + } else { + LM_DBG("codecs [%.*s] - found [%.*s]\n", + sdp_codecs.len, sdp_codecs.s, + fnd_codec.len, fnd_codec.s); + foundone = 1; + } + } + sdp_stream_num++; + } + sdp_session_num++; + } + + return (foundone + ((foundone)?notfound:0)); +} + +/** + * + */ +static int w_sdp_with_codecs_by_id(sip_msg_t* msg, char* codecs, char *bar) +{ + str lcodecs = {0, 0}; + int ret; + + if(codecs==0) + { + LM_ERR("invalid parameters\n"); + return -1; + } + + if(fixup_get_svalue(msg, (gparam_p)codecs, &lcodecs)!=0) + { + LM_ERR("unable to get the codecs\n"); + return -1; + } + + ret = sdp_with_codecs_by_id(msg, &lcodecs); + /* ret: -1 error; 0 not found */ + if(ret<=0) + return (ret - 1); + return ret; +} + +/** + * + */ +static int w_sdp_with_codecs_by_name(sip_msg_t* msg, char* codecs, char *bar) +{ + str lcodecs = {0, 0}; + str idslist; + sdp_info_t *sdp = NULL; + int ret; + + if(codecs==0) + { + LM_ERR("invalid parameters\n"); + return -1; + } + + if(fixup_get_svalue(msg, (gparam_p)codecs, &lcodecs)!=0) + { + LM_ERR("unable to get the codecs\n"); + return -1; + } + + if(parse_sdp(msg) < 0) { + LM_ERR("Unable to parse sdp\n"); + return -1; + } + + sdp = (sdp_info_t*)msg->body; + + if(sdp==NULL) { + LM_DBG("No sdp body\n"); + return -1; + } + + if(sdpops_build_ids_list(sdp, &lcodecs, &idslist)<0) + return -1; + + ret = sdp_with_codecs_by_id(msg, &idslist); + /* ret: -1 error; 0 not found */ + if(ret<=0) + return (ret - 1); + return ret; +} /** *