X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fopenvpn.c;h=9ce23b4f4cb9c9e2550e86d337a866a451931404;hb=aff80830f1154a5b6c4da16a0b1033aafde14e24;hp=81c5343d171af7e3bf1b8295a224844af1b251c9;hpb=68958b2edc1e4dae3fa9112b98543dff0494381a;p=collectd.git diff --git a/src/openvpn.c b/src/openvpn.c index 81c5343d..9ce23b4f 100644 --- a/src/openvpn.c +++ b/src/openvpn.c @@ -1,8 +1,9 @@ /** * collectd - src/openvpn.c - * Copyright (C) 2008 Doug MacEachern - * Copyright (C) 2009 Florian octo Forster - * Copyright (C) 2009 Marco Chiappero + * Copyright (C) 2008 Doug MacEachern + * Copyright (C) 2009,2010 Florian octo Forster + * Copyright (C) 2009 Marco Chiappero + * Copyright (C) 2009 Fabian Schuh * * 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 @@ -19,8 +20,9 @@ * * Authors: * Doug MacEachern - * Florian octo Forster + * Florian octo Forster * Marco Chiappero + * Fabian Schuh **/ #include "collectd.h" @@ -50,16 +52,19 @@ typedef struct vpn_status_s vpn_status_t; static vpn_status_t **vpn_list = NULL; static int vpn_num = 0; -static int store_compression = 1; -static int new_naming_schema = 0; -static int sumover_allusers = 0; +static _Bool new_naming_schema = 0; +static _Bool collect_compression = 1; +static _Bool collect_user_count = 0; +static _Bool collect_individual_users = 1; static const char *config_keys[] = { "StatusFile", - "Compression", + "Compression", /* old, deprecated name */ "ImprovedNamingSchema", - "SumOverAllUsers" + "CollectCompression", + "CollectUserCount", + "CollectIndividualUsers" }; static int config_keys_num = STATIC_ARRAY_SIZE (config_keys); @@ -87,14 +92,35 @@ static int openvpn_strsplit (char *string, char **fields, size_t size) return (i); } /* int openvpn_strsplit */ +/* dispatches number of users */ +static void numusers_submit (char *pinst, char *tinst, gauge_t value) +{ + value_t values[1]; + value_list_t vl = VALUE_LIST_INIT; + + values[0].gauge = value; + + vl.values = values; + vl.values_len = STATIC_ARRAY_SIZE (values); + sstrncpy (vl.host, hostname_g, sizeof (vl.host)); + sstrncpy (vl.plugin, "openvpn", sizeof (vl.plugin)); + sstrncpy (vl.type, "users", sizeof (vl.type)); + if (pinst != NULL) + sstrncpy (vl.plugin_instance, pinst, sizeof (vl.plugin_instance)); + if (tinst != NULL) + sstrncpy (vl.type_instance, tinst, sizeof (vl.type_instance)); + + plugin_dispatch_values (&vl); +} /* void numusers_submit */ + /* dispatches stats about traffic (TCP or UDP) generated by the tunnel per single endpoint */ -static void iostats_submit (char *pinst, char *tinst, counter_t rx, counter_t tx) +static void iostats_submit (char *pinst, char *tinst, derive_t rx, derive_t tx) { value_t values[2]; value_list_t vl = VALUE_LIST_INIT; - values[0].counter = rx; - values[1].counter = tx; + values[0].derive = rx; + values[1].derive = tx; /* NOTE ON THE NEW NAMING SCHEMA: * using plugin_instance to identify each vpn config (and @@ -118,13 +144,13 @@ static void iostats_submit (char *pinst, char *tinst, counter_t rx, counter_t tx /* dispatches stats about data compression shown when in single mode */ static void compression_submit (char *pinst, char *tinst, - counter_t uncompressed, counter_t compressed) + derive_t uncompressed, derive_t compressed) { value_t values[2]; value_list_t vl = VALUE_LIST_INIT; - values[0].counter = uncompressed; - values[1].counter = compressed; + values[0].derive = uncompressed; + values[1].derive = compressed; vl.values = values; vl.values_len = STATIC_ARRAY_SIZE (values); @@ -147,11 +173,11 @@ static int single_read (char *name, FILE *fh) const int max_fields = STATIC_ARRAY_SIZE (fields); int fields_num, read = 0; - counter_t link_rx, link_tx; - counter_t tun_rx, tun_tx; - counter_t pre_compress, post_compress; - counter_t pre_decompress, post_decompress; - counter_t overhead_rx, overhead_tx; + derive_t link_rx, link_tx; + derive_t tun_rx, tun_tx; + derive_t pre_compress, post_compress; + derive_t pre_decompress, post_decompress; + derive_t overhead_rx, overhead_tx; link_rx = 0; link_tx = 0; @@ -223,7 +249,7 @@ static int single_read (char *name, FILE *fh) iostats_submit (name, "overhead", overhead_rx, overhead_tx); - if (store_compression) + if (collect_compression) { compression_submit (name, "data_in", post_decompress, pre_decompress); compression_submit (name, "data_out", pre_compress, post_compress); @@ -240,8 +266,7 @@ static int multi1_read (char *name, FILE *fh) char buffer[1024]; char *fields[10]; int fields_num, read = 0, found_header = 0; - long long sum_rx = 0; - long long sum_tx = 0; + long long sum_users = 0; /* read the file until the "ROUTING TABLE" line is found (no more info after) */ while (fgets (buffer, sizeof (buffer), fh) != NULL) @@ -265,25 +290,24 @@ static int multi1_read (char *name, FILE *fh) if (fields_num < 4) continue; - if (sumover_allusers) - /* If so, sum over all users, ignore the individuals*/ + if (collect_user_count) + /* If so, sum all users, ignore the individuals*/ { - sum_rx += atoll(fields[2]); - sum_tx += atoll(fields[3]); + sum_users += 1; } - else + if (collect_individual_users) { if (new_naming_schema) { - iostats_submit (fields[0], /* "Common Name" */ - NULL, /* unused when in multimode */ + iostats_submit (name, /* vpn instance */ + fields[0], /* "Common Name" */ atoll (fields[2]), /* "Bytes Received" */ atoll (fields[3])); /* "Bytes Sent" */ } else { - iostats_submit (name, /* vpn instance */ - fields[0], /* "Common Name" */ + iostats_submit (fields[0], /* "Common Name" */ + NULL, /* unused when in multimode */ atoll (fields[2]), /* "Bytes Received" */ atoll (fields[3])); /* "Bytes Sent" */ } @@ -292,13 +316,11 @@ static int multi1_read (char *name, FILE *fh) read = 1; } - if (sumover_allusers) + if (collect_user_count) { - iostats_submit (name, /* vpn instance */ - "OverAllTraffic", /* "Common Name" */ - sum_rx, /* "Bytes Received" */ - sum_tx); /* "Bytes Sent" */ - } + numusers_submit(name, name, sum_users); + read = 1; + } return (read); } /* int multi1_read */ @@ -310,8 +332,7 @@ static int multi2_read (char *name, FILE *fh) char *fields[10]; const int max_fields = STATIC_ARRAY_SIZE (fields); int fields_num, read = 0; - long long sum_rx = 0; - long long sum_tx = 0; + long long sum_users = 0; while (fgets (buffer, sizeof (buffer), fh) != NULL) { @@ -329,13 +350,12 @@ static int multi2_read (char *name, FILE *fh) if (strcmp (fields[0], "CLIENT_LIST") != 0) continue; - if (sumover_allusers) - /* If so, sum over all users, ignore the individuals*/ + if (collect_user_count) + /* If so, sum all users, ignore the individuals*/ { - sum_rx += atoll(fields[2]); - sum_tx += atoll(fields[3]); + sum_users += 1; } - else + if (collect_individual_users) { if (new_naming_schema) { @@ -354,16 +374,15 @@ static int multi2_read (char *name, FILE *fh) atoll (fields[5])); /* "Bytes Sent" */ } } + read = 1; } - if (sumover_allusers) + if (collect_user_count) { - iostats_submit (name, /* vpn instance */ - "OverAllTraffic", /* "Common Name" */ - sum_rx, /* "Bytes Received" */ - sum_rx); /* "Bytes Sent" */ - } + numusers_submit(name, name, sum_users); + read = 1; + } return (read); } /* int multi2_read */ @@ -375,8 +394,7 @@ static int multi3_read (char *name, FILE *fh) char *fields[15]; const int max_fields = STATIC_ARRAY_SIZE (fields); int fields_num, read = 0; - long long sum_rx = 0; - long long sum_tx = 0; + long long sum_users = 0; while (fgets (buffer, sizeof (buffer), fh) != NULL) { @@ -397,13 +415,13 @@ static int multi3_read (char *name, FILE *fh) if (strcmp (fields[0], "CLIENT_LIST") != 0) continue; - if (sumover_allusers) - /* If so, sum over all users, ignore the individuals*/ + if (collect_user_count) + /* If so, sum all users, ignore the individuals*/ { - sum_rx += atoll(fields[2]); - sum_tx += atoll(fields[3]); + sum_users += 1; } - else + + if (collect_individual_users) { if (new_naming_schema) { @@ -425,13 +443,11 @@ static int multi3_read (char *name, FILE *fh) } } - if (sumover_allusers) + if (collect_user_count) { - iostats_submit (name, /* vpn instance */ - "OverAllTraffic", /* "Common Name" */ - sum_rx, /* "Bytes Received" */ - sum_rx); /* "Bytes Sent" */ - } + numusers_submit(name, name, sum_users); + read = 1; + } return (read); } /* int multi3_read */ @@ -452,7 +468,7 @@ static int openvpn_read (void) { char errbuf[1024]; WARNING ("openvpn plugin: fopen(%s) failed: %s", vpn_list[i]->file, - sstrerror (errno, errbuf, sizeof (errbuf))); + sstrerror (errno, errbuf, sizeof (errbuf))); continue; } @@ -564,7 +580,7 @@ static int openvpn_config (const char *key, const char *value) if (status_version == 0) { WARNING ("openvpn plugin: unable to detect status version, \ - discarding status file \"%s\".", value); + discarding status file \"%s\".", value); return (1); } @@ -573,7 +589,7 @@ static int openvpn_config (const char *key, const char *value) { char errbuf[1024]; WARNING ("openvpn plugin: sstrdup failed: %s", - sstrerror (errno, errbuf, sizeof (errbuf))); + sstrerror (errno, errbuf, sizeof (errbuf))); return (1); } @@ -614,7 +630,7 @@ static int openvpn_config (const char *key, const char *value) { char errbuf[1024]; ERROR ("openvpn plugin: malloc failed: %s", - sstrerror (errno, errbuf, sizeof (errbuf))); + sstrerror (errno, errbuf, sizeof (errbuf))); sfree (temp->file); sfree (temp); @@ -627,16 +643,14 @@ static int openvpn_config (const char *key, const char *value) DEBUG ("openvpn plugin: status file \"%s\" added", temp->file); } /* if (strcasecmp ("StatusFile", key) == 0) */ - else if (strcasecmp ("Compression", key) == 0) + else if ((strcasecmp ("CollectCompression", key) == 0) + || (strcasecmp ("Compression", key) == 0)) /* old, deprecated name */ { - if (IS_TRUE (value)) - store_compression = 1; + if (IS_FALSE (value)) + collect_compression = 0; else - { - store_compression = 0; - DEBUG ("openvpn plugin: no 'compression statistcs' collected"); - } - } /* if (strcasecmp ("Compression", key) == 0) */ + collect_compression = 1; + } /* if (strcasecmp ("CollectCompression", key) == 0) */ else if (strcasecmp ("ImprovedNamingSchema", key) == 0) { if (IS_TRUE (value)) @@ -649,18 +663,20 @@ static int openvpn_config (const char *key, const char *value) new_naming_schema = 0; } } /* if (strcasecmp ("ImprovedNamingSchema", key) == 0) */ - else if (strcasecmp("SumOverAllUsers", key) == 0) + else if (strcasecmp("CollectUserCount", key) == 0) { if (IS_TRUE(value)) - { - DEBUG ("openvpn plugin: Summing up over all users"); - sumover_allusers = 1; - } + collect_user_count = 1; else - { - sumover_allusers = 1; - } - } /* if (strcasecmp("SumOverAllUsers", key) == 0) */ + collect_user_count = 0; + } /* if (strcasecmp("CollectUserCount", key) == 0) */ + else if (strcasecmp("CollectIndividualUsers", key) == 0) + { + if (IS_FALSE (value)) + collect_individual_users = 0; + else + collect_individual_users = 1; + } /* if (strcasecmp("CollectIndividualUsers", key) == 0) */ else { return (-1); @@ -685,12 +701,29 @@ static int openvpn_shutdown (void) return (0); } /* int openvpn_shutdown */ +static int openvpn_init (void) +{ + if (!collect_individual_users + && !collect_compression + && !collect_user_count) + { + WARNING ("OpenVPN plugin: Neither `CollectIndividualUsers', " + "`CollectCompression', nor `CollectUserCount' is true. There's no " + "data left to collect."); + return (-1); + } + + plugin_register_read ("openvpn", openvpn_read); + plugin_register_shutdown ("openvpn", openvpn_shutdown); + + return (0); +} /* int openvpn_init */ + void module_register (void) { plugin_register_config ("openvpn", openvpn_config, config_keys, config_keys_num); - plugin_register_read ("openvpn", openvpn_read); - plugin_register_shutdown ("openvpn", openvpn_shutdown); + plugin_register_init ("openvpn", openvpn_init); } /* void module_register */ /* vim: set sw=2 ts=2 : */