projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'collectd-5.6' into collectd-5.7
[collectd.git]
/
src
/
intel_rdt.c
diff --git
a/src/intel_rdt.c
b/src/intel_rdt.c
index
21f3a20
..
7328836
100644
(file)
--- a/
src/intel_rdt.c
+++ b/
src/intel_rdt.c
@@
-25,8
+25,8
@@
* Serhiy Pshyk <serhiyx.pshyk@intel.com>
**/
* Serhiy Pshyk <serhiyx.pshyk@intel.com>
**/
-#include "collectd.h"
#include "common.h"
#include "common.h"
+#include "collectd.h"
#include <pqos.h>
#include <pqos.h>
@@
-36,6
+36,11
@@
#define RDT_MAX_SOCKET_CORES 64
#define RDT_MAX_CORES (RDT_MAX_SOCKET_CORES * RDT_MAX_SOCKETS)
#define RDT_MAX_SOCKET_CORES 64
#define RDT_MAX_CORES (RDT_MAX_SOCKET_CORES * RDT_MAX_SOCKETS)
+typedef enum {
+ UNKNOWN = 0,
+ CONFIGURATION_ERROR,
+} rdt_config_status;
+
struct rdt_core_group_s {
char *desc;
size_t num_cores;
struct rdt_core_group_s {
char *desc;
size_t num_cores;
@@
-56,6
+61,8
@@
typedef struct rdt_ctx_s rdt_ctx_t;
static rdt_ctx_t *g_rdt = NULL;
static rdt_ctx_t *g_rdt = NULL;
+static rdt_config_status g_state = UNKNOWN;
+
static int isdup(const uint64_t *nums, size_t size, uint64_t val) {
for (size_t i = 0; i < size; i++)
if (nums[i] == val)
static int isdup(const uint64_t *nums, size_t size, uint64_t val) {
for (size_t i = 0; i < size; i++)
if (nums[i] == val)
@@
-523,8
+530,14
@@
static int rdt_config(oconfig_item_t *ci) {
int ret = 0;
ret = rdt_preinit();
int ret = 0;
ret = rdt_preinit();
- if (ret != 0)
- return ret;
+ if (ret != 0) {
+ g_state = CONFIGURATION_ERROR;
+ /* if we return -1 at this point collectd
+ reports a failure in configuration and
+ aborts
+ */
+ goto exit;
+ }
for (int i = 0; i < ci->children_num; i++) {
oconfig_item_t *child = ci->children + i;
for (int i = 0; i < ci->children_num; i++) {
oconfig_item_t *child = ci->children + i;
@@
-532,8
+545,14
@@
static int rdt_config(oconfig_item_t *ci) {
if (strcasecmp("Cores", child->key) == 0) {
ret = rdt_config_cgroups(child);
if (strcasecmp("Cores", child->key) == 0) {
ret = rdt_config_cgroups(child);
- if (ret != 0)
- return ret;
+ if (ret != 0) {
+ g_state = CONFIGURATION_ERROR;
+ /* if we return -1 at this point collectd
+ reports a failure in configuration and
+ aborts
+ */
+ goto exit;
+ }
#if COLLECT_DEBUG
rdt_dump_cgroups();
#if COLLECT_DEBUG
rdt_dump_cgroups();
@@
-544,6
+563,7
@@
static int rdt_config(oconfig_item_t *ci) {
}
}
}
}
+exit:
return (0);
}
return (0);
}
@@
-626,6
+646,9
@@
static int rdt_read(__attribute__((unused)) user_data_t *ud) {
static int rdt_init(void) {
int ret;
static int rdt_init(void) {
int ret;
+ if(g_state == CONFIGURATION_ERROR)
+ return (-1);
+
ret = rdt_preinit();
if (ret != 0)
return ret;
ret = rdt_preinit();
if (ret != 0)
return ret;