res_pjsip.c File Reference

#include "asterisk.h"
#include <pjsip.h>
#include <pjsip_simple.h>
#include <pjsip/sip_transaction.h>
#include <pj/timer.h>
#include <pjlib.h>
#include <pjmedia/errno.h>
#include "asterisk/res_pjsip.h"
#include "asterisk/strings.h"
#include "pjsip/sip_parser.h"
#include "res_pjsip/include/res_pjsip_private.h"
#include "asterisk/linkedlists.h"
#include "asterisk/logger.h"
#include "asterisk/lock.h"
#include "asterisk/utils.h"
#include "asterisk/astobj2.h"
#include "asterisk/module.h"
#include "asterisk/serializer.h"
#include "asterisk/threadpool.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/uuid.h"
#include "asterisk/sorcery.h"
#include "asterisk/file.h"
#include "asterisk/causes.h"
#include "asterisk/cli.h"
#include "asterisk/callerid.h"
#include "asterisk/res_pjsip_cli.h"
#include "asterisk/test.h"
#include "asterisk/res_pjsip_presence_xml.h"
#include "asterisk/res_pjproject.h"
#include "asterisk/utf8.h"
#include "asterisk/acl.h"

Include dependency graph for res_pjsip.c:

Go to the source code of this file.

Data Structures
struct	endpoint_formatters
struct	endpoint_identifier_list
struct	endpoint_identifiers
struct	response_code_map
struct	send_request_data
	Structure to hold information about an outbound request. More...
struct	send_request_wrapper
struct	supplements
struct	sync_task_data

Macros
#define	DEBUG_BUF_SIZE   256
#define	ENDPOINT_IDENTIFIER_FORMAT   "%-20.20s\n"
#define	MOD_DATA_CONTACT   "contact"
#define	SERIALIZER_POOL_SIZE   8
#define	SIP_SERVANT_ID   0x5E2F1D
#define	TIMEOUT_TIMER2   5
#define	TIMER_INACTIVE   0

Typedefs
typedef pj_status_t(*	create_dlg_uac) (pjsip_user_agent *ua, pjsip_rx_data *rdata, const pj_str_t *contact, pjsip_dialog **p_dlg)

Functions
static void	__init_pj_thread_storage (void)
static void	__init_servant_id_storage (void)
static void	__reg_module (void)
static void	__unreg_module (void)
static pjsip_msg_body *	ast_body_to_pjsip_body (pj_pool_t *pool, const struct ast_sip_body *body)
void	ast_copy_pj_str (char *dest, const pj_str_t *src, size_t size)
	Copy a pj_str_t into a standard character buffer. More...
int	ast_copy_pj_str2 (char **dest, const pj_str_t *src)
	Create and copy a pj_str_t into a standard character buffer. More...
struct ast_module *	AST_MODULE_SELF_SYM (void)
int	ast_sip_add_body (pjsip_tx_data *tdata, const struct ast_sip_body *body)
	Add a body to an outbound SIP message. More...
int	ast_sip_add_body_multipart (pjsip_tx_data *tdata, const struct ast_sip_body *bodies[], int num_bodies)
	Add a multipart body to an outbound SIP message. More...
void	ast_sip_add_date_header (pjsip_tx_data *tdata)
	Adds a Date header to the tdata, formatted like: Date: Wed, 01 Jan 2021 14:53:01 GMT. More...
int	ast_sip_add_header (pjsip_tx_data *tdata, const char *name, const char *value)
	Add a header to an outbound SIP message. More...
pjsip_generic_string_hdr *	ast_sip_add_header2 (pjsip_tx_data *tdata, const char *name, const char *value)
	Add a header to an outbound SIP message, returning a pointer to the header. More...
void	ast_sip_add_usereqphone (const struct ast_sip_endpoint *endpoint, pj_pool_t *pool, pjsip_uri *uri)
	Add 'user=phone' parameter to URI if enabled and user is a phone number. More...
int	ast_sip_append_body (pjsip_tx_data *tdata, const char *body_text)
	Append body data to a SIP message. More...
int	ast_sip_are_media_types_equal (pjsip_media_type *a, pjsip_media_type *b)
	Compare pjsip media types. More...
const char *	ast_sip_call_codec_pref_to_str (struct ast_flags pref)
	Convert the call codec preference flags to a string. More...
int	ast_sip_call_codec_str_to_pref (struct ast_flags *pref, const char *pref_str, int is_outgoing)
	Convert a call codec preference string to preference flags. More...
enum ast_sip_check_auth_result	ast_sip_check_authentication (struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, pjsip_tx_data *tdata)
	Method to determine authentication status of an incoming request. More...
pjsip_dialog *	ast_sip_create_dialog_uac (const struct ast_sip_endpoint *endpoint, const char *uri, const char *request_user)
	General purpose method for creating a UAC dialog with an endpoint. More...
pjsip_dialog *	ast_sip_create_dialog_uas (const struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, pj_status_t *status)
	General purpose method for creating a UAS dialog with an endpoint. More...
pjsip_dialog *	ast_sip_create_dialog_uas_locked (const struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, pj_status_t *status)
	General purpose method for creating a UAS dialog with an endpoint. More...
int	ast_sip_create_rdata (pjsip_rx_data *rdata, char *packet, const char *src_name, int src_port, char *transport_type, const char *local_name, int local_port)
	General purpose method for creating an rdata structure using specific information. More...
int	ast_sip_create_rdata_with_contact (pjsip_rx_data *rdata, char *packet, const char *src_name, int src_port, char *transport_type, const char *local_name, int local_port, const char *contact)
	General purpose method for creating an rdata structure using specific information. More...
int	ast_sip_create_request (const char *method, struct pjsip_dialog *dlg, struct ast_sip_endpoint *endpoint, const char *uri, struct ast_sip_contact *contact, pjsip_tx_data **tdata)
	General purpose method for creating a SIP request. More...
int	ast_sip_create_request_with_auth (const struct ast_sip_auth_vector *auths, pjsip_rx_data *challenge, pjsip_tx_data *old_request, pjsip_tx_data **new_request)
	Create a response to an authentication challenge. More...
int	ast_sip_create_response (const pjsip_rx_data *rdata, int st_code, struct ast_sip_contact *contact, pjsip_tx_data **tdata)
	General purpose method for creating a SIP response. More...
struct ast_taskprocessor *	ast_sip_create_serializer (const char *name)
	Create a new serializer for SIP tasks. More...
struct ast_taskprocessor *	ast_sip_create_serializer_group (const char *name, struct ast_serializer_shutdown_group *shutdown_group)
	Create a new serializer for SIP tasks. More...
void *	ast_sip_dict_get (void *ht, const char *key)
	Retrieves the value associated with the given key. More...
void *	ast_sip_dict_set (pj_pool_t *pool, void *ht, const char *key, void *val)
	Set the value for the given key. More...
int	ast_sip_dlg_set_transport (const struct ast_sip_endpoint *endpoint, pjsip_dialog *dlg, pjsip_tpselector *selector)
	Set the transport on a dialog. More...
int	ast_sip_dtmf_to_str (const enum ast_sip_dtmf_mode dtmf, char *buf, size_t buf_len)
	Convert the DTMF mode enum value into a string. More...
int	ast_sip_failover_request (pjsip_tx_data *tdata)
	Set a request to use the next value in the list of resolved addresses. More...
struct ast_sip_transport_state *	ast_sip_find_transport_state_in_use (struct ast_sip_request_transport_details *details)
	Returns the transport state currently in use based on request transport details. More...
int	ast_sip_format_endpoint_ami (struct ast_sip_endpoint *endpoint, struct ast_sip_ami *ami, int *count)
	Formats the endpoint and sends over AMI. More...
pjsip_sip_uri *	ast_sip_get_contact_sip_uri (pjsip_tx_data *tdata)
	Return the SIP URI of the Contact header. More...
struct ast_sip_endpoint *	ast_sip_get_endpoint (const char *to, int get_default_outbound, char **uri)
	Retrieves an endpoint and URI from the "to" string. More...
int	ast_sip_get_host_ip (int af, pj_sockaddr *addr)
	Retrieve the local host address in IP form. More...
const char *	ast_sip_get_host_ip_string (int af)
	Retrieve the local host address in string form. More...
pjsip_endpoint *	ast_sip_get_pjsip_endpoint (void)
	Get a pointer to the PJSIP endpoint. More...
int	ast_sip_get_transport_name (const struct ast_sip_endpoint *endpoint, pjsip_sip_uri *sip_uri, char *buf, size_t buf_len)
	Get the transport name from an endpoint or request uri. More...
const int	ast_sip_hangup_sip2cause (int cause)
	Convert SIP hangup causes to Asterisk hangup causes. More...
struct ast_sip_endpoint *	ast_sip_identify_endpoint (pjsip_rx_data *rdata)
	Determine the endpoint that has sent a SIP message. More...
int	ast_sip_is_allowed_uri (pjsip_uri *uri)
	Check whether a pjsip_uri is allowed or not. More...
int	ast_sip_is_content_type (pjsip_media_type *content_type, char *type, char *subtype)
	Checks if the given content type matches type/subtype. More...
int	ast_sip_is_media_type_in (pjsip_media_type *a,...)
	Check if a media type is in a list of others. More...
int	ast_sip_is_uri_sip_sips (pjsip_uri *uri)
	Check whether a pjsip_uri is SIP/SIPS or not. More...
void	ast_sip_modify_id_header (pj_pool_t *pool, pjsip_fromto_hdr *id_hdr, const struct ast_party_id *id)
	Set name and number information on an identity header. More...
const pj_str_t *	ast_sip_pjsip_uri_get_hostname (pjsip_uri *uri)
	Get the host portion of the pjsip_uri. More...
struct pjsip_param *	ast_sip_pjsip_uri_get_other_param (pjsip_uri *uri, const pj_str_t *param_str)
	Find an 'other' SIP/SIPS URI parameter by name. More...
const pj_str_t *	ast_sip_pjsip_uri_get_username (pjsip_uri *uri)
	Get the user portion of the pjsip_uri. More...
