sr-dev April 2017

sr-dev@lists.kamailio.org

31 participants
427 discussions

git:master:29aec680: kazoo: add consistent worker key
by lazedo 14 Apr '17

14 Apr '17

Module: kamailio Branch: master Commit: 29aec6800099a3b1d7a2b2c7e6d4b3865f0bc6e6 URL: https://github.com/kamailio/kamailio/commit/29aec6800099a3b1d7a2b2c7e6d4b38… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)factorlusitano.com> Date: 2017-04-14T05:47:52+01:00 kazoo: add consistent worker key --- Modified: src/modules/kazoo/kz_amqp.c Modified: src/modules/kazoo/kz_amqp.h --- Diff: https://github.com/kamailio/kamailio/commit/29aec6800099a3b1d7a2b2c7e6d4b38… Patch: https://github.com/kamailio/kamailio/commit/29aec6800099a3b1d7a2b2c7e6d4b38… --- diff --git a/src/modules/kazoo/kz_amqp.c b/src/modules/kazoo/kz_amqp.c index f3a7c2c..d759490 100644 --- a/src/modules/kazoo/kz_amqp.c +++ b/src/modules/kazoo/kz_amqp.c @@ -384,6 +384,8 @@ void kz_amqp_free_bind(kz_amqp_bind_ptr bind) kz_amqp_bytes_free(bind->event_key); if(bind->event_subkey.bytes) kz_amqp_bytes_free(bind->event_subkey); + if(bind->consistent_worker_key) + shm_free(bind->consistent_worker_key); shm_free(bind); } @@ -1771,6 +1773,7 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) int no_ack = 1; int federate = 0; int consistent_worker = 0; + str* consistent_worker_key = NULL; int wait_for_consumer_ack = 1; kz_amqp_queue_ptr queue = NULL; kz_amqp_exchange_ptr exchange = NULL; @@ -1825,6 +1828,11 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) consistent_worker = json_object_get_int(tmpObj); } + tmpObj = kz_json_get_object(json_obj, "consistent-worker-key"); + if(tmpObj != NULL) { + consistent_worker_key = kz_str_dup_from_char((char*)json_object_get_string(tmpObj)); + } + tmpObj = kz_json_get_object(json_obj, "exchange-bindings"); if(tmpObj != NULL) { exchange_binding = kz_amqp_exchange_binding_from_json(tmpObj); @@ -1853,6 +1861,7 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) bind->wait_for_consumer_ack = wait_for_consumer_ack; bind->federate = federate; bind->consistent_worker = consistent_worker; + bind->consistent_worker_key = consistent_worker_key; kz_amqp_binding_ptr binding = shm_malloc(sizeof(kz_amqp_binding)); @@ -2866,6 +2875,8 @@ void kz_amqp_send_worker_event(kz_amqp_server_ptr server_ptr, amqp_envelope_t* e char buffer[100]; kz_amqp_cmd_ptr cmd = NULL; kz_amqp_consumer_delivery_ptr ptr = NULL; + json_obj_ptr json_obj = NULL; + json_object* JObj = NULL; str* message_id = NULL; int idx = envelope->channel-1; int worker = 0; @@ -2878,7 +2889,7 @@ void kz_amqp_send_worker_event(kz_amqp_server_ptr server_ptr, amqp_envelope_t* e } memset(json_data, 0, msg_size + 1); memcpy(json_data, (char*)envelope->message.body.bytes, msg_size); - json_obj_ptr json_obj = kz_json_parse(json_data); + json_obj = kz_json_parse(json_data); pkg_free(json_data); if (json_obj == NULL) { LM_ERR("error parsing json body\n"); @@ -2888,7 +2899,7 @@ void kz_amqp_send_worker_event(kz_amqp_server_ptr server_ptr, amqp_envelope_t* e json_object_object_add(json_obj, BLF_JSON_BROKER_ZONE, json_object_new_string(server_ptr->zone->zone)); - json_object* JObj = kz_json_get_object(json_obj, BLF_JSON_SERVERID); + JObj = kz_json_get_object(json_obj, BLF_JSON_SERVERID); if(JObj != NULL) { const char* _kz_server_id_str = json_object_get_string(JObj); sprintf(buffer, "consumer://%d/%s", _kz_server_id, _kz_server_id_str); @@ -2932,8 +2943,14 @@ void kz_amqp_send_worker_event(kz_amqp_server_ptr server_ptr, amqp_envelope_t* e if(bind && bind->consistent_worker) { str rk; - rk.s = (char*)envelope->routing_key.bytes; - rk.len = (int)envelope->routing_key.len; + if(bind->consistent_worker_key != NULL && + (JObj = kz_json_get_object(json_obj, bind->consistent_worker_key->s)) != NULL) { + rk.s = (char*)json_object_get_string(JObj); + rk.len = strlen(rk.s); + } else { + rk.s = (char*)envelope->routing_key.bytes; + rk.len = (int)envelope->routing_key.len; + } worker = core_hash(&rk, NULL, dbk_consumer_workers); LM_DBG("computed worker for %.*s is %d\n", rk.len, rk.s, worker); } else { diff --git a/src/modules/kazoo/kz_amqp.h b/src/modules/kazoo/kz_amqp.h index c412156..b4a88ff 100644 --- a/src/modules/kazoo/kz_amqp.h +++ b/src/modules/kazoo/kz_amqp.h @@ -217,6 +217,7 @@ typedef struct { amqp_boolean_t wait_for_consumer_ack; amqp_boolean_t federate; amqp_boolean_t consistent_worker; + str* consistent_worker_key; } kz_amqp_bind, *kz_amqp_bind_ptr; typedef struct {

