diff options
Diffstat (limited to 'collectors/ebpf.plugin/ebpf_shm.c')
| -rw-r--r-- | collectors/ebpf.plugin/ebpf_shm.c | 1327 |
1 files changed, 0 insertions, 1327 deletions
diff --git a/collectors/ebpf.plugin/ebpf_shm.c b/collectors/ebpf.plugin/ebpf_shm.c deleted file mode 100644 index f14eb67d0..000000000 --- a/collectors/ebpf.plugin/ebpf_shm.c +++ /dev/null @@ -1,1327 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -#include "ebpf.h" -#include "ebpf_shm.h" - -static char *shm_dimension_name[NETDATA_SHM_END] = { "get", "at", "dt", "ctl" }; -static netdata_syscall_stat_t shm_aggregated_data[NETDATA_SHM_END]; -static netdata_publish_syscall_t shm_publish_aggregated[NETDATA_SHM_END]; - -netdata_publish_shm_t *shm_vector = NULL; - -static netdata_idx_t shm_hash_values[NETDATA_SHM_END]; -static netdata_idx_t *shm_values = NULL; - -struct config shm_config = { .first_section = NULL, - .last_section = NULL, - .mutex = NETDATA_MUTEX_INITIALIZER, - .index = { .avl_tree = { .root = NULL, .compar = appconfig_section_compare }, - .rwlock = AVL_LOCK_INITIALIZER } }; - -static ebpf_local_maps_t shm_maps[] = {{.name = "tbl_pid_shm", .internal_input = ND_EBPF_DEFAULT_PID_SIZE, - .user_input = 0, - .type = NETDATA_EBPF_MAP_RESIZABLE | NETDATA_EBPF_MAP_PID, - .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED, -#ifdef LIBBPF_MAJOR_VERSION - .map_type = BPF_MAP_TYPE_PERCPU_HASH -#endif - }, - {.name = "shm_ctrl", .internal_input = NETDATA_CONTROLLER_END, - .user_input = 0, - .type = NETDATA_EBPF_MAP_CONTROLLER, - .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED, -#ifdef LIBBPF_MAJOR_VERSION - .map_type = BPF_MAP_TYPE_PERCPU_ARRAY -#endif - }, - {.name = "tbl_shm", .internal_input = NETDATA_SHM_END, - .user_input = 0, - .type = NETDATA_EBPF_MAP_STATIC, - .map_fd = ND_EBPF_MAP_FD_NOT_INITIALIZED, -#ifdef LIBBPF_MAJOR_VERSION - .map_type = BPF_MAP_TYPE_PERCPU_ARRAY -#endif - }, - {.name = NULL, .internal_input = 0, .user_input = 0}}; - -netdata_ebpf_targets_t shm_targets[] = { {.name = "shmget", .mode = EBPF_LOAD_TRAMPOLINE}, - {.name = "shmat", .mode = EBPF_LOAD_TRAMPOLINE}, - {.name = "shmdt", .mode = EBPF_LOAD_TRAMPOLINE}, - {.name = "shmctl", .mode = EBPF_LOAD_TRAMPOLINE}, - {.name = NULL, .mode = EBPF_LOAD_TRAMPOLINE}}; - -#ifdef NETDATA_DEV_MODE -int shm_disable_priority; -#endif - -#ifdef LIBBPF_MAJOR_VERSION -/***************************************************************** - * - * BTF FUNCTIONS - * - *****************************************************************/ - -/* - * Disable tracepoint - * - * Disable all tracepoints to use exclusively another method. - * - * @param obj is the main structure for bpf objects. - */ -static void ebpf_shm_disable_tracepoint(struct shm_bpf *obj) -{ - bpf_program__set_autoload(obj->progs.netdata_syscall_shmget, false); - bpf_program__set_autoload(obj->progs.netdata_syscall_shmat, false); - bpf_program__set_autoload(obj->progs.netdata_syscall_shmdt, false); - bpf_program__set_autoload(obj->progs.netdata_syscall_shmctl, false); -} - -/* - * Disable probe - * - * Disable all probes to use exclusively another method. - * - * @param obj is the main structure for bpf objects. - */ -static void ebpf_disable_probe(struct shm_bpf *obj) -{ - bpf_program__set_autoload(obj->progs.netdata_shmget_probe, false); - bpf_program__set_autoload(obj->progs.netdata_shmat_probe, false); - bpf_program__set_autoload(obj->progs.netdata_shmdt_probe, false); - bpf_program__set_autoload(obj->progs.netdata_shmctl_probe, false); - bpf_program__set_autoload(obj->progs.netdata_shm_release_task_probe, false); -} - -/* - * Disable trampoline - * - * Disable all trampoline to use exclusively another method. - * - * @param obj is the main structure for bpf objects. - */ -static void ebpf_disable_trampoline(struct shm_bpf *obj) -{ - bpf_program__set_autoload(obj->progs.netdata_shmget_fentry, false); - bpf_program__set_autoload(obj->progs.netdata_shmat_fentry, false); - bpf_program__set_autoload(obj->progs.netdata_shmdt_fentry, false); - bpf_program__set_autoload(obj->progs.netdata_shmctl_fentry, false); - bpf_program__set_autoload(obj->progs.netdata_shm_release_task_fentry, false); -} - -/** - * Set trampoline target - * - * Set the targets we will monitor. - * - * @param obj is the main structure for bpf objects. - */ -static void ebpf_set_trampoline_target(struct shm_bpf *obj) -{ - char syscall[NETDATA_EBPF_MAX_SYSCALL_LENGTH + 1]; - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMGET_CALL].name, running_on_kernel); - - bpf_program__set_attach_target(obj->progs.netdata_shmget_fentry, 0, - syscall); - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMAT_CALL].name, running_on_kernel); - bpf_program__set_attach_target(obj->progs.netdata_shmat_fentry, 0, - syscall); - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMDT_CALL].name, running_on_kernel); - bpf_program__set_attach_target(obj->progs.netdata_shmdt_fentry, 0, - syscall); - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMCTL_CALL].name, running_on_kernel); - bpf_program__set_attach_target(obj->progs.netdata_shmctl_fentry, 0, - syscall); - - bpf_program__set_attach_target(obj->progs.netdata_shm_release_task_fentry, 0, - EBPF_COMMON_FNCT_CLEAN_UP); -} - -/** - * SHM Attach Probe - * - * Attach probes to target - * - * @param obj is the main structure for bpf objects. - * - * @return It returns 0 on success and -1 otherwise. - */ -static int ebpf_shm_attach_probe(struct shm_bpf *obj) -{ - char syscall[NETDATA_EBPF_MAX_SYSCALL_LENGTH + 1]; - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMGET_CALL].name, running_on_kernel); - - obj->links.netdata_shmget_probe = bpf_program__attach_kprobe(obj->progs.netdata_shmget_probe, - false, syscall); - int ret = (int)libbpf_get_error(obj->links.netdata_shmget_probe); - if (ret) - return -1; - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMAT_CALL].name, running_on_kernel); - obj->links.netdata_shmat_probe = bpf_program__attach_kprobe(obj->progs.netdata_shmat_probe, - false, syscall); - ret = (int)libbpf_get_error(obj->links.netdata_shmat_probe); - if (ret) - return -1; - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMDT_CALL].name, running_on_kernel); - obj->links.netdata_shmdt_probe = bpf_program__attach_kprobe(obj->progs.netdata_shmdt_probe, - false, syscall); - ret = (int)libbpf_get_error(obj->links.netdata_shmdt_probe); - if (ret) - return -1; - - ebpf_select_host_prefix(syscall, NETDATA_EBPF_MAX_SYSCALL_LENGTH, - shm_targets[NETDATA_KEY_SHMCTL_CALL].name, running_on_kernel); - obj->links.netdata_shmctl_probe = bpf_program__attach_kprobe(obj->progs.netdata_shmctl_probe, - false, syscall); - ret = (int)libbpf_get_error(obj->links.netdata_shmctl_probe); - if (ret) - return -1; - - obj->links.netdata_shm_release_task_probe = bpf_program__attach_kprobe(obj->progs.netdata_shm_release_task_probe, - false, EBPF_COMMON_FNCT_CLEAN_UP); - ret = (int)libbpf_get_error(obj->links.netdata_shm_release_task_probe); - if (ret) - return -1; - - - return 0; -} - -/** - * Set hash tables - * - * Set the values for maps according the value given by kernel. - */ -static void ebpf_shm_set_hash_tables(struct shm_bpf *obj) -{ - shm_maps[NETDATA_PID_SHM_TABLE].map_fd = bpf_map__fd(obj->maps.tbl_pid_shm); - shm_maps[NETDATA_SHM_CONTROLLER].map_fd = bpf_map__fd(obj->maps.shm_ctrl); - shm_maps[NETDATA_SHM_GLOBAL_TABLE].map_fd = bpf_map__fd(obj->maps.tbl_shm); -} - -/** - * Disable Release Task - * - * Disable release task when apps is not enabled. - * - * @param obj is the main structure for bpf objects. - */ -static void ebpf_shm_disable_release_task(struct shm_bpf *obj) -{ - bpf_program__set_autoload(obj->progs.netdata_shm_release_task_probe, false); - bpf_program__set_autoload(obj->progs.netdata_shm_release_task_fentry, false); -} - -/** - * Adjust Map Size - * - * Resize maps according input from users. - * - * @param obj is the main structure for bpf objects. - * @param em structure with configuration - */ -static void ebpf_shm_adjust_map(struct shm_bpf *obj, ebpf_module_t *em) -{ - ebpf_update_map_size(obj->maps.tbl_pid_shm, &shm_maps[NETDATA_PID_SHM_TABLE], - em, bpf_map__name(obj->maps.tbl_pid_shm)); - - ebpf_update_map_type(obj->maps.tbl_shm, &shm_maps[NETDATA_SHM_GLOBAL_TABLE]); - ebpf_update_map_type(obj->maps.tbl_pid_shm, &shm_maps[NETDATA_PID_SHM_TABLE]); - ebpf_update_map_type(obj->maps.shm_ctrl, &shm_maps[NETDATA_SHM_CONTROLLER]); -} - -/** - * Load and attach - * - * Load and attach the eBPF code in kernel. - * - * @param obj is the main structure for bpf objects. - * @param em structure with configuration - * - * @return it returns 0 on success and -1 otherwise - */ -static inline int ebpf_shm_load_and_attach(struct shm_bpf *obj, ebpf_module_t *em) -{ - netdata_ebpf_targets_t *shmt = em->targets; - netdata_ebpf_program_loaded_t test = shmt[NETDATA_KEY_SHMGET_CALL].mode; - - // We are testing only one, because all will have the same behavior - if (test == EBPF_LOAD_TRAMPOLINE ) { - ebpf_shm_disable_tracepoint(obj); - ebpf_disable_probe(obj); - - ebpf_set_trampoline_target(obj); - } else if (test == EBPF_LOAD_PROBE || test == EBPF_LOAD_RETPROBE ) { - ebpf_shm_disable_tracepoint(obj); - ebpf_disable_trampoline(obj); - } else { - ebpf_disable_probe(obj); - ebpf_disable_trampoline(obj); - } - - ebpf_shm_adjust_map(obj, em); - if (!em->apps_charts && !em->cgroup_charts) - ebpf_shm_disable_release_task(obj); - - int ret = shm_bpf__load(obj); - if (!ret) { - if (test != EBPF_LOAD_PROBE && test != EBPF_LOAD_RETPROBE) - shm_bpf__attach(obj); - else - ret = ebpf_shm_attach_probe(obj); - - if (!ret) - ebpf_shm_set_hash_tables(obj); - } - - return ret; -} -#endif -/***************************************************************** - * FUNCTIONS TO CLOSE THE THREAD - *****************************************************************/ - -static void ebpf_obsolete_specific_shm_charts(char *type, int update_every); - -/** - * Obsolete services - * - * Obsolete all service charts created - * - * @param em a pointer to `struct ebpf_module` - */ -static void ebpf_obsolete_shm_services(ebpf_module_t *em) -{ - ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY, - NETDATA_SHMGET_CHART, - "", - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - NULL, - 20191, - em->update_every); - - ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY, - NETDATA_SHMAT_CHART, - "", - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - NULL, - 20192, - em->update_every); - - ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY, - NETDATA_SHMDT_CHART, - "", - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - NULL, - 20193, - em->update_every); - - ebpf_write_chart_obsolete(NETDATA_SERVICE_FAMILY, - NETDATA_SHMCTL_CHART, - "", - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - NULL, - 20193, - em->update_every); -} - -/** - * Obsolete cgroup chart - * - * Send obsolete for all charts created before to close. - * - * @param em a pointer to `struct ebpf_module` - */ -static inline void ebpf_obsolete_shm_cgroup_charts(ebpf_module_t *em) { - pthread_mutex_lock(&mutex_cgroup_shm); - - ebpf_obsolete_shm_services(em); - - ebpf_cgroup_target_t *ect; - for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) { - if (ect->systemd) - continue; - - ebpf_obsolete_specific_shm_charts(ect->name, em->update_every); - } - pthread_mutex_unlock(&mutex_cgroup_shm); -} - -/** - * Obsolette apps charts - * - * Obsolete apps charts. - * - * @param em a pointer to the structure with the default values. - */ -void ebpf_obsolete_shm_apps_charts(struct ebpf_module *em) -{ - struct ebpf_target *w; - int update_every = em->update_every; - for (w = apps_groups_root_target; w; w = w->next) { - if (unlikely(!(w->charts_created & (1<<EBPF_MODULE_SHM_IDX)))) - continue; - - ebpf_write_chart_obsolete(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmget_call", - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmget_call", - 20191, - update_every); - - ebpf_write_chart_obsolete(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmat_call", - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmat_call", - 20192, - update_every); - - ebpf_write_chart_obsolete(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmdt_call", - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmdt_call", - 20193, - update_every); - - ebpf_write_chart_obsolete(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmctl_call", - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmctl_call", - 20194, - update_every); - - w->charts_created &= ~(1<<EBPF_MODULE_SHM_IDX); - } -} - -/** - * Obsolete global - * - * Obsolete global charts created by thread. - * - * @param em a pointer to `struct ebpf_module` - */ -static void ebpf_obsolete_shm_global(ebpf_module_t *em) -{ - ebpf_write_chart_obsolete(NETDATA_EBPF_SYSTEM_GROUP, - NETDATA_SHM_GLOBAL_CHART, - "", - "Calls to shared memory system calls", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_SYSTEM_IPC_SHM_SUBMENU, - NETDATA_EBPF_CHART_TYPE_LINE, - NULL, - NETDATA_CHART_PRIO_SYSTEM_IPC_SHARED_MEM_CALLS, - em->update_every); -} - -/** - * SHM Exit - * - * Cancel child thread. - * - * @param ptr thread data. - */ -static void ebpf_shm_exit(void *ptr) -{ - ebpf_module_t *em = (ebpf_module_t *)ptr; - - if (em->enabled == NETDATA_THREAD_EBPF_FUNCTION_RUNNING) { - pthread_mutex_lock(&lock); - if (em->cgroup_charts) { - ebpf_obsolete_shm_cgroup_charts(em); - fflush(stdout); - } - - if (em->apps_charts & NETDATA_EBPF_APPS_FLAG_CHART_CREATED) { - ebpf_obsolete_shm_apps_charts(em); - } - - ebpf_obsolete_shm_global(em); - -#ifdef NETDATA_DEV_MODE - if (ebpf_aral_shm_pid) - ebpf_statistic_obsolete_aral_chart(em, shm_disable_priority); -#endif - - fflush(stdout); - pthread_mutex_unlock(&lock); - } - - ebpf_update_kernel_memory_with_vector(&plugin_statistics, em->maps, EBPF_ACTION_STAT_REMOVE); - -#ifdef LIBBPF_MAJOR_VERSION - if (shm_bpf_obj) { - shm_bpf__destroy(shm_bpf_obj); - shm_bpf_obj = NULL; - } -#endif - - if (em->objects) { - ebpf_unload_legacy_code(em->objects, em->probe_links); - em->objects = NULL; - em->probe_links = NULL; - } - - pthread_mutex_lock(&ebpf_exit_cleanup); - em->enabled = NETDATA_THREAD_EBPF_STOPPED; - ebpf_update_stats(&plugin_statistics, em); - pthread_mutex_unlock(&ebpf_exit_cleanup); -} - -/***************************************************************** - * COLLECTOR THREAD - *****************************************************************/ - -/** - * Apps Accumulator - * - * Sum all values read from kernel and store in the first address. - * - * @param out the vector with read values. - * @param maps_per_core do I need to read all cores? - */ -static void shm_apps_accumulator(netdata_publish_shm_t *out, int maps_per_core) -{ - int i, end = (maps_per_core) ? ebpf_nprocs : 1; - netdata_publish_shm_t *total = &out[0]; - for (i = 1; i < end; i++) { - netdata_publish_shm_t *w = &out[i]; - total->get += w->get; - total->at += w->at; - total->dt += w->dt; - total->ctl += w->ctl; - } -} - -/** - * Fill PID - * - * Fill PID structures - * - * @param current_pid pid that we are collecting data - * @param out values read from hash tables; - */ -static void shm_fill_pid(uint32_t current_pid, netdata_publish_shm_t *publish) -{ - netdata_publish_shm_t *curr = shm_pid[current_pid]; - if (!curr) { - curr = ebpf_shm_stat_get( ); - shm_pid[current_pid] = curr; - } - - memcpy(curr, publish, sizeof(netdata_publish_shm_t)); -} - -/** - * Update cgroup - * - * Update cgroup data based in - * - * @param maps_per_core do I need to read all cores? - */ -static void ebpf_update_shm_cgroup(int maps_per_core) -{ - netdata_publish_shm_t *cv = shm_vector; - int fd = shm_maps[NETDATA_PID_SHM_TABLE].map_fd; - size_t length = sizeof(netdata_publish_shm_t); - if (maps_per_core) - length *= ebpf_nprocs; - - ebpf_cgroup_target_t *ect; - - memset(cv, 0, length); - - pthread_mutex_lock(&mutex_cgroup_shm); - for (ect = ebpf_cgroup_pids; ect; ect = ect->next) { - struct pid_on_target2 *pids; - for (pids = ect->pids; pids; pids = pids->next) { - int pid = pids->pid; - netdata_publish_shm_t *out = &pids->shm; - if (likely(shm_pid) && shm_pid[pid]) { - netdata_publish_shm_t *in = shm_pid[pid]; - - memcpy(out, in, sizeof(netdata_publish_shm_t)); - } else { - if (!bpf_map_lookup_elem(fd, &pid, cv)) { - shm_apps_accumulator(cv, maps_per_core); - - memcpy(out, cv, sizeof(netdata_publish_shm_t)); - - // now that we've consumed the value, zero it out in the map. - memset(cv, 0, length); - bpf_map_update_elem(fd, &pid, cv, BPF_EXIST); - } - } - } - } - pthread_mutex_unlock(&mutex_cgroup_shm); -} - -/** - * Read APPS table - * - * Read the apps table and store data inside the structure. - * - * @param maps_per_core do I need to read all cores? - */ -static void read_shm_apps_table(int maps_per_core) -{ - netdata_publish_shm_t *cv = shm_vector; - uint32_t key; - struct ebpf_pid_stat *pids = ebpf_root_of_pids; - int fd = shm_maps[NETDATA_PID_SHM_TABLE].map_fd; - size_t length = sizeof(netdata_publish_shm_t); - if (maps_per_core) - length *= ebpf_nprocs; - - while (pids) { - key = pids->pid; - - if (bpf_map_lookup_elem(fd, &key, cv)) { - pids = pids->next; - continue; - } - - shm_apps_accumulator(cv, maps_per_core); - - shm_fill_pid(key, cv); - - // now that we've consumed the value, zero it out in the map. - memset(cv, 0, length); - bpf_map_update_elem(fd, &key, cv, BPF_EXIST); - - pids = pids->next; - } -} - -/** -* Send global charts to netdata agent. -*/ -static void shm_send_global() -{ - ebpf_write_begin_chart(NETDATA_EBPF_SYSTEM_GROUP, NETDATA_SHM_GLOBAL_CHART, ""); - write_chart_dimension( - shm_publish_aggregated[NETDATA_KEY_SHMGET_CALL].dimension, - (long long) shm_hash_values[NETDATA_KEY_SHMGET_CALL] - ); - write_chart_dimension( - shm_publish_aggregated[NETDATA_KEY_SHMAT_CALL].dimension, - (long long) shm_hash_values[NETDATA_KEY_SHMAT_CALL] - ); - write_chart_dimension( - shm_publish_aggregated[NETDATA_KEY_SHMDT_CALL].dimension, - (long long) shm_hash_values[NETDATA_KEY_SHMDT_CALL] - ); - write_chart_dimension( - shm_publish_aggregated[NETDATA_KEY_SHMCTL_CALL].dimension, - (long long) shm_hash_values[NETDATA_KEY_SHMCTL_CALL] - ); - ebpf_write_end_chart(); -} - -/** - * Read global counter - * - * Read the table with number of calls for all functions - * - * @param stats vector used to read data from control table. - * @param maps_per_core do I need to read all cores? - */ -static void ebpf_shm_read_global_table(netdata_idx_t *stats, int maps_per_core) -{ - ebpf_read_global_table_stats(shm_hash_values, - shm_values, - shm_maps[NETDATA_SHM_GLOBAL_TABLE].map_fd, - maps_per_core, - NETDATA_KEY_SHMGET_CALL, - NETDATA_SHM_END); - - ebpf_read_global_table_stats(stats, - shm_values, - shm_maps[NETDATA_SHM_CONTROLLER].map_fd, - maps_per_core, - NETDATA_CONTROLLER_PID_TABLE_ADD, - NETDATA_CONTROLLER_END); -} - -/** - * Sum values for all targets. - */ -static void ebpf_shm_sum_pids(netdata_publish_shm_t *shm, struct ebpf_pid_on_target *root) -{ - while (root) { - int32_t pid = root->pid; - netdata_publish_shm_t *w = shm_pid[pid]; - if (w) { - shm->get += w->get; - shm->at += w->at; - shm->dt += w->dt; - shm->ctl += w->ctl; - - // reset for next collection. - w->get = 0; - w->at = 0; - w->dt = 0; - w->ctl = 0; - } - root = root->next; - } -} - -/** - * Send data to Netdata calling auxiliary functions. - * - * @param root the target list. -*/ -void ebpf_shm_send_apps_data(struct ebpf_target *root) -{ - struct ebpf_target *w; - for (w = root; w; w = w->next) { - if (unlikely(!(w->charts_created & (1<<EBPF_MODULE_SHM_IDX)))) - continue; - - ebpf_shm_sum_pids(&w->shm, w->root_pid); - - ebpf_write_begin_chart(NETDATA_APP_FAMILY, w->clean_name, "_ebpf_shmget_call"); - write_chart_dimension("calls", (long long) w->shm.get); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_APP_FAMILY, w->clean_name, "_ebpf_shmat_call"); - write_chart_dimension("calls", (long long) w->shm.at); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_APP_FAMILY, w->clean_name, "_ebpf_shmdt_call"); - write_chart_dimension("calls", (long long) w->shm.dt); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_APP_FAMILY, w->clean_name, "_ebpf_shmctl_call"); - write_chart_dimension("calls", (long long) w->shm.ctl); - ebpf_write_end_chart(); - } -} - -/** - * Sum values for all targets. - */ -static void ebpf_shm_sum_cgroup_pids(netdata_publish_shm_t *shm, struct pid_on_target2 *root) -{ - netdata_publish_shm_t shmv; - memset(&shmv, 0, sizeof(shmv)); - while (root) { - netdata_publish_shm_t *w = &root->shm; - shmv.get += w->get; - shmv.at += w->at; - shmv.dt += w->dt; - shmv.ctl += w->ctl; - - root = root->next; - } - - memcpy(shm, &shmv, sizeof(shmv)); -} - -/** - * Create specific shared memory charts - * - * Create charts for cgroup/application. - * - * @param type the chart type. - * @param update_every value to overwrite the update frequency set by the server. - */ -static void ebpf_create_specific_shm_charts(char *type, int update_every) -{ - ebpf_create_chart(type, NETDATA_SHMGET_CHART, - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_CGROUP_SHM_GET_CONTEXT, - NETDATA_EBPF_CHART_TYPE_LINE, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5800, - ebpf_create_global_dimension, - &shm_publish_aggregated[NETDATA_KEY_SHMGET_CALL], - 1, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - - ebpf_create_chart(type, NETDATA_SHMAT_CHART, - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_CGROUP_SHM_AT_CONTEXT, - NETDATA_EBPF_CHART_TYPE_LINE, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5801, - ebpf_create_global_dimension, - &shm_publish_aggregated[NETDATA_KEY_SHMAT_CALL], - 1, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - - ebpf_create_chart(type, NETDATA_SHMDT_CHART, - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_CGROUP_SHM_DT_CONTEXT, - NETDATA_EBPF_CHART_TYPE_LINE, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5802, - ebpf_create_global_dimension, - &shm_publish_aggregated[NETDATA_KEY_SHMDT_CALL], - 1, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - - ebpf_create_chart(type, NETDATA_SHMCTL_CHART, - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_CGROUP_SHM_CTL_CONTEXT, - NETDATA_EBPF_CHART_TYPE_LINE, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5803, - ebpf_create_global_dimension, - &shm_publish_aggregated[NETDATA_KEY_SHMCTL_CALL], - 1, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); -} - -/** - * Obsolete specific shared memory charts - * - * Obsolete charts for cgroup/application. - * - * @param type the chart type. - * @param update_every value to overwrite the update frequency set by the server. - */ -static void ebpf_obsolete_specific_shm_charts(char *type, int update_every) -{ - ebpf_write_chart_obsolete(type, NETDATA_SHMGET_CHART, - "", - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_SHM_GET_CONTEXT, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5800, update_every); - - ebpf_write_chart_obsolete(type, NETDATA_SHMAT_CHART, - "", - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_SHM_AT_CONTEXT, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5801, update_every); - - ebpf_write_chart_obsolete(type, NETDATA_SHMDT_CHART, - "", - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_SHM_DT_CONTEXT, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5802, update_every); - - ebpf_write_chart_obsolete(type, NETDATA_SHMCTL_CHART, - "", - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_LINE, NETDATA_CGROUP_SHM_CTL_CONTEXT, - NETDATA_CHART_PRIO_CGROUPS_CONTAINERS + 5803, update_every); -} - -/** - * Create Systemd Swap Charts - * - * Create charts when systemd is enabled - * - * @param update_every value to overwrite the update frequency set by the server. - **/ -static void ebpf_create_systemd_shm_charts(int update_every) -{ - ebpf_create_charts_on_systemd(NETDATA_SHMGET_CHART, - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - 20191, - ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], - NETDATA_SYSTEMD_SHM_GET_CONTEXT, NETDATA_EBPF_MODULE_NAME_SHM, update_every); - - ebpf_create_charts_on_systemd(NETDATA_SHMAT_CHART, - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - 20192, - ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], - NETDATA_SYSTEMD_SHM_AT_CONTEXT, NETDATA_EBPF_MODULE_NAME_SHM, update_every); - - ebpf_create_charts_on_systemd(NETDATA_SHMDT_CHART, - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - 20193, - ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], - NETDATA_SYSTEMD_SHM_DT_CONTEXT, NETDATA_EBPF_MODULE_NAME_SHM, update_every); - - ebpf_create_charts_on_systemd(NETDATA_SHMCTL_CHART, - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - 20193, - ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX], - NETDATA_SYSTEMD_SHM_CTL_CONTEXT, NETDATA_EBPF_MODULE_NAME_SHM, update_every); -} - -/** - * Send Systemd charts - * - * Send collected data to Netdata. - */ -static void ebpf_send_systemd_shm_charts() -{ - ebpf_cgroup_target_t *ect; - ebpf_write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SHMGET_CHART, ""); - for (ect = ebpf_cgroup_pids; ect; ect = ect->next) { - if (unlikely(ect->systemd) && unlikely(ect->updated)) { - write_chart_dimension(ect->name, (long long)ect->publish_shm.get); - } - } - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SHMAT_CHART, ""); - for (ect = ebpf_cgroup_pids; ect; ect = ect->next) { - if (unlikely(ect->systemd) && unlikely(ect->updated)) { - write_chart_dimension(ect->name, (long long)ect->publish_shm.at); - } - } - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SHMDT_CHART, ""); - for (ect = ebpf_cgroup_pids; ect; ect = ect->next) { - if (unlikely(ect->systemd) && unlikely(ect->updated)) { - write_chart_dimension(ect->name, (long long)ect->publish_shm.dt); - } - } - ebpf_write_end_chart(); - - ebpf_write_begin_chart(NETDATA_SERVICE_FAMILY, NETDATA_SHMCTL_CHART, ""); - for (ect = ebpf_cgroup_pids; ect; ect = ect->next) { - if (unlikely(ect->systemd) && unlikely(ect->updated)) { - write_chart_dimension(ect->name, (long long)ect->publish_shm.ctl); - } - } - ebpf_write_end_chart(); -} - -/* - * Send Specific Shared memory data - * - * Send data for specific cgroup/apps. - * - * @param type chart type - * @param values structure with values that will be sent to netdata - */ -static void ebpf_send_specific_shm_data(char *type, netdata_publish_shm_t *values) -{ - ebpf_write_begin_chart(type, NETDATA_SHMGET_CHART, ""); - write_chart_dimension(shm_publish_aggregated[NETDATA_KEY_SHMGET_CALL].name, (long long)values->get); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(type, NETDATA_SHMAT_CHART, ""); - write_chart_dimension(shm_publish_aggregated[NETDATA_KEY_SHMAT_CALL].name, (long long)values->at); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(type, NETDATA_SHMDT_CHART, ""); - write_chart_dimension(shm_publish_aggregated[NETDATA_KEY_SHMDT_CALL].name, (long long)values->dt); - ebpf_write_end_chart(); - - ebpf_write_begin_chart(type, NETDATA_SHMCTL_CHART, ""); - write_chart_dimension(shm_publish_aggregated[NETDATA_KEY_SHMCTL_CALL].name, (long long)values->ctl); - ebpf_write_end_chart(); -} - -/** - * Send data to Netdata calling auxiliary functions. - * - * @param update_every value to overwrite the update frequency set by the server. -*/ -void ebpf_shm_send_cgroup_data(int update_every) -{ - if (!ebpf_cgroup_pids) - return; - - pthread_mutex_lock(&mutex_cgroup_shm); - ebpf_cgroup_target_t *ect; - for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) { - ebpf_shm_sum_cgroup_pids(&ect->publish_shm, ect->pids); - } - - int has_systemd = shm_ebpf_cgroup.header->systemd_enabled; - if (has_systemd) { - if (send_cgroup_chart) { - ebpf_create_systemd_shm_charts(update_every); - } - - ebpf_send_systemd_shm_charts(); - } - - for (ect = ebpf_cgroup_pids; ect ; ect = ect->next) { - if (ect->systemd) - continue; - - if (!(ect->flags & NETDATA_EBPF_CGROUP_HAS_SHM_CHART) && ect->updated) { - ebpf_create_specific_shm_charts(ect->name, update_every); - ect->flags |= NETDATA_EBPF_CGROUP_HAS_SHM_CHART; - } - - if (ect->flags & NETDATA_EBPF_CGROUP_HAS_SHM_CHART) { - if (ect->updated) { - ebpf_send_specific_shm_data(ect->name, &ect->publish_shm); - } else { - ebpf_obsolete_specific_shm_charts(ect->name, update_every); - ect->flags &= ~NETDATA_EBPF_CGROUP_HAS_SWAP_CHART; - } - } - } - - pthread_mutex_unlock(&mutex_cgroup_shm); -} - -/** -* Main loop for this collector. -*/ -static void shm_collector(ebpf_module_t *em) -{ - int cgroups = em->cgroup_charts; - int update_every = em->update_every; - heartbeat_t hb; - heartbeat_init(&hb); - int counter = update_every - 1; - int maps_per_core = em->maps_per_core; - uint32_t running_time = 0; - uint32_t lifetime = em->lifetime; - netdata_idx_t *stats = em->hash_table_stats; - memset(stats, 0, sizeof(em->hash_table_stats)); - while (!ebpf_plugin_exit && running_time < lifetime) { - (void)heartbeat_next(&hb, USEC_PER_SEC); - if (ebpf_plugin_exit || ++counter != update_every) - continue; - - counter = 0; - netdata_apps_integration_flags_t apps = em->apps_charts; - ebpf_shm_read_global_table(stats, maps_per_core); - pthread_mutex_lock(&collect_data_mutex); - if (apps) { - read_shm_apps_table(maps_per_core); - } - - if (cgroups) { - ebpf_update_shm_cgroup(maps_per_core); - } - - pthread_mutex_lock(&lock); - - shm_send_global(); - - if (apps & NETDATA_EBPF_APPS_FLAG_CHART_CREATED) { - ebpf_shm_send_apps_data(apps_groups_root_target); - } - -#ifdef NETDATA_DEV_MODE - if (ebpf_aral_shm_pid) - ebpf_send_data_aral_chart(ebpf_aral_shm_pid, em); -#endif - - if (cgroups) { - ebpf_shm_send_cgroup_data(update_every); - } - - pthread_mutex_unlock(&lock); - pthread_mutex_unlock(&collect_data_mutex); - - pthread_mutex_lock(&ebpf_exit_cleanup); - if (running_time && !em->running_time) - running_time = update_every; - else - running_time += update_every; - - em->running_time = running_time; - pthread_mutex_unlock(&ebpf_exit_cleanup); - } -} - -/***************************************************************** - * INITIALIZE THREAD - *****************************************************************/ - -/** - * Create apps charts - * - * Call ebpf_create_chart to create the charts on apps submenu. - * - * @param em a pointer to the structure with the default values. - */ -void ebpf_shm_create_apps_charts(struct ebpf_module *em, void *ptr) -{ - struct ebpf_target *root = ptr; - struct ebpf_target *w; - int update_every = em->update_every; - for (w = root; w; w = w->next) { - if (unlikely(!w->exposed)) - continue; - - ebpf_write_chart_cmd(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmget_call", - "Calls to syscall shmget(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmget_call", - 20191, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - ebpf_create_chart_labels("app_group", w->name, 1); - ebpf_commit_label(); - fprintf(stdout, "DIMENSION calls '' %s 1 1\n", ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX]); - - ebpf_write_chart_cmd(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmat_call", - "Calls to syscall shmat(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmat_call", - 20192, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - ebpf_create_chart_labels("app_group", w->name, 1); - ebpf_commit_label(); - fprintf(stdout, "DIMENSION calls '' %s 1 1\n", ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX]); - - ebpf_write_chart_cmd(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmdt_call", - "Calls to syscall shmdt(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmdt_call", - 20193, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - ebpf_create_chart_labels("app_group", w->name, 1); - ebpf_commit_label(); - fprintf(stdout, "DIMENSION calls '' %s 1 1\n", ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX]); - - ebpf_write_chart_cmd(NETDATA_APP_FAMILY, - w->clean_name, - "_ebpf_shmctl_call", - "Calls to syscall shmctl(2).", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_APPS_IPC_SHM_GROUP, - NETDATA_EBPF_CHART_TYPE_STACKED, - "app.ebpf_shmctl_call", - 20194, - update_every, - NETDATA_EBPF_MODULE_NAME_SHM); - ebpf_create_chart_labels("app_group", w->name, 1); - ebpf_commit_label(); - fprintf(stdout, "DIMENSION calls '' %s 1 1\n", ebpf_algorithms[NETDATA_EBPF_INCREMENTAL_IDX]); - - w->charts_created |= 1<<EBPF_MODULE_SHM_IDX; - } - - em->apps_charts |= NETDATA_EBPF_APPS_FLAG_CHART_CREATED; -} - -/** - * Allocate vectors used with this thread. - * - * We are not testing the return, because callocz does this and shutdown the software - * case it was not possible to allocate. - * - * @param apps is apps enabled? - */ -static void ebpf_shm_allocate_global_vectors(int apps) -{ - if (apps) { - ebpf_shm_aral_init(); - shm_pid = callocz((size_t)pid_max, sizeof(netdata_publish_shm_t *)); - shm_vector = callocz((size_t)ebpf_nprocs, sizeof(netdata_publish_shm_t)); - } - - shm_values = callocz((size_t)ebpf_nprocs, sizeof(netdata_idx_t)); - - memset(shm_hash_values, 0, sizeof(shm_hash_values)); -} - -/***************************************************************** - * MAIN THREAD - *****************************************************************/ - -/** - * Create global charts - * - * Call ebpf_create_chart to create the charts for the collector. - * - * @param update_every value to overwrite the update frequency set by the server. - */ -static void ebpf_create_shm_charts(int update_every) -{ - ebpf_create_chart( - NETDATA_EBPF_SYSTEM_GROUP, - NETDATA_SHM_GLOBAL_CHART, - "Calls to shared memory system calls", - EBPF_COMMON_DIMENSION_CALL, - NETDATA_SYSTEM_IPC_SHM_SUBMENU, - NULL, - NETDATA_EBPF_CHART_TYPE_LINE, - NETDATA_CHART_PRIO_SYSTEM_IPC_SHARED_MEM_CALLS, - ebpf_create_global_dimension, - shm_publish_aggregated, - NETDATA_SHM_END, - update_every, NETDATA_EBPF_MODULE_NAME_SHM - ); - - fflush(stdout); -} - -/* - * Load BPF - * - * Load BPF files. - * - * @param em the structure with configuration - */ -static int ebpf_shm_load_bpf(ebpf_module_t *em) -{ -#ifdef LIBBPF_MAJOR_VERSION - ebpf_define_map_type(em->maps, em->maps_per_core, running_on_kernel); -#endif - - int ret = 0; - - ebpf_adjust_apps_cgroup(em, em->targets[NETDATA_KEY_SHMGET_CALL].mode); - if (em->load & EBPF_LOAD_LEGACY) { - em->probe_links = ebpf_load_program(ebpf_plugin_dir, em, running_on_kernel, isrh, &em->objects); - if (!em->probe_links) { - ret = -1; - } - } -#ifdef LIBBPF_MAJOR_VERSION - else { - shm_bpf_obj = shm_bpf__open(); - if (!shm_bpf_obj) - ret = -1; - else - ret = ebpf_shm_load_and_attach(shm_bpf_obj, em); - } -#endif - - - if (ret) - netdata_log_error("%s %s", EBPF_DEFAULT_ERROR_MSG, em->info.thread_name); - - return ret; -} - -/** - * Shared memory thread. - * - * @param ptr a pointer to `struct ebpf_module` - * @return It always return NULL - */ -void *ebpf_shm_thread(void *ptr) -{ - netdata_thread_cleanup_push(ebpf_shm_exit, ptr); - - ebpf_module_t *em = (ebpf_module_t *)ptr; - em->maps = shm_maps; - - ebpf_update_pid_table(&shm_maps[NETDATA_PID_SHM_TABLE], em); - -#ifdef LIBBPF_MAJOR_VERSION - ebpf_adjust_thread_load(em, default_btf); -#endif - if (ebpf_shm_load_bpf(em)) { - goto endshm; - } - - ebpf_shm_allocate_global_vectors(em->apps_charts); - - int algorithms[NETDATA_SHM_END] = { - NETDATA_EBPF_INCREMENTAL_IDX, - NETDATA_EBPF_INCREMENTAL_IDX, - NETDATA_EBPF_INCREMENTAL_IDX, - NETDATA_EBPF_INCREMENTAL_IDX - }; - ebpf_global_labels( - shm_aggregated_data, - shm_publish_aggregated, - shm_dimension_name, - shm_dimension_name, - algorithms, - NETDATA_SHM_END - ); - - pthread_mutex_lock(&lock); - ebpf_create_shm_charts(em->update_every); - ebpf_update_stats(&plugin_statistics, em); - ebpf_update_kernel_memory_with_vector(&plugin_statistics, em->maps, EBPF_ACTION_STAT_ADD); -#ifdef NETDATA_DEV_MODE - if (ebpf_aral_shm_pid) - shm_disable_priority = ebpf_statistic_create_aral_chart(NETDATA_EBPF_SHM_ARAL_NAME, em); -#endif - - pthread_mutex_unlock(&lock); - - shm_collector(em); - -endshm: - ebpf_update_disabled_plugin_stats(em); - - netdata_thread_cleanup_pop(1); - return NULL; -} |