Asterisk - The Open Source Telephony Project GIT-master-7921072
Data Structures | Macros | Functions | Variables
pjsip_distributor.c File Reference
#include "asterisk.h"
#include <pjsip.h>
#include "asterisk/res_pjsip.h"
#include "asterisk/acl.h"
#include "include/res_pjsip_private.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/threadpool.h"
#include "asterisk/res_pjsip_cli.h"
Include dependency graph for pjsip_distributor.c:

Go to the source code of this file.

Data Structures

struct  distributor_dialog_data
 
struct  unidentified_request
 

Macros

#define DEFAULT_SUSPECTS_BUCKETS   53
 
#define DIALOG_ASSOCIATIONS_BUCKETS   251
 
#define DISTRIBUTOR_POOL_SIZE   31
 

Functions

static struct ast_sip_authalloc_artificial_auth (char *default_realm)
 
static AO2_GLOBAL_OBJ_STATIC (artificial_auth)
 
static void apply_acls (pjsip_rx_data *rdata)
 
static int apply_endpoint_acl (pjsip_rx_data *rdata, struct ast_sip_endpoint *endpoint)
 
static int apply_endpoint_contact_acl (pjsip_rx_data *rdata, struct ast_sip_endpoint *endpoint)
 
struct ast_sip_endpointast_pjsip_rdata_get_endpoint (pjsip_rx_data *rdata)
 Get the looked-up endpoint on an out-of dialog request or response. More...
 
void ast_sip_destroy_distributor (void)
 
struct ast_sip_endpointast_sip_dialog_get_endpoint (pjsip_dialog *dlg)
 Get the endpoint associated with this dialog. More...
 
void ast_sip_dialog_set_endpoint (pjsip_dialog *dlg, struct ast_sip_endpoint *endpoint)
 Set an endpoint on a SIP dialog so in-dialog requests do not undergo endpoint lookup. More...
 
void ast_sip_dialog_set_serializer (pjsip_dialog *dlg, struct ast_taskprocessor *serializer)
 Set a serializer on a SIP dialog so requests and responses are automatically serialized. More...
 
struct ast_sip_authast_sip_get_artificial_auth (void)
 Retrieves a reference to the artificial auth. More...
 
struct ast_sip_endpointast_sip_get_artificial_endpoint (void)
 Retrieves a reference to the artificial endpoint. More...
 
struct ast_taskprocessorast_sip_get_distributor_serializer (pjsip_rx_data *rdata)
 Determine the distributor serializer for the SIP message. More...
 
int ast_sip_initialize_distributor (void)
 
static pj_bool_t authenticate (pjsip_rx_data *rdata)
 
static int buf_hash (const char *pos, size_t len)
 
static int buf_hash_add (const char *pos, size_t len, int hash)
 
static void check_endpoint (pjsip_rx_data *rdata, struct unidentified_request *unid, const char *name)
 
static int clean_task (const void *data)
 
static struct ao2_containercli_unid_get_container (const char *regex)
 
static const char * cli_unid_get_id (const void *obj)
 
static int cli_unid_iterate (void *container, ao2_callback_fn callback, void *args)
 
static int cli_unid_print_body (void *obj, void *arg, int flags)
 
static int cli_unid_print_header (void *obj, void *arg, int flags)
 
static void * cli_unid_retrieve_by_id (const char *id)
 
static int create_artificial_auth (void)
 
static int create_artificial_endpoint (void)
 
static int dialog_associations_cmp (void *obj, void *arg, int flags)
 
static int dialog_associations_hash (const void *obj, int flags)
 
static int distribute (void *data)
 
static pj_bool_t distributor (pjsip_rx_data *rdata)
 
static int distributor_pool_setup (void)
 
static void distributor_pool_shutdown (void)
 
static pj_bool_t endpoint_lookup (pjsip_rx_data *rdata)
 
static int expire_requests (void *object, void *arg, int flags)
 
static int extract_contact_addr (pjsip_contact_hdr *contact, struct ast_sockaddr **addrs)
 
static pjsip_dialog * find_dialog (pjsip_rx_data *rdata)
 
static struct ast_taskprocessorfind_request_serializer (pjsip_rx_data *rdata)
 
static void global_loaded (const char *object_type)
 
static void log_failed_request (pjsip_rx_data *rdata, char *msg, unsigned int count, unsigned int period)
 
static int pjstr_hash (pj_str_t *str)
 
static int pjstr_hash_add (pj_str_t *str, int hash)
 
static int prune_task (const void *data)
 
static pj_status_t record_serializer (pjsip_tx_data *tdata)
 
static int suspects_compare (void *obj, void *arg, int flags)
 
static int suspects_hash (const void *obj, int flags)
 
static int suspects_sort (const void *obj, const void *arg, int flags)
 

Variables

static struct ast_sip_endpointartificial_endpoint = NULL
 
static pjsip_module auth_mod
 
static struct ast_cli_entry cli_commands []
 
static struct ao2_containerdialog_associations
 
static pjsip_module distributor_mod
 
static struct ast_taskprocessordistributor_pool [DISTRIBUTOR_POOL_SIZE]
 
static pjsip_module endpoint_mod
 
static struct ast_sorcery_observer global_observer
 Observer which is used to update our interval and default_realm when the global setting changes. More...
 
static enum ast_sip_taskprocessor_overload_trigger overload_trigger
 
struct ast_sched_contextprune_context
 
struct ast_sip_cli_formatter_entryunid_formatter
 
static unsigned int unidentified_count
 
static unsigned int unidentified_period
 
static unsigned int unidentified_prune_interval
 
static struct ao2_containerunidentified_requests
 
static int using_auth_username
 

Macro Definition Documentation

◆ DEFAULT_SUSPECTS_BUCKETS

#define DEFAULT_SUSPECTS_BUCKETS   53

Definition at line 44 of file pjsip_distributor.c.

◆ DIALOG_ASSOCIATIONS_BUCKETS

#define DIALOG_ASSOCIATIONS_BUCKETS   251

Definition at line 159 of file pjsip_distributor.c.

◆ DISTRIBUTOR_POOL_SIZE

#define DISTRIBUTOR_POOL_SIZE   31

Number of serializers in pool if one not otherwise known. (Best if prime number)

Definition at line 60 of file pjsip_distributor.c.

Function Documentation

◆ alloc_artificial_auth()

static struct ast_sip_auth * alloc_artificial_auth ( char *  default_realm)
static

Definition at line 591 of file pjsip_distributor.c.

592{
593 struct ast_sip_auth *fake_auth;
594
596 "artificial");
597 if (!fake_auth) {
598 return NULL;
599 }
600
602 ast_string_field_set(fake_auth, auth_user, "");
603 ast_string_field_set(fake_auth, auth_pass, "");
605
606 return fake_auth;
607}
@ AST_SIP_AUTH_TYPE_ARTIFICIAL
Definition: res_pjsip.h:574
#define SIP_SORCERY_AUTH_TYPE
Definition: res_pjsip.h:577
struct ast_sorcery * ast_sip_get_sorcery(void)
Get a pointer to the SIP sorcery structure.
static char default_realm[AST_SIP_AUTH_MAX_REALM_LENGTH+1]
#define NULL
Definition: resample.c:96
void * ast_sorcery_alloc(const struct ast_sorcery *sorcery, const char *type, const char *id)
Allocate an object.
Definition: sorcery.c:1744
#define ast_string_field_set(x, field, data)
Set a field to a simple string value.
Definition: stringfields.h:521
const ast_string_field realm
Definition: res_pjsip.h:597
const ast_string_field auth_user
Definition: res_pjsip.h:597
const ast_string_field auth_pass
Definition: res_pjsip.h:597
enum ast_sip_auth_type type
Definition: res_pjsip.h:601

References AST_SIP_AUTH_TYPE_ARTIFICIAL, ast_sip_get_sorcery(), ast_sorcery_alloc(), ast_string_field_set, ast_sip_auth::auth_pass, ast_sip_auth::auth_user, default_realm, NULL, ast_sip_auth::realm, SIP_SORCERY_AUTH_TYPE, and ast_sip_auth::type.

Referenced by create_artificial_auth(), and global_loaded().

◆ AO2_GLOBAL_OBJ_STATIC()

static AO2_GLOBAL_OBJ_STATIC ( artificial_auth  )
static

◆ apply_acls()

static void apply_acls ( pjsip_rx_data *  rdata)
static

Definition at line 698 of file pjsip_distributor.c.

699{
700 struct ast_sip_endpoint *endpoint;
701
702 /* Is the endpoint allowed with the source or contact address? */
703 endpoint = rdata->endpt_info.mod_data[endpoint_mod.id];
704 if (endpoint != artificial_endpoint
705 && (apply_endpoint_acl(rdata, endpoint)
706 || apply_endpoint_contact_acl(rdata, endpoint))) {
707 ast_debug(1, "Endpoint '%s' not allowed by ACL\n",
708 ast_sorcery_object_get_id(endpoint));
709
710 /* Replace the rdata endpoint with the artificial endpoint. */
711 ao2_replace(rdata->endpt_info.mod_data[endpoint_mod.id], artificial_endpoint);
712 }
713}
#define ao2_replace(dst, src)
Replace one object reference with another cleaning up the original.
Definition: astobj2.h:501
#define ast_debug(level,...)
Log a DEBUG message.
static int apply_endpoint_acl(pjsip_rx_data *rdata, struct ast_sip_endpoint *endpoint)
static pjsip_module endpoint_mod
static struct ast_sip_endpoint * artificial_endpoint
static int apply_endpoint_contact_acl(pjsip_rx_data *rdata, struct ast_sip_endpoint *endpoint)
const char * ast_sorcery_object_get_id(const void *object)
Get the unique identifier of a sorcery object.
Definition: sorcery.c:2312
An entity with which Asterisk communicates.
Definition: res_pjsip.h:963