int	ast_sip_push_task (struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
	Pushes a task to SIP servants. More...
int	ast_sip_push_task_synchronous (struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
	Push a task to SIP servants and wait for it to complete. More...
static int	ast_sip_push_task_wait (struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
int	ast_sip_push_task_wait_serializer (struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
	Push a task to the serializer and wait for it to complete. More...
int	ast_sip_push_task_wait_servant (struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
	Push a task to SIP servants and wait for it to complete. More...
char *	ast_sip_rdata_get_header_value (pjsip_rx_data *rdata, const pj_str_t str)
	Get a specific header value from rdata. More...
int	ast_sip_register_authenticator (struct ast_sip_authenticator *auth)
	Register a SIP authenticator. More...
void	ast_sip_register_endpoint_formatter (struct ast_sip_endpoint_formatter *obj)
	Register an endpoint formatter. More...
int	ast_sip_register_endpoint_identifier (struct ast_sip_endpoint_identifier *identifier)
	Register a SIP endpoint identifier. More...
int	ast_sip_register_endpoint_identifier_with_name (struct ast_sip_endpoint_identifier *identifier, const char *name)
	Register a SIP endpoint identifier with a name. More...
int	ast_sip_register_outbound_authenticator (struct ast_sip_outbound_authenticator *auth)
	Register an outbound SIP authenticator. More...
int	ast_sip_register_service (pjsip_module *module)
	Register a SIP service in Asterisk. More...
void	ast_sip_register_supplement (struct ast_sip_supplement *supplement)
	Register a supplement to SIP out of dialog processing. More...
int	ast_sip_requires_authentication (struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata)
	Determine if an incoming request requires authentication. More...
int	ast_sip_rewrite_uri_to_local (pjsip_sip_uri *uri, pjsip_tx_data *tdata)
	Replace domain and port of SIP URI to point to (external) signaling address of this Asterisk instance. More...
int	ast_sip_send_out_of_dialog_request (pjsip_tx_data *tdata, struct ast_sip_endpoint *endpoint, int timeout, void *token, void(*callback)(void *token, pjsip_event *e))
	General purpose method for sending an Out-Of-Dialog SIP request. More...
int	ast_sip_send_request (pjsip_tx_data *tdata, struct pjsip_dialog *dlg, struct ast_sip_endpoint *endpoint, void *token, void(*callback)(void *token, pjsip_event *e))
	General purpose method for sending a SIP request. More...
int	ast_sip_send_response (pjsip_response_addr *res_addr, pjsip_tx_data *tdata, struct ast_sip_endpoint *sip_endpoint)
	Send a response to an out of dialog request. More...
int	ast_sip_send_stateful_response (pjsip_rx_data *rdata, pjsip_tx_data *tdata, struct ast_sip_endpoint *sip_endpoint)
	Send a stateful response to an out of dialog request. More...
int	ast_sip_set_id_connected_line (struct pjsip_rx_data *rdata, struct ast_party_id *id)
	Set the ID for a connected line update. More...
int	ast_sip_set_id_from_invite (struct pjsip_rx_data *rdata, struct ast_party_id *id, struct ast_party_id *default_id, int trust_inbound)
	Set the ID from an INVITE. More...
int	ast_sip_set_outbound_proxy (pjsip_tx_data *tdata, const char *proxy)
	Set the outbound proxy for an outbound SIP message. More...
int	ast_sip_set_request_transport_details (struct ast_sip_request_transport_details *details, pjsip_tx_data *tdata, int use_ipv6)
	Sets request transport details based on tdata. More...
int	ast_sip_set_tpselector_from_ep_or_uri (const struct ast_sip_endpoint *endpoint, pjsip_sip_uri *sip_uri, pjsip_tpselector *selector)
	Sets pjsip_tpselector from an endpoint or uri. More...
int	ast_sip_set_tpselector_from_transport (const struct ast_sip_transport *transport, pjsip_tpselector *selector)
	Sets pjsip_tpselector from ast_sip_transport. More...
int	ast_sip_set_tpselector_from_transport_name (const char *transport_name, pjsip_tpselector *selector)
	Sets pjsip_tpselector from ast_sip_transport. More...
int	ast_sip_str2rc (const char *name)
	Convert name to SIP response code. More...
int	ast_sip_str_to_dtmf (const char *dtmf_mode)
	Convert the DTMF mode name into an enum. More...
int	ast_sip_thread_is_servant (void)
	Determine if the current thread is a SIP servant thread. More...
struct ast_threadpool *	ast_sip_threadpool (void)
	Retrieve the SIP threadpool object. More...
long	ast_sip_threadpool_queue_size (void)
	Return the size of the SIP threadpool's task queue. More...
void	ast_sip_tpselector_unref (pjsip_tpselector *selector)
	Unreference a pjsip_tpselector. More...
void	ast_sip_unregister_authenticator (struct ast_sip_authenticator *auth)
	Unregister a SIP authenticator. More...
void	ast_sip_unregister_endpoint_formatter (struct ast_sip_endpoint_formatter *obj)
	Unregister an endpoint formatter. More...
void	ast_sip_unregister_endpoint_identifier (struct ast_sip_endpoint_identifier *identifier)
	Unregister a SIP endpoint identifier. More...
void	ast_sip_unregister_outbound_authenticator (struct ast_sip_outbound_authenticator *auth)
	Unregister an outbound SIP authenticator. More...
void	ast_sip_unregister_service (pjsip_module *module)
void	ast_sip_unregister_supplement (struct ast_sip_supplement *supplement)
	Unregister a an supplement to SIP out of dialog processing. More...
int	ast_sip_update_from (pjsip_tx_data *tdata, char *from)
	Overwrite fields in the outbound 'From' header. More...
int	ast_sip_update_to_uri (pjsip_tx_data *tdata, const char *to)
	Replace the To URI in the tdata with the supplied one. More...
int	ast_sip_will_uri_survive_restart (pjsip_sip_uri *uri, struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata)
static int	check_request_status (struct send_request_data *req_data, pjsip_event *e)
static void	clean_contact_from_tdata (pjsip_tx_data *tdata)
static char *	cli_dump_endpt (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	cli_show_endpoint_identifiers (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	cli_show_settings (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static pjsip_dialog *	create_dialog_uas (const struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, pj_status_t *status, create_dlg_uac create_fun)
static int	create_in_dialog_request (const pjsip_method *method, struct pjsip_dialog *dlg, pjsip_tx_data **tdata)
static int	create_out_of_dialog_request (const pjsip_method *method, struct ast_sip_endpoint *endpoint, const char *uri, struct ast_sip_contact *provided_contact, pjsip_tx_data **tdata)
static int	do_cli_dump_endpt (void *v_a)
static pj_bool_t	does_method_match (const pj_str_t *message_method, const char *supplement_method)
static pj_status_t	endpt_send_request (struct ast_sip_endpoint *endpoint, pjsip_tx_data *tdata, pj_int32_t timeout, void *token, pjsip_endpt_send_callback cb)
static void	endpt_send_request_cb (void *token, pjsip_event *e)
static int	find_transport_state_in_use (void *obj, void *arg, int flags)
	Callback function for finding the transport the request is going out on. More...
static pjsip_fromto_hdr *	get_id_header (pjsip_rx_data *rdata, const pj_str_t *header_name)
static const pjsip_method *	get_pjsip_method (const char *method)
static struct ast_sip_endpoint *	handle_atsign (const char *to, char *destination, char **uri, char *slash, char *atsign, char *scheme, int get_default_outbound)
static struct ast_sip_endpoint *	handle_single_token (const char *to, char *destination, int get_default_outbound, char **uri)
static struct ast_sip_endpoint *	handle_slash (const char *to, char *destination, char **uri, char *slash, char *atsign, char *scheme)
static int	insert_user_in_contact_uri (const char *to, const char *endpoint_name, const char *aors, const char *user, char **uri)
	Find a contact and insert a "user@" into its URI. More...
static int	load_module (void)
static int	load_pjsip (void)
static void *	monitor_thread_exec (void *endpt)
void	never_called_res_pjsip (void)
static void	pool_destroy_callback (void *arg)
static int	register_service (void *data)
static int	reload_configuration_task (void *obj)
static int	reload_module (void)
static void	remove_request_headers (pjsip_endpoint *endpt)
static int	send_in_dialog_request (pjsip_tx_data *tdata, struct pjsip_dialog *dlg)
static void	send_request_cb (void *token, pjsip_event *e)
static struct send_request_data *	send_request_data_alloc (struct ast_sip_endpoint *endpoint, void *token, void(*callback)(void *token, pjsip_event *e))
static void	send_request_data_destroy (void *obj)
static void	send_request_timer_callback (pj_timer_heap_t *theap, pj_timer_entry *entry)
static void	send_request_wrapper_destructor (void *obj)
static int	set_id_from_from (struct pjsip_rx_data *rdata, struct ast_party_id *id)
static void	set_id_from_hdr (pjsip_fromto_hdr *hdr, struct ast_party_id *id)
static int	set_id_from_pai (pjsip_rx_data *rdata, struct ast_party_id *id)
static int	set_id_from_rpid (pjsip_rx_data *rdata, struct ast_party_id *id)
static int	sip_dialog_create_from (pj_pool_t *pool, pj_str_t *from, const char *user, const char *domain, const pj_str_t *target, pjsip_tpselector *selector)
static void	sip_thread_start (void)
static void	stop_monitor_thread (void)
static pj_bool_t	supplement_on_rx_request (pjsip_rx_data *rdata)
static void	supplement_outgoing_response (pjsip_tx_data *tdata, struct ast_sip_endpoint *sip_endpoint)
static int	sync_task (void *data)
static int	uas_use_sips_contact (pjsip_rx_data *rdata)
	Determine if a SIPS Contact header is required. More...
static int	unload_module (void)
static int	unload_pjsip (void *data)
static int	unregister_service (void *data)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Basic SIP resource" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND - 5, .requires = "dnsmgr,res_pjproject,res_sorcery_config,res_sorcery_memory,res_sorcery_astdb", .optional_modules = "res_geolocation,res_statsd", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static pjsip_endpoint *	ast_pjsip_endpoint
pj_caching_pool	caching_pool
static struct ast_cli_entry	cli_commands []
struct endpoint_formatters	endpoint_formatters = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }
static struct endpoint_identifiers	endpoint_identifiers = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }
static pj_sockaddr	host_ip_ipv4
static char	host_ip_ipv4_string [PJ_INET6_ADDRSTRLEN]
static pj_sockaddr	host_ip_ipv6
static char	host_ip_ipv6_string [PJ_INET6_ADDRSTRLEN]
static const pjsip_method	info_method = {PJSIP_OTHER_METHOD, {"INFO", 4} }
pj_pool_t *	memory_pool
static const pjsip_method	message_method = {PJSIP_OTHER_METHOD, {"MESSAGE", 7} }
struct {
const char *   method
const pjsip_method *   pmethod
}	methods []
static int	monitor_continue
pj_thread_t *	monitor_thread
static struct ast_threadstorage	pj_thread_storage = { .once = PTHREAD_ONCE_INIT , .key_init = __init_pj_thread_storage , .custom_init = NULL , }
pjsip_media_type	pjsip_media_type_application_cpim_xpidf_xml
pjsip_media_type	pjsip_media_type_application_json
pjsip_media_type	pjsip_media_type_application_media_control_xml
pjsip_media_type	pjsip_media_type_application_pidf_xml
pjsip_media_type	pjsip_media_type_application_rlmi_xml
pjsip_media_type	pjsip_media_type_application_sdp
pjsip_media_type	pjsip_media_type_application_simple_message_summary
pjsip_media_type	pjsip_media_type_application_xpidf_xml
pjsip_media_type	pjsip_media_type_multipart_alternative
pjsip_media_type	pjsip_media_type_multipart_mixed
pjsip_media_type	pjsip_media_type_multipart_related
pjsip_media_type	pjsip_media_type_text_plain
static const struct response_code_map	rc_map []
static const pjsip_method	refer_method = {PJSIP_OTHER_METHOD, {"REFER", 5} }
static struct ast_sip_authenticator *	registered_authenticator
static struct ast_sip_outbound_authenticator *	registered_outbound_authenticator
static struct ast_threadstorage	servant_id_storage = { .once = PTHREAD_ONCE_INIT , .key_init = __init_servant_id_storage , .custom_init = NULL , }
static struct ast_serializer_pool *	sip_serializer_pool
static struct ast_threadpool *	sip_threadpool
static pjsip_module	supplement_module
struct supplements	supplements = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

Macro Definition Documentation

DEBUG_BUF_SIZE

#define DEBUG_BUF_SIZE   256

ENDPOINT_IDENTIFIER_FORMAT

#define ENDPOINT_IDENTIFIER_FORMAT   "%-20.20s\n"

MOD_DATA_CONTACT

#define MOD_DATA_CONTACT   "contact"

Definition at line 66 of file res_pjsip.c.

SERIALIZER_POOL_SIZE

#define SERIALIZER_POOL_SIZE   8

Number of serializers in pool if one not supplied.

Definition at line 69 of file res_pjsip.c.

SIP_SERVANT_ID

#define SIP_SERVANT_ID   0x5E2F1D

Definition at line 2283 of file res_pjsip.c.

TIMEOUT_TIMER2

#define TIMEOUT_TIMER2   5

Definition at line 1513 of file res_pjsip.c.

TIMER_INACTIVE

#define TIMER_INACTIVE   0

Definition at line 1512 of file res_pjsip.c.

Typedef Documentation

create_dlg_uac

typedef pj_status_t(* create_dlg_uac) (pjsip_user_agent *ua, pjsip_rx_data *rdata, const pj_str_t *contact, pjsip_dialog **p_dlg)

Definition at line 1115 of file res_pjsip.c.

Function Documentation

__init_pj_thread_storage()

static void __init_pj_thread_storage ( void  )

static

Definition at line 2281 of file res_pjsip.c.

{

__init_servant_id_storage()

static void __init_servant_id_storage ( void  )

static

Definition at line 2282 of file res_pjsip.c.

{

__reg_module()

static void __reg_module ( void  )

static

Definition at line 4097 of file res_pjsip.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 4097 of file res_pjsip.c.

ast_body_to_pjsip_body()

static pjsip_msg_body * ast_body_to_pjsip_body ( pj_pool_t *  pool, const struct ast_sip_body *  body  )

static

Definition at line 2039 of file res_pjsip.c.

{
    pj_str_t type;
    pj_str_t subtype;
    pj_str_t body_text;
 
    pj_cstr(&type, body->type);
    pj_cstr(&subtype, body->subtype);
    pj_cstr(&body_text, body->body_text);
 
    return pjsip_msg_body_create(pool, &type, &subtype, &body_text);
}

References ast_sip_body::body_text, ast_sip_body::subtype, type, and ast_sip_body::type.

Referenced by ast_sip_add_body(), and ast_sip_add_body_multipart().

ast_copy_pj_str()

void ast_copy_pj_str	(	char *	dest,
		const pj_str_t *	src,
		size_t	size
	)

Copy a pj_str_t into a standard character buffer.

pj_str_t is not NULL-terminated. Any place that expects a NULL- terminated string needs to have the pj_str_t copied into a separate buffer.

This method copies the pj_str_t contents into the destination buffer and NULL-terminates the buffer.

Parameters

dest	The destination buffer
src	The pj_str_t to copy
size	The size of the destination buffer.

Definition at line 2201 of file res_pjsip.c.

{
    size_t chars_to_copy = MIN(size - 1, pj_strlen(src));
    memcpy(dest, pj_strbuf(src), chars_to_copy);
    dest[chars_to_copy] = '\0';
}

References MIN.

Referenced by apply_dtls_attrib(), apply_negotiated_sdp_stream(), assign_uuid(), ast_sip_get_transport_name(), ast_sip_header_to_security_mechanism(), ast_sip_report_auth_challenge_sent(), ast_sip_report_auth_failed_challenge_response(), chan_pjsip_get_uniqueid(), change_outgoing_sdp_stream_media_address(), channel_read_pjsip(), cli_complete_subscription_common(), cli_list_subscriptions_detail(), cli_show_subscriptions_detail(), copy_string(), determine_sip_publish_type(), dialog_info_generate_body_content(), endpoint_lookup(), evaluate_like(), extract_contact_addr(), extract_oli(), find_aor2(), find_aor_name(), find_authorization(), get_auth_header(), get_codecs(), get_dest_tn(), get_destination(), get_endpoint_details(), get_from_header(), get_mid_bundle_group(), get_user_agent(), handle_incoming_request(), handle_incoming_sdp(), handle_negotiated_sdp_session_media(), handle_registration_response(), headers_to_vars(), incoming_in_dialog_request(), log_failed_request(), negotiate_incoming_sdp_stream(), options_on_rx_request(), parse_uri_cb(), process_extmap_attributes(), process_ice_attributes(), process_ice_auth_attrb(), process_ssrc_attributes(), publish_request_initial(), pubsub_on_rx_publish_request(), pubsub_on_rx_subscribe_request(), refer_blind_callback(), refer_incoming_ari_request(), refer_incoming_blind_request(), refer_incoming_refer_request(), rfc3326_use_reason_header(), rfc3329_incoming_response(), rx_data_to_ast_msg(), save_response_fields_to_transport(), sdp_requires_deferral(), security_event_populate(), session_inv_on_redirected(), session_outgoing_nat_hook(), set_id_from_hdr(), set_mid_and_bundle_group(), set_redirecting_value(), set_remote_mslabel_and_stream_group(), set_sipdomain_variable(), sip_subscription_to_ami(), sub_persistence_recreate(), subscription_get_generator_from_rdata(), subscription_get_handler_from_rdata(), subscription_persistence_create(), subscription_persistence_update(), and transfer_refer().

ast_copy_pj_str2()

int ast_copy_pj_str2	(	char **	dest,
		const pj_str_t *	src
	)

Create and copy a pj_str_t into a standard character buffer.

pj_str_t is not NULL-terminated. Any place that expects a NULL- terminated string needs to have the pj_str_t copied into a separate buffer.

Copies the pj_str_t contents into a newly allocated buffer pointed to by dest. NULL-terminates the buffer.

Note

Caller is responsible for freeing the allocated memory.

Parameters

[out]	dest	The destination buffer
	src	The pj_str_t to copy

Returns

Number of characters copied or negative value on error

Definition at line 2208 of file res_pjsip.c.

{
    int res = ast_asprintf(dest, "%.*s", (int)pj_strlen(src), pj_strbuf(src));
 
    if (res < 0) {
        *dest = NULL;
    }
 
    return res;
}

References ast_asprintf, and NULL.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 4097 of file res_pjsip.c.

ast_sip_add_body()

int ast_sip_add_body	(	pjsip_tx_data *	tdata,
		const struct ast_sip_body *	body
	)

Add a body to an outbound SIP message.

If this is called multiple times, the latest body will replace the current body.

Parameters

tdata	The message to add the body to
body	The message body to add

Return values

0	Success
-1	Failure

Definition at line 2052 of file res_pjsip.c.

{
    pjsip_msg_body *pjsip_body = ast_body_to_pjsip_body(tdata->pool, body);
    tdata->msg->body = pjsip_body;
    return 0;
}

References ast_body_to_pjsip_body().

Referenced by aoc_bye_outgoing_request(), aoc_bye_outgoing_response(), aoc_send_as_xml(), build_notify_body(), msg_send(), send_unsolicited_mwi_notify_to_contact(), sendtext(), sip_publisher_service_queue(), transmit_info_dtmf(), and transmit_info_with_vidupdate().

ast_sip_add_body_multipart()

int ast_sip_add_body_multipart	(	pjsip_tx_data *	tdata,
		const struct ast_sip_body *	bodies[],
		int	num_bodies
	)

Add a multipart body to an outbound SIP message.

This will treat each part of the input vector as part of a multipart body and add each part to the SIP message.

Parameters

tdata	The message to add the body to
bodies	The message bodies to add
num_bodies	The parts of the body to add

Return values

0	Success
-1	Failure

Definition at line 2059 of file res_pjsip.c.

{
    int i;
    /* NULL for type and subtype automatically creates "multipart/mixed" */
    pjsip_msg_body *body = pjsip_multipart_create(tdata->pool, NULL, NULL);
 
    for (i = 0; i < num_bodies; ++i) {
        pjsip_multipart_part *part = pjsip_multipart_create_part(tdata->pool);
        part->body = ast_body_to_pjsip_body(tdata->pool, bodies[i]);
        pjsip_multipart_add_part(tdata->pool, body, part);
    }
 
    tdata->msg->body = body;
    return 0;
}

References ast_body_to_pjsip_body(), and NULL.

ast_sip_add_date_header()

void ast_sip_add_date_header

(

pjsip_tx_data *

tdata

)

Adds a Date header to the tdata, formatted like: Date: Wed, 01 Jan 2021 14:53:01 GMT.

Since

16.19.0

Note

There is no checking done to see if the header already exists before adding it. It's up to the caller of this function to determine if that needs to be done or not.

Definition at line 90 of file res_pjsip.c.

{
    char date[256];
    struct tm tm;
    time_t t = time(NULL);
 
    gmtime_r(&t, &tm);
    strftime(date, sizeof(date), "%a, %d %b %Y %T GMT", &tm);
 
    ast_sip_add_header(tdata, "Date", date);
}

References ast_sip_add_header(), and NULL.

Referenced by add_date_header().

ast_sip_add_header()

int ast_sip_add_header	(	pjsip_tx_data *	tdata,
		const char *	name,
		const char *	value
	)

Add a header to an outbound SIP message.

Parameters

tdata	The message to add the header to
name	The header name
value	The header value

Return values

0	Success
-1	Failure

Definition at line 2008 of file res_pjsip.c.

{
    pj_str_t hdr_name;
    pj_str_t hdr_value;
    pjsip_generic_string_hdr *hdr;
 
    pj_cstr(&hdr_name, name);
    pj_cstr(&hdr_value, value);
 
    hdr = pjsip_generic_string_hdr_create(tdata->pool, &hdr_name, &hdr_value);
 
    pjsip_msg_add_hdr(tdata->msg, (pjsip_hdr *) hdr);
    return 0;
}

References name, and value.

Referenced by add_header_from_channel_var(), add_headers_to_message(), ast_sip_add_date_header(), ast_sip_add_security_headers(), ast_sip_message_apply_transport(), build_notify(), handle_outgoing_request(), notify_channel(), notify_contact(), notify_uri(), options_incoming_request(), rfc3326_add_reason_header(), send_options_response(), sip_publication_respond(), transfer_refer(), and vars_to_headers().

ast_sip_add_header2()

pjsip_generic_string_hdr * ast_sip_add_header2	(	pjsip_tx_data *	tdata,
		const char *	name,
		const char *	value
	)

Add a header to an outbound SIP message, returning a pointer to the header.

Parameters

tdata	The message to add the header to
name	The header name
value	The header value

Returns

The pjsip_generic_string_hdr * added.

Definition at line 2023 of file res_pjsip.c.

{
    pj_str_t hdr_name;
    pj_str_t hdr_value;
    pjsip_generic_string_hdr *hdr;
 
    pj_cstr(&hdr_name, name);
    pj_cstr(&hdr_value, value);
 
    hdr = pjsip_generic_string_hdr_create(tdata->pool, &hdr_name, &hdr_value);
 
    pjsip_msg_add_hdr(tdata->msg, (pjsip_hdr *) hdr);
    return hdr;
}

References name, and value.

Referenced by handle_outgoing_request().

ast_sip_add_usereqphone()

void ast_sip_add_usereqphone	(	const struct ast_sip_endpoint *	endpoint,
		pj_pool_t *	pool,
		pjsip_uri *	uri
	)

Add 'user=phone' parameter to URI if enabled and user is a phone number.

Parameters

endpoint	The endpoint to use for configuration
pool	The memory pool to allocate the parameter from
uri	The URI to check for user and to add parameter to

Definition at line 930 of file res_pjsip.c.

{
    pjsip_sip_uri *sip_uri;
    int i = 0;
    static const pj_str_t STR_PHONE = { "phone", 5 };
 
    if (!endpoint || !endpoint->usereqphone || (!PJSIP_URI_SCHEME_IS_SIP(uri) && !PJSIP_URI_SCHEME_IS_SIPS(uri))) {
        return;
    }
 
    sip_uri = pjsip_uri_get_uri(uri);
 
    if (!pj_strlen(&sip_uri->user)) {
        return;
    }
 
    if (pj_strbuf(&sip_uri->user)[0] == '+') {
        i = 1;
    }
 
    /* Test URI user against allowed characters in AST_DIGIT_ANY */
    for (; i < pj_strlen(&sip_uri->user); i++) {
        if (!strchr(AST_DIGIT_ANY, pj_strbuf(&sip_uri->user)[i])) {
            break;
        }
    }
 
    if (i < pj_strlen(&sip_uri->user)) {
        return;
    }
 
    sip_uri->user_param = STR_PHONE;
}

References AST_DIGIT_ANY, and ast_sip_endpoint::usereqphone.

Referenced by ast_sip_create_dialog_uac(), create_out_of_dialog_request(), and set_from_header().

ast_sip_append_body()

int ast_sip_append_body	(	pjsip_tx_data *	tdata,
		const char *	body_text
	)

Append body data to a SIP message.

This acts mostly the same as ast_sip_add_body, except that rather than replacing a body if it currently exists, it appends data to an existing body.

Parameters

tdata	The message to append the body to
body_text	The string to append to the end of the current body

Return values

0	Success
-1	Failure

Definition at line 2075 of file res_pjsip.c.

{
    size_t combined_size = strlen(body_text) + tdata->msg->body->len;
    struct ast_str *body_buffer = ast_str_alloca(combined_size);
 
    ast_str_set(&body_buffer, 0, "%.*s%s", (int) tdata->msg->body->len, (char *) tdata->msg->body->data, body_text);
 
    tdata->msg->body->data = pj_pool_alloc(tdata->pool, combined_size);
    pj_memcpy(tdata->msg->body->data, ast_str_buffer(body_buffer), combined_size);
    tdata->msg->body->len = combined_size;
 
    return 0;
}

References ast_str_alloca, ast_str_buffer(), and ast_str_set().

ast_sip_are_media_types_equal()

int ast_sip_are_media_types_equal	(	pjsip_media_type *	a,
		pjsip_media_type *	b
	)

Compare pjsip media types.

Parameters

a	the first media type
b	the second media type

Return values

1	Media types are equal
0	Media types are not equal

Definition at line 2219 of file res_pjsip.c.

{
    int rc = 0;
    if (a != NULL && b != NULL) {
        rc = pjsip_media_type_cmp(a, b, 0) ? 0 : 1;
    }
    return rc;
}

References a, b, and NULL.

Referenced by find_pidf(), and video_info_incoming_request().

ast_sip_call_codec_pref_to_str()

const char * ast_sip_call_codec_pref_to_str

(

struct ast_flags

pref

)

Convert the call codec preference flags to a string.

Since

18.0.0

Parameters

pref	the call codec preference setting

Returns

a constant string with either the setting value or 'unknown'

Note

Don't try to free the string!

Definition at line 2554 of file res_pjsip.c.

{
    const char *value;
 
    if (ast_sip_call_codec_pref_test(pref, LOCAL) &&  ast_sip_call_codec_pref_test(pref, INTERSECT) && ast_sip_call_codec_pref_test(pref, ALL)) {
        value = "local";
    } else if (ast_sip_call_codec_pref_test(pref, LOCAL) &&  ast_sip_call_codec_pref_test(pref, UNION) && ast_sip_call_codec_pref_test(pref, ALL)) {
        value = "local_merge";
    } else if (ast_sip_call_codec_pref_test(pref, LOCAL) &&  ast_sip_call_codec_pref_test(pref, INTERSECT) && ast_sip_call_codec_pref_test(pref, FIRST)) {
        value = "local_first";
    } else if (ast_sip_call_codec_pref_test(pref, REMOTE) &&  ast_sip_call_codec_pref_test(pref, INTERSECT) && ast_sip_call_codec_pref_test(pref, ALL)) {
        value = "remote";
    } else if (ast_sip_call_codec_pref_test(pref, REMOTE) &&  ast_sip_call_codec_pref_test(pref, UNION) && ast_sip_call_codec_pref_test(pref, ALL)) {
        value = "remote_merge";
    } else if (ast_sip_call_codec_pref_test(pref, REMOTE) &&  ast_sip_call_codec_pref_test(pref, UNION) && ast_sip_call_codec_pref_test(pref, FIRST)) {
        value = "remote_first";
    } else {
        value = "unknown";
    }
 
    return value;
}

References ast_sip_call_codec_pref_test, and value.

Referenced by incoming_call_offer_pref_to_str(), log_caps(), and outgoing_call_offer_pref_to_str().

ast_sip_call_codec_str_to_pref()

int ast_sip_call_codec_str_to_pref	(	struct ast_flags *	pref,
		const char *	pref_str,
		int	is_outgoing
	)

Convert a call codec preference string to preference flags.

Since

18.0.0

Parameters

pref	A pointer to an ast_flags structure to receive the preference flags
pref_str	The call codec preference setting string
is_outgoing	Is for outgoing calls?

Return values

0	The string was parsed successfully
-1	The string option was invalid

Definition at line 2577 of file res_pjsip.c.

{
    pref->flags = 0;
 
    if (strcmp(pref_str, "local") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_LOCAL | AST_SIP_CALL_CODEC_PREF_INTERSECT | AST_SIP_CALL_CODEC_PREF_ALL);
    } else if (is_outgoing && strcmp(pref_str, "local_merge") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_LOCAL | AST_SIP_CALL_CODEC_PREF_UNION | AST_SIP_CALL_CODEC_PREF_ALL);
    } else if (strcmp(pref_str, "local_first") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_LOCAL | AST_SIP_CALL_CODEC_PREF_INTERSECT | AST_SIP_CALL_CODEC_PREF_FIRST);
    } else if (strcmp(pref_str, "remote") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_REMOTE | AST_SIP_CALL_CODEC_PREF_INTERSECT | AST_SIP_CALL_CODEC_PREF_ALL);
    } else if (is_outgoing && strcmp(pref_str, "remote_merge") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_REMOTE | AST_SIP_CALL_CODEC_PREF_UNION | AST_SIP_CALL_CODEC_PREF_ALL);
    } else if (strcmp(pref_str, "remote_first") == 0) {
        ast_set_flag(pref, AST_SIP_CALL_CODEC_PREF_REMOTE | AST_SIP_CALL_CODEC_PREF_UNION | AST_SIP_CALL_CODEC_PREF_FIRST);
    } else {
        return -1;
    }
 
    return 0;
}

References ast_set_flag, AST_SIP_CALL_CODEC_PREF_ALL, AST_SIP_CALL_CODEC_PREF_FIRST, AST_SIP_CALL_CODEC_PREF_INTERSECT, AST_SIP_CALL_CODEC_PREF_LOCAL, AST_SIP_CALL_CODEC_PREF_REMOTE, AST_SIP_CALL_CODEC_PREF_UNION, and ast_flags::flags.

Referenced by call_offer_pref_handler(), and test_create_joint().

ast_sip_check_authentication()

enum ast_sip_check_auth_result ast_sip_check_authentication	(	struct ast_sip_endpoint *	endpoint,
		pjsip_rx_data *	rdata,
		pjsip_tx_data *	tdata
	)

Method to determine authentication status of an incoming request.

This will call into a registered authenticator. The registered authenticator will do what is necessary to determine whether the incoming request passes authentication. A tentative response is passed into this function so that if, say, a digest authentication challenge should be sent in the ensuing response, it can be added to the response.

Parameters

endpoint	The endpoint from the request was sent
rdata	The request to potentially authenticate
tdata	Tentative response to the request

Returns

The result of checking authentication.

Definition at line 179 of file res_pjsip.c.

{
    if (!registered_authenticator) {
        ast_log(LOG_WARNING, "No SIP authenticator registered. Assuming authentication is successful\n");
        return AST_SIP_AUTHENTICATION_SUCCESS;
    }
    return registered_authenticator->check_authentication(endpoint, rdata, tdata);
}

References ast_log, AST_SIP_AUTHENTICATION_SUCCESS, ast_sip_authenticator::check_authentication, LOG_WARNING, and registered_authenticator.

Referenced by authenticate().

ast_sip_create_dialog_uac()

pjsip_dialog * ast_sip_create_dialog_uac	(	const struct ast_sip_endpoint *	endpoint,
		const char *	aor_name,
		const char *	request_user
	)

General purpose method for creating a UAC dialog with an endpoint.

Parameters

endpoint	A pointer to the endpoint
aor_name	Optional name of the AOR to target, may even be an explicit SIP URI
request_user	Optional user to place into the target URI

Return values

non-NULL	success
NULL	failure

Definition at line 964 of file res_pjsip.c.

{
    char enclosed_uri[PJSIP_MAX_URL_SIZE];
    pj_str_t local_uri = { "sip:temp@temp", 13 }, remote_uri, target_uri;
    pj_status_t res;
    pjsip_dialog *dlg = NULL;
    const char *outbound_proxy = endpoint->outbound_proxy;
    pjsip_tpselector selector = { .type = PJSIP_TPSELECTOR_NONE, };
    static const pj_str_t HCONTACT = { "Contact", 7 };
 
    if (!ast_begins_with(uri, "<")) {
        snprintf(enclosed_uri, sizeof(enclosed_uri), "<%s>", uri);
    } else {
        snprintf(enclosed_uri, sizeof(enclosed_uri), "%s", uri);
    }
    pj_cstr(&remote_uri, enclosed_uri);
 
    pj_cstr(&target_uri, uri);
 
    res = pjsip_dlg_create_uac(pjsip_ua_instance(), &local_uri, NULL, &remote_uri, &target_uri, &dlg);
    if (res == PJ_SUCCESS && !(PJSIP_URI_SCHEME_IS_SIP(dlg->target) || PJSIP_URI_SCHEME_IS_SIPS(dlg->target))) {
        /* dlg->target is a pjsip_other_uri, but it's assumed to be a
         * pjsip_sip_uri below. Fail fast. */
        res = PJSIP_EINVALIDURI;
        pjsip_dlg_terminate(dlg);
    }
    if (res != PJ_SUCCESS) {
        if (res == PJSIP_EINVALIDURI) {
            ast_log(LOG_ERROR,
                "Endpoint '%s': Could not create dialog to invalid URI '%s'.  Is endpoint registered and reachable?\n",
                ast_sorcery_object_get_id(endpoint), uri);
        }
        return NULL;
    }
 
    /* We have to temporarily bump up the sess_count here so the dialog is not prematurely destroyed */
    dlg->sess_count++;
 
    ast_sip_dlg_set_transport(endpoint, dlg, &selector);
 
    if (sip_dialog_create_from(dlg->pool, &local_uri, endpoint->fromuser, endpoint->fromdomain, &remote_uri, &selector)) {
        dlg->sess_count--;
        pjsip_dlg_terminate(dlg);
        ast_sip_tpselector_unref(&selector);
        return NULL;
    }
 
    ast_sip_tpselector_unref(&selector);
 
    /* Update the dialog with the new local URI, we do it afterwards so we can use the dialog pool for construction */
    pj_strdup_with_null(dlg->pool, &dlg->local.info_str, &local_uri);
    dlg->local.info->uri = pjsip_parse_uri(dlg->pool, dlg->local.info_str.ptr, dlg->local.info_str.slen, 0);
    if (!dlg->local.info->uri) {
        ast_log(LOG_ERROR,
            "Could not parse URI '%s' for endpoint '%s'\n",
            dlg->local.info_str.ptr, ast_sorcery_object_get_id(endpoint));
        dlg->sess_count--;
        pjsip_dlg_terminate(dlg);
        return NULL;
    }
 
    dlg->local.contact = pjsip_parse_hdr(dlg->pool, &HCONTACT, local_uri.ptr, local_uri.slen, NULL);
 
    if (!ast_strlen_zero(endpoint->contact_user)) {
        pjsip_sip_uri *sip_uri;
 
        sip_uri = pjsip_uri_get_uri(dlg->local.contact->uri);
        pj_strdup2(dlg->pool, &sip_uri->user, endpoint->contact_user);
    }
 
    /* If a request user has been specified and we are permitted to change it, do so */
    if (!ast_strlen_zero(request_user)) {
        pjsip_sip_uri *sip_uri;
 
        if (PJSIP_URI_SCHEME_IS_SIP(dlg->target) || PJSIP_URI_SCHEME_IS_SIPS(dlg->target)) {
            sip_uri = pjsip_uri_get_uri(dlg->target);
            pj_strdup2(dlg->pool, &sip_uri->user, request_user);
        }
        if (PJSIP_URI_SCHEME_IS_SIP(dlg->remote.info->uri) || PJSIP_URI_SCHEME_IS_SIPS(dlg->remote.info->uri)) {
            sip_uri = pjsip_uri_get_uri(dlg->remote.info->uri);
            pj_strdup2(dlg->pool, &sip_uri->user, request_user);
        }
    }
 
    /* Add the user=phone parameter if applicable */
    ast_sip_add_usereqphone(endpoint, dlg->pool, dlg->target);
    ast_sip_add_usereqphone(endpoint, dlg->pool, dlg->remote.info->uri);
    ast_sip_add_usereqphone(endpoint, dlg->pool, dlg->local.info->uri);
 
    if (!ast_strlen_zero(outbound_proxy)) {
        pjsip_route_hdr route_set, *route;
        static const pj_str_t ROUTE_HNAME = { "Route", 5 };
        pj_str_t tmp;
 
        pj_list_init(&route_set);
 
        pj_strdup2_with_null(dlg->pool, &tmp, outbound_proxy);
        if (!(route = pjsip_parse_hdr(dlg->pool, &ROUTE_HNAME, tmp.ptr, tmp.slen, NULL))) {
            ast_log(LOG_ERROR, "Could not create dialog to endpoint '%s' as outbound proxy URI '%s' is not valid\n",
                ast_sorcery_object_get_id(endpoint), outbound_proxy);
            dlg->sess_count--;
            pjsip_dlg_terminate(dlg);
            return NULL;
        }
        pj_list_insert_nodes_before(&route_set, route);
 
        pjsip_dlg_set_route_set(dlg, &route_set);
    }
 
    dlg->sess_count--;
 
    return dlg;
}

References ast_begins_with(), ast_log, ast_sip_add_usereqphone(), ast_sip_dlg_set_transport(), ast_sip_tpselector_unref(), ast_sorcery_object_get_id(), ast_strlen_zero(), ast_sip_endpoint::contact_user, ast_sip_endpoint::fromdomain, ast_sip_endpoint::fromuser, ast_sip_endpoint::info, LOG_ERROR, NULL, ast_sip_endpoint::outbound_proxy, and sip_dialog_create_from().

Referenced by ast_sip_create_subscription(), ast_sip_session_create_outgoing(), and refer_send().

ast_sip_create_dialog_uas()

pjsip_dialog * ast_sip_create_dialog_uas	(	const struct ast_sip_endpoint *	endpoint,
		pjsip_rx_data *	rdata,
		pj_status_t *	status
	)

General purpose method for creating a UAS dialog with an endpoint.

Deprecated:

This function is unsafe (due to the returned object not being locked nor having its reference incremented) and should no longer be used. Instead use ast_sip_create_dialog_uas_locked so a properly locked and referenced object is returned.

Parameters

	endpoint	A pointer to the endpoint
	rdata	The request that is starting the dialog
[out]	status	On failure, the reason for failure in creating the dialog

Definition at line 1176 of file res_pjsip.c.

{
#ifdef HAVE_PJSIP_DLG_CREATE_UAS_AND_INC_LOCK
    pjsip_dialog *dlg;
 
    dlg = create_dialog_uas(endpoint, rdata, status, pjsip_dlg_create_uas_and_inc_lock);
    if (dlg) {
        pjsip_dlg_dec_lock(dlg);
    }
 
    return dlg;
#else
    return create_dialog_uas(endpoint, rdata, status, pjsip_dlg_create_uas);
#endif
}

References create_dialog_uas(), and status.

ast_sip_create_dialog_uas_locked()

pjsip_dialog * ast_sip_create_dialog_uas_locked	(	const struct ast_sip_endpoint *	endpoint,
		pjsip_rx_data *	rdata,
		pj_status_t *	status
	)

General purpose method for creating a UAS dialog with an endpoint.

This function creates and returns a locked, and referenced counted pjsip dialog object. The caller is thus responsible for freeing the allocated memory, decrementing the reference, and releasing the lock when done with the returned object.

Note

The safest way to unlock the object, and decrement its reference is by calling pjsip_dlg_dec_lock. Alternatively, pjsip_dlg_dec_session can be used to decrement the reference only.

The dialog is returned locked and with a reference in order to ensure that the dialog object, and any of its associated objects (e.g. transaction) are not untimely destroyed. For instance, that could happen when a transport error occurs.

As long as the caller maintains a reference to the dialog there should be no worry that it might unknowingly be destroyed. However, once the caller unlocks the dialog there is a danger that some of the dialog's internal objects could be lost and/or compromised. For example, when the aforementioned transport error occurs the dialog's associated transaction gets destroyed (see pjsip_dlg_on_tsx_state in sip_dialog.c, and mod_inv_on_tsx_state in sip_inv.c).

In this case and before using the dialog again the caller should re-lock the dialog, check to make sure the dialog is still established, and the transaction still exists and has not been destroyed.

Parameters

	endpoint	A pointer to the endpoint
	rdata	The request that is starting the dialog
[out]	status	On failure, the reason for failure in creating the dialog

Return values

A	locked, and reference counted pjsip_dialog object.
NULL	on failure

Definition at line 1192 of file res_pjsip.c.

{
#ifdef HAVE_PJSIP_DLG_CREATE_UAS_AND_INC_LOCK
    return create_dialog_uas(endpoint, rdata, status, pjsip_dlg_create_uas_and_inc_lock);
#else
    /*
     * This is put here in order to be compatible with older versions of pjproject.
     * Best we can do in this case is immediately lock after getting the dialog.
     * However, that does leave a "gap" between creating and locking.
     */
    pjsip_dialog *dlg;
 
    dlg = create_dialog_uas(endpoint, rdata, status, pjsip_dlg_create_uas);
    if (dlg) {
        pjsip_dlg_inc_lock(dlg);
    }
 
    return dlg;
#endif
 }

References create_dialog_uas(), and status.

Referenced by create_subscription_tree(), and pre_session_setup().

ast_sip_create_rdata()

int ast_sip_create_rdata	(	pjsip_rx_data *	rdata,
		char *	packet,
		const char *	src_name,
		int	src_port,
		char *	transport_type,
		const char *	local_name,
		int	local_port
	)

General purpose method for creating an rdata structure using specific information.

Parameters

[out]	rdata	The rdata structure that will be populated
	packet	A SIP message
	src_name	The source IP address of the message
	src_port	The source port of the message
	transport_type	The type of transport the message was received on
	local_name	The local IP address the message was received on
	local_port	The local port the message was received on

Return values

0	success
-1	failure

Definition at line 1266 of file res_pjsip.c.

{
    return ast_sip_create_rdata_with_contact(rdata, packet, src_name, src_port, transport_type,
        local_name, local_port, NULL);
}

References ast_sip_create_rdata_with_contact(), and NULL.

ast_sip_create_rdata_with_contact()

int ast_sip_create_rdata_with_contact	(	pjsip_rx_data *	rdata,
		char *	packet,
		const char *	src_name,
		int	src_port,
		char *	transport_type,
		const char *	local_name,
		int	local_port,
		const char *	contact_uri
	)

General purpose method for creating an rdata structure using specific information.

Since

13.15.0

Parameters

[out]	rdata	The rdata structure that will be populated
	packet	A SIP message
	src_name	The source IP address of the message
	src_port	The source port of the message
	transport_type	The type of transport the message was received on
	local_name	The local IP address the message was received on
	local_port	The local port the message was received on
	contact_uri	The contact URI of the message

Return values

0	success
-1	failure

Definition at line 1214 of file res_pjsip.c.

{
    pj_str_t tmp;
 
    /*
     * Initialize the error list in case there is a parse error
     * in the given packet.
     */
    pj_list_init(&rdata->msg_info.parse_err);
 
    rdata->tp_info.transport = PJ_POOL_ZALLOC_T(rdata->tp_info.pool, pjsip_transport);
    if (!rdata->tp_info.transport) {
        return -1;
    }
 
    ast_copy_string(rdata->pkt_info.packet, packet, sizeof(rdata->pkt_info.packet));
    ast_copy_string(rdata->pkt_info.src_name, src_name, sizeof(rdata->pkt_info.src_name));
    rdata->pkt_info.src_port = src_port;
    pj_sockaddr_parse(pj_AF_UNSPEC(), 0, pj_cstr(&tmp, src_name), &rdata->pkt_info.src_addr);
    pj_sockaddr_set_port(&rdata->pkt_info.src_addr, src_port);
 
    pjsip_parse_rdata(packet, strlen(packet), rdata);
    if (!rdata->msg_info.msg || !pj_list_empty(&rdata->msg_info.parse_err)) {
        return -1;
    }
 
    if (!ast_strlen_zero(contact)) {
        pjsip_contact_hdr *contact_hdr;
 
        contact_hdr = pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_CONTACT, NULL);
        if (contact_hdr) {
            contact_hdr->uri = pjsip_parse_uri(rdata->tp_info.pool, (char *)contact,
                strlen(contact), PJSIP_PARSE_URI_AS_NAMEADDR);
            if (!contact_hdr->uri) {
                ast_log(LOG_WARNING, "Unable to parse contact URI from '%s'.\n", contact);
                return -1;
            }
        }
    }
 
    pj_strdup2(rdata->tp_info.pool, &rdata->msg_info.via->recvd_param, rdata->pkt_info.src_name);
    rdata->msg_info.via->rport_param = -1;
 
    rdata->tp_info.transport->key.type = pjsip_transport_get_type_from_name(pj_cstr(&tmp, transport_type));
    rdata->tp_info.transport->type_name = transport_type;
    pj_strdup2(rdata->tp_info.pool, &rdata->tp_info.transport->local_name.host, local_name);
    rdata->tp_info.transport->local_name.port = local_port;
 
    return 0;
}

References ast_copy_string(), ast_log, ast_strlen_zero(), LOG_WARNING, and NULL.

Referenced by ast_sip_create_rdata(), and subscription_persistence_recreate().

ast_sip_create_request()

int ast_sip_create_request	(	const char *	method,
		struct pjsip_dialog *	dlg,
		struct ast_sip_endpoint *	endpoint,
		const char *	uri,
		struct ast_sip_contact *	contact,
		pjsip_tx_data **	tdata
	)

General purpose method for creating a SIP request.

Its typical use would be to create one-off requests such as an out of dialog SIP MESSAGE.

The request can either be in- or out-of-dialog. If in-dialog, the dlg parameter MUST be present. If out-of-dialog the endpoint parameter MUST be present. If both are present, then we will assume that the message is to be sent in-dialog.

The uri parameter can be specified if the request should be sent to an explicit URI rather than one configured on the endpoint.

Parameters

	method	The method of the SIP request to send
	dlg	Optional. If specified, the dialog on which to request the message.
	endpoint	Optional. If specified, the request will be created out-of-dialog to the endpoint.
	uri	Optional. If specified, the request will be sent to this URI rather than one configured for the endpoint.
	contact	The contact with which this request is associated for out-of-dialog requests.
[out]	tdata	The newly-created request

The provided contact is attached to tdata with its reference bumped, but will not survive for the entire lifetime of tdata since the contact is cleaned up when all supplements have completed execution.

Return values

0	Success
-1	Failure

Definition at line 1435 of file res_pjsip.c.

{
    const pjsip_method *pmethod = get_pjsip_method(method);
 
    if (!pmethod) {
        ast_log(LOG_WARNING, "Unknown method '%s'. Cannot send request\n", method);
        return -1;
    }
 
    if (dlg) {
        return create_in_dialog_request(pmethod, dlg, tdata);
    } else {
        ast_assert(endpoint != NULL);
        return create_out_of_dialog_request(pmethod, endpoint, uri, contact, tdata);
    }
}

References ast_assert, ast_log, create_in_dialog_request(), create_out_of_dialog_request(), get_pjsip_method(), LOG_WARNING, method, NULL, and pmethod.

Referenced by aoc_send_as_xml(), msg_send(), notify_channel(), notify_contact(), notify_uri(), send_unsolicited_mwi_notify_to_contact(), sendtext(), sip_options_qualify_contact(), transmit_info_dtmf(), and transmit_info_with_vidupdate().

ast_sip_create_request_with_auth()

int ast_sip_create_request_with_auth	(	const struct ast_sip_auth_vector *	auths,
		pjsip_rx_data *	challenge,
		pjsip_tx_data *	tdata,
		pjsip_tx_data **	new_request
	)

Create a response to an authentication challenge.

This will call into an outbound authenticator's create_request_with_auth callback to create a new request with authentication credentials. See the create_request_with_auth callback in the ast_sip_outbound_authenticator structure for details about the parameters and return values.

Definition at line 214 of file res_pjsip.c.

{
    if (!registered_outbound_authenticator) {
        ast_log(LOG_WARNING, "No SIP outbound authenticator registered. Cannot respond to authentication challenge\n");
        return -1;
    }
    return registered_outbound_authenticator->create_request_with_auth(auths, challenge, old_request, new_request);
}

References ast_log, challenge(), ast_sip_outbound_authenticator::create_request_with_auth, LOG_WARNING, and registered_outbound_authenticator.

Referenced by check_request_status(), handle_registration_response(), outbound_invite_auth(), refer_client_on_evsub_state(), session_inv_on_tsx_state_changed(), and sip_outbound_publish_callback().

ast_sip_create_response()

int ast_sip_create_response	(	const pjsip_rx_data *	rdata,
		int	st_code,
		struct ast_sip_contact *	contact,
		pjsip_tx_data **	p_tdata
	)

General purpose method for creating a SIP response.

Its typical use would be to create responses for out of dialog requests.

Parameters

	rdata	The rdata from the incoming request.
	st_code	The response code to transmit.
	contact	The contact with which this request is associated.
[out]	p_tdata	The newly-created response

The provided contact is attached to tdata with its reference bumped, but will not survive for the entire lifetime of tdata since the contact is cleaned up when all supplements have completed execution.

Return values

0	Success
-1	Failure

Definition at line 2468 of file res_pjsip.c.

{
    int res = pjsip_endpt_create_response(ast_sip_get_pjsip_endpoint(), rdata, st_code, NULL, tdata);
 
    if (!res) {
        ast_sip_mod_data_set((*tdata)->pool, (*tdata)->mod_data, supplement_module.id, MOD_DATA_CONTACT, ao2_bump(contact));
    }
 
    return res;
}

References ao2_bump, ast_sip_get_pjsip_endpoint(), ast_sip_mod_data_set, MOD_DATA_CONTACT, NULL, and supplement_module.

Referenced by send_options_response(), and send_response().

ast_sip_dict_get()

void * ast_sip_dict_get	(	void *	ht,
		const char *	key
	)

Retrieves the value associated with the given key.

Parameters

ht	the hash table/dictionary to search
key	the key to find

Return values

the	value associated with the key, NULL otherwise.

Definition at line 2327 of file res_pjsip.c.

{
    unsigned int hval = 0;
 
    if (!ht) {
        return NULL;
    }
 
    return pj_hash_get(ht, key, PJ_HASH_KEY_STRING, &hval);
}

References NULL.

ast_sip_dict_set()

void * ast_sip_dict_set	(	pj_pool_t *	pool,
		void *	ht,
		const char *	key,
		void *	val
	)

Set the value for the given key.

Note - if the hash table does not exist one is created first, the key/value pair is set, and the hash table returned.

Parameters

pool	the pool to allocate memory in
ht	the hash table/dictionary in which to store the key/value pair
key	the key to associate a value with
val	the value to associate with a key

Return values

the	given, or newly created, hash table.

Definition at line 2338 of file res_pjsip.c.

{
    if (!ht) {
        ht = pj_hash_create(pool, 11);
    }
 
    pj_hash_set(pool, ht, key, PJ_HASH_KEY_STRING, 0, val);
 
    return ht;
}

ast_sip_dlg_set_transport()

int ast_sip_dlg_set_transport	(	const struct ast_sip_endpoint *	endpoint,
		pjsip_dialog *	dlg,
		pjsip_tpselector *	selector
	)

Set the transport on a dialog.

Since

13.15.0

Parameters

endpoint
dlg
selector	(optional)

Note

This API calls ast_sip_get_transport_name(endpoint, dlg->target) and if the result is non-NULL, calls pjsip_dlg_set_transport. If 'selector' is non-NULL, it is updated with the selector used.

It is the responsibility of the caller to unref the passed in selector if one is provided.

Definition at line 727 of file res_pjsip.c.

{
    pjsip_sip_uri *uri;
    pjsip_tpselector sel = { .type = PJSIP_TPSELECTOR_NONE, };
 
    uri = pjsip_uri_get_uri(dlg->target);
    if (!selector) {
        selector = &sel;
    }
 
    ast_sip_set_tpselector_from_ep_or_uri(endpoint, uri, selector);
 
    pjsip_dlg_set_transport(dlg, selector);
 
    if (selector == &sel) {
        ast_sip_tpselector_unref(&sel);
    }
 
    return 0;
}

References ast_sip_set_tpselector_from_ep_or_uri(), and ast_sip_tpselector_unref().

Referenced by ast_sip_create_dialog_uac().

ast_sip_dtmf_to_str()

int ast_sip_dtmf_to_str	(	const enum ast_sip_dtmf_mode	dtmf,
		char *	buf,
		size_t	buf_len
	)

Convert the DTMF mode enum value into a string.

Since

13.18.0

Parameters

dtmf	the dtmf mode
buf	Buffer to receive dtmf mode string
buf_len	Buffer length

Return values

0	Success
-1	Failure

Definition at line 2504 of file res_pjsip.c.

{
    switch (dtmf) {
    case AST_SIP_DTMF_NONE:
        ast_copy_string(buf, "none", buf_len);
        break;
    case AST_SIP_DTMF_RFC_4733:
        ast_copy_string(buf, "rfc4733", buf_len);
        break;
    case AST_SIP_DTMF_INBAND:
        ast_copy_string(buf, "inband", buf_len);
        break;
    case AST_SIP_DTMF_INFO:
        ast_copy_string(buf, "info", buf_len);
        break;
    case AST_SIP_DTMF_AUTO:
        ast_copy_string(buf, "auto", buf_len);
        break;
    case AST_SIP_DTMF_AUTO_INFO:
        ast_copy_string(buf, "auto_info", buf_len);
        break;
    default:
        buf[0] = '\0';
        return -1;
    }
    return 0;
}

References ast_copy_string(), AST_SIP_DTMF_AUTO, AST_SIP_DTMF_AUTO_INFO, AST_SIP_DTMF_INBAND, AST_SIP_DTMF_INFO, AST_SIP_DTMF_NONE, AST_SIP_DTMF_RFC_4733, and buf.

Referenced by dtmf_to_str(), and pjsip_acf_dtmf_mode_read().

ast_sip_failover_request()

int ast_sip_failover_request

(

pjsip_tx_data *

tdata

)

Set a request to use the next value in the list of resolved addresses.

Parameters

tdata

the tx data from the original request

Return values

0	No more addresses to try
1	The request was successfully re-intialized

Definition at line 1816 of file res_pjsip.c.

{
    pjsip_via_hdr *via;
 
    if (!tdata || !tdata->dest_info.addr.count
        || (tdata->dest_info.cur_addr == tdata->dest_info.addr.count - 1)) {
        /* No more addresses to try */
        return 0;
    }
 
    /* Try next address */
    ++tdata->dest_info.cur_addr;
 
    via = (pjsip_via_hdr*)pjsip_msg_find_hdr(tdata->msg, PJSIP_H_VIA, NULL);
    via->branch_param.slen = 0;
 
    pjsip_tx_data_invalidate_msg(tdata);
 
    return 1;
}

References NULL, and send_request_wrapper::tdata.

Referenced by check_request_status(), and handle_registration_response().

ast_sip_find_transport_state_in_use()

struct ast_sip_transport_state * ast_sip_find_transport_state_in_use

(

struct ast_sip_request_transport_details *

details

)

Returns the transport state currently in use based on request transport details.

Parameters

details

Return values

transport_state

Note

ao2_cleanup(...) or ao2_ref(..., -1) must be called on the returned object

Definition at line 595 of file res_pjsip.c.

                                                                                                                       {
    RAII_VAR(struct ao2_container *, transport_states, NULL, ao2_cleanup);
 
    if (!(transport_states = ast_sip_get_transport_states())) {
        return NULL;
    }
 
    return ao2_callback(transport_states, 0, find_transport_state_in_use, details);
}

References ao2_callback, ao2_cleanup, ast_sip_get_transport_states(), find_transport_state_in_use(), NULL, RAII_VAR, and transport_states.

Referenced by ast_sip_rewrite_uri_to_local(), and process_nat().

ast_sip_format_endpoint_ami()

int ast_sip_format_endpoint_ami	(	struct ast_sip_endpoint *	endpoint,
		struct ast_sip_ami *	ami,
		int *	count
	)

Formats the endpoint and sends over AMI.

Parameters

endpoint	the endpoint to format and send
ami	AMI variable container
count	the number of formatters operated on

Return values

0	Success, otherwise non-zero on error

Definition at line 501 of file res_pjsip.c.

{
    int res = 0;
    struct ast_sip_endpoint_formatter *i;
    SCOPED_LOCK(lock, &endpoint_formatters, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK);
    *count = 0;
    AST_RWLIST_TRAVERSE(&endpoint_formatters, i, next) {
        if (i->format_ami && ((res = i->format_ami(endpoint, ami)) < 0)) {
            return res;
        }
 
        if (!res) {
            (*count)++;
        }
    }
    return 0;
}

References AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, ast_sip_endpoint_formatter::format_ami, lock, and SCOPED_LOCK.

Referenced by ami_show_endpoint().

ast_sip_get_contact_sip_uri()

pjsip_sip_uri * ast_sip_get_contact_sip_uri

(

pjsip_tx_data *

tdata

)

Return the SIP URI of the Contact header.

Parameters

tdata

Return values

Pointer	to SIP URI of Contact
NULL	if Contact header not found or not a SIP(S) URI

Note

Do not free the returned object.

Definition at line 564 of file res_pjsip.c.

{
    pjsip_contact_hdr *contact = pjsip_msg_find_hdr(tdata->msg, PJSIP_H_CONTACT, NULL);
 
    if (!contact || (!PJSIP_URI_SCHEME_IS_SIP(contact->uri) && !PJSIP_URI_SCHEME_IS_SIPS(contact->uri))) {
        return NULL;
    }
 
    return pjsip_uri_get_uri(contact->uri);
}

References NULL.

Referenced by ast_sip_rewrite_uri_to_local(), ast_sip_set_request_transport_details(), and process_nat().

ast_sip_get_endpoint()

struct ast_sip_endpoint * ast_sip_get_endpoint	(	const char *	to,
		int	get_default_outbound,
		char **	uri
	)

Retrieves an endpoint and URI from the "to" string.

This URI is used as the Request URI.

Expects the given 'to' to be in one of the following formats: Why we allow so many is a mystery.

Basic:

 endpoint        : We'll get URI from the default aor/contact
 endpoint/aor    : We'll get the URI from the specific aor/contact
 endpoint@domain : We toss the domain part and just use the endpoint

These all use the endpoint and specified URI:

     endpoint/<sip[s]:host>
     endpoint/<sip[s]:user@host>
     endpoint/"Bob" <sip[s]:host>
     endpoint/"Bob" <sip[s]:user@host>
     endpoint/sip[s]:host
     endpoint/sip[s]:user@host
     endpoint/host
     endpoint/user@host

These all use the default endpoint and specified URI:

     <sip[s]:host>
     <sip[s]:user@host>
     "Bob" <sip[s]:host>
     "Bob" <sip[s]:user@host>
     sip[s]:host
     sip[s]:user@host

These use the default endpoint and specified host:

     host
     user@host

This form is similar to a dialstring:

     PJSIP/user@endpoint

In this case, the user will be added to the endpoint contact's URI. If the contact URI already has a user, it will be replaced.

The ones that have the sip[s] scheme are the easiest to parse. The rest all have some issue.

 endpoint vs host              : We have to test for endpoint first
 endpoint/aor vs endpoint/host : We have to test for aor first
                                 What if there's an aor with the same
                                 name as the host?
 endpoint@domain vs user@host  : We have to test for endpoint first.
                                 What if there's an endpoint with the
                                 same name as the user?

Parameters

to	'To' field with possible endpoint
get_default_outbound	If nonzero, try to retrieve the default outbound endpoint if no endpoint was found. Otherwise, return NULL if no endpoint was found.
uri	Pointer to a char* which will be set to the URI. Always must be ast_free'd by the caller - even if the return value is NULL!

Note

The logic below could probably be condensed but then it wouldn't be as clear.

Definition at line 3249 of file res_pjsip.c.

{
    char *destination;
    char *slash = NULL;
    char *atsign = NULL;
    char *scheme = NULL;
    struct ast_sip_endpoint *endpoint = NULL;
 
    destination = ast_strdupa(to);
 
    slash = strchr(destination, '/');
    atsign = strchr(destination, '@');
    scheme = S_OR(strstr(destination, "sip:"), strstr(destination, "sips:"));
 
    if (!slash && !atsign && !scheme) {
        /*
         * If there's only a single token, it can be either...
         *  endpoint
         *  host
         */
        return handle_single_token(to, destination, get_default_outbound, uri);
    }
 
    if (slash) {
        /*
         * If there's a '/', then the form must be one of the following...
         *  PJSIP/user@endpoint
         *  endpoint/aor
         *  endpoint/uri
         */
        return handle_slash(to, destination, uri, slash, atsign, scheme);
    }
 
    if (atsign && !scheme) {
        /*
         * If there's an '@' but no scheme then it's either following an endpoint name
         * and being followed by a domain name (which we discard).
         * OR is's a user@host uri without a scheme.  It's probably the latter but because
         * endpoint@domain looks just like user@host, we'll test for endpoint first.
         */
        return handle_atsign(to, destination, uri, slash, atsign, scheme, get_default_outbound);
    }
 
    /*
     * If all else fails, we assume it's a URI or just a hostname.
     */
    if (scheme) {
        *uri = ast_strdup(destination);
        if (!(*uri)) {
            goto failure;
        }
        ast_debug(3, "Dest: '%s' Didn't find an endpoint but did find a scheme so using URI '%s'%s\n",
            to, *uri, get_default_outbound ? " with default endpoint" : "");
    } else {
        *uri = ast_malloc(strlen(destination) + strlen("sip:") + 1);
        if (!(*uri)) {
            goto failure;
        }
        sprintf(*uri, "sip:%s", destination);
        ast_debug(3, "Dest: '%s' Didn't find an endpoint and didn't find scheme so adding scheme and using URI '%s'%s\n",
            to, *uri, get_default_outbound ? " with default endpoint" : "");
    }
    if (get_default_outbound) {
        endpoint = ast_sip_default_outbound_endpoint();
    }
 
    return endpoint;
 
failure:
    ao2_cleanup(endpoint);
    *uri = NULL;
    return NULL;
}

References ao2_cleanup, ast_debug, ast_malloc, ast_sip_default_outbound_endpoint(), ast_strdup, ast_strdupa, handle_atsign(), handle_single_token(), handle_slash(), NULL, and S_OR.

Referenced by msg_send(), and refer_send().

ast_sip_get_host_ip()

int ast_sip_get_host_ip	(	int	af,
		pj_sockaddr *	addr
	)

Retrieve the local host address in IP form.

Parameters

af	The address family to retrieve
addr	A place to store the local host address

Return values

0	success
-1	failure

Since

13.6.0

Definition at line 2480 of file res_pjsip.c.

{
    if (af == pj_AF_INET() && !ast_strlen_zero(host_ip_ipv4_string)) {
        pj_sockaddr_copy_addr(addr, &host_ip_ipv4);
        return 0;
    } else if (af == pj_AF_INET6() && !ast_strlen_zero(host_ip_ipv6_string)) {
        pj_sockaddr_copy_addr(addr, &host_ip_ipv6);
        return 0;
    }
 
    return -1;
}

References ast_strlen_zero(), host_ip_ipv4, host_ip_ipv4_string, host_ip_ipv6, and host_ip_ipv6_string.

ast_sip_get_host_ip_string()

const char * ast_sip_get_host_ip_string

(

int

af

)

Retrieve the local host address in string form.

Parameters

af	The address family to retrieve

Return values

non-NULL	success
NULL	failure

Since

13.6.0

Note

An empty string may be returned if the address family is valid but no local address exists

Definition at line 2493 of file res_pjsip.c.

{
    if (af == pj_AF_INET()) {
        return host_ip_ipv4_string;
    } else if (af == pj_AF_INET6()) {
        return host_ip_ipv6_string;
    }
 
    return NULL;
}

References host_ip_ipv4_string, host_ip_ipv6_string, and NULL.

Referenced by create_local_sdp(), create_outgoing_sdp_stream(), and multihomed_rewrite_sdp().

ast_sip_get_pjsip_endpoint()

pjsip_endpoint * ast_sip_get_pjsip_endpoint

(

void

)

Get a pointer to the PJSIP endpoint.

This is useful when modules have specific information they need to register with the PJSIP core.

Return values

NULL	endpoint has not been created yet.
non-NULL	PJSIP endpoint.

Definition at line 520 of file res_pjsip.c.

{
    return ast_pjsip_endpoint;
}

References ast_pjsip_endpoint.

Referenced by acl_on_rx_msg(), aoc_release_pool(), aoc_send_as_xml(), ast_res_pjsip_cleanup_options_handling(), ast_res_pjsip_init_options_handling(), ast_sip_create_response(), ast_sip_destroy_transport_events(), ast_sip_initialize_transport_events(), ast_sip_pubsub_register_body_generator(), ast_sip_send_response(), ast_sip_send_stateful_response(), ast_sip_session_defer_termination(), ast_sip_session_resume_reinvite(), authenticate(), cancel_publish_refresh(), cancel_registration(), channel_read_pjsip(), create_out_of_dialog_request(), digest_create_request_with_auth(), distribute(), distributor(), do_cli_dump_endpt(), endpoint_lookup(), endpt_send_request(), endpt_send_request_cb(), exten_state_data_alloc(), exten_state_data_destructor(), exten_state_publisher_cb(), filter_on_tx_message(), find_registrar_aor(), insert_user_in_contact_uri(), keepalive_transport_send_keepalive(), load_module(), logging_on_rx_msg(), logging_on_tx_msg(), notify_task(), on_rx_process_uris(), options_incoming_request(), parse_uri_cb(), pool_destroy_callback(), pre_session_setup(), publish_request_initial(), pubsub_on_rx_mwi_notify_request(), pubsub_on_rx_publish_request(), pubsub_on_rx_subscribe_request(), register_aor(), registrar_on_rx_request(), reschedule_reinvite(), schedule_publish_refresh(), schedule_registration(), send_options_response(), session_reinvite_on_rx_request(), sip_dialog_create_contact(), sip_dialog_create_from(), sip_outbound_publisher_init(), sip_outbound_registration_regc_alloc(), sip_publication_respond(), sip_session_defer_termination_stop_timer(), subscription_persistence_load(), system_create_resolver_and_set_nameservers(), t38_change_state(), transport_apply(), and transport_create().

ast_sip_get_transport_name()

int ast_sip_get_transport_name	(	const struct ast_sip_endpoint *	endpoint,
		pjsip_sip_uri *	sip_uri,
		char *	buf,
		size_t	buf_len
	)

Get the transport name from an endpoint or request uri.

Since

13.15.0

Parameters

endpoint
sip_uri
buf	Buffer to receive transport name
buf_len	Buffer length

Return values

0	Success
-1	Failure

Note

If endpoint->transport is not NULL, it is returned in buf. Otherwise if sip_uri has an 'x-ast-txp' parameter AND the sip_uri host is an ip4 or ip6 address, its value is returned,

Definition at line 698 of file res_pjsip.c.

{
    char *host = NULL;
    static const pj_str_t x_name = { AST_SIP_X_AST_TXP, AST_SIP_X_AST_TXP_LEN };
    pjsip_param *x_transport;
 
    if (!ast_strlen_zero(endpoint->transport)) {
        ast_copy_string(buf, endpoint->transport, buf_len);
        return 0;
    }
 
    x_transport = pjsip_param_find(&sip_uri->other_param, &x_name);
    if (!x_transport) {
        return -1;
    }
 
    /* Only use x_transport if the uri host is an ip (4 or 6) address */
    host = ast_alloca(sip_uri->host.slen + 1);
    ast_copy_pj_str(host, &sip_uri->host, sip_uri->host.slen + 1);
    if (!ast_sockaddr_parse(NULL, host, PARSE_PORT_FORBID)) {
        return -1;
    }
 
    ast_copy_pj_str(buf, &x_transport->value, buf_len);
 
    return 0;
}

References ast_alloca, ast_copy_pj_str(), ast_copy_string(), AST_SIP_X_AST_TXP, AST_SIP_X_AST_TXP_LEN, ast_sockaddr_parse(), ast_strlen_zero(), buf, NULL, PARSE_PORT_FORBID, and ast_sip_endpoint::transport.

Referenced by ast_sip_set_tpselector_from_ep_or_uri().

ast_sip_hangup_sip2cause()

const int ast_sip_hangup_sip2cause

(

int

cause

)

Convert SIP hangup causes to Asterisk hangup causes.

Parameters

cause

SIP cause

Return values

matched

cause code from causes.h

Definition at line 3531 of file res_pjsip.c.

{
    /* Possible values taken from causes.h */
 
    switch(cause) {
    case 401:       /* Unauthorized */
        return AST_CAUSE_CALL_REJECTED;
    case 403:       /* Not found */
        return AST_CAUSE_CALL_REJECTED;
    case 404:       /* Not found */
        return AST_CAUSE_UNALLOCATED;
    case 405:       /* Method not allowed */
        return AST_CAUSE_INTERWORKING;
    case 407:       /* Proxy authentication required */
        return AST_CAUSE_CALL_REJECTED;
    case 408:       /* No reaction */
        return AST_CAUSE_NO_USER_RESPONSE;
    case 409:       /* Conflict */
        return AST_CAUSE_NORMAL_TEMPORARY_FAILURE;
    case 410:       /* Gone */
        return AST_CAUSE_NUMBER_CHANGED;
    case 411:       /* Length required */
        return AST_CAUSE_INTERWORKING;
    case 413:       /* Request entity too large */
        return AST_CAUSE_INTERWORKING;
    case 414:       /* Request URI too large */
        return AST_CAUSE_INTERWORKING;
    case 415:       /* Unsupported media type */
        return AST_CAUSE_INTERWORKING;
    case 420:       /* Bad extension */
        return AST_CAUSE_NO_ROUTE_DESTINATION;
    case 480:       /* No answer */
        return AST_CAUSE_NO_ANSWER;
    case 481:       /* No answer */
        return AST_CAUSE_INTERWORKING;
    case 482:       /* Loop detected */
        return AST_CAUSE_INTERWORKING;
    case 483:       /* Too many hops */
        return AST_CAUSE_NO_ANSWER;
    case 484:       /* Address incomplete */
        return AST_CAUSE_INVALID_NUMBER_FORMAT;
    case 485:       /* Ambiguous */
        return AST_CAUSE_UNALLOCATED;
    case 486:       /* Busy everywhere */
        return AST_CAUSE_BUSY;
    case 487:       /* Request terminated */
        return AST_CAUSE_INTERWORKING;
    case 488:       /* No codecs approved */
        return AST_CAUSE_BEARERCAPABILITY_NOTAVAIL;
    case 491:       /* Request pending */
        return AST_CAUSE_INTERWORKING;
    case 493:       /* Undecipherable */
        return AST_CAUSE_INTERWORKING;
    case 500:       /* Server internal failure */
        return AST_CAUSE_FAILURE;
    case 501:       /* Call rejected */
        return AST_CAUSE_FACILITY_REJECTED;
    case 502:
        return AST_CAUSE_DESTINATION_OUT_OF_ORDER;
    case 503:       /* Service unavailable */
        return AST_CAUSE_CONGESTION;
    case 504:       /* Gateway timeout */
        return AST_CAUSE_RECOVERY_ON_TIMER_EXPIRE;
    case 505:       /* SIP version not supported */
        return AST_CAUSE_INTERWORKING;
    case 600:       /* Busy everywhere */
        return AST_CAUSE_USER_BUSY;
    case 603:       /* Decline */
        return AST_CAUSE_CALL_REJECTED;
    case 604:       /* Does not exist anywhere */
        return AST_CAUSE_UNALLOCATED;
    case 606:       /* Not acceptable */
        return AST_CAUSE_BEARERCAPABILITY_NOTAVAIL;
    default:
        if (cause < 500 && cause >= 400) {
            /* 4xx class error that is unknown - someting wrong with our request */
            return AST_CAUSE_INTERWORKING;
        } else if (cause < 600 && cause >= 500) {
            /* 5xx class error - problem in the remote end */
            return AST_CAUSE_CONGESTION;
        } else if (cause < 700 && cause >= 600) {
            /* 6xx - global errors in the 4xx class */
            return AST_CAUSE_INTERWORKING;
        }
        return AST_CAUSE_NORMAL;
    }
    /* Never reached */
    return 0;
}

References AST_CAUSE_BEARERCAPABILITY_NOTAVAIL, AST_CAUSE_BUSY, AST_CAUSE_CALL_REJECTED, AST_CAUSE_CONGESTION, AST_CAUSE_DESTINATION_OUT_OF_ORDER, AST_CAUSE_FACILITY_REJECTED, AST_CAUSE_FAILURE, AST_CAUSE_INTERWORKING, AST_CAUSE_INVALID_NUMBER_FORMAT, AST_CAUSE_NO_ANSWER, AST_CAUSE_NO_ROUTE_DESTINATION, AST_CAUSE_NO_USER_RESPONSE, AST_CAUSE_NORMAL, AST_CAUSE_NORMAL_TEMPORARY_FAILURE, AST_CAUSE_NUMBER_CHANGED, AST_CAUSE_RECOVERY_ON_TIMER_EXPIRE, AST_CAUSE_UNALLOCATED, and AST_CAUSE_USER_BUSY.

Referenced by chan_pjsip_incoming_response_update_cause(), chan_pjsip_session_end(), and rfc3326_use_reason_header().

ast_sip_identify_endpoint()

struct ast_sip_endpoint * ast_sip_identify_endpoint

(

pjsip_rx_data *

rdata

)

Determine the endpoint that has sent a SIP message.

This will call into each of the registered endpoint identifiers' identify_endpoint() callbacks until one returns a non-NULL endpoint. This will return an ao2 object. Its reference count will need to be decremented when completed using the endpoint.

Parameters

rdata

The inbound SIP message to use when identifying the endpoint.

Return values

NULL	No matching endpoint
non-NULL	The matching endpoint

Definition at line 330 of file res_pjsip.c.

{
    struct endpoint_identifier_list *iter;
    struct ast_sip_endpoint *endpoint = NULL;
    SCOPED_LOCK(lock, &endpoint_identifiers, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK);
    AST_RWLIST_TRAVERSE(&endpoint_identifiers, iter, list) {
        ast_assert(iter->identifier->identify_endpoint != NULL);
        endpoint = iter->identifier->identify_endpoint(rdata);
        if (endpoint) {
            break;
        }
    }
    return endpoint;
}

References ast_assert, AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, endpoint_identifier_list::identifier, ast_sip_endpoint_identifier::identify_endpoint, lock, NULL, and SCOPED_LOCK.

Referenced by endpoint_lookup().

ast_sip_is_allowed_uri()

int ast_sip_is_allowed_uri

(

pjsip_uri *

uri

)

Check whether a pjsip_uri is allowed or not.

Since

16.28.0

Parameters

uri	The pjsip_uri to check

Return values

1	if allowed
0	if not allowed

Definition at line 3472 of file res_pjsip.c.

{
    return (ast_sip_is_uri_sip_sips(uri) || PJSIP_URI_SCHEME_IS_TEL(uri));
}

References ast_sip_is_uri_sip_sips().

Referenced by endpoint_lookup(), get_destination(), on_rx_process_uris(), options_on_rx_request(), rx_data_to_ast_msg(), and set_redirecting_reason_by_cause().

ast_sip_is_content_type()

int ast_sip_is_content_type	(	pjsip_media_type *	content_type,
		char *	type,
		char *	subtype
	)

Checks if the given content type matches type/subtype.

Compares the pjsip_media_type with the passed type and subtype and returns the result of that comparison. The media type parameters are ignored.

Parameters

content_type	The pjsip_media_type structure to compare
type	The media type to compare
subtype	The media subtype to compare

Return values

0	No match
-1	Match

Definition at line 2248 of file res_pjsip.c.

{
    pjsip_media_type compare;
 
    if (!content_type) {
        return 0;
    }
 
    pjsip_media_type_init2(&compare, type, subtype);
 
    return pjsip_media_type_cmp(content_type, &compare, 0) ? 0 : -1;
}

References compare(), and type.

Referenced by asterisk_publication_devicestate_state_change(), asterisk_publication_mwi_state_change(), check_content_type(), and pubsub_on_rx_notify_request().

ast_sip_is_media_type_in()

int ast_sip_is_media_type_in	(	pjsip_media_type *	a,
			...
	)

Check if a media type is in a list of others.

Parameters

a	pjsip_media_type to search for
...	one or more pointers to pjsip_media_types the last of which must be "SENTINEL"

Return values

1	Media types are equal
0	Media types are not equal

Definition at line 2228 of file res_pjsip.c.

{
    int rc = 0;
    pjsip_media_type *b = NULL;
    va_list ap;
 
    ast_assert(a != NULL);
    va_start(ap, a);
 
    while ((b = va_arg(ap, pjsip_media_type *)) != (pjsip_media_type *)SENTINEL) {
        if (pjsip_media_type_cmp(a, b, 0) == 0) {
            rc = 1;
            break;
        }
    }
    va_end(ap);
 
    return rc;
}

References a, ast_assert, b, NULL, and SENTINEL.

Referenced by check_content_disposition().

ast_sip_is_uri_sip_sips()

int ast_sip_is_uri_sip_sips

(

pjsip_uri *

uri

)

Check whether a pjsip_uri is SIP/SIPS or not.

Since

16.28.0

Parameters

uri	The pjsip_uri to check

Return values

1	if true
0	if false

Definition at line 3467 of file res_pjsip.c.

{
    return (PJSIP_URI_SCHEME_IS_SIP(uri) || PJSIP_URI_SCHEME_IS_SIPS(uri));
}

Referenced by ast_sip_is_allowed_uri(), ast_sip_pjsip_uri_get_hostname(), ast_sip_pjsip_uri_get_other_param(), ast_sip_pjsip_uri_get_username(), filter_on_tx_message(), get_endpoint_details(), get_from_header(), publish_request_initial(), pubsub_on_rx_subscribe_request(), sanitize_tdata(), and set_id_from_oli().

ast_sip_modify_id_header()

void ast_sip_modify_id_header	(	pj_pool_t *	pool,
		pjsip_fromto_hdr *	id_hdr,
		const struct ast_party_id *	id
	)

Set name and number information on an identity header.

Parameters

pool	Memory pool to use for string duplication
id_hdr	A From, P-Asserted-Identity, or Remote-Party-ID header to modify
id	The identity information to apply to the header

Definition at line 2850 of file res_pjsip.c.

{
    pjsip_name_addr *id_name_addr;
    pjsip_sip_uri *id_uri;
 
    id_name_addr = (pjsip_name_addr *) id_hdr->uri;
    id_uri = pjsip_uri_get_uri(id_name_addr->uri);
 
    if (id->name.valid) {
        if (!ast_strlen_zero(id->name.str)) {
            int name_buf_len = strlen(id->name.str) * 2 + 1;
            char *name_buf = ast_alloca(name_buf_len);
 
            ast_escape_quoted(id->name.str, name_buf, name_buf_len);
            pj_strdup2(pool, &id_name_addr->display, name_buf);
        } else {
            pj_strdup2(pool, &id_name_addr->display, NULL);
        }
    }
 
    if (id->number.valid) {
        pj_strdup2(pool, &id_uri->user, id->number.str);
    }
}

References ast_alloca, ast_escape_quoted(), ast_strlen_zero(), id, and NULL.

Referenced by add_pai_header(), add_rpid_header(), and set_from_header().

ast_sip_pjsip_uri_get_hostname()

const pj_str_t * ast_sip_pjsip_uri_get_hostname

(

pjsip_uri *

uri

)

Get the host portion of the pjsip_uri.

Since

16.28.0

Parameters

uri	The pjsip_uri to get the host from

Note

This function will check what kind of URI it receives and return the host based off of that

Returns

Host string or empty string if not present

Definition at line 3496 of file res_pjsip.c.

{
    if (ast_sip_is_uri_sip_sips(uri)) {
        pjsip_sip_uri *sip_uri = pjsip_uri_get_uri(uri);
        if (!sip_uri) {
            return &AST_PJ_STR_EMPTY;
        }
        return &sip_uri->host;
    } else if (PJSIP_URI_SCHEME_IS_TEL(uri)) {
        return &AST_PJ_STR_EMPTY;
    }
 
    return &AST_PJ_STR_EMPTY;
}

References AST_PJ_STR_EMPTY, and ast_sip_is_uri_sip_sips().

Referenced by dialog_info_generate_body_content(), find_aor2(), get_endpoint_details(), get_from_header(), and set_sipdomain_variable().

ast_sip_pjsip_uri_get_other_param()

struct pjsip_param * ast_sip_pjsip_uri_get_other_param	(	pjsip_uri *	uri,
		const pj_str_t *	param_str
	)

Find an 'other' SIP/SIPS URI parameter by name.

Since

16.28.0

A convenience function to find a named parameter from a SIP/SIPS URI. This function will not find the following standard SIP/SIPS URI parameters which are stored separately by PJSIP:

• user
• method
• transport
• ttl
• lr
• maddr

Parameters

uri	The pjsip_uri to get the parameter from
param_str	The name of the parameter to find

Note

This function will check what kind of URI it receives and return the parameter based off of that

Returns

Find parameter or NULL if not present

Definition at line 3511 of file res_pjsip.c.

{
    if (ast_sip_is_uri_sip_sips(uri)) {
        pjsip_sip_uri *sip_uri = pjsip_uri_get_uri(uri);
        if (!sip_uri) {
            return NULL;
        }
        return pjsip_param_find(&sip_uri->other_param, param_str);
    } else if (PJSIP_URI_SCHEME_IS_TEL(uri)) {
        pjsip_tel_uri *tel_uri = pjsip_uri_get_uri(uri);
        if (!tel_uri) {
            return NULL;
        }
        return pjsip_param_find(&tel_uri->other_param, param_str);
    }
 
    return NULL;
}

References ast_sip_is_uri_sip_sips(), and NULL.

Referenced by get_uri_option_line(), and set_redirecting_reason_by_cause().

ast_sip_pjsip_uri_get_username()

const pj_str_t * ast_sip_pjsip_uri_get_username

(

pjsip_uri *

uri

)

Get the user portion of the pjsip_uri.

Since

16.28.0

Parameters

uri	The pjsip_uri to get the user from

Note

This function will check what kind of URI it receives and return the user based off of that

Returns

User string or empty string if not present

Definition at line 3477 of file res_pjsip.c.

{
    if (ast_sip_is_uri_sip_sips(uri)) {
        pjsip_sip_uri *sip_uri = pjsip_uri_get_uri(uri);
        if (!sip_uri) {
            return &AST_PJ_STR_EMPTY;
        }
        return &sip_uri->user;
    } else if (PJSIP_URI_SCHEME_IS_TEL(uri)) {
        pjsip_tel_uri *tel_uri = pjsip_uri_get_uri(uri);
        if (!tel_uri) {
            return &AST_PJ_STR_EMPTY;
        }
        return &tel_uri->number;
    }
 
    return &AST_PJ_STR_EMPTY;
}

References AST_PJ_STR_EMPTY, and ast_sip_is_uri_sip_sips().

Referenced by add_diversion_header(), endpoint_lookup(), find_aor2(), get_destination(), get_from_header(), options_on_rx_request(), publish_request_initial(), pubsub_on_rx_subscribe_request(), rx_data_to_ast_msg(), set_id_from_hdr(), and sub_persistence_recreate().

ast_sip_push_task_wait()

static int ast_sip_push_task_wait ( struct ast_taskprocessor *  serializer, int(*)(void *)  sip_task, void *  task_data  )

static

Definition at line 2137 of file res_pjsip.c.

{
    /* This method is an onion */
    struct sync_task_data std;
 
    memset(&std, 0, sizeof(std));
    ast_mutex_init(&std.lock);
    ast_cond_init(&std.cond, NULL);
    std.task = sip_task;
    std.task_data = task_data;
 
    if (ast_sip_push_task(serializer, sync_task, &std)) {
        ast_mutex_destroy(&std.lock);
        ast_cond_destroy(&std.cond);
        return -1;
    }
 
    ast_mutex_lock(&std.lock);
    while (!std.complete) {
        ast_cond_wait(&std.cond, &std.lock);
    }
    ast_mutex_unlock(&std.lock);
 
    ast_mutex_destroy(&std.lock);
    ast_cond_destroy(&std.cond);
    return std.fail;
}

References ast_cond_destroy, ast_cond_init, ast_cond_wait, ast_mutex_destroy, ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, ast_sip_push_task(), sync_task_data::complete, sync_task_data::cond, sync_task_data::fail, sync_task_data::lock, NULL, sync_task(), sync_task_data::task, and sync_task_data::task_data.

Referenced by ast_sip_push_task_wait_serializer(), and ast_sip_push_task_wait_servant().

ast_sip_rdata_get_header_value()

char * ast_sip_rdata_get_header_value	(	pjsip_rx_data *	rdata,
		const pj_str_t	str
	)

Get a specific header value from rdata.

Note

The returned value does not need to be freed since it's from the rdata pool

Parameters

rdata	The rdata
str	The header to find

Return values

NULL	on failure
The	header value on success

Definition at line 345 of file res_pjsip.c.

{
    pjsip_generic_string_hdr *hdr;
    pj_str_t hdr_val;
 
    hdr = pjsip_msg_find_hdr_by_name(rdata->msg_info.msg, &str, NULL);
    if (!hdr) {
        return NULL;
    }
 
    pj_strdup_with_null(rdata->tp_info.pool, &hdr_val, &hdr->hvalue);
 
    return hdr_val.ptr;
}

References NULL, and str.

Referenced by stir_shaken_incoming_request().

ast_sip_register_authenticator()

int ast_sip_register_authenticator

(

struct ast_sip_authenticator *

auth

)

Register a SIP authenticator.

An authenticator has three main purposes: 1) Determining if authentication should be performed on an incoming request 2) Gathering credentials necessary for issuing an authentication challenge 3) Authenticating a request that has credentials

