From: Florian Forster Date: Wed, 21 Sep 2016 06:48:12 +0000 (+0200) Subject: dpkgstat plugin: Filter through clang-format. X-Git-Tag: collectd-5.7.0~73^2 X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=d0a97673ed7746184fc2338afa3c200a34310196;p=collectd.git dpkgstat plugin: Filter through clang-format. --- diff --git a/src/dpdkstat.c b/src/dpdkstat.c index a5ed03e2..58425437 100644 --- a/src/dpdkstat.c +++ b/src/dpdkstat.c @@ -4,15 +4,15 @@ * * Copyright(c) 2016 Intel Corporation. All rights reserved. * - * Permission is hereby granted, free of charge, to any person obtaining a copy of - * this software and associated documentation files (the "Software"), to deal in - * the Software without restriction, including without limitation the rights to - * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies - * of the Software, and to permit persons to whom the Software is furnished to do - * so, subject to the following conditions: + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: * - * The above copyright notice and this permission notice shall be included in all - * copies or substantial portions of the Software. + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, @@ -59,7 +59,7 @@ #define DPDK_DEFAULT_RTE_CONFIG "/var/run/.rte_config" #define DPDK_MAX_ARGC 8 -#define DPDKSTAT_MAX_BUFFER_SIZE (4096*4) +#define DPDKSTAT_MAX_BUFFER_SIZE (4096 * 4) #define DPDK_SHM_NAME "dpdk_collectd_stats_shm" #define ERR_BUF_SIZE 1024 #define REINIT_SHM 1 @@ -92,11 +92,11 @@ struct dpdk_config_s { char port_name[RTE_MAX_ETHPORTS][DATA_MAX_NAME_LEN]; uint32_t eal_argc; /* Helper info */ - int collectd_reinit_shm; + int collectd_reinit_shm; pid_t helper_pid; sem_t sema_helper_get_stats; sem_t sema_stats_in_shm; - int helper_pipes[2]; + int helper_pipes[2]; enum DPDK_HELPER_STATUS helper_status; enum DPDK_HELPER_ACTION helper_action; /* xstats info */ @@ -124,37 +124,37 @@ static int dpdk_shm_cleanup(void); static int dpdk_shm_init(size_t size); /* Write the default configuration to the g_configuration instances */ -static void dpdk_config_init_default(void) -{ +static void dpdk_config_init_default(void) { g_configuration->interval = plugin_get_interval(); if (g_configuration->interval == cf_get_default_interval()) - WARNING("dpdkstat: No time interval was configured, default value %lu ms is set", - CDTIME_T_TO_MS(g_configuration->interval)); - /* Default is all ports enabled */ - g_configuration->enabled_port_mask = ~0; - g_configuration->eal_argc = DPDK_MAX_ARGC; - g_configuration->eal_initialized = 0; - ssnprintf(g_configuration->coremask, DATA_MAX_NAME_LEN, "%s", "0xf"); - ssnprintf(g_configuration->memory_channels, DATA_MAX_NAME_LEN, "%s", "1"); - ssnprintf(g_configuration->process_type, DATA_MAX_NAME_LEN, "%s", "secondary"); - ssnprintf(g_configuration->file_prefix, DATA_MAX_NAME_LEN, "%s", - DPDK_DEFAULT_RTE_CONFIG); - - for (int i = 0; i < RTE_MAX_ETHPORTS; i++) - g_configuration->port_name[i][0] = 0; + WARNING("dpdkstat: No time interval was configured, default value %lu ms " + "is set", + CDTIME_T_TO_MS(g_configuration->interval)); + /* Default is all ports enabled */ + g_configuration->enabled_port_mask = ~0; + g_configuration->eal_argc = DPDK_MAX_ARGC; + g_configuration->eal_initialized = 0; + ssnprintf(g_configuration->coremask, DATA_MAX_NAME_LEN, "%s", "0xf"); + ssnprintf(g_configuration->memory_channels, DATA_MAX_NAME_LEN, "%s", "1"); + ssnprintf(g_configuration->process_type, DATA_MAX_NAME_LEN, "%s", + "secondary"); + ssnprintf(g_configuration->file_prefix, DATA_MAX_NAME_LEN, "%s", + DPDK_DEFAULT_RTE_CONFIG); + + for (int i = 0; i < RTE_MAX_ETHPORTS; i++) + g_configuration->port_name[i][0] = 0; } -static int dpdk_config(oconfig_item_t *ci) -{ +static int dpdk_config(oconfig_item_t *ci) { int port_counter = 0; char errbuf[ERR_BUF_SIZE]; /* Allocate g_configuration and * initialize a POSIX SHared Memory (SHM) object. */ - int err = dpdk_shm_init(sizeof (dpdk_config_t)); + int err = dpdk_shm_init(sizeof(dpdk_config_t)); if (err) { - DEBUG("dpdkstat: error in shm_init, %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + DEBUG("dpdkstat: error in shm_init, %s", + sstrerror(errno, errbuf, sizeof(errbuf))); return -1; } @@ -166,40 +166,42 @@ static int dpdk_config(oconfig_item_t *ci) if (strcasecmp("Coremask", child->key) == 0) { cf_util_get_string_buffer(child, g_configuration->coremask, - sizeof (g_configuration->coremask)); + sizeof(g_configuration->coremask)); DEBUG("dpdkstat:COREMASK %s ", g_configuration->coremask); } else if (strcasecmp("MemoryChannels", child->key) == 0) { cf_util_get_string_buffer(child, g_configuration->memory_channels, - sizeof (g_configuration->memory_channels)); + sizeof(g_configuration->memory_channels)); DEBUG("dpdkstat:Memory Channels %s ", g_configuration->memory_channels); } else if (strcasecmp("SocketMemory", child->key) == 0) { cf_util_get_string_buffer(child, g_configuration->socket_memory, - sizeof (g_configuration->memory_channels)); + sizeof(g_configuration->memory_channels)); DEBUG("dpdkstat: socket mem %s ", g_configuration->socket_memory); } else if (strcasecmp("ProcessType", child->key) == 0) { cf_util_get_string_buffer(child, g_configuration->process_type, - sizeof (g_configuration->process_type)); + sizeof(g_configuration->process_type)); DEBUG("dpdkstat: proc type %s ", g_configuration->process_type); } else if ((strcasecmp("FilePrefix", child->key) == 0) && - (child->values[0].type == OCONFIG_TYPE_STRING)) { - ssnprintf(g_configuration->file_prefix, DATA_MAX_NAME_LEN, "/var/run/.%s_config", - child->values[0].value.string); + (child->values[0].type == OCONFIG_TYPE_STRING)) { + ssnprintf(g_configuration->file_prefix, DATA_MAX_NAME_LEN, + "/var/run/.%s_config", child->values[0].value.string); DEBUG("dpdkstat: file prefix %s ", g_configuration->file_prefix); } else if ((strcasecmp("EnabledPortMask", child->key) == 0) && - (child->values[0].type == OCONFIG_TYPE_NUMBER)) { - g_configuration->enabled_port_mask = (uint32_t) child->values[0].value.number; - DEBUG("dpdkstat: Enabled Port Mask %u", g_configuration->enabled_port_mask); + (child->values[0].type == OCONFIG_TYPE_NUMBER)) { + g_configuration->enabled_port_mask = + (uint32_t)child->values[0].value.number; + DEBUG("dpdkstat: Enabled Port Mask %u", + g_configuration->enabled_port_mask); } else if (strcasecmp("PortName", child->key) == 0) { - cf_util_get_string_buffer(child, g_configuration->port_name[port_counter], - sizeof (g_configuration->port_name[port_counter])); + cf_util_get_string_buffer( + child, g_configuration->port_name[port_counter], + sizeof(g_configuration->port_name[port_counter])); DEBUG("dpdkstat: Port %d Name: %s ", port_counter, - g_configuration->port_name[port_counter]); + g_configuration->port_name[port_counter]); port_counter++; } else { - WARNING("dpdkstat: The config option \"%s\" is unknown.", - child->key); + WARNING("dpdkstat: The config option \"%s\" is unknown.", child->key); } - } /* End for (int i = 0; i < ci->children_num; i++)*/ + } /* End for (int i = 0; i < ci->children_num; i++)*/ g_configured = 1; /* Bypass configuration in dpdk_shm_init(). */ return 0; @@ -209,14 +211,13 @@ static int dpdk_config(oconfig_item_t *ci) * Allocate g_configuration and initialize SHared Memory (SHM) * for config and helper process */ -static int dpdk_shm_init(size_t size) -{ +static int dpdk_shm_init(size_t size) { /* * Check if SHM is already configured: when config items are provided, the * config function initializes SHM. If there is no config, then init() will * just return. */ - if(g_configuration) + if (g_configuration) return 0; char errbuf[ERR_BUF_SIZE]; @@ -225,21 +226,21 @@ static int dpdk_shm_init(size_t size) int fd = shm_open(DPDK_SHM_NAME, O_CREAT | O_TRUNC | O_RDWR, 0666); if (fd < 0) { WARNING("dpdkstat:Failed to open %s as SHM:%s", DPDK_SHM_NAME, - sstrerror(errno, errbuf, sizeof (errbuf))); + sstrerror(errno, errbuf, sizeof(errbuf))); goto fail; } /* Set the size of the shared memory object. */ int ret = ftruncate(fd, size); if (ret != 0) { - WARNING("dpdkstat:Failed to resize SHM:%s", sstrerror(errno, errbuf, - sizeof (errbuf))); + WARNING("dpdkstat:Failed to resize SHM:%s", + sstrerror(errno, errbuf, sizeof(errbuf))); goto fail_close; } /* Map the shared memory object into this process' virtual address space. */ g_configuration = mmap(0, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); if (g_configuration == MAP_FAILED) { - WARNING("dpdkstat:Failed to mmap SHM:%s", sstrerror(errno, errbuf, - sizeof (errbuf))); + WARNING("dpdkstat:Failed to mmap SHM:%s", + sstrerror(errno, errbuf, sizeof(errbuf))); goto fail_close; } /* @@ -253,15 +254,15 @@ static int dpdk_shm_init(size_t size) /* Initialize the semaphores for SHM use */ int err = sem_init(&g_configuration->sema_helper_get_stats, 1, 0); - if(err) { - ERROR("dpdkstat semaphore init failed: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + if (err) { + ERROR("dpdkstat semaphore init failed: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); goto fail_close; } err = sem_init(&g_configuration->sema_stats_in_shm, 1, 0); - if(err) { - ERROR("dpdkstat semaphore init failed: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + if (err) { + ERROR("dpdkstat semaphore init failed: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); goto fail_close; } @@ -279,16 +280,16 @@ fail: return -1; } -static int dpdk_re_init_shm() -{ +static int dpdk_re_init_shm() { dpdk_config_t temp_config; memcpy(&temp_config, g_configuration, sizeof(dpdk_config_t)); - DEBUG("dpdkstat: %s: ports %"PRIu32", xstats %"PRIu32, __func__, temp_config.num_ports, - temp_config.num_xstats); + DEBUG("dpdkstat: %s: ports %" PRIu32 ", xstats %" PRIu32, __func__, + temp_config.num_ports, temp_config.num_xstats); - size_t shm_xstats_size = sizeof(dpdk_config_t) + (sizeof(struct rte_eth_xstats) * - g_configuration->num_xstats); - DEBUG("=== SHM new size for %"PRIu32" xstats", g_configuration->num_xstats); + size_t shm_xstats_size = + sizeof(dpdk_config_t) + + (sizeof(struct rte_eth_xstats) * g_configuration->num_xstats); + DEBUG("=== SHM new size for %" PRIu32 " xstats", g_configuration->num_xstats); int err = dpdk_shm_cleanup(); if (err) { @@ -301,17 +302,16 @@ static int dpdk_re_init_shm() return err; } /* If the XML config() function has been run, don't re-initialize defaults */ - if(!g_configured) + if (!g_configured) dpdk_config_init_default(); memcpy(g_configuration, &temp_config, sizeof(dpdk_config_t)); g_configuration->collectd_reinit_shm = 0; - g_configuration->xstats = (struct rte_eth_xstats *) (g_configuration + 1); + g_configuration->xstats = (struct rte_eth_xstats *)(g_configuration + 1); return 0; } -static int dpdk_init(void) -{ +static int dpdk_init(void) { int err = dpdk_shm_init(sizeof(dpdk_config_t)); if (err) { ERROR("dpdkstat: %s : error %d in shm_init()", __func__, err); @@ -319,15 +319,14 @@ static int dpdk_init(void) } /* If the XML config() function has been run, dont re-initialize defaults */ - if(!g_configured) { + if (!g_configured) { dpdk_config_init_default(); } return 0; } -static int dpdk_helper_stop(int reset) -{ +static int dpdk_helper_stop(int reset) { g_configuration->helper_status = DPDK_HELPER_GRACEFUL_QUIT; if (reset) { g_configuration->eal_initialized = 0; @@ -341,15 +340,14 @@ static int dpdk_helper_stop(int reset) int err = kill(g_configuration->helper_pid, SIGKILL); if (err) { char errbuf[ERR_BUF_SIZE]; - WARNING("dpdkstat: error sending kill to helper: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + WARNING("dpdkstat: error sending kill to helper: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); } return 0; } -static int dpdk_helper_spawn(enum DPDK_HELPER_ACTION action) -{ +static int dpdk_helper_spawn(enum DPDK_HELPER_ACTION action) { char errbuf[ERR_BUF_SIZE]; g_configuration->eal_initialized = 0; g_configuration->helper_action = action; @@ -358,24 +356,24 @@ static int dpdk_helper_spawn(enum DPDK_HELPER_ACTION action) * logging EAL failures, as rte_eal_init() calls rte_panic(). */ if (pipe(g_configuration->helper_pipes) != 0) { - DEBUG("dpdkstat: Could not create helper pipe: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + DEBUG("dpdkstat: Could not create helper pipe: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); return -1; } int pipe0_flags = fcntl(g_configuration->helper_pipes[0], F_GETFL, 0); int pipe1_flags = fcntl(g_configuration->helper_pipes[1], F_GETFL, 0); if (pipe0_flags == -1 || pipe1_flags == -1) { - WARNING("dpdkstat: Failed setting up pipe flags: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + WARNING("dpdkstat: Failed setting up pipe flags: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); } - int pipe0_err = fcntl(g_configuration->helper_pipes[0], F_SETFL, pipe1_flags - | O_NONBLOCK); - int pipe1_err = fcntl(g_configuration->helper_pipes[1], F_SETFL, pipe0_flags - | O_NONBLOCK); + int pipe0_err = fcntl(g_configuration->helper_pipes[0], F_SETFL, + pipe1_flags | O_NONBLOCK); + int pipe1_err = fcntl(g_configuration->helper_pipes[1], F_SETFL, + pipe0_flags | O_NONBLOCK); if (pipe0_err == -1 || pipe1_err == -1) { - WARNING("dpdkstat: Failed setting up pipes: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + WARNING("dpdkstat: Failed setting up pipes: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); } pid_t pid = fork(); @@ -393,8 +391,8 @@ static int dpdk_helper_spawn(enum DPDK_HELPER_ACTION action) dpdk_helper_run(); exit(0); } else { - ERROR("dpdkstat: Failed to fork helper process: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + ERROR("dpdkstat: Failed to fork helper process: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); return -1; } return 0; @@ -404,8 +402,7 @@ static int dpdk_helper_spawn(enum DPDK_HELPER_ACTION action) * Initialize the DPDK EAL, if this returns, EAL is successfully initialized. * On failure, the EAL prints an error message, and the helper process exits. */ -static int dpdk_helper_init_eal(void) -{ +static int dpdk_helper_init_eal(void) { g_configuration->helper_status = DPDK_HELPER_INITIALIZING_EAL; char *argp[(g_configuration->eal_argc) + 1]; int i = 0; @@ -424,7 +421,7 @@ static int dpdk_helper_init_eal(void) argp[i++] = g_configuration->socket_memory; } if (strcasecmp(g_configuration->file_prefix, "") != 0 && - strcasecmp(g_configuration->file_prefix, DPDK_DEFAULT_RTE_CONFIG) != 0) { + strcasecmp(g_configuration->file_prefix, DPDK_DEFAULT_RTE_CONFIG) != 0) { argp[i++] = "--file-prefix"; argp[i++] = g_configuration->file_prefix; } @@ -443,23 +440,23 @@ static int dpdk_helper_init_eal(void) return 0; } -static int dpdk_helper_run (void) -{ +static int dpdk_helper_run(void) { char errbuf[ERR_BUF_SIZE]; pid_t ppid = getppid(); g_configuration->helper_status = DPDK_HELPER_WAITING_ON_PRIMARY; - while (1) { + while (1) { /* sem_timedwait() to avoid blocking forever */ struct timespec ts; cdtime_t now = cdtime(); cdtime_t safety_period = MS_TO_CDTIME_T(1500); - CDTIME_T_TO_TIMESPEC(now + safety_period + g_configuration->interval * 2, &ts); + CDTIME_T_TO_TIMESPEC(now + safety_period + g_configuration->interval * 2, + &ts); int ret = sem_timedwait(&g_configuration->sema_helper_get_stats, &ts); if (ret == -1 && errno == ETIMEDOUT) { ERROR("dpdkstat-helper: sem timedwait()" - " timeout, did collectd terminate?"); + " timeout, did collectd terminate?"); dpdk_helper_stop(RESET); } /* Parent PID change means collectd died so quit the helper process. */ @@ -472,7 +469,7 @@ static int dpdk_helper_run (void) if (!rte_eal_primary_proc_alive(g_configuration->file_prefix)) { if (g_configuration->eal_initialized) { WARNING("dpdkstat-helper: no primary alive but EAL initialized:" - " quitting."); + " quitting."); dpdk_helper_stop(RESET); } g_configuration->helper_status = DPDK_HELPER_WAITING_ON_PRIMARY; @@ -483,7 +480,7 @@ static int dpdk_helper_run (void) if (!g_configuration->eal_initialized) { /* Initialize EAL. */ int ret = dpdk_helper_init_eal(); - if(ret != 0) { + if (ret != 0) { WARNING("ERROR INITIALIZING EAL"); dpdk_helper_stop(RESET); } @@ -509,7 +506,7 @@ static int dpdk_helper_run (void) if (g_configuration->helper_action == DPDK_HELPER_ACTION_COUNT_STATS) { len = rte_eth_xstats_get(i, NULL, 0); if (len < 0) { - ERROR("dpdkstat-helper: Cannot get xstats count on port %"PRIu8, i); + ERROR("dpdkstat-helper: Cannot get xstats count on port %" PRIu8, i); break; } num_xstats += len; @@ -519,11 +516,13 @@ static int dpdk_helper_run (void) } else { len = g_configuration->num_stats_in_port[enabled_port_count]; g_configuration->port_read_time[enabled_port_count] = cdtime(); - ret = rte_eth_xstats_get(i, g_configuration->xstats + num_xstats, - g_configuration->num_stats_in_port[enabled_port_count]); + ret = rte_eth_xstats_get( + i, g_configuration->xstats + num_xstats, + g_configuration->num_stats_in_port[enabled_port_count]); if (ret < 0 || ret != len) { - DEBUG("dpdkstat-helper: Error reading xstats on port %"PRIu8" len = %d", - i, len); + DEBUG("dpdkstat-helper: Error reading xstats on port %" PRIu8 + " len = %d", + i, len); break; } num_xstats += g_configuration->num_stats_in_port[enabled_port_count]; @@ -534,8 +533,8 @@ static int dpdk_helper_run (void) if (g_configuration->helper_action == DPDK_HELPER_ACTION_COUNT_STATS) { g_configuration->num_ports = enabled_port_count; g_configuration->num_xstats = num_xstats; - DEBUG("dpdkstat-helper ports: %"PRIu32", num stats: %"PRIu32, - g_configuration->num_ports, g_configuration->num_xstats); + DEBUG("dpdkstat-helper ports: %" PRIu32 ", num stats: %" PRIu32, + g_configuration->num_ports, g_configuration->num_xstats); /* Exit, allowing collectd to re-init SHM to the right size */ g_configuration->collectd_reinit_shm = REINIT_SHM; dpdk_helper_stop(NO_RESET); @@ -543,8 +542,8 @@ static int dpdk_helper_run (void) /* Now kick collectd send thread to send the stats */ int err = sem_post(&g_configuration->sema_stats_in_shm); if (err) { - WARNING("dpdkstat: error posting semaphore to helper %s", sstrerror(errno, - errbuf, sizeof (errbuf))); + WARNING("dpdkstat: error posting semaphore to helper %s", + sstrerror(errno, errbuf, sizeof(errbuf))); dpdk_helper_stop(RESET); } } /* while(1) */ @@ -552,102 +551,84 @@ static int dpdk_helper_run (void) return 0; } -static void dpdk_submit_xstats(const char* dev_name, - const struct rte_eth_xstats *xstats, uint32_t counters, cdtime_t port_read_time) -{ +static void dpdk_submit_xstats(const char *dev_name, + const struct rte_eth_xstats *xstats, + uint32_t counters, cdtime_t port_read_time) { for (uint32_t j = 0; j < counters; j++) { value_list_t dpdkstat_vl = VALUE_LIST_INIT; char *type_end; - dpdkstat_vl.values = &(value_t) { .derive = (derive_t) xstats[j].value }; + dpdkstat_vl.values = &(value_t){.derive = (derive_t)xstats[j].value}; dpdkstat_vl.values_len = 1; /* Submit stats one at a time */ dpdkstat_vl.time = port_read_time; - sstrncpy(dpdkstat_vl.host, hostname_g, sizeof (dpdkstat_vl.host)); - sstrncpy(dpdkstat_vl.plugin, "dpdkstat", sizeof (dpdkstat_vl.plugin)); + sstrncpy(dpdkstat_vl.host, hostname_g, sizeof(dpdkstat_vl.host)); + sstrncpy(dpdkstat_vl.plugin, "dpdkstat", sizeof(dpdkstat_vl.plugin)); sstrncpy(dpdkstat_vl.plugin_instance, dev_name, - sizeof (dpdkstat_vl.plugin_instance)); + sizeof(dpdkstat_vl.plugin_instance)); type_end = strrchr(xstats[j].name, '_'); if ((type_end != NULL) && - (strncmp(xstats[j].name, "rx_", strlen("rx_")) == 0)) { + (strncmp(xstats[j].name, "rx_", strlen("rx_")) == 0)) { if (strncmp(type_end, "_errors", strlen("_errors")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_errors", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_dropped", strlen("_dropped")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_dropped", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_dropped", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_bytes", strlen("_bytes")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_octets", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_octets", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_packets", strlen("_packets")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_packets", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_packets", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_placement", strlen("_placement")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_errors", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_buff", strlen("_buff")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_rx_errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_rx_errors", sizeof(dpdkstat_vl.type)); } else { /* Does not fit obvious type: use a more generic one */ - sstrncpy(dpdkstat_vl.type, "derive", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "derive", sizeof(dpdkstat_vl.type)); } } else if ((type_end != NULL) && - (strncmp(xstats[j].name, "tx_", strlen("tx_"))) == 0) { + (strncmp(xstats[j].name, "tx_", strlen("tx_"))) == 0) { if (strncmp(type_end, "_errors", strlen("_errors")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_tx_errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_tx_errors", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_dropped", strlen("_dropped")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_tx_dropped", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_tx_dropped", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_bytes", strlen("_bytes")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_tx_octets", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_tx_octets", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_packets", strlen("_packets")) == 0) { - sstrncpy(dpdkstat_vl.type, "if_tx_packets", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "if_tx_packets", sizeof(dpdkstat_vl.type)); } else { /* Does not fit obvious type: use a more generic one */ - sstrncpy(dpdkstat_vl.type, "derive", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "derive", sizeof(dpdkstat_vl.type)); } } else if ((type_end != NULL) && - (strncmp(xstats[j].name, "flow_", strlen("flow_"))) == 0) { + (strncmp(xstats[j].name, "flow_", strlen("flow_"))) == 0) { if (strncmp(type_end, "_filters", strlen("_filters")) == 0) { - sstrncpy(dpdkstat_vl.type, "operations", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "operations", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_errors", strlen("_errors")) == 0) { - sstrncpy(dpdkstat_vl.type, "errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "errors", sizeof(dpdkstat_vl.type)); } else if (strncmp(type_end, "_filters", strlen("_filters")) == 0) { - sstrncpy(dpdkstat_vl.type, "filter_result", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "filter_result", sizeof(dpdkstat_vl.type)); } } else if ((type_end != NULL) && - (strncmp(xstats[j].name, "mac_", strlen("mac_"))) == 0) { + (strncmp(xstats[j].name, "mac_", strlen("mac_"))) == 0) { if (strncmp(type_end, "_errors", strlen("_errors")) == 0) { - sstrncpy(dpdkstat_vl.type, "errors", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "errors", sizeof(dpdkstat_vl.type)); } } else { /* Does not fit obvious type, or strrchr error: * use a more generic type */ - sstrncpy(dpdkstat_vl.type, "derive", - sizeof (dpdkstat_vl.type)); + sstrncpy(dpdkstat_vl.type, "derive", sizeof(dpdkstat_vl.type)); } sstrncpy(dpdkstat_vl.type_instance, xstats[j].name, - sizeof (dpdkstat_vl.type_instance)); + sizeof(dpdkstat_vl.type_instance)); plugin_dispatch_values(&dpdkstat_vl); } } -static int dpdk_read(user_data_t *ud) -{ +static int dpdk_read(user_data_t *ud) { int ret = 0; /* @@ -665,16 +646,16 @@ static int dpdk_read(user_data_t *ud) * alive at dpdk_init() time. */ if (g_configuration->helper_status == DPDK_HELPER_NOT_INITIALIZED || - g_configuration->helper_status == DPDK_HELPER_GRACEFUL_QUIT) { + g_configuration->helper_status == DPDK_HELPER_GRACEFUL_QUIT) { int action = DPDK_HELPER_ACTION_SEND_STATS; - if(g_configuration->num_xstats == 0) + if (g_configuration->num_xstats == 0) action = DPDK_HELPER_ACTION_COUNT_STATS; /* Spawn the helper thread to count stats or to read stats. */ int err = dpdk_helper_spawn(action); if (err) { char errbuf[ERR_BUF_SIZE]; - ERROR("dpdkstat: error spawning helper %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + ERROR("dpdkstat: error spawning helper %s", + sstrerror(errno, errbuf, sizeof(errbuf))); return -1; } } @@ -694,15 +675,14 @@ static int dpdk_read(user_data_t *ud) /* non blocking check on helper logging pipe */ struct pollfd fds = { - .fd = g_configuration->helper_pipes[0], - .events = POLLIN, + .fd = g_configuration->helper_pipes[0], .events = POLLIN, }; int data_avail = poll(&fds, 1, 0); if (data_avail < 0) { char errbuf[ERR_BUF_SIZE]; if (errno != EINTR || errno != EAGAIN) ERROR("dpdkstats: poll(2) failed: %s", - sstrerror(errno, errbuf, sizeof (errbuf))); + sstrerror(errno, errbuf, sizeof(errbuf))); } while (data_avail) { int nbytes = read(g_configuration->helper_pipes[0], buf, sizeof(buf)); @@ -727,7 +707,8 @@ static int dpdk_read(user_data_t *ud) ret = sem_timedwait(&g_configuration->sema_stats_in_shm, &ts); if (ret == -1) { if (errno == ETIMEDOUT) - DEBUG("dpdkstat: timeout in collectd thread: is a DPDK Primary running? "); + DEBUG( + "dpdkstat: timeout in collectd thread: is a DPDK Primary running? "); return 0; } @@ -738,7 +719,7 @@ static int dpdk_read(user_data_t *ud) char dev_name[64]; cdtime_t port_read_time = g_configuration->port_read_time[i]; uint32_t counters_num = g_configuration->num_stats_in_port[i]; - size_t ports_max = CHAR_BIT * sizeof (g_configuration->enabled_port_mask); + size_t ports_max = CHAR_BIT * sizeof(g_configuration->enabled_port_mask); for (size_t j = port_num; j < ports_max; j++) { if ((g_configuration->enabled_port_mask & (1 << j)) != 0) break; @@ -746,9 +727,10 @@ static int dpdk_read(user_data_t *ud) } if (g_configuration->port_name[i][0] != 0) - ssnprintf(dev_name, sizeof(dev_name), "%s", g_configuration->port_name[i]); + ssnprintf(dev_name, sizeof(dev_name), "%s", + g_configuration->port_name[i]); else - ssnprintf(dev_name, sizeof(dev_name), "port.%"PRIu32, port_num); + ssnprintf(dev_name, sizeof(dev_name), "port.%" PRIu32, port_num); struct rte_eth_xstats *xstats = g_configuration->xstats + count; dpdk_submit_xstats(dev_name, xstats, counters_num, port_read_time); @@ -758,8 +740,7 @@ static int dpdk_read(user_data_t *ud) return 0; } -static int dpdk_shm_cleanup(void) -{ +static int dpdk_shm_cleanup(void) { int ret = munmap(g_configuration, sizeof(dpdk_config_t)); g_configuration = 0; if (ret) { @@ -774,29 +755,27 @@ static int dpdk_shm_cleanup(void) return 0; } -static int dpdk_shutdown(void) -{ +static int dpdk_shutdown(void) { int ret = 0; char errbuf[ERR_BUF_SIZE]; close(g_configuration->helper_pipes[1]); int err = kill(g_configuration->helper_pid, SIGKILL); if (err) { - ERROR("dpdkstat: error sending sigkill to helper %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + ERROR("dpdkstat: error sending sigkill to helper %s", + sstrerror(errno, errbuf, sizeof(errbuf))); ret = -1; } err = dpdk_shm_cleanup(); if (err) { - ERROR("dpdkstat: error cleaning up SHM: %s", sstrerror(errno, errbuf, - sizeof (errbuf))); + ERROR("dpdkstat: error cleaning up SHM: %s", + sstrerror(errno, errbuf, sizeof(errbuf))); ret = -1; } return ret; } -void module_register(void) -{ +void module_register(void) { plugin_register_complex_config("dpdkstat", dpdk_config); plugin_register_init("dpdkstat", dpdk_init); plugin_register_complex_read(NULL, "dpdkstat", dpdk_read, 0, NULL);