References ao2_replace, apply_endpoint_acl(), apply_endpoint_contact_acl(), artificial_endpoint, ast_debug, ast_sorcery_object_get_id(), and endpoint_mod.

Referenced by endpoint_lookup().

◆ apply_endpoint_acl()

static int apply_endpoint_acl ( pjsip_rx_data *  rdata,
struct ast_sip_endpoint endpoint 
)
static

Definition at line 803 of file pjsip_distributor.c.

804{
805 struct ast_sockaddr addr;
806
807 if (ast_acl_list_is_empty(endpoint->acl)) {
808 return 0;
809 }
810
811 memset(&addr, 0, sizeof(addr));
812 ast_sockaddr_parse(&addr, rdata->pkt_info.src_name, PARSE_PORT_FORBID);
813 ast_sockaddr_set_port(&addr, rdata->pkt_info.src_port);
814
815 if (ast_apply_acl(endpoint->acl, &addr, "SIP ACL: ") != AST_SENSE_ALLOW) {
816 log_failed_request(rdata, "Not match Endpoint ACL", 0, 0);
817 ast_sip_report_failed_acl(endpoint, rdata, "not_match_endpoint_acl");
818 return 1;
819 }
820 return 0;
821}
enum ast_acl_sense ast_apply_acl(struct ast_acl_list *acl_list, const struct ast_sockaddr *addr, const char *purpose)
Apply a set of rules to a given IP address.
Definition: acl.c:799
@ AST_SENSE_ALLOW
Definition: acl.h:38
int ast_acl_list_is_empty(struct ast_acl_list *acl_list)
Determines if an ACL is empty or if it contains entries.
Definition: acl.c:540
int ast_sockaddr_parse(struct ast_sockaddr *addr, const char *str, int flags)
Parse an IPv4 or IPv6 address string.
Definition: netsock2.c:230
#define ast_sockaddr_set_port(addr, port)
Sets the port number of a socket address.
Definition: netsock2.h:532
static void log_failed_request(pjsip_rx_data *rdata, char *msg, unsigned int count, unsigned int period)
void ast_sip_report_failed_acl(struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, const char *name)
Send a security event notification for when an ACL check fails.
struct ast_acl_list * acl
Definition: res_pjsip.h:1036
Socket address structure.
Definition: netsock2.h:97

References ast_sip_endpoint::acl, ast_acl_list_is_empty(), ast_apply_acl(), AST_SENSE_ALLOW, ast_sip_report_failed_acl(), ast_sockaddr_parse(), ast_sockaddr_set_port, log_failed_request(), and PARSE_PORT_FORBID.

Referenced by apply_acls().

◆ apply_endpoint_contact_acl()

static int apply_endpoint_contact_acl ( pjsip_rx_data *  rdata,
struct ast_sip_endpoint endpoint 
)
static

Definition at line 842 of file pjsip_distributor.c.

843{
844 int num_contact_addrs;
845 int forbidden = 0;
846 struct ast_sockaddr *contact_addrs;
847 int i;
848 pjsip_contact_hdr *contact = (pjsip_contact_hdr *)&rdata->msg_info.msg->hdr;
849
851 return 0;
852 }
853
854 while ((contact = pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_CONTACT, contact->next))) {
855 num_contact_addrs = extract_contact_addr(contact, &contact_addrs);
856 if (num_contact_addrs <= 0) {
857 continue;
858 }
859 for (i = 0; i < num_contact_addrs; ++i) {
860 if (ast_apply_acl(endpoint->contact_acl, &contact_addrs[i], "SIP Contact ACL: ") != AST_SENSE_ALLOW) {
861 log_failed_request(rdata, "Not match Endpoint Contact ACL", 0, 0);
862 ast_sip_report_failed_acl(endpoint, rdata, "not_match_endpoint_contact_acl");
863 forbidden = 1;
864 break;
865 }
866 }
867 ast_free(contact_addrs);
868 if (forbidden) {
869 /* No use checking other contacts if we already have failed ACL check */
870 break;
871 }
872 }
873
874 return forbidden;
875}
if(!yyg->yy_init)
Definition: ast_expr2f.c:854
#define ast_free(a)
Definition: astmm.h:180
static int extract_contact_addr(pjsip_contact_hdr *contact, struct ast_sockaddr **addrs)
struct ast_acl_list * contact_acl
Definition: res_pjsip.h:1038

References ast_acl_list_is_empty(), ast_apply_acl(), ast_free, AST_SENSE_ALLOW, ast_sip_report_failed_acl(), ast_sip_endpoint::contact_acl, extract_contact_addr(), if(), and log_failed_request().

Referenced by apply_acls().

◆ ast_pjsip_rdata_get_endpoint()

struct ast_sip_endpoint * ast_pjsip_rdata_get_endpoint ( pjsip_rx_data *  rdata)

Get the looked-up endpoint on an out-of dialog request or response.

The function may ONLY be called on out-of-dialog requests or responses. For in-dialog requests and responses, it is required that the user of the dialog has the looked-up endpoint stored locally.

This function should never return NULL if the message is out-of-dialog. It will always return NULL if the message is in-dialog.

This function will increase the reference count of the returned endpoint by one. Release your reference using the ao2_ref function when finished.

Parameters
rdataOut-of-dialog request or response
Returns
The looked up endpoint

Definition at line 966 of file pjsip_distributor.c.

967{
968 struct ast_sip_endpoint *endpoint = rdata->endpt_info.mod_data[endpoint_mod.id];
969 if (endpoint) {
970 ao2_ref(endpoint, +1);
971 }
972 return endpoint;
973}
#define ao2_ref(o, delta)
Reference/unreference an object and return the old refcount.
Definition: astobj2.h:459

References ao2_ref, and endpoint_mod.

Referenced by authenticate(), handle_new_invite_request(), nat_on_rx_message(), options_on_rx_request(), pubsub_on_rx_mwi_notify_request(), pubsub_on_rx_publish_request(), pubsub_on_rx_refresh(), pubsub_on_rx_subscribe_request(), registrar_on_rx_request(), rx_data_to_ast_msg(), send_options_response(), send_response(), and supplement_on_rx_request().

◆ ast_sip_destroy_distributor()

void ast_sip_destroy_distributor ( void  )

Definition at line 1329 of file pjsip_distributor.c.

1330{
1333
1337
1338 ao2_global_obj_release(artificial_auth);
1340
1342
1343 if (prune_context) {
1345 }
1346
1348
1351}
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
#define ao2_global_obj_release(holder)
Release the ao2 object held in the global holder.
Definition: astobj2.h:859
int ast_cli_unregister_multiple(struct ast_cli_entry *e, int len)
Unregister multiple commands.
Definition: clicompat.c:30
static struct ast_sorcery_observer global_observer
Observer which is used to update our interval and default_realm when the global setting changes.
static pjsip_module distributor_mod
static void distributor_pool_shutdown(void)
static struct ao2_container * unidentified_requests
static struct ast_cli_entry cli_commands[]
static pjsip_module auth_mod
struct ast_sched_context * prune_context
struct ast_sip_cli_formatter_entry * unid_formatter
static struct ao2_container * dialog_associations
void ast_sip_unregister_service(pjsip_module *module)
Definition: res_pjsip.c:133
int ast_sip_unregister_cli_formatter(struct ast_sip_cli_formatter_entry *formatter)
Unregisters a CLI formatter.
Definition: pjsip_cli.c:326
void ast_sched_context_destroy(struct ast_sched_context *c)
destroys a schedule context
Definition: sched.c:271
void ast_sorcery_observer_remove(const struct ast_sorcery *sorcery, const char *type, const struct ast_sorcery_observer *callbacks)
Remove an observer from a specific object type.
Definition: sorcery.c:2418
#define ARRAY_LEN(a)
Definition: utils.h:666

References ao2_cleanup, ao2_global_obj_release, ARRAY_LEN, artificial_endpoint, ast_cli_unregister_multiple(), ast_sched_context_destroy(), ast_sip_get_sorcery(), ast_sip_unregister_cli_formatter(), ast_sip_unregister_service(), ast_sorcery_observer_remove(), auth_mod, cli_commands, dialog_associations, distributor_mod, distributor_pool_shutdown(), endpoint_mod, global_observer, prune_context, unid_formatter, and unidentified_requests.

Referenced by ast_sip_initialize_distributor(), and unload_pjsip().

◆ ast_sip_get_artificial_auth()

struct ast_sip_auth * ast_sip_get_artificial_auth ( void  )

Retrieves a reference to the artificial auth.

Return values
Theartificial auth

Definition at line 628 of file pjsip_distributor.c.

629{
630 return ao2_global_obj_ref(artificial_auth);
631}
#define ao2_global_obj_ref(holder)
Get a reference to the object stored in the global holder.
Definition: astobj2.h:918

References ao2_global_obj_ref.

Referenced by digest_check_auth(), and global_loaded().

◆ ast_sip_get_artificial_endpoint()

struct ast_sip_endpoint * ast_sip_get_artificial_endpoint ( void  )

Retrieves a reference to the artificial endpoint.

Return values
Theartificial endpoint

Definition at line 651 of file pjsip_distributor.c.

652{
654 return artificial_endpoint;
655}

References ao2_ref, and artificial_endpoint.

Referenced by digest_check_auth(), digest_requires_authentication(), endpoint_lookup(), and get_account_id().

◆ ast_sip_initialize_distributor()

int ast_sip_initialize_distributor ( void  )

Definition at line 1255 of file pjsip_distributor.c.

