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/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;