From f31a12e006a694dca717c951b466fb3e3970aa43 Mon Sep 17 00:00:00 2001
From: Fabien Wernli <faxmodem@collectd.org>
Date: Tue, 20 Jan 2015 15:21:06 +0100
Subject: [PATCH] implement reporting of ncpu

Change-Id: Ia305b74139352f16f71b1f747875d6c7a0c376a4
---
 src/collectd.conf.pod |  5 +++++
 src/cpu.c             | 31 +++++++++++++++++++++++++++++++
 2 files changed, 36 insertions(+)

diff --git a/src/collectd.conf.pod b/src/collectd.conf.pod
index f3ff4bb9..6562158f 100644
--- a/src/collectd.conf.pod
+++ b/src/collectd.conf.pod
@@ -1447,6 +1447,11 @@ are set to B<true>. In this case, by default, metrics will be reported as
 Jiffies. By setting this option to B<true>, you can request percentage values
 in the un-aggregated (per-CPU, per-state) mode as well.
 
+=item B<ReportNumCpu> B<false>|B<true>
+
+When set to B<true>, reports the number of available CPUs.
+Defaults to B<false>.
+
 =back
 
 =head2 Plugin C<cpufreq>
diff --git a/src/cpu.c b/src/cpu.c
index 80029667..d194872f 100644
--- a/src/cpu.c
+++ b/src/cpu.c
@@ -192,11 +192,13 @@ static size_t global_cpu_num = 0;
 static _Bool report_by_cpu = 1;
 static _Bool report_by_state = 1;
 static _Bool report_percent = 0;
+static _Bool report_num_cpu = 0;
 
 static const char *config_keys[] =
 {
 	"ReportByCpu",
 	"ReportByState",
+	"ReportNumCpu",
 	"ValuesPercentage"
 };
 static int config_keys_num = STATIC_ARRAY_SIZE (config_keys);
@@ -209,6 +211,8 @@ static int cpu_config (char const *key, char const *value) /* {{{ */
 		report_percent = IS_TRUE (value) ? 1 : 0;
 	else if (strcasecmp (key, "ReportByState") == 0)
 		report_by_state = IS_TRUE (value) ? 1 : 0;
+	else if (strcasecmp (key, "ReportNumCpu") == 0)
+		report_num_cpu = IS_TRUE (value) ? 1 : 0;
 	else
 		return (-1);
 
@@ -459,6 +463,28 @@ static void cpu_commit_one (int cpu_num, /* {{{ */
 	}
 } /* }}} void cpu_commit_one */
 
+/* Commits the number of cores */
+static void cpu_commit_num_cpu (gauge_t num_cpu) /* {{{ */
+{
+//// static void submit_value (int cpu_num, int cpu_state, const char *type, value_t value)
+	value_t values[1];
+	value_list_t vl = VALUE_LIST_INIT;
+
+	/// memcpy(&values[0], &value, sizeof(value));
+	values[0].gauge = num_cpu;
+
+	vl.values = values;
+	vl.values_len = 1;
+
+	sstrncpy (vl.host, hostname_g, sizeof (vl.host));
+	sstrncpy (vl.plugin, "cpu", sizeof (vl.plugin));
+	sstrncpy (vl.type, "gauge", sizeof (vl.type));
+	sstrncpy (vl.type_instance, "ncpu",
+			sizeof (vl.type_instance));
+
+	plugin_dispatch_values (&vl);
+} /* }}} void cpu_commit_num_cpu */
+
 /* Resets the internal aggregation. This is called by the read callback after
  * each iteration / after each call to cpu_commit(). */
 static void cpu_reset (void) /* {{{ */
@@ -493,6 +519,11 @@ static void cpu_commit (void) /* {{{ */
 		NAN, NAN, NAN, NAN, NAN, NAN, NAN, NAN, NAN, NAN /* Batman! */
 	};
 
+	if (report_num_cpu)
+	{
+		cpu_commit_num_cpu ((gauge_t) global_cpu_num);
+	}
+
 	if (report_by_state && report_by_cpu && !report_percent)
 	{
 		cpu_commit_without_aggregation ();
-- 
2.30.2