kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-11-19 08:11:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

StatsD: Send stuff to the StatsD server and test

Browse Source 
Added code to allow the StatsD dialplan application to
send data to the server specified in statsd.conf.

ASTERISK-25419

Change-Id: I400db2f37c6ddf61515ff5a019646e36dcd0f922
This commit is contained in:
tcambron
2015-10-29 15:25:32 -05:00
parent b522a5e30f
commit c5093b21ad
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
apps/app_statsd.c
View File

@@ -33,6 +33,7 @@ ASTERISK_REGISTER_FILE()
#include "asterisk/app.h" #include "asterisk/app.h"
#include "asterisk/pbx.h" #include "asterisk/pbx.h"
#include "asterisk/strings.h" #include "asterisk/strings.h"
#include "asterisk/statsd.h"
/*** DOCUMENTATION /*** DOCUMENTATION
<application name="StatsD" language="en_US"> <application name="StatsD" language="en_US">
@@ -76,7 +77,7 @@ static int value_in_range(const char *value, const char *metric)
{ {
double numerical_value = strtod(value, NULL); double numerical_value = strtod(value, NULL);
if (!strcmp(metric, "counter")) { if (!strcmp(metric, "c")) {
if (numerical_value < pow(-2, 63) || numerical_value > pow(2, 63)) { if (numerical_value < pow(-2, 63) || numerical_value > pow(2, 63)) {
ast_log(AST_LOG_WARNING, "Value %lf out of range!\n", numerical_value); ast_log(AST_LOG_WARNING, "Value %lf out of range!\n", numerical_value);
return 1; return 1;
@@ -104,7 +105,7 @@ static int value_in_range(const char *value, const char *metric)
*/ */
static int validate_metric(const char *metric) static int validate_metric(const char *metric)
{ {
const char *valid_metrics[] = {"gauge","set","timer","counter"}; const char *valid_metrics[] = {"g","s","ms","c"};
int i; int i;
if (ast_strlen_zero(metric)) { if (ast_strlen_zero(metric)) {
@@ -168,7 +169,7 @@ static int validate_value(const char *value, const char *metric)
return 1; return 1;
} }
if (!strcmp(metric, "gauge") || !strcmp(metric, "counter")) { if (!strcmp(metric, "g") || !strcmp(metric, "c")) {
if ((value[0] == '+') || (value[0] == '-')) { if ((value[0] == '+') || (value[0] == '-')) {
actual_value = &value[1]; actual_value = &value[1];
if (ast_strlen_zero(actual_value)) { if (ast_strlen_zero(actual_value)) {
@@ -198,6 +199,7 @@ static int validate_value(const char *value, const char *metric)
static int statsd_exec(struct ast_channel *chan, const char *data) static int statsd_exec(struct ast_channel *chan, const char *data)
{ {
char *stats; char *stats;
double numerical_value;
AST_DECLARE_APP_ARGS(args, AST_DECLARE_APP_ARGS(args,
AST_APP_ARG(metric_type); AST_APP_ARG(metric_type);
@@ -223,6 +225,13 @@ static int statsd_exec(struct ast_channel *chan, const char *data)
return 1; return 1;
} }
/*
* Conversion to a double is safe here since the value would have been validated as a
* number in validate_value().
*/
numerical_value = strtod(args.value, NULL);
ast_statsd_log(args.statistic_name, args.metric_type, numerical_value);
return 0; return 0;
} }