1 0

git:master:d511399b: kazoo: add more explicit fields to kz_pua
by lazedo 14 Apr '17

14 Apr '17

Module: kamailio Branch: master Commit: d511399baa6a701fa0303487174a7bdc996fd051 URL: https://github.com/kamailio/kamailio/commit/d511399baa6a701fa0303487174a7bd… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)factorlusitano.com> Date: 2017-04-14T04:54:57+01:00 kazoo: add more explicit fields to kz_pua kz_pua.c was reformatted --- Modified: src/modules/kazoo/defs.h Modified: src/modules/kazoo/kz_pua.c --- Diff: https://github.com/kamailio/kamailio/commit/d511399baa6a701fa0303487174a7bd… Patch: https://github.com/kamailio/kamailio/commit/d511399baa6a701fa0303487174a7bd…

1 0

git:master:349def6b: kazoo: add pua transaction lock type
by lazedo 14 Apr '17

14 Apr '17

Module: kamailio Branch: master Commit: 349def6b129e63cdc46b88c502562c9e2543d421 URL: https://github.com/kamailio/kamailio/commit/349def6b129e63cdc46b88c502562c9… Author: lazedo <luis.azedo(a)factorlusitano.com> Committer: lazedo <luis.azedo(a)factorlusitano.com> Date: 2017-04-14T04:38:30+01:00 kazoo: add pua transaction lock type --- Modified: src/modules/kazoo/kazoo.c Modified: src/modules/kazoo/kz_pua.c --- Diff: https://github.com/kamailio/kamailio/commit/349def6b129e63cdc46b88c502562c9… Patch: https://github.com/kamailio/kamailio/commit/349def6b129e63cdc46b88c502562c9… --- diff --git a/src/modules/kazoo/kazoo.c b/src/modules/kazoo/kazoo.c index 5c81ad2..8574de6 100644 --- a/src/modules/kazoo/kazoo.c +++ b/src/modules/kazoo/kazoo.c @@ -88,6 +88,7 @@ int dbk_consumer_loop_count = 10; int dbk_consumer_ack_loop_count = 20; int dbk_include_entity = 1; int dbk_pua_mode = 1; +db_locking_t kz_pua_lock_type = DB_LOCKING_WRITE; int dbk_use_hearbeats = 0; int dbk_single_consumer_on_reconnect = 1; int dbk_consume_messages_on_reconnect = 1; @@ -197,6 +198,7 @@ static param_export_t params[] = { {"amqps_key", STR_PARAM, &kz_amqps_key.s}, {"amqps_verify_peer", INT_PARAM, &kz_amqps_verify_peer}, {"amqps_verify_hostname", INT_PARAM, &kz_amqps_verify_hostname}, + {"pua_lock_type", INT_PARAM, &kz_pua_lock_type}, {0, 0, 0} }; diff --git a/src/modules/kazoo/kz_pua.c b/src/modules/kazoo/kz_pua.c index 60b89dc..3c1e3cf 100644 --- a/src/modules/kazoo/kz_pua.c +++ b/src/modules/kazoo/kz_pua.c @@ -43,6 +43,7 @@ extern db1_con_t *kz_pa_db; extern db_func_t kz_pa_dbf; extern str kz_presentity_table; +extern db_locking_t kz_pua_lock_type; int kz_pua_update_presentity(str* event, str* realm, str* user, str* etag, str* sender, str* body, int expires, int reset) { @@ -125,7 +126,7 @@ int kz_pua_update_presentity(str* event, str* realm, str* user, str* etag, str* if (kz_pa_dbf.start_transaction) { - if (kz_pa_dbf.start_transaction(kz_pa_db, DB_LOCKING_WRITE) < 0) + if (kz_pa_dbf.start_transaction(kz_pa_db, kz_pua_lock_type) < 0) { LM_ERR("in start_transaction\n"); goto error;

