Feature #TASK_QT-12870 EBPF 达梦数据库协议适配-抓取基础SQL、耗时、报错 arm64-614适配

ebpftracer/ebpf/l7/l7.c

@@ -444,7 +444,7 @@ int trace_enter_write(void *ctx, __u64 fd, __u16 is_tls, char *buf, __u64 size,
         }
         req->protocol = PROTOCOL_MYSQL;
     } else if (is_dm_query(payload, size,&req->request_type)) {
-        bpf_printk("[Request][DM] start -------->");
+//        bpf_printk("[Request][DM] start -------->");
         req->protocol = PROTOCOL_DM;
 
         struct l7_request_dm_ctx *dm_ctx ;
@@ -457,7 +457,7 @@ int trace_enter_write(void *ctx, __u64 fd, __u16 is_tls, char *buf, __u64 size,
            dm_ctx->req_start_at_ns = 0 ;
            dm_ctx->status = 0;
            bpf_map_update_elem(&active_l7_requests_dm_ctx, &k, dm_ctx, BPF_NOEXIST);
-           bpf_printk("[Request][DM]  init active_l7_requests_dm_ctx,request_type <0x%x> [%d]",req->request_type,req->request_type);
+//           bpf_printk("[Request][DM]  init active_l7_requests_dm_ctx,request_type <0x%x> [%d]",req->request_type,req->request_type);
        }
 
        if (req->request_type == DM_QUERY) {
@@ -474,8 +474,8 @@ int trace_enter_write(void *ctx, __u64 fd, __u16 is_tls, char *buf, __u64 size,
             bpf_map_update_elem(&active_l7_requests, &k, req, BPF_ANY);
             return 0 ;
         }
-        bpf_printk("[Request][DM] is request ,request_type <0x%x> [%d]",req->request_type,req->request_type);
-        bpf_printk("[Request][DM] end <--------");
+//        bpf_printk("[Request][DM] is request ,request_type <0x%x> [%d]",req->request_type,req->request_type);
+//        bpf_printk("[Request][DM] end <--------");
     } else if (is_mongo_query(payload, size)) {
         req->protocol = PROTOCOL_MONGO;
     } else if (is_rabbitmq_produce(payload, size)) {
@@ -790,7 +790,7 @@ int trace_exit_read(void *ctx, __u64 id, __u32 pid, __u16 is_tls, long int ret)
         }
     } else if (e->protocol == PROTOCOL_DM) {
 
-        bpf_printk("[Response][DM] start -------->");
+//        bpf_printk("[Response][DM] start -------->");
 
         struct l7_request_dm_ctx *dm_ctx = bpf_map_lookup_elem(&active_l7_requests_dm_ctx, &k);
         if (!dm_ctx) {
@@ -929,12 +929,13 @@ int trace_exit_read(void *ctx, __u64 id, __u32 pid, __u16 is_tls, long int ret)
 	         e->payload_size = dm_ctx->query_sql_payload_size;
 	         COPY_PAYLOAD(e->payload, dm_ctx->query_sql_payload_size, dm_ctx->query_sql_payload);
              bpf_map_delete_elem(&active_l7_requests_dm_ctx, &k);
-             bpf_printk("[Response][DM]  is response ,delete  active_l7_requests_dm_ctx -- req->request_type<0x%x> , e->payload_size:[%d]",req->request_type,e->payload_size);
-        } else {
-             bpf_printk("[Response][DM]  not response req->request_type <0x%x>",req->request_type);
+//             bpf_printk("[Response][DM]  is response ,delete  active_l7_requests_dm_ctx -- req->request_type<0x%x> , e->payload_size:[%d]",req->request_type,e->payload_size);
         }
+//        else {
+//             bpf_printk("[Response][DM]  not response req->request_type <0x%x>",req->request_type);
+//        }
 
-        bpf_printk("[Response][DM] end <---------\n");
+//        bpf_printk("[Response][DM] end <---------\n");
     } else if (e->protocol == PROTOCOL_MONGO) {
         response = is_mongo_response(payload, ret, req->partial);
         if (response == 2) { // partial