1256{
1259 if (!unidentified_requests) {
1260 return -1;
1261 }
1262
1266 if (!dialog_associations) {
1268 return -1;
1269 }
1270
1271 if (distributor_pool_setup()) {
1273 return -1;
1274 }
1275
1277 if (!prune_context) {
1279 return -1;
1280 }
1281
1284 return -1;
1285 }
1286
1289
1292 return -1;
1293 }
1294
1297 return -1;
1298 }
1301 return -1;
1302 }
1305 return -1;
1306 }
1307
1310 if (!unid_formatter) {
1312 ast_log(LOG_ERROR, "Unable to allocate memory for unid_formatter\n");
1313 return -1;
1314 }
1315 unid_formatter->name = "unidentified_request";
1323
1325
1326 return 0;
1327}
#define ast_log
Definition: astobj2.c:42
@ AO2_ALLOC_OPT_LOCK_NOLOCK
Definition: astobj2.h:367
@ AO2_ALLOC_OPT_LOCK_RWLOCK
Definition: astobj2.h:365
#define ao2_alloc_options(data_size, destructor_fn, options)
Definition: astobj2.h:404
#define ao2_container_alloc_hash(ao2_options, container_options, n_buckets, hash_fn, sort_fn, cmp_fn)
Allocate and initialize a hash container with the desired number of buckets.
Definition: astobj2.h:1303
#define ast_cli_register_multiple(e, len)
Register multiple commands.
Definition: cli.h:265
#define LOG_ERROR
static int dialog_associations_hash(const void *obj, int flags)
static int cli_unid_iterate(void *container, ao2_callback_fn callback, void *args)
static int cli_unid_print_header(void *obj, void *arg, int flags)
#define DIALOG_ASSOCIATIONS_BUCKETS
static struct ao2_container * cli_unid_get_container(const char *regex)
static int cli_unid_print_body(void *obj, void *arg, int flags)
static int suspects_hash(const void *obj, int flags)
static void * cli_unid_retrieve_by_id(const char *id)
static int suspects_compare(void *obj, void *arg, int flags)
static int create_artificial_endpoint(void)
static int dialog_associations_cmp(void *obj, void *arg, int flags)
void ast_sip_destroy_distributor(void)
static int create_artificial_auth(void)
static const char * cli_unid_get_id(const void *obj)
static int distributor_pool_setup(void)
#define DEFAULT_SUSPECTS_BUCKETS
int ast_sip_register_service(pjsip_module *module)
Register a SIP service in Asterisk.
Definition: res_pjsip.c:117
int ast_sip_register_cli_formatter(struct ast_sip_cli_formatter_entry *formatter)
Registers a CLI formatter.
Definition: pjsip_cli.c:310
int ast_sched_start_thread(struct ast_sched_context *con)
Start a thread for processing scheduler entries.
Definition: sched.c:197
struct ast_sched_context * ast_sched_context_create(void)
Create a scheduler context.
Definition: sched.c:238
int ast_sorcery_observer_add(const struct ast_sorcery *sorcery, const char *type, const struct ast_sorcery_observer *callbacks)
Add an observer to a specific object type.
Definition: sorcery.c:2386
void ast_sorcery_reload_object(const struct ast_sorcery *sorcery, const char *type)
Inform any wizards of a specific object type to reload persistent objects.
Definition: sorcery.c:1442
CLI Formatter Registry Entry.
Definition: res_pjsip_cli.h:52
int(* iterate)(void *container, ao2_callback_fn callback, void *args)
Definition: res_pjsip_cli.h:66
ao2_callback_fn * print_header
Definition: res_pjsip_cli.h:60
void *(* retrieve_by_id)(const char *id)
Definition: res_pjsip_cli.h:68
const char *(* get_id)(const void *obj)
Definition: res_pjsip_cli.h:70
const char * name
Definition: res_pjsip_cli.h:58
ao2_callback_fn * print_body
Definition: res_pjsip_cli.h:62
struct ao2_container *(* get_container)(const char *regex)
Definition: res_pjsip_cli.h:64

References AO2_ALLOC_OPT_LOCK_NOLOCK, AO2_ALLOC_OPT_LOCK_RWLOCK, ao2_alloc_options, ao2_container_alloc_hash, ARRAY_LEN, ast_cli_register_multiple, ast_log, ast_sched_context_create(), ast_sched_start_thread(), ast_sip_destroy_distributor(), ast_sip_get_sorcery(), ast_sip_register_cli_formatter(), ast_sip_register_service(), ast_sorcery_observer_add(), ast_sorcery_reload_object(), auth_mod, cli_commands, cli_unid_get_container(), cli_unid_get_id(), cli_unid_iterate(), cli_unid_print_body(), cli_unid_print_header(), cli_unid_retrieve_by_id(), create_artificial_auth(), create_artificial_endpoint(), DEFAULT_SUSPECTS_BUCKETS, dialog_associations, DIALOG_ASSOCIATIONS_BUCKETS, dialog_associations_cmp(), dialog_associations_hash(), distributor_mod, distributor_pool_setup(), endpoint_mod, ast_sip_cli_formatter_entry::get_container, ast_sip_cli_formatter_entry::get_id, global_observer, ast_sip_cli_formatter_entry::iterate, LOG_ERROR, ast_sip_cli_formatter_entry::name, NULL, ast_sip_cli_formatter_entry::print_body, ast_sip_cli_formatter_entry::print_header, prune_context, ast_sip_cli_formatter_entry::retrieve_by_id, suspects_compare(), suspects_hash(), unid_formatter, and unidentified_requests.

Referenced by load_module().

◆ authenticate()

static pj_bool_t authenticate ( pjsip_rx_data *  rdata)
static

Definition at line 877 of file pjsip_distributor.c.

878{
880 int is_ack = rdata->msg_info.msg->line.req.method.id == PJSIP_ACK_METHOD;
881
882 ast_assert(endpoint != NULL);
883
884 if (is_ack) {
885 return PJ_FALSE;
886 }
887
888 if (ast_sip_requires_authentication(endpoint, rdata)) {
889 pjsip_tx_data *tdata;
890 struct unidentified_request *unid;
891
892 pjsip_endpt_create_response(ast_sip_get_pjsip_endpoint(), rdata, 401, NULL, &tdata);
893 switch (ast_sip_check_authentication(endpoint, rdata, tdata)) {
895 /* Send the 401 we created for them */
896 ast_sip_report_auth_challenge_sent(endpoint, rdata, tdata);
897 if (pjsip_endpt_send_response2(ast_sip_get_pjsip_endpoint(), rdata, tdata, NULL, NULL) != PJ_SUCCESS) {
898 pjsip_tx_data_dec_ref(tdata);
899 }
900 return PJ_TRUE;
902 /* See note in endpoint_lookup about not holding an unnecessary write lock */
903 unid = ao2_find(unidentified_requests, rdata->pkt_info.src_name, OBJ_SEARCH_KEY);
904 if (unid) {
906 ao2_ref(unid, -1);
907 }
908 ast_sip_report_auth_success(endpoint, rdata);
909 break;
911 log_failed_request(rdata, "Failed to authenticate", 0, 0);
913 if (pjsip_endpt_send_response2(ast_sip_get_pjsip_endpoint(), rdata, tdata, NULL, NULL) != PJ_SUCCESS) {
914 pjsip_tx_data_dec_ref(tdata);
915 }
916 return PJ_TRUE;
918 log_failed_request(rdata, "Error to authenticate", 0, 0);
920 pjsip_tx_data_dec_ref(tdata);
921 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata, 500, NULL, NULL, NULL);
922 return PJ_TRUE;
923 }
924 pjsip_tx_data_dec_ref(tdata);
925 } else if (endpoint == artificial_endpoint) {
926 /* Uh. Oh. The artificial endpoint couldn't challenge so block the request. */
927 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata, 500, NULL, NULL, NULL);
928 return PJ_TRUE;
929 }
930
931 return PJ_FALSE;
932}
#define ao2_unlink(container, obj)
Remove an object from a container.
Definition: astobj2.h:1578
#define ao2_find(container, arg, flags)
Definition: astobj2.h:1736
@ OBJ_SEARCH_KEY
The arg parameter is a search key, but is not an object.
Definition: astobj2.h:1101
struct ast_sip_endpoint * ast_pjsip_rdata_get_endpoint(pjsip_rx_data *rdata)
Get the looked-up endpoint on an out-of dialog request or response.
int ast_sip_requires_authentication(struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata)
Determine if an incoming request requires authentication.
Definition: res_pjsip.c:163
void ast_sip_report_auth_success(struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata)
Send a security event notification for when authentication succeeds.
void ast_sip_report_auth_challenge_sent(struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata, pjsip_tx_data *tdata)
Send a security event notification for when an authentication challenge is sent.
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.
Definition: res_pjsip.c:179
pjsip_endpoint * ast_sip_get_pjsip_endpoint(void)
Get a pointer to the PJSIP endpoint.
Definition: res_pjsip.c:520
void ast_sip_report_auth_failed_challenge_response(struct ast_sip_endpoint *endpoint, pjsip_rx_data *rdata)
Send a security event notification for when a challenge response has failed.
@ AST_SIP_AUTHENTICATION_CHALLENGE
Definition: res_pjsip.h:1231
@ AST_SIP_AUTHENTICATION_ERROR
Definition: res_pjsip.h:1237
@ AST_SIP_AUTHENTICATION_SUCCESS
Definition: res_pjsip.h:1233
@ AST_SIP_AUTHENTICATION_FAILED
Definition: res_pjsip.h:1235
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
Definition: utils.h:941
#define ast_assert(a)
Definition: utils.h:739

References ao2_cleanup, ao2_find, ao2_ref, ao2_unlink, artificial_endpoint, ast_assert, ast_pjsip_rdata_get_endpoint(), AST_SIP_AUTHENTICATION_CHALLENGE, AST_SIP_AUTHENTICATION_ERROR, AST_SIP_AUTHENTICATION_FAILED, AST_SIP_AUTHENTICATION_SUCCESS, ast_sip_check_authentication(), ast_sip_get_pjsip_endpoint(), ast_sip_report_auth_challenge_sent(), ast_sip_report_auth_failed_challenge_response(), ast_sip_report_auth_success(), ast_sip_requires_authentication(), log_failed_request(), NULL, OBJ_SEARCH_KEY, RAII_VAR, and unidentified_requests.

◆ buf_hash()

static int buf_hash ( const char *  pos,
size_t  len 
)
static

Definition at line 207 of file pjsip_distributor.c.

208{
209 return buf_hash_add(pos, len, 5381);
210}
static int len(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t buflen)
static int buf_hash_add(const char *pos, size_t len, int hash)

References buf_hash_add(), and len().

Referenced by dialog_associations_hash().

◆ buf_hash_add()

static int buf_hash_add ( const char *  pos,
size_t  len,
int  hash 
)
static

Definition at line 181 of file pjsip_distributor.c.

182{
183 while (len--) {
184 hash = hash * 33 ^ *pos++;
185 }
186
187 return hash;
188}

References len().

Referenced by buf_hash(), and pjstr_hash_add().

◆ check_endpoint()

static void check_endpoint ( pjsip_rx_data *  rdata,
struct unidentified_request unid,
const char *  name 
)
static

Definition at line 680 of file pjsip_distributor.c.

682{
683 int64_t ms = ast_tvdiff_ms(ast_tvnow(), unid->first_seen);
684
685 ao2_wrlock(unid);
686 unid->count++;
687
688 if (ms < (unidentified_period * 1000) && unid->count >= unidentified_count) {
689 log_failed_request(rdata, "No matching endpoint found", unid->count, ms);
691 }
692 ao2_unlock(unid);
693}
#define ao2_wrlock(a)
Definition: astobj2.h:719
#define ao2_unlock(a)
Definition: astobj2.h:729
static const char name[]
Definition: format_mp3.c:68
static unsigned int unidentified_period
static unsigned int unidentified_count
void ast_sip_report_invalid_endpoint(const char *name, pjsip_rx_data *rdata)
Send a security event notification for when an invalid endpoint is requested.
struct timeval first_seen
int64_t ast_tvdiff_ms(struct timeval end, struct timeval start)
Computes the difference (in milliseconds) between two struct timeval instances.
Definition: time.h:107
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
Definition: time.h:159

References ao2_unlock, ao2_wrlock, ast_sip_report_invalid_endpoint(), ast_tvdiff_ms(), ast_tvnow(), unidentified_request::count, unidentified_request::first_seen, log_failed_request(), name, unidentified_count, and unidentified_period.

Referenced by endpoint_lookup().

◆ clean_task()

static int clean_task ( const void *  data)
static

Definition at line 1157 of file pjsip_distributor.c.

1158{
1159 return 0;
1160}

Referenced by global_loaded().

◆ cli_unid_get_container()

static struct ao2_container * cli_unid_get_container ( const char *  regex)
static

Definition at line 1048 of file pjsip_distributor.c.

1049{
1050 struct ao2_container *s_container;
1051
1054 if (!s_container) {
1055 return NULL;
1056 }
1057
1058 if (ao2_container_dup(s_container, unidentified_requests, 0)) {
1059 ao2_ref(s_container, -1);
1060 return NULL;
1061 }
1062
1063 return s_container;
1064}
int ao2_container_dup(struct ao2_container *dest, struct ao2_container *src, enum search_flags flags)
Copy all object references in the src container into the dest container.
#define ao2_container_alloc_list(ao2_options, container_options, sort_fn, cmp_fn)
Allocate and initialize a list container.
Definition: astobj2.h:1327
static int suspects_sort(const void *obj, const void *arg, int flags)
Generic container type.

References AO2_ALLOC_OPT_LOCK_NOLOCK, ao2_container_alloc_list, ao2_container_dup(), ao2_ref, NULL, suspects_compare(), suspects_sort(), and unidentified_requests.

Referenced by ast_sip_initialize_distributor().

◆ cli_unid_get_id()

static const char * cli_unid_get_id ( const void *  obj)
static

Definition at line 1078 of file pjsip_distributor.c.

1079{
1080 const struct unidentified_request *unid = obj;
1081
1082 return unid->src_name;
1083}

References unidentified_request::src_name.

Referenced by ast_sip_initialize_distributor().

◆ cli_unid_iterate()

static int cli_unid_iterate ( void *  container,
ao2_callback_fn  callback,
void *  args 
)
static

Definition at line 1066 of file pjsip_distributor.c.

1067{
1068 ao2_callback(container, 0, callback, args);
1069
1070 return 0;
1071}
#define ao2_callback(c, flags, cb_fn, arg)
ao2_callback() is a generic function that applies cb_fn() to all objects in a container,...
Definition: astobj2.h:1693
struct ao2_container * container
Definition: res_fax.c:501
const char * args

References ao2_callback, args, and container.

Referenced by ast_sip_initialize_distributor().

◆ cli_unid_print_body()

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

Definition at line 1102 of file pjsip_distributor.c.

1103{
1104 struct unidentified_request *unid = obj;
1105 struct ast_sip_cli_context *context = arg;
1106 int indent;
1107 int flexwidth;
1108 int64_t ms = ast_tvdiff_ms(ast_tvnow(), unid->first_seen);
1109
1110 ast_assert(context->output_buffer != NULL);
1111
1112 indent = CLI_INDENT_TO_SPACES(context->indent_level);
1113 flexwidth = CLI_LAST_TABSTOP - 4;
1114
1115 ast_str_append(&context->output_buffer, 0, "%*s: %-*.*s %7d %10.3f\n",
1116 indent,
1117 "Request",
1118 flexwidth, flexwidth,
1119 unid->src_name, unid->count, ms / 1000.0);
1120
1121 return 0;
1122}
#define CLI_LAST_TABSTOP
Definition: res_pjsip_cli.h:27
#define CLI_INDENT_TO_SPACES(x)
Definition: res_pjsip_cli.h:29
int ast_str_append(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Append to a thread local dynamic string.
Definition: strings.h:1139
CLI Formatter Context passed to all formatters.
Definition: res_pjsip_cli.h:34

References ast_assert, ast_str_append(), ast_tvdiff_ms(), ast_tvnow(), CLI_INDENT_TO_SPACES, CLI_LAST_TABSTOP, voicemailpwcheck::context, unidentified_request::count, unidentified_request::first_seen, NULL, and unidentified_request::src_name.

Referenced by ast_sip_initialize_distributor().

◆ cli_unid_print_header()

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

Definition at line 1085 of file pjsip_distributor.c.

1086{
1087 struct ast_sip_cli_context *context = arg;
1088 RAII_VAR(struct ast_sip_cli_formatter_entry *, formatter_entry, NULL, ao2_cleanup);
1089
1090 int indent = CLI_INDENT_TO_SPACES(context->indent_level);
1091 int filler = CLI_LAST_TABSTOP - indent - 7;
1092
1093 ast_assert(context->output_buffer != NULL);
1094
1095 ast_str_append(&context->output_buffer, 0,
1096 "%*s: <IP Address%*.*s> <Count> <Age(sec)>\n",
1097 indent, "Request", filler, filler, CLI_HEADER_FILLER);
1098
1099 return 0;
1100}
#define CLI_HEADER_FILLER
Definition: res_pjsip_cli.h:24

References ao2_cleanup, ast_assert, ast_str_append(), CLI_HEADER_FILLER, CLI_INDENT_TO_SPACES, CLI_LAST_TABSTOP, voicemailpwcheck::context, NULL, and RAII_VAR.

Referenced by ast_sip_initialize_distributor().

◆ cli_unid_retrieve_by_id()

static void * cli_unid_retrieve_by_id ( const char *  id)
static

Definition at line 1073 of file pjsip_distributor.c.

1074{
1076}

References ao2_find, OBJ_SEARCH_KEY, and unidentified_requests.

Referenced by ast_sip_initialize_distributor().

◆ create_artificial_auth()

static int create_artificial_auth ( void  )
static

Definition at line 611 of file pjsip_distributor.c.

612{
614 struct ast_sip_auth *fake_auth;
615
618 if (!fake_auth) {
619 ast_log(LOG_ERROR, "Unable to create artificial auth\n");
620 return -1;
621 }
622
623 ao2_global_obj_replace_unref(artificial_auth, fake_auth);
624 ao2_ref(fake_auth, -1);
625 return 0;
626}
#define ao2_global_obj_replace_unref(holder, obj)
Replace an ao2 object in the global holder, throwing away any old object.
Definition: astobj2.h:901
static struct ast_sip_auth * alloc_artificial_auth(char *default_realm)
void ast_sip_get_default_realm(char *realm, size_t size)
Retrieve the global default realm.
#define AST_SIP_AUTH_MAX_REALM_LENGTH
Definition: res_pjsip.h:74

References alloc_artificial_auth(), ao2_global_obj_replace_unref, ao2_ref, ast_log, AST_SIP_AUTH_MAX_REALM_LENGTH, ast_sip_get_default_realm(), default_realm, and LOG_ERROR.

Referenced by ast_sip_initialize_distributor().

◆ create_artificial_endpoint()

static int create_artificial_endpoint ( void  )
static

Definition at line 635 of file pjsip_distributor.c.

636{
638 if (!artificial_endpoint) {
639 return -1;
640 }
641
643 /* Pushing a bogus value into the vector will ensure that
644 * the proper size of the vector is returned. This value is
645 * not actually used anywhere
646 */
648 return 0;
649}
#define ast_strdup(str)
A wrapper for strdup()
Definition: astmm.h:241
struct ast_sip_auth_vector inbound_auths
Definition: res_pjsip.h:1008
#define AST_VECTOR_INIT(vec, size)
Initialize a vector.
Definition: vector.h:113
#define AST_VECTOR_APPEND(vec, elem)
Append an element to a vector, growing the vector if needed.
Definition: vector.h:256

References artificial_endpoint, ast_sip_get_sorcery(), ast_sorcery_alloc(), ast_strdup, AST_VECTOR_APPEND, AST_VECTOR_INIT, ast_sip_endpoint::inbound_auths, and NULL.

Referenced by ast_sip_initialize_distributor().

◆ dialog_associations_cmp()

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

Definition at line 236 of file pjsip_distributor.c.

237{
238 const struct distributor_dialog_data *object_left = obj;
239 const struct distributor_dialog_data *object_right = arg;
240 const pjsip_dialog *right_key = arg;
241 int cmp = 0;
242
243 switch (flags & OBJ_SEARCH_MASK) {
245 right_key = object_right->dlg;
246 /* Fall through */
247 case OBJ_SEARCH_KEY:
248 if (object_left->dlg == right_key) {
249 cmp = CMP_MATCH;
250 }
251 break;
253 /* There is no such thing for this container. */
254 ast_assert(0);
255 break;
256 default:
257 cmp = 0;
258 break;
259 }
260 return cmp;
261}
@ CMP_MATCH
Definition: astobj2.h:1027
@ OBJ_SEARCH_PARTIAL_KEY
The arg parameter is a partial search key similar to OBJ_SEARCH_KEY.
Definition: astobj2.h:1116
@ OBJ_SEARCH_OBJECT
The arg parameter is an object of the same type.
Definition: astobj2.h:1087
@ OBJ_SEARCH_MASK
Search option field mask.
Definition: astobj2.h:1072

References ast_assert, CMP_MATCH, distributor_dialog_data::dlg, OBJ_SEARCH_KEY, OBJ_SEARCH_MASK, OBJ_SEARCH_OBJECT, and OBJ_SEARCH_PARTIAL_KEY.

Referenced by ast_sip_initialize_distributor().

◆ dialog_associations_hash()

static int dialog_associations_hash ( const void *  obj,
int  flags 
)
static

Definition at line 212 of file pjsip_distributor.c.

213{
214 const struct distributor_dialog_data *object;
215 union {
216 const pjsip_dialog *dlg;
217 const char buf[sizeof(pjsip_dialog *)];
218 } key;
219
220 switch (flags & OBJ_SEARCH_MASK) {
221 case OBJ_SEARCH_KEY:
222 key.dlg = obj;
223 break;
225 object = obj;
226 key.dlg = object->dlg;
227 break;
228 default:
229 /* Hash can only work on something with a full key. */
230 ast_assert(0);
231 return 0;
232 }
233 return ast_str_hash_restrict(buf_hash(key.buf, sizeof(key.buf)));
234}
char buf[BUFSIZE]
Definition: eagi_proxy.c:66
static int buf_hash(const char *pos, size_t len)
static force_inline int attribute_pure ast_str_hash_restrict(unsigned int hash)
Restrict hash value range.
Definition: strings.h:1246

References ast_assert, ast_str_hash_restrict(), buf, buf_hash(), distributor_dialog_data::dlg, OBJ_SEARCH_KEY, OBJ_SEARCH_MASK, and OBJ_SEARCH_OBJECT.

Referenced by ast_sip_initialize_distributor().

◆ distribute()

static int distribute ( void *  data)
static

Definition at line 940 of file pjsip_distributor.c.

941{
942 static pjsip_process_rdata_param param = {
943 .start_mod = &distributor_mod,
944 .idx_after_start = 1,
945 };
946 pj_bool_t handled = PJ_FALSE;
947 pjsip_rx_data *rdata = data;
948 int is_request = rdata->msg_info.msg->type == PJSIP_REQUEST_MSG;
949 int is_ack = is_request ? rdata->msg_info.msg->line.req.method.id == PJSIP_ACK_METHOD : 0;
950 struct ast_sip_endpoint *endpoint;
951
952 pjsip_endpt_process_rx_data(ast_sip_get_pjsip_endpoint(), rdata, &param, &handled);
953 if (!handled && is_request && !is_ack) {
954 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata, 501, NULL, NULL, NULL);
955 }
956
957 /* The endpoint_mod stores an endpoint reference in the mod_data of rdata. This
958 * is the only appropriate spot to actually decrement the reference.
959 */
960 endpoint = rdata->endpt_info.mod_data[endpoint_mod.id];
961 ao2_cleanup(endpoint);
962 pjsip_rx_data_free_cloned(rdata);
963 return 0;
964}

References ao2_cleanup, ast_sip_get_pjsip_endpoint(), distributor_mod, endpoint_mod, and NULL.

Referenced by distributor().

◆ distributor()

static pj_bool_t distributor ( pjsip_rx_data *  rdata)
static

Definition at line 482 of file pjsip_distributor.c.

483{
484 pjsip_dialog *dlg;
485 struct distributor_dialog_data *dist = NULL;
487 pjsip_rx_data *clone;
488
490 /*
491 * Ignore everything until we are fully booted. Let the
492 * peer retransmit messages until we are ready.
493 */
494 return PJ_TRUE;
495 }
496
497 dlg = find_dialog(rdata);
498 if (dlg) {
499 ast_debug(3, "Searching for serializer associated with dialog %s for %s\n",
500 dlg->obj_name, pjsip_rx_data_get_info(rdata));
502 if (dist) {
503 ao2_lock(dist);
505 ao2_unlock(dist);
506 if (serializer) {
507 ast_debug(3, "Found serializer %s associated with dialog %s\n",
508 ast_taskprocessor_name(serializer), dlg->obj_name);
509 }
510 }
511 }
512
513 if (serializer) {
514 /* We have a serializer so we know where to send the message. */
515 } else if (rdata->msg_info.msg->type == PJSIP_RESPONSE_MSG) {
516 ast_debug(3, "No dialog serializer for %s. Using request transaction as basis.\n",
517 pjsip_rx_data_get_info(rdata));
519 if (!serializer) {
520 /*
521 * Pick a serializer for the unmatched response.
522 * We couldn't determine what serializer originally
523 * sent the request or the serializer is gone.
524 */
526 }
527 } else if (!pjsip_method_cmp(&rdata->msg_info.msg->line.req.method, &pjsip_cancel_method)
528 || !pjsip_method_cmp(&rdata->msg_info.msg->line.req.method, &pjsip_bye_method)) {
529 /* We have a BYE or CANCEL request without a serializer. */
530 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
531 PJSIP_SC_CALL_TSX_DOES_NOT_EXIST, NULL, NULL, NULL);
532 ao2_cleanup(dist);
533 return PJ_TRUE;
534 } else {
539 /*
540 * When taskprocessors get backed up, there is a good chance that
541 * we are being overloaded and need to defer adding new work to
542 * the system. To defer the work we will ignore the request and
543 * rely on the peer's transport layer to retransmit the message.
544 * We usually work off the overload within a few seconds.
545 * If transport is non-UDP we send a 503 response instead.
546 */
547 switch (rdata->tp_info.transport->key.type) {
548 case PJSIP_TRANSPORT_UDP6:
549 case PJSIP_TRANSPORT_UDP:
550 ast_debug(3, "Taskprocessor overload alert: Ignoring '%s'.\n",
551 pjsip_rx_data_get_info(rdata));
552 break;
553 default:
554 ast_debug(3, "Taskprocessor overload on non-udp transport. Received:'%s'. "
555 "Responding with a 503.\n", pjsip_rx_data_get_info(rdata));
556 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
557 PJSIP_SC_SERVICE_UNAVAILABLE, NULL, NULL, NULL);
558 break;
559 }
560 ao2_cleanup(dist);
561 return PJ_TRUE;
562 }
563
564 /* Pick a serializer for the out-of-dialog request. */
566 }
567
568 if (pjsip_rx_data_clone(rdata, 0, &clone) != PJ_SUCCESS) {
570 ao2_cleanup(dist);
571 return PJ_TRUE;
572 }
573
574 if (dist) {
575 ao2_lock(dist);
576 clone->endpt_info.mod_data[endpoint_mod.id] = ao2_bump(dist->endpoint);
577 ao2_unlock(dist);
578 ao2_cleanup(dist);
579 }
580
582 ao2_cleanup(clone->endpt_info.mod_data[endpoint_mod.id]);
583 pjsip_rx_data_free_cloned(clone);
584 }
585
587
588 return PJ_TRUE;
589}
#define ao2_lock(a)
Definition: astobj2.h:717
#define ao2_bump(obj)
Bump refcount on an AO2 object by one, returning the object.
Definition: astobj2.h:480
struct ast_flags ast_options
Definition: options.c:61
@ AST_OPT_FLAG_FULLY_BOOTED
Definition: options.h:58
struct ast_taskprocessor * ast_sip_get_distributor_serializer(pjsip_rx_data *rdata)
Determine the distributor serializer for the SIP message.
int ast_sip_push_task(struct ast_taskprocessor *serializer, int(*sip_task)(void *), void *task_data)
Pushes a task to SIP servants.
Definition: res_pjsip.c:2099
static int distribute(void *data)
static enum ast_sip_taskprocessor_overload_trigger overload_trigger
static pjsip_dialog * find_dialog(pjsip_rx_data *rdata)
static struct ast_taskprocessor * find_request_serializer(pjsip_rx_data *rdata)
@ TASKPROCESSOR_OVERLOAD_TRIGGER_GLOBAL
@ TASKPROCESSOR_OVERLOAD_TRIGGER_PJSIP_ONLY
A ast_taskprocessor structure is a singleton by name.
Definition: taskprocessor.c:69
struct ast_sip_endpoint * endpoint
struct ast_taskprocessor * serializer
void * ast_taskprocessor_unreference(struct ast_taskprocessor *tps)
Unreference the specified taskprocessor and its reference count will decrement.
unsigned int ast_taskprocessor_alert_get(void)
Get the current taskprocessor high water alert count.
unsigned int ast_taskprocessor_get_subsystem_alert(const char *subsystem)
Get the current taskprocessor high water alert count by subsystem.
const char * ast_taskprocessor_name(struct ast_taskprocessor *tps)
Return the name of the taskprocessor singleton.
#define ast_test_flag(p, flag)
Definition: utils.h:63

References ao2_bump, ao2_cleanup, ao2_find, ao2_lock, ao2_unlock, ast_debug, AST_OPT_FLAG_FULLY_BOOTED, ast_options, ast_sip_get_distributor_serializer(), ast_sip_get_pjsip_endpoint(), ast_sip_push_task(), ast_taskprocessor_alert_get(), ast_taskprocessor_get_subsystem_alert(), ast_taskprocessor_name(), ast_taskprocessor_unreference(), ast_test_flag, dialog_associations, distribute(), distributor_dialog_data::endpoint, endpoint_mod, find_dialog(), find_request_serializer(), NULL, OBJ_SEARCH_KEY, overload_trigger, distributor_dialog_data::serializer, TASKPROCESSOR_OVERLOAD_TRIGGER_GLOBAL, and TASKPROCESSOR_OVERLOAD_TRIGGER_PJSIP_ONLY.

◆ distributor_pool_setup()

static int distributor_pool_setup ( void  )
static

Definition at line 1238 of file pjsip_distributor.c.

1239{
1240 char tps_name[AST_TASKPROCESSOR_MAX_NAME + 1];
1241 int idx;
1242
1243 for (idx = 0; idx < ARRAY_LEN(distributor_pool); ++idx) {
1244 /* Create name with seq number appended. */
1245 ast_taskprocessor_build_name(tps_name, sizeof(tps_name), "pjsip/distributor");
1246
1248 if (!distributor_pool[idx]) {
1249 return -1;
1250 }
1251 }
1252 return 0;
1253}
struct ast_taskprocessor * ast_sip_create_serializer(const char *name)
Create a new serializer for SIP tasks.
Definition: res_pjsip.c:2094
static struct ast_taskprocessor * distributor_pool[DISTRIBUTOR_POOL_SIZE]
void ast_taskprocessor_build_name(char *buf, unsigned int size, const char *format,...)
Build a taskprocessor name with a sequence number on the end.
#define AST_TASKPROCESSOR_MAX_NAME
Suggested maximum taskprocessor name length (less null terminator).
Definition: taskprocessor.h:61

References ARRAY_LEN, ast_sip_create_serializer(), ast_taskprocessor_build_name(), AST_TASKPROCESSOR_MAX_NAME, and distributor_pool.

Referenced by ast_sip_initialize_distributor().

◆ distributor_pool_shutdown()

static void distributor_pool_shutdown ( void  )
static

Definition at line 1220 of file pjsip_distributor.c.

1221{
1222 int idx;
1223
1224 for (idx = 0; idx < ARRAY_LEN(distributor_pool); ++idx) {
1226 distributor_pool[idx] = NULL;
1227 }
1228}

References ARRAY_LEN, ast_taskprocessor_unreference(), distributor_pool, and NULL.

Referenced by ast_sip_destroy_distributor().

◆ endpoint_lookup()

static pj_bool_t endpoint_lookup ( pjsip_rx_data *  rdata)
static

Definition at line 715 of file pjsip_distributor.c.

716{
717 struct ast_sip_endpoint *endpoint;
718 struct unidentified_request *unid;
719 int is_ack = rdata->msg_info.msg->line.req.method.id == PJSIP_ACK_METHOD;
720
721 endpoint = rdata->endpt_info.mod_data[endpoint_mod.id];
722 if (endpoint) {
723 /*
724 * ao2_find with OBJ_UNLINK always write locks the container before even searching
725 * for the object. Since the majority case is that the object won't be found, do
726 * the find without OBJ_UNLINK to prevent the unnecessary write lock, then unlink
727 * if needed.
728 */
729 unid = ao2_find(unidentified_requests, rdata->pkt_info.src_name, OBJ_SEARCH_KEY);
730 if (unid) {
732 ao2_ref(unid, -1);
733 }
734 apply_acls(rdata);
735 return PJ_FALSE;
736 }
737
738 endpoint = ast_sip_identify_endpoint(rdata);
739 if (endpoint) {
740 unid = ao2_find(unidentified_requests, rdata->pkt_info.src_name, OBJ_SEARCH_KEY);
741 if (unid) {
743 ao2_ref(unid, -1);
744 }
745 }
746
747 if (!endpoint) {
748 /* always use an artificial endpoint - per discussion no reason
749 to have "alwaysauthreject" as an option. It is felt using it
750 was a bug fix and it is not needed since we are not worried about
751 breaking old stuff and we really don't want to enable the discovery
752 of SIP accounts */
754 }
755
756 /* endpoint ref held by mod_data[] */
757 rdata->endpt_info.mod_data[endpoint_mod.id] = endpoint;
758
759 if (endpoint == artificial_endpoint && !is_ack) {
760 char name[AST_UUID_STR_LEN] = "";
761 pjsip_uri *from = rdata->msg_info.from->uri;
762
763 if (ast_sip_is_allowed_uri(from)) {
765 }
766
767 unid = ao2_find(unidentified_requests, rdata->pkt_info.src_name, OBJ_SEARCH_KEY);
768 if (unid) {
769 check_endpoint(rdata, unid, name);
770 ao2_ref(unid, -1);
771 } else if (using_auth_username) {
773 /* Checking again with the write lock held allows us to eliminate the DUPS_REPLACE and sort_fn */
774 unid = ao2_find(unidentified_requests, rdata->pkt_info.src_name,
776 if (unid) {
777 check_endpoint(rdata, unid, name);
778 } else {
779 unid = ao2_alloc_options(sizeof(*unid) + strlen(rdata->pkt_info.src_name) + 1,
781 if (!unid) {
783 pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata, 500, NULL, NULL, NULL);
784 return PJ_TRUE;
785 }
786 strcpy(unid->src_name, rdata->pkt_info.src_name); /* Safe */
787 unid->first_seen = ast_tvnow();
788 unid->count = 1;
790 }
791 ao2_ref(unid, -1);
793 } else {
794 log_failed_request(rdata, "No matching endpoint found", 0, 0);
796 }
797 }
798
799 apply_acls(rdata);
800 return PJ_FALSE;
801}
#define ao2_link_flags(container, obj, flags)
Add an object to a container.
Definition: astobj2.h:1554
@ OBJ_NOLOCK
Assume that the ao2_container is already locked.
Definition: astobj2.h:1063
struct ast_sip_endpoint * ast_sip_get_artificial_endpoint(void)
Retrieves a reference to the artificial endpoint.
static void check_endpoint(pjsip_rx_data *rdata, struct unidentified_request *unid, const char *name)
static void apply_acls(pjsip_rx_data *rdata)
static int using_auth_username
const pj_str_t * ast_sip_pjsip_uri_get_username(pjsip_uri *uri)
Get the user portion of the pjsip_uri.
Definition: res_pjsip.c:3477
int ast_sip_is_allowed_uri(pjsip_uri *uri)
Check whether a pjsip_uri is allowed or not.
Definition: res_pjsip.c:3472
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.
Definition: res_pjsip.c:2201
struct ast_sip_endpoint * ast_sip_identify_endpoint(pjsip_rx_data *rdata)
Determine the endpoint that has sent a SIP message.
Definition: res_pjsip.c:330
#define AST_UUID_STR_LEN
Definition: uuid.h:27

References AO2_ALLOC_OPT_LOCK_RWLOCK, ao2_alloc_options, ao2_find, ao2_link_flags, ao2_ref, ao2_unlink, ao2_unlock, ao2_wrlock, apply_acls(), artificial_endpoint, ast_copy_pj_str(), ast_sip_get_artificial_endpoint(), ast_sip_get_pjsip_endpoint(), ast_sip_identify_endpoint(), ast_sip_is_allowed_uri(), ast_sip_pjsip_uri_get_username(), ast_sip_report_invalid_endpoint(), ast_tvnow(), AST_UUID_STR_LEN, check_endpoint(), unidentified_request::count, endpoint_mod, unidentified_request::first_seen, log_failed_request(), name, NULL, OBJ_NOLOCK, OBJ_SEARCH_KEY, unidentified_request::src_name, unidentified_requests, and using_auth_username.

◆ expire_requests()

static int expire_requests ( void *  object,
void *  arg,
int  flags 
)
static

Definition at line 1133 of file pjsip_distributor.c.

1134{
1135 struct unidentified_request *unid = object;
1136 int *maxage = arg;
1137 int64_t ms = ast_tvdiff_ms(ast_tvnow(), unid->first_seen);
1138
1139 if (ms > (*maxage) * 2 * 1000) {
1140 return CMP_MATCH;
1141 }
1142
1143 return 0;
1144}

References ast_tvdiff_ms(), ast_tvnow(), CMP_MATCH, and unidentified_request::first_seen.

Referenced by prune_task().

◆ extract_contact_addr()

static int extract_contact_addr ( pjsip_contact_hdr *  contact,
struct ast_sockaddr **  addrs 
)
static

Definition at line 823 of file pjsip_distributor.c.

824{
825 pjsip_sip_uri *sip_uri;
826 char host[256];
827
828 if (!contact || contact->star) {
829 *addrs = NULL;
830 return 0;
831 }
832
833 if (!PJSIP_URI_SCHEME_IS_SIP(contact->uri) && !PJSIP_URI_SCHEME_IS_SIPS(contact->uri)) {
834 *addrs = NULL;
835 return 0;
836 }
837 sip_uri = pjsip_uri_get_uri(contact->uri);
838 ast_copy_pj_str(host, &sip_uri->host, sizeof(host));
840}
@ AST_AF_UNSPEC
Definition: netsock2.h:54
int ast_sockaddr_resolve(struct ast_sockaddr **addrs, const char *str, int flags, int family)
Parses a string with an IPv4 or IPv6 address and place results into an array.
Definition: netsock2.c:280

References AST_AF_UNSPEC, ast_copy_pj_str(), ast_sockaddr_resolve(), NULL, and PARSE_PORT_FORBID.

Referenced by apply_endpoint_contact_acl().

◆ find_dialog()

static pjsip_dialog * find_dialog ( pjsip_rx_data *  rdata)
static

Definition at line 336 of file pjsip_distributor.c.

337{
338 pj_str_t tsx_key;
339 pjsip_transaction *tsx;
340 pjsip_dialog *dlg;
341 pj_str_t *local_tag;
342 pj_str_t *remote_tag;
343
344 if (!rdata->msg_info.msg) {
345 return NULL;
346 }
347
348 if (rdata->msg_info.msg->type == PJSIP_REQUEST_MSG) {
349 local_tag = &rdata->msg_info.to->tag;
350 remote_tag = &rdata->msg_info.from->tag;
351 } else {
352 local_tag = &rdata->msg_info.from->tag;
353 remote_tag = &rdata->msg_info.to->tag;
354 }
355
356 /* We can only call the convenient method for
357 * 1) responses
358 * 2) non-CANCEL requests
359 * 3) CANCEL requests with a to-tag
360 */
361 if (rdata->msg_info.msg->type == PJSIP_RESPONSE_MSG ||
362 pjsip_method_cmp(&rdata->msg_info.msg->line.req.method, &pjsip_cancel_method) ||
363 rdata->msg_info.to->tag.slen != 0) {
364 dlg = pjsip_ua_find_dialog(&rdata->msg_info.cid->id, local_tag,
365 remote_tag, PJ_FALSE);
366 if (dlg) {
367 return dlg;
368 }
369 }
370
371 /*
372 * There may still be a matching dialog if this is
373 * 1) an incoming CANCEL request without a to-tag
374 * 2) an incoming response to a dialog-creating request.
375 */
376 if (rdata->msg_info.msg->type == PJSIP_REQUEST_MSG) {
377 /* CANCEL requests will need to match the INVITE we initially received. Any
378 * other request type will either have been matched already or is not in
379 * dialog
380 */
381 pjsip_tsx_create_key(rdata->tp_info.pool, &tsx_key, PJSIP_ROLE_UAS,
382 pjsip_get_invite_method(), rdata);
383 } else {
384 pjsip_tsx_create_key(rdata->tp_info.pool, &tsx_key, PJSIP_ROLE_UAC,
385 &rdata->msg_info.cseq->method, rdata);
386 }
387
388 tsx = pjsip_tsx_layer_find_tsx(&tsx_key, PJ_TRUE);
389 if (!tsx) {
390 ast_debug(3, "Could not find matching transaction for %s\n",
391 pjsip_rx_data_get_info(rdata));
392 return NULL;
393 }
394
395 dlg = pjsip_tsx_get_dlg(tsx);
396
397#ifdef HAVE_PJ_TRANSACTION_GRP_LOCK
398 pj_grp_lock_release(tsx->grp_lock);
399#else
400 pj_mutex_unlock(tsx->mutex);
401#endif
402
403 return dlg;
404}

References ast_debug, and NULL.

Referenced by distributor().

◆ find_request_serializer()

static struct ast_taskprocessor * find_request_serializer ( pjsip_rx_data *  rdata)
static

Definition at line 109 of file pjsip_distributor.c.

110{
112 pj_str_t tsx_key;
113 pjsip_transaction *tsx;
114
115 pjsip_tsx_create_key(rdata->tp_info.pool, &tsx_key, PJSIP_ROLE_UAC,
116 &rdata->msg_info.cseq->method, rdata);
117
118 tsx = pjsip_tsx_layer_find_tsx(&tsx_key, PJ_TRUE);
119 if (!tsx) {
120 ast_debug(1, "Could not find transaction for %s.\n",
121 pjsip_rx_data_get_info(rdata));
122 return NULL;
123 }
124 ast_debug(3, "Found transaction %s for %s.\n",
125 tsx->obj_name, pjsip_rx_data_get_info(rdata));
126
127 if (tsx->last_tx) {
128 const char *serializer_name;
129
130 serializer_name = tsx->last_tx->mod_data[distributor_mod.id];
131 if (!ast_strlen_zero(serializer_name)) {
133 if (serializer) {
134 ast_debug(3, "Found serializer %s on transaction %s\n",
135 serializer_name, tsx->obj_name);
136 }
137 }
138 }
139
140#ifdef HAVE_PJ_TRANSACTION_GRP_LOCK
141 pj_grp_lock_release(tsx->grp_lock);
142#else
143 pj_mutex_unlock(tsx->mutex);
144#endif
145
146 return serializer;
147}
static force_inline int attribute_pure ast_strlen_zero(const char *s)
Definition: strings.h:65
struct ast_taskprocessor * ast_taskprocessor_get(const char *name, enum ast_tps_options create)
Get a reference to a taskprocessor with the specified name and create the taskprocessor if necessary.
@ TPS_REF_IF_EXISTS
return a reference to a taskprocessor ONLY if it already exists
Definition: taskprocessor.h:78

References ast_debug, ast_strlen_zero(), ast_taskprocessor_get(), distributor_mod, NULL, and TPS_REF_IF_EXISTS.

Referenced by distributor().

◆ global_loaded()

static void global_loaded ( const char *  object_type)
static

Definition at line 1162 of file pjsip_distributor.c.

1163{
1165 struct ast_sip_auth *fake_auth;
1166 char *identifier_order;
1167
1168 /* Update using_auth_username */
1169 identifier_order = ast_sip_get_endpoint_identifier_order();
1170 if (identifier_order) {
1171 char *identify_method;
1172 char *io_copy = ast_strdupa(identifier_order);
1173 int new_using = 0;
1174
1175 ast_free(identifier_order);
1176 while ((identify_method = ast_strip(strsep(&io_copy, ",")))) {
1177 if (!strcmp(identify_method, "auth_username")) {
1178 new_using = 1;
1179 break;
1180 }
1181 }
1182 using_auth_username = new_using;
1183 }
1184
1185 /* Update default_realm of artificial_auth */
1187 fake_auth = ast_sip_get_artificial_auth();
1188 if (!fake_auth || strcmp(fake_auth->realm, default_realm)) {
1189 ao2_cleanup(fake_auth);
1190
1192 if (fake_auth) {
1193 ao2_global_obj_replace_unref(artificial_auth, fake_auth);
1194 }
1195 }
1196 ao2_cleanup(fake_auth);
1197
1199
1201
1202 /* Clean out the old task, if any */
1204 /* Have to do something with the return value to shut up the stupid compiler. */
1206 return;
1207 }
1208}
#define ast_strdupa(s)
duplicate a string in memory from the stack
Definition: astmm.h:298
enum ast_sip_taskprocessor_overload_trigger ast_sip_get_taskprocessor_overload_trigger(void)
char * strsep(char **str, const char *delims)
struct ast_sip_auth * ast_sip_get_artificial_auth(void)
Retrieves a reference to the artificial auth.
static int prune_task(const void *data)
static unsigned int unidentified_prune_interval
static int clean_task(const void *data)
char * ast_sip_get_endpoint_identifier_order(void)
Retrieve the global endpoint_identifier_order setting.
void ast_sip_get_unidentified_request_thresholds(unsigned int *count, unsigned int *period, unsigned int *prune_interval)
Retrieve the unidentified request security event thresholds.
void ast_sched_clean_by_callback(struct ast_sched_context *con, ast_sched_cb match, ast_sched_cb cleanup_cb)
Clean all scheduled events with matching callback.
Definition: sched.c:409
int ast_sched_add_variable(struct ast_sched_context *con, int when, ast_sched_cb callback, const void *data, int variable) attribute_warn_unused_result
Adds a scheduled event with rescheduling support.
Definition: sched.c:526
char * ast_strip(char *s)
Strip leading/trailing whitespace from a string.
Definition: strings.h:223

References alloc_artificial_auth(), ao2_cleanup, ao2_global_obj_replace_unref, ast_free, ast_sched_add_variable(), ast_sched_clean_by_callback(), AST_SIP_AUTH_MAX_REALM_LENGTH, ast_sip_get_artificial_auth(), ast_sip_get_default_realm(), ast_sip_get_endpoint_identifier_order(), ast_sip_get_taskprocessor_overload_trigger(), ast_sip_get_unidentified_request_thresholds(), ast_strdupa, ast_strip(), clean_task(), default_realm, NULL, overload_trigger, prune_context, prune_task(), ast_sip_auth::realm, strsep(), unidentified_count, unidentified_period, unidentified_prune_interval, and using_auth_username.

◆ log_failed_request()

static void log_failed_request ( pjsip_rx_data *  rdata,
char *  msg,
unsigned int  count,
unsigned int  period 
)
static

Definition at line 657 of file pjsip_distributor.c.