1 0

git:4.4:4febe26a: p_usrloc: fix to update expires column when db_ops_ruid set
by Lucian Balaceanu 13 Apr '17

13 Apr '17

Module: kamailio Branch: 4.4 Commit: 4febe26a166390b47bf63775cdeea71bb9089781 URL: https://github.com/kamailio/kamailio/commit/4febe26a166390b47bf63775cdeea71… Author: Lucian Balaceanu <lucian.balaceanu(a)1and1.ro> Committer: Lucian Balaceanu <lucian.balaceanu(a)1and1.ro> Date: 2017-04-13T16:52:50+03:00 p_usrloc: fix to update expires column when db_ops_ruid set --- Modified: modules/p_usrloc/ucontact.c --- Diff: https://github.com/kamailio/kamailio/commit/4febe26a166390b47bf63775cdeea71… Patch: https://github.com/kamailio/kamailio/commit/4febe26a166390b47bf63775cdeea71… --- diff --git a/modules/p_usrloc/ucontact.c b/modules/p_usrloc/ucontact.c index 72a5e65..ac7ba49 100644 --- a/modules/p_usrloc/ucontact.c +++ b/modules/p_usrloc/ucontact.c @@ -819,10 +819,10 @@ int db_update_ucontact_ruid(ucontact_t* _c) vals2[n2].val.str_val = _c->c; n2++; - keys2[n2] = &callid_col; - vals2[n2].type = DB1_STR; + keys2[n2] = &expires_col; + vals2[n2].type = DB1_DATETIME; vals2[n2].nul = 0; - vals2[n2].val.str_val = _c->callid; + vals2[n2].val.time_val = _c->expires; n2++; keys2[n2] = &q_col;

1 0

git:master:3cdcb8ae: p_usrloc: fix to update expires column when db_ops_ruid set
by Lucian Balaceanu 13 Apr '17

13 Apr '17

