add block_rq_issue

sf1999817 · Sep 5, 2024 · cdc9323 · cdc9323
1 parent 8632749
commit cdc9323
Show file tree

Hide file tree

Showing 6 changed files with 4 additions and 7 deletions.
diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.bpf.c b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.bpf.c
@@ -12,7 +12,7 @@ struct {
     __uint(max_entries, 256 * 1024);
 } rb SEC(".maps");
 
-// Tracepoint 处理程序
+// 这里挂载点必须是struct trace_event_raw_block_rq_completion *ctx
 SEC("tracepoint/block/block_rq_issue")
 int tracepoint_block_rq_issue(struct trace_event_raw_block_rq_completion *ctx) {
     struct event *e;

diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.c b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.c
@@ -4,7 +4,6 @@
 #include <bpf/libbpf.h>
 #include "block_rq_issue.h"
 #include "block_rq_issue.skel.h"
-#include <inttypes.h> // For PRIu64
 
 static int libbpf_print_fn(enum libbpf_print_level level, const char *format, va_list args)
 {

diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.h b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/block_rq_issue.h
@@ -3,7 +3,6 @@
 
 #define TASK_COMM_LEN 256
 
-// 定义事件结构体
 struct event {
     long timestamp;       // 时间戳
     int dev;           // 设备号

diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/disk_io_visit.bpf.c b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/disk_io_visit.bpf.c
@@ -20,7 +20,7 @@ struct {
     __type(value, u32);
 } io_count_map SEC(".maps");
 
-// Tracepoint 处理程序
+// 这里挂载点得是这个struct trace_event_raw_block_rq_completion *ctx
 SEC("tracepoint/block/block_rq_complete")
 int tracepoint_block_visit(struct trace_event_raw_block_rq_completion *ctx) {
     struct event *e;

diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/fs_watcher.c b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/fs_watcher.c
@@ -229,7 +229,6 @@ static int handle_event_open(void *ctx, void *data, size_t data_sz)
 	int i = 0;
     int map_fd = *(int *)ctx;//传递map得文件描述符
 
-
 	for (; i < e->n_; ++i) {
 		snprintf(fd_path, sizeof(fd_path), "/proc/%d/fd/%d", e->pid_,
 			 i);

diff --git a/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/include/fs_watcher.h b/eBPF_Supermarket/Filesystem_Subsystem/fs_watcher/include/fs_watcher.h
@@ -1,11 +1,11 @@
 #ifndef __FS_WATCHER_H
 #define __FS_WATCHER_H
 
-/*open*/
+
 #define path_size 256
 
 #define TASK_COMM_LEN 256
-
+/*open*/
 struct event_open {
 	int pid_;
 	char path_name_[path_size];