mirror of
https://github.com/asterisk/asterisk.git
synced 2025-09-03 03:20:57 +00:00
9ae9893c63
Correct typos of the following word families: identifying structures actcount initializer attributes statement enough locking declaration userevent provides unregister session execute searches verification suppressed prepared passwords recipients event because brief unidentified redundancy character the module reload operation backslashes accurate incorrect collision initializing instance interpreted buddies omitted manually requires queries generator scheduler configuration has owner resource performed masquerade apparently routable ASTERISK-29714 Change-Id: I88485116d2c59b776aa2e1f8b4ce8239a21decda
132 lines
3.2 KiB
C
132 lines
3.2 KiB
C
/*
|
|
* Asterisk -- An open source telephony toolkit.
|
|
*
|
|
* Copyright (C) 2017, CFWare, LLC
|
|
*
|
|
* Corey Farrell <git@cfware.com>
|
|
*
|
|
* See http://www.asterisk.org for more information about
|
|
* the Asterisk project. Please do not directly contact
|
|
* any of the maintainers of this project for assistance;
|
|
* the project provides a web site, mailing lists and IRC
|
|
* channels for your use.
|
|
*
|
|
* This program is free software, distributed under the terms of
|
|
* the GNU General Public License Version 2. See the LICENSE file
|
|
* at the top of the source tree.
|
|
*/
|
|
|
|
#include "asterisk.h"
|
|
|
|
#include <pjsip.h>
|
|
#include <pjsip_ua.h>
|
|
#include <pjlib.h>
|
|
|
|
#include "asterisk/res_pjsip.h"
|
|
#include "asterisk/res_pjsip_session.h"
|
|
#include "include/res_pjsip_private.h"
|
|
#include "asterisk/linkedlists.h"
|
|
#include "asterisk/lock.h"
|
|
#include "asterisk/module.h"
|
|
|
|
|
|
AST_RWLIST_HEAD_STATIC(session_supplements, ast_sip_session_supplement);
|
|
|
|
void ast_sip_session_register_supplement_with_module(struct ast_module *module, struct ast_sip_session_supplement *supplement)
|
|
{
|
|
struct ast_sip_session_supplement *iter;
|
|
int inserted = 0;
|
|
SCOPED_LOCK(lock, &session_supplements, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
|
|
|
|
ast_assert(supplement != NULL);
|
|
|
|
supplement->module = module;
|
|
|
|
if (!supplement->response_priority) {
|
|
supplement->response_priority = AST_SIP_SESSION_BEFORE_MEDIA;
|
|
}
|
|
|
|
AST_RWLIST_TRAVERSE_SAFE_BEGIN(&session_supplements, iter, next) {
|
|
if (iter->priority > supplement->priority) {
|
|
AST_RWLIST_INSERT_BEFORE_CURRENT(supplement, next);
|
|
inserted = 1;
|
|
break;
|
|
}
|
|
}
|
|
AST_RWLIST_TRAVERSE_SAFE_END;
|
|
|
|
if (!inserted) {
|
|
AST_RWLIST_INSERT_TAIL(&session_supplements, supplement, next);
|
|
}
|
|
}
|
|
|
|
void ast_sip_session_unregister_supplement(struct ast_sip_session_supplement *supplement)
|
|
{
|
|
struct ast_sip_session_supplement *iter;
|
|
SCOPED_LOCK(lock, &session_supplements, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
|
|
|
|
AST_RWLIST_TRAVERSE_SAFE_BEGIN(&session_supplements, iter, next) {
|
|
if (supplement == iter) {
|
|
AST_RWLIST_REMOVE_CURRENT(next);
|
|
break;
|
|
}
|
|
}
|
|
AST_RWLIST_TRAVERSE_SAFE_END;
|
|
}
|
|
|
|
static struct ast_sip_session_supplement *supplement_dup(const struct ast_sip_session_supplement *src)
|
|
{
|
|
struct ast_sip_session_supplement *dst = ast_calloc(1, sizeof(*dst));
|
|
|
|
if (!dst) {
|
|
return NULL;
|
|
}
|
|
/* Will need to revisit if shallow copy becomes an issue */
|
|
*dst = *src;
|
|
|
|
return dst;
|
|
}
|
|
|
|
int ast_sip_session_add_supplements(struct ast_sip_session *session)
|
|
{
|
|
struct ast_sip_session_supplement *iter;
|
|
SCOPED_LOCK(lock, &session_supplements, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK);
|
|
|
|
AST_RWLIST_TRAVERSE(&session_supplements, iter, next) {
|
|
struct ast_sip_session_supplement *copy = supplement_dup(iter);
|
|
|
|
if (!copy) {
|
|
return -1;
|
|
}
|
|
|
|
/* referenced session created. increasing module reference. */
|
|
ast_module_ref(copy->module);
|
|
|
|
AST_LIST_INSERT_TAIL(&session->supplements, copy, next);
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
void ast_sip_session_remove_supplements(struct ast_sip_session *session)
|
|
{
|
|
struct ast_sip_session_supplement *iter;
|
|
|
|
if (!session) {
|
|
return;
|
|
}
|
|
|
|
/* free the supplements */
|
|
while ((iter = AST_LIST_REMOVE_HEAD(&session->supplements, next))) {
|
|
if (iter->module) {
|
|
/* referenced session closed. decreasing module reference. */
|
|
ast_module_unref(iter->module);
|
|
}
|
|
|
|
ast_free(iter);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|