Module: kamailio Branch: master Commit: 3cdcb8ae3783d7221d212df00769b495f88c740b URL: https://github.com/kamailio/kamailio/commit/3cdcb8ae3783d7221d212df00769b49… Author: Lucian Balaceanu <lucian.balaceanu(a)1and1.ro> Committer: Lucian Balaceanu <lucian.balaceanu(a)1and1.ro> Date: 2017-04-13T15:02:37+03:00 p_usrloc: fix to update expires column when db_ops_ruid set --- Modified: src/modules/p_usrloc/ucontact.c --- Diff: https://github.com/kamailio/kamailio/commit/3cdcb8ae3783d7221d212df00769b49… Patch: https://github.com/kamailio/kamailio/commit/3cdcb8ae3783d7221d212df00769b49… --- diff --git a/src/modules/p_usrloc/ucontact.c b/src/modules/p_usrloc/ucontact.c index 5bc5e09..75da91a 100644 --- a/src/modules/p_usrloc/ucontact.c +++ b/src/modules/p_usrloc/ucontact.c @@ -819,10 +819,10 @@ int db_update_ucontact_ruid(ucontact_t* _c) vals2[n2].val.str_val = _c->c; n2++; - keys2[n2] = &callid_col; - vals2[n2].type = DB1_STR; + keys2[n2] = &expires_col; + vals2[n2].type = DB1_DATETIME; vals2[n2].nul = 0; - vals2[n2].val.str_val = _c->callid; + vals2[n2].val.time_val = _c->expires; n2++; keys2[n2] = &q_col;

1 0

git:master:0efa0994: speeddial: exported functions to kemi framework
by Daniel-Constantin Mierla 13 Apr '17

13 Apr '17

