增加subscribe ip扫描, 重构maat部分代码

2 files changed, 12 insertions, 1 deletions

diff --git a/common/include/kni_utils.h b/common/include/kni_utils.h
index cadbdad..13e0424 100644
--- a/common/include/kni_utils.h
+++ b/common/include/kni_utils.h
@@ -184,6 +184,6 @@ int kni_ipv4_header_parse(const void *a_packet, struct pkt_info *pktinfo);
 int kni_ipv6_header_parse(const void *a_packet, struct pkt_info *pktinfo);
 char* kni_ipv4_errmsg_get(enum kni_ipv4hdr_parse_error _errno);
 char* kni_ipv6_errmsg_get(enum kni_ipv6hdr_parse_error _errno);
-
+char* kni_strdup(const char* s);
 
 MESA_htable_handle kni_create_htable(const char *profile, const char *section, void *free_data_cb, void *expire_notify_cb, void *logger);
\ No newline at end of file
diff --git a/common/src/kni_utils.cpp b/common/src/kni_utils.cpp
index b7ba83e..3150ac1 100644
--- a/common/src/kni_utils.cpp
+++ b/common/src/kni_utils.cpp
@@ -22,6 +22,17 @@ int kni_addr_trans_v6(struct stream_tuple4_v6 *tuple4, char *output, int len){
 	return 0;
 }
 
+char* kni_strdup(const char* s){
+	char*d=NULL;
+	if(s==NULL){
+		return NULL;
+	}
+
+	d=(char*)malloc(strlen(s)+1);
+	memcpy(d,s,strlen(s)+1);
+	return d;
+}
+
 uint16_t kni_ip_checksum(const void *buf, size_t hdr_len){
 	unsigned long sum = 0;
 	const uint16_t *ip1;