kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-04 20:25:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge "res_hep: Add additional config initialization and validation"

Browse Source
This commit is contained in:
George Joseph
2017-04-25 16:39:03 -05:00
committed by Gerrit Code Review
parent 8df729517e 0611f2ca17
commit a3a77890dc
1 changed files with 29 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
res/res_hep.c
View File

@@ -69,7 +69,7 @@
</enumlist> </enumlist>
</description> </description>
</configOption> </configOption>
<configOption name="capture_address" default="192.168.1.1:9061"> <configOption name="capture_address">
<synopsis>The address and port of the Homer server to send packets to.</synopsis> <synopsis>The address and port of the Homer server to send packets to.</synopsis>
</configOption> </configOption>
<configOption name="capture_password"> <configOption name="capture_password">
@@ -96,8 +96,6 @@
#include <netinet/udp.h> #include <netinet/udp.h>
#include <netinet/ip6.h> #include <netinet/ip6.h>
#define DEFAULT_HEP_SERVER ""
/*! Generic vendor ID. Used for HEPv3 standard packets */ /*! Generic vendor ID. Used for HEPv3 standard packets */
#define GENERIC_VENDOR_ID 0x0000 #define GENERIC_VENDOR_ID 0x0000
@@ -280,11 +278,13 @@ static AO2_GLOBAL_OBJ_STATIC(global_data);
static struct ast_taskprocessor *hep_queue_tp; static struct ast_taskprocessor *hep_queue_tp;
static void *module_config_alloc(void); static void *module_config_alloc(void);
static int hepv3_config_pre_apply(void);
static void hepv3_config_post_apply(void); static void hepv3_config_post_apply(void);
/*! \brief Register information about the configs being processed by this module */ /*! \brief Register information about the configs being processed by this module */
CONFIG_INFO_STANDARD(cfg_info, global_config, module_config_alloc, CONFIG_INFO_STANDARD(cfg_info, global_config, module_config_alloc,
.files = ACO_FILES(&hepv3_conf), .files = ACO_FILES(&hepv3_conf),
.pre_apply_config = hepv3_config_pre_apply,
.post_apply_config = hepv3_config_post_apply, .post_apply_config = hepv3_config_post_apply,
); );
@@ -377,6 +377,8 @@ static struct hepv3_runtime_data *hepv3_data_alloc(struct hepv3_global_config *c
return NULL; return NULL;
} }
data->sockfd = -1;
if (!ast_sockaddr_parse(&data->remote_addr, config->capture_address, PARSE_PORT_REQUIRE)) { if (!ast_sockaddr_parse(&data->remote_addr, config->capture_address, PARSE_PORT_REQUIRE)) {
ast_log(AST_LOG_WARNING, "Failed to create address from %s\n", config->capture_address); ast_log(AST_LOG_WARNING, "Failed to create address from %s\n", config->capture_address);
ao2_ref(data, -1); ao2_ref(data, -1);
@@ -593,12 +595,34 @@ int hepv3_send_packet(struct hepv3_capture_info *capture_info)
return res; return res;
} }
/*!
* \brief Pre-apply callback for the config framework.
*
* This validates that required fields exist and are populated.
*/
static int hepv3_config_pre_apply(void)
{
struct module_config *config = aco_pending_config(&cfg_info);
if (!config->general->enabled) {
/* If we're not enabled, we don't care about anything else */
return 0;
}
if (ast_strlen_zero(config->general->capture_address)) {
ast_log(AST_LOG_ERROR, "Missing required configuration option 'capture_address'\n");
return -1;
}
return 0;
}
/*! /*!
* \brief Post-apply callback for the config framework. * \brief Post-apply callback for the config framework.
* *
* This will create the run-time information from the supplied * This will create the run-time information from the supplied
* configuration. * configuration.
*/ */
static void hepv3_config_post_apply(void) static void hepv3_config_post_apply(void)
{ {
RAII_VAR(struct module_config *, mod_cfg, ao2_global_obj_ref(global_config), ao2_cleanup); RAII_VAR(struct module_config *, mod_cfg, ao2_global_obj_ref(global_config), ao2_cleanup);
@@ -653,7 +677,7 @@ static int load_module(void)
} }
aco_option_register(&cfg_info, "enabled", ACO_EXACT, global_options, "yes", OPT_BOOL_T, 1, FLDSET(struct hepv3_global_config, enabled)); aco_option_register(&cfg_info, "enabled", ACO_EXACT, global_options, "yes", OPT_BOOL_T, 1, FLDSET(struct hepv3_global_config, enabled));
aco_option_register(&cfg_info, "capture_address", ACO_EXACT, global_options, DEFAULT_HEP_SERVER, OPT_STRINGFIELD_T, 0, STRFLDSET(struct hepv3_global_config, capture_address)); aco_option_register(&cfg_info, "capture_address", ACO_EXACT, global_options, "", OPT_STRINGFIELD_T, 1, STRFLDSET(struct hepv3_global_config, capture_address));
aco_option_register(&cfg_info, "capture_password", ACO_EXACT, global_options, "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct hepv3_global_config, capture_password)); aco_option_register(&cfg_info, "capture_password", ACO_EXACT, global_options, "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct hepv3_global_config, capture_password));
aco_option_register(&cfg_info, "capture_id", ACO_EXACT, global_options, "0", OPT_UINT_T, 0, STRFLDSET(struct hepv3_global_config, capture_id)); aco_option_register(&cfg_info, "capture_id", ACO_EXACT, global_options, "0", OPT_UINT_T, 0, STRFLDSET(struct hepv3_global_config, capture_id));
aco_option_register_custom(&cfg_info, "uuid_type", ACO_EXACT, global_options, "call-id", uuid_type_handler, 0); aco_option_register_custom(&cfg_info, "uuid_type", ACO_EXACT, global_options, "call-id", uuid_type_handler, 0);