Asterisk provides a default authenticator, but it may be replaced by a custom one if desired.

Parameters

auth	The authenticator to register

Return values

0	Success
-1	Failure

Definition at line 140 of file res_pjsip.c.

{
    if (registered_authenticator) {
        ast_log(LOG_WARNING, "Authenticator %p is already registered. Cannot register a new one\n", registered_authenticator);
        return -1;
    }
    registered_authenticator = auth;
    ast_debug(1, "Registered SIP authenticator module %p\n", auth);
 
    return 0;
}

References ast_debug, ast_log, LOG_WARNING, and registered_authenticator.

Referenced by load_module().

ast_sip_register_endpoint_formatter()

void ast_sip_register_endpoint_formatter

(

struct ast_sip_endpoint_formatter *

obj

)

Register an endpoint formatter.

Parameters

obj	the formatter to register

Definition at line 481 of file res_pjsip.c.

{
    SCOPED_LOCK(lock, &endpoint_formatters, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
    AST_RWLIST_INSERT_TAIL(&endpoint_formatters, obj, next);
}

References AST_RWLIST_INSERT_TAIL, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, lock, ast_cli_entry::next, and SCOPED_LOCK.

Referenced by ast_res_pjsip_init_options_handling(), ast_sip_initialize_sorcery_auth(), ast_sip_initialize_sorcery_location(), ast_sip_initialize_sorcery_transport(), and load_module().

ast_sip_register_endpoint_identifier()

int ast_sip_register_endpoint_identifier

(

struct ast_sip_endpoint_identifier *

identifier

)

Register a SIP endpoint identifier.

An endpoint identifier's purpose is to determine which endpoint a given SIP message has come from.

Multiple endpoint identifiers may be registered so that if an endpoint cannot be identified by one identifier, it may be identified by another.

Asterisk provides two endpoint identifiers. One identifies endpoints based on the user part of the From header URI. The other identifies endpoints based on the source IP address.

If the order in which endpoint identifiers is run is important to you, then be sure to load individual endpoint identifier modules in the order you wish for them to be run in modules.conf

Note

endpoint identifiers registered using this method (no name specified) are placed at the front of the endpoint identifiers list ahead of any named identifiers.

Parameters

identifier

The SIP endpoint identifier to register

Return values

0	Success
-1	Failure

Definition at line 310 of file res_pjsip.c.

{
    return ast_sip_register_endpoint_identifier_with_name(identifier, NULL);
}

References ast_sip_register_endpoint_identifier_with_name(), endpoint_identifier_list::identifier, and NULL.

Referenced by load_module().

ast_sip_register_endpoint_identifier_with_name()

int ast_sip_register_endpoint_identifier_with_name	(	struct ast_sip_endpoint_identifier *	identifier,
		const char *	name
	)

Register a SIP endpoint identifier with a name.

An endpoint identifier's purpose is to determine which endpoint a given SIP message has come from.

Multiple endpoint identifiers may be registered so that if an endpoint cannot be identified by one identifier, it may be identified by another.

Parameters

identifier	The SIP endpoint identifier to register
name	The name of the endpoint identifier

Return values

0	Success
-1	Failure

Definition at line 233 of file res_pjsip.c.

{
    char *prev, *current, *identifier_order;
    struct endpoint_identifier_list *iter, *id_list_item;
    SCOPED_LOCK(lock, &endpoint_identifiers, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
 
    id_list_item = ast_calloc(1, sizeof(*id_list_item));
    if (!id_list_item) {
        ast_log(LOG_ERROR, "Unable to add endpoint identifier. Out of memory.\n");
        return -1;
    }
    id_list_item->identifier = identifier;
    id_list_item->name = name;
 
    ast_debug(1, "Register endpoint identifier %s(%p)\n", name ?: "", identifier);
 
    if (ast_strlen_zero(name)) {
        /* if an identifier has no name then place in front */
        AST_RWLIST_INSERT_HEAD(&endpoint_identifiers, id_list_item, list);
        return 0;
    }
 
    /* see if the name of the identifier is in the global endpoint_identifier_order list */
    identifier_order = prev = current = ast_sip_get_endpoint_identifier_order();
 
    if (ast_strlen_zero(identifier_order)) {
        id_list_item->priority = UINT_MAX;
        AST_RWLIST_INSERT_TAIL(&endpoint_identifiers, id_list_item, list);
        ast_free(identifier_order);
        return 0;
    }
 
    id_list_item->priority = 0;
    while ((current = strchr(current, ','))) {
        ++id_list_item->priority;
        if (!strncmp(prev, name, current - prev)
            && strlen(name) == current - prev) {
            break;
        }
        prev = ++current;
    }
 
    if (!current) {
        /* check to see if it is the only or last item */
        if (!strcmp(prev, name)) {
            ++id_list_item->priority;
        } else {
            id_list_item->priority = UINT_MAX;
        }
    }
 
    if (id_list_item->priority == UINT_MAX || AST_RWLIST_EMPTY(&endpoint_identifiers)) {
        /* if not in the endpoint_identifier_order list then consider it less in
           priority and add it to the end */
        AST_RWLIST_INSERT_TAIL(&endpoint_identifiers, id_list_item, list);
        ast_free(identifier_order);
        return 0;
    }
 
    AST_RWLIST_TRAVERSE_SAFE_BEGIN(&endpoint_identifiers, iter, list) {
        if (id_list_item->priority < iter->priority) {
            AST_RWLIST_INSERT_BEFORE_CURRENT(id_list_item, list);
            break;
        }
 
        if (!AST_RWLIST_NEXT(iter, list)) {
            AST_RWLIST_INSERT_AFTER(&endpoint_identifiers, iter, id_list_item, list);
            break;
        }
    }
    AST_RWLIST_TRAVERSE_SAFE_END;
 
    ast_free(identifier_order);
    return 0;
}

References ast_calloc, ast_debug, ast_free, ast_log, AST_RWLIST_EMPTY, AST_RWLIST_INSERT_AFTER, AST_RWLIST_INSERT_BEFORE_CURRENT, AST_RWLIST_INSERT_HEAD, AST_RWLIST_INSERT_TAIL, AST_RWLIST_NEXT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_sip_get_endpoint_identifier_order(), ast_strlen_zero(), current, endpoint_identifier_list::identifier, lock, LOG_ERROR, name, endpoint_identifier_list::name, endpoint_identifier_list::priority, and SCOPED_LOCK.

Referenced by ast_sip_register_endpoint_identifier(), and load_module().

ast_sip_register_outbound_authenticator()

int ast_sip_register_outbound_authenticator

(

struct ast_sip_outbound_authenticator *

outbound_auth

)

Register an outbound SIP authenticator.

An outbound authenticator is responsible for creating responses to authentication challenges by remote endpoints.

Parameters

outbound_auth

The authenticator to register

Return values

0	Success
-1	Failure

Definition at line 191 of file res_pjsip.c.

{
    if (registered_outbound_authenticator) {
        ast_log(LOG_WARNING, "Outbound authenticator %p is already registered. Cannot register a new one\n", registered_outbound_authenticator);
        return -1;
    }
    registered_outbound_authenticator = auth;
    ast_debug(1, "Registered SIP outbound authenticator module %p\n", auth);
 
    return 0;
}

References ast_debug, ast_log, LOG_WARNING, and registered_outbound_authenticator.

Referenced by load_module().

ast_sip_register_service()

int ast_sip_register_service

(

pjsip_module *

module

)

Register a SIP service in Asterisk.

This is more-or-less a wrapper around pjsip_endpt_register_module(). Registering a service makes it so that PJSIP will call into the service at appropriate times. For more information about PJSIP module callbacks, see the PJSIP documentation. Asterisk modules that call this function will likely do so at module load time.

Parameters

module

The module that is to be registered with PJSIP

Return values

0	Success
-1	Failure

Definition at line 117 of file res_pjsip.c.

{
    return ast_sip_push_task_wait_servant(NULL, register_service, &module);
}

References ast_sip_push_task_wait_servant(), NULL, and register_service().

Referenced by ast_res_pjsip_init_message_filter(), ast_sip_initialize_distributor(), ast_sip_initialize_global_headers(), ast_sip_initialize_transport_management(), and load_module().

ast_sip_register_supplement()

void ast_sip_register_supplement

(

struct ast_sip_supplement *

supplement

)

Register a supplement to SIP out of dialog processing.

This allows for someone to insert themselves in the processing of out of dialog SIP requests and responses. This, for example could allow for a module to set channel data based on headers in an incoming message. Similarly, a module could reject an incoming request if desired.

Parameters

supplement

The supplement to register

Definition at line 1456 of file res_pjsip.c.

{
    struct ast_sip_supplement *iter;
    int inserted = 0;
    SCOPED_LOCK(lock, &supplements, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
 
    AST_RWLIST_TRAVERSE_SAFE_BEGIN(&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(&supplements, supplement, next);
    }
}

References AST_RWLIST_INSERT_BEFORE_CURRENT, AST_RWLIST_INSERT_TAIL, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, lock, ast_sip_supplement::next, ast_sip_supplement::priority, and SCOPED_LOCK.

Referenced by ast_res_pjsip_init_message_filter(), and load_module().

ast_sip_requires_authentication()

int ast_sip_requires_authentication	(	struct ast_sip_endpoint *	endpoint,
		pjsip_rx_data *	rdata
	)

Determine if an incoming request requires authentication.

This calls into the registered authenticator's requires_authentication callback in order to determine if the request requires authentication.

If there is no registered authenticator, then authentication will be assumed not to be required.

Parameters

endpoint	The endpoint from which the request originates
rdata	The incoming SIP request

Return values

non-zero	The request requires authentication
0	The request does not require authentication

Definition at line 163 of file res_pjsip.c.

{
    if (endpoint->allow_unauthenticated_options
        && !pjsip_method_cmp(&rdata->msg_info.msg->line.req.method, &pjsip_options_method)) {
        ast_debug(3, "Skipping OPTIONS authentication due to endpoint configuration\n");
        return 0;
    }
 
    if (!registered_authenticator) {
        ast_log(LOG_WARNING, "No SIP authenticator registered. Assuming authentication is not required\n");
        return 0;
    }
 
    return registered_authenticator->requires_authentication(endpoint, rdata);
}

References ast_sip_endpoint::allow_unauthenticated_options, ast_debug, ast_log, LOG_WARNING, registered_authenticator, and ast_sip_authenticator::requires_authentication.

Referenced by authenticate().

ast_sip_rewrite_uri_to_local()

int ast_sip_rewrite_uri_to_local	(	pjsip_sip_uri *	uri,
		pjsip_tx_data *	tdata
	)

Replace domain and port of SIP URI to point to (external) signaling address of this Asterisk instance.

Parameters

uri
tdata

Return values

0	success
-1	failure

Note

Uses domain and port in Contact header if it exists, otherwise the local URI of the dialog is used if the message is sent within the context of a dialog. Further, NAT settings are considered - i.e. if the target is not in the localnet, the external_signaling_address and port are used.

Definition at line 605 of file res_pjsip.c.

                                                                           {
    RAII_VAR(struct ast_sip_transport *, transport, NULL, ao2_cleanup);
    RAII_VAR(struct ast_sip_transport_state *, transport_state, NULL, ao2_cleanup);
    struct ast_sip_request_transport_details details = { 0, };
    pjsip_sip_uri *tmp_uri;
    pjsip_dialog *dlg;
    struct ast_sockaddr addr = { { 0, } };
 
    if ((tmp_uri = ast_sip_get_contact_sip_uri(tdata))) {
        pj_strdup(tdata->pool, &uri->host, &tmp_uri->host);
        uri->port = tmp_uri->port;
    } else if ((dlg = pjsip_tdata_get_dlg(tdata))
        && (tmp_uri = pjsip_uri_get_uri(dlg->local.info->uri))
        && (PJSIP_URI_SCHEME_IS_SIP(tmp_uri) || PJSIP_URI_SCHEME_IS_SIPS(tmp_uri))) {
        pj_strdup(tdata->pool, &uri->host, &tmp_uri->host);
        uri->port = tmp_uri->port;
    }
 
    if (ast_sip_set_request_transport_details(&details, tdata, 1)
        || !(transport_state = ast_sip_find_transport_state_in_use(&details))
        || !(transport = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "transport", transport_state->id))) {
        return 0;
    }
 
    if (transport_state->localnet) {
        ast_sockaddr_parse(&addr, tdata->tp_info.dst_name, PARSE_PORT_FORBID);
        ast_sockaddr_set_port(&addr, tdata->tp_info.dst_port);
        if (ast_sip_transport_is_local(transport_state, &addr)) {
            return 0;
        }
    }
 
    if (!ast_sockaddr_isnull(&transport_state->external_signaling_address)) {
        pj_strdup2(tdata->pool, &uri->host, ast_sockaddr_stringify_host(&transport_state->external_signaling_address));
    }
 
    if (transport->external_signaling_port) {
        uri->port = transport->external_signaling_port;
    }
 
    return 0;
}

References ao2_cleanup, ast_sip_find_transport_state_in_use(), ast_sip_get_contact_sip_uri(), ast_sip_get_sorcery(), ast_sip_set_request_transport_details(), ast_sip_transport_is_local, ast_sockaddr_isnull(), ast_sockaddr_parse(), ast_sockaddr_set_port, ast_sockaddr_stringify_host(), ast_sorcery_retrieve_by_id(), NULL, PARSE_PORT_FORBID, RAII_VAR, and ast_sip_transport_state::transport.

Referenced by refer_on_tx_request().

ast_sip_send_out_of_dialog_request()

int ast_sip_send_out_of_dialog_request	(	pjsip_tx_data *	tdata,
		struct ast_sip_endpoint *	endpoint,
		int	timeout,
		void *	token,
		void(*)(void *token, pjsip_event *e)	callback
	)

General purpose method for sending an Out-Of-Dialog SIP request.

This is a companion function for ast_sip_create_request. The request created there can be passed to this function, though any request may be passed in.

This will automatically set up handling outbound authentication challenges if they arrive.

Parameters

tdata	The request to send
endpoint	Optional. If specified, the out-of-dialog request is sent to the endpoint.
timeout	If non-zero, after the timeout the transaction will be terminated and the callback will be called with the PJSIP_EVENT_TIMER type.
token	Data to be passed to the callback upon receipt of out-of-dialog response.
callback	Callback to be called upon receipt of out-of-dialog response.

Return values

0	Success
-1	Failure (out-of-dialog callback will not be called.)

Note

Timeout processing: There are 2 timers associated with this request, PJSIP timer_b which is set globally in the "system" section of pjsip.conf, and the timeout specified on this call. The timer that expires first (before normal completion) will cause the callback to be run with e->body.tsx_state.type = PJSIP_EVENT_TIMER. The timer that expires second is simply ignored and the callback is not run again.

Definition at line 1938 of file res_pjsip.c.

{
    struct ast_sip_supplement *supplement;
    struct send_request_data *req_data;
    struct ast_sip_contact *contact;
 
    req_data = send_request_data_alloc(endpoint, token, callback);
    if (!req_data) {
        pjsip_tx_data_dec_ref(tdata);
        return -1;
    }
 
    if (endpoint) {
        ast_sip_message_apply_transport(endpoint->transport, tdata);
    }
 
    contact = ast_sip_mod_data_get(tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT);
 
    AST_RWLIST_RDLOCK(&supplements);
    AST_LIST_TRAVERSE(&supplements, supplement, next) {
        if (supplement->outgoing_request
            && does_method_match(&tdata->msg->line.req.method.name, supplement->method)) {
            supplement->outgoing_request(endpoint, contact, tdata);
        }
    }
    AST_RWLIST_UNLOCK(&supplements);
 
    ast_sip_mod_data_set(tdata->pool, tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT, NULL);
    ao2_cleanup(contact);
 
    if (endpt_send_request(endpoint, tdata, timeout, req_data, send_request_cb)
        != PJ_SUCCESS) {
        ao2_cleanup(req_data);
        return -1;
    }
 
    return 0;
}

References ao2_cleanup, AST_LIST_TRAVERSE, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, ast_sip_message_apply_transport(), ast_sip_mod_data_get, ast_sip_mod_data_set, callback(), does_method_match(), ast_sip_contact::endpoint, endpt_send_request(), ast_sip_supplement::method, MOD_DATA_CONTACT, NULL, ast_sip_supplement::outgoing_request, send_request_cb(), send_request_data_alloc(), supplement_module, and ast_sip_endpoint::transport.

Referenced by ast_sip_send_request(), and sip_options_qualify_contact().

ast_sip_send_request()

int ast_sip_send_request	(	pjsip_tx_data *	tdata,
		struct pjsip_dialog *	dlg,
		struct ast_sip_endpoint *	endpoint,
		void *	token,
		void(*)(void *token, pjsip_event *e)	callback
	)

General purpose method for sending a SIP request.

This is a companion function for ast_sip_create_request. The request created there can be passed to this function, though any request may be passed in.

This will automatically set up handling outbound authentication challenges if they arrive.

Parameters

tdata	The request to send
dlg	Optional. The dialog in which the request is sent. Otherwise it is out-of-dialog.
endpoint	Optional. If specified, the out-of-dialog request is sent to the endpoint.
token	Data to be passed to the callback upon receipt of out-of-dialog response.
callback	Callback to be called upon receipt of out-of-dialog response.

Return values

0	Success
-1	Failure (out-of-dialog callback will not be called.)

Definition at line 1979 of file res_pjsip.c.

{
    ast_assert(tdata->msg->type == PJSIP_REQUEST_MSG);
 
    if (dlg) {
        return send_in_dialog_request(tdata, dlg);
    } else {
        return ast_sip_send_out_of_dialog_request(tdata, endpoint, -1, token, callback);
    }
}

References ast_assert, ast_sip_send_out_of_dialog_request(), callback(), ast_sip_contact::endpoint, and send_in_dialog_request().

Referenced by msg_send(), notify_channel(), notify_contact(), notify_uri(), refer_client_on_evsub_state(), send_unsolicited_mwi_notify_to_contact(), and sendtext().

ast_sip_send_response()

int ast_sip_send_response	(	pjsip_response_addr *	res_addr,
		pjsip_tx_data *	tdata,
		struct ast_sip_endpoint *	sip_endpoint
	)

Send a response to an out of dialog request.

Use this function sparingly, since this does not create a transaction within PJSIP. This means that if the request is retransmitted, it is your responsibility to detect this and not process the same request twice, and to send the same response for each retransmission.

Parameters

res_addr	The response address for this response
tdata	The response to send
sip_endpoint	The ast_sip_endpoint associated with this response

Return values

0	Success
-1	Failure

Definition at line 2396 of file res_pjsip.c.

{
    pj_status_t status;
 
    supplement_outgoing_response(tdata, sip_endpoint);
    status = pjsip_endpt_send_response(ast_sip_get_pjsip_endpoint(), res_addr, tdata, NULL, NULL);
    if (status != PJ_SUCCESS) {
        pjsip_tx_data_dec_ref(tdata);
    }
 
    return status == PJ_SUCCESS ? 0 : -1;
}

References ast_sip_get_pjsip_endpoint(), NULL, status, and supplement_outgoing_response().

ast_sip_send_stateful_response()

int ast_sip_send_stateful_response	(	pjsip_rx_data *	rdata,
		pjsip_tx_data *	tdata,
		struct ast_sip_endpoint *	sip_endpoint
	)

Send a stateful response to an out of dialog request.

This creates a transaction within PJSIP, meaning that if the request that we are responding to is retransmitted, we will not attempt to re-handle the request.

Parameters

rdata	The request that is being responded to
tdata	The response to send
sip_endpoint	The ast_sip_endpoint associated with this response

Since

13.4.0

Return values

0	Success
-1	Failure

Definition at line 2424 of file res_pjsip.c.

{
    pjsip_transaction *tsx;
    pj_grp_lock_t *tsx_glock;
    pj_pool_t *pool;
 
    /* Create and initialize global lock pool */
    pool = pjsip_endpt_create_pool(ast_sip_get_pjsip_endpoint(), "stateful response", PJSIP_POOL_TSX_LEN, PJSIP_POOL_TSX_INC);
    if (!pool){
        /* ast_sip_create_response bumps the refcount of the contact and adds it to the tdata.
         * We'll leak that reference if we don't get rid of it here.
         */
        clean_contact_from_tdata(tdata);
        return -1;
    }
    /* Create with handler so that we can release the pool once the glock derefs out */
    if(pj_grp_lock_create_w_handler(pool, NULL, pool, &pool_destroy_callback, &tsx_glock) != PJ_SUCCESS) {
        clean_contact_from_tdata(tdata);
        pool_destroy_callback((void *) pool);
        return -1;
    }
    /* We need an additional reference as the qualify thread may destroy this out
     * from under us. Add it now before it gets added to the tsx. */
    pj_grp_lock_add_ref(tsx_glock);
 
    if (pjsip_tsx_create_uas2(NULL, rdata, tsx_glock, &tsx) != PJ_SUCCESS) {
        clean_contact_from_tdata(tdata);
        pj_grp_lock_dec_ref(tsx_glock);
        return -1;
    }
 
    pjsip_tsx_recv_msg(tsx, rdata);
    supplement_outgoing_response(tdata, sip_endpoint);
 
    if (pjsip_tsx_send_msg(tsx, tdata) != PJ_SUCCESS) {
        pj_grp_lock_dec_ref(tsx_glock);
        pjsip_tx_data_dec_ref(tdata);
        return -1;
    }
 
    pj_grp_lock_dec_ref(tsx_glock);
    return 0;
}

References ast_sip_get_pjsip_endpoint(), clean_contact_from_tdata(), NULL, pool_destroy_callback(), and supplement_outgoing_response().

Referenced by register_aor(), send_options_response(), and send_response().

ast_sip_set_id_connected_line()

int ast_sip_set_id_connected_line	(	struct pjsip_rx_data *	rdata,
		struct ast_party_id *	id
	)

Set the ID for a connected line update.

Return values

-1	on failure, 0 on success

Definition at line 2822 of file res_pjsip.c.

{
    return !set_id_from_pai(rdata, id) || !set_id_from_rpid(rdata, id) ? 0 : -1;
}

References set_id_from_pai(), and set_id_from_rpid().

Referenced by update_incoming_connected_line().

ast_sip_set_id_from_invite()

int ast_sip_set_id_from_invite	(	struct pjsip_rx_data *	rdata,
		struct ast_party_id *	id,
		struct ast_party_id *	default_id,
		int	trust_inbound
	)

Set the ID from an INVITE.

Parameters

rdata
id	ID structure to fill
default_id	Default ID structure with data to use (for non-trusted endpoints)
trust_inbound	Whether or not the endpoint is trusted (controls whether PAI or RPID can be used)

Return values

-1	on failure, 0 on success

Definition at line 2827 of file res_pjsip.c.

{
    if (trust_inbound && (!set_id_from_pai(rdata, id) || !set_id_from_rpid(rdata, id))) {
        /* Trusted: Check PAI and RPID */
        ast_free(id->tag);
        id->tag = ast_strdup(default_id->tag);
        return 0;
    }
    /* Not trusted: check the endpoint config or use From. */
    ast_party_id_copy(id, default_id);
    if (!default_id->number.valid) {
        set_id_from_from(rdata, id);
    }
    return 0;
}

References ast_free, ast_party_id_copy(), ast_strdup, id, ast_party_id::number, set_id_from_from(), set_id_from_pai(), set_id_from_rpid(), ast_party_id::tag, and ast_party_number::valid.

Referenced by caller_id_incoming_request(), and fetch_callerid_num().

ast_sip_set_outbound_proxy()

int ast_sip_set_outbound_proxy	(	pjsip_tx_data *	tdata,
		const char *	proxy
	)

Set the outbound proxy for an outbound SIP message.

Parameters

tdata	The message to set the outbound proxy on
proxy	SIP uri of the proxy

Return values

0	Success
-1	Failure

Definition at line 1992 of file res_pjsip.c.

{
    pjsip_route_hdr *route;
    static const pj_str_t ROUTE_HNAME = { "Route", 5 };
    pj_str_t tmp;
 
    pj_strdup2_with_null(tdata->pool, &tmp, proxy);
    if (!(route = pjsip_parse_hdr(tdata->pool, &ROUTE_HNAME, tmp.ptr, tmp.slen, NULL))) {
        return -1;
    }
 
    pj_list_insert_nodes_before(&tdata->msg->hdr, (pjsip_hdr*)route);
 
    return 0;
}

References NULL.

Referenced by create_out_of_dialog_request(), path_outgoing_request(), and sip_options_qualify_contact().

ast_sip_set_request_transport_details()

int ast_sip_set_request_transport_details	(	struct ast_sip_request_transport_details *	details,
		pjsip_tx_data *	tdata,
		int	use_ipv6
	)

Sets request transport details based on tdata.

Parameters

details	pre-allocated request transport details to set
tdata
use_ipv6	if non-zero, ipv6 transports will be considered

Return values

0	success
-1	failure

Definition at line 648 of file res_pjsip.c.

                  {
    pjsip_sip_uri *uri;
    pjsip_via_hdr *via;
    long transport_type;
 
    if (!details || !tdata) {
        return -1;
    }
 
    /* If IPv6 should be considered, un-set Bit 7 to make TCP6 equal to TCP and TLS6 equal to TLS */
    transport_type = use_ipv6 ? tdata->tp_info.transport->key.type & ~(PJSIP_TRANSPORT_IPV6)
        : tdata->tp_info.transport->key.type;
 
    if (tdata->tp_sel.type == PJSIP_TPSELECTOR_TRANSPORT) {
        details->transport = tdata->tp_sel.u.transport;
    } else if (tdata->tp_sel.type == PJSIP_TPSELECTOR_LISTENER) {
        details->factory = tdata->tp_sel.u.listener;
    } else if (transport_type == PJSIP_TRANSPORT_UDP || transport_type == PJSIP_TRANSPORT_UDP6) {
        /* Connectionless uses the same transport for all requests */
        details->type = AST_TRANSPORT_UDP;
        details->transport = tdata->tp_info.transport;
    } else {
        if (transport_type == PJSIP_TRANSPORT_TCP) {
            details->type = AST_TRANSPORT_TCP;
        } else if (transport_type == PJSIP_TRANSPORT_TLS) {
            details->type = AST_TRANSPORT_TLS;
        } else {
            /* Unknown transport type, we can't map. */
            return -1;
        }
 
        if ((uri = ast_sip_get_contact_sip_uri(tdata))) {
            details->local_address = uri->host;
            details->local_port = uri->port;
        } else if ((tdata->msg->type == PJSIP_REQUEST_MSG) &&
            (via = pjsip_msg_find_hdr(tdata->msg, PJSIP_H_VIA, NULL))) {
            details->local_address = via->sent_by.host;
            details->local_port = via->sent_by.port;
        } else {
            return -1;
        }
 
        if (!details->local_port) {
            details->local_port = (details->type == AST_TRANSPORT_TLS) ? 5061 : 5060;
        }
    }
    return 0;
}

References ast_sip_get_contact_sip_uri(), AST_TRANSPORT_TCP, AST_TRANSPORT_TLS, AST_TRANSPORT_UDP, ast_sip_request_transport_details::factory, if(), ast_sip_request_transport_details::local_address, ast_sip_request_transport_details::local_port, NULL, ast_sip_request_transport_details::transport, and ast_sip_request_transport_details::type.

Referenced by ast_sip_rewrite_uri_to_local(), and process_nat().

ast_sip_set_tpselector_from_ep_or_uri()

int ast_sip_set_tpselector_from_ep_or_uri	(	const struct ast_sip_endpoint *	endpoint,
		pjsip_sip_uri *	sip_uri,
		pjsip_tpselector *	selector
	)

Sets pjsip_tpselector from an endpoint or uri.

Since

13.15.0

Parameters

endpoint	If endpoint->transport is set, it's used
sip_uri	If sip_uri contains a x-ast-txp parameter, it's used
selector	The selector to be populated

Return values

0	success
-1	failure

Definition at line 911 of file res_pjsip.c.

{
    char transport_name[128];
 
    if (ast_sip_get_transport_name(endpoint, sip_uri, transport_name, sizeof(transport_name))) {
        return 0;
    }
 
    return ast_sip_set_tpselector_from_transport_name(transport_name, selector);
}

References ast_sip_get_transport_name(), and ast_sip_set_tpselector_from_transport_name().

Referenced by ast_sip_dlg_set_transport(), create_dialog_uas(), and create_out_of_dialog_request().

ast_sip_set_tpselector_from_transport()

int ast_sip_set_tpselector_from_transport	(	const struct ast_sip_transport *	transport,
		pjsip_tpselector *	selector
	)

Sets pjsip_tpselector from ast_sip_transport.

Since

13.8.0

Parameters

transport	The transport to be used
selector	The selector to be populated

Return values

0	success
-1	failure

Note

The transport selector must be unreffed using ast_sip_tpselector_unref

Definition at line 843 of file res_pjsip.c.

{
    int res = 0;
    struct ast_sip_transport_state *transport_state;
 
    transport_state = ast_sip_get_transport_state(ast_sorcery_object_get_id(transport));
    if (!transport_state) {
        ast_log(LOG_ERROR, "Unable to retrieve PJSIP transport state for '%s'\n",
            ast_sorcery_object_get_id(transport));
        return -1;
    }
 
    /* Only flows maintain dynamic state which needs protection */
    if (transport_state->flow) {
        ao2_lock(transport_state);
    }
 
    if (transport_state->transport) {
        selector->type = PJSIP_TPSELECTOR_TRANSPORT;
        selector->u.transport = transport_state->transport;
        pjsip_transport_add_ref(selector->u.transport);
    } else if (transport_state->factory) {
        selector->type = PJSIP_TPSELECTOR_LISTENER;
        selector->u.listener = transport_state->factory;
    } else if (transport->type == AST_TRANSPORT_WS || transport->type == AST_TRANSPORT_WSS) {
        /* The WebSocket transport has no factory as it can not create outgoing connections, so
         * even if an endpoint is locked to a WebSocket transport we let the PJSIP logic
         * find the existing connection if available and use it.
         */
    } else if (transport->flow) {
        /* This is a child of another transport, so we need to establish a new connection */
#ifdef HAVE_PJSIP_TRANSPORT_DISABLE_CONNECTION_REUSE
        selector->disable_connection_reuse = PJ_TRUE;
#else
        ast_log(LOG_WARNING, "Connection reuse could not be disabled on transport '%s' as support is not available\n",
            ast_sorcery_object_get_id(transport));
#endif
    } else {
        res = -1;
    }
 
    if (transport_state->flow) {
        ao2_unlock(transport_state);
    }
 
    ao2_ref(transport_state, -1);
 
    return res;
}

References ao2_lock, ao2_ref, ao2_unlock, ast_log, ast_sip_get_transport_state(), ast_sorcery_object_get_id(), AST_TRANSPORT_WS, AST_TRANSPORT_WSS, ast_sip_transport_state::factory, ast_sip_transport_state::flow, LOG_ERROR, LOG_WARNING, and ast_sip_transport_state::transport.

Referenced by ast_sip_set_tpselector_from_transport_name().

ast_sip_set_tpselector_from_transport_name()

int ast_sip_set_tpselector_from_transport_name	(	const char *	transport_name,
		pjsip_tpselector *	selector
	)

Sets pjsip_tpselector from ast_sip_transport.

Since

13.8.0

Parameters

transport_name	The name of the transport to be used
selector	The selector to be populated

Return values

0	success
-1	failure

Note

The transport selector must be unreffed using ast_sip_tpselector_unref

Definition at line 893 of file res_pjsip.c.

{
    RAII_VAR(struct ast_sip_transport *, transport, NULL, ao2_cleanup);
 
    if (ast_strlen_zero(transport_name)) {
        return 0;
    }
 
    transport = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "transport", transport_name);
    if (!transport) {
        ast_log(LOG_ERROR, "Unable to retrieve PJSIP transport '%s'\n",
            transport_name);
        return -1;
    }
 
    return ast_sip_set_tpselector_from_transport(transport, selector);
}

References ao2_cleanup, ast_log, ast_sip_get_sorcery(), ast_sip_set_tpselector_from_transport(), ast_sorcery_retrieve_by_id(), ast_strlen_zero(), LOG_ERROR, NULL, RAII_VAR, and ast_sip_transport_state::transport.

Referenced by ast_sip_set_tpselector_from_ep_or_uri(), registration_client_send(), set_transport(), and sip_outbound_registration_regc_alloc().

ast_sip_str2rc()

int ast_sip_str2rc

(

const char *

name

)

Convert name to SIP response code.

Parameters

name	SIP response code name matching one of the enum names defined in "enum pjsip_status_code" defined in sip_msg.h. May be specified with or without the PJSIP_SC_ prefix.

Return values

SIP	response code
-1	if matching code not found

Definition at line 3714 of file res_pjsip.c.

{
    int i;
 
    if (ast_strlen_zero(name)) {
        return -1;
    }
 
    for (i = 0; i < ARRAY_LEN(rc_map); i++) {
        if (strcasecmp(rc_map[i].short_name, name) == 0 ||
            strcasecmp(rc_map[i].long_name, name) == 0) {
            return rc_map[i].code;
        }
    }
 
    return -1;
}

References ARRAY_LEN, ast_strlen_zero(), response_code_map::code, response_code_map::long_name, name, rc_map, and response_code_map::short_name.

Referenced by response_code_validator().

ast_sip_str_to_dtmf()

int ast_sip_str_to_dtmf

(

const char *

dtmf_mode

)

Convert the DTMF mode name into an enum.

Since

13.18.0

Parameters

dtmf_mode

dtmf mode as a string

Return values

>=	0 The enum value
-1	Failure

Definition at line 2533 of file res_pjsip.c.

{
    int result = -1;
 
    if (!strcasecmp(dtmf_mode, "info")) {
        result = AST_SIP_DTMF_INFO;
    } else if (!strcasecmp(dtmf_mode, "rfc4733")) {
        result = AST_SIP_DTMF_RFC_4733;
    } else if (!strcasecmp(dtmf_mode, "inband")) {
        result = AST_SIP_DTMF_INBAND;
    } else if (!strcasecmp(dtmf_mode, "none")) {
        result = AST_SIP_DTMF_NONE;
    } else if (!strcasecmp(dtmf_mode, "auto")) {
        result = AST_SIP_DTMF_AUTO;
    } else if (!strcasecmp(dtmf_mode, "auto_info")) {
        result = AST_SIP_DTMF_AUTO_INFO;
    }
 
    return result;
}

References AST_SIP_DTMF_AUTO, AST_SIP_DTMF_AUTO_INFO, AST_SIP_DTMF_INBAND, AST_SIP_DTMF_INFO, AST_SIP_DTMF_NONE, AST_SIP_DTMF_RFC_4733, and result.

Referenced by dtmf_handler(), and pjsip_acf_dtmf_mode_write().

ast_sip_threadpool()

struct ast_threadpool * ast_sip_threadpool

(

void

)

Retrieve the SIP threadpool object.

Definition at line 3462 of file res_pjsip.c.

{
    return sip_threadpool;
}

References sip_threadpool.

Referenced by load_module().

ast_sip_threadpool_queue_size()

long ast_sip_threadpool_queue_size

(

void

)

Return the size of the SIP threadpool's task queue.

Since

13.7.0

Definition at line 3457 of file res_pjsip.c.

{
    return ast_threadpool_queue_size(sip_threadpool);
}

References ast_threadpool_queue_size(), and sip_threadpool.

ast_sip_tpselector_unref()

void ast_sip_tpselector_unref

(

pjsip_tpselector *

selector

)

Unreference a pjsip_tpselector.

Since

17.0.0

Parameters

selector

The selector to be unreffed

Definition at line 923 of file res_pjsip.c.

{
    if (selector->type == PJSIP_TPSELECTOR_TRANSPORT && selector->u.transport) {
        pjsip_transport_dec_ref(selector->u.transport);
    }
}

Referenced by ast_sip_create_dialog_uac(), ast_sip_dlg_set_transport(), create_dialog_uas(), create_out_of_dialog_request(), registration_client_send(), set_transport(), and sip_outbound_registration_regc_alloc().

ast_sip_unregister_authenticator()

void ast_sip_unregister_authenticator

(

struct ast_sip_authenticator *

auth

)

Unregister a SIP authenticator.

When there is no authenticator registered, requests cannot be challenged or authenticated.

Parameters

auth	The authenticator to unregister

Definition at line 152 of file res_pjsip.c.

{
    if (registered_authenticator != auth) {
        ast_log(LOG_WARNING, "Trying to unregister authenticator %p but authenticator %p registered\n",
                auth, registered_authenticator);
        return;
    }
    registered_authenticator = NULL;
    ast_debug(1, "Unregistered SIP authenticator %p\n", auth);
}

References ast_debug, ast_log, LOG_WARNING, NULL, and registered_authenticator.

Referenced by unload_module().

ast_sip_unregister_endpoint_formatter()

void ast_sip_unregister_endpoint_formatter

(

struct ast_sip_endpoint_formatter *

obj

)

Unregister an endpoint formatter.

Parameters

obj	the formatter to unregister

Definition at line 487 of file res_pjsip.c.

{
    struct ast_sip_endpoint_formatter *i;
    SCOPED_LOCK(lock, &endpoint_formatters, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
 
    AST_RWLIST_TRAVERSE_SAFE_BEGIN(&endpoint_formatters, i, next) {
        if (i == obj) {
            AST_RWLIST_REMOVE_CURRENT(next);
            break;
        }
    }
    AST_RWLIST_TRAVERSE_SAFE_END;
}

References AST_RWLIST_REMOVE_CURRENT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, lock, and SCOPED_LOCK.

Referenced by ast_res_pjsip_cleanup_options_handling(), ast_sip_destroy_sorcery_auth(), ast_sip_destroy_sorcery_location(), ast_sip_destroy_sorcery_transport(), and unload_module().

ast_sip_unregister_endpoint_identifier()

void ast_sip_unregister_endpoint_identifier

(

struct ast_sip_endpoint_identifier *

identifier

)

Unregister a SIP endpoint identifier.

This stops an endpoint identifier from being used.

Parameters

identifier

The SIP endoint identifier to unregister

Definition at line 315 of file res_pjsip.c.

{
    struct endpoint_identifier_list *iter;
    SCOPED_LOCK(lock, &endpoint_identifiers, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
    AST_RWLIST_TRAVERSE_SAFE_BEGIN(&endpoint_identifiers, iter, list) {
        if (iter->identifier == identifier) {
            AST_RWLIST_REMOVE_CURRENT(list);
            ast_free(iter);
            ast_debug(1, "Unregistered endpoint identifier %p\n", identifier);
            break;
        }
    }
    AST_RWLIST_TRAVERSE_SAFE_END;
}

References ast_debug, ast_free, AST_RWLIST_REMOVE_CURRENT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, endpoint_identifier_list::identifier, lock, and SCOPED_LOCK.

Referenced by unload_module().

ast_sip_unregister_outbound_authenticator()

void ast_sip_unregister_outbound_authenticator

(

struct ast_sip_outbound_authenticator *

auth

)

Unregister an outbound SIP authenticator.

When there is no outbound authenticator registered, authentication challenges will be handled as any other final response would be.

Parameters

auth	The authenticator to unregister

Definition at line 203 of file res_pjsip.c.

{
    if (registered_outbound_authenticator != auth) {
        ast_log(LOG_WARNING, "Trying to unregister outbound authenticator %p but outbound authenticator %p registered\n",
                auth, registered_outbound_authenticator);
        return;
    }
    registered_outbound_authenticator = NULL;
    ast_debug(1, "Unregistered SIP outbound authenticator %p\n", auth);
}

References ast_debug, ast_log, LOG_WARNING, NULL, and registered_outbound_authenticator.

Referenced by unload_module().

ast_sip_unregister_service()

void ast_sip_unregister_service

(

pjsip_module *

module

)

This is the opposite of ast_sip_register_service(). Unregistering a service means that PJSIP will no longer call into the module any more. This will likely occur when an Asterisk module is unloaded.

Parameters

module

The PJSIP module to unregister

Definition at line 133 of file res_pjsip.c.

{
    ast_sip_push_task_wait_servant(NULL, unregister_service, &module);
}

References ast_sip_push_task_wait_servant(), NULL, and unregister_service().

Referenced by ast_res_pjsip_cleanup_message_filter(), ast_sip_destroy_distributor(), ast_sip_destroy_global_headers(), ast_sip_destroy_transport_management(), load_module(), unload_module(), and unload_pjsip().

ast_sip_unregister_supplement()

void ast_sip_unregister_supplement

(

struct ast_sip_supplement *

supplement

)

Unregister a an supplement to SIP out of dialog processing.

Parameters

supplement

The supplement to unregister

Definition at line 1476 of file res_pjsip.c.

{
    struct ast_sip_supplement *iter;
    SCOPED_LOCK(lock, &supplements, AST_RWLIST_WRLOCK, AST_RWLIST_UNLOCK);
 
    AST_RWLIST_TRAVERSE_SAFE_BEGIN(&supplements, iter, next) {
        if (supplement == iter) {
            AST_RWLIST_REMOVE_CURRENT(next);
            break;
        }
    }
    AST_RWLIST_TRAVERSE_SAFE_END;
}

References AST_RWLIST_REMOVE_CURRENT, AST_RWLIST_TRAVERSE_SAFE_BEGIN, AST_RWLIST_TRAVERSE_SAFE_END, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, lock, ast_sip_supplement::next, and SCOPED_LOCK.

Referenced by ast_res_pjsip_cleanup_message_filter(), and unload_module().

ast_sip_update_from()

int ast_sip_update_from	(	pjsip_tx_data *	tdata,
		char *	from
	)

Overwrite fields in the outbound 'From' header.

The outbound 'From' header is created/added in ast_sip_create_request with default data. If available that data may be info specified in the 'from_user' and 'from_domain' options found on the endpoint. That information will be overwritten with data in the given 'from' parameter.

Parameters

tdata	the outbound message data structure
from	info to copy into the header. Can be either a SIP URI, or in the format user[@domain]

Return values

0	success, -1: failure

Definition at line 3383 of file res_pjsip.c.

{
    pjsip_name_addr *name_addr;
    pjsip_sip_uri *uri;
    pjsip_name_addr *parsed_name_addr;
    pjsip_from_hdr *from_hdr;
 
    if (ast_strlen_zero(from)) {
        return 0;
    }
 
    from_hdr = PJSIP_MSG_FROM_HDR(tdata->msg);
    if (!from_hdr) {
        return -1;
    }
    name_addr = (pjsip_name_addr *) from_hdr->uri;
    uri = pjsip_uri_get_uri(name_addr);
 
    parsed_name_addr = (pjsip_name_addr *) pjsip_parse_uri(tdata->pool, from,
        strlen(from), PJSIP_PARSE_URI_AS_NAMEADDR);
    if (parsed_name_addr) {
        pjsip_sip_uri *parsed_uri;
 
        if (!PJSIP_URI_SCHEME_IS_SIP(parsed_name_addr->uri)
                && !PJSIP_URI_SCHEME_IS_SIPS(parsed_name_addr->uri)) {
            ast_log(LOG_WARNING, "From address '%s' is not a valid SIP/SIPS URI\n", from);
            return -1;
        }
 
        parsed_uri = pjsip_uri_get_uri(parsed_name_addr->uri);
 
        if (pj_strlen(&parsed_name_addr->display)) {
            pj_strdup(tdata->pool, &name_addr->display, &parsed_name_addr->display);
        }
 
        /* Unlike the To header, we only want to replace the user, host and port */
        pj_strdup(tdata->pool, &uri->user, &parsed_uri->user);
        pj_strdup(tdata->pool, &uri->host, &parsed_uri->host);
        uri->port = parsed_uri->port;
 
        return 0;
    } else {
        /* assume it is 'user[@domain]' format */
        char *domain = strchr(from, '@');
 
        if (domain) {
            pj_str_t pj_from;
 
            pj_strset3(&pj_from, from, domain);
            pj_strdup(tdata->pool, &uri->user, &pj_from);
 
            pj_strdup2(tdata->pool, &uri->host, domain + 1);
        } else {
            pj_strdup2(tdata->pool, &uri->user, from);
        }
 
        return 0;
    }
 
    return -1;
}

References ast_log, ast_strlen_zero(), and LOG_WARNING.

Referenced by msg_send(), and refer_send().

ast_sip_update_to_uri()

int ast_sip_update_to_uri	(	pjsip_tx_data *	tdata,
		const char *	to
	)

Replace the To URI in the tdata with the supplied one.

Parameters

tdata	the outbound message data structure
to	URI to replace the To URI with. Must be a valid SIP URI.

Return values

0	success, -1: failure

Definition at line 3323 of file res_pjsip.c.

{
    pjsip_name_addr *parsed_name_addr;
    pjsip_sip_uri *sip_uri;
    pjsip_name_addr *tdata_name_addr;
    pjsip_sip_uri *tdata_sip_uri;
    pjsip_to_hdr *to_hdr;
    char *buf = NULL;
#define DEBUG_BUF_SIZE 256
 
    parsed_name_addr = (pjsip_name_addr *) pjsip_parse_uri(tdata->pool, (char*)to, strlen(to),
        PJSIP_PARSE_URI_AS_NAMEADDR);
 
    if (!parsed_name_addr || (!PJSIP_URI_SCHEME_IS_SIP(parsed_name_addr->uri)
            && !PJSIP_URI_SCHEME_IS_SIPS(parsed_name_addr->uri))) {
        ast_log(LOG_WARNING, "To address '%s' is not a valid SIP/SIPS URI\n", to);
        return -1;
    }
 
    sip_uri = pjsip_uri_get_uri(parsed_name_addr->uri);
    if (DEBUG_ATLEAST(3)) {
        buf = ast_alloca(DEBUG_BUF_SIZE);
        pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, sip_uri, buf, DEBUG_BUF_SIZE);
        ast_debug(3, "Parsed To: %.*s  %s\n", (int)parsed_name_addr->display.slen,
            parsed_name_addr->display.ptr, buf);
    }
 
    to_hdr = PJSIP_MSG_TO_HDR(tdata->msg);
    tdata_name_addr = to_hdr ? (pjsip_name_addr *) to_hdr->uri : NULL;
    if (!tdata_name_addr || (!PJSIP_URI_SCHEME_IS_SIP(tdata_name_addr->uri)
            && !PJSIP_URI_SCHEME_IS_SIPS(tdata_name_addr->uri))) {
        /* Highly unlikely but we have to check */
        ast_log(LOG_WARNING, "tdata To address '%s' is not a valid SIP/SIPS URI\n", to);
        return -1;
    }
 
    tdata_sip_uri = pjsip_uri_get_uri(tdata_name_addr->uri);
    if (DEBUG_ATLEAST(3)) {
        buf[0] = '\0';
        pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, buf, DEBUG_BUF_SIZE);
        ast_debug(3, "Original tdata To: %.*s  %s\n", (int)tdata_name_addr->display.slen,
            tdata_name_addr->display.ptr, buf);
    }
 
    /* Replace the uri */
    pjsip_sip_uri_assign(tdata->pool, tdata_sip_uri, sip_uri);
    /* The display name isn't part of the URI so we need to replace it separately */
    pj_strdup(tdata->pool, &tdata_name_addr->display, &parsed_name_addr->display);
 
    if (DEBUG_ATLEAST(3)) {
        buf[0] = '\0';
        pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, buf, 256);
        ast_debug(3, "New tdata To: %.*s  %s\n", (int)tdata_name_addr->display.slen,
            tdata_name_addr->display.ptr, buf);
    }
 
    return 0;
#undef DEBUG_BUF_SIZE
}

