diff options
-rw-r--r-- | CHANGES | 9 | ||||
-rw-r--r-- | apps/app_record.c | 56 | ||||
-rw-r--r-- | channels/chan_pjsip.c | 25 | ||||
-rw-r--r-- | channels/iax2/parser.c | 4 | ||||
-rw-r--r-- | configs/samples/asterisk.conf.sample | 9 | ||||
-rw-r--r-- | include/asterisk/alertpipe.h | 3 | ||||
-rw-r--r-- | include/asterisk/options.h | 5 | ||||
-rw-r--r-- | include/asterisk/vector.h | 23 | ||||
-rw-r--r-- | main/asterisk.c | 13 | ||||
-rw-r--r-- | main/audiohook.c | 4 | ||||
-rw-r--r-- | main/frame.c | 19 | ||||
-rw-r--r-- | main/plc.c | 2 | ||||
-rw-r--r-- | menuselect/.gitignore | 1 | ||||
-rw-r--r-- | menuselect/aclocal.m4 | 296 | ||||
-rw-r--r-- | third-party/pjproject/patches/0010-r5665-svn-backport-ICE-Use-STUN-FINGERPRINT-attribut.patch | 41 | ||||
-rw-r--r-- | third-party/pjproject/patches/0020-sip_parser-Add-validity-checking-for-numeric-header-.patch | 973 | ||||
-rw-r--r-- | third-party/pjproject/patches/0021-sip_parser-Fix-return-code-in-pjsip_find_msg-and-add.patch | 41 | ||||
-rw-r--r-- | third-party/pjproject/patches/0030-sip_transport-Destroy-transports-not-in-hash.patch | 27 | ||||
-rw-r--r-- | third-party/versions.mak | 2 |
19 files changed, 208 insertions, 1345 deletions
@@ -12,6 +12,15 @@ --- Functionality changes from Asterisk 15.1.0 to Asterisk 15.2.0 ------------ ------------------------------------------------------------------------------ +Core +------------------ + * Added the "cache_media_frames" option to asterisk.conf. Disabling the option + helps track down media frame mismanagement when using valgrind or + MALLOC_DEBUG. The cache gets in the way of determining if the frame is + used after free and who freed it. NOTE: This option has no effect when + Asterisk is compiled with the LOW_MEMORY compile time option enabled because + the cache code does not exist. + res_rtp_asterisk ------------------ * The X.509 certificate used for DTLS negotation can now be automatically diff --git a/apps/app_record.c b/apps/app_record.c index 8c3a577ef..b9014fed7 100644 --- a/apps/app_record.c +++ b/apps/app_record.c @@ -137,6 +137,12 @@ enum { OPTION_NO_TRUNCATE = (1 << 9), }; +enum dtmf_response { + RESPONSE_NO_MATCH = 0, + RESPONSE_OPERATOR, + RESPONSE_DTMF, +}; + AST_APP_OPTIONS(app_opts,{ AST_APP_OPTION('a', OPTION_APPEND), AST_APP_OPTION('k', OPTION_KEEP), @@ -160,24 +166,22 @@ AST_APP_OPTIONS(app_opts,{ * \param dtmf_integer the integer value of the DTMF key received * \param terminator key currently set to be pressed for normal termination * - * \retval 0 do not exit - * \retval -1 do exit + * \returns One of enum dtmf_response */ -static int record_dtmf_response(struct ast_channel *chan, struct ast_flags *flags, int dtmf_integer, int terminator) +static enum dtmf_response record_dtmf_response(struct ast_channel *chan, + struct ast_flags *flags, int dtmf_integer, int terminator) { if ((dtmf_integer == OPERATOR_KEY) && (ast_test_flag(flags, OPTION_OPERATOR_EXIT))) { - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "OPERATOR"); - return -1; + return RESPONSE_OPERATOR; } if ((dtmf_integer == terminator) || (ast_test_flag(flags, OPTION_ANY_TERMINATE))) { - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "DTMF"); - return -1; + return RESPONSE_DTMF; } - return 0; + return RESPONSE_NO_MATCH; } static int create_destination_directory(const char *path) @@ -246,6 +250,7 @@ static int record_exec(struct ast_channel *chan, const char *data) ); int ms; struct timeval start; + const char *status_response = "ERROR"; /* The next few lines of code parse out the filename and header from the input string */ if (ast_strlen_zero(data)) { /* no data implies no filename or anything is present */ @@ -343,7 +348,7 @@ static int record_exec(struct ast_channel *chan, const char *data) if (res) { ast_log(LOG_WARNING, "Could not answer channel '%s'\n", ast_channel_name(chan)); - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "ERROR"); + status_response = "ERROR"; goto out; } @@ -379,7 +384,7 @@ static int record_exec(struct ast_channel *chan, const char *data) if (create_destination_directory(tmp)) { ast_log(LOG_WARNING, "Could not create directory for file %s\n", args.filename); - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "ERROR"); + status_response = "ERROR"; goto out; } @@ -388,7 +393,7 @@ static int record_exec(struct ast_channel *chan, const char *data) if (!s) { ast_log(LOG_WARNING, "Could not create file %s\n", args.filename); - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "ERROR"); + status_response = "ERROR"; goto out; } @@ -423,7 +428,7 @@ static int record_exec(struct ast_channel *chan, const char *data) if (res) { ast_log(LOG_WARNING, "Problem writing frame\n"); ast_frfree(f); - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "ERROR"); + status_response = "ERROR"; break; } @@ -439,7 +444,7 @@ static int record_exec(struct ast_channel *chan, const char *data) /* Ended happily with silence */ ast_frfree(f); gotsilence = 1; - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "SILENCE"); + status_response = "SILENCE"; break; } } @@ -448,12 +453,26 @@ static int record_exec(struct ast_channel *chan, const char *data) if (res) { ast_log(LOG_WARNING, "Problem writing frame\n"); - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "ERROR"); + status_response = "ERROR"; ast_frfree(f); break; } } else if (f->frametype == AST_FRAME_DTMF) { - if (record_dtmf_response(chan, &flags, f->subclass.integer, terminator)) { + enum dtmf_response rc = + record_dtmf_response(chan, &flags, f->subclass.integer, terminator); + switch(rc) { + case RESPONSE_NO_MATCH: + break; + case RESPONSE_OPERATOR: + status_response = "OPERATOR"; + ast_debug(1, "Got OPERATOR\n"); + break; + case RESPONSE_DTMF: + status_response = "DTMF"; + ast_debug(1, "Got DTMF\n"); + break; + } + if (rc != RESPONSE_NO_MATCH) { ast_frfree(f); break; } @@ -463,13 +482,13 @@ static int record_exec(struct ast_channel *chan, const char *data) if (maxduration > 0 && !ms) { gottimeout = 1; - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "TIMEOUT"); + status_response = "TIMEOUT"; } if (!f) { ast_debug(1, "Got hangup\n"); res = -1; - pbx_builtin_setvar_helper(chan, "RECORD_STATUS", "HANGUP"); + status_response = "HANGUP"; if (!ast_test_flag(&flags, OPTION_KEEP)) { ast_filedelete(args.filename, NULL); } @@ -504,6 +523,9 @@ out: if (sildet) { ast_dsp_free(sildet); } + + pbx_builtin_setvar_helper(chan, "RECORD_STATUS", status_response); + return res; } diff --git a/channels/chan_pjsip.c b/channels/chan_pjsip.c index 0160425e6..e4e8fa586 100644 --- a/channels/chan_pjsip.c +++ b/channels/chan_pjsip.c @@ -672,7 +672,19 @@ static int answer(void *data) pjsip_inv_dec_ref(session->inv_session); #endif - return (status == PJ_SUCCESS) ? 0 : -1; + if (status != PJ_SUCCESS) { + char err[PJ_ERR_MSG_SIZE]; + + pj_strerror(status, err, sizeof(err)); + ast_log(LOG_WARNING,"Cannot answer '%s': %s\n", + ast_channel_name(session->channel), err); + /* + * Return this value so we can distinguish between this + * failure and the threadpool synchronous push failing. + */ + return -2; + } + return 0; } /*! \brief Function called by core when we should answer a PJSIP session */ @@ -680,6 +692,7 @@ static int chan_pjsip_answer(struct ast_channel *ast) { struct ast_sip_channel_pvt *channel = ast_channel_tech_pvt(ast); struct ast_sip_session *session; + int res; if (ast_channel_state(ast) == AST_STATE_UP) { return 0; @@ -700,11 +713,15 @@ static int chan_pjsip_answer(struct ast_channel *ast) can occur between this thread and bridging (specifically when native bridging attempts to do direct media) */ ast_channel_unlock(ast); - if (ast_sip_push_task_synchronous(session->serializer, answer, session)) { - ast_log(LOG_WARNING, "Unable to push answer task to the threadpool. Cannot answer call\n"); + res = ast_sip_push_task_synchronous(session->serializer, answer, session); + if (res) { + if (res == -1) { + ast_log(LOG_ERROR,"Cannot answer '%s': Unable to push answer task to the threadpool.\n", + ast_channel_name(session->channel)); #ifdef HAVE_PJSIP_INV_SESSION_REF - pjsip_inv_dec_ref(session->inv_session); + pjsip_inv_dec_ref(session->inv_session); #endif + } ao2_ref(session, -1); ast_channel_lock(ast); return -1; diff --git a/channels/iax2/parser.c b/channels/iax2/parser.c index ec9d34608..6eda98260 100644 --- a/channels/iax2/parser.c +++ b/channels/iax2/parser.c @@ -1296,7 +1296,9 @@ void iax_frame_free(struct iax_frame *fr) ast_atomic_fetchadd_int(&frames, -1); #if !defined(LOW_MEMORY) - if (!fr->cacheable || !(iax_frames = ast_threadstorage_get(&frame_cache, sizeof(*iax_frames)))) { + if (!fr->cacheable + || !ast_opt_cache_media_frames + || !(iax_frames = ast_threadstorage_get(&frame_cache, sizeof(*iax_frames)))) { ast_free(fr); return; } diff --git a/configs/samples/asterisk.conf.sample b/configs/samples/asterisk.conf.sample index 30934e4a9..8379b6ef0 100644 --- a/configs/samples/asterisk.conf.sample +++ b/configs/samples/asterisk.conf.sample @@ -44,6 +44,15 @@ astsbindir => /usr/sbin ;minmemfree = 1 ; In MBs, Asterisk stops accepting new calls if ; the amount of free memory falls below this ; watermark. +;cache_media_frames = yes ; Cache media frames for performance + ; Disable this option to help track down media frame + ; mismanagement when using valgrind or MALLOC_DEBUG. + ; The cache gets in the way of determining if the + ; frame is used after being freed and who freed it. + ; NOTE: This option has no effect when Asterisk is + ; compiled with the LOW_MEMORY compile time option + ; enabled because the cache code does not exist. + ; Default yes ;cache_record_files = yes ; Cache recorded sound files to another ; directory during recording. ;record_cache_dir = /tmp ; Specify cache directory (used in conjunction diff --git a/include/asterisk/alertpipe.h b/include/asterisk/alertpipe.h index 5ff854ce8..09c335829 100644 --- a/include/asterisk/alertpipe.h +++ b/include/asterisk/alertpipe.h @@ -65,7 +65,8 @@ ast_alert_status_t ast_alertpipe_read(int alert_pipe[2]); * * \param p a two-element array containing the alert pipe's file descriptors * - * \return see write(2) + * \retval 0 Success + * \retval 1 Failure */ ssize_t ast_alertpipe_write(int alert_pipe[2]); diff --git a/include/asterisk/options.h b/include/asterisk/options.h index 0a20f10a8..878748d16 100644 --- a/include/asterisk/options.h +++ b/include/asterisk/options.h @@ -66,6 +66,8 @@ enum ast_option_flags { AST_OPT_FLAG_CACHE_RECORD_FILES = (1 << 13), /*! Display timestamp in CLI verbose output */ AST_OPT_FLAG_TIMESTAMP = (1 << 14), + /*! Cache media frames for performance */ + AST_OPT_FLAG_CACHE_MEDIA_FRAMES = (1 << 15), /*! Reconnect */ AST_OPT_FLAG_RECONNECT = (1 << 16), /*! Transmit Silence during Record() and DTMF Generation */ @@ -99,7 +101,7 @@ enum ast_option_flags { }; /*! These are the options that set by default when Asterisk starts */ -#define AST_DEFAULT_OPTIONS AST_OPT_FLAG_TRANSCODE_VIA_SLIN +#define AST_DEFAULT_OPTIONS (AST_OPT_FLAG_TRANSCODE_VIA_SLIN | AST_OPT_FLAG_CACHE_MEDIA_FRAMES) #define ast_opt_exec_includes ast_test_flag(&ast_options, AST_OPT_FLAG_EXEC_INCLUDES) #define ast_opt_no_fork ast_test_flag(&ast_options, AST_OPT_FLAG_NO_FORK) @@ -116,6 +118,7 @@ enum ast_option_flags { #define ast_opt_stdexten_macro ast_test_flag(&ast_options, AST_OPT_FLAG_STDEXTEN_MACRO) #define ast_opt_dump_core ast_test_flag(&ast_options, AST_OPT_FLAG_DUMP_CORE) #define ast_opt_cache_record_files ast_test_flag(&ast_options, AST_OPT_FLAG_CACHE_RECORD_FILES) +#define ast_opt_cache_media_frames ast_test_flag(&ast_options, AST_OPT_FLAG_CACHE_MEDIA_FRAMES) #define ast_opt_timestamp ast_test_flag(&ast_options, AST_OPT_FLAG_TIMESTAMP) #define ast_opt_reconnect ast_test_flag(&ast_options, AST_OPT_FLAG_RECONNECT) #define ast_opt_transmit_silence ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSMIT_SILENCE) diff --git a/include/asterisk/vector.h b/include/asterisk/vector.h index 68ce13065..8bd1cefef 100644 --- a/include/asterisk/vector.h +++ b/include/asterisk/vector.h @@ -51,6 +51,9 @@ /*! \brief Integer vector definition */ AST_VECTOR(ast_vector_int, int); +/*! \brief String vector definition */ +AST_VECTOR(ast_vector_string, char *); + /*! * \brief Define a vector structure with a read/write lock * @@ -91,6 +94,26 @@ AST_VECTOR(ast_vector_int, int); }) /*! + * \brief Steal the elements from a vector and reinitialize. + * + * \param vec Vector to operate on. + * + * This allows you to use vector.h to construct a list and use the + * data as a bare array. + * + * \note The stolen array must eventually be released using ast_free. + * + * \warning AST_VECTOR_SIZE and AST_VECTOR_MAX_SIZE are both reset + * to 0. If either are needed they must be saved to a local + * variable before stealing the elements. + */ +#define AST_VECTOR_STEAL_ELEMENTS(vec) ({ \ + typeof((vec)->elems) __elems = (vec)->elems; \ + AST_VECTOR_INIT((vec), 0); \ + (__elems); \ +}) + +/*! * \brief Initialize a vector with a read/write lock * * If \a size is 0, then no space will be allocated until the vector is diff --git a/main/asterisk.c b/main/asterisk.c index 40986a484..c4ed9093f 100644 --- a/main/asterisk.c +++ b/main/asterisk.c @@ -607,6 +607,9 @@ static char *handle_show_settings(struct ast_cli_entry *e, int cmd, struct ast_c ast_cli(a->fd, " Transmit silence during rec: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSMIT_SILENCE) ? "Enabled" : "Disabled"); ast_cli(a->fd, " Generic PLC: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_GENERIC_PLC) ? "Enabled" : "Disabled"); ast_cli(a->fd, " Min DTMF duration:: %u\n", option_dtmfminduration); +#if !defined(LOW_MEMORY) + ast_cli(a->fd, " Cache media frames: %s\n", ast_opt_cache_media_frames ? "Enabled" : "Disabled"); +#endif ast_cli(a->fd, " RTP use dynamic payloads: %u\n", ast_option_rtpusedynamic); if (ast_option_rtpptdynamic == AST_RTP_PT_LAST_REASSIGN) { @@ -3655,7 +3658,6 @@ static void ast_readconfig(void) ast_copy_string(cfg_paths.agi_dir, v->value, sizeof(cfg_paths.agi_dir)); } else if (!strcasecmp(v->name, "astrundir")) { snprintf(cfg_paths.pid_path, sizeof(cfg_paths.pid_path), "%s/%s", v->value, "asterisk.pid"); - snprintf(cfg_paths.socket_path, sizeof(cfg_paths.socket_path), "%s/%s", v->value, ast_config_AST_CTL); ast_copy_string(cfg_paths.run_dir, v->value, sizeof(cfg_paths.run_dir)); } else if (!strcasecmp(v->name, "astmoddir")) { ast_copy_string(cfg_paths.module_dir, v->value, sizeof(cfg_paths.module_dir)); @@ -3664,6 +3666,10 @@ static void ast_readconfig(void) } } + /* Combine astrundir and astctl settings. */ + snprintf(cfg_paths.socket_path, sizeof(cfg_paths.socket_path), "%s/%s", + ast_config_AST_RUN_DIR, ast_config_AST_CTL); + for (v = ast_variable_browse(cfg, "options"); v; v = v->next) { /* verbose level (-v at startup) */ if (!strcasecmp(v->name, "verbose")) { @@ -3714,6 +3720,11 @@ static void ast_readconfig(void) /* Cache recorded sound files to another directory during recording */ } else if (!strcasecmp(v->name, "cache_record_files")) { ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_CACHE_RECORD_FILES); +#if !defined(LOW_MEMORY) + /* Cache media frames for performance */ + } else if (!strcasecmp(v->name, "cache_media_frames")) { + ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_CACHE_MEDIA_FRAMES); +#endif /* Specify cache directory */ } else if (!strcasecmp(v->name, "record_cache_dir")) { ast_copy_string(record_cache_dir, v->value, AST_CACHE_DIR_LEN); diff --git a/main/audiohook.c b/main/audiohook.c index 2cba2de6e..04a379fef 100644 --- a/main/audiohook.c +++ b/main/audiohook.c @@ -950,7 +950,9 @@ static struct ast_frame *audio_audiohook_write_list(struct ast_channel *chan, st * rely on actual media being present to do things. */ if (!middle_frame->data.ptr) { - ast_frfree(middle_frame); + if (middle_frame != start_frame) { + ast_frfree(middle_frame); + } return start_frame; } diff --git a/main/frame.c b/main/frame.c index 8a151eff8..dd47f42d0 100644 --- a/main/frame.c +++ b/main/frame.c @@ -120,14 +120,18 @@ static void __frame_free(struct ast_frame *fr, int cache) return; #if !defined(LOW_MEMORY) - if (cache && fr->mallocd == AST_MALLOCD_HDR) { + if (fr->mallocd == AST_MALLOCD_HDR + && cache + && ast_opt_cache_media_frames) { /* Cool, only the header is malloc'd, let's just cache those for now * to keep things simple... */ struct ast_frame_cache *frames; - if ((frames = ast_threadstorage_get(&frame_cache, sizeof(*frames))) && - (frames->size < FRAME_CACHE_MAX_SIZE)) { - if ((fr->frametype == AST_FRAME_VOICE) || (fr->frametype == AST_FRAME_VIDEO) || - (fr->frametype == AST_FRAME_IMAGE)) { + + frames = ast_threadstorage_get(&frame_cache, sizeof(*frames)); + if (frames && frames->size < FRAME_CACHE_MAX_SIZE) { + if (fr->frametype == AST_FRAME_VOICE + || fr->frametype == AST_FRAME_VIDEO + || fr->frametype == AST_FRAME_IMAGE) { ao2_cleanup(fr->subclass.format); } @@ -147,8 +151,9 @@ static void __frame_free(struct ast_frame *fr, int cache) ast_free((void *) fr->src); } if (fr->mallocd & AST_MALLOCD_HDR) { - if ((fr->frametype == AST_FRAME_VOICE) || (fr->frametype == AST_FRAME_VIDEO) || - (fr->frametype == AST_FRAME_IMAGE)) { + if (fr->frametype == AST_FRAME_VOICE + || fr->frametype == AST_FRAME_VIDEO + || fr->frametype == AST_FRAME_IMAGE) { ao2_cleanup(fr->subclass.format); } diff --git a/main/plc.c b/main/plc.c index b649357dc..739f7276d 100644 --- a/main/plc.c +++ b/main/plc.c @@ -96,7 +96,7 @@ static void normalise_history(plc_state_t *s) if (s->buf_ptr == 0) return; memcpy(tmp, s->history, sizeof(int16_t)*s->buf_ptr); - memcpy(s->history, s->history + s->buf_ptr, sizeof(int16_t) * (PLC_HISTORY_LEN - s->buf_ptr)); + memmove(s->history, s->history + s->buf_ptr, sizeof(int16_t) * (PLC_HISTORY_LEN - s->buf_ptr)); memcpy(s->history + PLC_HISTORY_LEN - s->buf_ptr, tmp, sizeof(int16_t) * s->buf_ptr); s->buf_ptr = 0; } diff --git a/menuselect/.gitignore b/menuselect/.gitignore index ded8d2d6e..05f4778ff 100644 --- a/menuselect/.gitignore +++ b/menuselect/.gitignore @@ -1,3 +1,4 @@ +aclocal.m4 autoconfig.h cmenuselect config.log diff --git a/menuselect/aclocal.m4 b/menuselect/aclocal.m4 deleted file mode 100644 index e67774c06..000000000 --- a/menuselect/aclocal.m4 +++ /dev/null @@ -1,296 +0,0 @@ -# generated automatically by aclocal 1.15 -*- Autoconf -*- - -# Copyright (C) 1996-2014 Free Software Foundation, Inc. - -# This file is free software; the Free Software Foundation -# gives unlimited permission to copy and/or distribute it, -# with or without modifications, as long as this notice is preserved. - -# This program is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY, to the extent permitted by law; without -# even the implied warranty of MERCHANTABILITY or FITNESS FOR A -# PARTICULAR PURPOSE. - -m4_ifndef([AC_CONFIG_MACRO_DIRS], [m4_defun([_AM_CONFIG_MACRO_DIRS], [])m4_defun([AC_CONFIG_MACRO_DIRS], [_AM_CONFIG_MACRO_DIRS($@)])]) -dnl pkg.m4 - Macros to locate and utilise pkg-config. -*- Autoconf -*- -dnl serial 11 (pkg-config-0.29) -dnl -dnl Copyright © 2004 Scott James Remnant <scott@netsplit.com>. -dnl Copyright © 2012-2015 Dan Nicholson <dbn.lists@gmail.com> -dnl -dnl This program is free software; you can redistribute it and/or modify -dnl it under the terms of the GNU General Public License as published by -dnl the Free Software Foundation; either version 2 of the License, or -dnl (at your option) any later version. -dnl -dnl This program is distributed in the hope that it will be useful, but -dnl WITHOUT ANY WARRANTY; without even the implied warranty of -dnl MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU -dnl General Public License for more details. -dnl -dnl You should have received a copy of the GNU General Public License -dnl along with this program; if not, write to the Free Software -dnl Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA -dnl 02111-1307, USA. -dnl -dnl As a special exception to the GNU General Public License, if you -dnl distribute this file as part of a program that contains a -dnl configuration script generated by Autoconf, you may include it under -dnl the same distribution terms that you use for the rest of that -dnl program. - -dnl PKG_PREREQ(MIN-VERSION) -dnl ----------------------- -dnl Since: 0.29 -dnl -dnl Verify that the version of the pkg-config macros are at least -dnl MIN-VERSION. Unlike PKG_PROG_PKG_CONFIG, which checks the user's -dnl installed version of pkg-config, this checks the developer's version -dnl of pkg.m4 when generating configure. -dnl -dnl To ensure that this macro is defined, also add: -dnl m4_ifndef([PKG_PREREQ], -dnl [m4_fatal([must install pkg-config 0.29 or later before running autoconf/autogen])]) -dnl -dnl See the "Since" comment for each macro you use to see what version -dnl of the macros you require. -m4_defun([PKG_PREREQ], -[m4_define([PKG_MACROS_VERSION], [0.29]) -m4_if(m4_version_compare(PKG_MACROS_VERSION, [$1]), -1, - [m4_fatal([pkg.m4 version $1 or higher is required but ]PKG_MACROS_VERSION[ found])]) -])dnl PKG_PREREQ - -dnl PKG_PROG_PKG_CONFIG([MIN-VERSION]) -dnl ---------------------------------- -dnl Since: 0.16 -dnl -dnl Search for the pkg-config tool and set the PKG_CONFIG variable to -dnl first found in the path. Checks that the version of pkg-config found -dnl is at least MIN-VERSION. If MIN-VERSION is not specified, 0.9.0 is -dnl used since that's the first version where most current features of -dnl pkg-config existed. -AC_DEFUN([PKG_PROG_PKG_CONFIG], -[m4_pattern_forbid([^_?PKG_[A-Z_]+$]) -m4_pattern_allow([^PKG_CONFIG(_(PATH|LIBDIR|SYSROOT_DIR|ALLOW_SYSTEM_(CFLAGS|LIBS)))?$]) -m4_pattern_allow([^PKG_CONFIG_(DISABLE_UNINSTALLED|TOP_BUILD_DIR|DEBUG_SPEW)$]) -AC_ARG_VAR([PKG_CONFIG], [path to pkg-config utility]) -AC_ARG_VAR([PKG_CONFIG_PATH], [directories to add to pkg-config's search path]) -AC_ARG_VAR([PKG_CONFIG_LIBDIR], [path overriding pkg-config's built-in search path]) - -if test "x$ac_cv_env_PKG_CONFIG_set" != "xset"; then - AC_PATH_TOOL([PKG_CONFIG], [pkg-config]) -fi -if test -n "$PKG_CONFIG"; then - _pkg_min_version=m4_default([$1], [0.9.0]) - AC_MSG_CHECKING([pkg-config is at least version $_pkg_min_version]) - if $PKG_CONFIG --atleast-pkgconfig-version $_pkg_min_version; then - AC_MSG_RESULT([yes]) - else - AC_MSG_RESULT([no]) - PKG_CONFIG="" - fi -fi[]dnl -])dnl PKG_PROG_PKG_CONFIG - -dnl PKG_CHECK_EXISTS(MODULES, [ACTION-IF-FOUND], [ACTION-IF-NOT-FOUND]) -dnl ------------------------------------------------------------------- -dnl Since: 0.18 -dnl -dnl Check to see whether a particular set of modules exists. Similar to -dnl PKG_CHECK_MODULES(), but does not set variables or print errors. -dnl -dnl Please remember that m4 expands AC_REQUIRE([PKG_PROG_PKG_CONFIG]) -dnl only at the first occurence in configure.ac, so if the first place -dnl it's called might be skipped (such as if it is within an "if", you -dnl have to call PKG_CHECK_EXISTS manually -AC_DEFUN([PKG_CHECK_EXISTS], -[AC_REQUIRE([PKG_PROG_PKG_CONFIG])dnl -if test -n "$PKG_CONFIG" && \ - AC_RUN_LOG([$PKG_CONFIG --exists --print-errors "$1"]); then - m4_default([$2], [:]) -m4_ifvaln([$3], [else - $3])dnl -fi]) - -dnl _PKG_CONFIG([VARIABLE], [COMMAND], [MODULES]) -dnl --------------------------------------------- -dnl Internal wrapper calling pkg-config via PKG_CONFIG and setting -dnl pkg_failed based on the result. -m4_define([_PKG_CONFIG], -[if test -n "$$1"; then - pkg_cv_[]$1="$$1" - elif test -n "$PKG_CONFIG"; then - PKG_CHECK_EXISTS([$3], - [pkg_cv_[]$1=`$PKG_CONFIG --[]$2 "$3" 2>/dev/null` - test "x$?" != "x0" && pkg_failed=yes ], - [pkg_failed=yes]) - else - pkg_failed=untried -fi[]dnl -])dnl _PKG_CONFIG - -dnl _PKG_SHORT_ERRORS_SUPPORTED -dnl --------------------------- -dnl Internal check to see if pkg-config supports short errors. -AC_DEFUN([_PKG_SHORT_ERRORS_SUPPORTED], -[AC_REQUIRE([PKG_PROG_PKG_CONFIG]) -if $PKG_CONFIG --atleast-pkgconfig-version 0.20; then - _pkg_short_errors_supported=yes -else - _pkg_short_errors_supported=no -fi[]dnl -])dnl _PKG_SHORT_ERRORS_SUPPORTED - - -dnl PKG_CHECK_MODULES(VARIABLE-PREFIX, MODULES, [ACTION-IF-FOUND], -dnl [ACTION-IF-NOT-FOUND]) -dnl -------------------------------------------------------------- -dnl Since: 0.4.0 -dnl -dnl Note that if there is a possibility the first call to -dnl PKG_CHECK_MODULES might not happen, you should be sure to include an -dnl explicit call to PKG_PROG_PKG_CONFIG in your configure.ac -AC_DEFUN([PKG_CHECK_MODULES], -[AC_REQUIRE([PKG_PROG_PKG_CONFIG])dnl -AC_ARG_VAR([$1][_CFLAGS], [C compiler flags for $1, overriding pkg-config])dnl -AC_ARG_VAR([$1][_LIBS], [linker flags for $1, overriding pkg-config])dnl - -pkg_failed=no -AC_MSG_CHECKING([for $1]) - -_PKG_CONFIG([$1][_CFLAGS], [cflags], [$2]) -_PKG_CONFIG([$1][_LIBS], [libs], [$2]) - -m4_define([_PKG_TEXT], [Alternatively, you may set the environment variables $1[]_CFLAGS -and $1[]_LIBS to avoid the need to call pkg-config. -See the pkg-config man page for more details.]) - -if test $pkg_failed = yes; then - AC_MSG_RESULT([no]) - _PKG_SHORT_ERRORS_SUPPORTED - if test $_pkg_short_errors_supported = yes; then - $1[]_PKG_ERRORS=`$PKG_CONFIG --short-errors --print-errors --cflags --libs "$2" 2>&1` - else - $1[]_PKG_ERRORS=`$PKG_CONFIG --print-errors --cflags --libs "$2" 2>&1` - fi - # Put the nasty error message in config.log where it belongs - echo "$$1[]_PKG_ERRORS" >&AS_MESSAGE_LOG_FD - - m4_default([$4], [AC_MSG_ERROR( -[Package requirements ($2) were not met: - -$$1_PKG_ERRORS - -Consider adjusting the PKG_CONFIG_PATH environment variable if you -installed software in a non-standard prefix. - -_PKG_TEXT])[]dnl - ]) -elif test $pkg_failed = untried; then - AC_MSG_RESULT([no]) - m4_default([$4], [AC_MSG_FAILURE( -[The pkg-config script could not be found or is too old. Make sure it -is in your PATH or set the PKG_CONFIG environment variable to the full -path to pkg-config. - -_PKG_TEXT - -To get pkg-config, see <http://pkg-config.freedesktop.org/>.])[]dnl - ]) -else - $1[]_CFLAGS=$pkg_cv_[]$1[]_CFLAGS - $1[]_LIBS=$pkg_cv_[]$1[]_LIBS - AC_MSG_RESULT([yes]) - $3 -fi[]dnl -])dnl PKG_CHECK_MODULES - - -dnl PKG_CHECK_MODULES_STATIC(VARIABLE-PREFIX, MODULES, [ACTION-IF-FOUND], -dnl [ACTION-IF-NOT-FOUND]) -dnl --------------------------------------------------------------------- -dnl Since: 0.29 -dnl -dnl Checks for existence of MODULES and gathers its build flags with -dnl static libraries enabled. Sets VARIABLE-PREFIX_CFLAGS from --cflags -dnl and VARIABLE-PREFIX_LIBS from --libs. -dnl -dnl Note that if there is a possibility the first call to -dnl PKG_CHECK_MODULES_STATIC might not happen, you should be sure to -dnl include an explicit call to PKG_PROG_PKG_CONFIG in your -dnl configure.ac. -AC_DEFUN([PKG_CHECK_MODULES_STATIC], -[AC_REQUIRE([PKG_PROG_PKG_CONFIG])dnl -_save_PKG_CONFIG=$PKG_CONFIG -PKG_CONFIG="$PKG_CONFIG --static" -PKG_CHECK_MODULES($@) -PKG_CONFIG=$_save_PKG_CONFIG[]dnl -])dnl PKG_CHECK_MODULES_STATIC - - -dnl PKG_INSTALLDIR([DIRECTORY]) -dnl ------------------------- -dnl Since: 0.27 -dnl -dnl Substitutes the variable pkgconfigdir as the location where a module -dnl should install pkg-config .pc files. By default the directory is -dnl $libdir/pkgconfig, but the default can be changed by passing -dnl DIRECTORY. The user can override through the --with-pkgconfigdir -dnl parameter. -AC_DEFUN([PKG_INSTALLDIR], -[m4_pushdef([pkg_default], [m4_default([$1], ['${libdir}/pkgconfig'])]) -m4_pushdef([pkg_description], - [pkg-config installation directory @<:@]pkg_default[@:>@]) -AC_ARG_WITH([pkgconfigdir], - [AS_HELP_STRING([--with-pkgconfigdir], pkg_description)],, - [with_pkgconfigdir=]pkg_default) -AC_SUBST([pkgconfigdir], [$with_pkgconfigdir]) -m4_popdef([pkg_default]) -m4_popdef([pkg_description]) -])dnl PKG_INSTALLDIR - - -dnl PKG_NOARCH_INSTALLDIR([DIRECTORY]) -dnl -------------------------------- -dnl Since: 0.27 -dnl -dnl Substitutes the variable noarch_pkgconfigdir as the location where a -dnl module should install arch-independent pkg-config .pc files. By -dnl default the directory is $datadir/pkgconfig, but the default can be -dnl changed by passing DIRECTORY. The user can override through the -dnl --with-noarch-pkgconfigdir parameter. -AC_DEFUN([PKG_NOARCH_INSTALLDIR], -[m4_pushdef([pkg_default], [m4_default([$1], ['${datadir}/pkgconfig'])]) -m4_pushdef([pkg_description], - [pkg-config arch-independent installation directory @<:@]pkg_default[@:>@]) -AC_ARG_WITH([noarch-pkgconfigdir], - [AS_HELP_STRING([--with-noarch-pkgconfigdir], pkg_description)],, - [with_noarch_pkgconfigdir=]pkg_default) -AC_SUBST([noarch_pkgconfigdir], [$with_noarch_pkgconfigdir]) -m4_popdef([pkg_default]) -m4_popdef([pkg_description]) -])dnl PKG_NOARCH_INSTALLDIR - - -dnl PKG_CHECK_VAR(VARIABLE, MODULE, CONFIG-VARIABLE, -dnl [ACTION-IF-FOUND], [ACTION-IF-NOT-FOUND]) -dnl ------------------------------------------- -dnl Since: 0.28 -dnl -dnl Retrieves the value of the pkg-config variable for the given module. -AC_DEFUN([PKG_CHECK_VAR], -[AC_REQUIRE([PKG_PROG_PKG_CONFIG])dnl -AC_ARG_VAR([$1], [value of $3 for $2, overriding pkg-config])dnl - -_PKG_CONFIG([$1], [variable="][$3]["], [$2]) -AS_VAR_COPY([$1], [pkg_cv_][$1]) - -AS_VAR_IF([$1], [""], [$5], [$4])dnl -])dnl PKG_CHECK_VAR - -m4_include([../autoconf/ast_check_gnu_make.m4]) -m4_include([../autoconf/ast_ext_lib.m4]) -m4_include([../autoconf/ast_ext_tool_check.m4]) -m4_include([../autoconf/ast_gcc_attribute.m4]) -m4_include([../autoconf/ast_pkgconfig.m4]) -m4_include([../autoconf/ast_prog_sed.m4]) diff --git a/third-party/pjproject/patches/0010-r5665-svn-backport-ICE-Use-STUN-FINGERPRINT-attribut.patch b/third-party/pjproject/patches/0010-r5665-svn-backport-ICE-Use-STUN-FINGERPRINT-attribut.patch deleted file mode 100644 index 3c83cc502..000000000 --- a/third-party/pjproject/patches/0010-r5665-svn-backport-ICE-Use-STUN-FINGERPRINT-attribut.patch +++ /dev/null @@ -1,41 +0,0 @@ -From 06bc834969a34d2c60e05beed3051b4a6d34c125 Mon Sep 17 00:00:00 2001 -From: Richard Mudgett <rmudgett@digium.com> -Date: Thu, 28 Sep 2017 10:57:23 -0500 -Subject: [PATCH 3/3] r5665 svn backport ICE: Use STUN FINGERPRINT attribute - when sending keepalives - -Fixed #2046: ICE: Use STUN FINGERPRINT attribute when sending keepalives - -Per RFC 5245 Section 10: - - If STUN is being used for keepalives, a STUN Binding Indication is - used [RFC5389]. The Indication MUST NOT utilize any authentication - mechanism. It SHOULD contain the FINGERPRINT attribute to aid in - demultiplexing, but SHOULD NOT contain any other attributes. ---- - pjnath/src/pjnath/ice_session.c | 8 +++++--- - 1 file changed, 5 insertions(+), 3 deletions(-) - -diff --git a/pjnath/src/pjnath/ice_session.c b/pjnath/src/pjnath/ice_session.c -index 27a2950..63a0d1c 100644 ---- a/pjnath/src/pjnath/ice_session.c -+++ b/pjnath/src/pjnath/ice_session.c -@@ -1217,10 +1217,12 @@ static void ice_keep_alive(pj_ice_sess *ice, pj_bool_t send_now) - msg_data = PJ_POOL_ZALLOC_T(tdata->pool, pj_ice_msg_data); - msg_data->transport_id = the_check->lcand->transport_id; - -- /* Temporarily disable FINGERPRINT. The Binding Indication -- * SHOULD NOT contain any attributes. -+ /* RFC 5245 Section 10: -+ * The Binding Indication SHOULD contain the FINGERPRINT attribute -+ * to aid in demultiplexing, but SHOULD NOT contain any other -+ * attributes. - */ -- saved = pj_stun_session_use_fingerprint(comp->stun_sess, PJ_FALSE); -+ saved = pj_stun_session_use_fingerprint(comp->stun_sess, PJ_TRUE); - - /* Send to session */ - addr_len = pj_sockaddr_get_len(&the_check->rcand->addr); --- -2.7.4 - diff --git a/third-party/pjproject/patches/0020-sip_parser-Add-validity-checking-for-numeric-header-.patch b/third-party/pjproject/patches/0020-sip_parser-Add-validity-checking-for-numeric-header-.patch deleted file mode 100644 index dfee4b2c2..000000000 --- a/third-party/pjproject/patches/0020-sip_parser-Add-validity-checking-for-numeric-header-.patch +++ /dev/null @@ -1,973 +0,0 @@ -From b21042956dc4d3526052d5030953e5c565bb0895 Mon Sep 17 00:00:00 2001 -From: George Joseph <gjoseph@digium.com> -Date: Thu, 2 Nov 2017 08:23:00 -0600 -Subject: [PATCH] sip_parser: Add validity checking for numeric header values - -Parsing the numeric header fields like cseq, ttl, port, etc. all -had the potential to overflow, either causing unintended values to -be captured or, if the values were subsequently converted back to -strings, a buffer overrun. To address this, new "strto" functions -have been created that do range checking and those functions are -used wherever possible in the parser. - - * Created pjlib/include/limits.h and pjlib/include/compat/limits.h - to either include the system limits.h or define common numeric - limits if there is no system limits.h. - - * Created strto*_validate functions in sip_parser that take bounds - and on failure call the on_str_parse_error function which prints - an error message and calls PJ_THROW. - - * Updated sip_parser to validate the numeric fields. - - * Fixed an issue in sip_transport that prevented error messages - from being properly displayed. - - * Added "volatile" to some variables referenced in PJ_CATCH blocks - as the optimizer was sometimes optimizing them away. - - * Fixed length calculation in sip_transaction/create_tsx_key_2543 - to account for signed ints being 11 characters, not 9. - -Reported by: Youngsung Kim at LINE Corporation ---- - pjlib/build/pjlib.vcproj | 14 +++- - pjlib/build/pjlib.vcxproj | 4 +- - pjlib/build/pjlib.vcxproj.filters | 6 ++ - pjlib/include/pj/compat/limits.h | 65 +++++++++++++++ - pjlib/include/pj/compat/os_win32.h | 1 + - pjlib/include/pj/limits.h | 51 ++++++++++++ - pjlib/include/pj/string.h | 46 +++++++++- - pjlib/include/pj/types.h | 3 - - pjlib/src/pj/string.c | 119 +++++++++++++++++++++++++- - pjlib/src/pj/timer.c | 1 + - pjsip/include/pjsip/sip_parser.h | 25 ++++++ - pjsip/src/pjsip/sip_parser.c | 166 +++++++++++++++++++++++++++++-------- - pjsip/src/pjsip/sip_transaction.c | 4 +- - pjsip/src/pjsip/sip_transport.c | 7 +- - 14 files changed, 463 insertions(+), 49 deletions(-) - create mode 100644 pjlib/include/pj/compat/limits.h - create mode 100644 pjlib/include/pj/limits.h - -diff --git a/pjlib/build/pjlib.vcproj b/pjlib/build/pjlib.vcproj -index 6a217a0b7..12592ef94 100644 ---- a/pjlib/build/pjlib.vcproj -+++ b/pjlib/build/pjlib.vcproj -@@ -14967,7 +14967,11 @@ - </File>
- <File
- RelativePath="..\include\pj\ip_helper.h"
-- >
-+ > -+ </File> -+ <File -+ RelativePath="..\include\pj\limits.h" -+ > - </File>
- <File
- RelativePath="..\include\pj\list.h"
-@@ -15070,8 +15074,12 @@ - </File>
- <File
- RelativePath="..\include\pj\compat\high_precision.h"
-- >
-- </File>
-+ > -+ </File> -+ <File -+ RelativePath="..\include\pj\compat\limits.h" -+ > -+ </File> - <File
- RelativePath="..\include\pj\compat\m_alpha.h"
- >
-diff --git a/pjlib/build/pjlib.vcxproj b/pjlib/build/pjlib.vcxproj -index abf09ec44..e41731e3c 100644 ---- a/pjlib/build/pjlib.vcxproj -+++ b/pjlib/build/pjlib.vcxproj -@@ -494,7 +494,7 @@ - <ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Release|ARM'">true</ExcludedFromBuild> - <ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Release|x64'">true</ExcludedFromBuild> - </ClCompile> -- <ClCompile Include="..\src\pj\file_io_win32.c" /> -+ <ClCompile Include="..\src\pj\file_io_win32.c" /> - <ClCompile Include="..\src\pj\guid.c" /> - <ClCompile Include="..\src\pj\guid_simple.c"> - <ExcludedFromBuild Condition="'$(Configuration)|$(Platform)'=='Debug-Dynamic|Win32'">true</ExcludedFromBuild> -@@ -890,6 +890,7 @@ - <ClInclude Include="..\include\pj\compat\ctype.h" /> - <ClInclude Include="..\include\pj\compat\errno.h" /> - <ClInclude Include="..\include\pj\compat\high_precision.h" /> -+ <ClInclude Include="..\include\pj\compat\limits.h" /> - <ClInclude Include="..\include\pj\compat\malloc.h" /> - <ClInclude Include="..\include\pj\compat\m_alpha.h" /> - <ClInclude Include="..\include\pj\compat\m_i386.h" /> -@@ -925,6 +926,7 @@ - <ClInclude Include="..\include\pj\hash.h" /> - <ClInclude Include="..\include\pj\ioqueue.h" /> - <ClInclude Include="..\include\pj\ip_helper.h" /> -+ <ClInclude Include="..\include\pj\limits.h" /> - <ClInclude Include="..\include\pj\list.h" /> - <ClInclude Include="..\include\pj\list_i.h" /> - <ClInclude Include="..\include\pj\lock.h" /> -diff --git a/pjlib/build/pjlib.vcxproj.filters b/pjlib/build/pjlib.vcxproj.filters -index 0b5cbf109..6f343b019 100644 ---- a/pjlib/build/pjlib.vcxproj.filters -+++ b/pjlib/build/pjlib.vcxproj.filters -@@ -439,5 +439,11 @@ - <ClInclude Include="..\include\pj\compat\os_winuwp.h"> - <Filter>Header Files\compat</Filter> - </ClInclude> -+ <ClInclude Include="..\include\pj\limits.h"> -+ <Filter>Header Files</Filter> -+ </ClInclude> -+ <ClInclude Include="..\include\pj\compat\limits.h"> -+ <Filter>Header Files\compat</Filter> -+ </ClInclude> - </ItemGroup> - </Project> -\ No newline at end of file -diff --git a/pjlib/include/pj/compat/limits.h b/pjlib/include/pj/compat/limits.h -new file mode 100644 -index 000000000..fba0625df ---- /dev/null -+++ b/pjlib/include/pj/compat/limits.h -@@ -0,0 +1,65 @@ -+/* $Id$ */ -+/* -+ * Copyright (C) 2017 Teluu Inc. (http://www.teluu.com) -+ * Copyright (C) 2017 George Joseph <gjoseph@digium.com> -+ * -+ * This program is free software; you can redistribute it and/or modify -+ * it under the terms of the GNU General Public License as published by -+ * the Free Software Foundation; either version 2 of the License, or -+ * (at your option) any later version. -+ * -+ * This program is distributed in the hope that it will be useful, -+ * but WITHOUT ANY WARRANTY; without even the implied warranty of -+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -+ * GNU General Public License for more details. -+ * -+ * You should have received a copy of the GNU General Public License -+ * along with this program; if not, write to the Free Software -+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA -+ */ -+#ifndef __PJ_COMPAT_LIMITS_H__ -+#define __PJ_COMPAT_LIMITS_H__ -+ -+/** -+ * @file limits.h -+ * @brief Provides integer limits normally found in limits.h. -+ */ -+ -+#if defined(PJ_HAS_LIMITS_H) && PJ_HAS_LIMITS_H != 0 -+# include <limits.h> -+#else -+ -+# ifdef _MSC_VER -+# pragma message("limits.h is not found or not supported. LONG_MIN and "\ -+ "LONG_MAX will be defined by the library in "\ -+ "pj/compats/limits.h and overridable in config_site.h") -+# else -+# warning "limits.h is not found or not supported. LONG_MIN and LONG_MAX " \ -+ "will be defined by the library in pj/compats/limits.h and "\ -+ "overridable in config_site.h" -+# endif -+ -+/* Minimum and maximum values a `signed long int' can hold. */ -+# ifndef LONG_MAX -+# if __WORDSIZE == 64 -+# define LONG_MAX 9223372036854775807L -+# else -+# define LONG_MAX 2147483647L -+# endif -+# endif -+ -+# ifndef LONG_MIN -+# define LONG_MIN (-LONG_MAX - 1L) -+# endif -+ -+/* Maximum value an `unsigned long int' can hold. (Minimum is 0.) */ -+# ifndef ULONG_MAX -+# if __WORDSIZE == 64 -+# define ULONG_MAX 18446744073709551615UL -+# else -+# define ULONG_MAX 4294967295UL -+# endif -+# endif -+#endif -+ -+#endif /* __PJ_COMPAT_LIMITS_H__ */ -diff --git a/pjlib/include/pj/compat/os_win32.h b/pjlib/include/pj/compat/os_win32.h -index 4fa8b21ea..9b18e4eb1 100644 ---- a/pjlib/include/pj/compat/os_win32.h -+++ b/pjlib/include/pj/compat/os_win32.h -@@ -57,6 +57,7 @@ - #define PJ_HAS_SYS_TYPES_H 1 - #define PJ_HAS_TIME_H 1 - #define PJ_HAS_UNISTD_H 0 -+#define PJ_HAS_LIMITS_H 1 - - #define PJ_HAS_MSWSOCK_H 1 - #define PJ_HAS_WINSOCK_H 0 -diff --git a/pjlib/include/pj/limits.h b/pjlib/include/pj/limits.h -new file mode 100644 -index 000000000..8b00ae52a ---- /dev/null -+++ b/pjlib/include/pj/limits.h -@@ -0,0 +1,51 @@ -+/* $Id$ */ -+/* -+ * Copyright (C) 2017 Teluu Inc. (http://www.teluu.com) -+ * Copyright (C) 2017 George Joseph <gjoseph@digium.com> -+ * -+ * This program is free software; you can redistribute it and/or modify -+ * it under the terms of the GNU General Public License as published by -+ * the Free Software Foundation; either version 2 of the License, or -+ * (at your option) any later version. -+ * -+ * This program is distributed in the hope that it will be useful, -+ * but WITHOUT ANY WARRANTY; without even the implied warranty of -+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -+ * GNU General Public License for more details. -+ * -+ * You should have received a copy of the GNU General Public License -+ * along with this program; if not, write to the Free Software -+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA -+ */ -+#ifndef __PJ_LIMITS_H__ -+#define __PJ_LIMITS_H__ -+ -+/** -+ * @file limits.h -+ * @brief Common min and max values -+ */ -+ -+#include <pj/compat/limits.h> -+ -+/** Maximum value for signed 32-bit integer. */ -+#define PJ_MAXINT32 0x7fffffff -+ -+/** Minimum value for signed 32-bit integer. */ -+#define PJ_MININT32 0x80000000 -+ -+/** Maximum value for unsigned 16-bit integer. */ -+#define PJ_MAXUINT16 0xffff -+ -+/** Maximum value for unsigned char. */ -+#define PJ_MAXUINT8 0xff -+ -+/** Maximum value for long. */ -+#define PJ_MAXLONG LONG_MAX -+ -+/** Minimum value for long. */ -+#define PJ_MINLONG LONG_MIN -+ -+/** Minimum value for unsigned long. */ -+#define PJ_MAXULONG ULONG_MAX -+ -+#endif /* __PJ_LIMITS_H__ */ -diff --git a/pjlib/include/pj/string.h b/pjlib/include/pj/string.h -index 70a1d6c8c..5de236a65 100644 ---- a/pjlib/include/pj/string.h -+++ b/pjlib/include/pj/string.h -@@ -28,7 +28,6 @@ - #include <pj/types.h> - #include <pj/compat/string.h> - -- - PJ_BEGIN_DECL - - /** -@@ -636,6 +635,29 @@ PJ_DECL(char*) pj_create_random_string(char *str, pj_size_t length); - PJ_DECL(long) pj_strtol(const pj_str_t *str); - - /** -+ * Convert string to signed long integer. The conversion will stop as -+ * soon as non-digit character is found or all the characters have -+ * been processed. -+ * -+ * @param str the string. -+ * @param value Pointer to a long to receive the value. -+ * -+ * @return PJ_SUCCESS if successful. Otherwise: -+ * PJ_ETOOSMALL if the value was an impossibly long negative number. -+ * In this case *value will be set to LONG_MIN. -+ * \n -+ * PJ_ETOOBIG if the value was an impossibly long positive number. -+ * In this case, *value will be set to LONG_MAX. -+ * \n -+ * PJ_EINVAL if the input string was NULL, the value pointer was NULL -+ * or the input string could not be parsed at all such as starting with -+ * a character other than a '+', '-' or not in the '0' - '9' range. -+ * In this case, *value will be left untouched. -+ */ -+PJ_DECL(pj_status_t) pj_strtol2(const pj_str_t *str, long *value); -+ -+ -+/** - * Convert string to unsigned integer. The conversion will stop as - * soon as non-digit character is found or all the characters have - * been processed. -@@ -664,6 +686,27 @@ PJ_DECL(unsigned long) pj_strtoul2(const pj_str_t *str, pj_str_t *endptr, - unsigned base); - - /** -+ * Convert string to unsigned long integer. The conversion will stop as -+ * soon as non-digit character is found or all the characters have -+ * been processed. -+ * -+ * @param str The input string. -+ * @param value Pointer to an unsigned long to receive the value. -+ * @param base Number base to use. -+ * -+ * @return PJ_SUCCESS if successful. Otherwise: -+ * PJ_ETOOBIG if the value was an impossibly long positive number. -+ * In this case, *value will be set to ULONG_MAX. -+ * \n -+ * PJ_EINVAL if the input string was NULL, the value pointer was NULL -+ * or the input string could not be parsed at all such as starting -+ * with a character outside the base character range. In this case, -+ * *value will be left untouched. -+ */ -+PJ_DECL(pj_status_t) pj_strtoul3(const pj_str_t *str, unsigned long *value, -+ unsigned base); -+ -+/** - * Convert string to float. - * - * @param str the string. -@@ -786,7 +829,6 @@ PJ_INLINE(void*) pj_memchr(const void *buf, int c, pj_size_t size) - return (void*)memchr((void*)buf, c, size); - } - -- - /** - * @} - */ -diff --git a/pjlib/include/pj/types.h b/pjlib/include/pj/types.h -index 0e0e2d9a7..8c9f78238 100644 ---- a/pjlib/include/pj/types.h -+++ b/pjlib/include/pj/types.h -@@ -280,9 +280,6 @@ typedef int pj_exception_id_t; - /** Utility macro to compute the number of elements in static array. */ - #define PJ_ARRAY_SIZE(a) (sizeof(a)/sizeof(a[0])) - --/** Maximum value for signed 32-bit integer. */ --#define PJ_MAXINT32 0x7FFFFFFFL -- - /** - * Length of object names. - */ -diff --git a/pjlib/src/pj/string.c b/pjlib/src/pj/string.c -index 307cfb47e..b95f141be 100644 ---- a/pjlib/src/pj/string.c -+++ b/pjlib/src/pj/string.c -@@ -23,11 +23,14 @@ - #include <pj/ctype.h> - #include <pj/rand.h> - #include <pj/os.h> -+#include <pj/errno.h> -+#include <pj/limits.h> - - #if PJ_FUNCTIONS_ARE_INLINED==0 - # include <pj/string_i.h> - #endif - -+ - PJ_DEF(pj_ssize_t) pj_strspn(const pj_str_t *str, const pj_str_t *set_char) - { - pj_ssize_t i, j, count = 0; -@@ -230,6 +233,55 @@ PJ_DEF(long) pj_strtol(const pj_str_t *str) - return pj_strtoul(str); - } - -+ -+PJ_DEF(pj_status_t) pj_strtol2(const pj_str_t *str, long *value) -+{ -+ pj_str_t s; -+ unsigned long retval = 0; -+ pj_bool_t is_negative = PJ_FALSE; -+ int rc = 0; -+ -+ PJ_CHECK_STACK(); -+ -+ if (!str || !value) { -+ return PJ_EINVAL; -+ } -+ -+ s = *str; -+ pj_strltrim(&s); -+ -+ if (s.slen == 0) -+ return PJ_EINVAL; -+ -+ if (s.ptr[0] == '+' || s.ptr[0] == '-') { -+ is_negative = (s.ptr[0] == '-'); -+ s.ptr += 1; -+ s.slen -= 1; -+ } -+ -+ rc = pj_strtoul3(&s, &retval, 10); -+ if (rc == PJ_EINVAL) { -+ return rc; -+ } else if (rc != PJ_SUCCESS) { -+ *value = is_negative ? PJ_MINLONG : PJ_MAXLONG; -+ return is_negative ? PJ_ETOOSMALL : PJ_ETOOBIG; -+ } -+ -+ if (retval > PJ_MAXLONG && !is_negative) { -+ *value = PJ_MAXLONG; -+ return PJ_ETOOBIG; -+ } -+ -+ if (retval > (PJ_MAXLONG + 1UL) && is_negative) { -+ *value = PJ_MINLONG; -+ return PJ_ETOOSMALL; -+ } -+ -+ *value = is_negative ? -(long)retval : retval; -+ -+ return PJ_SUCCESS; -+} -+ - PJ_DEF(unsigned long) pj_strtoul(const pj_str_t *str) - { - unsigned long value; -@@ -282,6 +334,71 @@ PJ_DEF(unsigned long) pj_strtoul2(const pj_str_t *str, pj_str_t *endptr, - return value; - } - -+PJ_DEF(pj_status_t) pj_strtoul3(const pj_str_t *str, unsigned long *value, -+ unsigned base) -+{ -+ pj_str_t s; -+ unsigned i; -+ -+ PJ_CHECK_STACK(); -+ -+ if (!str || !value) { -+ return PJ_EINVAL; -+ } -+ -+ s = *str; -+ pj_strltrim(&s); -+ -+ if (s.slen == 0 || s.ptr[0] < '0' || -+ (base <= 10 && (unsigned)s.ptr[0] > ('0' - 1) + base) || -+ (base == 16 && !pj_isxdigit(s.ptr[0]))) -+ { -+ return PJ_EINVAL; -+ } -+ -+ *value = 0; -+ if (base <= 10) { -+ for (i=0; i<(unsigned)s.slen; ++i) { -+ unsigned c = s.ptr[i] - '0'; -+ if (s.ptr[i] < '0' || (unsigned)s.ptr[i] > ('0' - 1) + base) { -+ break; -+ } -+ if (*value > PJ_MAXULONG / base) { -+ *value = PJ_MAXULONG; -+ return PJ_ETOOBIG; -+ } -+ -+ *value *= base; -+ if ((PJ_MAXULONG - *value) < c) { -+ *value = PJ_MAXULONG; -+ return PJ_ETOOBIG; -+ } -+ *value += c; -+ } -+ } else if (base == 16) { -+ for (i=0; i<(unsigned)s.slen; ++i) { -+ unsigned c = pj_hex_digit_to_val(s.ptr[i]); -+ if (!pj_isxdigit(s.ptr[i])) -+ break; -+ -+ if (*value > PJ_MAXULONG / base) { -+ *value = PJ_MAXULONG; -+ return PJ_ETOOBIG; -+ } -+ *value *= base; -+ if ((PJ_MAXULONG - *value) < c) { -+ *value = PJ_MAXULONG; -+ return PJ_ETOOBIG; -+ } -+ *value += c; -+ } -+ } else { -+ pj_assert(!"Unsupported base"); -+ return PJ_EINVAL; -+ } -+ return PJ_SUCCESS; -+} -+ - PJ_DEF(float) pj_strtof(const pj_str_t *str) - { - pj_str_t part; -@@ -356,5 +473,3 @@ PJ_DEF(int) pj_utoa_pad( unsigned long val, char *buf, int min_dig, int pad) - - return len; - } -- -- -diff --git a/pjlib/src/pj/timer.c b/pjlib/src/pj/timer.c -index 225be4498..399e114a8 100644 ---- a/pjlib/src/pj/timer.c -+++ b/pjlib/src/pj/timer.c -@@ -36,6 +36,7 @@ - #include <pj/lock.h> - #include <pj/log.h> - #include <pj/rand.h> -+#include <pj/limits.h> - - #define THIS_FILE "timer.c" - -diff --git a/pjsip/include/pjsip/sip_parser.h b/pjsip/include/pjsip/sip_parser.h -index 0d767f0ad..5691fed3a 100644 ---- a/pjsip/include/pjsip/sip_parser.h -+++ b/pjsip/include/pjsip/sip_parser.h -@@ -39,6 +39,26 @@ PJ_BEGIN_DECL - */ - - /** -+ * Contants for limit checks -+ */ -+#define PJSIP_MIN_CONTENT_LENGTH 0 -+#define PJSIP_MAX_CONTENT_LENGTH PJ_MAXINT32 -+#define PJSIP_MIN_PORT 0 -+#define PJSIP_MAX_PORT PJ_MAXUINT16 -+#define PJSIP_MIN_TTL 0 -+#define PJSIP_MAX_TTL PJ_MAXUINT8 -+#define PJSIP_MIN_STATUS_CODE 100 -+#define PJSIP_MAX_STATUS_CODE 999 -+#define PJSIP_MIN_Q1000 0 -+#define PJSIP_MAX_Q1000 PJ_MAXINT32 / 1000 -+#define PJSIP_MIN_EXPIRES 0 -+#define PJSIP_MAX_EXPIRES PJ_MAXINT32 -+#define PJSIP_MIN_CSEQ 0 -+#define PJSIP_MAX_CSEQ PJ_MAXINT32 -+#define PJSIP_MIN_RETRY_AFTER 0 -+#define PJSIP_MAX_RETRY_AFTER PJ_MAXINT32 -+ -+/** - * URI Parsing options. - */ - enum -@@ -64,6 +84,11 @@ enum - extern int PJSIP_SYN_ERR_EXCEPTION; - - /** -+ * Invalid value error exception value. -+ */ -+extern int PJSIP_EINVAL_ERR_EXCEPTION; -+ -+/** - * This structure is used to get error reporting from parser. - */ - typedef struct pjsip_parser_err_report -diff --git a/pjsip/src/pjsip/sip_parser.c b/pjsip/src/pjsip/sip_parser.c -index cf3b879f6..f9a0e65b5 100644 ---- a/pjsip/src/pjsip/sip_parser.c -+++ b/pjsip/src/pjsip/sip_parser.c -@@ -34,6 +34,7 @@ - #include <pj/string.h> - #include <pj/ctype.h> - #include <pj/assert.h> -+#include <pj/limits.h> - - #define THIS_FILE "sip_parser.c" - -@@ -93,6 +94,7 @@ static unsigned uri_handler_count; - * Global vars (also extern). - */ - int PJSIP_SYN_ERR_EXCEPTION = -1; -+int PJSIP_EINVAL_ERR_EXCEPTION = -2; - - /* Parser constants */ - static pjsip_parser_const_t pconst = -@@ -205,7 +207,6 @@ static unsigned long pj_strtoul_mindigit(const pj_str_t *str, - /* Case insensitive comparison */ - #define parser_stricmp(s1, s2) (s1.slen!=s2.slen || pj_stricmp_alnum(&s1, &s2)) - -- - /* Get a token and unescape */ - PJ_INLINE(void) parser_get_and_unescape(pj_scanner *scanner, pj_pool_t *pool, - const pj_cis_t *spec, -@@ -223,8 +224,6 @@ PJ_INLINE(void) parser_get_and_unescape(pj_scanner *scanner, pj_pool_t *pool, - #endif - } - -- -- - /* Syntax error handler for parser. */ - static void on_syntax_error(pj_scanner *scanner) - { -@@ -232,6 +231,60 @@ static void on_syntax_error(pj_scanner *scanner) - PJ_THROW(PJSIP_SYN_ERR_EXCEPTION); - } - -+/* Syntax error handler for parser. */ -+static void on_str_parse_error(const pj_str_t *str, int rc) -+{ -+ char *s; -+ -+ switch(rc) { -+ case PJ_EINVAL: -+ s = "NULL input string, invalid input string, or NULL return "\ -+ "value pointer"; -+ break; -+ case PJ_ETOOSMALL: -+ s = "String value was less than the minimum allowed value."; -+ break; -+ case PJ_ETOOBIG: -+ s = "String value was greater than the maximum allowed value."; -+ break; -+ default: -+ s = "Unknown error"; -+ } -+ -+ if (str) { -+ PJ_LOG(1, (THIS_FILE, "Error parsing '%.*s': %s", -+ (int)str->slen, str->ptr, s)); -+ } else { -+ PJ_LOG(1, (THIS_FILE, "Can't parse input string: %s", s)); -+ } -+ PJ_THROW(PJSIP_EINVAL_ERR_EXCEPTION); -+} -+ -+static void strtoi_validate(const pj_str_t *str, int min_val, -+ int max_val, int *value) -+{ -+ long retval; -+ pj_status_t status; -+ -+ if (!str || !value) { -+ on_str_parse_error(str, PJ_EINVAL); -+ } -+ status = pj_strtol2(str, &retval); -+ if (status != PJ_EINVAL) { -+ if (min_val > retval) { -+ *value = min_val; -+ status = PJ_ETOOSMALL; -+ } else if (retval > max_val) { -+ *value = max_val; -+ status = PJ_ETOOBIG; -+ } else -+ *value = (int)retval; -+ } -+ -+ if (status != PJ_SUCCESS) -+ on_str_parse_error(str, status); -+} -+ - /* Get parser constants. */ - PJ_DEF(const pjsip_parser_const_t*) pjsip_parser_const(void) - { -@@ -285,6 +338,14 @@ static pj_status_t init_parser() - PJ_ASSERT_RETURN(status == PJ_SUCCESS, status); - - /* -+ * Invalid value exception. -+ */ -+ pj_assert (PJSIP_EINVAL_ERR_EXCEPTION == -2); -+ status = pj_exception_id_alloc("PJSIP invalid value error", -+ &PJSIP_EINVAL_ERR_EXCEPTION); -+ PJ_ASSERT_RETURN(status == PJ_SUCCESS, status); -+ -+ /* - * Init character input spec (cis) - */ - -@@ -502,6 +563,9 @@ void deinit_sip_parser(void) - /* Deregister exception ID */ - pj_exception_id_free(PJSIP_SYN_ERR_EXCEPTION); - PJSIP_SYN_ERR_EXCEPTION = -1; -+ -+ pj_exception_id_free(PJSIP_EINVAL_ERR_EXCEPTION); -+ PJSIP_EINVAL_ERR_EXCEPTION = -2; - } - pj_leave_critical_section(); - } -@@ -766,7 +830,7 @@ PJ_DEF(pjsip_msg *) pjsip_parse_rdata( char *buf, pj_size_t size, - } - - /* Determine if a message has been received. */ --PJ_DEF(pj_bool_t) pjsip_find_msg( const char *buf, pj_size_t size, -+PJ_DEF(pj_status_t) pjsip_find_msg( const char *buf, pj_size_t size, - pj_bool_t is_datagram, pj_size_t *msg_size) - { - #if PJ_HAS_TCP -@@ -776,6 +840,7 @@ PJ_DEF(pj_bool_t) pjsip_find_msg( const char *buf, pj_size_t size, - const char *line; - int content_length = -1; - pj_str_t cur_msg; -+ pj_status_t status = PJ_SUCCESS; - const pj_str_t end_hdr = { "\n\r\n", 3}; - - *msg_size = size; -@@ -836,9 +901,16 @@ PJ_DEF(pj_bool_t) pjsip_find_msg( const char *buf, pj_size_t size, - pj_scan_get_newline(&scanner); - - /* Found a valid Content-Length header. */ -- content_length = pj_strtoul(&str_clen); -+ strtoi_validate(&str_clen, PJSIP_MIN_CONTENT_LENGTH, -+ PJSIP_MAX_CONTENT_LENGTH, &content_length); - } - PJ_CATCH_ANY { -+ int eid = PJ_GET_EXCEPTION(); -+ if (eid == PJSIP_SYN_ERR_EXCEPTION) { -+ status = PJSIP_EMISSINGHDR; -+ } else if (eid == PJSIP_EINVAL_ERR_EXCEPTION) { -+ status = PJSIP_EINVALIDHDR; -+ } - content_length = -1; - } - PJ_END -@@ -858,7 +930,7 @@ PJ_DEF(pj_bool_t) pjsip_find_msg( const char *buf, pj_size_t size, - - /* Found Content-Length? */ - if (content_length == -1) { -- return PJSIP_EMISSINGHDR; -+ return status; - } - - /* Enough packet received? */ -@@ -938,10 +1010,14 @@ static pj_bool_t is_next_sip_version(pj_scanner *scanner) - static pjsip_msg *int_parse_msg( pjsip_parse_ctx *ctx, - pjsip_parser_err_report *err_list) - { -- pj_bool_t parsing_headers; -- pjsip_msg *msg = NULL; -+ /* These variables require "volatile" so their values get -+ * preserved when re-entering the PJ_TRY block after an error. -+ */ -+ volatile pj_bool_t parsing_headers; -+ pjsip_msg *volatile msg = NULL; -+ pjsip_ctype_hdr *volatile ctype_hdr = NULL; -+ - pj_str_t hname; -- pjsip_ctype_hdr *ctype_hdr = NULL; - pj_scanner *scanner = ctx->scanner; - pj_pool_t *pool = ctx->pool; - PJ_USE_EXCEPTION; -@@ -1023,7 +1099,6 @@ parse_headers: - hdr->name = hdr->sname = hname; - } - -- - /* Single parse of header line can produce multiple headers. - * For example, if one Contact: header contains Contact list - * separated by comma, then these Contacts will be split into -@@ -1267,7 +1342,7 @@ static void int_parse_uri_host_port( pj_scanner *scanner, - pj_str_t port; - pj_scan_get_char(scanner); - pj_scan_get(scanner, &pconst.pjsip_DIGIT_SPEC, &port); -- *p_port = pj_strtoul(&port); -+ strtoi_validate(&port, PJSIP_MIN_PORT, PJSIP_MAX_PORT, p_port); - } else { - *p_port = 0; - } -@@ -1458,8 +1533,8 @@ static void* int_parse_sip_url( pj_scanner *scanner, - url->transport_param = pvalue; - - } else if (!parser_stricmp(pname, pconst.pjsip_TTL_STR) && pvalue.slen) { -- url->ttl_param = pj_strtoul(&pvalue); -- -+ strtoi_validate(&pvalue, PJSIP_MIN_TTL, PJSIP_MAX_TTL, -+ &url->ttl_param); - } else if (!parser_stricmp(pname, pconst.pjsip_MADDR_STR) && pvalue.slen) { - url->maddr_param = pvalue; - -@@ -1595,7 +1670,8 @@ static void int_parse_status_line( pj_scanner *scanner, - - parse_sip_version(scanner); - pj_scan_get( scanner, &pconst.pjsip_DIGIT_SPEC, &token); -- status_line->code = pj_strtoul(&token); -+ strtoi_validate(&token, PJSIP_MIN_STATUS_CODE, PJSIP_MAX_STATUS_CODE, -+ &status_line->code); - if (*scanner->curptr != '\r' && *scanner->curptr != '\n') - pj_scan_get( scanner, &pconst.pjsip_NOT_NEWLINE, &status_line->reason); - else -@@ -1780,20 +1856,34 @@ static void int_parse_contact_param( pjsip_contact_hdr *hdr, - if (!parser_stricmp(pname, pconst.pjsip_Q_STR) && pvalue.slen) { - char *dot_pos = (char*) pj_memchr(pvalue.ptr, '.', pvalue.slen); - if (!dot_pos) { -- hdr->q1000 = pj_strtoul(&pvalue) * 1000; -+ strtoi_validate(&pvalue, PJSIP_MIN_Q1000, PJSIP_MAX_Q1000, -+ &hdr->q1000); -+ hdr->q1000 *= 1000; - } else { - pj_str_t tmp = pvalue; -+ unsigned long qval_frac; - - tmp.slen = dot_pos - pvalue.ptr; -- hdr->q1000 = pj_strtoul(&tmp) * 1000; -+ strtoi_validate(&tmp, PJSIP_MIN_Q1000, PJSIP_MAX_Q1000, -+ &hdr->q1000); -+ hdr->q1000 *= 1000; - - pvalue.slen = (pvalue.ptr+pvalue.slen) - (dot_pos+1); - pvalue.ptr = dot_pos + 1; -- hdr->q1000 += pj_strtoul_mindigit(&pvalue, 3); -+ if (pvalue.slen > 3) { -+ pvalue.slen = 3; -+ } -+ qval_frac = pj_strtoul_mindigit(&pvalue, 3); -+ if ((unsigned)hdr->q1000 > (PJ_MAXINT32 - qval_frac)) { -+ PJ_THROW(PJSIP_SYN_ERR_EXCEPTION); -+ } -+ hdr->q1000 += qval_frac; - } -- } else if (!parser_stricmp(pname, pconst.pjsip_EXPIRES_STR) && pvalue.slen) { -- hdr->expires = pj_strtoul(&pvalue); -- -+ } else if (!parser_stricmp(pname, pconst.pjsip_EXPIRES_STR) && -+ pvalue.slen) -+ { -+ strtoi_validate(&pvalue, PJSIP_MIN_EXPIRES, PJSIP_MAX_EXPIRES, -+ &hdr->expires); - } else { - pjsip_param *p = PJ_POOL_ALLOC_T(pool, pjsip_param); - p->name = pname; -@@ -1890,19 +1980,22 @@ static pjsip_hdr* parse_hdr_content_type( pjsip_parse_ctx *ctx ) - static pjsip_hdr* parse_hdr_cseq( pjsip_parse_ctx *ctx ) - { - pj_str_t cseq, method; -- pjsip_cseq_hdr *hdr; -+ pjsip_cseq_hdr *hdr = NULL; -+ int cseq_val = 0; - -- hdr = pjsip_cseq_hdr_create(ctx->pool); - pj_scan_get( ctx->scanner, &pconst.pjsip_DIGIT_SPEC, &cseq); -- hdr->cseq = pj_strtoul(&cseq); -+ strtoi_validate(&cseq, PJSIP_MIN_CSEQ, PJSIP_MAX_CSEQ, &cseq_val); - -- pj_scan_get( ctx->scanner, &pconst.pjsip_TOKEN_SPEC, &method); -- pjsip_method_init_np(&hdr->method, &method); -+ hdr = pjsip_cseq_hdr_create(ctx->pool); -+ hdr->cseq = cseq_val; - -+ pj_scan_get( ctx->scanner, &pconst.pjsip_TOKEN_SPEC, &method); - parse_hdr_end( ctx->scanner ); - -- if (ctx->rdata) -+ pjsip_method_init_np(&hdr->method, &method); -+ if (ctx->rdata) { - ctx->rdata->msg_info.cseq = hdr; -+ } - - return (pjsip_hdr*)hdr; - } -@@ -1984,7 +2077,8 @@ static pjsip_hdr* parse_hdr_retry_after(pjsip_parse_ctx *ctx) - hdr = pjsip_retry_after_hdr_create(ctx->pool, 0); - - pj_scan_get(scanner, &pconst.pjsip_DIGIT_SPEC, &tmp); -- hdr->ivalue = pj_strtoul(&tmp); -+ strtoi_validate(&tmp, PJSIP_MIN_RETRY_AFTER, PJSIP_MAX_RETRY_AFTER, -+ &hdr->ivalue); - - while (!pj_scan_is_eof(scanner) && *scanner->curptr!='\r' && - *scanner->curptr!='\n') -@@ -2073,7 +2167,8 @@ static void int_parse_via_param( pjsip_via_hdr *hdr, pj_scanner *scanner, - hdr->branch_param = pvalue; - - } else if (!parser_stricmp(pname, pconst.pjsip_TTL_STR) && pvalue.slen) { -- hdr->ttl_param = pj_strtoul(&pvalue); -+ strtoi_validate(&pvalue, PJSIP_MIN_TTL, PJSIP_MAX_TTL, -+ &hdr->ttl_param); - - } else if (!parser_stricmp(pname, pconst.pjsip_MADDR_STR) && pvalue.slen) { - hdr->maddr_param = pvalue; -@@ -2082,9 +2177,10 @@ static void int_parse_via_param( pjsip_via_hdr *hdr, pj_scanner *scanner, - hdr->recvd_param = pvalue; - - } else if (!parser_stricmp(pname, pconst.pjsip_RPORT_STR)) { -- if (pvalue.slen) -- hdr->rport_param = pj_strtoul(&pvalue); -- else -+ if (pvalue.slen) { -+ strtoi_validate(&pvalue, PJSIP_MIN_PORT, PJSIP_MAX_PORT, -+ &hdr->rport_param); -+ } else - hdr->rport_param = 0; - } else { - pjsip_param *p = PJ_POOL_ALLOC_T(pool, pjsip_param); -@@ -2213,7 +2309,8 @@ static pjsip_hdr* parse_hdr_via( pjsip_parse_ctx *ctx ) - pj_str_t digit; - pj_scan_get_char(scanner); - pj_scan_get(scanner, &pconst.pjsip_DIGIT_SPEC, &digit); -- hdr->sent_by.port = pj_strtoul(&digit); -+ strtoi_validate(&digit, PJSIP_MIN_PORT, PJSIP_MAX_PORT, -+ &hdr->sent_by.port); - } - - int_parse_via_param(hdr, scanner, ctx->pool); -@@ -2298,9 +2395,10 @@ PJ_DEF(pj_status_t) pjsip_parse_headers( pj_pool_t *pool, char *input, - unsigned options) - { - enum { STOP_ON_ERROR = 1 }; -+ pj_str_t hname; - pj_scanner scanner; - pjsip_parse_ctx ctx; -- pj_str_t hname; -+ - PJ_USE_EXCEPTION; - - pj_scan_init(&scanner, input, size, PJ_SCAN_AUTOSKIP_WS_HEADER, -@@ -2323,7 +2421,7 @@ retry_parse: - */ - hname.slen = 0; - -- /* Get hname. */ -+ /* Get hname. */ - pj_scan_get( &scanner, &pconst.pjsip_TOKEN_SPEC, &hname); - if (pj_scan_get_char( &scanner ) != ':') { - PJ_THROW(PJSIP_SYN_ERR_EXCEPTION); -diff --git a/pjsip/src/pjsip/sip_transaction.c b/pjsip/src/pjsip/sip_transaction.c -index f3be93beb..7ac3d1b76 100644 ---- a/pjsip/src/pjsip/sip_transaction.c -+++ b/pjsip/src/pjsip/sip_transaction.c -@@ -289,11 +289,11 @@ static pj_status_t create_tsx_key_2543( pj_pool_t *pool, - - /* Calculate length required. */ - len_required = method->name.slen + /* Method */ -- 9 + /* CSeq number */ -+ 11 + /* CSeq number */ - rdata->msg_info.from->tag.slen + /* From tag. */ - rdata->msg_info.cid->id.slen + /* Call-ID */ - host->slen + /* Via host. */ -- 9 + /* Via port. */ -+ 11 + /* Via port. */ - 16; /* Separator+Allowance. */ - key = p = (char*) pj_pool_alloc(pool, len_required); - -diff --git a/pjsip/src/pjsip/sip_transport.c b/pjsip/src/pjsip/sip_transport.c -index 0c338e8fd..b24cbb411 100644 ---- a/pjsip/src/pjsip/sip_transport.c -+++ b/pjsip/src/pjsip/sip_transport.c -@@ -1848,7 +1848,7 @@ PJ_DEF(pj_ssize_t) pjsip_tpmgr_receive_packet( pjsip_tpmgr *mgr, - /* Check for parsing syntax error */ - if (msg==NULL || !pj_list_empty(&rdata->msg_info.parse_err)) { - pjsip_parser_err_report *err; -- char buf[128]; -+ char buf[256]; - pj_str_t tmp; - - /* Gather syntax error information */ -@@ -1862,7 +1862,10 @@ PJ_DEF(pj_ssize_t) pjsip_tpmgr_receive_packet( pjsip_tpmgr *mgr, - pj_exception_id_name(err->except_code), - (int)err->hname.slen, err->hname.ptr, - err->line, err->col); -- if (len > 0 && len < (int) (sizeof(buf)-tmp.slen)) { -+ if (len >= (int)sizeof(buf)-tmp.slen) { -+ len = (int)sizeof(buf)-tmp.slen; -+ } -+ if (len > 0) { - tmp.slen += len; - } - err = err->next; --- -2.13.6 - diff --git a/third-party/pjproject/patches/0021-sip_parser-Fix-return-code-in-pjsip_find_msg-and-add.patch b/third-party/pjproject/patches/0021-sip_parser-Fix-return-code-in-pjsip_find_msg-and-add.patch new file mode 100644 index 000000000..86d5aa7dd --- /dev/null +++ b/third-party/pjproject/patches/0021-sip_parser-Fix-return-code-in-pjsip_find_msg-and-add.patch @@ -0,0 +1,41 @@ +From 186f82627c40d0c3a56a6a94ce55c055ad1f7620 Mon Sep 17 00:00:00 2001 +From: George Joseph <gjoseph@digium.com> +Date: Fri, 10 Nov 2017 09:26:29 -0700 +Subject: [PATCH] sip_parser: Fix return code in pjsip_find_msg and add + "volatile" + +The default return code for pjsip_find_msg was PJ_SUCCESS so if +a Content-Length header wasn't found at all, pjsip_find_msg was +returning PJ_SUCCESS instead of PJSIP_EMISSINGHDR. + +Also added the volatile keyword to a few variables what are used +both insude and outsude the PJ_TRY/PJ_CATCH block. +--- + pjsip/src/pjsip/sip_parser.c | 8 ++++---- + 1 file changed, 4 insertions(+), 4 deletions(-) + +diff --git a/pjsip/src/pjsip/sip_parser.c b/pjsip/src/pjsip/sip_parser.c +index f9a0e65b5..f65ffca5a 100644 +--- a/pjsip/src/pjsip/sip_parser.c ++++ b/pjsip/src/pjsip/sip_parser.c +@@ -834,13 +834,13 @@ PJ_DEF(pj_status_t) pjsip_find_msg( const char *buf, pj_size_t size, + pj_bool_t is_datagram, pj_size_t *msg_size) + { + #if PJ_HAS_TCP +- const char *hdr_end; +- const char *body_start; ++ const char *volatile hdr_end; ++ const char *volatile body_start; + const char *pos; +- const char *line; ++ const char *volatile line; + int content_length = -1; + pj_str_t cur_msg; +- pj_status_t status = PJ_SUCCESS; ++ volatile pj_status_t status = PJSIP_EMISSINGHDR; + const pj_str_t end_hdr = { "\n\r\n", 3}; + + *msg_size = size; +-- +2.13.6 + diff --git a/third-party/pjproject/patches/0030-sip_transport-Destroy-transports-not-in-hash.patch b/third-party/pjproject/patches/0030-sip_transport-Destroy-transports-not-in-hash.patch new file mode 100644 index 000000000..e42b0f7c6 --- /dev/null +++ b/third-party/pjproject/patches/0030-sip_transport-Destroy-transports-not-in-hash.patch @@ -0,0 +1,27 @@ +diff --git a/pjsip/src/pjsip/sip_transport.c b/pjsip/src/pjsip/sip_transport.c +index e4bec24..a39b56e 100644 +--- a/pjsip/src/pjsip/sip_transport.c ++++ b/pjsip/src/pjsip/sip_transport.c +@@ -957,7 +957,21 @@ static pj_bool_t is_transport_valid(pjsip_tpmgr *tpmgr, pjsip_transport *tp, + const pjsip_transport_key *key, + int key_len) + { +- return (pj_hash_get(tpmgr->table, key, key_len, NULL) == (void*)tp); ++ transport *tp_iter; ++ ++ if (pj_hash_get(tpmgr->table, key, key_len, NULL) == (void*)tp) { ++ return PJ_TRUE; ++ } ++ ++ tp_iter = tpmgr->tp_list.next; ++ while (tp_iter != &tpmgr->tp_list) { ++ if (tp_iter->tp == tp) { ++ return PJ_TRUE; ++ } ++ tp_iter = tp_iter->next; ++ } ++ ++ return PJ_FALSE; + } + + /* diff --git a/third-party/versions.mak b/third-party/versions.mak index 4f645f1bb..a90a52348 100644 --- a/third-party/versions.mak +++ b/third-party/versions.mak @@ -1,2 +1,2 @@ -PJPROJECT_VERSION = 2.7 +PJPROJECT_VERSION = 2.7.1 |