[asterisk-commits] kmoore: trunk r396321 - in /trunk/res: ./ res_pjsip/ res_pjsip/include/
SVN commits to the Asterisk project
asterisk-commits at lists.digium.com
Tue Aug 6 08:08:18 CDT 2013
Author: kmoore
Date: Tue Aug 6 08:08:13 2013
New Revision: 396321
URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=396321
Log:
Expose res_pjsip threadpool options
Expose initial size, automatic increment, maximum size, and idle
timeout as configurable parameters for the res_pjsip thread pool.
Review: https://reviewboard.asterisk.org/r/2704/
(closes issue ASTERISK-22143)
Modified:
trunk/res/res_pjsip.c
trunk/res/res_pjsip/config_system.c
trunk/res/res_pjsip/include/res_pjsip_private.h
Modified: trunk/res/res_pjsip.c
URL: http://svnview.digium.com/svn/asterisk/trunk/res/res_pjsip.c?view=diff&rev=396321&r1=396320&r2=396321
==============================================================================
--- trunk/res/res_pjsip.c (original)
+++ trunk/res/res_pjsip.c Tue Aug 6 08:08:13 2013
@@ -935,6 +935,19 @@
<configOption name="compactheaders" default="no">
<synopsis>Use the short forms of common SIP header names.</synopsis>
</configOption>
+ <configOption name="threadpool_initial_size" default="0">
+ <synopsis>Initial number of threads in the res_pjsip threadpool.</synopsis>
+ </configOption>
+ <configOption name="threadpool_auto_increment" default="5">
+ <synopsis>The amount by which the number of threads is incremented when necessary.</synopsis>
+ </configOption>
+ <configOption name="threadpool_idle_timeout" default="60">
+ <synopsis>Number of seconds before an idle thread should be disposed of.</synopsis>
+ </configOption>
+ <configOption name="threadpool_max_size" default="0">
+ <synopsis>Maximum number of threads in the res_pjsip threadpool.
+ A value of 0 indicates no maximum.</synopsis>
+ </configOption>
</configObject>
<configObject name="global">
<synopsis>Options that apply globally to all SIP communications</synopsis>
@@ -1760,26 +1773,12 @@
static int load_module(void)
{
- /* The third parameter is just copied from
- * example code from PJLIB. This can be adjusted
- * if necessary.
+ /* The third parameter is just copied from
+ * example code from PJLIB. This can be adjusted
+ * if necessary.
*/
pj_status_t status;
-
- /* XXX For the time being, create hard-coded threadpool
- * options. Just bump up by five threads every time we
- * don't have any available threads. Idle threads time
- * out after a minute. No maximum size
- */
- struct ast_threadpool_options options = {
- .version = AST_THREADPOOL_OPTIONS_VERSION,
- .auto_increment = 5,
- .max_size = 0,
- .idle_timeout = 60,
- .initial_size = 0,
- .thread_start = sip_thread_start,
- };
- sip_threadpool = ast_threadpool_create("SIP", NULL, &options);
+ struct ast_threadpool_options options;
if (pj_init() != PJ_SUCCESS) {
return AST_MODULE_LOAD_DECLINE;
@@ -1809,6 +1808,14 @@
if (ast_sip_initialize_system()) {
ast_log(LOG_ERROR, "Failed to initialize SIP system configuration. Aborting load\n");
+ goto error;
+ }
+
+ sip_get_threadpool_options(&options);
+ options.thread_start = sip_thread_start;
+ sip_threadpool = ast_threadpool_create("SIP", NULL, &options);
+ if (!sip_threadpool) {
+ ast_log(LOG_ERROR, "Failed to create SIP threadpool. Aborting load\n");
goto error;
}
Modified: trunk/res/res_pjsip/config_system.c
URL: http://svnview.digium.com/svn/asterisk/trunk/res/res_pjsip/config_system.c?view=diff&rev=396321&r1=396320&r2=396321
==============================================================================
--- trunk/res/res_pjsip/config_system.c (original)
+++ trunk/res/res_pjsip/config_system.c Tue Aug 6 08:08:13 2013
@@ -24,6 +24,7 @@
#include "asterisk/res_pjsip.h"
#include "asterisk/sorcery.h"
#include "include/res_pjsip_private.h"
+#include "asterisk/threadpool.h"
#define TIMER_T1_MIN 100
#define DEFAULT_TIMER_T1 500
@@ -37,7 +38,26 @@
unsigned int timerb;
/*! Should we use short forms for headers? */
unsigned int compactheaders;
+ struct {
+ /*! Initial number of threads in the threadpool */
+ int initial_size;
+ /*! The amount by which the number of threads is incremented when necessary */
+ int auto_increment;
+ /*! Thread idle timeout in seconds */
+ int idle_timeout;
+ /*! Maxumum number of threads in the threadpool */
+ int max_size;
+ } threadpool;
};
+
+static struct ast_threadpool_options sip_threadpool_options = {
+ .version = AST_THREADPOOL_OPTIONS_VERSION,
+};
+
+void sip_get_threadpool_options(struct ast_threadpool_options *threadpool_options)
+{
+ *threadpool_options = sip_threadpool_options;
+}
static struct ast_sorcery *system_sorcery;
@@ -77,11 +97,19 @@
pjsip_use_compact_form = PJ_TRUE;
}
+ sip_threadpool_options.initial_size = system->threadpool.initial_size;
+ sip_threadpool_options.auto_increment = system->threadpool.auto_increment;
+ sip_threadpool_options.idle_timeout = system->threadpool.idle_timeout;
+ sip_threadpool_options.max_size = system->threadpool.max_size;
+
return 0;
}
int ast_sip_initialize_system(void)
{
+ RAII_VAR(struct ao2_container *, system_configs, NULL, ao2_cleanup);
+ RAII_VAR(struct system_config *, system, NULL, ao2_cleanup);
+
system_sorcery = ast_sorcery_open();
if (!system_sorcery) {
ast_log(LOG_ERROR, "Failed to open SIP system sorcery\n");
@@ -105,8 +133,35 @@
OPT_UINT_T, 0, FLDSET(struct system_config, timerb));
ast_sorcery_object_field_register(system_sorcery, "system", "compactheaders", "no",
OPT_BOOL_T, 1, FLDSET(struct system_config, compactheaders));
+ ast_sorcery_object_field_register(system_sorcery, "system", "threadpool_initial_size", "0",
+ OPT_UINT_T, 0, FLDSET(struct system_config, threadpool.initial_size));
+ ast_sorcery_object_field_register(system_sorcery, "system", "threadpool_auto_increment", "5",
+ OPT_UINT_T, 0, FLDSET(struct system_config, threadpool.auto_increment));
+ ast_sorcery_object_field_register(system_sorcery, "system", "threadpool_idle_timeout", "60",
+ OPT_UINT_T, 0, FLDSET(struct system_config, threadpool.idle_timeout));
+ ast_sorcery_object_field_register(system_sorcery, "system", "threadpool_max_size", "0",
+ OPT_UINT_T, 0, FLDSET(struct system_config, threadpool.max_size));
ast_sorcery_load(system_sorcery);
+ system_configs = ast_sorcery_retrieve_by_fields(system_sorcery, "system",
+ AST_RETRIEVE_FLAG_MULTIPLE | AST_RETRIEVE_FLAG_ALL, NULL);
+
+ if (ao2_container_count(system_configs)) {
+ return 0;
+ }
+
+ /* No config present, allocate one and apply defaults */
+ system = ast_sorcery_alloc(system_sorcery, "system", NULL);
+ if (!system) {
+ ast_log(LOG_ERROR, "Unable to allocate default system config.\n");
+ return -1;
+ }
+
+ if (system_apply(system_sorcery, system)) {
+ ast_log(LOG_ERROR, "Failed to apply default system config.\n");
+ return -1;
+ }
+
return 0;
}
Modified: trunk/res/res_pjsip/include/res_pjsip_private.h
URL: http://svnview.digium.com/svn/asterisk/trunk/res/res_pjsip/include/res_pjsip_private.h?view=diff&rev=396321&r1=396320&r2=396321
==============================================================================
--- trunk/res/res_pjsip/include/res_pjsip_private.h (original)
+++ trunk/res/res_pjsip/include/res_pjsip_private.h Tue Aug 6 08:08:13 2013
@@ -76,4 +76,9 @@
*/
void ast_res_pjsip_cleanup_options_handling(void);
+/*!
+ * \brief Get threadpool options
+ */
+void sip_get_threadpool_options(struct ast_threadpool_options *threadpool_options);
+
#endif /* RES_PJSIP_PRIVATE_H_ */
More information about the asterisk-commits
mailing list