References ast_alloca, ast_debug, ast_log, buf, DEBUG_ATLEAST, DEBUG_BUF_SIZE, if(), LOG_WARNING, and NULL.

Referenced by msg_send(), and refer_send().

ast_sip_will_uri_survive_restart()

int ast_sip_will_uri_survive_restart	(	pjsip_sip_uri *	uri,
		struct ast_sip_endpoint *	endpoint,
		pjsip_rx_data *	rdata
	)

Definition at line 525 of file res_pjsip.c.

{
    pj_str_t host_name;
    int result = 1;
 
    /* Determine if the contact cannot survive a restart/boot. */
    if (uri->port == rdata->pkt_info.src_port
        && !pj_strcmp(&uri->host,
            pj_cstr(&host_name, rdata->pkt_info.src_name))
        /* We have already checked if the URI scheme is sip: or sips: */
        && PJSIP_TRANSPORT_IS_RELIABLE(rdata->tp_info.transport)) {
        pj_str_t type_name;
 
        /* Determine the transport parameter value */
        if (!strcasecmp("WSS", rdata->tp_info.transport->type_name)) {
            /* WSS is special, as it needs to be ws. */
            pj_cstr(&type_name, "ws");
        } else {
            pj_cstr(&type_name, rdata->tp_info.transport->type_name);
        }
 
        if (!pj_stricmp(&uri->transport_param, &type_name)
            && (endpoint->nat.rewrite_contact
                /* Websockets are always rewritten */
                || !pj_stricmp(&uri->transport_param,
                    pj_cstr(&type_name, "ws")))) {
            /*
             * The contact was rewritten to the reliable transport's
             * source address.  Disconnecting the transport for any
             * reason invalidates the contact.
             */
            result = 0;
        }
    }
 
    return result;
}