Module: kamailio Branch: master Commit: 0efa0994519428c415c0cf16266b6bfc8345b67c URL: https://github.com/kamailio/kamailio/commit/0efa0994519428c415c0cf16266b6bf… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-04-13T09:27:13+02:00 speeddial: exported functions to kemi framework --- Modified: src/modules/speeddial/sdlookup.c Modified: src/modules/speeddial/sdlookup.h Modified: src/modules/speeddial/speeddial.c --- Diff: https://github.com/kamailio/kamailio/commit/0efa0994519428c415c0cf16266b6bf… Patch: https://github.com/kamailio/kamailio/commit/0efa0994519428c415c0cf16266b6bf… --- diff --git a/src/modules/speeddial/sdlookup.c b/src/modules/speeddial/sdlookup.c index 79d52a8..13c7095 100644 --- a/src/modules/speeddial/sdlookup.c +++ b/src/modules/speeddial/sdlookup.c @@ -61,7 +61,7 @@ static inline int rewrite_ruri(struct sip_msg* _m, char* _s) /** * */ -int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) +int sd_lookup_owner(sip_msg_t* _msg, str* stable, str* sowner) { str user_s, table_s, uri_s; int nr_keys; @@ -72,24 +72,21 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) db_key_t db_cols[1]; db1_res_t* db_res = NULL; - if(_table==NULL || fixup_get_svalue(_msg, (gparam_p)_table, &table_s)!=0) + if(stable==NULL || stable->s==NULL || stable->len<=0) { LM_ERR("invalid table parameter"); return -1; } + table_s = *stable; /* init */ nr_keys = 0; db_cols[0]=&new_uri_column; - if(_owner) + if(sowner!=NULL && sowner->s!=NULL && sowner->len>0) { + uri_s = *sowner; memset(&turi, 0, sizeof(struct sip_uri)); - if(fixup_get_svalue(_msg, (gparam_p)_owner, &uri_s)!=0) - { - LM_ERR("invalid owner uri parameter"); - return -1; - } if(parse_uri(uri_s.s, uri_s.len, &turi)!=0) { LM_ERR("bad owner SIP address!\n"); @@ -236,3 +233,28 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) return -1; } +/** + * + */ +int w_sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) +{ + str table_s, uri_s; + + if(_table==NULL || fixup_get_svalue(_msg, (gparam_p)_table, &table_s)!=0) + { + LM_ERR("invalid table parameter"); + return -1; + } + + if(_owner) + { + if(fixup_get_svalue(_msg, (gparam_p)_owner, &uri_s)!=0) + { + LM_ERR("invalid owner uri parameter"); + return -1; + } + return sd_lookup_owner(_msg, &table_s, &uri_s); + } + + return sd_lookup_owner(_msg, &table_s, NULL); +} diff --git a/src/modules/speeddial/sdlookup.h b/src/modules/speeddial/sdlookup.h index ea846b7..582afd4 100644 --- a/src/modules/speeddial/sdlookup.h +++ b/src/modules/speeddial/sdlookup.h @@ -26,6 +26,7 @@ #include "../../core/parser/msg_parser.h" -int sd_lookup(struct sip_msg* _msg, char* _table, char* _str2); +int w_sd_lookup(struct sip_msg* _msg, char* _table, char* _owner); +int sd_lookup_owner(struct sip_msg* _msg, str* _stable, str* _sowner); #endif /* _SDLOOKUP_H_ */ diff --git a/src/modules/speeddial/speeddial.c b/src/modules/speeddial/speeddial.c index 6c4e2a5..d5baa65 100644 --- a/src/modules/speeddial/speeddial.c +++ b/src/modules/speeddial/speeddial.c @@ -29,6 +29,7 @@ #include "../../core/error.h" #include "../../core/mem/mem.h" #include "../../core/mod_fix.h" +#include "../../core/kemi.h" #include "sdlookup.h" @@ -65,9 +66,9 @@ db1_con_t* db_handle=0; /* Database connection handle */ /* Exported functions */ static cmd_export_t cmds[] = { - {"sd_lookup", (cmd_function)sd_lookup, 1, fixup_spve_null, 0, + {"sd_lookup", (cmd_function)w_sd_lookup, 1, fixup_spve_null, 0, REQUEST_ROUTE}, - {"sd_lookup", (cmd_function)sd_lookup, 2, fixup_spve_spve, 0, + {"sd_lookup", (cmd_function)w_sd_lookup, 2, fixup_spve_spve, 0, REQUEST_ROUTE}, {0, 0, 0, 0, 0, 0} }; @@ -158,3 +159,39 @@ static void destroy(void) db_funcs.close(db_handle); } +/** + * + */ +static int ki_sd_lookup(sip_msg_t *msg, str *stable) +{ + return sd_lookup_owner(msg, stable, NULL); +} + +/** + * + */ +/* clang-format off */ +static sr_kemi_t sr_kemi_speeddial_exports[] = { + { str_init("speeddial"), str_init("lookup"), + SR_KEMIP_INT, ki_sd_lookup, + { SR_KEMIP_STR, SR_KEMIP_NONE, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + { str_init("speeddial"), str_init("lookup_owner"), + SR_KEMIP_INT, sd_lookup_owner, + { SR_KEMIP_STR, SR_KEMIP_STR, SR_KEMIP_NONE, + SR_KEMIP_NONE, SR_KEMIP_NONE, SR_KEMIP_NONE } + }, + + { {0, 0}, {0, 0}, 0, NULL, { 0, 0, 0, 0, 0, 0 } } +}; +/* clang-format on */ + +/** + * + */ +int mod_register(char *path, int *dlflags, void *p1, void *p2) +{ + sr_kemi_modules_add(sr_kemi_speeddial_exports); + return 0; +}

1 0

git:master:911a051b: speeddial: coherent indentation
by Daniel-Constantin Mierla 13 Apr '17

13 Apr '17

