TSG-13778 TSG master支持MAAT4

1 files changed, 85 insertions, 0 deletions

diff --git a/src/tsg_variable.cpp b/src/tsg_variable.cpp
new file mode 100644
index 0000000..19d3b9f
--- /dev/null
+++ b/src/tsg_variable.cpp
@@ -0,0 +1,85 @@
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+
+#include "tsg_label.h"
+#include "tsg_variable.h"
+
+struct tsg_rt_para g_tsg_para;
+
+struct id2field g_tsg_proto_name2id[PROTO_MAX]={{PROTO_UNKONWN, 0, "unknown"}, 
+										 {PROTO_IPv4, 	0,	"IPV4"},
+										 {PROTO_IPv6, 	0,	"IPV6"},
+										 {PROTO_TCP, 	0, 	"TCP"},
+										 {PROTO_UDP, 	0, 	"UDP"},
+										 {PROTO_HTTP, 	0, 	"HTTP"},
+										 {PROTO_MAIL, 	0, 	"MAIL"},
+										 {PROTO_DNS, 	0, 	"DNS"},
+										 {PROTO_FTP, 	0, 	"FTP"},
+										 {PROTO_SSL, 	0, 	"SSL"},
+										 {PROTO_SIP, 	0, 	"SIP"},
+										 {PROTO_BGP, 	0, 	"BGP"},
+										 {PROTO_STREAMING_MEDIA, 0, "STREAMING_MEDIA"},
+										 {PROTO_QUIC, 	0,	 "QUIC"},
+										 {PROTO_SSH, 	0, 	"SSH"},
+										 {PROTO_SMTP, 	0, 	"SMTP"},
+										 {PROTO_IMAP, 	0, 	"IMAP"},
+										 {PROTO_POP3, 	0, 	"POP3"},
+										 {PROTO_RTP, 	0, 	"RTP"},
+										 {PROTO_APP, 	0,	"BASE"},
+										 {PROTO_L2TP, 	0,	"L2TP"},
+										 {PROTO_PPTP, 	0,	"PPTP"},
+										 {PROTO_STRATUM, 	0,	"Stratum"},
+										 {PROTO_RDP, 	0,	"RDP"},
+										 {PROTO_DTLS, 	0,	"DTLS"}
+										};
+
+const char *tsg_l7_protocol_id2name(unsigned int l7_protocol_id)
+{	
+	struct l7_protocol *l7_proto=NULL;
+	HASH_FIND(hh1, g_tsg_para.name_by_id, &l7_protocol_id, sizeof(l7_protocol_id), l7_proto);
+	if(l7_proto!=NULL)
+	{
+		return (const char *)l7_proto->name;
+	}
+
+	return NULL;
+}
+
+unsigned int tsg_l7_protocol_name2id(const char *l7_protocol_name)
+{
+	struct l7_protocol *l7_proto=NULL;
+
+	HASH_FIND(hh2, g_tsg_para.id_by_name, l7_protocol_name, strlen(l7_protocol_name), l7_proto);
+	if(l7_proto!=NULL)
+	{
+		return l7_proto->id;
+	}
+
+	return 0;
+}
+
+long long tsg_get_current_time_ms(void)
+{
+	int size=sizeof(long long); 	
+	long long current_time_ms=0;		
+	sapp_get_platform_opt(SPO_CURTIME_TIMET_MS, &current_time_ms, &size);
+
+	return current_time_ms;
+}
+
+unsigned long long tsg_get_stream_trace_id(const struct streaminfo * a_stream)
+{
+	int ret=0;
+	int device_id_size=sizeof(unsigned long long);
+	unsigned long long device_id=(unsigned long long)g_tsg_para.device_seq_in_dc;
+
+	ret=MESA_get_stream_opt(a_stream, MSO_GLOBAL_STREAM_ID, (void *)&device_id, &device_id_size);
+	if(ret==0)
+	{
+		return device_id;
+	}
+
+	return -1;
+}
+