References ast_sip_endpoint::nat, result, and ast_sip_endpoint_nat_configuration::rewrite_contact.

Referenced by subscription_persistence_update().

check_request_status()

static int check_request_status ( struct send_request_data *  req_data, pjsip_event *  e  )

static

Definition at line 1839 of file res_pjsip.c.

{
    struct ast_sip_endpoint *endpoint;
    pjsip_transaction *tsx;
    pjsip_tx_data *tdata;
    int res = 0;
 
    if (!(endpoint = ao2_bump(req_data->endpoint))) {
        return 0;
    }
 
    tsx = e->body.tsx_state.tsx;
 
    switch (tsx->status_code) {
    case 401:
    case 407:
        /* Resend the request with a challenge response if we are challenged. */
        res = ++req_data->challenge_count < MAX_RX_CHALLENGES /* Not in a challenge loop */
            && !ast_sip_create_request_with_auth(&endpoint->outbound_auths,
                e->body.tsx_state.src.rdata, tsx->last_tx, &tdata);
        break;
    case 408:
    case 503:
        if ((res = ast_sip_failover_request(tsx->last_tx))) {
            tdata = tsx->last_tx;
            /*
             * Bump the ref since it will be on a new transaction and
             * we don't want it to go away along with the old transaction.
             */
            pjsip_tx_data_add_ref(tdata);
        }
        break;
    }
 
    if (res) {
        res = endpt_send_request(endpoint, tdata, -1,
                     req_data, send_request_cb) == PJ_SUCCESS;
    }
 
    ao2_ref(endpoint, -1);
    return res;
}

References ao2_bump, ao2_ref, ast_sip_create_request_with_auth(), ast_sip_failover_request(), send_request_data::challenge_count, send_request_data::endpoint, endpt_send_request(), MAX_RX_CHALLENGES, ast_sip_endpoint::outbound_auths, and send_request_cb().

Referenced by send_request_cb().

clean_contact_from_tdata()

static void clean_contact_from_tdata ( pjsip_tx_data *  tdata )

static

Definition at line 2415 of file res_pjsip.c.

{
    struct ast_sip_contact *contact;
    contact = ast_sip_mod_data_get(tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT);
    ao2_cleanup(contact);
    ast_sip_mod_data_set(tdata->pool, tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT, NULL);
    pjsip_tx_data_dec_ref(tdata);
}