Module: kamailio Branch: master Commit: 911a051b9573d43e01bc627692d99f548f9fc344 URL: https://github.com/kamailio/kamailio/commit/911a051b9573d43e01bc627692d99f5… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-04-13T09:00:11+02:00 speeddial: coherent indentation --- Modified: src/modules/speeddial/sdlookup.c Modified: src/modules/speeddial/sdlookup.h Modified: src/modules/speeddial/speeddial.c Modified: src/modules/speeddial/speeddial.h --- Diff: https://github.com/kamailio/kamailio/commit/911a051b9573d43e01bc627692d99f5… Patch: https://github.com/kamailio/kamailio/commit/911a051b9573d43e01bc627692d99f5… --- diff --git a/src/modules/speeddial/sdlookup.c b/src/modules/speeddial/sdlookup.c index f561d77..79d52a8 100644 --- a/src/modules/speeddial/sdlookup.c +++ b/src/modules/speeddial/sdlookup.c @@ -81,7 +81,7 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) /* init */ nr_keys = 0; db_cols[0]=&new_uri_column; - + if(_owner) { memset(&turi, 0, sizeof(struct sip_uri)); @@ -105,7 +105,7 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) goto err_server; } } - + db_keys[nr_keys]=&user_column; db_vals[nr_keys].type = DB1_STR; db_vals[nr_keys].nul = 0; @@ -121,7 +121,7 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) db_vals[nr_keys].val.str_val.s = puri->host.s; db_vals[nr_keys].val.str_val.len = puri->host.len; nr_keys++; - + if (dstrip_s.s!=NULL && dstrip_s.len>0 && dstrip_s.len<puri->host.len && strncasecmp(puri->host.s,dstrip_s.s,dstrip_s.len)==0) @@ -180,21 +180,21 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) user_s.s = useruri_buf+4; switch(RES_ROWS(db_res)[0].values[0].type) - { + { case DB1_STRING: - strcpy(user_s.s, + strcpy(user_s.s, (char*)RES_ROWS(db_res)[0].values[0].val.string_val); user_s.len = strlen(user_s.s); break; case DB1_STR: - strncpy(user_s.s, + strncpy(user_s.s, (char*)RES_ROWS(db_res)[0].values[0].val.str_val.s, RES_ROWS(db_res)[0].values[0].val.str_val.len); user_s.len = RES_ROWS(db_res)[0].values[0].val.str_val.len; user_s.s[user_s.len] = '\0'; break; case DB1_BLOB: - strncpy(user_s.s, + strncpy(user_s.s, (char*)RES_ROWS(db_res)[0].values[0].val.blob_val.s, RES_ROWS(db_res)[0].values[0].val.blob_val.len); user_s.len = RES_ROWS(db_res)[0].values[0].val.blob_val.len; @@ -207,7 +207,7 @@ int sd_lookup(struct sip_msg* _msg, char* _table, char* _owner) } goto err_server; } - + /* check 'sip:' */ if(user_s.len<4 || strncmp(user_s.s, "sip:", 4)) { diff --git a/src/modules/speeddial/sdlookup.h b/src/modules/speeddial/sdlookup.h index f1fce5d..ea846b7 100644 --- a/src/modules/speeddial/sdlookup.h +++ b/src/modules/speeddial/sdlookup.h @@ -17,7 +17,7 @@ * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * - * + * */ diff --git a/src/modules/speeddial/speeddial.c b/src/modules/speeddial/speeddial.c index 9ad3f98..6c4e2a5 100644 --- a/src/modules/speeddial/speeddial.c +++ b/src/modules/speeddial/speeddial.c @@ -17,7 +17,7 @@ * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * - * + * */ @@ -89,7 +89,7 @@ static param_export_t params[] = { /* Module interface */ struct module_exports exports = { - "speeddial", + "speeddial", DEFAULT_DLFLAGS, /* dlopen flags */ cmds, /* Exported functions */ params, /* Exported parameters */ @@ -128,7 +128,7 @@ static int child_init(int rank) */ static int mod_init(void) { - /* Find a database module */ + /* Find a database module */ if (db_bind_mod(&db_url, &db_funcs)) { LM_ERR("failed to bind database module\n"); diff --git a/src/modules/speeddial/speeddial.h b/src/modules/speeddial/speeddial.h index 73ac321..49dbd6d 100644 --- a/src/modules/speeddial/speeddial.h +++ b/src/modules/speeddial/speeddial.h @@ -17,7 +17,7 @@ * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * - * + * */

1 0

I was surprised
by vladiksip 12 Apr '17

12 Apr '17

Dear! I was surprised to receive your message last Saturday, please take a look at the information I found for you http://www.maven-international.com/recently.php?b2b3 Sent from a prehistoric stone tablet, vladiksip

1 0

git:master:27ecfa5f: modules: readme files regenerated - evrexec ... [skip ci]
by Kamailio Dev 12 Apr '17

