[sr-dev] git:3.2: app_lua: lookup pv in cached table for unset and isnull

Module: sip-router Branch: 3.2 Commit: 6b8cdd3fbe3e4cb930dedd5e52ff447e9ed91164 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=6b8cdd3… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Wed Jan 11 12:04:56 2012 +0100 app_lua: lookup pv in cached table for unset and isnull (cherry picked from commit f101dacbf640f08e2133c197c465ff7d312dda1b) --- modules/app_lua/app_lua_sr.c | 32 ++++++++++++++++++++++++-------- 1 files changed, 24 insertions(+), 8 deletions(-) diff --git a/modules/app_lua/app_lua_sr.c b/modules/app_lua/app_lua_sr.c index 3a2bf72..b5a6a6c 100644 --- a/modules/app_lua/app_lua_sr.c +++ b/modules/app_lua/app_lua_sr.c @@ -1027,9 +1027,10 @@ static int lua_sr_pv_sets (lua_State *L) static int lua_sr_pv_unset (lua_State *L) { str pvn; - pv_spec_t pvs; + pv_spec_t *pvs; pv_value_t val; sr_lua_env_t *env_L; + int pl; env_L = sr_lua_env_get(); @@ -1039,14 +1040,21 @@ static int lua_sr_pv_unset (lua_State *L) pvn.len = strlen(pvn.s); LM_DBG("pv unset: %s\n", pvn.s); - if(pv_parse_spec(&pvn, &pvs)<0) + pl = pv_locate_name(&pvn); + if(pl != pvn.len) + { + LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len); + return 0; + } + pvs = pv_cache_get(&pvn); + if(pvs==NULL) { - LM_ERR("unable to parse pv [%s]\n", pvn.s); + LM_ERR("cannot get pv spec for [%s]\n", pvn.s); return 0; } memset(&val, 0, sizeof(pv_value_t)); val.flags |= PV_VAL_NULL; - if(pv_set_spec_value(env_L->msg, &pvs, 0, &val)<0) + if(pv_set_spec_value(env_L->msg, pvs, 0, &val)<0) { LM_ERR("unable to unset pv [%s]\n", pvn.s); return 0; @@ -1061,9 +1069,10 @@ static int lua_sr_pv_unset (lua_State *L) static int lua_sr_pv_is_null (lua_State *L) { str pvn; - pv_spec_t pvs; + pv_spec_t *pvs; pv_value_t val; sr_lua_env_t *env_L; + int pl; env_L = sr_lua_env_get(); @@ -1073,13 +1082,20 @@ static int lua_sr_pv_is_null (lua_State *L) pvn.len = strlen(pvn.s); LM_DBG("pv is null test: %s\n", pvn.s); - if(pv_parse_spec(&pvn, &pvs)<0) + pl = pv_locate_name(&pvn); + if(pl != pvn.len) + { + LM_ERR("invalid pv [%s] (%d/%d)\n", pvn.s, pl, pvn.len); + return 0; + } + pvs = pv_cache_get(&pvn); + if(pvs==NULL) { - LM_ERR("unable to parse pv [%s]\n", pvn.s); + LM_ERR("cannot get pv spec for [%s]\n", pvn.s); return 0; } memset(&val, 0, sizeof(pv_value_t)); - if(pv_get_spec_value(env_L->msg, &pvs, &val) != 0) + if(pv_get_spec_value(env_L->msg, pvs, &val) != 0) { LM_NOTICE("unable to get pv value for [%s]\n", pvn.s); lua_pushboolean(L, 1);