References ao2_cleanup, ast_sip_mod_data_get, ast_sip_mod_data_set, MOD_DATA_CONTACT, NULL, and supplement_module.

Referenced by ast_sip_send_stateful_response().

cli_dump_endpt()

static char * cli_dump_endpt ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 371 of file res_pjsip.c.

{
    switch (cmd) {
    case CLI_INIT:
#ifdef AST_DEVMODE
        e->command = "pjsip dump endpt [details]";
        e->usage =
            "Usage: pjsip dump endpt [details]\n"
            "       Dump the res_pjsip endpt internals.\n"
            "\n"
            "Warning: PJPROJECT documents that the function used by this\n"
            "CLI command may cause a crash when asking for details because\n"
            "it tries to access all active memory pools.\n";
#else
        /*
         * In non-developer mode we will not document or make easily accessible
         * the details option even though it is still available.  The user has
         * to know it exists to use it.  Presumably they would also be aware of
         * the potential crash warning.
         */
        e->command = "pjsip dump endpt";
        e->usage =
            "Usage: pjsip dump endpt\n"
            "       Dump the res_pjsip endpt internals.\n";
#endif /* AST_DEVMODE */
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (4 < a->argc
        || (a->argc == 4 && strcasecmp(a->argv[3], "details"))) {
        return CLI_SHOWUSAGE;
    }
 
    ast_sip_push_task_wait_servant(NULL, do_cli_dump_endpt, a);
 
    return CLI_SUCCESS;
}

References a, ast_sip_push_task_wait_servant(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, do_cli_dump_endpt(), NULL, and ast_cli_entry::usage.

cli_show_endpoint_identifiers()

static char * cli_show_endpoint_identifiers ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 411 of file res_pjsip.c.

{
#define ENDPOINT_IDENTIFIER_FORMAT "%-20.20s\n"
    struct endpoint_identifier_list *iter;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "pjsip show identifiers";
        e->usage = "Usage: pjsip show identifiers\n"
                    "      List all registered endpoint identifiers\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 3) {
                return CLI_SHOWUSAGE;
        }
 
    ast_cli(a->fd, ENDPOINT_IDENTIFIER_FORMAT, "Identifier Names:");
    {
        SCOPED_LOCK(lock, &endpoint_identifiers, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK);
        AST_RWLIST_TRAVERSE(&endpoint_identifiers, iter, list) {
            ast_cli(a->fd, ENDPOINT_IDENTIFIER_FORMAT,
                iter->name ? iter->name : "name not specified");
        }
    }
    return CLI_SUCCESS;
#undef ENDPOINT_IDENTIFIER_FORMAT
}

References a, ast_cli(), AST_RWLIST_RDLOCK, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ENDPOINT_IDENTIFIER_FORMAT, lock, endpoint_identifier_list::name, NULL, SCOPED_LOCK, and ast_cli_entry::usage.

cli_show_settings()

static char * cli_show_settings ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 442 of file res_pjsip.c.

{
    struct ast_sip_cli_context context;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "pjsip show settings";
        e->usage = "Usage: pjsip show settings\n"
                    "      Show global and system configuration options\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    context.output_buffer = ast_str_create(256);
    if (!context.output_buffer) {
        ast_cli(a->fd, "Could not allocate output buffer.\n");
        return CLI_FAILURE;
    }
 
    if (sip_cli_print_global(&context) || sip_cli_print_system(&context)) {
        ast_free(context.output_buffer);
        ast_cli(a->fd, "Error retrieving settings.\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "%s", ast_str_buffer(context.output_buffer));
    ast_free(context.output_buffer);
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_free, ast_str_buffer(), ast_str_create, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_cli_entry::command, voicemailpwcheck::context, NULL, sip_cli_print_global(), sip_cli_print_system(), and ast_cli_entry::usage.

create_dialog_uas()

static pjsip_dialog * create_dialog_uas ( const struct ast_sip_endpoint *  endpoint, pjsip_rx_data *  rdata, pj_status_t *  status, create_dlg_uac  create_fun  )

static

Definition at line 1118 of file res_pjsip.c.

{
    pjsip_dialog *dlg;
    pj_str_t contact;
    pjsip_transport_type_e type = rdata->tp_info.transport->key.type;
    pjsip_tpselector selector = { .type = PJSIP_TPSELECTOR_NONE, };
    pjsip_transport *transport;
    pjsip_contact_hdr *contact_hdr;
 
    ast_assert(status != NULL);
 
    contact_hdr = pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_CONTACT, NULL);
    if (!contact_hdr || ast_sip_set_tpselector_from_ep_or_uri(endpoint, pjsip_uri_get_uri(contact_hdr->uri),
        &selector)) {
        return NULL;
    }
 
    transport = rdata->tp_info.transport;
    if (selector.type == PJSIP_TPSELECTOR_TRANSPORT) {
        transport = selector.u.transport;
    }
    type = transport->key.type;
 
    contact.ptr = pj_pool_alloc(rdata->tp_info.pool, PJSIP_MAX_URL_SIZE);
    contact.slen = pj_ansi_snprintf(contact.ptr, PJSIP_MAX_URL_SIZE,
            "<%s:%s%s%s%.*s%s:%d%s%s>",
            uas_use_sips_contact(rdata) ? "sips" : "sip",
            S_OR(endpoint->contact_user, ""),
                        (!ast_strlen_zero(endpoint->contact_user)) ? "@" : "",
            (type & PJSIP_TRANSPORT_IPV6) ? "[" : "",
            (int)transport->local_name.host.slen,
            transport->local_name.host.ptr,
            (type & PJSIP_TRANSPORT_IPV6) ? "]" : "",
            transport->local_name.port,
            (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? ";transport=" : "",
            (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? pjsip_transport_get_type_name(type) : "");
 
    *status = create_fun(pjsip_ua_instance(), rdata, &contact, &dlg);
    if (*status != PJ_SUCCESS) {
        char err[PJ_ERR_MSG_SIZE];
 
        pj_strerror(*status, err, sizeof(err));
        ast_log(LOG_ERROR, "Could not create dialog with endpoint %s. %s\n",
                ast_sorcery_object_get_id(endpoint), err);
        ast_sip_tpselector_unref(&selector);
        return NULL;
    }
 
    dlg->sess_count++;
    pjsip_dlg_set_transport(dlg, &selector);
    dlg->sess_count--;
 
    ast_sip_tpselector_unref(&selector);
 
    return dlg;
}

References ast_assert, ast_log, ast_sip_set_tpselector_from_ep_or_uri(), ast_sip_tpselector_unref(), ast_sorcery_object_get_id(), ast_strlen_zero(), ast_sip_endpoint::contact_user, LOG_ERROR, NULL, S_OR, status, ast_sip_transport_state::transport, type, and uas_use_sips_contact().

Referenced by ast_sip_create_dialog_uas(), and ast_sip_create_dialog_uas_locked().

create_in_dialog_request()

static int create_in_dialog_request ( const pjsip_method *  method, struct pjsip_dialog *  dlg, pjsip_tx_data **  tdata  )

static

Definition at line 1307 of file res_pjsip.c.

{
    if (pjsip_dlg_create_request(dlg, method, -1, tdata) != PJ_SUCCESS) {
        ast_log(LOG_WARNING, "Unable to create in-dialog request.\n");
        return -1;
    }
 
    return 0;
}

References ast_log, LOG_WARNING, and method.

Referenced by ast_sip_create_request().

create_out_of_dialog_request()

static int create_out_of_dialog_request ( const pjsip_method *  method, struct ast_sip_endpoint *  endpoint, const char *  uri, struct ast_sip_contact *  provided_contact, pjsip_tx_data **  tdata  )

static

Definition at line 1325 of file res_pjsip.c.

{
    RAII_VAR(struct ast_sip_contact *, contact, ao2_bump(provided_contact), ao2_cleanup);
    pj_str_t remote_uri;
    pj_str_t from;
    pj_pool_t *pool;
    pjsip_tpselector selector = { .type = PJSIP_TPSELECTOR_NONE, };
    pjsip_uri *sip_uri;
    const char *fromuser;
 
    if (ast_strlen_zero(uri)) {
        if (!endpoint && (!contact || ast_strlen_zero(contact->uri))) {
            ast_log(LOG_ERROR, "An endpoint and/or uri must be specified\n");
            return -1;
        }
 
        if (!contact) {
            contact = ast_sip_location_retrieve_contact_from_aor_list(endpoint->aors);
        }
        if (!contact || ast_strlen_zero(contact->uri)) {
            ast_log(LOG_WARNING, "Unable to retrieve contact for endpoint %s\n",
                    ast_sorcery_object_get_id(endpoint));
            return -1;
        }
 
        pj_cstr(&remote_uri, contact->uri);
    } else {
        pj_cstr(&remote_uri, uri);
    }
 
    pool = pjsip_endpt_create_pool(ast_sip_get_pjsip_endpoint(), "Outbound request", 256, 256);
 
    if (!pool) {
        ast_log(LOG_ERROR, "Unable to create PJLIB memory pool\n");
        return -1;
    }
 
    sip_uri = pjsip_parse_uri(pool, remote_uri.ptr, remote_uri.slen, 0);
    if (!sip_uri || (!PJSIP_URI_SCHEME_IS_SIP(sip_uri) && !PJSIP_URI_SCHEME_IS_SIPS(sip_uri))) {
        ast_log(LOG_ERROR, "Unable to create outbound %.*s request to endpoint %s as URI '%s' is not valid\n",
            (int) pj_strlen(&method->name), pj_strbuf(&method->name),
            endpoint ? ast_sorcery_object_get_id(endpoint) : "<none>",
            pj_strbuf(&remote_uri));
        pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
        return -1;
    }
 
    ast_sip_set_tpselector_from_ep_or_uri(endpoint, pjsip_uri_get_uri(sip_uri), &selector);
 
    fromuser = endpoint ? (!ast_strlen_zero(endpoint->fromuser) ? endpoint->fromuser : ast_sorcery_object_get_id(endpoint)) : NULL;
    if (sip_dialog_create_from(pool, &from, fromuser,
                endpoint ? endpoint->fromdomain : NULL, &remote_uri, &selector)) {
        ast_log(LOG_ERROR, "Unable to create From header for %.*s request to endpoint %s\n",
                (int) pj_strlen(&method->name), pj_strbuf(&method->name),
                endpoint ? ast_sorcery_object_get_id(endpoint) : "<none>");
        pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
        ast_sip_tpselector_unref(&selector);
        return -1;
    }
 
    if (pjsip_endpt_create_request(ast_sip_get_pjsip_endpoint(), method, &remote_uri,
            &from, &remote_uri, &from, NULL, -1, NULL, tdata) != PJ_SUCCESS) {
        ast_log(LOG_ERROR, "Unable to create outbound %.*s request to endpoint %s\n",
                (int) pj_strlen(&method->name), pj_strbuf(&method->name),
                endpoint ? ast_sorcery_object_get_id(endpoint) : "<none>");
        pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
        ast_sip_tpselector_unref(&selector);
        return -1;
    }
 
    pjsip_tx_data_set_transport(*tdata, &selector);
 
    ast_sip_tpselector_unref(&selector);
 
    if (endpoint && !ast_strlen_zero(endpoint->contact_user)){
        pjsip_contact_hdr *contact_hdr;
        pjsip_sip_uri *contact_uri;
        static const pj_str_t HCONTACT = { "Contact", 7 };
        static const pj_str_t HCONTACTSHORT = { "m", 1 };
 
        contact_hdr = pjsip_msg_find_hdr_by_names((*tdata)->msg, &HCONTACT, &HCONTACTSHORT, NULL);
        if (contact_hdr) {
            contact_uri = pjsip_uri_get_uri(contact_hdr->uri);
            pj_strdup2((*tdata)->pool, &contact_uri->user, endpoint->contact_user);
        }
    }
 
    /* Add the user=phone parameter if applicable */
    ast_sip_add_usereqphone(endpoint, (*tdata)->pool, (*tdata)->msg->line.req.uri);
 
    /* If an outbound proxy is specified on the endpoint apply it to this request */
    if (endpoint && !ast_strlen_zero(endpoint->outbound_proxy) &&
        ast_sip_set_outbound_proxy((*tdata), endpoint->outbound_proxy)) {
        ast_log(LOG_ERROR, "Unable to apply outbound proxy on request %.*s to endpoint %s as outbound proxy URI '%s' is not valid\n",
            (int) pj_strlen(&method->name), pj_strbuf(&method->name), ast_sorcery_object_get_id(endpoint),
            endpoint->outbound_proxy);
        pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
        return -1;
    }
 
    ast_sip_mod_data_set((*tdata)->pool, (*tdata)->mod_data, supplement_module.id, MOD_DATA_CONTACT, ao2_bump(contact));
 
    /* We can release this pool since request creation copied all the necessary
     * data into the outbound request's pool
     */
    pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
    return 0;
}

References ao2_bump, ao2_cleanup, ast_sip_endpoint::aors, ast_log, ast_sip_add_usereqphone(), ast_sip_get_pjsip_endpoint(), ast_sip_location_retrieve_contact_from_aor_list(), ast_sip_mod_data_set, ast_sip_set_outbound_proxy(), ast_sip_set_tpselector_from_ep_or_uri(), ast_sip_tpselector_unref(), ast_sorcery_object_get_id(), ast_strlen_zero(), ast_sip_endpoint::contact_user, ast_sip_endpoint::fromdomain, ast_sip_endpoint::fromuser, LOG_ERROR, LOG_WARNING, method, MOD_DATA_CONTACT, NULL, ast_sip_endpoint::outbound_proxy, RAII_VAR, sip_dialog_create_from(), and supplement_module.

Referenced by ast_sip_create_request().

do_cli_dump_endpt()

static int do_cli_dump_endpt ( void *  v_a )

static

Definition at line 360 of file res_pjsip.c.

{
    struct ast_cli_args *a = v_a;
 
    ast_pjproject_log_intercept_begin(a->fd);
    pjsip_endpt_dump(ast_sip_get_pjsip_endpoint(), a->argc == 4 ? PJ_TRUE : PJ_FALSE);
    ast_pjproject_log_intercept_end();
 
    return 0;
}

References a, ast_pjproject_log_intercept_begin(), ast_pjproject_log_intercept_end(), and ast_sip_get_pjsip_endpoint().

Referenced by cli_dump_endpt().

does_method_match()

static pj_bool_t does_method_match ( const pj_str_t *  message_method, const char *  supplement_method  )

static

Definition at line 1499 of file res_pjsip.c.

{
    pj_str_t method;
 
    if (ast_strlen_zero(supplement_method)) {
        return PJ_TRUE;
    }
 
    pj_cstr(&method, supplement_method);
 
    return pj_stristr(&method, message_method) ? PJ_TRUE : PJ_FALSE;
}

References ast_strlen_zero(), message_method, and method.

Referenced by ast_sip_send_out_of_dialog_request(), send_request_cb(), supplement_on_rx_request(), and supplement_outgoing_response().

endpt_send_request()

static pj_status_t endpt_send_request ( struct ast_sip_endpoint *  endpoint, pjsip_tx_data *  tdata, pj_int32_t  timeout, void *  token, pjsip_endpt_send_callback  cb  )

static

Definition at line 1696 of file res_pjsip.c.

{
    struct send_request_wrapper *req_wrapper;
    pj_status_t ret_val;
    pjsip_endpoint *endpt = ast_sip_get_pjsip_endpoint();
 
    if (!cb && token) {
        /* Silly.  Without a callback we cannot do anything with token. */
        pjsip_tx_data_dec_ref(tdata);
        return PJ_EINVAL;
    }
 
    /* Create wrapper to detect if the callback was actually called on an error. */
    req_wrapper = ao2_alloc(sizeof(*req_wrapper), send_request_wrapper_destructor);
    if (!req_wrapper) {
        pjsip_tx_data_dec_ref(tdata);
        return PJ_ENOMEM;
    }
 
    ast_debug(2, "%p: Wrapper created\n", req_wrapper);
 
    req_wrapper->token = token;
    req_wrapper->callback = cb;
    req_wrapper->timeout = timeout;
    req_wrapper->timeout_timer = NULL;
    req_wrapper->tdata = tdata;
    /* Add a reference to tdata.  The wrapper destructor cleans it up. */
    pjsip_tx_data_add_ref(tdata);
 
    if (timeout > 0) {
        pj_time_val timeout_timer_val = { timeout / 1000, timeout % 1000 };
 
        req_wrapper->timeout_timer = PJ_POOL_ALLOC_T(tdata->pool, pj_timer_entry);
 
        ast_debug(2, "%p: Set timer to %d msec\n", req_wrapper, timeout);
 
        pj_timer_entry_init(req_wrapper->timeout_timer, TIMEOUT_TIMER2,
            req_wrapper, send_request_timer_callback);
 
        /* We need to insure that the wrapper and tdata are available if/when the
         * timer callback is executed.
         */
        ao2_ref(req_wrapper, +1);
        ret_val = pj_timer_heap_schedule(pjsip_endpt_get_timer_heap(endpt),
            req_wrapper->timeout_timer, &timeout_timer_val);
        if (ret_val != PJ_SUCCESS) {
            ast_log(LOG_ERROR,
                "Failed to set timer.  Not sending %.*s request to endpoint %s.\n",
                (int) pj_strlen(&tdata->msg->line.req.method.name),
                pj_strbuf(&tdata->msg->line.req.method.name),
                endpoint ? ast_sorcery_object_get_id(endpoint) : "<unknown>");
            ao2_t_ref(req_wrapper, -2, "Drop timer and routine ref");
            pjsip_tx_data_dec_ref(tdata);
            return ret_val;
        }
    }
 
    /* We need to insure that the wrapper and tdata are available when the
     * transaction callback is executed.
     */
    ao2_ref(req_wrapper, +1);
    ret_val = pjsip_endpt_send_request(endpt, tdata, -1, req_wrapper, endpt_send_request_cb);
    if (ret_val != PJ_SUCCESS) {
        char errmsg[PJ_ERR_MSG_SIZE];
 
        if (!req_wrapper->send_cb_called) {
            /* endpt_send_request_cb is not expected to ever be called now. */
            ao2_ref(req_wrapper, -1);
        }
 
        /* Complain of failure to send the request. */
        pj_strerror(ret_val, errmsg, sizeof(errmsg));
        ast_log(LOG_ERROR, "Error %d '%s' sending %.*s request to endpoint %s\n",
            (int) ret_val, errmsg, (int) pj_strlen(&tdata->msg->line.req.method.name),
            pj_strbuf(&tdata->msg->line.req.method.name),
            endpoint ? ast_sorcery_object_get_id(endpoint) : "<unknown>");
 
        if (timeout > 0) {
            int timers_cancelled;
 
            ao2_lock(req_wrapper);
            timers_cancelled = pj_timer_heap_cancel_if_active(
                pjsip_endpt_get_timer_heap(endpt),
                req_wrapper->timeout_timer, TIMER_INACTIVE);
            if (timers_cancelled > 0) {
                ao2_ref(req_wrapper, -1);
            }
 
            /* Was the callback called? */
            if (req_wrapper->cb_called) {
                /*
                 * Yes so we cannot report any error.  The callback
                 * has already freed any resources associated with
                 * token.
                 */
                ret_val = PJ_SUCCESS;
            } else {
                /*
                 * No so we claim it is called so our caller can free
                 * any resources associated with token because of
                 * failure.
                 */
                req_wrapper->cb_called = 1;
            }
            ao2_unlock(req_wrapper);
        } else if (req_wrapper->cb_called) {
            /*
             * We cannot report any error.  The callback has
             * already freed any resources associated with
             * token.
             */
            ret_val = PJ_SUCCESS;
        }
    }
 
    ao2_ref(req_wrapper, -1);
    return ret_val;
}

References ao2_alloc, ao2_lock, ao2_ref, ao2_t_ref, ao2_unlock, ast_debug, ast_log, ast_sip_get_pjsip_endpoint(), ast_sorcery_object_get_id(), send_request_wrapper::callback, send_request_wrapper::cb_called, endpt_send_request_cb(), LOG_ERROR, NULL, send_request_wrapper::send_cb_called, send_request_timer_callback(), send_request_wrapper_destructor(), send_request_wrapper::tdata, send_request_wrapper::timeout, send_request_wrapper::timeout_timer, TIMEOUT_TIMER2, TIMER_INACTIVE, and send_request_wrapper::token.

Referenced by ast_sip_send_out_of_dialog_request(), and check_request_status().

endpt_send_request_cb()

static void endpt_send_request_cb ( void *  token, pjsip_event *  e  )

static

Definition at line 1573 of file res_pjsip.c.

{
    struct send_request_wrapper *req_wrapper = token;
    unsigned int cb_called;
 
    /*
     * Needed because we cannot otherwise tell if this callback was
     * called when pjsip_endpt_send_request() returns error.
     */
    req_wrapper->send_cb_called = 1;
 
    if (e->body.tsx_state.type == PJSIP_EVENT_TIMER) {
        ast_debug(2, "%p: PJSIP tsx timer expired\n", req_wrapper);
 
        if (req_wrapper->timeout_timer
            && req_wrapper->timeout_timer->id != TIMEOUT_TIMER2) {
            ast_debug(3, "%p: Timeout already handled\n", req_wrapper);
            ao2_ref(req_wrapper, -1);
            return;
        }
    } else {
        ast_debug(2, "%p: PJSIP tsx response received\n", req_wrapper);
    }
 
    ao2_lock(req_wrapper);
 
    /* It's possible that our own timer was already processing while
     * we were waiting on the lock so check the timer id.  If it's
     * still TIMER2 then we still need to process.
     */
    if (req_wrapper->timeout_timer
        && req_wrapper->timeout_timer->id == TIMEOUT_TIMER2) {
        int timers_cancelled = 0;
 
        ast_debug(3, "%p: Cancelling timer\n", req_wrapper);
 
        timers_cancelled = pj_timer_heap_cancel_if_active(
            pjsip_endpt_get_timer_heap(ast_sip_get_pjsip_endpoint()),
            req_wrapper->timeout_timer, TIMER_INACTIVE);
        if (timers_cancelled > 0) {
            /* If the timer was cancelled the callback will never run so
             * clean up its reference to the wrapper.
             */
            ast_debug(3, "%p: Timer cancelled\n", req_wrapper);
            ao2_ref(req_wrapper, -1);
        } else {
            /*
             * If it wasn't cancelled, it MAY be in the callback already
             * waiting on the lock.  When we release the lock, it will
             * now know not to proceed.
             */
            ast_debug(3, "%p: Timer already expired\n", req_wrapper);
        }
    }
 
    cb_called = req_wrapper->cb_called;
    req_wrapper->cb_called = 1;
    ao2_unlock(req_wrapper);
 
    /* It's possible that our own timer expired and called the callbacks
     * so no need to call them again.
     */
    if (!cb_called && req_wrapper->callback) {
        req_wrapper->callback(req_wrapper->token, e);
        ast_debug(2, "%p: Callbacks executed\n", req_wrapper);
    }
 
    ao2_ref(req_wrapper, -1);
}

References ao2_lock, ao2_ref, ao2_unlock, ast_debug, ast_sip_get_pjsip_endpoint(), send_request_wrapper::callback, send_request_wrapper::cb_called, send_request_wrapper::send_cb_called, send_request_wrapper::timeout_timer, TIMEOUT_TIMER2, TIMER_INACTIVE, and send_request_wrapper::token.

Referenced by endpt_send_request().

find_transport_state_in_use()

static int find_transport_state_in_use ( void *  obj, void *  arg, int  flags  )

static

Callback function for finding the transport the request is going out on.

Definition at line 576 of file res_pjsip.c.

{
    struct ast_sip_transport_state *transport_state = obj;
    struct ast_sip_request_transport_details *details = arg;
 
    /* If an explicit transport or factory matches then this is what is in use, if we are unavailable
     * to compare based on that we make sure that the type is the same and the source IP address/port are the same
     */
    if (transport_state && ((details->transport && details->transport == transport_state->transport) ||
        (details->factory && details->factory == transport_state->factory) ||
        ((details->type == transport_state->type) && (transport_state->factory) &&
            !pj_strcmp(&transport_state->factory->addr_name.host, &details->local_address) &&
            transport_state->factory->addr_name.port == details->local_port))) {
        return CMP_MATCH | CMP_STOP;
    }
 
    return 0;
}

References CMP_MATCH, CMP_STOP, ast_sip_transport_state::factory, ast_sip_request_transport_details::factory, ast_sip_request_transport_details::local_address, ast_sip_request_transport_details::local_port, ast_sip_transport_state::transport, ast_sip_request_transport_details::transport, ast_sip_transport_state::type, and ast_sip_request_transport_details::type.

Referenced by ast_sip_find_transport_state_in_use().

get_id_header()

static pjsip_fromto_hdr * get_id_header ( pjsip_rx_data *  rdata, const pj_str_t *  header_name  )

static

Definition at line 2673 of file res_pjsip.c.

{
    static const pj_str_t from = { "From", 4 };
    pj_str_t header_content;
    pjsip_fromto_hdr *parsed_hdr;
    pjsip_generic_string_hdr *ident = pjsip_msg_find_hdr_by_name(rdata->msg_info.msg,
            header_name, NULL);
    int parsed_len;
 
    if (!ident) {
        return NULL;
    }
 
    pj_strdup_with_null(rdata->tp_info.pool, &header_content, &ident->hvalue);
 
    parsed_hdr = pjsip_parse_hdr(rdata->tp_info.pool, &from, header_content.ptr,
            pj_strlen(&header_content), &parsed_len);
 
    if (!parsed_hdr) {
        return NULL;
    }
 
    return parsed_hdr;
}

References NULL.

Referenced by set_id_from_pai(), and set_id_from_rpid().

get_pjsip_method()

static const pjsip_method * get_pjsip_method ( const char *  method )

static

Definition at line 1296 of file res_pjsip.c.

{
    int i;
    for (i = 0; i < ARRAY_LEN(methods); ++i) {
        if (!strcmp(method, methods[i].method)) {
            return methods[i].pmethod;
        }
    }
    return NULL;
}

References ARRAY_LEN, method, methods, and NULL.

Referenced by ast_sip_create_request().

handle_atsign()

static struct ast_sip_endpoint * handle_atsign ( const char *  to, char *  destination, char **  uri, char *  slash, char *  atsign, char *  scheme, int  get_default_outbound  )

static

Definition at line 3191 of file res_pjsip.c.

{
    char *endpoint_name = NULL;
    struct ast_sip_endpoint *endpoint = NULL;
    struct ast_sip_contact *contact = NULL;
    char *afterat = atsign + 1;
 
    *atsign = '\0';
    endpoint_name = destination;
 
    /* Apparently there may be ';<user_options>' after the endpoint name ??? */
    AST_SIP_USER_OPTIONS_TRUNCATE_CHECK(endpoint_name);
    endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", endpoint_name);
    if (!endpoint) {
        /*
         * It's probably a uri with a user but without a scheme but we don't have a way to tell.
         * We're going to assume it is and prepend it with a scheme.
         */
        *uri = ast_malloc(strlen(to) + strlen("sip:") + 1);
        if (!(*uri)) {
            goto failure;
        }
        sprintf(*uri, "sip:%s", to);
        if (get_default_outbound) {
            endpoint = ast_sip_default_outbound_endpoint();
        }
        ast_debug(3, "Dest: '%s' Didn't find endpoint before the '@' so using URI '%s'%s\n",
            to, *uri, get_default_outbound ? " with default endpoint" : "");
        return endpoint;
    }
 
    /*
     * OK, it's an endpoint and a domain (which we ignore)
     */
    contact = ast_sip_location_retrieve_contact_from_aor_list(endpoint->aors);
    if (!contact) {
        ast_log(LOG_WARNING, "Dest: '%s'. Found endpoint '%s' but didn't find contact\n",
            to, endpoint_name);
        goto failure;
    }
 
    *uri = ast_strdup(contact->uri);
    ao2_cleanup(contact);
    if (!(*uri)) {
        goto failure;
    }
    ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s' (discarding domain %s)\n",
        to, endpoint_name, *uri, afterat);
 
    return endpoint;
 
failure:
    ao2_cleanup(endpoint);
    *uri = NULL;
    return NULL;
}

References ao2_cleanup, ast_sip_endpoint::aors, ast_debug, ast_log, ast_malloc, ast_sip_default_outbound_endpoint(), ast_sip_get_sorcery(), ast_sip_location_retrieve_contact_from_aor_list(), AST_SIP_USER_OPTIONS_TRUNCATE_CHECK, ast_sorcery_retrieve_by_id(), ast_strdup, ast_sip_contact::endpoint, ast_sip_contact::endpoint_name, LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by ast_sip_get_endpoint().

handle_single_token()

static struct ast_sip_endpoint * handle_single_token ( const char *  to, char *  destination, int  get_default_outbound, char **  uri  )

static

Definition at line 2955 of file res_pjsip.c.

                                                                                                                             {
    RAII_VAR(struct ast_sip_contact*, contact, NULL, ao2_cleanup);
    char *endpoint_name = NULL;
    struct ast_sip_endpoint *endpoint = NULL;
 
    /*
     * If "destination" is just one token, it could be an endpoint name
     * or a hostname without a scheme.
     */
 
    endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", destination);
    if (!endpoint) {
        /*
         * We can only assume it's a hostname.
         */
        char *temp_uri = ast_malloc(strlen(destination) + strlen("sip:") + 1);
        if (!temp_uri) {
            goto failure;
        }
        sprintf(temp_uri, "sip:%s", destination);
        *uri = temp_uri;
        if (get_default_outbound) {
            endpoint = ast_sip_default_outbound_endpoint();
        }
        ast_debug(3, "Dest: '%s' Didn't find endpoint so adding scheme and using URI '%s'%s\n",
            to, *uri, get_default_outbound ? " with default endpoint" : "");
        return endpoint;
    }
 
    /*
     * It's an endpoint
     */
 
    endpoint_name = destination;
    contact = ast_sip_location_retrieve_contact_from_aor_list(endpoint->aors);
    if (!contact) {
        ast_log(LOG_WARNING, "Dest: '%s'. Found endpoint '%s' but didn't find an aor/contact for it\n",
            to, endpoint_name);
        ao2_cleanup(endpoint);
        goto failure;
    }
 
    *uri = ast_strdup(contact->uri);
    if (!(*uri)) {
        ao2_cleanup(endpoint);
        goto failure;
    }
 
    ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s'\n",
        to, endpoint_name, *uri);
    return endpoint;
 
failure:
    *uri = NULL;
    return NULL;
}

References ao2_cleanup, ast_sip_endpoint::aors, ast_debug, ast_log, ast_malloc, ast_sip_default_outbound_endpoint(), ast_sip_get_sorcery(), ast_sip_location_retrieve_contact_from_aor_list(), ast_sorcery_retrieve_by_id(), ast_strdup, LOG_WARNING, NULL, and RAII_VAR.

Referenced by ast_sip_get_endpoint().

handle_slash()

static struct ast_sip_endpoint * handle_slash ( const char *  to, char *  destination, char **  uri, char *  slash, char *  atsign, char *  scheme  )

static

Definition at line 3034 of file res_pjsip.c.

{
    char *endpoint_name = NULL;
    struct ast_sip_endpoint *endpoint = NULL;
    struct ast_sip_contact *contact = NULL;
    char *user = NULL;
    char *afterslash = slash + 1;
    struct ast_sip_aor *aor;
 
    if (ast_begins_with(destination, "PJSIP/")) {
        ast_debug(3, "Dest: '%s' Dialplan format'\n", to);
        /*
         * This has to be the form PJSIP/user@endpoint
         */
        if (!atsign || strchr(afterslash, '/')) {
            /*
             * If there's no "user@" or there's a slash somewhere after
             * "PJSIP/" then we go no further.
             */
            ast_log(LOG_WARNING,
                "Dest: '%s'. Destinations beginning with 'PJSIP/' must be in the form of 'PJSIP/user@endpoint'\n",
                to);
            goto failure;
        }
        *atsign = '\0';
        user = afterslash;
        endpoint_name = atsign + 1;
        ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'\n", to, user, endpoint_name);
    } else {
        /*
         * Either...
         *  endpoint/aor
         *  endpoint/uri
         */
        *slash = '\0';
        endpoint_name = destination;
        ast_debug(3, "Dest: '%s' Endpoint: '%s'\n", to, endpoint_name);
    }
 
    endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", endpoint_name);
    if (!endpoint) {
        ast_log(LOG_WARNING, "Dest: '%s'. Didn't find endpoint with name '%s'\n",
            to, endpoint_name);
        goto failure;
    }
 
    if (scheme) {
        /*
         * If we found a scheme, then everything after the slash MUST be a URI.
         * We don't need to do any further modification.
         */
        *uri = ast_strdup(afterslash);
        if (!(*uri)) {
            goto failure;
        }
        ast_debug(3, "Dest: '%s' Found endpoint '%s' and found URI '%s' after '/'\n",
            to, endpoint_name, *uri);
        return endpoint;
    }
 
    if (user) {
        /*
         * This has to be the form PJSIP/user@endpoint
         */
        int rc;
 
        /*
         * Set the return URI to be the endpoint's contact URI with the user
         * portion set to the user that was specified before the endpoint name.
         */
        rc = insert_user_in_contact_uri(to, endpoint_name, endpoint->aors, user, uri);
        if (rc != 0) {
            /*
             * insert_user_in_contact_uri prints the warning message.
             */
            goto failure;
        }
        ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'  URI: '%s'\n", to, user,
            endpoint_name, *uri);
 
        return endpoint;
    }
 
    /*
     * We're now left with two possibilities...
     *  endpoint/aor
     *  endpoint/uri-without-scheme
     */
    aor = ast_sip_location_retrieve_aor(afterslash);
    if (!aor) {
        /*
         * It's probably a URI without a scheme but we don't have a way to tell
         * for sure.  We're going to assume it is and prepend it with a scheme.
         */
        *uri = ast_malloc(strlen(afterslash) + strlen("sip:") + 1);
        if (!(*uri)) {
            goto failure;
        }
        sprintf(*uri, "sip:%s", afterslash);
        ast_debug(3, "Dest: '%s' Found endpoint '%s' but didn't find aor after '/' so using URI '%s'\n",
            to, endpoint_name, *uri);
        return endpoint;
    }
 
    /*
     * Only one possibility left... There was an aor name after the slash.
     */
    ast_debug(3, "Dest: '%s' Found endpoint '%s' and found aor '%s' after '/'\n",
        to, endpoint_name, ast_sorcery_object_get_id(aor));
 
    contact = ast_sip_location_retrieve_first_aor_contact(aor);
    if (!contact) {
        ast_log(LOG_WARNING, "Dest: '%s'. Found endpoint '%s' but didn't find contact for aor '%s'\n",
            to, endpoint_name, ast_sorcery_object_get_id(aor));
        ao2_cleanup(aor);
        goto failure;
    }
 
    *uri = ast_strdup(contact->uri);
    ao2_cleanup(contact);
    ao2_cleanup(aor);
    if (!(*uri)) {
        goto failure;
    }
 
    ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s' for aor '%s'\n",
        to, endpoint_name, *uri, ast_sorcery_object_get_id(aor));
 
    return endpoint;
 
failure:
    ao2_cleanup(endpoint);
    *uri = NULL;
    return NULL;
}

References ao2_cleanup, ast_sip_endpoint::aors, ast_begins_with(), ast_debug, ast_log, ast_malloc, ast_sip_get_sorcery(), ast_sip_location_retrieve_aor(), ast_sip_location_retrieve_first_aor_contact(), ast_sorcery_object_get_id(), ast_sorcery_retrieve_by_id(), ast_strdup, insert_user_in_contact_uri(), LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by ast_sip_get_endpoint().

insert_user_in_contact_uri()

static int insert_user_in_contact_uri ( const char *  to, const char *  endpoint_name, const char *  aors, const char *  user, char **  uri  )

static

Find a contact and insert a "user@" into its URI.

Parameters

to	Original destination (for error messages only)
endpoint_name	Endpoint name (for error messages only)
aors	Command separated list of AORs
user	The user to insert in the contact URI
uri	Pointer to buffer in which to return the URI. Must be freed by caller.

Returns

0 Success

-1 Fail

Note

If the contact URI found for the endpoint already has a user in its URI, it will be replaced by the user passed as an argument to this function.

Definition at line 2890 of file res_pjsip.c.

{
    RAII_VAR(struct ast_sip_contact *, contact, NULL, ao2_cleanup);
    pj_pool_t *pool;
    pjsip_name_addr *name_addr;
    pjsip_sip_uri *sip_uri;
    int err = 0;
 
    contact = ast_sip_location_retrieve_contact_from_aor_list(aors);
    if (!contact) {
        ast_log(LOG_WARNING, "Dest: '%s'. Couldn't find contact for endpoint '%s'\n",
            to, endpoint_name);
        return -1;
    }
 
    pool = pjsip_endpt_create_pool(ast_sip_get_pjsip_endpoint(), "uri-user-insert", 128, 128);
    if (!pool) {
        ast_log(LOG_WARNING, "Failed to allocate ParseUri endpoint pool.\n");
        return -1;
    }
 
    name_addr = (pjsip_name_addr *) pjsip_parse_uri(pool, (char*)contact->uri, strlen(contact->uri), PJSIP_PARSE_URI_AS_NAMEADDR);
    if (!name_addr || (!PJSIP_URI_SCHEME_IS_SIP(name_addr->uri) && !PJSIP_URI_SCHEME_IS_SIPS(name_addr->uri))) {
        ast_log(LOG_WARNING, "Failed to parse URI '%s'\n", contact->uri);
        err = -1;
        goto out;
    }
 
    ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'  ContactURI: '%s'\n", to, user, endpoint_name, contact->uri);
 
    sip_uri = pjsip_uri_get_uri(name_addr->uri);
    pj_strset2(&sip_uri->user, (char*)user);
 
    *uri = ast_malloc(PJSIP_MAX_URL_SIZE);
    if (!(*uri)) {
        err = -1;
        goto out;
    }
    pjsip_uri_print(PJSIP_URI_IN_REQ_URI, name_addr, *uri, PJSIP_MAX_URL_SIZE);
 
out:
    pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
 
    return err;
}

References ao2_cleanup, ast_debug, ast_log, ast_malloc, ast_sip_get_pjsip_endpoint(), ast_sip_location_retrieve_contact_from_aor_list(), ast_sip_contact::endpoint_name, LOG_WARNING, NULL, out, RAII_VAR, and ast_sip_contact::uri.

Referenced by handle_slash().

load_module()

static int load_module ( void  )

static

Definition at line 3922 of file res_pjsip.c.

{
    struct ast_threadpool_options options;
 
    /* pjproject and config_system need to be initialized before all else */
    if (pj_init() != PJ_SUCCESS) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (pjlib_util_init() != PJ_SUCCESS) {
        goto error;
    }
 
    /* Register PJMEDIA error codes for SDP parsing errors */
    if (pj_register_strerror(PJMEDIA_ERRNO_START, PJ_ERRNO_SPACE_SIZE, pjmedia_strerror)
        != PJ_SUCCESS) {
        ast_log(LOG_WARNING, "Failed to register pjmedia error codes.  Codes will not be decoded.\n");
    }
 
    /* Initialize common media types */
    pjsip_media_type_init2(&pjsip_media_type_application_json, "application", "json");
    pjsip_media_type_init2(&pjsip_media_type_application_media_control_xml, "application", "media_control+xml");
    pjsip_media_type_init2(&pjsip_media_type_application_pidf_xml, "application", "pidf+xml");
    pjsip_media_type_init2(&pjsip_media_type_application_xpidf_xml, "application", "xpidf+xml");
    pjsip_media_type_init2(&pjsip_media_type_application_cpim_xpidf_xml, "application", "cpim-xpidf+xml");
    pjsip_media_type_init2(&pjsip_media_type_application_rlmi_xml, "application", "rlmi+xml");
    pjsip_media_type_init2(&pjsip_media_type_application_sdp, "application", "sdp");
    pjsip_media_type_init2(&pjsip_media_type_application_simple_message_summary, "application", "simple-message-summary");
    pjsip_media_type_init2(&pjsip_media_type_multipart_alternative, "multipart", "alternative");
    pjsip_media_type_init2(&pjsip_media_type_multipart_mixed, "multipart", "mixed");
    pjsip_media_type_init2(&pjsip_media_type_multipart_related, "multipart", "related");
    pjsip_media_type_init2(&pjsip_media_type_text_plain, "text", "plain");
 
 
    if (ast_sip_initialize_system()) {
        ast_log(LOG_ERROR, "Failed to initialize SIP 'system' configuration section. Aborting load\n");
        goto error;
    }
 
    /* The serializer needs threadpool and threadpool needs pjproject to be initialized so it's next */
    sip_get_threadpool_options(&options);
    options.thread_start = sip_thread_start;
    sip_threadpool = ast_threadpool_create("pjsip", NULL, &options);
    if (!sip_threadpool) {
        goto error;
    }
 
    sip_serializer_pool = ast_serializer_pool_create(
        "pjsip/default", SERIALIZER_POOL_SIZE, sip_threadpool, -1);
    if (!sip_serializer_pool) {
        ast_log(LOG_ERROR, "Failed to create SIP serializer pool. Aborting load\n");
        goto error;
    }
 
    if (ast_sip_initialize_scheduler()) {
        ast_log(LOG_ERROR, "Failed to start scheduler. Aborting load\n");
        goto error;
    }
 
    /* Now load all the pjproject infrastructure. */
    if (load_pjsip()) {
        goto error;
    }
 
    if (ast_sip_initialize_transport_events()) {
        ast_log(LOG_ERROR, "Failed to initialize SIP transport monitor. Aborting load\n");
        goto error;
    }
 
    ast_sip_initialize_dns();
    ast_sip_initialize_global_headers();
 
    if (ast_res_pjsip_preinit_options_handling()) {
        ast_log(LOG_ERROR, "Failed to pre-initialize OPTIONS handling. Aborting load\n");
        goto error;
    }
 
    if (ast_res_pjsip_initialize_configuration()) {
        ast_log(LOG_ERROR, "Failed to initialize SIP configuration. Aborting load\n");
        goto error;
    }
 
    ast_sip_initialize_resolver();
    ast_sip_initialize_dns();
 
    if (ast_sip_initialize_transport_management()) {
        ast_log(LOG_ERROR, "Failed to initialize SIP transport management. Aborting load\n");
        goto error;
    }
 
    if (ast_sip_initialize_distributor()) {
        ast_log(LOG_ERROR, "Failed to register distributor module. Aborting load\n");
        goto error;
    }
 
    if (ast_sip_register_service(&supplement_module)) {
        ast_log(LOG_ERROR, "Failed to initialize supplement hooks. Aborting load\n");
        goto error;
    }
 
    if (ast_res_pjsip_init_options_handling(0)) {
        ast_log(LOG_ERROR, "Failed to initialize OPTIONS handling. Aborting load\n");
        goto error;
    }
 
    /*
     * It is OK to prune the contacts now that
     * ast_res_pjsip_init_options_handling() has added the contact observer
     * of res/res_pjsip/pjsip_options.c to sorcery (to ensure that any
     * pruned contacts are removed from this module's data structure).
     */
    ast_sip_location_prune_boot_contacts();
 
    if (ast_res_pjsip_init_message_filter()) {
        ast_log(LOG_ERROR, "Failed to initialize message IP updating. Aborting load\n");
        goto error;
    }
 
    ast_cli_register_multiple(cli_commands, ARRAY_LEN(cli_commands));
 
    AST_TEST_REGISTER(xml_sanitization_end_null);
    AST_TEST_REGISTER(xml_sanitization_exceeds_buffer);
 
    return AST_MODULE_LOAD_SUCCESS;
 
error:
    unload_pjsip(NULL);
 
    /* These functions all check for NULLs and are safe to call at any time */
    ast_sip_destroy_scheduler();
    ast_serializer_pool_destroy(sip_serializer_pool);
    ast_threadpool_shutdown(sip_threadpool);
 
    return AST_MODULE_LOAD_DECLINE;
}

References ARRAY_LEN, ast_cli_register_multiple, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_res_pjsip_init_message_filter(), ast_res_pjsip_init_options_handling(), ast_res_pjsip_initialize_configuration(), ast_res_pjsip_preinit_options_handling(), ast_serializer_pool_create(), ast_serializer_pool_destroy(), ast_sip_destroy_scheduler(), ast_sip_initialize_distributor(), ast_sip_initialize_dns(), ast_sip_initialize_global_headers(), ast_sip_initialize_resolver(), ast_sip_initialize_scheduler(), ast_sip_initialize_system(), ast_sip_initialize_transport_events(), ast_sip_initialize_transport_management(), ast_sip_location_prune_boot_contacts(), ast_sip_register_service(), AST_TEST_REGISTER, ast_threadpool_create(), ast_threadpool_shutdown(), cli_commands, error(), load_pjsip(), LOG_ERROR, LOG_WARNING, NULL, options, pjsip_media_type_application_cpim_xpidf_xml, pjsip_media_type_application_json, pjsip_media_type_application_media_control_xml, pjsip_media_type_application_pidf_xml, pjsip_media_type_application_rlmi_xml, pjsip_media_type_application_sdp, pjsip_media_type_application_simple_message_summary, pjsip_media_type_application_xpidf_xml, pjsip_media_type_multipart_alternative, pjsip_media_type_multipart_mixed, pjsip_media_type_multipart_related, pjsip_media_type_text_plain, SERIALIZER_POOL_SIZE, sip_get_threadpool_options(), sip_serializer_pool, sip_thread_start(), sip_threadpool, supplement_module, and unload_pjsip().

load_pjsip()

static int load_pjsip ( void  )

static

Definition at line 3842 of file res_pjsip.c.

{
    const unsigned int flags = 0; /* no port, no brackets */
    pj_status_t status;
 
    /* The third parameter is just copied from
     * example code from PJLIB. This can be adjusted
     * if necessary.
     */
    ast_pjproject_caching_pool_init(&caching_pool, NULL, 1024 * 1024);
    if (pjsip_endpt_create(&caching_pool.factory, "SIP", &ast_pjsip_endpoint) != PJ_SUCCESS) {
        ast_log(LOG_ERROR, "Failed to create PJSIP endpoint structure. Aborting load\n");
        goto error;
    }
 
    /* PJSIP will automatically try to add a Max-Forwards header. Since we want to control that,
     * we need to stop PJSIP from doing it automatically
     */
    remove_request_headers(ast_pjsip_endpoint);
 
    memory_pool = pj_pool_create(&caching_pool.factory, "SIP", 1024, 1024, NULL);
    if (!memory_pool) {
        ast_log(LOG_ERROR, "Failed to create memory pool for SIP. Aborting load\n");
        goto error;
    }
 
    if (!pj_gethostip(pj_AF_INET(), &host_ip_ipv4)) {
        pj_sockaddr_print(&host_ip_ipv4, host_ip_ipv4_string, sizeof(host_ip_ipv4_string), flags);
        ast_verb(3, "Local IPv4 address determined to be: %s\n", host_ip_ipv4_string);
    }
 
    if (!pj_gethostip(pj_AF_INET6(), &host_ip_ipv6)) {
        pj_sockaddr_print(&host_ip_ipv6, host_ip_ipv6_string, sizeof(host_ip_ipv6_string), flags);
        ast_verb(3, "Local IPv6 address determined to be: %s\n", host_ip_ipv6_string);
    }
 
    pjsip_tsx_layer_init_module(ast_pjsip_endpoint);
    pjsip_ua_init_module(ast_pjsip_endpoint, NULL);
 
    monitor_continue = 1;
    status = pj_thread_create(memory_pool, "SIP", (pj_thread_proc *) &monitor_thread_exec,
            NULL, PJ_THREAD_DEFAULT_STACK_SIZE * 2, 0, &monitor_thread);
    if (status != PJ_SUCCESS) {
        ast_log(LOG_ERROR, "Failed to start SIP monitor thread. Aborting load\n");
        goto error;
    }
 
    return AST_MODULE_LOAD_SUCCESS;
 
error:
    return AST_MODULE_LOAD_DECLINE;
}

References ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_pjproject_caching_pool_init(), ast_pjsip_endpoint, ast_verb, caching_pool, error(), host_ip_ipv4, host_ip_ipv4_string, host_ip_ipv6, host_ip_ipv6_string, LOG_ERROR, memory_pool, monitor_continue, monitor_thread, monitor_thread_exec(), NULL, remove_request_headers(), and status.

Referenced by load_module().

monitor_thread_exec()

static void * monitor_thread_exec ( void *  endpt )

static

Definition at line 2266 of file res_pjsip.c.

{
    while (monitor_continue) {
        const pj_time_val delay = {0, 10};
        pjsip_endpt_handle_events(ast_pjsip_endpoint, &delay);
    }
    return NULL;
}

References ast_pjsip_endpoint, monitor_continue, and NULL.

Referenced by load_pjsip().

never_called_res_pjsip()

void never_called_res_pjsip

(

void

)

Definition at line 3903 of file res_pjsip.c.

{
    pjmedia_strerror(0, NULL, 0);
}

References NULL.

pool_destroy_callback()

static void pool_destroy_callback ( void *  arg )

static

Definition at line 2409 of file res_pjsip.c.

{
    pj_pool_t *pool = (pj_pool_t *)arg;
    pjsip_endpt_release_pool(ast_sip_get_pjsip_endpoint(), pool);
}

References ast_sip_get_pjsip_endpoint().

Referenced by ast_sip_send_stateful_response().

register_service()

static int register_service ( void *  data )

static

Definition at line 102 of file res_pjsip.c.

{
    pjsip_module **module = data;
    if (!ast_pjsip_endpoint) {
        ast_log(LOG_ERROR, "There is no PJSIP endpoint. Unable to register services\n");
        return -1;
    }
    if (pjsip_endpt_register_module(ast_pjsip_endpoint, *module) != PJ_SUCCESS) {
        ast_log(LOG_ERROR, "Unable to register module %.*s\n", (int) pj_strlen(&(*module)->name), pj_strbuf(&(*module)->name));
        return -1;
    }
    ast_debug(1, "Registered SIP service %.*s (%p)\n", (int) pj_strlen(&(*module)->name), pj_strbuf(&(*module)->name), *module);
    return 0;
}

References ast_debug, ast_log, ast_pjsip_endpoint, and LOG_ERROR.

Referenced by ast_sip_register_service().

reload_configuration_task()

static int reload_configuration_task ( void *  obj )

static

Definition at line 3790 of file res_pjsip.c.

{
    ast_res_pjsip_reload_configuration();
    ast_res_pjsip_init_options_handling(1);
    ast_sip_initialize_dns();
    return 0;
}

References ast_res_pjsip_init_options_handling(), ast_res_pjsip_reload_configuration(), and ast_sip_initialize_dns().

Referenced by reload_module().

reload_module()

static int reload_module ( void  )

static

Definition at line 4058 of file res_pjsip.c.

{
    /*
     * We must wait for the reload to complete so multiple
     * reloads cannot happen at the same time.
     */
    if (ast_sip_push_task_wait_servant(NULL, reload_configuration_task, NULL)) {
        ast_log(LOG_WARNING, "Failed to reload PJSIP\n");
        return -1;
    }
 
    return 0;
}

References ast_log, ast_sip_push_task_wait_servant(), LOG_WARNING, NULL, and reload_configuration_task().

remove_request_headers()

static void remove_request_headers ( pjsip_endpoint *  endpt )

static

Definition at line 3445 of file res_pjsip.c.

{
    const pjsip_hdr *request_headers = pjsip_endpt_get_request_headers(endpt);
    pjsip_hdr *iter = request_headers->next;
 
    while (iter != request_headers) {
        pjsip_hdr *to_erase = iter;
        iter = iter->next;
        pj_list_erase(to_erase);
    }
}

References request_headers.

Referenced by load_pjsip().

send_in_dialog_request()

static int send_in_dialog_request ( pjsip_tx_data *  tdata, struct pjsip_dialog *  dlg  )

static

Definition at line 1490 of file res_pjsip.c.

{
    if (pjsip_dlg_send_request(dlg, tdata, -1, NULL) != PJ_SUCCESS) {
        ast_log(LOG_WARNING, "Unable to send in-dialog request.\n");
        return -1;
    }
    return 0;
}

References ast_log, LOG_WARNING, and NULL.

Referenced by ast_sip_send_request().

send_request_cb()

static void send_request_cb ( void *  token, pjsip_event *  e  )

static

Definition at line 1882 of file res_pjsip.c.

{
    struct send_request_data *req_data = token;
    pjsip_rx_data *challenge;
    struct ast_sip_supplement *supplement;
 
    if (e->type == PJSIP_EVENT_TSX_STATE) {
        switch(e->body.tsx_state.type) {
        case PJSIP_EVENT_TRANSPORT_ERROR:
        case PJSIP_EVENT_TIMER:
            /*
             * Check the request status on transport error or timeout. A transport
             * error can occur when a TCP socket closes and that can be the result
             * of a 503. Also we may need to failover on a timeout (408).
             */
            if (check_request_status(req_data, e)) {
                return;
            }
            break;
        case PJSIP_EVENT_RX_MSG:
            challenge = e->body.tsx_state.src.rdata;
 
            /*
             * Call any supplements that want to know about a response
             * with any received data.
             */
            AST_RWLIST_RDLOCK(&supplements);
            AST_LIST_TRAVERSE(&supplements, supplement, next) {
                if (supplement->incoming_response
                    && does_method_match(&challenge->msg_info.cseq->method.name,
                        supplement->method)) {
                    supplement->incoming_response(req_data->endpoint, challenge);
                }
            }
            AST_RWLIST_UNLOCK(&supplements);
 
            if (check_request_status(req_data, e)) {
                /*
                 * Request with challenge response or failover sent.
                 * Passed our req_data ref to the new request.
                 */
                return;
            }
            break;
        default:
            ast_log(LOG_ERROR, "Unexpected PJSIP event %u\n", e->body.tsx_state.type);
            break;
        }
    }
 
    if (req_data->callback) {
        req_data->callback(req_data->token, e);
    }
    ao2_ref(req_data, -1);
}

References ao2_ref, AST_LIST_TRAVERSE, ast_log, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, send_request_data::callback, challenge(), check_request_status(), does_method_match(), send_request_data::endpoint, ast_sip_supplement::incoming_response, LOG_ERROR, ast_sip_supplement::method, ast_sip_supplement::next, and send_request_data::token.

Referenced by ast_sip_send_out_of_dialog_request(), and check_request_status().

send_request_data_alloc()

static struct send_request_data * send_request_data_alloc ( struct ast_sip_endpoint *  endpoint, void *  token, void(*)(void *token, pjsip_event *e)  callback  )

static

Definition at line 1534 of file res_pjsip.c.

{
    struct send_request_data *req_data;
 
    req_data = ao2_alloc_options(sizeof(*req_data), send_request_data_destroy,
        AO2_ALLOC_OPT_LOCK_NOLOCK);
    if (!req_data) {
        return NULL;
    }
 
    req_data->endpoint = ao2_bump(endpoint);
    req_data->token = token;
    req_data->callback = callback;
 
    return req_data;
}

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_alloc_options, ao2_bump, callback(), send_request_data::callback, send_request_data::endpoint, NULL, send_request_data_destroy(), and send_request_data::token.

Referenced by ast_sip_send_out_of_dialog_request().

send_request_data_destroy()

static void send_request_data_destroy ( void *  obj )

static

Definition at line 1527 of file res_pjsip.c.

{
    struct send_request_data *req_data = obj;
 
    ao2_cleanup(req_data->endpoint);
}

References ao2_cleanup, and send_request_data::endpoint.

Referenced by send_request_data_alloc().

send_request_timer_callback()

static void send_request_timer_callback ( pj_timer_heap_t *  theap, pj_timer_entry *  entry  )

static

Definition at line 1648 of file res_pjsip.c.

{
    struct send_request_wrapper *req_wrapper = entry->user_data;
    unsigned int cb_called;
 
    ast_debug(2, "%p: Internal tsx timer expired after %d msec\n",
        req_wrapper, req_wrapper->timeout);
 
    ao2_lock(req_wrapper);
    /*
     * If the id is not TIMEOUT_TIMER2 then the timer was cancelled
     * before we got the lock or it was already handled so just clean up.
     */
    if (entry->id != TIMEOUT_TIMER2) {
        ao2_unlock(req_wrapper);
        ast_debug(3, "%p: Timeout already handled\n", req_wrapper);
        ao2_ref(req_wrapper, -1);
        return;
    }
    entry->id = TIMER_INACTIVE;
 
    ast_debug(3, "%p: Timer handled here\n", req_wrapper);
 
    cb_called = req_wrapper->cb_called;
    req_wrapper->cb_called = 1;
    ao2_unlock(req_wrapper);
 
    if (!cb_called && req_wrapper->callback) {
        pjsip_event event;
 
        PJSIP_EVENT_INIT_TX_MSG(event, req_wrapper->tdata);
        event.body.tsx_state.type = PJSIP_EVENT_TIMER;
 
        req_wrapper->callback(req_wrapper->token, &event);
        ast_debug(2, "%p: Callbacks executed\n", req_wrapper);
    }
 
    ao2_ref(req_wrapper, -1);
}

References ao2_lock, ao2_ref, ao2_unlock, ast_debug, send_request_wrapper::callback, send_request_wrapper::cb_called, send_request_wrapper::tdata, send_request_wrapper::timeout, TIMEOUT_TIMER2, TIMER_INACTIVE, and send_request_wrapper::token.

Referenced by endpt_send_request().

send_request_wrapper_destructor()

static void send_request_wrapper_destructor ( void *  obj )

static

Definition at line 1688 of file res_pjsip.c.

{
    struct send_request_wrapper *req_wrapper = obj;
 
    pjsip_tx_data_dec_ref(req_wrapper->tdata);
    ast_debug(2, "%p: wrapper destroyed\n", req_wrapper);
}

References ast_debug, and send_request_wrapper::tdata.

Referenced by endpt_send_request().

set_id_from_from()

static int set_id_from_from ( struct pjsip_rx_data *  rdata, struct ast_party_id *  id  )

static

Definition at line 2803 of file res_pjsip.c.

{
    pjsip_fromto_hdr *from = pjsip_msg_find_hdr(rdata->msg_info.msg,
            PJSIP_H_FROM, rdata->msg_info.msg->hdr.next);
 
    if (!from) {
        /* This had better not happen */
        return -1;
    }
 
    set_id_from_hdr(from, id);
 
    if (!id->number.valid) {
        return -1;
    }
 
    return 0;
}

References id, and set_id_from_hdr().

Referenced by ast_sip_set_id_from_invite().

set_id_from_hdr()

static void set_id_from_hdr ( pjsip_fromto_hdr *  hdr, struct ast_party_id *  id  )

static

Definition at line 2606 of file res_pjsip.c.

{
    char cid_name[AST_CHANNEL_NAME];
    char cid_num[AST_CHANNEL_NAME];
    size_t cid_name_size = AST_CHANNEL_NAME;
    pjsip_name_addr *id_name_addr = (pjsip_name_addr *) hdr->uri;
    char *semi;
    enum ast_utf8_replace_result result;
 
    ast_copy_pj_str(cid_num, ast_sip_pjsip_uri_get_username(hdr->uri), sizeof(cid_num));
    /* Always truncate caller-id number at a semicolon. */
    semi = strchr(cid_num, ';');
    if (semi) {
        /*
         * We need to be able to handle URI's looking like
         * "sip:1235557890;phone-context=national@x.x.x.x;user=phone"
         *
         * Where the uri->user field will result in:
         * "1235557890;phone-context=national"
         *
         * People don't care about anything after the semicolon
         * showing up on their displays even though the RFC
         * allows the semicolon.
         */
        *semi = '\0';
    }
 
    /*
     * It's safe to pass a NULL or empty string as the source.
     * The result will be an empty string assuming the destination
     * size was at least 1.
     */
    result = ast_utf8_replace_invalid_chars(cid_name, &cid_name_size,
        id_name_addr->display.ptr, id_name_addr->display.slen);
 
    if (result != AST_UTF8_REPLACE_VALID) {
        ast_log(LOG_WARNING, "CallerID Name '" PJSTR_PRINTF_SPEC
            "' for number '%s' has invalid UTF-8 characters which "
            "were replaced",
            PJSTR_PRINTF_VAR(id_name_addr->display), cid_num);
    }
 
    ast_free(id->name.str);
    id->name.str = ast_strdup(cid_name);
    if (!ast_strlen_zero(cid_name)) {
        id->name.valid = 1;
    }
    ast_free(id->number.str);
    id->number.str = ast_strdup(cid_num);
    if (!ast_strlen_zero(cid_num)) {
        id->number.valid = 1;
    }
}

References AST_CHANNEL_NAME, ast_copy_pj_str(), ast_free, ast_log, ast_sip_pjsip_uri_get_username(), ast_strdup, ast_strlen_zero(), ast_utf8_replace_invalid_chars(), AST_UTF8_REPLACE_VALID, id, LOG_WARNING, PJSTR_PRINTF_SPEC, PJSTR_PRINTF_VAR, and result.

Referenced by set_id_from_from(), set_id_from_pai(), and set_id_from_rpid().

set_id_from_pai()

static int set_id_from_pai ( pjsip_rx_data *  rdata, struct ast_party_id *  id  )

static

Definition at line 2710 of file res_pjsip.c.

{
    static const pj_str_t pai_str = { "P-Asserted-Identity", 19 };
    static const pj_str_t privacy_str = { "Privacy", 7 };
    pjsip_fromto_hdr *pai_hdr = get_id_header(rdata, &pai_str);
    pjsip_generic_string_hdr *privacy;
 
    if (!pai_hdr) {
        return -1;
    }
 
    set_id_from_hdr(pai_hdr, id);
 
    if (!id->number.valid) {
        return -1;
    }
 
    privacy = pjsip_msg_find_hdr_by_name(rdata->msg_info.msg, &privacy_str, NULL);
    if (!privacy || !pj_stricmp2(&privacy->hvalue, "none")) {
        id->number.presentation = AST_PRES_ALLOWED_USER_NUMBER_NOT_SCREENED;
        id->name.presentation = AST_PRES_ALLOWED_USER_NUMBER_NOT_SCREENED;
    } else {
        id->number.presentation = AST_PRES_PROHIB_USER_NUMBER_NOT_SCREENED;
        id->name.presentation = AST_PRES_PROHIB_USER_NUMBER_NOT_SCREENED;
    }
 
    return 0;
}

References AST_PRES_ALLOWED_USER_NUMBER_NOT_SCREENED, AST_PRES_PROHIB_USER_NUMBER_NOT_SCREENED, get_id_header(), id, NULL, and set_id_from_hdr().

Referenced by ast_sip_set_id_connected_line(), and ast_sip_set_id_from_invite().

set_id_from_rpid()

static int set_id_from_rpid ( pjsip_rx_data *  rdata, struct ast_party_id *  id  )

static

Definition at line 2751 of file res_pjsip.c.

{
    static const pj_str_t rpid_str = { "Remote-Party-ID", 15 };
    static const pj_str_t privacy_str = { "privacy", 7 };
    static const pj_str_t screen_str = { "screen", 6 };
    pjsip_fromto_hdr *rpid_hdr = get_id_header(rdata, &rpid_str);
    pjsip_param *screen;
    pjsip_param *privacy;
 
    if (!rpid_hdr) {
        return -1;
    }
 
    set_id_from_hdr(rpid_hdr, id);
 
    if (!id->number.valid) {
        return -1;
    }
 
    privacy = pjsip_param_find(&rpid_hdr->other_param, &privacy_str);
    screen = pjsip_param_find(&rpid_hdr->other_param, &screen_str);
    if (privacy && !pj_stricmp2(&privacy->value, "full")) {
        id->number.presentation = AST_PRES_RESTRICTED;
        id->name.presentation = AST_PRES_RESTRICTED;
    } else {
        id->number.presentation = AST_PRES_ALLOWED;
        id->name.presentation = AST_PRES_ALLOWED;
    }
    if (screen && !pj_stricmp2(&screen->value, "yes")) {
        id->number.presentation |= AST_PRES_USER_NUMBER_PASSED_SCREEN;
        id->name.presentation |= AST_PRES_USER_NUMBER_PASSED_SCREEN;
    } else {
        id->number.presentation |= AST_PRES_USER_NUMBER_UNSCREENED;
        id->name.presentation |= AST_PRES_USER_NUMBER_UNSCREENED;
    }
 
    return 0;
}

References AST_PRES_ALLOWED, AST_PRES_RESTRICTED, AST_PRES_USER_NUMBER_PASSED_SCREEN, AST_PRES_USER_NUMBER_UNSCREENED, get_id_header(), id, and set_id_from_hdr().

Referenced by ast_sip_set_id_connected_line(), and ast_sip_set_id_from_invite().

sip_dialog_create_from()

static int sip_dialog_create_from ( pj_pool_t *  pool, pj_str_t *  from, const char *  user, const char *  domain, const pj_str_t *  target, pjsip_tpselector *  selector  )

static

Definition at line 749 of file res_pjsip.c.

{
    pj_str_t tmp, local_addr;
    pjsip_uri *uri;
    pjsip_sip_uri *sip_uri;
    pjsip_transport_type_e type;
    int local_port;
    char default_user[PJSIP_MAX_URL_SIZE];
 
    if (ast_strlen_zero(user)) {
        ast_sip_get_default_from_user(default_user, sizeof(default_user));
        user = default_user;
    }
 
    /* Parse the provided target URI so we can determine what transport it will end up using */
    pj_strdup_with_null(pool, &tmp, target);
 
    if (!(uri = pjsip_parse_uri(pool, tmp.ptr, tmp.slen, 0)) ||
        (!PJSIP_URI_SCHEME_IS_SIP(uri) && !PJSIP_URI_SCHEME_IS_SIPS(uri))) {
        return -1;
    }
 
    sip_uri = pjsip_uri_get_uri(uri);
 
    /* Determine the transport type to use */
    type = pjsip_transport_get_type_from_name(&sip_uri->transport_param);
    if (PJSIP_URI_SCHEME_IS_SIPS(sip_uri)) {
        if (type == PJSIP_TRANSPORT_UNSPECIFIED
            || !(pjsip_transport_get_flag_from_type(type) & PJSIP_TRANSPORT_SECURE)) {
            type = PJSIP_TRANSPORT_TLS;
        }
    } else if (!sip_uri->transport_param.slen) {
        type = PJSIP_TRANSPORT_UDP;
    } else if (type == PJSIP_TRANSPORT_UNSPECIFIED) {
        return -1;
    }
 
    /* If the host is IPv6 turn the transport into an IPv6 version */
    if (pj_strchr(&sip_uri->host, ':')) {
        type |= PJSIP_TRANSPORT_IPV6;
    }
 
    /* In multidomain scenario, username may contain @ with domain info */
    if (!ast_sip_get_disable_multi_domain() && strchr(user, '@')) {
        from->ptr = pj_pool_alloc(pool, PJSIP_MAX_URL_SIZE);
        from->slen = pj_ansi_snprintf(from->ptr, PJSIP_MAX_URL_SIZE,
                "<sip:%s%s%s>",
                user,
                (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? ";transport=" : "",
                (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? pjsip_transport_get_type_name(type) : "");
        return 0;
    }
 
    if (!ast_strlen_zero(domain)) {
        from->ptr = pj_pool_alloc(pool, PJSIP_MAX_URL_SIZE);
        from->slen = pj_ansi_snprintf(from->ptr, PJSIP_MAX_URL_SIZE,
                "<sip:%s@%s%s%s>",
                user,
                domain,
                (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? ";transport=" : "",
                (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? pjsip_transport_get_type_name(type) : "");
        return 0;
    }
 
    /* Get the local bound address for the transport that will be used when communicating with the provided URI */
    if (pjsip_tpmgr_find_local_addr(pjsip_endpt_get_tpmgr(ast_sip_get_pjsip_endpoint()), pool, type, selector,
                                  &local_addr, &local_port) != PJ_SUCCESS) {
 
        /* If no local address can be retrieved using the transport manager use the host one */
        pj_strdup(pool, &local_addr, pj_gethostname());
        local_port = pjsip_transport_get_default_port_for_type(PJSIP_TRANSPORT_UDP);
    }
 
    /* If IPv6 was specified in the transport, set the proper type */
    if (pj_strchr(&local_addr, ':')) {
        type |= PJSIP_TRANSPORT_IPV6;
    }
 
    from->ptr = pj_pool_alloc(pool, PJSIP_MAX_URL_SIZE);
    from->slen = pj_ansi_snprintf(from->ptr, PJSIP_MAX_URL_SIZE,
                      "<sip:%s@%s%.*s%s:%d%s%s>",
                      user,
                      (type & PJSIP_TRANSPORT_IPV6) ? "[" : "",
                      (int)local_addr.slen,
                      local_addr.ptr,
                      (type & PJSIP_TRANSPORT_IPV6) ? "]" : "",
                      local_port,
                      (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? ";transport=" : "",
                      (type != PJSIP_TRANSPORT_UDP && type != PJSIP_TRANSPORT_UDP6) ? pjsip_transport_get_type_name(type) : "");
 
    return 0;
}

References ast_sip_get_default_from_user(), ast_sip_get_disable_multi_domain(), ast_sip_get_pjsip_endpoint(), ast_strlen_zero(), and type.

Referenced by ast_sip_create_dialog_uac(), and create_out_of_dialog_request().

sip_thread_start()

static void sip_thread_start ( void  )

static

Definition at line 2285 of file res_pjsip.c.

{
    pj_thread_desc *desc;
    pj_thread_t *thread;
    uint32_t *servant_id;
 
    servant_id = ast_threadstorage_get(&servant_id_storage, sizeof(*servant_id));
    if (!servant_id) {
        ast_log(LOG_ERROR, "Could not set SIP servant ID in thread-local storage.\n");
        return;
    }
    *servant_id = SIP_SERVANT_ID;
 
    desc = ast_threadstorage_get(&pj_thread_storage, sizeof(pj_thread_desc));
    if (!desc) {
        ast_log(LOG_ERROR, "Could not get thread desc from thread-local storage. Expect awful things to occur\n");
        return;
    }
    pj_bzero(*desc, sizeof(*desc));
 
    if (pj_thread_register("Asterisk Thread", *desc, &thread) != PJ_SUCCESS) {
        ast_log(LOG_ERROR, "Couldn't register thread with PJLIB.\n");
    }
}

References ast_log, ast_threadstorage_get(), desc, LOG_ERROR, pj_thread_storage, servant_id_storage, SIP_SERVANT_ID, and thread.

Referenced by load_module().

stop_monitor_thread()

static void stop_monitor_thread ( void  )

static

Definition at line 2275 of file res_pjsip.c.

{
    monitor_continue = 0;
    pj_thread_join(monitor_thread);
}

References monitor_continue, and monitor_thread.

Referenced by unload_pjsip().

supplement_on_rx_request()

static pj_bool_t supplement_on_rx_request ( pjsip_rx_data *  rdata )

static

Definition at line 2350 of file res_pjsip.c.

{
    struct ast_sip_supplement *supplement;
 
    if (pjsip_rdata_get_dlg(rdata)) {
        return PJ_FALSE;
    }
 
    AST_RWLIST_RDLOCK(&supplements);
    AST_LIST_TRAVERSE(&supplements, supplement, next) {
        if (supplement->incoming_request
            && does_method_match(&rdata->msg_info.msg->line.req.method.name, supplement->method)) {
            struct ast_sip_endpoint *endpoint;
 
            endpoint = ast_pjsip_rdata_get_endpoint(rdata);
            supplement->incoming_request(endpoint, rdata);
            ao2_cleanup(endpoint);
        }
    }
    AST_RWLIST_UNLOCK(&supplements);
 
    return PJ_FALSE;
}

References ao2_cleanup, AST_LIST_TRAVERSE, ast_pjsip_rdata_get_endpoint(), AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, does_method_match(), ast_sip_supplement::incoming_request, ast_sip_supplement::method, and ast_sip_supplement::next.

supplement_outgoing_response()

static void supplement_outgoing_response ( pjsip_tx_data *  tdata, struct ast_sip_endpoint *  sip_endpoint  )

static

Definition at line 2374 of file res_pjsip.c.

{
    struct ast_sip_supplement *supplement;
    pjsip_cseq_hdr *cseq = pjsip_msg_find_hdr(tdata->msg, PJSIP_H_CSEQ, NULL);
    struct ast_sip_contact *contact = ast_sip_mod_data_get(tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT);
 
    if (sip_endpoint) {
        ast_sip_message_apply_transport(sip_endpoint->transport, tdata);
    }
 
    AST_RWLIST_RDLOCK(&supplements);
    AST_LIST_TRAVERSE(&supplements, supplement, next) {
        if (supplement->outgoing_response && does_method_match(&cseq->method.name, supplement->method)) {
            supplement->outgoing_response(sip_endpoint, contact, tdata);
        }
    }
    AST_RWLIST_UNLOCK(&supplements);
 
    ast_sip_mod_data_set(tdata->pool, tdata->mod_data, supplement_module.id, MOD_DATA_CONTACT, NULL);
    ao2_cleanup(contact);
}

References ao2_cleanup, AST_LIST_TRAVERSE, AST_RWLIST_RDLOCK, AST_RWLIST_UNLOCK, ast_sip_message_apply_transport(), ast_sip_mod_data_get, ast_sip_mod_data_set, does_method_match(), ast_sip_supplement::method, MOD_DATA_CONTACT, NULL, ast_sip_supplement::outgoing_response, supplement_module, and ast_sip_endpoint::transport.

Referenced by ast_sip_send_response(), and ast_sip_send_stateful_response().

sync_task()

static int sync_task ( void *  data )

static

Definition at line 2117 of file res_pjsip.c.

{
    struct sync_task_data *std = data;
    int ret;
 
    std->fail = std->task(std->task_data);
 
    /*
     * Once we unlock std->lock after signaling, we cannot access
     * std again.  The thread waiting within ast_sip_push_task_wait()
     * is free to continue and release its local variable (std).
     */
    ast_mutex_lock(&std->lock);
    std->complete = 1;
    ast_cond_signal(&std->cond);
    ret = std->fail;
    ast_mutex_unlock(&std->lock);
    return ret;
}

References ast_cond_signal, ast_mutex_lock, ast_mutex_unlock, sync_task_data::complete, sync_task_data::cond, sync_task_data::fail, sync_task_data::lock, sync_task_data::task, and sync_task_data::task_data.

Referenced by ast_sip_push_task_wait().

uas_use_sips_contact()

static int uas_use_sips_contact ( pjsip_rx_data *  rdata )

static

Determine if a SIPS Contact header is required.

This uses the guideline provided in RFC 3261 Section 12.1.1 to determine if the Contact header must be a sips: URI.

Parameters

rdata

The incoming dialog-starting request

Return values

0	SIPS not required
1	SIPS required

Definition at line 1089 of file res_pjsip.c.

{
    pjsip_rr_hdr *record_route;
 
    if (PJSIP_URI_SCHEME_IS_SIPS(rdata->msg_info.msg->line.req.uri)) {
        return 1;
    }
 
    record_route = pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_RECORD_ROUTE, NULL);
    if (record_route) {
        if (PJSIP_URI_SCHEME_IS_SIPS(&record_route->name_addr)) {
            return 1;
        }
    } else {
        pjsip_contact_hdr *contact;
 
        contact = pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_CONTACT, NULL);
        ast_assert(contact != NULL);
        if (PJSIP_URI_SCHEME_IS_SIPS(contact->uri)) {
            return 1;
        }
    }
 
    return 0;
}

References ast_assert, and NULL.

Referenced by create_dialog_uas().

unload_module()

static int unload_module ( void  )

static

Definition at line 4072 of file res_pjsip.c.

{
    AST_TEST_UNREGISTER(xml_sanitization_end_null);
    AST_TEST_UNREGISTER(xml_sanitization_exceeds_buffer);
    ast_cli_unregister_multiple(cli_commands, ARRAY_LEN(cli_commands));
 
    /* The thread this is called from cannot call PJSIP/PJLIB functions,
     * so we have to push the work to the threadpool to handle
     */
    ast_sip_push_task_wait_servant(NULL, unload_pjsip, NULL);
    ast_sip_destroy_scheduler();
    ast_serializer_pool_destroy(sip_serializer_pool);
    ast_threadpool_shutdown(sip_threadpool);
 
    return 0;
}

References ARRAY_LEN, ast_cli_unregister_multiple(), ast_serializer_pool_destroy(), ast_sip_destroy_scheduler(), ast_sip_push_task_wait_servant(), AST_TEST_UNREGISTER, ast_threadpool_shutdown(), cli_commands, NULL, sip_serializer_pool, sip_threadpool, and unload_pjsip().

unload_pjsip()

static int unload_pjsip ( void *  data )

static

Definition at line 3798 of file res_pjsip.c.

{
    /*
     * These calls need the pjsip endpoint and serializer to clean up.
     * If they're not set, then there's nothing to clean up anyway.
     */
    if (ast_pjsip_endpoint && sip_serializer_pool) {
        ast_res_pjsip_cleanup_options_handling();
        ast_res_pjsip_cleanup_message_filter();
        ast_sip_destroy_distributor();
        ast_sip_destroy_transport_management();
        ast_res_pjsip_destroy_configuration();
        ast_sip_destroy_system();
        ast_sip_destroy_global_headers();
        ast_sip_unregister_service(&supplement_module);
        ast_sip_destroy_transport_events();
    }
 
    if (monitor_thread) {
        stop_monitor_thread();
        monitor_thread = NULL;
    }
 
    if (memory_pool) {
        /* This mimics the behavior of pj_pool_safe_release
         * which was introduced in pjproject 2.6.
         */
        pj_pool_t *temp_pool = memory_pool;
 
        memory_pool = NULL;
        pj_pool_release(temp_pool);
    }
 
    ast_pjsip_endpoint = NULL;
 
    if (caching_pool.lock) {
        ast_pjproject_caching_pool_destroy(&caching_pool);
    }
 
    pj_shutdown();
 
    return 0;
}

References ast_pjproject_caching_pool_destroy(), ast_pjsip_endpoint, ast_res_pjsip_cleanup_message_filter(), ast_res_pjsip_cleanup_options_handling(), ast_res_pjsip_destroy_configuration(), ast_sip_destroy_distributor(), ast_sip_destroy_global_headers(), ast_sip_destroy_system(), ast_sip_destroy_transport_events(), ast_sip_destroy_transport_management(), ast_sip_unregister_service(), caching_pool, memory_pool, monitor_thread, NULL, sip_serializer_pool, stop_monitor_thread(), and supplement_module.

Referenced by load_module(), and unload_module().

unregister_service()

static int unregister_service ( void *  data )

static

Definition at line 122 of file res_pjsip.c.

{
    pjsip_module **module = data;
    if (!ast_pjsip_endpoint) {
        return -1;
    }
    pjsip_endpt_unregister_module(ast_pjsip_endpoint, *module);
    ast_debug(1, "Unregistered SIP service %.*s\n", (int) pj_strlen(&(*module)->name), pj_strbuf(&(*module)->name));
    return 0;
}

References ast_debug, and ast_pjsip_endpoint.

Referenced by ast_sip_unregister_service().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Basic SIP resource" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND - 5, .requires = "dnsmgr,res_pjproject,res_sorcery_config,res_sorcery_memory,res_sorcery_astdb", .optional_modules = "res_geolocation,res_statsd", }

static

Definition at line 4097 of file res_pjsip.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 4097 of file res_pjsip.c.

ast_pjsip_endpoint

pjsip_endpoint* ast_pjsip_endpoint

static

Definition at line 74 of file res_pjsip.c.

Referenced by ast_sip_get_pjsip_endpoint(), load_pjsip(), monitor_thread_exec(), register_service(), unload_pjsip(), and unregister_service().

caching_pool

pj_caching_pool caching_pool

Definition at line 2261 of file res_pjsip.c.

Referenced by load_pjsip(), and unload_pjsip().

cli_commands

struct ast_cli_entry cli_commands[]

static

Initial value:

= {
    { .handler =  cli_dump_endpt , .summary =  "Dump the res_pjsip endpt internals" ,},
    { .handler =  cli_show_settings , .summary =  "Show global and system configuration options" ,},
    { .handler =  cli_show_endpoint_identifiers , .summary =  "List registered endpoint identifiers" ,}
}

Definition at line 473 of file res_pjsip.c.

Referenced by load_module(), and unload_module().

endpoint_formatters

struct endpoint_formatters endpoint_formatters = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

endpoint_identifiers

struct endpoint_identifiers endpoint_identifiers = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

static

host_ip_ipv4

pj_sockaddr host_ip_ipv4

static

Local host address for IPv4

Definition at line 79 of file res_pjsip.c.

Referenced by ast_sip_get_host_ip(), and load_pjsip().

host_ip_ipv4_string

char host_ip_ipv4_string[PJ_INET6_ADDRSTRLEN]

static

Local host address for IPv4 (string form)

Definition at line 82 of file res_pjsip.c.

Referenced by ast_sip_get_host_ip(), ast_sip_get_host_ip_string(), and load_pjsip().

host_ip_ipv6

pj_sockaddr host_ip_ipv6

static

Local host address for IPv6

Definition at line 85 of file res_pjsip.c.

Referenced by ast_sip_get_host_ip(), and load_pjsip().

host_ip_ipv6_string

char host_ip_ipv6_string[PJ_INET6_ADDRSTRLEN]

static

Local host address for IPv6 (string form)

Definition at line 88 of file res_pjsip.c.

Referenced by ast_sip_get_host_ip(), ast_sip_get_host_ip_string(), and load_pjsip().

info_method

const pjsip_method info_method = {PJSIP_OTHER_METHOD, {"INFO", 4} }

static

Definition at line 1274 of file res_pjsip.c.

memory_pool

pj_pool_t* memory_pool

Definition at line 2262 of file res_pjsip.c.

Referenced by load_pjsip(), and unload_pjsip().

message_method

const pjsip_method message_method = {PJSIP_OTHER_METHOD, {"MESSAGE", 7} }

static

Definition at line 1275 of file res_pjsip.c.

Referenced by does_method_match().

method

const char* method

Definition at line 1279 of file res_pjsip.c.

Referenced by apply_method_filter(), ari_handle_websocket(), ast_ari_callback(), ast_ari_invoke(), ast_geoloc_eprofile_create_from_profile(), ast_geoloc_eprofile_dup(), ast_geoloc_eprofile_refresh_location(), ast_get_http_method(), ast_get_http_method_from_string(), ast_http_send(), ast_sip_create_request(), ast_sip_session_refresh(), ast_websocket_uri_cb(), auth_http_callback(), auth_manager_http_callback(), auth_mxml_http_callback(), auth_rawman_http_callback(), caldav_request(), create_in_dialog_request(), create_out_of_dialog_request(), delay_request(), delayed_method2str(), delayed_request_alloc(), does_method_match(), exchangecal_request(), generic_http_callback(), geoloc_config_load(), geoloc_eprofile_create_from_xslt_result(), geoloc_profile_write(), get_pjsip_method(), handle_uri(), has_supplement(), http_callback(), http_post_callback(), httpd_process_request(), httpstatus_callback(), ident_handler(), ident_to_str(), is_allowed_tel_uri_request(), manager_add_filter(), manager_http_callback(), method_logging_info_alloc(), mxml_http_callback(), phoneprov_callback(), pjsip_enable_logger_method(), pjsip_log_test_filter(), rawman_http_callback(), res_sdp_crypto_parse_offer(), send_topology_change_refresh(), sip_endpoint_identifier_str2type(), sip_endpoint_identifier_type2str(), sip_session_refresh(), sorcery_function_read(), static_callback(), and update_connected_line_information().

struct { ... } methods[]

Referenced by get_auth_methods(), get_pjsip_method(), ident_to_str(), and sorcery_function_read().

monitor_continue

int monitor_continue

static

Definition at line 2264 of file res_pjsip.c.

Referenced by load_pjsip(), monitor_thread_exec(), and stop_monitor_thread().

monitor_thread

pj_thread_t* monitor_thread

Definition at line 2263 of file res_pjsip.c.

Referenced by ast_sip_thread_is_servant(), load_pjsip(), stop_monitor_thread(), and unload_pjsip().

pj_thread_storage

struct ast_threadstorage pj_thread_storage = { .once = PTHREAD_ONCE_INIT , .key_init = __init_pj_thread_storage , .custom_init = NULL , }

static

Definition at line 2281 of file res_pjsip.c.

Referenced by sip_thread_start().

pjsip_media_type_application_cpim_xpidf_xml

pjsip_media_type pjsip_media_type_application_cpim_xpidf_xml

Definition at line 3913 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_application_json

pjsip_media_type pjsip_media_type_application_json

Common media types used throughout res_pjsip and pjproject

Definition at line 3909 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_application_media_control_xml

pjsip_media_type pjsip_media_type_application_media_control_xml

Definition at line 3910 of file res_pjsip.c.

Referenced by load_module(), and video_info_incoming_request().

pjsip_media_type_application_pidf_xml

pjsip_media_type pjsip_media_type_application_pidf_xml

Definition at line 3911 of file res_pjsip.c.

Referenced by add_eprofile_to_tdata(), find_pidf(), and load_module().

pjsip_media_type_application_rlmi_xml

pjsip_media_type pjsip_media_type_application_rlmi_xml

Definition at line 3914 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_application_sdp

pjsip_media_type pjsip_media_type_application_sdp

Definition at line 3916 of file res_pjsip.c.

Referenced by filter_on_tx_message(), load_module(), and session_outgoing_nat_hook().

pjsip_media_type_application_simple_message_summary

pjsip_media_type pjsip_media_type_application_simple_message_summary

Definition at line 3915 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_application_xpidf_xml

pjsip_media_type pjsip_media_type_application_xpidf_xml

Definition at line 3912 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_multipart_alternative

pjsip_media_type pjsip_media_type_multipart_alternative

Definition at line 3917 of file res_pjsip.c.

Referenced by check_content_disposition(), and load_module().

pjsip_media_type_multipart_mixed

pjsip_media_type pjsip_media_type_multipart_mixed

Definition at line 3918 of file res_pjsip.c.

Referenced by add_eprofile_to_tdata(), aoc_invite_outgoing_response(), check_content_disposition(), find_pidf(), and load_module().

pjsip_media_type_multipart_related

pjsip_media_type pjsip_media_type_multipart_related

Definition at line 3919 of file res_pjsip.c.

Referenced by load_module().

pjsip_media_type_text_plain

pjsip_media_type pjsip_media_type_text_plain

Definition at line 3920 of file res_pjsip.c.

Referenced by load_module().

pmethod

const pjsip_method* pmethod

Definition at line 1280 of file res_pjsip.c.

Referenced by ast_sip_create_request().

rc_map

const struct response_code_map rc_map[]

static

Definition at line 3634 of file res_pjsip.c.

Referenced by ast_sip_str2rc().

refer_method

const pjsip_method refer_method = {PJSIP_OTHER_METHOD, {"REFER", 5} }

static

Definition at line 1276 of file res_pjsip.c.

registered_authenticator

struct ast_sip_authenticator* registered_authenticator

static

Definition at line 138 of file res_pjsip.c.

Referenced by ast_sip_check_authentication(), ast_sip_register_authenticator(), ast_sip_requires_authentication(), and ast_sip_unregister_authenticator().

registered_outbound_authenticator

struct ast_sip_outbound_authenticator* registered_outbound_authenticator

static

Definition at line 189 of file res_pjsip.c.

Referenced by ast_sip_create_request_with_auth(), ast_sip_register_outbound_authenticator(), and ast_sip_unregister_outbound_authenticator().

servant_id_storage

struct ast_threadstorage servant_id_storage = { .once = PTHREAD_ONCE_INIT , .key_init = __init_servant_id_storage , .custom_init = NULL , }

static

Definition at line 2282 of file res_pjsip.c.

Referenced by ast_sip_thread_is_servant(), and sip_thread_start().

sip_serializer_pool

struct ast_serializer_pool* sip_serializer_pool

static

Pool of serializers to use if not supplied.

Definition at line 72 of file res_pjsip.c.

Referenced by ast_sip_push_task(), ast_sip_push_task_wait_serializer(), load_module(), unload_module(), and unload_pjsip().

sip_threadpool

struct ast_threadpool* sip_threadpool

static

Definition at line 76 of file res_pjsip.c.

Referenced by ast_sip_create_serializer_group(), ast_sip_threadpool(), ast_sip_threadpool_queue_size(), load_module(), and unload_module().

supplement_module

pjsip_module supplement_module

static

Definition at line 1318 of file res_pjsip.c.

Referenced by ast_sip_create_response(), ast_sip_send_out_of_dialog_request(), clean_contact_from_tdata(), create_out_of_dialog_request(), load_module(), supplement_outgoing_response(), and unload_pjsip().

supplements

struct supplements supplements = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }