Asterisk
/
asterisk
mirror of https://github.com/asterisk/asterisk
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge "res_pjsip: Filter out non SIP(S) requests" into 13

Browse Source
certified/13.18
Jenkins2 8 years ago committed by Gerrit Code Review
parent 14109355f3 63900374fa
commit b6e1b13de4
7 changed files with 204 additions and 78 deletions
Show Stats Download Patch File Download Diff File

2
configs/samples/pjsip.conf.sample
Unescape View File

@ -1123,7 +1123,7 @@
; MODULE PROVIDING BELOW SECTION(S): res_pjsip_outbound_publish ; MODULE PROVIDING BELOW SECTION(S): res_pjsip_outbound_publish
;======================OUTBOUND_PUBLISHEN SECTION OPTIONS===================== ;======================OUTBOUND_PUBLISH SECTION OPTIONS=====================
; See https://wiki.asterisk.org/wiki/display/AST/Publishing+Extension+State ; See https://wiki.asterisk.org/wiki/display/AST/Publishing+Extension+State
; for more information. ; for more information.
;[outbound-publish] ;[outbound-publish]

4
res/res_pjsip.c
Unescape View File

@ -4589,7 +4589,7 @@ static int unload_pjsip(void *data)
if (ast_pjsip_endpoint && serializer_pool[0]) { if (ast_pjsip_endpoint && serializer_pool[0]) {
ast_res_pjsip_cleanup_options_handling(); ast_res_pjsip_cleanup_options_handling();
internal_sip_destroy_outbound_authentication(); internal_sip_destroy_outbound_authentication();
ast_res_pjsip_cleanup_message_ip_updater(); ast_res_pjsip_cleanup_message_filter();
ast_sip_destroy_distributor(); ast_sip_destroy_distributor();
ast_res_pjsip_destroy_configuration(); ast_res_pjsip_destroy_configuration();
ast_sip_destroy_system(); ast_sip_destroy_system();
@ -4770,7 +4770,7 @@ static int load_module(void)
ast_res_pjsip_init_options_handling(0); ast_res_pjsip_init_options_handling(0);
if (ast_res_pjsip_init_message_ip_updater()) { if (ast_res_pjsip_init_message_filter()) {
ast_log(LOG_ERROR, "Failed to initialize message IP updating. Aborting load\n"); ast_log(LOG_ERROR, "Failed to initialize message IP updating. Aborting load\n");
goto error; goto error;
} }

4
res/res_pjsip/include/res_pjsip_private.h
Unescape View File

@ -212,7 +212,7 @@ int ast_res_pjsip_init_options_handling(int reload);
* \retval 0 on success * \retval 0 on success
* \retval other on failure * \retval other on failure
*/ */
int ast_res_pjsip_init_message_ip_updater(void); int ast_res_pjsip_init_message_filter(void);
/*! /*!
* \internal * \internal
@ -281,7 +281,7 @@ void ast_res_pjsip_cleanup_options_handling(void);
* \internal * \internal
* \brief Clean up res_pjsip message ip updating handling * \brief Clean up res_pjsip message ip updating handling
*/ */
void ast_res_pjsip_cleanup_message_ip_updater(void); void ast_res_pjsip_cleanup_message_filter(void);
/*! /*!
* \internal * \internal

2
res/res_pjsip/location.c
Unescape View File

@ -620,7 +620,7 @@ static int permanent_uri_handler(const struct aco_option *opt, struct ast_variab
} }
if (ast_sip_validate_uri_length(contact_uri)) { if (ast_sip_validate_uri_length(contact_uri)) {
ast_log(LOG_ERROR, "Contact uri or hostname length exceeds pjproject limit: %s\n", contact_uri); ast_log(LOG_ERROR, "Contact uri or hostname length exceeds pjproject limit or is not a sip(s) uri: %s\n", contact_uri);
return -1; return -1;
} }

248
res/res_pjsip/pjsip_message_ip_updater.c → res/res_pjsip/pjsip_message_filter.c
Unescape View File

@ -27,72 +27,72 @@
#define MOD_DATA_RESTRICTIONS "restrictions" #define MOD_DATA_RESTRICTIONS "restrictions"
static pj_status_t multihomed_on_tx_message(pjsip_tx_data *tdata); static pj_status_t filter_on_tx_message(pjsip_tx_data *tdata);
static pj_bool_t multihomed_on_rx_message(pjsip_rx_data *rdata); static pj_bool_t filter_on_rx_message(pjsip_rx_data *rdata);
/*! \brief Outgoing message modification restrictions */ /*! \brief Outgoing message modification restrictions */
struct multihomed_message_restrictions { struct filter_message_restrictions {
/*! \brief Disallow modification of the From domain */ /*! \brief Disallow modification of the From domain */
unsigned int disallow_from_domain_modification; unsigned int disallow_from_domain_modification;
}; };
static pjsip_module multihomed_module = { static pjsip_module filter_module = {
.name = { "Multihomed Routing", 18 }, .name = { "Message Filtering", 17 },
.id = -1, .id = -1,
.priority = PJSIP_MOD_PRIORITY_TSX_LAYER - 1, .priority = PJSIP_MOD_PRIORITY_TRANSPORT_LAYER,
.on_tx_request = multihomed_on_tx_message, .on_tx_request = filter_on_tx_message,
.on_tx_response = multihomed_on_tx_message, .on_tx_response = filter_on_tx_message,
.on_rx_request = multihomed_on_rx_message, .on_rx_request = filter_on_rx_message,
}; };
/*! \brief Helper function to get (or allocate if not already present) restrictions on a message */ /*! \brief Helper function to get (or allocate if not already present) restrictions on a message */
static struct multihomed_message_restrictions *multihomed_get_restrictions(pjsip_tx_data *tdata) static struct filter_message_restrictions *get_restrictions(pjsip_tx_data *tdata)
{ {
struct multihomed_message_restrictions *restrictions; struct filter_message_restrictions *restrictions;
restrictions = ast_sip_mod_data_get(tdata->mod_data, multihomed_module.id, MOD_DATA_RESTRICTIONS); restrictions = ast_sip_mod_data_get(tdata->mod_data, filter_module.id, MOD_DATA_RESTRICTIONS);
if (restrictions) { if (restrictions) {
return restrictions; return restrictions;
} }
restrictions = PJ_POOL_ALLOC_T(tdata->pool, struct multihomed_message_restrictions); restrictions = PJ_POOL_ALLOC_T(tdata->pool, struct filter_message_restrictions);
ast_sip_mod_data_set(tdata->pool, tdata->mod_data, multihomed_module.id, MOD_DATA_RESTRICTIONS, restrictions); ast_sip_mod_data_set(tdata->pool, tdata->mod_data, filter_module.id, MOD_DATA_RESTRICTIONS, restrictions);
return restrictions; return restrictions;
} }
/*! \brief Callback invoked on non-session outgoing messages */ /*! \brief Callback invoked on non-session outgoing messages */
static void multihomed_outgoing_message(struct ast_sip_endpoint *endpoint, struct ast_sip_contact *contact, struct pjsip_tx_data *tdata) static void filter_outgoing_message(struct ast_sip_endpoint *endpoint, struct ast_sip_contact *contact, struct pjsip_tx_data *tdata)
{ {
struct multihomed_message_restrictions *restrictions = multihomed_get_restrictions(tdata); struct filter_message_restrictions *restrictions = get_restrictions(tdata);
restrictions->disallow_from_domain_modification = !ast_strlen_zero(endpoint->fromdomain); restrictions->disallow_from_domain_modification = !ast_strlen_zero(endpoint->fromdomain);
} }
/*! \brief PJSIP Supplement for tagging messages with restrictions */ /*! \brief PJSIP Supplement for tagging messages with restrictions */
static struct ast_sip_supplement multihomed_supplement = { static struct ast_sip_supplement filter_supplement = {
.priority = AST_SIP_SUPPLEMENT_PRIORITY_FIRST, .priority = AST_SIP_SUPPLEMENT_PRIORITY_FIRST,
.outgoing_request = multihomed_outgoing_message, .outgoing_request = filter_outgoing_message,
.outgoing_response = multihomed_outgoing_message, .outgoing_response = filter_outgoing_message,
}; };
/*! \brief Callback invoked on session outgoing messages */ /*! \brief Callback invoked on session outgoing messages */
static void multihomed_session_outgoing_message(struct ast_sip_session *session, struct pjsip_tx_data *tdata) static void filter_session_outgoing_message(struct ast_sip_session *session, struct pjsip_tx_data *tdata)
{ {
struct multihomed_message_restrictions *restrictions = multihomed_get_restrictions(tdata); struct filter_message_restrictions *restrictions = get_restrictions(tdata);
restrictions->disallow_from_domain_modification = !ast_strlen_zero(session->endpoint->fromdomain); restrictions->disallow_from_domain_modification = !ast_strlen_zero(session->endpoint->fromdomain);
} }
/*! \brief PJSIP Session Supplement for tagging messages with restrictions */ /*! \brief PJSIP Session Supplement for tagging messages with restrictions */
static struct ast_sip_session_supplement multihomed_session_supplement = { static struct ast_sip_session_supplement filter_session_supplement = {
.priority = 1, .priority = 1,
.outgoing_request = multihomed_session_outgoing_message, .outgoing_request = filter_session_outgoing_message,
.outgoing_response = multihomed_session_outgoing_message, .outgoing_response = filter_session_outgoing_message,
}; };
/*! \brief Helper function which returns a UDP transport bound to the given address and port */ /*! \brief Helper function which returns a UDP transport bound to the given address and port */
static pjsip_transport *multihomed_get_udp_transport(pj_str_t *address, int port) static pjsip_transport *get_udp_transport(pj_str_t *address, int port)
{ {
struct ao2_container *transport_states = ast_sip_get_transport_states(); struct ao2_container *transport_states = ast_sip_get_transport_states();
struct ast_sip_transport_state *transport_state; struct ast_sip_transport_state *transport_state;
@ -121,7 +121,7 @@ static pjsip_transport *multihomed_get_udp_transport(pj_str_t *address, int port
} }
/*! \brief Helper function which determines if a transport is bound to any */ /*! \brief Helper function which determines if a transport is bound to any */
static int multihomed_bound_any(pjsip_transport *transport) static int is_bound_any(pjsip_transport *transport)
{ {
pj_uint32_t loop6[4] = {0, 0, 0, 0}; pj_uint32_t loop6[4] = {0, 0, 0, 0};
@ -156,6 +156,19 @@ static int multihomed_rewrite_sdp(struct pjmedia_sdp_session *sdp)
#define is_sip_uri(uri) \ #define is_sip_uri(uri) \
(PJSIP_URI_SCHEME_IS_SIP(uri) || PJSIP_URI_SCHEME_IS_SIPS(uri)) (PJSIP_URI_SCHEME_IS_SIP(uri) || PJSIP_URI_SCHEME_IS_SIPS(uri))
static void print_sanitize_debug(char *msg, pjsip_uri_context_e context, pjsip_sip_uri *uri)
{
#ifdef AST_DEVMODE
char hdrbuf[512];
int hdrbuf_len;
hdrbuf_len = pjsip_uri_print(context, uri, hdrbuf, 512);
hdrbuf[hdrbuf_len] = '\0';
ast_debug(2, "%s: %s\n", msg, hdrbuf);
#endif
}
/* If in DEVMODE, prevent inlining to assist in debugging */
#ifdef AST_DEVMODE #ifdef AST_DEVMODE
#define FUNC_ATTRS __attribute__ ((noinline)) #define FUNC_ATTRS __attribute__ ((noinline))
#else #else
@ -167,21 +180,12 @@ static void FUNC_ATTRS sanitize_tdata(pjsip_tx_data *tdata)
static const pj_str_t x_name = { AST_SIP_X_AST_TXP, AST_SIP_X_AST_TXP_LEN }; static const pj_str_t x_name = { AST_SIP_X_AST_TXP, AST_SIP_X_AST_TXP_LEN };
pjsip_param *x_transport; pjsip_param *x_transport;
pjsip_sip_uri *uri; pjsip_sip_uri *uri;
pjsip_fromto_hdr *fromto;
pjsip_contact_hdr *contact;
pjsip_hdr *hdr; pjsip_hdr *hdr;
#ifdef AST_DEVMODE
char hdrbuf[512];
int hdrbuf_len;
#endif
if (tdata->msg->type == PJSIP_REQUEST_MSG) { if (tdata->msg->type == PJSIP_REQUEST_MSG) {
if (is_sip_uri(tdata->msg->line.req.uri)) { if (is_sip_uri(tdata->msg->line.req.uri)) {
uri = pjsip_uri_get_uri(tdata->msg->line.req.uri); uri = pjsip_uri_get_uri(tdata->msg->line.req.uri);
#ifdef AST_DEVMODE print_sanitize_debug("Sanitizing Request", PJSIP_URI_IN_REQ_URI, uri);
hdrbuf_len = pjsip_uri_print(PJSIP_URI_IN_REQ_URI, uri, hdrbuf, 512);
ast_debug(2, "Sanitizing Request: %s\n", hdrbuf);
#endif
while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) { while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) {
pj_list_erase(x_transport); pj_list_erase(x_transport);
} }
@ -190,27 +194,17 @@ static void FUNC_ATTRS sanitize_tdata(pjsip_tx_data *tdata)
for (hdr = tdata->msg->hdr.next; hdr != &tdata->msg->hdr; hdr = hdr->next) { for (hdr = tdata->msg->hdr.next; hdr != &tdata->msg->hdr; hdr = hdr->next) {
if (hdr->type == PJSIP_H_TO || hdr->type == PJSIP_H_FROM) { if (hdr->type == PJSIP_H_TO || hdr->type == PJSIP_H_FROM) {
fromto = (pjsip_fromto_hdr *) hdr; if (is_sip_uri(((pjsip_fromto_hdr *) hdr)->uri)) {
if (is_sip_uri(fromto->uri)) { uri = pjsip_uri_get_uri(((pjsip_fromto_hdr *) hdr)->uri);
uri = pjsip_uri_get_uri(fromto->uri); print_sanitize_debug("Sanitizing From/To header", PJSIP_URI_IN_FROMTO_HDR, uri);
#ifdef AST_DEVMODE
hdrbuf_len = pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, uri, hdrbuf, 512);
hdrbuf[hdrbuf_len] = '\0';
ast_debug(2, "Sanitizing From/To: %s\n", hdrbuf);
#endif
while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) { while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) {
pj_list_erase(x_transport); pj_list_erase(x_transport);
} }
} }
} else if (hdr->type == PJSIP_H_CONTACT) { } else if (hdr->type == PJSIP_H_CONTACT) {
contact = (pjsip_contact_hdr *) hdr; if (!((pjsip_contact_hdr *) hdr)->star && is_sip_uri(((pjsip_contact_hdr *) hdr)->uri)) {
if (is_sip_uri(contact->uri)) { uri = pjsip_uri_get_uri(((pjsip_contact_hdr *) hdr)->uri);
uri = pjsip_uri_get_uri(contact->uri); print_sanitize_debug("Sanitizing Contact header", PJSIP_URI_IN_CONTACT_HDR, uri);
#ifdef AST_DEVMODE
hdrbuf_len = pjsip_uri_print(PJSIP_URI_IN_CONTACT_HDR, uri, hdrbuf, 512);
hdrbuf[hdrbuf_len] = '\0';
ast_debug(2, "Sanitizing Contact: %s\n", hdrbuf);
#endif
while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) { while ((x_transport = pjsip_param_find(&uri->other_param, &x_name))) {
pj_list_erase(x_transport); pj_list_erase(x_transport);
} }
@ -221,9 +215,9 @@ static void FUNC_ATTRS sanitize_tdata(pjsip_tx_data *tdata)
pjsip_tx_data_invalidate_msg(tdata); pjsip_tx_data_invalidate_msg(tdata);
} }
static pj_status_t multihomed_on_tx_message(pjsip_tx_data *tdata) static pj_status_t filter_on_tx_message(pjsip_tx_data *tdata)
{ {
struct multihomed_message_restrictions *restrictions = ast_sip_mod_data_get(tdata->mod_data, multihomed_module.id, MOD_DATA_RESTRICTIONS); struct filter_message_restrictions *restrictions = ast_sip_mod_data_get(tdata->mod_data, filter_module.id, MOD_DATA_RESTRICTIONS);
pjsip_tpmgr_fla2_param prm; pjsip_tpmgr_fla2_param prm;
pjsip_cseq_hdr *cseq; pjsip_cseq_hdr *cseq;
pjsip_via_hdr *via; pjsip_via_hdr *via;
@ -256,7 +250,7 @@ static pj_status_t multihomed_on_tx_message(pjsip_tx_data *tdata)
tdata->tp_info.transport->key.type == PJSIP_TRANSPORT_UDP6) { tdata->tp_info.transport->key.type == PJSIP_TRANSPORT_UDP6) {
pjsip_transport *transport; pjsip_transport *transport;
transport = multihomed_get_udp_transport(&prm.ret_addr, prm.ret_port); transport = get_udp_transport(&prm.ret_addr, prm.ret_port);
if (transport) { if (transport) {
tdata->tp_info.transport = transport; tdata->tp_info.transport = transport;
@ -264,7 +258,7 @@ static pj_status_t multihomed_on_tx_message(pjsip_tx_data *tdata)
} }
/* If the chosen transport is not bound to any we can't use the source address as it won't get back to us */ /* If the chosen transport is not bound to any we can't use the source address as it won't get back to us */
if (!multihomed_bound_any(tdata->tp_info.transport)) { if (!is_bound_any(tdata->tp_info.transport)) {
pj_strassign(&prm.ret_addr, &tdata->tp_info.transport->local_name.host); pj_strassign(&prm.ret_addr, &tdata->tp_info.transport->local_name.host);
} }
} else { } else {
@ -345,7 +339,104 @@ static pj_status_t multihomed_on_tx_message(pjsip_tx_data *tdata)
return PJ_SUCCESS; return PJ_SUCCESS;
} }
static pj_bool_t multihomed_on_rx_message(pjsip_rx_data *rdata) enum uri_type {
URI_TYPE_REQUEST = -1,
URI_TYPE_TO = PJSIP_H_TO,
URI_TYPE_FROM = PJSIP_H_FROM,
URI_TYPE_CONTACT = PJSIP_H_CONTACT,
};
static void print_uri_debug(enum uri_type ut, pjsip_rx_data *rdata, pjsip_hdr *hdr)
{
#ifdef AST_DEVMODE
pjsip_uri *local_uri = NULL;
char hdrbuf[512];
int hdrbuf_len;
char *request_uri;
pjsip_uri_context_e context = PJSIP_URI_IN_OTHER;
char header_name[32];
switch (ut) {
case(URI_TYPE_REQUEST):
context = PJSIP_URI_IN_REQ_URI;
strcpy(header_name, "Request"); /* Safe */
local_uri = rdata->msg_info.msg->line.req.uri;
break;
case(PJSIP_H_FROM):
strcpy(header_name, "From"); /* Safe */
context = PJSIP_URI_IN_FROMTO_HDR;
local_uri = pjsip_uri_get_uri(((pjsip_from_hdr *)hdr)->uri);
break;
case(PJSIP_H_TO):
strcpy(header_name, "To"); /* Safe */
context = PJSIP_URI_IN_FROMTO_HDR;
local_uri = pjsip_uri_get_uri(((pjsip_to_hdr *)hdr)->uri);
break;
case(PJSIP_H_CONTACT):
strcpy(header_name, "Contact"); /* Safe */
context = PJSIP_URI_IN_CONTACT_HDR;
local_uri = pjsip_uri_get_uri(((pjsip_contact_hdr *)hdr)->uri);
break;
}
hdrbuf_len = pjsip_uri_print(PJSIP_URI_IN_REQ_URI, rdata->msg_info.msg->line.req.uri, hdrbuf, 512);
hdrbuf[hdrbuf_len] = '\0';
request_uri = ast_strdupa(hdrbuf);
hdrbuf_len = pjsip_uri_print(context, local_uri, hdrbuf, 512);
hdrbuf[hdrbuf_len] = '\0';
ast_debug(2, "There was a non sip(s) URI scheme in %s URI '%s' for request '%*.*s %s'\n",
header_name, hdrbuf,
(int)rdata->msg_info.msg->line.req.method.name.slen,
(int)rdata->msg_info.msg->line.req.method.name.slen,
rdata->msg_info.msg->line.req.method.name.ptr, request_uri);
#endif
}
static pj_bool_t on_rx_process_uris(pjsip_rx_data *rdata)
{
pjsip_contact_hdr *contact = NULL;
if (rdata->msg_info.msg->type != PJSIP_REQUEST_MSG) {
return PJ_FALSE;
}
if (!is_sip_uri(rdata->msg_info.msg->line.req.uri)) {
print_uri_debug(URI_TYPE_REQUEST, rdata, NULL);
pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
PJSIP_SC_UNSUPPORTED_URI_SCHEME, NULL, NULL, NULL);
return PJ_TRUE;
}
if (!is_sip_uri(rdata->msg_info.from->uri)) {
print_uri_debug(URI_TYPE_FROM, rdata, (pjsip_hdr *)rdata->msg_info.from);
pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
PJSIP_SC_UNSUPPORTED_URI_SCHEME, NULL, NULL, NULL);
return PJ_TRUE;
}
if (!is_sip_uri(rdata->msg_info.to->uri)) {
print_uri_debug(URI_TYPE_TO, rdata, (pjsip_hdr *)rdata->msg_info.to);
pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
PJSIP_SC_UNSUPPORTED_URI_SCHEME, NULL, NULL, NULL);
return PJ_TRUE;
}
while ((contact =
(pjsip_contact_hdr *) pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_CONTACT,
contact ? contact->next : NULL))) {
if (!contact->star && !is_sip_uri(contact->uri)) {
print_uri_debug(URI_TYPE_CONTACT, rdata, (pjsip_hdr *)contact);
pjsip_endpt_respond_stateless(ast_sip_get_pjsip_endpoint(), rdata,
PJSIP_SC_UNSUPPORTED_URI_SCHEME, NULL, NULL, NULL);
return PJ_TRUE;
}
}
return PJ_FALSE;
}
static pj_bool_t on_rx_process_symmetric_transport(pjsip_rx_data *rdata)
{ {
pjsip_contact_hdr *contact; pjsip_contact_hdr *contact;
pjsip_sip_uri *uri; pjsip_sip_uri *uri;
@ -388,29 +479,46 @@ static pj_bool_t multihomed_on_rx_message(pjsip_rx_data *rdata)
return PJ_FALSE; return PJ_FALSE;
} }
void ast_res_pjsip_cleanup_message_ip_updater(void) static pj_bool_t filter_on_rx_message(pjsip_rx_data *rdata)
{
pj_bool_t rc;
rc = on_rx_process_uris(rdata);
if (rc == PJ_TRUE) {
return rc;
}
rc = on_rx_process_symmetric_transport(rdata);
if (rc == PJ_TRUE) {
return rc;
}
return PJ_FALSE;
}
void ast_res_pjsip_cleanup_message_filter(void)
{ {
ast_sip_unregister_service(&multihomed_module); ast_sip_unregister_service(&filter_module);
ast_sip_unregister_supplement(&multihomed_supplement); ast_sip_unregister_supplement(&filter_supplement);
ast_sip_session_unregister_supplement(&multihomed_session_supplement); ast_sip_session_unregister_supplement(&filter_session_supplement);
} }
int ast_res_pjsip_init_message_ip_updater(void) int ast_res_pjsip_init_message_filter(void)
{ {
if (ast_sip_session_register_supplement(&multihomed_session_supplement)) { if (ast_sip_session_register_supplement(&filter_session_supplement)) {
ast_log(LOG_ERROR, "Could not register multihomed session supplement for outgoing requests\n"); ast_log(LOG_ERROR, "Could not register message filter session supplement for outgoing requests\n");
return -1; return -1;
} }
if (ast_sip_register_supplement(&multihomed_supplement)) { if (ast_sip_register_supplement(&filter_supplement)) {
ast_log(LOG_ERROR, "Could not register multihomed supplement for outgoing requests\n"); ast_log(LOG_ERROR, "Could not register message filter supplement for outgoing requests\n");
ast_res_pjsip_cleanup_message_ip_updater(); ast_res_pjsip_cleanup_message_filter();
return -1; return -1;
} }
if (ast_sip_register_service(&multihomed_module)) { if (ast_sip_register_service(&filter_module)) {
ast_log(LOG_ERROR, "Could not register multihomed module for incoming and outgoing requests\n"); ast_log(LOG_ERROR, "Could not register message filter module for incoming and outgoing requests\n");
ast_res_pjsip_cleanup_message_ip_updater(); ast_res_pjsip_cleanup_message_filter();
return -1; return -1;
} }

18
res/res_pjsip_outbound_publish.c
Unescape View File

@ -33,6 +33,7 @@
#include "asterisk/taskprocessor.h" #include "asterisk/taskprocessor.h"
#include "asterisk/threadpool.h" #include "asterisk/threadpool.h"
#include "asterisk/datastore.h" #include "asterisk/datastore.h"
#include "res_pjsip/include/res_pjsip_private.h"
/*** DOCUMENTATION /*** DOCUMENTATION
<configInfo name="res_pjsip_outbound_publish" language="en_US"> <configInfo name="res_pjsip_outbound_publish" language="en_US">
@ -1115,10 +1116,27 @@ static int validate_publish_config(struct ast_sip_outbound_publish *publish)
ast_log(LOG_ERROR, "No server URI specified on outbound publish '%s'\n", ast_log(LOG_ERROR, "No server URI specified on outbound publish '%s'\n",
ast_sorcery_object_get_id(publish)); ast_sorcery_object_get_id(publish));
return -1; return -1;
} else if (ast_sip_validate_uri_length(publish->server_uri)) {
ast_log(LOG_ERROR, "Server URI or hostname length exceeds pjproject limit or is not a sip(s) uri: '%s' on outbound publish '%s'\n",
publish->server_uri,
ast_sorcery_object_get_id(publish));
return -1;
} else if (ast_strlen_zero(publish->event)) { } else if (ast_strlen_zero(publish->event)) {
ast_log(LOG_ERROR, "No event type specified for outbound publish '%s'\n", ast_log(LOG_ERROR, "No event type specified for outbound publish '%s'\n",
ast_sorcery_object_get_id(publish)); ast_sorcery_object_get_id(publish));
return -1; return -1;
} else if (!ast_strlen_zero(publish->from_uri)
&& ast_sip_validate_uri_length(publish->from_uri)) {
ast_log(LOG_ERROR, "From URI or hostname length exceeds pjproject limit or is not a sip(s) uri: '%s' on outbound publish '%s'\n",
publish->from_uri,
ast_sorcery_object_get_id(publish));
return -1;
} else if (!ast_strlen_zero(publish->to_uri)
&& ast_sip_validate_uri_length(publish->to_uri)) {
ast_log(LOG_ERROR, "To URI or hostname length exceeds pjproject limit or is not a sip(s) uri: '%s' on outbound publish '%s'\n",
publish->to_uri,
ast_sorcery_object_get_id(publish));
return -1;
} }
return 0; return 0;
} }

4
res/res_pjsip_outbound_registration.c
Unescape View File

@ -1429,7 +1429,7 @@ static int sip_outbound_registration_apply(const struct ast_sorcery *sorcery, vo
ast_sorcery_object_get_id(applied)); ast_sorcery_object_get_id(applied));
return -1; return -1;
} else if (ast_sip_validate_uri_length(applied->server_uri)) { } else if (ast_sip_validate_uri_length(applied->server_uri)) {
ast_log(LOG_ERROR, "Server URI or hostname length exceeds pjpropject limit '%s'\n", ast_log(LOG_ERROR, "Server URI or hostname length exceeds pjproject limit or is not a sip(s) uri: '%s'\n",
ast_sorcery_object_get_id(applied)); ast_sorcery_object_get_id(applied));
return -1; return -1;
} else if (ast_strlen_zero(applied->client_uri)) { } else if (ast_strlen_zero(applied->client_uri)) {
@ -1437,7 +1437,7 @@ static int sip_outbound_registration_apply(const struct ast_sorcery *sorcery, vo
ast_sorcery_object_get_id(applied)); ast_sorcery_object_get_id(applied));
return -1; return -1;
} else if (ast_sip_validate_uri_length(applied->client_uri)) { } else if (ast_sip_validate_uri_length(applied->client_uri)) {
ast_log(LOG_ERROR, "Client URI or hostname length exceeds pjpropject limit '%s'\n", ast_log(LOG_ERROR, "Client URI or hostname length exceeds pjproject limit or is not a sip(s) uri: '%s'\n",
ast_sorcery_object_get_id(applied)); ast_sorcery_object_get_id(applied));
return -1; return -1;
} else if (applied->line && ast_strlen_zero(applied->endpoint)) { } else if (applied->line && ast_strlen_zero(applied->endpoint)) {

Write Preview
Loading…
Cancel
Save