kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-09-06 12:36:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge "res_pjsip: improve realtime performance on CLI 'pjsip show contacts'" into 13

Browse Source
This commit is contained in:
Joshua Colp
2018-10-01 06:50:53 -05:00
committed by Gerrit Code Review
parent dc03526380 7d79805d54
commit a02522c140
1 changed files with 58 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
res/res_pjsip/location.c
View File

@@ -1001,35 +1001,83 @@ static int cli_filter_contacts(void *obj, void *arg, int flags)
return CMP_MATCH; return CMP_MATCH;
} }
static int cli_gather_contact(void *obj, void *arg, int flags)
{
struct ast_sip_contact *contact = obj;
RAII_VAR(struct ast_sip_contact_wrapper *, wrapper, NULL, ao2_cleanup);
if (strcmp(contact->reg_server, ast_config_AST_SYSTEM_NAME ?: "")) {
return 0;
}
wrapper = ao2_alloc_options(sizeof(struct ast_sip_contact_wrapper),
contact_wrapper_destroy, AO2_ALLOC_OPT_LOCK_NOLOCK);
if (!wrapper) {
return -1;
}
wrapper->contact_id = ast_malloc(strlen(contact->aor) + strlen(contact->uri) + 2);
if (!wrapper->contact_id) {
return -1;
}
sprintf(wrapper->contact_id, "%s/%s", contact->aor, contact->uri);
wrapper->aor_id = ast_strdup(contact->aor);
if (!wrapper->aor_id) {
return -1;
}
wrapper->contact = ao2_bump(contact);
ao2_link(arg, wrapper);
return 0;
}
static struct ao2_container *cli_contact_get_container(const char *regex) static struct ao2_container *cli_contact_get_container(const char *regex)
{ {
RAII_VAR(struct ao2_container *, parent_container, NULL, ao2_cleanup); RAII_VAR(struct ao2_container *, aors, NULL, ao2_cleanup);
struct ao2_container *child_container; RAII_VAR(struct ao2_container *, contacts, NULL, ao2_cleanup);
RAII_VAR(struct ast_variable *, var_aor, NULL, ast_variables_destroy);
struct ao2_container *contacts_container;
regex_t regexbuf; regex_t regexbuf;
parent_container = cli_aor_get_container(""); if (!(var_aor = ast_variable_new("contact !=", "", ""))) {
if (!parent_container) {
return NULL; return NULL;
} }
child_container = ao2_container_alloc_list(AO2_ALLOC_OPT_LOCK_NOLOCK, 0, contacts_container = ao2_container_alloc_list(AO2_ALLOC_OPT_LOCK_NOLOCK, 0,
cli_contact_sort, cli_contact_compare); cli_contact_sort, cli_contact_compare);
if (!child_container) { if (!contacts_container) {
return NULL; return NULL;
} }
ao2_callback(parent_container, OBJ_NODATA, cli_aor_gather_contacts, child_container); contacts = ast_sorcery_retrieve_by_regex(ast_sip_get_sorcery(), "contact", regex);
if (!contacts) {
ao2_ref(contacts_container, -1);
return NULL;
}
ao2_callback(contacts, OBJ_NODATA, cli_gather_contact, contacts_container);
aors = ast_sorcery_retrieve_by_fields(ast_sip_get_sorcery(),
"aor", AST_RETRIEVE_FLAG_MULTIPLE, var_aor);
if (!aors) {
ao2_ref(contacts_container, -1);
return NULL;
}
ao2_callback(aors, OBJ_NODATA, cli_aor_gather_contacts, contacts_container);
if (!ast_strlen_zero(regex)) { if (!ast_strlen_zero(regex)) {
if (regcomp(&regexbuf, regex, REG_EXTENDED | REG_NOSUB)) { if (regcomp(&regexbuf, regex, REG_EXTENDED | REG_NOSUB)) {
ao2_ref(child_container, -1); ao2_ref(contacts_container, -1);
return NULL; return NULL;
} }
ao2_callback(child_container, OBJ_UNLINK | OBJ_MULTIPLE | OBJ_NODATA, cli_filter_contacts, &regexbuf); ao2_callback(contacts_container, OBJ_UNLINK | OBJ_MULTIPLE | OBJ_NODATA, cli_filter_contacts, &regexbuf);
regfree(&regexbuf); regfree(&regexbuf);
} }
return child_container; return contacts_container;
} }
static void *cli_contact_retrieve_by_id(const char *id) static void *cli_contact_retrieve_by_id(const char *id)