sr-dev March 2019

sr-dev@lists.kamailio.org

28 participants
322 discussions

git:master:bbcbd691: core: option to run event_route[core:msg-received] in incomming message

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: bbcbd691ce86d58e56c7620e6b06093349bd549b URL: https://github.com/kamailio/kamailio/commit/bbcbd691ce86d58e56c7620e6b06093… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2019-03-01T12:55:41+01:00 core: option to run event_route[core:msg-received] in incomming message - done before any major SIP parsing - on drop, processing of the message is stopped - enable with received_route_mode=yes (or 1) - for kemi, set the callback name via kemi.received_route_callback param --- Modified: src/core/cfg.lex Modified: src/core/cfg.y Modified: src/core/globals.h Modified: src/core/ip_addr.h Modified: src/core/receive.c --- Diff: https://github.com/kamailio/kamailio/commit/bbcbd691ce86d58e56c7620e6b06093… Patch: https://github.com/kamailio/kamailio/commit/bbcbd691ce86d58e56c7620e6b06093…

5 years, 1 month

git:master:99d5da8d: dialplan: basic safety for concurent rpc reload

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 99d5da8d595961063249f871a5d150474fa6f317 URL: https://github.com/kamailio/kamailio/commit/99d5da8d595961063249f871a5d1504… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2019-03-01T10:51:29+01:00 dialplan: basic safety for concurent rpc reload - reported by GH #1874 --- Modified: src/modules/dialplan/dialplan.c --- Diff: https://github.com/kamailio/kamailio/commit/99d5da8d595961063249f871a5d1504… Patch: https://github.com/kamailio/kamailio/commit/99d5da8d595961063249f871a5d1504… --- diff --git a/src/modules/dialplan/dialplan.c b/src/modules/dialplan/dialplan.c index a96b246b72..d8685d52f2 100644 --- a/src/modules/dialplan/dialplan.c +++ b/src/modules/dialplan/dialplan.c @@ -88,6 +88,8 @@ int dp_fetch_rows = 1000; int dp_match_dynamic = 0; int dp_append_branch = 1; +static time_t *dp_rpc_reload_time = NULL; + static param_export_t mod_params[]={ { "db_url", PARAM_STR, &dp_db_url }, { "table_name", PARAM_STR, &dp_table_name }, @@ -185,6 +187,13 @@ static int mod_init(void) return -1; } + dp_rpc_reload_time = shm_malloc(sizeof(time_t)); + if(dp_rpc_reload_time == NULL) { + SHM_MEM_ERROR; + return -1; + } + *dp_rpc_reload_time = 0; + return 0; } @@ -202,6 +211,10 @@ static void mod_destroy(void) shm_free(default_par2); default_par2 = NULL; } + if(dp_rpc_reload_time!=NULL) { + shm_free(dp_rpc_reload_time); + dp_rpc_reload_time = 0; + } destroy_data(); } @@ -601,6 +614,17 @@ static const char* dialplan_rpc_reload_doc[2] = { */ static void dialplan_rpc_reload(rpc_t* rpc, void* ctx) { + if(dp_rpc_reload_time==NULL) { + LM_ERR("not ready for reload\n"); + rpc->fault(ctx, 500, "Not ready for reload"); + return; + } + if(*dp_rpc_reload_time!=0 && *dp_rpc_reload_time > time(NULL) - 5) { + LM_ERR("ongoing reload\n"); + rpc->fault(ctx, 500, "ongoing reload"); + return; + } + *dp_rpc_reload_time = time(NULL); if (dp_connect_db() < 0) { LM_ERR("failed to reload rules fron database (db connect)\n"); rpc->fault(ctx, 500, "DB Connection Error");

5 years, 1 month

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev March 2019