658{
659 char from_buf[PJSIP_MAX_URL_SIZE];
660 char callid_buf[PJSIP_MAX_URL_SIZE];
661 char method_buf[PJSIP_MAX_URL_SIZE];
662 char src_addr_buf[AST_SOCKADDR_BUFLEN];
663 pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, rdata->msg_info.from->uri, from_buf, PJSIP_MAX_URL_SIZE);
664 ast_copy_pj_str(callid_buf, &rdata->msg_info.cid->id, PJSIP_MAX_URL_SIZE);
665 ast_copy_pj_str(method_buf, &rdata->msg_info.msg->line.req.method.name, PJSIP_MAX_URL_SIZE);
666 if (count) {
667 ast_log(LOG_NOTICE, "Request '%s' from '%s' failed for '%s' (callid: %s) - %s"
668 " after %u tries in %.3f ms\n",
669 method_buf, from_buf,
670 pj_sockaddr_print(&rdata->pkt_info.src_addr, src_addr_buf, sizeof(src_addr_buf), 3),
671 callid_buf, msg, count, period / 1000.0);
672 } else {
673 ast_log(LOG_NOTICE, "Request '%s' from '%s' failed for '%s' (callid: %s) - %s\n",
674 method_buf, from_buf,
675 pj_sockaddr_print(&rdata->pkt_info.src_addr, src_addr_buf, sizeof(src_addr_buf), 3),
676 callid_buf, msg);
677 }
678}
#define LOG_NOTICE
#define AST_SOCKADDR_BUFLEN
Definition: netsock2.h:46

References ast_copy_pj_str(), ast_log, AST_SOCKADDR_BUFLEN, and LOG_NOTICE.

Referenced by apply_endpoint_acl(), apply_endpoint_contact_acl(), authenticate(), check_endpoint(), and endpoint_lookup().

◆ pjstr_hash()

static int pjstr_hash ( pj_str_t *  str)
static

Definition at line 440 of file pjsip_distributor.c.

441{
442 return pjstr_hash_add(str, 5381);
443}
const char * str
Definition: app_jack.c:147
static int pjstr_hash_add(pj_str_t *str, int hash)

References pjstr_hash_add(), and str.

Referenced by ast_sip_get_distributor_serializer().

◆ pjstr_hash_add()

static int pjstr_hash_add ( pj_str_t *  str,
int  hash 
)
static

Definition at line 423 of file pjsip_distributor.c.

424{
425 return buf_hash_add(pj_strbuf(str), pj_strlen(str), hash);
426}

References buf_hash_add(), and str.

Referenced by ast_sip_get_distributor_serializer(), and pjstr_hash().

◆ prune_task()

static int prune_task ( const void *  data)
static

◆ record_serializer()

static pj_status_t record_serializer ( pjsip_tx_data *  tdata)
static

Definition at line 74 of file pjsip_distributor.c.

75{
77
79 if (serializer) {
80 const char *name;
81
84 && (!tdata->mod_data[distributor_mod.id]
85 || strcmp(tdata->mod_data[distributor_mod.id], name))) {
86 char *tdata_name;
87
88 /* The serializer in use changed. */
89 tdata_name = pj_pool_alloc(tdata->pool, strlen(name) + 1);
90 strcpy(tdata_name, name);/* Safe */
91
92 tdata->mod_data[distributor_mod.id] = tdata_name;
93 }
94 }
95
96 return PJ_SUCCESS;
97}
struct ast_taskprocessor * ast_threadpool_serializer_get_current(void)
Get the threadpool serializer currently associated with this thread.
Definition: threadpool.c:1393

References ast_strlen_zero(), ast_taskprocessor_name(), ast_threadpool_serializer_get_current(), distributor_mod, and name.

◆ suspects_compare()

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

Definition at line 999 of file pjsip_distributor.c.

1000{
1001 const struct unidentified_request *object_left = obj;
1002 const struct unidentified_request *object_right = arg;
1003 const char *right_key = arg;
1004 int cmp = 0;
1005
1006 switch (flags & OBJ_SEARCH_MASK) {
1007 case OBJ_SEARCH_OBJECT:
1008 right_key = object_right->src_name;
1009 /* Fall through */
1010 case OBJ_SEARCH_KEY:
1011 if (strcmp(object_left->src_name, right_key) == 0) {
1012 cmp = CMP_MATCH;
1013 }
1014 break;
1016 if (strncmp(object_left->src_name, right_key, strlen(right_key)) == 0) {
1017 cmp = CMP_MATCH;
1018 }
1019 break;
1020 default:
1021 cmp = 0;
1022 break;
1023 }
1024 return cmp;
1025}

References CMP_MATCH, OBJ_SEARCH_KEY, OBJ_SEARCH_MASK, OBJ_SEARCH_OBJECT, OBJ_SEARCH_PARTIAL_KEY, and unidentified_request::src_name.

Referenced by ast_sip_initialize_distributor(), and cli_unid_get_container().

◆ suspects_hash()

static int suspects_hash ( const void *  obj,
int  flags 
)
static

Definition at line 1027 of file pjsip_distributor.c.

1028{
1029 const struct unidentified_request *object;
1030 const char *key;
1031
1032 switch (flags & OBJ_SEARCH_MASK) {
1033 case OBJ_SEARCH_KEY:
1034 key = obj;
1035 break;
1036 case OBJ_SEARCH_OBJECT:
1037 object = obj;
1038 key = object->src_name;
1039 break;
1040 default:
1041 /* Hash can only work on something with a full key. */
1042 ast_assert(0);
1043 return 0;
1044 }
1045 return ast_str_hash(key);
1046}
static force_inline int attribute_pure ast_str_hash(const char *str)
Compute a hash value on a string.
Definition: strings.h:1259

References ast_assert, ast_str_hash(), OBJ_SEARCH_KEY, OBJ_SEARCH_MASK, and OBJ_SEARCH_OBJECT.

Referenced by ast_sip_initialize_distributor().

◆ suspects_sort()

static int suspects_sort ( const void *  obj,
const void *  arg,
int  flags 
)
static

Definition at line 975 of file pjsip_distributor.c.

976{
977 const struct unidentified_request *object_left = obj;
978 const struct unidentified_request *object_right = arg;
979 const char *right_key = arg;
980 int cmp;
981
982 switch (flags & OBJ_SEARCH_MASK) {
984 right_key = object_right->src_name;
985 /* Fall through */
986 case OBJ_SEARCH_KEY:
987 cmp = strcmp(object_left->src_name, right_key);
988 break;
990 cmp = strncmp(object_left->src_name, right_key, strlen(right_key));
991 break;
992 default:
993 cmp = 0;
994 break;
995 }
996 return cmp;
997}

References OBJ_SEARCH_KEY, OBJ_SEARCH_MASK, OBJ_SEARCH_OBJECT, OBJ_SEARCH_PARTIAL_KEY, and unidentified_request::src_name.

Referenced by cli_unid_get_container().

Variable Documentation

◆ artificial_endpoint

struct ast_sip_endpoint* artificial_endpoint = NULL
static

◆ auth_mod

pjsip_module auth_mod
static
Initial value:
= {
.name = {"Request Authenticator", 21},
.priority = PJSIP_MOD_PRIORITY_APPLICATION - 2,
.on_rx_request = authenticate,
}
static pj_bool_t authenticate(pjsip_rx_data *rdata)

Definition at line 934 of file pjsip_distributor.c.

Referenced by ast_sip_destroy_distributor(), and ast_sip_initialize_distributor().

◆ cli_commands

struct ast_cli_entry cli_commands[]
static

◆ dialog_associations

struct ao2_container* dialog_associations
static

◆ distributor_mod

pjsip_module distributor_mod
static

◆ distributor_pool

struct ast_taskprocessor* distributor_pool[DISTRIBUTOR_POOL_SIZE]
static

Pool of serializers to use if not supplied.

Definition at line 63 of file pjsip_distributor.c.

Referenced by ast_sip_get_distributor_serializer(), distributor_pool_setup(), and distributor_pool_shutdown().

◆ endpoint_mod

pjsip_module endpoint_mod
static
Initial value:
= {
.name = {"Endpoint Identifier", 19},
.priority = PJSIP_MOD_PRIORITY_TSX_LAYER - 3,
.on_rx_request = endpoint_lookup,
}
static pj_bool_t endpoint_lookup(pjsip_rx_data *rdata)

Definition at line 476 of file pjsip_distributor.c.

Referenced by apply_acls(), ast_pjsip_rdata_get_endpoint(), ast_sip_destroy_distributor(), ast_sip_initialize_distributor(), distribute(), distributor(), and endpoint_lookup().

◆ global_observer

struct ast_sorcery_observer global_observer
static
Initial value:
= {
.loaded = global_loaded,
}
static void global_loaded(const char *object_type)

Observer which is used to update our interval and default_realm when the global setting changes.

Definition at line 1211 of file pjsip_distributor.c.

Referenced by ast_sip_destroy_distributor(), and ast_sip_initialize_distributor().

◆ overload_trigger

enum ast_sip_taskprocessor_overload_trigger overload_trigger
static

Definition at line 51 of file pjsip_distributor.c.

Referenced by distributor(), and global_loaded().

◆ prune_context

struct ast_sched_context* prune_context

◆ unid_formatter

struct ast_sip_cli_formatter_entry* unid_formatter

◆ unidentified_count

unsigned int unidentified_count
static

Definition at line 47 of file pjsip_distributor.c.

Referenced by check_endpoint(), global_loaded(), and prune_task().

◆ unidentified_period

unsigned int unidentified_period
static

Definition at line 48 of file pjsip_distributor.c.

Referenced by check_endpoint(), global_loaded(), and prune_task().

◆ unidentified_prune_interval

unsigned int unidentified_prune_interval
static

Definition at line 49 of file pjsip_distributor.c.

Referenced by global_loaded(), and prune_task().

◆ unidentified_requests

struct ao2_container* unidentified_requests
static

◆ using_auth_username

int using_auth_username
static

Definition at line 50 of file pjsip_distributor.c.

Referenced by endpoint_lookup(), and global_loaded().