summaryrefslogtreecommitdiffstats
path: root/collectors/perf.plugin/perf_plugin.c
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-07-24 09:54:23 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-07-24 09:54:44 +0000
commit836b47cb7e99a977c5a23b059ca1d0b5065d310e (patch)
tree1604da8f482d02effa033c94a84be42bc0c848c3 /collectors/perf.plugin/perf_plugin.c
parentReleasing debian version 1.44.3-2. (diff)
downloadnetdata-836b47cb7e99a977c5a23b059ca1d0b5065d310e.tar.xz
netdata-836b47cb7e99a977c5a23b059ca1d0b5065d310e.zip
Merging upstream version 1.46.3.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'collectors/perf.plugin/perf_plugin.c')
-rw-r--r--collectors/perf.plugin/perf_plugin.c1342
1 files changed, 0 insertions, 1342 deletions
diff --git a/collectors/perf.plugin/perf_plugin.c b/collectors/perf.plugin/perf_plugin.c
deleted file mode 100644
index fe3b04da..00000000
--- a/collectors/perf.plugin/perf_plugin.c
+++ /dev/null
@@ -1,1342 +0,0 @@
-// SPDX-License-Identifier: GPL-3.0-or-later
-
-#include "libnetdata/libnetdata.h"
-#include "libnetdata/required_dummies.h"
-
-#include <linux/perf_event.h>
-
-#define PLUGIN_PERF_NAME "perf.plugin"
-
-// Hardware counters
-#define NETDATA_CHART_PRIO_PERF_CPU_CYCLES 8800
-#define NETDATA_CHART_PRIO_PERF_INSTRUCTIONS 8801
-#define NETDATA_CHART_PRIO_PERF_IPC 8802
-#define NETDATA_CHART_PRIO_PERF_BRANCH_INSTRUCTIONS 8803
-#define NETDATA_CHART_PRIO_PERF_CACHE 8804
-#define NETDATA_CHART_PRIO_PERF_BUS_CYCLES 8805
-#define NETDATA_CHART_PRIO_PERF_FRONT_BACK_CYCLES 8806
-
-// Software counters
-#define NETDATA_CHART_PRIO_PERF_MIGRATIONS 8810
-#define NETDATA_CHART_PRIO_PERF_ALIGNMENT 8811
-#define NETDATA_CHART_PRIO_PERF_EMULATION 8812
-
-// Hardware cache counters
-#define NETDATA_CHART_PRIO_PERF_L1D 8820
-#define NETDATA_CHART_PRIO_PERF_L1D_PREFETCH 8821
-#define NETDATA_CHART_PRIO_PERF_L1I 8822
-#define NETDATA_CHART_PRIO_PERF_LL 8823
-#define NETDATA_CHART_PRIO_PERF_DTLB 8824
-#define NETDATA_CHART_PRIO_PERF_ITLB 8825
-#define NETDATA_CHART_PRIO_PERF_PBU 8826
-
-#define RRD_TYPE_PERF "perf"
-#define RRD_FAMILY_HW "hardware"
-#define RRD_FAMILY_SW "software"
-#define RRD_FAMILY_CACHE "cache"
-
-#define NO_FD -1
-#define ALL_PIDS -1
-#define RUNNING_THRESHOLD 100
-
-static int debug = 0;
-
-static int update_every = 1;
-static int freq = 0;
-
-typedef enum perf_event_id {
- // Hardware counters
- EV_ID_CPU_CYCLES,
- EV_ID_INSTRUCTIONS,
- EV_ID_CACHE_REFERENCES,
- EV_ID_CACHE_MISSES,
- EV_ID_BRANCH_INSTRUCTIONS,
- EV_ID_BRANCH_MISSES,
- EV_ID_BUS_CYCLES,
- EV_ID_STALLED_CYCLES_FRONTEND,
- EV_ID_STALLED_CYCLES_BACKEND,
- EV_ID_REF_CPU_CYCLES,
-
- // Software counters
- // EV_ID_CPU_CLOCK,
- // EV_ID_TASK_CLOCK,
- // EV_ID_PAGE_FAULTS,
- // EV_ID_CONTEXT_SWITCHES,
- EV_ID_CPU_MIGRATIONS,
- // EV_ID_PAGE_FAULTS_MIN,
- // EV_ID_PAGE_FAULTS_MAJ,
- EV_ID_ALIGNMENT_FAULTS,
- EV_ID_EMULATION_FAULTS,
-
- // Hardware cache counters
- EV_ID_L1D_READ_ACCESS,
- EV_ID_L1D_READ_MISS,
- EV_ID_L1D_WRITE_ACCESS,
- EV_ID_L1D_WRITE_MISS,
- EV_ID_L1D_PREFETCH_ACCESS,
-
- EV_ID_L1I_READ_ACCESS,
- EV_ID_L1I_READ_MISS,
-
- EV_ID_LL_READ_ACCESS,
- EV_ID_LL_READ_MISS,
- EV_ID_LL_WRITE_ACCESS,
- EV_ID_LL_WRITE_MISS,
-
- EV_ID_DTLB_READ_ACCESS,
- EV_ID_DTLB_READ_MISS,
- EV_ID_DTLB_WRITE_ACCESS,
- EV_ID_DTLB_WRITE_MISS,
-
- EV_ID_ITLB_READ_ACCESS,
- EV_ID_ITLB_READ_MISS,
-
- EV_ID_PBU_READ_ACCESS,
-
- EV_ID_END
-} perf_event_id_t;
-
-enum perf_event_group {
- EV_GROUP_CYCLES,
- EV_GROUP_INSTRUCTIONS_AND_CACHE,
- EV_GROUP_SOFTWARE,
- EV_GROUP_CACHE_L1D,
- EV_GROUP_CACHE_L1I_LL_DTLB,
- EV_GROUP_CACHE_ITLB_BPU,
-
- EV_GROUP_NUM
-};
-
-static int number_of_cpus;
-
-static int *group_leader_fds[EV_GROUP_NUM];
-
-static struct perf_event {
- perf_event_id_t id;
-
- int type;
- int config;
-
- int **group_leader_fd;
- int *fd;
-
- int disabled;
- int updated;
-
- uint64_t value;
-
- uint64_t *prev_value;
- uint64_t *prev_time_enabled;
- uint64_t *prev_time_running;
-} perf_events[] = {
- // Hardware counters
- {EV_ID_CPU_CYCLES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_CPU_CYCLES, &group_leader_fds[EV_GROUP_CYCLES], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_INSTRUCTIONS, PERF_TYPE_HARDWARE, PERF_COUNT_HW_INSTRUCTIONS, &group_leader_fds[EV_GROUP_INSTRUCTIONS_AND_CACHE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_CACHE_REFERENCES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_CACHE_REFERENCES, &group_leader_fds[EV_GROUP_INSTRUCTIONS_AND_CACHE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_CACHE_MISSES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_CACHE_MISSES, &group_leader_fds[EV_GROUP_INSTRUCTIONS_AND_CACHE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_BRANCH_INSTRUCTIONS, PERF_TYPE_HARDWARE, PERF_COUNT_HW_BRANCH_INSTRUCTIONS, &group_leader_fds[EV_GROUP_INSTRUCTIONS_AND_CACHE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_BRANCH_MISSES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_BRANCH_MISSES, &group_leader_fds[EV_GROUP_INSTRUCTIONS_AND_CACHE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_BUS_CYCLES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_BUS_CYCLES, &group_leader_fds[EV_GROUP_CYCLES], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_STALLED_CYCLES_FRONTEND, PERF_TYPE_HARDWARE, PERF_COUNT_HW_STALLED_CYCLES_FRONTEND, &group_leader_fds[EV_GROUP_CYCLES], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_STALLED_CYCLES_BACKEND, PERF_TYPE_HARDWARE, PERF_COUNT_HW_STALLED_CYCLES_BACKEND, &group_leader_fds[EV_GROUP_CYCLES], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_REF_CPU_CYCLES, PERF_TYPE_HARDWARE, PERF_COUNT_HW_REF_CPU_CYCLES, &group_leader_fds[EV_GROUP_CYCLES], NULL, 1, 0, 0, NULL, NULL, NULL},
-
- // Software counters
- // {EV_ID_CPU_CLOCK, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_CPU_CLOCK, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- // {EV_ID_TASK_CLOCK, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_TASK_CLOCK, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- // {EV_ID_PAGE_FAULTS, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_PAGE_FAULTS, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- // {EV_ID_CONTEXT_SWITCHES, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_CONTEXT_SWITCHES, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_CPU_MIGRATIONS, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_CPU_MIGRATIONS, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- // {EV_ID_PAGE_FAULTS_MIN, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_PAGE_FAULTS_MIN, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- // {EV_ID_PAGE_FAULTS_MAJ, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_PAGE_FAULTS_MAJ, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_ALIGNMENT_FAULTS, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_ALIGNMENT_FAULTS, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
- {EV_ID_EMULATION_FAULTS, PERF_TYPE_SOFTWARE, PERF_COUNT_SW_EMULATION_FAULTS, &group_leader_fds[EV_GROUP_SOFTWARE], NULL, 1, 0, 0, NULL, NULL, NULL},
-
- // Hardware cache counters
- {
- EV_ID_L1D_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1D) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1D], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_L1D_READ_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1D) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1D], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_L1D_WRITE_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1D) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1D], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_L1D_WRITE_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1D) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1D], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_L1D_PREFETCH_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1D) | (PERF_COUNT_HW_CACHE_OP_PREFETCH << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1D], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {
- EV_ID_L1I_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1I) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_L1I_READ_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_L1I) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {
- EV_ID_LL_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_LL) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_LL_READ_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_LL) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_LL_WRITE_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_LL) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_LL_WRITE_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_LL) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {
- EV_ID_DTLB_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_DTLB) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_DTLB_READ_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_DTLB) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_DTLB_WRITE_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_DTLB) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_L1I_LL_DTLB], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_DTLB_WRITE_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_DTLB) | (PERF_COUNT_HW_CACHE_OP_WRITE << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_ITLB_BPU], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {
- EV_ID_ITLB_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_ITLB) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_ITLB_BPU], NULL, 1, 0, 0, NULL, NULL, NULL
- }, {
- EV_ID_ITLB_READ_MISS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_ITLB) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_MISS << 16),
- &group_leader_fds[EV_GROUP_CACHE_ITLB_BPU], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {
- EV_ID_PBU_READ_ACCESS, PERF_TYPE_HW_CACHE,
- (PERF_COUNT_HW_CACHE_BPU) | (PERF_COUNT_HW_CACHE_OP_READ << 8) | (PERF_COUNT_HW_CACHE_RESULT_ACCESS << 16),
- &group_leader_fds[EV_GROUP_CACHE_ITLB_BPU], NULL, 1, 0, 0, NULL, NULL, NULL
- },
-
- {EV_ID_END, 0, 0, NULL, NULL, 0, 0, 0, NULL, NULL, NULL}
-};
-
-static int perf_init() {
- int cpu, group;
- struct perf_event_attr perf_event_attr;
- struct perf_event *current_event = NULL;
- unsigned long flags = 0;
-
- number_of_cpus = (int)get_system_cpus();
-
- // initialize all perf event file descriptors
- for(current_event = &perf_events[0]; current_event->id != EV_ID_END; current_event++) {
- current_event->fd = mallocz(number_of_cpus * sizeof(int));
- memset(current_event->fd, NO_FD, number_of_cpus * sizeof(int));
-
- current_event->prev_value = mallocz(number_of_cpus * sizeof(uint64_t));
- memset(current_event->prev_value, 0, number_of_cpus * sizeof(uint64_t));
-
- current_event->prev_time_enabled = mallocz(number_of_cpus * sizeof(uint64_t));
- memset(current_event->prev_time_enabled, 0, number_of_cpus * sizeof(uint64_t));
-
- current_event->prev_time_running = mallocz(number_of_cpus * sizeof(uint64_t));
- memset(current_event->prev_time_running, 0, number_of_cpus * sizeof(uint64_t));
- }
-
- for(group = 0; group < EV_GROUP_NUM; group++) {
- group_leader_fds[group] = mallocz(number_of_cpus * sizeof(int));
- memset(group_leader_fds[group], NO_FD, number_of_cpus * sizeof(int));
- }
-
- memset(&perf_event_attr, 0, sizeof(perf_event_attr));
-
- for(cpu = 0; cpu < number_of_cpus; cpu++) {
- for(current_event = &perf_events[0]; current_event->id != EV_ID_END; current_event++) {
- if(unlikely(current_event->disabled)) continue;
-
- perf_event_attr.type = current_event->type;
- perf_event_attr.config = current_event->config;
- perf_event_attr.read_format = PERF_FORMAT_TOTAL_TIME_ENABLED | PERF_FORMAT_TOTAL_TIME_RUNNING;
-
- int fd, group_leader_fd = *(*current_event->group_leader_fd + cpu);
-
- fd = syscall(
- __NR_perf_event_open,
- &perf_event_attr,
- ALL_PIDS,
- cpu,
- group_leader_fd,
- flags
- );
-
- if(unlikely(group_leader_fd == NO_FD)) group_leader_fd = fd;
-
- if(unlikely(fd < 0)) {
- switch errno {
- case EACCES:
- collector_error("Cannot access to the PMU: Permission denied");
- break;
- case EBUSY:
- collector_error("Another event already has exclusive access to the PMU");
- break;
- default:
- collector_error("Cannot open perf event");
- }
- collector_error("Disabling event %u", current_event->id);
- current_event->disabled = 1;
- }
-
- *(current_event->fd + cpu) = fd;
- *(*current_event->group_leader_fd + cpu) = group_leader_fd;
-
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: event id = %u, cpu = %d, fd = %d, leader_fd = %d\n", current_event->id, cpu, fd, group_leader_fd);
- }
- }
-
- return 0;
-}
-
-static void perf_free(void) {
- int cpu, group;
- struct perf_event *current_event = NULL;
-
- for(current_event = &perf_events[0]; current_event->id != EV_ID_END; current_event++) {
- for(cpu = 0; cpu < number_of_cpus; cpu++)
- if(*(current_event->fd + cpu) != NO_FD) close(*(current_event->fd + cpu));
-
- free(current_event->fd);
- free(current_event->prev_value);
- free(current_event->prev_time_enabled);
- free(current_event->prev_time_running);
- }
-
- for(group = 0; group < EV_GROUP_NUM; group++)
- free(group_leader_fds[group]);
-}
-
-static void reenable_events() {
- int group, cpu;
-
- for(group = 0; group < EV_GROUP_NUM; group++) {
- for(cpu = 0; cpu < number_of_cpus; cpu++) {
- int current_fd = *(group_leader_fds[group] + cpu);
-
- if(unlikely(current_fd == NO_FD)) continue;
-
- if(ioctl(current_fd, PERF_EVENT_IOC_DISABLE, PERF_IOC_FLAG_GROUP) == -1
- || ioctl(current_fd, PERF_EVENT_IOC_ENABLE, PERF_IOC_FLAG_GROUP) == -1)
- {
- collector_error("Cannot reenable event group");
- }
- }
- }
-}
-
-static int perf_collect() {
- int cpu;
- struct perf_event *current_event = NULL;
- static uint64_t prev_cpu_cycles_value = 0;
- struct {
- uint64_t value;
- uint64_t time_enabled;
- uint64_t time_running;
- } read_result;
-
- for(current_event = &perf_events[0]; current_event->id != EV_ID_END; current_event++) {
- current_event->updated = 0;
- current_event->value = 0;
-
- if(unlikely(current_event->disabled)) continue;
-
- for(cpu = 0; cpu < number_of_cpus; cpu++) {
-
- ssize_t read_size = read(current_event->fd[cpu], &read_result, sizeof(read_result));
-
- if(likely(read_size == sizeof(read_result))) {
- if (likely(read_result.time_running
- && read_result.time_running != *(current_event->prev_time_running + cpu)
- && (read_result.time_enabled / read_result.time_running < RUNNING_THRESHOLD))) {
- current_event->value += (read_result.value - *(current_event->prev_value + cpu)) \
- * (read_result.time_enabled - *(current_event->prev_time_enabled + cpu)) \
- / (read_result.time_running - *(current_event->prev_time_running + cpu));
- }
-
- *(current_event->prev_value + cpu) = read_result.value;
- *(current_event->prev_time_enabled + cpu) = read_result.time_enabled;
- *(current_event->prev_time_running + cpu) = read_result.time_running;
-
- current_event->updated = 1;
- }
- else {
- collector_error("Cannot update value for event %u", current_event->id);
- return 1;
- }
- }
-
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: successfully read event id = %u, value = %"PRIu64"\n", current_event->id, current_event->value);
- }
-
- if(unlikely(perf_events[EV_ID_CPU_CYCLES].value == prev_cpu_cycles_value))
- reenable_events();
- prev_cpu_cycles_value = perf_events[EV_ID_CPU_CYCLES].value;
-
- return 0;
-}
-
-static void perf_send_metrics() {
- static int // Hardware counters
- cpu_cycles_chart_generated = 0,
- instructions_chart_generated = 0,
- ipc_chart_generated = 0,
- branch_chart_generated = 0,
- cache_chart_generated = 0,
- bus_cycles_chart_generated = 0,
- stalled_cycles_chart_generated = 0,
-
- // Software counters
- migrations_chart_generated = 0,
- alignment_chart_generated = 0,
- emulation_chart_generated = 0,
-
- // Hardware cache counters
- L1D_chart_generated = 0,
- L1D_prefetch_chart_generated = 0,
- L1I_chart_generated = 0,
- LL_chart_generated = 0,
- DTLB_chart_generated = 0,
- ITLB_chart_generated = 0,
- PBU_chart_generated = 0;
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_CPU_CYCLES].updated || perf_events[EV_ID_REF_CPU_CYCLES].updated)) {
- if(unlikely(!cpu_cycles_chart_generated)) {
- cpu_cycles_chart_generated = 1;
-
- printf("CHART %s.%s '' 'CPU cycles' 'cycles/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "cpu_cycles"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_CPU_CYCLES
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "cpu");
- printf("DIMENSION %s '' absolute 1 1\n", "ref_cpu");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "cpu_cycles"
- );
- if(likely(perf_events[EV_ID_CPU_CYCLES].updated)) {
- printf(
- "SET %s = %lld\n"
- , "cpu"
- , (collected_number) perf_events[EV_ID_CPU_CYCLES].value
- );
- }
- if(likely(perf_events[EV_ID_REF_CPU_CYCLES].updated)) {
- printf(
- "SET %s = %lld\n"
- , "ref_cpu"
- , (collected_number) perf_events[EV_ID_REF_CPU_CYCLES].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_INSTRUCTIONS].updated)) {
- if(unlikely(!instructions_chart_generated)) {
- instructions_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Instructions' 'instructions/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "instructions"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_INSTRUCTIONS
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "instructions");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "instructions"
- );
- printf(
- "SET %s = %lld\n"
- , "instructions"
- , (collected_number) perf_events[EV_ID_INSTRUCTIONS].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_INSTRUCTIONS].updated) && likely(perf_events[EV_ID_CPU_CYCLES].updated)) {
- if(unlikely(!ipc_chart_generated)) {
- ipc_chart_generated = 1;
-
- printf("CHART %s.%s '' '%s' 'instructions/cycle' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "instructions_per_cycle"
- , "Instructions per Cycle(IPC)"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_IPC
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 100\n", "ipc");
- }
-
- printf("BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "instructions_per_cycle"
- );
-
- NETDATA_DOUBLE result = ((NETDATA_DOUBLE)perf_events[EV_ID_INSTRUCTIONS].value /
- (NETDATA_DOUBLE)perf_events[EV_ID_CPU_CYCLES].value) * 100.0;
- printf("SET %s = %lld\n"
- , "ipc"
- , (collected_number) result
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_BRANCH_INSTRUCTIONS].updated || perf_events[EV_ID_BRANCH_MISSES].updated)) {
- if(unlikely(!branch_chart_generated)) {
- branch_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Branch instructions' 'instructions/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "branch_instructions"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_BRANCH_INSTRUCTIONS
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "instructions");
- printf("DIMENSION %s '' absolute 1 1\n", "misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "branch_instructions"
- );
- if(likely(perf_events[EV_ID_BRANCH_INSTRUCTIONS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "instructions"
- , (collected_number) perf_events[EV_ID_BRANCH_INSTRUCTIONS].value
- );
- }
- if(likely(perf_events[EV_ID_BRANCH_MISSES].updated)) {
- printf(
- "SET %s = %lld\n"
- , "misses"
- , (collected_number) perf_events[EV_ID_BRANCH_MISSES].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_CACHE_REFERENCES].updated || perf_events[EV_ID_CACHE_MISSES].updated)) {
- if(unlikely(!cache_chart_generated)) {
- cache_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Cache operations' 'operations/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "cache"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_CACHE
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "references");
- printf("DIMENSION %s '' absolute 1 1\n", "misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "cache"
- );
- if(likely(perf_events[EV_ID_CACHE_REFERENCES].updated)) {
- printf(
- "SET %s = %lld\n"
- , "references"
- , (collected_number) perf_events[EV_ID_CACHE_REFERENCES].value
- );
- }
- if(likely(perf_events[EV_ID_CACHE_MISSES].updated)) {
- printf(
- "SET %s = %lld\n"
- , "misses"
- , (collected_number) perf_events[EV_ID_CACHE_MISSES].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_BUS_CYCLES].updated)) {
- if(unlikely(!bus_cycles_chart_generated)) {
- bus_cycles_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Bus cycles' 'cycles/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "bus_cycles"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_BUS_CYCLES
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "bus");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "bus_cycles"
- );
- printf(
- "SET %s = %lld\n"
- , "bus"
- , (collected_number) perf_events[EV_ID_BUS_CYCLES].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_STALLED_CYCLES_FRONTEND].updated || perf_events[EV_ID_STALLED_CYCLES_BACKEND].updated)) {
- if(unlikely(!stalled_cycles_chart_generated)) {
- stalled_cycles_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Stalled frontend and backend cycles' 'cycles/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "stalled_cycles"
- , RRD_FAMILY_HW
- , NETDATA_CHART_PRIO_PERF_FRONT_BACK_CYCLES
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "frontend");
- printf("DIMENSION %s '' absolute 1 1\n", "backend");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "stalled_cycles"
- );
- if(likely(perf_events[EV_ID_STALLED_CYCLES_FRONTEND].updated)) {
- printf(
- "SET %s = %lld\n"
- , "frontend"
- , (collected_number) perf_events[EV_ID_STALLED_CYCLES_FRONTEND].value
- );
- }
- if(likely(perf_events[EV_ID_STALLED_CYCLES_BACKEND].updated)) {
- printf(
- "SET %s = %lld\n"
- , "backend"
- , (collected_number) perf_events[EV_ID_STALLED_CYCLES_BACKEND].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_CPU_MIGRATIONS].updated)) {
- if(unlikely(!migrations_chart_generated)) {
- migrations_chart_generated = 1;
-
- printf("CHART %s.%s '' 'CPU migrations' 'migrations' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "migrations"
- , RRD_FAMILY_SW
- , NETDATA_CHART_PRIO_PERF_MIGRATIONS
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "migrations");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "migrations"
- );
- printf(
- "SET %s = %lld\n"
- , "migrations"
- , (collected_number) perf_events[EV_ID_CPU_MIGRATIONS].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_ALIGNMENT_FAULTS].updated)) {
- if(unlikely(!alignment_chart_generated)) {
- alignment_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Alignment faults' 'faults' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "alignment_faults"
- , RRD_FAMILY_SW
- , NETDATA_CHART_PRIO_PERF_ALIGNMENT
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "faults");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "alignment_faults"
- );
- printf(
- "SET %s = %lld\n"
- , "faults"
- , (collected_number) perf_events[EV_ID_ALIGNMENT_FAULTS].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_EMULATION_FAULTS].updated)) {
- if(unlikely(!emulation_chart_generated)) {
- emulation_chart_generated = 1;
-
- printf("CHART %s.%s '' 'Emulation faults' 'faults' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "emulation_faults"
- , RRD_FAMILY_SW
- , NETDATA_CHART_PRIO_PERF_EMULATION
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "faults");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "emulation_faults"
- );
- printf(
- "SET %s = %lld\n"
- , "faults"
- , (collected_number) perf_events[EV_ID_EMULATION_FAULTS].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_L1D_READ_ACCESS].updated || perf_events[EV_ID_L1D_READ_MISS].updated
- || perf_events[EV_ID_L1D_WRITE_ACCESS].updated || perf_events[EV_ID_L1D_WRITE_MISS].updated)) {
- if(unlikely(!L1D_chart_generated)) {
- L1D_chart_generated = 1;
-
- printf("CHART %s.%s '' 'L1D cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "l1d_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_L1D
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- printf("DIMENSION %s '' absolute 1 1\n", "read_misses");
- printf("DIMENSION %s '' absolute -1 1\n", "write_access");
- printf("DIMENSION %s '' absolute -1 1\n", "write_misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "l1d_cache"
- );
- if(likely(perf_events[EV_ID_L1D_READ_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_L1D_READ_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_L1D_READ_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_misses"
- , (collected_number) perf_events[EV_ID_L1D_READ_MISS].value
- );
- }
- if(likely(perf_events[EV_ID_L1D_WRITE_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_access"
- , (collected_number) perf_events[EV_ID_L1D_WRITE_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_L1D_WRITE_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_misses"
- , (collected_number) perf_events[EV_ID_L1D_WRITE_MISS].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_L1D_PREFETCH_ACCESS].updated)) {
- if(unlikely(!L1D_prefetch_chart_generated)) {
- L1D_prefetch_chart_generated = 1;
-
- printf("CHART %s.%s '' 'L1D prefetch cache operations' 'prefetches/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "l1d_cache_prefetch"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_L1D_PREFETCH
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "prefetches");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "l1d_cache_prefetch"
- );
- printf(
- "SET %s = %lld\n"
- , "prefetches"
- , (collected_number) perf_events[EV_ID_L1D_PREFETCH_ACCESS].value
- );
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_L1I_READ_ACCESS].updated || perf_events[EV_ID_L1I_READ_MISS].updated)) {
- if(unlikely(!L1I_chart_generated)) {
- L1I_chart_generated = 1;
-
- printf("CHART %s.%s '' 'L1I cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "l1i_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_L1I
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- printf("DIMENSION %s '' absolute 1 1\n", "read_misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "l1i_cache"
- );
- if(likely(perf_events[EV_ID_L1I_READ_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_L1I_READ_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_L1I_READ_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_misses"
- , (collected_number) perf_events[EV_ID_L1I_READ_MISS].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_LL_READ_ACCESS].updated || perf_events[EV_ID_LL_READ_MISS].updated
- || perf_events[EV_ID_LL_WRITE_ACCESS].updated || perf_events[EV_ID_LL_WRITE_MISS].updated)) {
- if(unlikely(!LL_chart_generated)) {
- LL_chart_generated = 1;
-
- printf("CHART %s.%s '' 'LL cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "ll_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_LL
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- printf("DIMENSION %s '' absolute 1 1\n", "read_misses");
- printf("DIMENSION %s '' absolute -1 1\n", "write_access");
- printf("DIMENSION %s '' absolute -1 1\n", "write_misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "ll_cache"
- );
- if(likely(perf_events[EV_ID_LL_READ_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_LL_READ_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_LL_READ_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_misses"
- , (collected_number) perf_events[EV_ID_LL_READ_MISS].value
- );
- }
- if(likely(perf_events[EV_ID_LL_WRITE_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_access"
- , (collected_number) perf_events[EV_ID_LL_WRITE_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_LL_WRITE_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_misses"
- , (collected_number) perf_events[EV_ID_LL_WRITE_MISS].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_DTLB_READ_ACCESS].updated || perf_events[EV_ID_DTLB_READ_MISS].updated
- || perf_events[EV_ID_DTLB_WRITE_ACCESS].updated || perf_events[EV_ID_DTLB_WRITE_MISS].updated)) {
- if(unlikely(!DTLB_chart_generated)) {
- DTLB_chart_generated = 1;
-
- printf("CHART %s.%s '' 'DTLB cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "dtlb_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_DTLB
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- printf("DIMENSION %s '' absolute 1 1\n", "read_misses");
- printf("DIMENSION %s '' absolute -1 1\n", "write_access");
- printf("DIMENSION %s '' absolute -1 1\n", "write_misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "dtlb_cache"
- );
- if(likely(perf_events[EV_ID_DTLB_READ_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_DTLB_READ_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_DTLB_READ_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_misses"
- , (collected_number) perf_events[EV_ID_DTLB_READ_MISS].value
- );
- }
- if(likely(perf_events[EV_ID_DTLB_WRITE_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_access"
- , (collected_number) perf_events[EV_ID_DTLB_WRITE_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_DTLB_WRITE_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "write_misses"
- , (collected_number) perf_events[EV_ID_DTLB_WRITE_MISS].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_ITLB_READ_ACCESS].updated || perf_events[EV_ID_ITLB_READ_MISS].updated)) {
- if(unlikely(!ITLB_chart_generated)) {
- ITLB_chart_generated = 1;
-
- printf("CHART %s.%s '' 'ITLB cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "itlb_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_ITLB
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- printf("DIMENSION %s '' absolute 1 1\n", "read_misses");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "itlb_cache"
- );
- if(likely(perf_events[EV_ID_ITLB_READ_ACCESS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_ITLB_READ_ACCESS].value
- );
- }
- if(likely(perf_events[EV_ID_ITLB_READ_MISS].updated)) {
- printf(
- "SET %s = %lld\n"
- , "read_misses"
- , (collected_number) perf_events[EV_ID_ITLB_READ_MISS].value
- );
- }
- printf("END\n");
- }
-
- // ------------------------------------------------------------------------
-
- if(likely(perf_events[EV_ID_PBU_READ_ACCESS].updated)) {
- if(unlikely(!PBU_chart_generated)) {
- PBU_chart_generated = 1;
-
- printf("CHART %s.%s '' 'PBU cache operations' 'events/s' %s '' line %d %d '' %s\n"
- , RRD_TYPE_PERF
- , "pbu_cache"
- , RRD_FAMILY_CACHE
- , NETDATA_CHART_PRIO_PERF_PBU
- , update_every
- , PLUGIN_PERF_NAME
- );
- printf("DIMENSION %s '' absolute 1 1\n", "read_access");
- }
-
- printf(
- "BEGIN %s.%s\n"
- , RRD_TYPE_PERF
- , "pbu_cache"
- );
- printf(
- "SET %s = %lld\n"
- , "read_access"
- , (collected_number) perf_events[EV_ID_PBU_READ_ACCESS].value
- );
- printf("END\n");
- }
-}
-
-void parse_command_line(int argc, char **argv) {
- int i, plugin_enabled = 0;
-
- for(i = 1; i < argc ; i++) {
- if(isdigit(*argv[i]) && !freq) {
- int n = str2i(argv[i]);
- if(n > 0 && n < 86400) {
- freq = n;
- continue;
- }
- }
- else if(strcmp("version", argv[i]) == 0 || strcmp("-version", argv[i]) == 0 || strcmp("--version", argv[i]) == 0 || strcmp("-v", argv[i]) == 0 || strcmp("-V", argv[i]) == 0) {
- printf("perf.plugin %s\n", VERSION);
- exit(0);
- }
- else if(strcmp("all", argv[i]) == 0) {
- struct perf_event *current_event = NULL;
-
- for(current_event = &perf_events[0]; current_event->id != EV_ID_END; current_event++)
- current_event->disabled = 0;
-
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("cycles", argv[i]) == 0) {
- perf_events[EV_ID_CPU_CYCLES].disabled = 0;
- perf_events[EV_ID_REF_CPU_CYCLES].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("instructions", argv[i]) == 0) {
- perf_events[EV_ID_INSTRUCTIONS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("branch", argv[i]) == 0) {
- perf_events[EV_ID_BRANCH_INSTRUCTIONS].disabled = 0;
- perf_events[EV_ID_BRANCH_MISSES].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("cache", argv[i]) == 0) {
- perf_events[EV_ID_CACHE_REFERENCES].disabled = 0;
- perf_events[EV_ID_CACHE_MISSES].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("bus", argv[i]) == 0) {
- perf_events[EV_ID_BUS_CYCLES].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("stalled", argv[i]) == 0) {
- perf_events[EV_ID_STALLED_CYCLES_FRONTEND].disabled = 0;
- perf_events[EV_ID_STALLED_CYCLES_BACKEND].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("migrations", argv[i]) == 0) {
- perf_events[EV_ID_CPU_MIGRATIONS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("alignment", argv[i]) == 0) {
- perf_events[EV_ID_ALIGNMENT_FAULTS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("emulation", argv[i]) == 0) {
- perf_events[EV_ID_EMULATION_FAULTS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("L1D", argv[i]) == 0) {
- perf_events[EV_ID_L1D_READ_ACCESS].disabled = 0;
- perf_events[EV_ID_L1D_READ_MISS].disabled = 0;
- perf_events[EV_ID_L1D_WRITE_ACCESS].disabled = 0;
- perf_events[EV_ID_L1D_WRITE_MISS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("L1D-prefetch", argv[i]) == 0) {
- perf_events[EV_ID_L1D_PREFETCH_ACCESS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("L1I", argv[i]) == 0) {
- perf_events[EV_ID_L1I_READ_ACCESS].disabled = 0;
- perf_events[EV_ID_L1I_READ_MISS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("LL", argv[i]) == 0) {
- perf_events[EV_ID_LL_READ_ACCESS].disabled = 0;
- perf_events[EV_ID_LL_READ_MISS].disabled = 0;
- perf_events[EV_ID_LL_WRITE_ACCESS].disabled = 0;
- perf_events[EV_ID_LL_WRITE_MISS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("DTLB", argv[i]) == 0) {
- perf_events[EV_ID_DTLB_READ_ACCESS].disabled = 0;
- perf_events[EV_ID_DTLB_READ_MISS].disabled = 0;
- perf_events[EV_ID_DTLB_WRITE_ACCESS].disabled = 0;
- perf_events[EV_ID_DTLB_WRITE_MISS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("ITLB", argv[i]) == 0) {
- perf_events[EV_ID_ITLB_READ_ACCESS].disabled = 0;
- perf_events[EV_ID_ITLB_READ_MISS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("PBU", argv[i]) == 0) {
- perf_events[EV_ID_PBU_READ_ACCESS].disabled = 0;
- plugin_enabled = 1;
- continue;
- }
- else if(strcmp("debug", argv[i]) == 0) {
- debug = 1;
- continue;
- }
- else if(strcmp("-h", argv[i]) == 0 || strcmp("--help", argv[i]) == 0) {
- fprintf(stderr,
- "\n"
- " netdata perf.plugin %s\n"
- " Copyright (C) 2019 Netdata Inc.\n"
- " Released under GNU General Public License v3 or later.\n"
- " All rights reserved.\n"
- "\n"
- " This program is a data collector plugin for netdata.\n"
- "\n"
- " Available command line options:\n"
- "\n"
- " COLLECTION_FREQUENCY data collection frequency in seconds\n"
- " minimum: %d\n"
- "\n"
- " all enable all charts\n"
- "\n"
- " cycles enable CPU cycles chart\n"
- "\n"
- " instructions enable Instructions chart\n"
- "\n"
- " branch enable Branch instructions chart\n"
- "\n"
- " cache enable Cache operations chart\n"
- "\n"
- " bus enable Bus cycles chart\n"
- "\n"
- " stalled enable Stalled frontend and backend cycles chart\n"
- "\n"
- " migrations enable CPU migrations chart\n"
- "\n"
- " alignment enable Alignment faults chart\n"
- "\n"
- " emulation enable Emulation faults chart\n"
- "\n"
- " L1D enable L1D cache operations chart\n"
- "\n"
- " L1D-prefetch enable L1D prefetch cache operations chart\n"
- "\n"
- " L1I enable L1I cache operations chart\n"
- "\n"
- " LL enable LL cache operations chart\n"
- "\n"
- " DTLB enable DTLB cache operations chart\n"
- "\n"
- " ITLB enable ITLB cache operations chart\n"
- "\n"
- " PBU enable PBU cache operations chart\n"
- "\n"
- " debug enable verbose output\n"
- " default: disabled\n"
- "\n"
- " -v\n"
- " -V\n"
- " --version print version and exit\n"
- "\n"
- " -h\n"
- " --help print this message and exit\n"
- "\n"
- " For more information:\n"
- " https://github.com/netdata/netdata/tree/master/collectors/perf.plugin\n"
- "\n"
- , VERSION
- , update_every
- );
- exit(1);
- }
-
- collector_error("ignoring parameter '%s'", argv[i]);
- }
-
- if(!plugin_enabled){
- collector_info("no charts enabled - nothing to do.");
- printf("DISABLE\n");
- exit(1);
- }
-}
-
-int main(int argc, char **argv) {
- clocks_init();
- nd_log_initialize_for_external_plugins("perf.plugin");
-
- parse_command_line(argc, argv);
-
- errno = 0;
-
- if(freq >= update_every)
- update_every = freq;
- else if(freq)
- collector_error("update frequency %d seconds is too small for PERF. Using %d.", freq, update_every);
-
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: calling perf_init()\n");
- int perf = !perf_init();
-
- // ------------------------------------------------------------------------
- // the main loop
-
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: starting data collection\n");
-
- time_t started_t = now_monotonic_sec();
-
- size_t iteration;
- usec_t step = update_every * USEC_PER_SEC;
-
- heartbeat_t hb;
- heartbeat_init(&hb);
- for(iteration = 0; 1; iteration++) {
- usec_t dt = heartbeat_next(&hb, step);
-
- if(unlikely(netdata_exit)) break;
-
- if(unlikely(debug && iteration))
- fprintf(stderr, "perf.plugin: iteration %zu, dt %"PRIu64" usec\n"
- , iteration
- , dt
- );
-
- if(likely(perf)) {
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: calling perf_collect()\n");
- perf = !perf_collect();
-
- if(likely(perf)) {
- if(unlikely(debug)) fprintf(stderr, "perf.plugin: calling perf_send_metrics()\n");
- perf_send_metrics();
- }
- }
-
- fflush(stdout);
-
- // restart check (14400 seconds)
- if(now_monotonic_sec() - started_t > 14400) break;
- }
-
- collector_info("process exiting");
- perf_free();
-}