kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-31 02:37:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge "pjsip_options: handle modification of qualify options in realtime"

Browse Source
This commit is contained in:
George Joseph
2018-06-06 10:12:58 -05:00
committed by Gerrit Code Review
parent fdc931ffc6 e46b442e38
commit 7b5fc5d20f
1 changed files with 45 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
res/res_pjsip/pjsip_options.c
View File

@@ -2059,6 +2059,29 @@ struct sip_options_contact_observer_task_data {
struct ast_sip_contact *contact;
};
/*!
* \brief Check if the contact qualify options are different than local aor qualify options
*/
static int has_qualify_changed (struct ast_sip_contact *contact, struct sip_options_aor *aor_options)
{
if (!contact) {
return 0;
}
if (!aor_options) {
if (contact->qualify_frequency) {
return 1;
}
} else if (contact->qualify_frequency != aor_options->qualify_frequency
|| contact->authenticate_qualify != aor_options->authenticate_qualify
|| ((int)(contact->qualify_timeout * 1000)) != ((int)(aor_options->qualify_timeout * 1000))) {
return 1;
}
return 0;
}
/*!
* \brief Task which adds a dynamic contact to an AOR
* \note Run by aor_options->serializer
@@ -2129,23 +2152,21 @@ static int sip_options_contact_add_management_task(void *obj)
task_data.contact = obj;
task_data.aor_options = ao2_find(sip_options_aors, task_data.contact->aor,
OBJ_SEARCH_KEY);
if (!task_data.aor_options) {
if (has_qualify_changed(task_data.contact, task_data.aor_options)) {
struct ast_sip_aor *aor;
/*
* The only reason this would occur is if the AOR was sourced
* after the last reload happened. To handle this we fetch the
* AOR and treat it as if we received notification that it had
* been created. This will create the needed AOR feeder
* compositor and will cause any associated contact statuses and
* endpoint state compositors to also get created if needed.
*/
aor = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "aor",
task_data.contact->aor);
if (aor) {
ast_debug(3, "AOR '%s' qualify options have been modified. Synchronize an AOR local state\n",
task_data.contact->aor);
sip_options_aor_observer_modified_task(aor);
ao2_ref(aor, -1);
}
}
if (!task_data.aor_options) {
return 0;
}
@@ -2207,6 +2228,21 @@ static void contact_observer_updated(const void *obj)
task_data->contact = (struct ast_sip_contact *) obj;
task_data->aor_options = ao2_find(sip_options_aors, task_data->contact->aor,
OBJ_SEARCH_KEY);
if (has_qualify_changed(task_data->contact, task_data->aor_options)) {
struct ast_sip_aor *aor;
aor = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "aor",
task_data->contact->aor);
if (aor) {
ast_debug(3, "AOR '%s' qualify options have been modified. Synchronize an AOR local state\n",
task_data->contact->aor);
ast_sip_push_task_wait_serializer(management_serializer,
sip_options_aor_observer_modified_task, aor);
ao2_ref(aor, -1);
}
}
if (!task_data->aor_options) {
ast_free(task_data);
return;