Add tuple info

Author: yinjiping

agent/src/ebpf/kernel/include/common.h

@@ -103,6 +103,7 @@ enum process_data_extra_source {
 DATA_SOURCE_GO_HTTP2_DATAFRAME_UPROBE,
 DATA_SOURCE_CLOSE,
 DATA_SOURCE_DPDK,
+DATA_SOURCE_UNIX_SOCKET,
 };
 
 struct protocol_message_t {

agent/src/ebpf/kernel/include/protocol_inference.h

@@ -3805,6 +3805,11 @@ infer_protocol_1(struct ctx_info_s *ctx,
 if (conn_info->sk == NULL)
 return inferred_message;
 
+if ((conn_info->sk_type != SOCK_UNIX) &&
+ (conn_info->tuple.dport == 0 || conn_info->tuple.num == 0)) {
+return inferred_message;
+}
+
 /*
  * The socket that is indeed determined to be a protocol does not
  * enter drop_msg_by_comm().

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

@@ -1640,7 +1640,11 @@ __data_submit(struct pt_regs *ctx, struct conn_info_s *conn_info,
 v->extra_data_count = 0;
 
 v->coroutine_id = trace_key.goid;
-v->source = extra->source;
+
+if (conn_info->sk_type == SOCK_UNIX)
+v->source = DATA_SOURCE_UNIX_SOCKET;
+else
+v->source = extra->source;
 
 #if defined(LINUX_VER_KFUNC) || defined(LINUX_VER_5_2_PLUS)
 __u32 cache_key = ((__u32) bpf_get_current_pid_tgid()) >> 16;

agent/src/ebpf/user/socket.c

@@ -1126,6 +1126,14 @@ static void reader_raw_cb(void *cookie, void *raw, int raw_size)
 if (sd->source != DATA_SOURCE_DPDK) {
 submit_data->socket_id = sd->socket_id;
 submit_data->tuple = sd->tuple;
+if (sd->source == DATA_SOURCE_UNIX_SOCKET) {
+submit_data->tuple.l4_protocol = IPPROTO_UDP;
+submit_data->tuple.dport = submit_data->tuple.num = 0; 
+submit_data->tuple.addr_len = 4;
+*(in_addr_t *)submit_data->tuple.rcv_saddr = htonl(0x7F000001); 
+*(in_addr_t *)submit_data->tuple.daddr = htonl(0x7F000001);
+}
+
 submit_data->need_reconfirm =
  need_proto_reconfirm(sd->data_type);
 submit_data->process_id = sd->tgid;