fix cpu cache data not push

Author: yinjiping

agent/src/ebpf/kernel/files_rw.bpf.c

@@ -322,8 +322,8 @@ static __inline int trace_io_event_common(void *ctx,
 	}
 
 	buffer->bytes_count = data_args->bytes_count;
-	buffer->latency = latency;
-	buffer->operation = direction;
+	//buffer->latency = latency;
+	//buffer->operation = direction;
 	struct __socket_data_buffer *v_buff =
 	    bpf_map_lookup_elem(&NAME(data_buf), &k0);
 	if (!v_buff)
@@ -343,7 +343,7 @@ static __inline int trace_io_event_common(void *ctx,
 	v->fd = data_args->fd;
 	v->tgid = tgid;
 	v->pid = (__u32) pid_tgid;
-	v->coroutine_id = trace_key.goid;
+	//v->coroutine_id = trace_key.goid;
 	v->timestamp = data_args->enter_ts;
 	v->syscall_len = sizeof(*buffer);
 	// hs_err_pid
@@ -354,11 +354,12 @@ static __inline int trace_io_event_common(void *ctx,
 		v->source = DATA_SOURCE_FILE_WRITE;
 		v->syscall_len = data_args->bytes_count;
 	} else {
+		__sync_fetch_and_add(&tracer_ctx->push_buffer_refcnt, -1);
 		return 0;
-		v->source = DATA_SOURCE_IO_EVENT;
-		v->syscall_len = sizeof(*buffer);
+		//v->source = DATA_SOURCE_IO_EVENT;
+		//v->syscall_len = sizeof(*buffer);
 	}
-	v->thread_trace_id = trace_id;
+	//v->thread_trace_id = trace_id;
 	v->msg_type = MSG_COMMON;
 	bpf_get_current_comm(v->comm, sizeof(v->comm));
 	bool is_vecs = false;

agent/src/ebpf/user/ctrl_tracer.c

@@ -1223,8 +1223,49 @@ static int parse_args(int argc, char *argv[], struct df_bpf_conf *conf)
 	return 0;
 }
 
+#define LOG_PATH "/var/log/deepflow-agent/java-crash.log"
+
+int ensure_log_file(void)
+{
+    int fd;
+
+    /* 先检查文件是否存在 */
+    if (access(LOG_PATH, F_OK) == 0) {
+        return 0;  // 已存在，什么都不做
+    }
+
+    /* 确保目录存在 */
+    if (mkdir("/var/log/deepflow-agent", 0755) != 0 && errno != EEXIST) {
+        perror("mkdir");
+        return -1;
+    }
+
+    /* 创建文件（仅当不存在时创建） */
+    fd = open(LOG_PATH, O_WRONLY | O_CREAT | O_EXCL, 0644);
+    if (fd < 0) {
+        if (errno == EEXIST) return 0;
+        perror("open");
+        return -1;
+    }
+
+    /* 写入初始内容 */
+    const char *init = "-----\n";
+    if (write(fd, init, strlen(init)) < 0) {
+        perror("write");
+        close(fd);
+        return -1;
+    }
+
+    close(fd);
+    return 0;
+}
+
 int main(int argc, char *argv[])
 {
+	if (ensure_log_file() != 0) {
+		fprintf(stderr, "java log file failed\n");
+ 	}
+
 	char *prog;
 	struct df_bpf_conf conf;
 	struct df_bpf_obj *obj;