wip

aquasecurity · Oct 1, 2024 · b3a3181 · b3a3181
1 parent 1e46fff
commit b3a3181
Show file tree

Hide file tree

Showing 6 changed files with 189 additions and 125 deletions.
diff --git a/api/v1beta1/diagnostic.pb.go b/api/v1beta1/diagnostic.pb.go
diff --git a/api/v1beta1/diagnostic.proto b/api/v1beta1/diagnostic.proto
@@ -12,12 +12,13 @@ message GetMetricsResponse {
 	uint64 EventsFiltered = 2;
 	uint64 NetCapCount = 3;
 	uint64 BPFLogsCount = 4;
-	uint64 BPFPerfEventWrites = 5;
-	uint64 ErrorCount = 6;
-	uint64 LostEvCount = 7; 
-	uint64 LostWrCount = 8; 
-	uint64 LostNtCapCount = 9; 
-	uint64 LostBPFLogsCount = 10;
+	uint64 BPFPerfEventWriteAttempts = 5;
+	uint64 BPFPerfEventWriteFailures = 6;
+	uint64 ErrorCount = 7;
+	uint64 LostEvCount = 8; 
+	uint64 LostWrCount = 9; 
+	uint64 LostNtCapCount = 10; 
+	uint64 LostBPFLogsCount = 11;
 }
 
 enum LogLevel {

diff --git a/pkg/ebpf/c/common/buffer.h b/pkg/ebpf/c/common/buffer.h
@@ -459,12 +459,18 @@ statfunc int save_args_to_submit_buf(event_data_t *event, args_t *args)
 }
 
 #ifdef DEBUG
-struct event_counts {
+
+typedef struct {
+    u64 attempts;
+    u64 failures;
+} event_stats_values_t;
+
+struct events_stats {
     __uint(type, BPF_MAP_TYPE_HASH);
     __uint(max_entries, MAX_EVENT_ID);
-    __type(key, u32);   // eventid
-    __type(value, u64); // count
-} event_counts SEC(".maps");
+    __type(key, u32);                   // eventid
+    __type(value, event_stats_values_t);
+} events_stats SEC(".maps");
 #endif
 
 statfunc int events_perf_submit(program_data_t *p, long ret)
@@ -493,14 +499,20 @@ statfunc int events_perf_submit(program_data_t *p, long ret)
                  :
                  : [size] "r"(size), [max_size] "i"(MAX_EVENT_SIZE));
 
+    u64 perf_ret = bpf_perf_event_output(p->ctx, &events, BPF_F_CURRENT_CPU, p->event, size);
+
 #ifdef DEBUG
-    // increment event count before event submission attempt
-    u64 *event_count = bpf_map_lookup_elem(&event_counts, &p->event->context.eventid);
-    if (event_count)
-        __sync_fetch_and_add(event_count, 1);
+    // update event stats
+    event_stats_values_t *evt_stat = bpf_map_lookup_elem(&events_stats, &p->event->context.eventid);
+    if (unlikely(evt_stat == NULL))
+        return perf_ret;
+
+    __sync_fetch_and_add(&evt_stat->attempts, 1);
+    if (perf_ret < 0)
+        __sync_fetch_and_add(&evt_stat->failures, 1);
 #endif
 
-    return bpf_perf_event_output(p->ctx, &events, BPF_F_CURRENT_CPU, p->event, size);
+    return perf_ret;
 }
 
 statfunc int signal_perf_submit(void *ctx, controlplane_signal_t *sig)