[sr-dev] git:master:d0436602: core: foundation for config interpreter engine via kemi

Module: kamailio Branch: master Commit: d0436602dd9459f00945f47e67ea4bb9225caf43 URL: https://github.com/kamailio/kamailio/commit/d0436602dd9459f00945f47e67ea4bb… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2016-04-12T12:21:56+02:00 core: foundation for config interpreter engine via kemi - to allow execution of a config file written in an embedded language --- Modified: kemi.c Modified: kemi.h --- Diff: https://github.com/kamailio/kamailio/commit/d0436602dd9459f00945f47e67ea4bb… Patch: https://github.com/kamailio/kamailio/commit/d0436602dd9459f00945f47e67ea4bb… --- diff --git a/kemi.c b/kemi.c index 305d066..22f55c0 100644 --- a/kemi.c +++ b/kemi.c @@ -145,3 +145,71 @@ sr_kemi_t* sr_kemi_lookup(str *mname, int midx, str *fname) } return NULL; } + +/** + * + */ + +#define SR_KEMI_ENG_LIST_MAX_SIZE 8 +static sr_kemi_eng_t _sr_kemi_eng_list[SR_KEMI_ENG_LIST_MAX_SIZE]; +sr_kemi_eng_t *_sr_kemi_eng = NULL; +static int _sr_kemi_eng_list_size=0; + +/** + * + */ +int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute) +{ + int i; + + for(i=0; i<_sr_kemi_eng_list_size; i++) { + if(_sr_kemi_eng_list[i].ename.len==ename->len + && strncasecmp(_sr_kemi_eng_list[i].ename.s, ename->s, + ename->len)==0) { + /* found */ + return 1; + } + } + if(_sr_kemi_eng_list_size>=SR_KEMI_ENG_LIST_MAX_SIZE) { + LM_ERR("too many config routing engines registered\n"); + return -1; + } + if(ename->len>=SR_KEMI_BNAME_SIZE) { + LM_ERR("config routing engine name too long\n"); + return -1; + } + strncpy(_sr_kemi_eng_list[_sr_kemi_eng_list_size].bname, + ename->s, ename->len); + _sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.s + = _sr_kemi_eng_list[_sr_kemi_eng_list_size].bname; + _sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.len = ename->len; + _sr_kemi_eng_list[_sr_kemi_eng_list_size].ename.s[ename->len] = 0; + _sr_kemi_eng_list[_sr_kemi_eng_list_size].froute = froute; + _sr_kemi_eng_list_size++; + + return 0; +} + +/** + * + */ +int sr_kemi_eng_set(str *ename, str *cpath) +{ + int i; + + for(i=0; i<_sr_kemi_eng_list_size; i++) { + if(_sr_kemi_eng_list[i].ename.len==ename->len + && strncasecmp(_sr_kemi_eng_list[i].ename.s, ename->s, + ename->len)==0) { + /* found */ + _sr_kemi_eng = &_sr_kemi_eng_list[i]; + return 0; + } + } + return -1; +} + +sr_kemi_eng_t* sr_kemi_eng_get(void) +{ + return _sr_kemi_eng; +} diff --git a/kemi.h b/kemi.h index 45b98a2..c0087c6 100644 --- a/kemi.h +++ b/kemi.h @@ -89,4 +89,17 @@ int sr_kemi_modules_add(sr_kemi_t *klist); int sr_kemi_modules_size_get(void); sr_kemi_module_t* sr_kemi_modules_get(void); +typedef int (*sr_kemi_eng_route_f)(sip_msg_t*, int, str *); + +#define SR_KEMI_BNAME_SIZE 256 +typedef struct sr_kemi_eng { + char bname[SR_KEMI_BNAME_SIZE]; + str ename; + sr_kemi_eng_route_f froute; +} sr_kemi_eng_t; + +int sr_kemi_eng_register(str *ename, sr_kemi_eng_route_f froute); +int sr_kemi_eng_set(str *ename, str *cpath); +sr_kemi_eng_t* sr_kemi_eng_get(void); + #endif