12 Apr '17

Module: kamailio Branch: master Commit: 27ecfa5fd8557a65e18c36b8388b7f176213c77b URL: https://github.com/kamailio/kamailio/commit/27ecfa5fd8557a65e18c36b8388b7f1… Author: Kamailio Dev <kamailio.dev(a)kamailio.org> Committer: Kamailio Dev <kamailio.dev(a)kamailio.org> Date: 2017-04-12T21:31:23+02:00 modules: readme files regenerated - evrexec ... [skip ci] --- Modified: src/modules/evrexec/README --- Diff: https://github.com/kamailio/kamailio/commit/27ecfa5fd8557a65e18c36b8388b7f1… Patch: https://github.com/kamailio/kamailio/commit/27ecfa5fd8557a65e18c36b8388b7f1… --- diff --git a/src/modules/evrexec/README b/src/modules/evrexec/README index cc8a1cd..c259f43 100644 --- a/src/modules/evrexec/README +++ b/src/modules/evrexec/README @@ -11,7 +11,7 @@ Daniel-Constantin Mierla <miconda(a)gmail.com> - Copyright © 2017 http://www.asipto.com + Copyright Â© 2017 http://www.asipto.com __________________________________________________________________ Table of Contents @@ -48,8 +48,9 @@ Chapter 1. Admin Guide 1. Overview - The module executes even route blocks once on dedicated processes. The - execution can be delayed for an interval of time. + The module executes event route blocks or KEMI functions on dedicated + processes at startup. The execution can be delayed for a specified + interval of time. The actions in the event route should be a loop or other tasks that run forever. @@ -82,7 +83,10 @@ Chapter 1. Admin Guide The parameter can be set multiple times to get more exec tasks in same configuration file. - * name - name of the event route to be executed. + * name - name of the event route to be executed. When used with a + KEMI embedded laguage, this has to be the name of a function from + the KEMI script. The function must have a string parameter, which + will retrieve the index of the works in string format. * workers - if set to 0 or 1 the task is executed in a dedicated process. Any number > 1 will create more dedicated processes, each of them executing the task.

1 0

git:master:a26a65ef: evrexec: notes about usage of modules with KEMI scripts
by Daniel-Constantin Mierla 12 Apr '17

12 Apr '17

Module: kamailio Branch: master Commit: a26a65efe5b18ad471a9c5d5fe1a047ade2bda65 URL: https://github.com/kamailio/kamailio/commit/a26a65efe5b18ad471a9c5d5fe1a047… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-04-12T21:15:30+02:00 evrexec: notes about usage of modules with KEMI scripts --- Modified: src/modules/evrexec/doc/evrexec_admin.xml --- Diff: https://github.com/kamailio/kamailio/commit/a26a65efe5b18ad471a9c5d5fe1a047… Patch: https://github.com/kamailio/kamailio/commit/a26a65efe5b18ad471a9c5d5fe1a047… --- diff --git a/src/modules/evrexec/doc/evrexec_admin.xml b/src/modules/evrexec/doc/evrexec_admin.xml index 840399e..b624eed 100644 --- a/src/modules/evrexec/doc/evrexec_admin.xml +++ b/src/modules/evrexec/doc/evrexec_admin.xml @@ -16,8 +16,9 @@ <section> <title>Overview</title> <para> - The module executes even route blocks once on dedicated processes. The - execution can be delayed for an interval of time. + The module executes event route blocks or KEMI functions on dedicated + processes at startup. The execution can be delayed for a specified + interval of time. </para> <para> The actions in the event route should be a loop or other tasks that @@ -77,6 +78,10 @@ <listitem> <para> <emphasis>name</emphasis> - name of the event route to be executed. + When used with a KEMI embedded laguage, this has to be the name + of a function from the KEMI script. The function must have a + string parameter, which will retrieve the index of the works in + string format. </para> </listitem> <listitem>

1 0

← Newer
1
...
25
26
27
28
29
30
31
...
43
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 2017