summaryrefslogtreecommitdiff
path: root/common
diff options
context:
space:
mode:
authorluwenpeng <[email protected]>2023-08-09 18:47:16 +0800
committerluwenpeng <[email protected]>2023-08-10 18:31:38 +0800
commite34aa3f5e23d7fa0b95944269c499d5c1e7c23aa (patch)
treeaf0565991e01741c850d9479850fc58df6f9b509 /common
parent1063574ca0d3fea91f26b8a6bd76a2d021efd822 (diff)
TSG-16531 PacketAdapter适配容器环境，使用mrzcpd收包，通过RAW Socket注RST包v2.0.0-20230810
Diffstat (limited to 'common')
-rw-r--r--common/CMakeLists.txt13
-rw-r--r--common/include/decode_gtp.h36
-rw-r--r--common/include/decode_ipv4.h55
-rw-r--r--common/include/decode_ipv6.h58
-rw-r--r--common/include/decode_tcp.h46
-rw-r--r--common/include/decode_udp.h40
-rw-r--r--common/include/log.h73
-rw-r--r--common/include/packet_inject.h19
-rw-r--r--common/include/packet_io.h35
-rw-r--r--common/include/packet_parser.h85
-rw-r--r--common/include/public.h38
-rw-r--r--common/include/utils.h61
-rw-r--r--common/src/decode_gtp.c56
-rw-r--r--common/src/decode_ipv4.c68
-rw-r--r--common/src/decode_ipv6.c55
-rw-r--r--common/src/decode_tcp.c52
-rw-r--r--common/src/decode_udp.c48
-rw-r--r--common/src/log.cpp33
-rw-r--r--common/src/packet_inject.cpp58
-rw-r--r--common/src/packet_io.cpp280
-rw-r--r--common/src/packet_parser.cpp668
-rw-r--r--common/test/CMakeLists.txt23
-rw-r--r--common/test/gtest_packet_inject.cpp178
-rw-r--r--common/test/gtest_packet_parser.cpp1525
-rw-r--r--common/test/pcap/1-ETH_VLAN_VLAN_IP4_IP4_UDP.pcapbin0 -> 954 bytes
-rw-r--r--common/test/pcap/10-ETH_IP6_UDP_GTP_IP4_TCP_TLS.pcapbin0 -> 1510 bytes
-rw-r--r--common/test/pcap/11-ETH_IP4_UDP_VXLAN_ETH_IP4_UDP_DNS.pcapbin0 -> 776 bytes
-rw-r--r--common/test/pcap/12-ETH_MPLS_MPLS_PWETHCW_ETH_ARP.pcapbin0 -> 1256 bytes
-rw-r--r--common/test/pcap/2-ETH_IP6_IP4_TCP_SSH.pcapbin0 -> 1356 bytes
-rw-r--r--common/test/pcap/3-ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS.pcapbin0 -> 312 bytes
-rw-r--r--common/test/pcap/4-ETH_IP4_IP6_TCP.pcap.pcapbin0 -> 1424 bytes
-rw-r--r--common/test/pcap/5-ETH_IP6_IP6_UDP.pcapbin0 -> 268 bytes
-rw-r--r--common/test/pcap/6-ETH_MPLS_IP4_TCP.pcapbin0 -> 3726 bytes
-rw-r--r--common/test/pcap/7-ETH_MPLS_MPLS_IP4_TCP.pcapbin0 -> 832 bytes
-rw-r--r--common/test/pcap/8-ETH_VLAN_PPPOE_IP4_TCP.pcapbin0 -> 79857 bytes
-rw-r--r--common/test/pcap/9-ETH_IP6_UDP_GTP_IP6_TCP_TLS.pcapbin0 -> 1482 bytes
36 files changed, 3049 insertions, 554 deletions
diff --git a/common/CMakeLists.txt b/common/CMakeLists.txt
index c9d83f3..a14f32a 100644
--- a/common/CMakeLists.txt
+++ b/common/CMakeLists.txt
@@ -1,2 +1,11 @@
-add_library(common src/decode_ipv4.c src/decode_ipv6.c src/decode_tcp.c src/decode_udp.c src/decode_gtp.c)
-target_include_directories(common PUBLIC ${CMAKE_CURRENT_LIST_DIR}/include) \ No newline at end of file
+add_library(common
+ src/log.cpp
+ src/packet_io.cpp
+ src/packet_parser.cpp
+ src/packet_inject.cpp)
+target_include_directories(common PUBLIC ${CMAKE_CURRENT_LIST_DIR}/include)
+
+target_link_libraries(common PUBLIC mrzcpd)
+target_link_libraries(common PUBLIC MESA_prof_load)
+target_link_libraries(common PUBLIC MESA_handle_logger)
+add_subdirectory(test) \ No newline at end of file
diff --git a/common/include/decode_gtp.h b/common/include/decode_gtp.h
deleted file mode 100644
index 0d936a6..0000000
--- a/common/include/decode_gtp.h
+++ /dev/null
@@ -1,36 +0,0 @@
-#ifndef _DECODE_GTP_H
-#define _DECODE_GTP_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include "public.h"
-
- /* According to 3GPP TS 29.060. */
- typedef struct gtp1_header_s
- {
- uint8_t flags;
- uint8_t type;
- uint16_t length;
- uint32_t tid;
- } __attribute__((packed)) gtp1_header_t;
-
- typedef struct gtp_info_s
- {
- gtp1_header_t *hdr;
- uint8_t *payload;
-
- uint32_t hdr_len;
- uint32_t payload_len;
- } gtp_info_t;
-
- int decode_gtp(gtp_info_t *packet, const uint8_t *data, uint32_t len);
- int dump_gtp_info(gtp_info_t *packet, char *buff, size_t size);
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/decode_ipv4.h b/common/include/decode_ipv4.h
deleted file mode 100644
index 73cacd1..0000000
--- a/common/include/decode_ipv4.h
+++ /dev/null
@@ -1,55 +0,0 @@
-#ifndef _DECODE_IPV4_H
-#define _DECODE_IPV4_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include "public.h"
-
-#define IPV4_HEADER_LEN 20
-
- typedef struct ipv4_header_s
- {
- uint8_t ip_verhl; // version & header length
- uint8_t ip_tos;
- uint16_t ip_len;
- uint16_t ip_id;
- uint16_t ip_off;
- uint8_t ip_ttl;
- uint8_t ip_proto;
- uint16_t ip_csum;
- union
- {
- struct
- {
- struct in_addr ip_src;
- struct in_addr ip_dst;
- } ip4_un1;
- uint16_t ip_addrs[4];
- } ip4_hdrun1;
- } __attribute__((__packed__)) ipv4_header_t;
-
- typedef struct ipv4_info_s
- {
- char src_addr[INET_ADDRSTRLEN];
- char dst_addr[INET_ADDRSTRLEN];
-
- ipv4_header_t *hdr;
- uint8_t *payload;
- uint8_t next_protocol;
-
- uint32_t hdr_len;
- uint32_t opts_len;
- uint32_t payload_len;
- } ipv4_info_t;
-
- int decode_ipv4(ipv4_info_t *packet, const uint8_t *data, uint32_t len);
- int dump_ipv4_info(ipv4_info_t *packet, char *buff, size_t size);
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/decode_ipv6.h b/common/include/decode_ipv6.h
deleted file mode 100644
index 6e66226..0000000
--- a/common/include/decode_ipv6.h
+++ /dev/null
@@ -1,58 +0,0 @@
-#ifndef _DECODE_IPV6_H
-#define _DECODE_IPV6_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include "public.h"
-
-#define IPV6_HEADER_LEN 40
-
- typedef struct ipv6_header_s
- {
- union
- {
- struct ip6_un1_
- {
- uint32_t ip6_un1_flow; /* 20 bits of flow-ID */
- uint16_t ip6_un1_plen; /* payload length */
- uint8_t ip6_un1_nxt; /* next header */
- uint8_t ip6_un1_hlim; /* hop limit */
- } ip6_un1;
- uint8_t ip6_un2_vfc; /* 4 bits version, top 4 bits class */
- } ip6_hdrun;
-
- union
- {
- struct
- {
- uint32_t ip6_src[4];
- uint32_t ip6_dst[4];
- } ip6_un2;
- uint16_t ip6_addrs[16];
- } ip6_hdrun2;
- } __attribute__((__packed__)) ipv6_header_t;
-
- typedef struct ipv6_info_s
- {
- char src_addr[INET6_ADDRSTRLEN];
- char dst_addr[INET6_ADDRSTRLEN];
-
- ipv6_header_t *hdr;
- uint8_t *payload;
- uint8_t next_protocol;
-
- uint32_t hdr_len;
- uint32_t payload_len;
- } ipv6_info_t;
-
- int decode_ipv6(ipv6_info_t *packet, const uint8_t *data, uint32_t len);
- int dump_ipv6_info(ipv6_info_t *packet, char *buff, size_t size);
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/decode_tcp.h b/common/include/decode_tcp.h
deleted file mode 100644
index 26197ac..0000000
--- a/common/include/decode_tcp.h
+++ /dev/null
@@ -1,46 +0,0 @@
-#ifndef _DECODE_TCP_H
-#define _DECODE_TCP_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include "public.h"
-
-#define TCP_HEADER_LEN 20
-
- typedef struct tcp_header_s
- {
- uint16_t th_sport; /**< source port */
- uint16_t th_dport; /**< destination port */
- uint32_t th_seq; /**< sequence number */
- uint32_t th_ack; /**< acknowledgement number */
- uint8_t th_offx2; /**< offset and reserved */
- uint8_t th_flags; /**< pkt flags */
- uint16_t th_win; /**< pkt window */
- uint16_t th_sum; /**< checksum */
- uint16_t th_urp; /**< urgent pointer */
- } __attribute__((__packed__)) tcp_header_t;
-
- typedef struct tcp_info_s
- {
- uint16_t src_port;
- uint16_t dst_port;
-
- tcp_header_t *hdr;
- uint8_t *payload;
-
- uint32_t opt_len;
- uint32_t hdr_len;
- uint32_t payload_len;
- } tcp_info_t;
-
- int decode_tcp(tcp_info_t *packet, const uint8_t *data, uint32_t len);
- int dump_tcp_info(tcp_info_t *packet, char *buff, size_t size);
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/decode_udp.h b/common/include/decode_udp.h
deleted file mode 100644
index fc12ffe..0000000
--- a/common/include/decode_udp.h
+++ /dev/null
@@ -1,40 +0,0 @@
-#ifndef _DECODE_UDP_H
-#define _DECODE_UDP_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include "public.h"
-
-#define UDP_HEADER_LEN 8
-
- typedef struct udp_header_s
- {
- uint16_t udp_src_port;
- uint16_t udp_dst_port;
- uint16_t udp_len;
- uint16_t udp_sum;
- } __attribute__((__packed__)) udp_header_t;
-
- typedef struct udp_info_s
- {
- uint16_t src_port;
- uint16_t dst_port;
-
- udp_header_t *hdr;
- uint8_t *payload;
-
- uint32_t hdr_len;
- uint32_t payload_len;
- } udp_info_t;
-
- int decode_udp(udp_info_t *packet, const uint8_t *data, uint32_t len);
- int dump_udp_info(udp_info_t *packet, char *buff, size_t size);
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/log.h b/common/include/log.h
new file mode 100644
index 0000000..98f8239
--- /dev/null
+++ b/common/include/log.h
@@ -0,0 +1,73 @@
+#ifndef _LOG_H
+#define _LOG_H
+
+#ifdef __cpluscplus
+extern "C"
+{
+#endif
+
+#include <stdio.h>
+#include <MESA/MESA_handle_logger.h>
+
+extern void *default_logger;
+
+int LOG_INIT(const char *profile);
+void LOG_CLOSE(void);
+void LOG_RELOAD(void);
+
+#define LOG_DEBUG(format, ...) \
+ do \
+ { \
+ if (default_logger == NULL) \
+ { \
+ fprintf(stdout, "[DEBUG] " format "\n", ##__VA_ARGS__); \
+ fflush(stdout); \
+ } \
+ else \
+ { \
+ if (MESA_handle_runtime_log_level_enabled(default_logger, RLOG_LV_DEBUG)) \
+ { \
+ MESA_handle_runtime_log(default_logger, RLOG_LV_DEBUG, __FUNCTION__, format, ##__VA_ARGS__); \
+ } \
+ } \
+ } while (0)
+
+#define LOG_INFO(format, ...) \
+ do \
+ { \
+ if (default_logger == NULL) \
+ { \
+ fprintf(stdout, "[INFOR] " format "\n", ##__VA_ARGS__); \
+ fflush(stdout); \
+ } \
+ else \
+ { \
+ if (MESA_handle_runtime_log_level_enabled(default_logger, RLOG_LV_INFO)) \
+ { \
+ MESA_handle_runtime_log(default_logger, RLOG_LV_INFO, __FUNCTION__, format, ##__VA_ARGS__); \
+ } \
+ } \
+ } while (0)
+
+#define LOG_ERROR(format, ...) \
+ do \
+ { \
+ if (default_logger == NULL) \
+ { \
+ fprintf(stdout, "[ERROR] " format "\n", ##__VA_ARGS__); \
+ fflush(stdout); \
+ } \
+ else \
+ { \
+ if (MESA_handle_runtime_log_level_enabled(default_logger, RLOG_LV_FATAL)) \
+ { \
+ MESA_handle_runtime_log(default_logger, RLOG_LV_FATAL, __FUNCTION__, format, ##__VA_ARGS__); \
+ } \
+ } \
+ } while (0)
+
+#ifdef __cpluscplus
+}
+#endif
+
+#endif
diff --git a/common/include/packet_inject.h b/common/include/packet_inject.h
new file mode 100644
index 0000000..a70bcd4
--- /dev/null
+++ b/common/include/packet_inject.h
@@ -0,0 +1,19 @@
+#ifndef _PACKET_INJECT_H
+#define _PACKET_INJECT_H
+
+#ifdef __cpluscplus
+extern "C"
+{
+#endif
+
+#include <netinet/ip.h>
+#include <netinet/ip6.h>
+
+int packet_inject_ipv4(struct in_addr *ip_dst, const char *data, int len);
+int packet_inject_ipv6(struct in6_addr *ip6_dst, const char *data, int len);
+
+#ifdef __cpluscplus
+}
+#endif
+
+#endif
diff --git a/common/include/packet_io.h b/common/include/packet_io.h
new file mode 100644
index 0000000..db8a011
--- /dev/null
+++ b/common/include/packet_io.h
@@ -0,0 +1,35 @@
+#ifndef _PACKET_IO_H
+#define _PACKET_IO_H
+
+#ifdef __cpluscplus
+extern "C"
+{
+#endif
+
+#include <marsio.h>
+
+#define MAX_THREAD_NUM 128
+
+enum action
+{
+ ACTION_BYPASS = 0x1,
+ ACTION_DROP = 0x2,
+};
+
+struct packet_io;
+typedef enum action packet_handle_cb(const char *data, int len, void *args);
+void packet_io_set_callback(struct packet_io *handle, packet_handle_cb *cb, void *args);
+
+struct packet_io *packet_io_create(const char *profile);
+void packet_io_destory(struct packet_io *handle);
+
+int packet_io_thread_init(struct packet_io *handle, int thread_index);
+void packet_io_thread_wait(struct packet_io *handle, int thread_index, int timeout_ms);
+int packet_io_thread_polling(struct packet_io *handle, int thread_index);
+int packet_io_thread_number(struct packet_io *handle);
+
+#ifdef __cpluscplus
+}
+#endif
+
+#endif
diff --git a/common/include/packet_parser.h b/common/include/packet_parser.h
new file mode 100644
index 0000000..58f475c
--- /dev/null
+++ b/common/include/packet_parser.h
@@ -0,0 +1,85 @@
+#ifndef _PACKET_PARSER_H
+#define _PACKET_PARSER_H
+
+#ifdef __cpluscplus
+extern "C"
+{
+#endif
+
+#include <stdint.h>
+
+enum layer_type
+{
+ // 数据链路层
+ LAYER_TYPE_ETHER = 1 << 0,
+ LAYER_TYPE_PPP = 1 << 1,
+ LAYER_TYPE_HDLC = 1 << 2,
+ LAYER_TYPE_L2 = (LAYER_TYPE_ETHER | LAYER_TYPE_PPP | LAYER_TYPE_HDLC),
+
+ // 数据链路层 -- 隧道
+ LAYER_TYPE_VLAN = 1 << 3,
+ LAYER_TYPE_PPPOE = 1 << 4,
+ LAYER_TYPE_MPLS = 1 << 5,
+ LAYER_TYPE_L2_TUN = (LAYER_TYPE_VLAN | LAYER_TYPE_PPPOE | LAYER_TYPE_MPLS),
+
+ // 网络层
+ LAYER_TYPE_IPV4 = 1 << 6,
+ LAYER_TYPE_IPV6 = 1 << 7,
+ LAYER_TYPE_L3 = (LAYER_TYPE_IPV4 | LAYER_TYPE_IPV6),
+
+ // 网络层 -- 隧道
+
+ // 传输层
+ LAYER_TYPE_UDP = 1 << 8,
+ LAYER_TYPE_TCP = 1 << 9,
+ LAYER_TYPE_L4 = (LAYER_TYPE_UDP | LAYER_TYPE_TCP),
+
+ // 传输层 -- 隧道
+ LAYER_TYPE_G_VXLAN = 1 << 10,
+ LAYER_TYPE_GTPV1_U = 1 << 11,
+
+ // ALL
+ LAYER_TYPE_ALL = (LAYER_TYPE_L2 | LAYER_TYPE_L2_TUN | LAYER_TYPE_L3 | LAYER_TYPE_L4 | LAYER_TYPE_G_VXLAN | LAYER_TYPE_GTPV1_U),
+
+ // UNKNOWN
+ LAYER_TYPE_UNKNOWN,
+};
+
+struct layer_record
+{
+ enum layer_type type;
+ uint16_t hdr_offset;
+ uint16_t hdr_len;
+ uint16_t pld_len;
+};
+
+struct parser_result
+{
+ struct layer_record layers[16];
+ uint16_t used;
+ uint16_t size;
+};
+
+struct packet_parser
+{
+ struct parser_result result;
+
+ const void *packet_data;
+ uint16_t packet_len;
+ uint64_t packet_id;
+};
+
+void packet_parser_init(struct packet_parser *handler);
+const void *packet_parser_parse(struct packet_parser *handler, const void *packet_data, uint16_t packet_len, uint64_t packet_id); // return most inner payload
+const struct layer_record *packet_parser_get_most_inner(struct packet_parser *handler, enum layer_type type);
+const struct layer_record *packet_parser_get_most_outer(struct packet_parser *handler, enum layer_type type);
+
+// return 4: IPv4
+// return 6: IPv6
+uint8_t gtp_next_proto(const char *data);
+
+#ifdef __cpluscplus
+}
+#endif
+
+#endif
diff --git a/common/include/public.h b/common/include/public.h
deleted file mode 100644
index 3e8083e..0000000
--- a/common/include/public.h
+++ /dev/null
@@ -1,38 +0,0 @@
-#ifndef _PUBLIC_H
-#define _PUBLIC_H
-
-#ifdef __cpluscplus
-extern "C"
-{
-#endif
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <signal.h>
-#include <sys/stat.h>
-#include <arpa/inet.h>
-
-#define MIN(a, b) (((a) < (b)) ? (a) : (b))
-#define IP_GET_RAW_VER(raw_pkt) ((((raw_pkt)[0] & 0xf0) >> 4))
-
-#define LOG_DEBUG(format, ...) \
- { \
- fprintf(stdout, format "\n", ##__VA_ARGS__); \
- fflush(stdout); \
- }
-
-#define LOG_ERROR(format, ...) \
- { \
- fprintf(stderr, format "\n", ##__VA_ARGS__); \
- fflush(stderr); \
- }
-
-#ifdef __cpluscplus
-}
-#endif
-
-#endif \ No newline at end of file
diff --git a/common/include/utils.h b/common/include/utils.h
new file mode 100644
index 0000000..7b26103
--- /dev/null
+++ b/common/include/utils.h
@@ -0,0 +1,61 @@
+#ifndef _UTILS_H
+#define _UTILS_H
+
+#ifdef __cpluscplus
+extern "C"
+{
+#endif
+
+#include <stdint.h>
+#include <stdio.h>
+
+struct metrics
+{
+ uint64_t rx_pkts;
+ uint64_t rx_bytes;
+
+ uint64_t rx_err_pkts;
+ uint64_t rx_err_bytes;
+
+ uint64_t succ_tx_v4_pkts;
+ uint64_t succ_tx_v4_bytes;
+
+ uint64_t succ_tx_v6_pkts;
+ uint64_t succ_tx_v6_bytes;
+
+ uint64_t err_tx_v4_pkts;
+ uint64_t err_tx_v4_bytes;
+
+ uint64_t err_tx_v6_pkts;
+ uint64_t err_tx_v6_bytes;
+};
+
+inline void metrics_dump(struct metrics *metrics)
+{
+ printf(" rx_pkts : %ld\n", metrics->rx_pkts);
+ printf(" rx_bytes : %ld\n", metrics->rx_bytes);
+
+ printf(" rx_err_pkts : %ld\n", metrics->rx_err_pkts);
+ printf(" rx_err_bytes : %ld\n", metrics->rx_err_bytes);
+
+ printf(" succ_tx_v4_pkts : %ld\n", metrics->succ_tx_v4_pkts);
+ printf(" succ_tx_v4_bytes : %ld\n", metrics->succ_tx_v4_bytes);
+
+ printf(" succ_tx_v6_pkts : %ld\n", metrics->succ_tx_v6_pkts);
+ printf(" succ_tx_v6_bytes : %ld\n", metrics->succ_tx_v6_bytes);
+
+ printf(" err_tx_v4_pkts : %ld\n", metrics->err_tx_v4_pkts);
+ printf(" err_tx_v4_bytes : %ld\n", metrics->err_tx_v4_bytes);
+
+ printf(" err_tx_v6_pkts : %ld\n", metrics->err_tx_v6_pkts);
+ printf(" err_tx_v6_bytes : %ld\n", metrics->err_tx_v6_bytes);
+}
+
+#define ATOMIC_READ(x) __atomic_fetch_add(x, 0, __ATOMIC_RELAXED)
+#define ATOMIC_ADD(x, y) __atomic_fetch_add(x, y, __ATOMIC_RELAXED)
+
+#ifdef __cpluscplus
+}
+#endif
+
+#endif
diff --git a/common/src/decode_gtp.c b/common/src/decode_gtp.c
deleted file mode 100644
index 9398ab5..0000000
--- a/common/src/decode_gtp.c
+++ /dev/null
@@ -1,56 +0,0 @@
-#include "decode_gtp.h"
-
-#define GTP_TPDU 255
-#define GTP1U_PORT 2152
-#define GTP1_F_MASK 0x07
-
-#define GTP1_GET_TYPE(gtp1_hdr) ((gtp1_hdr)->type)
-#define GTP1_GET_FLAGS(gtp1_hdr) ((gtp1_hdr)->flags >> 5)
-#define GTP1_GET_HLEN(gtp1_hdr) (((gtp1_hdr)->flags & GTP1_F_MASK) > 0 ? 12 : 8)
-
-enum gtp_version_e
-{
- GTP_V0 = 0,
- GTP_V1,
-};
-
-int decode_gtp(gtp_info_t *packet, const uint8_t *data, uint32_t len)
-{
- if (len < sizeof(gtp1_header_t))
- {
- LOG_ERROR("Parser GTP Header: packet length too small %d", len);
- return -1;
- }
-
- packet->hdr = (gtp1_header_t *)data;
- if (GTP1_GET_FLAGS(packet->hdr) != GTP_V1)
- {
- LOG_ERROR("Parser GTP Header: invalid gtp flags %d", GTP1_GET_FLAGS(packet->hdr));
- return -1;
- }
-
- if (GTP1_GET_TYPE(packet->hdr) != GTP_TPDU)
- {
- LOG_ERROR("Parser GTP Header: invalid gtp type %d", GTP1_GET_TYPE(packet->hdr));
- return -1;
- }
-
- /* From 29.060: "This field shall be present if and only if any one or
- * more of the S, PN and E flags are set.".
- *
- * If any of the bit is set, then the remaining ones also have to be set.
- */
- packet->hdr_len = GTP1_GET_HLEN(packet->hdr);
- packet->payload = (uint8_t *)data + packet->hdr_len;
- packet->payload_len = len - packet->hdr_len;
-
- return 0;
-}
-
-int dump_gtp_info(gtp_info_t *packet, char *buff, size_t size)
-{
- return snprintf(buff, size,
- "{\"hdr_len\":%u,\"data_len\":%u}",
- packet->hdr_len,
- packet->payload_len);
-} \ No newline at end of file
diff --git a/common/src/decode_ipv4.c b/common/src/decode_ipv4.c
deleted file mode 100644
index 512d5af..0000000
--- a/common/src/decode_ipv4.c
+++ /dev/null
@@ -1,68 +0,0 @@
-#include "decode_ipv4.h"
-
-#define IPV4_GET_HLEN(ip4_hdr) (((ip4_hdr)->ip_verhl & 0x0f) << 2)
-#define IPV4_GET_IPPROTO(ip4_hdr) ((ip4_hdr)->ip_proto)
-#define IPV4_GET_IPLEN(ip4_hdr) ((uint16_t)ntohs((ip4_hdr)->ip_len))
-#define IPV4_GET_SRC_ADDR(ip4_hdr) ((ip4_hdr)->ip4_hdrun1.ip4_un1.ip_src)
-#define IPV4_GET_DST_ADDR(ip4_hdr) ((ip4_hdr)->ip4_hdrun1.ip4_un1.ip_dst)
-
-int decode_ipv4(ipv4_info_t *packet, const uint8_t *data, uint32_t len)
-{
- // 检查包长是否大于 IPv4 header
- if (len < IPV4_HEADER_LEN)
- {
- LOG_ERROR("Parser IPv4 Header: packet length too small %d", len);
- return -1;
- }
-
- // 检查 IPv4 header version
- if (IP_GET_RAW_VER(data) != 4)
- {
- LOG_ERROR("Parser IPv4 Header: invalid IP version %d", IP_GET_RAW_VER(data));
- return -1;
- }
-
- packet->hdr = (ipv4_header_t *)data;
- // 检查 IPv4 header length
- if (IPV4_GET_HLEN(packet->hdr) < IPV4_HEADER_LEN)
- {
- LOG_ERROR("Parser IPv4 Header: invalid IP header length %d", IPV4_GET_HLEN(packet->hdr));
- return -1;
- }
-
- // 检查 IPv4 header total length
- if (IPV4_GET_IPLEN(packet->hdr) < IPV4_GET_HLEN(packet->hdr))
- {
- LOG_ERROR("Parser IPv4 Header: invalid IP header total length %d", IPV4_GET_IPLEN(packet->hdr));
- return -1;
- }
-
- // 检查是否 IP 分片
- if (len < IPV4_GET_IPLEN(packet->hdr))
- {
- LOG_ERROR("Parser IPv4 Header: trunc packet");
- return -1;
- }
-
- inet_ntop(AF_INET, &IPV4_GET_SRC_ADDR(packet->hdr), packet->src_addr, sizeof(packet->src_addr));
- inet_ntop(AF_INET, &IPV4_GET_DST_ADDR(packet->hdr), packet->dst_addr, sizeof(packet->dst_addr));
-
- packet->next_protocol = IPV4_GET_IPPROTO(packet->hdr);
- packet->hdr_len = IPV4_GET_HLEN(packet->hdr);
- packet->opts_len = packet->hdr_len - IPV4_HEADER_LEN;
- packet->payload_len = len - packet->hdr_len;
- packet->payload = (uint8_t *)data + packet->hdr_len;
-
- return 0;
-}
-
-int dump_ipv4_info(ipv4_info_t *packet, char *buff, size_t size)
-{
- return snprintf(buff, size,
- "{\"src_addr\":\"%s\",\"dst_addr\":\"%s\",\"hdr_len\":%u,\"opts_len\":%u,\"data_len\":%u}",
- packet->src_addr,
- packet->dst_addr,
- packet->hdr_len,
- packet->opts_len,
- packet->payload_len);
-} \ No newline at end of file
diff --git a/common/src/decode_ipv6.c b/common/src/decode_ipv6.c
deleted file mode 100644
index b360550..0000000
--- a/common/src/decode_ipv6.c
+++ /dev/null
@@ -1,55 +0,0 @@
-#include "decode_ipv6.h"
-
-#define IPV6_GET_PLEN(ip6_hdr) ((uint16_t)ntohs((ip6_hdr)->ip6_hdrun.ip6_un1.ip6_un1_plen))
-#define IPV6_GET_NH(ip6_hdr) ((ip6_hdr)->ip6_hdrun.ip6_un1.ip6_un1_nxt)
-#define IPV6_GET_SRC_ADDR(ip6_hdr) ((ip6_hdr)->ip6_hdrun2.ip6_un2.ip6_src)
-#define IPV6_GET_DST_ADDR(ip6_hdr) ((ip6_hdr)->ip6_hdrun2.ip6_un2.ip6_dst)
-
-int decode_ipv6(ipv6_info_t *packet, const uint8_t *data, uint32_t len)
-{
- if (len < IPV6_HEADER_LEN)
- {
- LOG_ERROR("Parser IPv6 Header: packet length too small %d", len);
- return -1;
- }
-
- // 检查 IPv6 header version
- if (IP_GET_RAW_VER(data) != 6)
- {
- LOG_ERROR("Parser IPv6 Header: invalid IP version %d", IP_GET_RAW_VER(data));
- return -1;
- }
-
- packet->hdr = (ipv6_header_t *)data;
- if (len < (IPV6_HEADER_LEN + IPV6_GET_PLEN(packet->hdr)))
- {
- LOG_ERROR("Parser IPv6 Header: trunc packet");
- return -1;
- }
-
- if (len != (IPV6_HEADER_LEN + IPV6_GET_PLEN(packet->hdr)))
- {
- LOG_ERROR("Parser IPv6 Header: invalid payload length %d", IPV6_GET_PLEN(packet->hdr));
- return -1;
- }
-
- inet_ntop(AF_INET6, &IPV6_GET_SRC_ADDR(packet->hdr), packet->src_addr, sizeof(packet->src_addr));
- inet_ntop(AF_INET6, &IPV6_GET_DST_ADDR(packet->hdr), packet->dst_addr, sizeof(packet->dst_addr));
-
- packet->next_protocol = IPV6_GET_NH(packet->hdr);
- packet->hdr_len = IPV6_HEADER_LEN;
- packet->payload = (uint8_t *)data + packet->hdr_len;
- packet->payload_len = len - packet->hdr_len;
-
- return 0;
-}
-
-int dump_ipv6_info(ipv6_info_t *packet, char *buff, size_t size)
-{
- return snprintf(buff, size,
- "{\"src_addr\":\"%s\",\"dst_addr\":\"%s\",\"hdr_len\":%u,\"data_len\":%u}",
- packet->src_addr,
- packet->dst_addr,
- packet->hdr_len,
- packet->payload_len);
-} \ No newline at end of file
diff --git a/common/src/decode_tcp.c b/common/src/decode_tcp.c
deleted file mode 100644
index f8a7cd6..0000000
--- a/common/src/decode_tcp.c
+++ /dev/null
@@ -1,52 +0,0 @@
-#include "decode_tcp.h"
-
-#define TCP_OPTLENMAX 40
-
-#define TCP_GET_HLEN(tcp_hdr) ((((tcp_hdr)->th_offx2 & 0xf0) >> 4) << 2)
-#define TCP_GET_SRC_PORT(tcp_hdr) ((uint16_t)ntohs((tcp_hdr)->th_sport))
-#define TCP_GET_DST_PORT(tcp_hdr) ((uint16_t)ntohs((tcp_hdr)->th_dport))
-
-int decode_tcp(tcp_info_t *packet, const uint8_t *data, uint32_t len)
-{
- if (len < TCP_HEADER_LEN)
- {
- LOG_ERROR("Parser TCP Header: packet length too small %d", len);
- return -1;
- }
-
- packet->hdr = (tcp_header_t *)data;
- uint8_t hlen = TCP_GET_HLEN(packet->hdr);
- if (len < hlen)
- {
- LOG_ERROR("Parser TCP Header: TCP packet too small %d", len);
- return -1;
- }
-
- uint8_t tcp_opt_len = hlen - TCP_HEADER_LEN;
- if (tcp_opt_len > TCP_OPTLENMAX)
- {
- LOG_ERROR("Parser TCP Header: invalid opt length %d", tcp_opt_len);
- return -1;
- }
-
- packet->opt_len = tcp_opt_len;
- packet->src_port = TCP_GET_SRC_PORT(packet->hdr);
- packet->dst_port = TCP_GET_DST_PORT(packet->hdr);
-
- packet->hdr_len = hlen;
- packet->payload = (uint8_t *)data + packet->hdr_len;
- packet->payload_len = len - packet->hdr_len;
-
- return 0;
-}
-
-int dump_tcp_info(tcp_info_t *packet, char *buff, size_t size)
-{
- return snprintf(buff, size,
- "{\"src_port\":%u,\"dst_port\":%u,\"hdr_len\":%u,\"opt_len\":%u,\"data_len\":%u}",
- packet->src_port,
- packet->dst_port,
- packet->hdr_len,
- packet->opt_len,
- packet->payload_len);
-} \ No newline at end of file
diff --git a/common/src/decode_udp.c b/common/src/decode_udp.c
deleted file mode 100644
index fff1256..0000000
--- a/common/src/decode_udp.c
+++ /dev/null
@@ -1,48 +0,0 @@
-#include "decode_udp.h"
-
-#define UDP_GET_LEN(udp_hdr) ((uint16_t)ntohs((udp_hdr)->udp_len))
-#define UDP_GET_SRC_PORT(udp_hdr) ((uint16_t)ntohs((udp_hdr)->udp_src_port))
-#define UDP_GET_DST_PORT(udp_hdr) ((uint16_t)ntohs((udp_hdr)->udp_dst_port))
-
-int decode_udp(udp_info_t *packet, const uint8_t *data, uint32_t len)
-{
- if (len < UDP_HEADER_LEN)
- {
- LOG_ERROR("Parser UDP Header: packet length too small %d", len);
- return -1;
- }
-
- packet->hdr = (udp_header_t *)data;
- // 检查 UDP header len
- if (len < UDP_GET_LEN(packet->hdr))
- {
- LOG_ERROR("Parser UDP Header: UDP packet too small %d", len);
- return -1;
- }
-
- // 检查 UDP header len
- if (len != UDP_GET_LEN(packet->hdr))
- {
- LOG_ERROR("Parser UDP Header: invalid UDP header length %d", UDP_GET_LEN(packet->hdr));
- return -1;
- }
-
- packet->src_port = UDP_GET_SRC_PORT(packet->hdr);
- packet->dst_port = UDP_GET_DST_PORT(packet->hdr);
-
- packet->hdr_len = UDP_HEADER_LEN;
- packet->payload = (uint8_t *)data + UDP_HEADER_LEN;
- packet->payload_len = len - UDP_HEADER_LEN;
-
- return 0;
-}
-
-int dump_udp_info(udp_info_t *packet, char *buff, size_t size)
-{
- return snprintf(buff, size,
- "{\"src_port\":%u,\"dst_port\":%u,\"hdr_len\":%u,\"data_len\":%u}",
- packet->src_port,
- packet->dst_port,
- packet->hdr_len,
- packet->payload_len);
-}
diff --git a/common/src/log.cpp b/common/src/log.cpp
new file mode 100644
index 0000000..5a6a7cf
--- /dev/null
+++ b/common/src/log.cpp
@@ -0,0 +1,33 @@
+#include "log.h"
+
+void *default_logger = NULL;
+
+// return 0 : success
+// return -1 : error
+int LOG_INIT(const char *profile)
+{
+ if (0 != MESA_handle_runtime_log_creation(profile))
+ {
+ fprintf(stderr, "FATAL: unable to create runtime logger\n");
+ return -1;
+ }
+
+ default_logger = MESA_create_runtime_log_handle("packet_adapter", RLOG_LV_DEBUG);
+ if (default_logger == NULL)
+ {
+ fprintf(stderr, "FATAL: unable to create log handle\n");
+ return -1;
+ }
+
+ return 0;
+}
+
+void LOG_CLOSE(void)
+{
+ MESA_handle_runtime_log_destruction();
+}
+
+void LOG_RELOAD(void)
+{
+ MESA_handle_runtime_log_reconstruction(NULL);
+}
diff --git a/common/src/packet_inject.cpp b/common/src/packet_inject.cpp
new file mode 100644
index 0000000..464fefa
--- /dev/null
+++ b/common/src/packet_inject.cpp
@@ -0,0 +1,58 @@
+#include <errno.h>
+#include <string.h>
+#include <unistd.h>
+#include <arpa/inet.h>
+
+#include "log.h"
+
+int packet_inject_ipv4(struct in_addr *ip_dst, const char *data, int len)
+{
+ struct sockaddr_in saddr4 = {0};
+ saddr4.sin_family = PF_INET;
+ memcpy(&saddr4.sin_addr, ip_dst, sizeof(struct in_addr));
+
+ int fd = socket(PF_INET, SOCK_RAW, IPPROTO_RAW);
+ if (fd == -1)
+ {
+ LOG_ERROR("Failed at socket(PF_INET, SOCK_RAW), %d: %s", errno, strerror(errno));
+ return -1;
+ }
+
+ if (sendto(fd, data, len, 0, (struct sockaddr *)&saddr4, sizeof(saddr4)) == -1)
+ {
+ char string[256] = {0};
+ inet_ntop(PF_INET, ip_dst, string, sizeof(string));
+ LOG_ERROR("Failed at send() %s, (%d: %s)", string, errno, strerror(errno));
+ close(fd);
+ return -1;
+ }
+
+ close(fd);
+ return 0;
+}
+
+int packet_inject_ipv6(struct in6_addr *ip6_dst, const char *data, int len)
+{
+ struct sockaddr_in6 saddr6 = {0};
+ saddr6.sin6_family = PF_INET6;
+ memcpy(&saddr6.sin6_addr, ip6_dst, sizeof(struct in6_addr));
+
+ int fd = socket(PF_INET6, SOCK_RAW, IPPROTO_RAW);
+ if (fd == -1)
+ {
+ LOG_ERROR("Failed at socket(PF_INET6, SOCK_RAW), %d: %s", errno, strerror(errno));
+ return -1;
+ }
+
+ if (sendto(fd, data, len, 0, (struct sockaddr *)&saddr6, sizeof(saddr6)) == -1)
+ {
+ char string[256] = {0};
+ inet_ntop(PF_INET6, ip6_dst, string, sizeof(string));
+ LOG_ERROR("Failed at send() %s, (%d: %s)", string, errno, strerror(errno));
+ close(fd);
+ return -1;
+ }
+
+ close(fd);
+ return 0;
+}
diff --git a/common/src/packet_io.cpp b/common/src/packet_io.cpp
new file mode 100644
index 0000000..0209514
--- /dev/null
+++ b/common/src/packet_io.cpp
@@ -0,0 +1,280 @@
+#include <sched.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include <netinet/ether.h>
+#include <MESA/MESA_prof_load.h>
+
+#include "log.h"
+#include "packet_io.h"
+
+#define MAX_RX_BURST 128
+
+#define LOG_PKTIO "PACKET_IO"
+#define MIN(a, b) ((a) > (b) ? (b) : (a))
+
+struct config
+{
+ int thread_num;
+ int cpu_mask[MAX_THREAD_NUM];
+
+ int rx_burst_max;
+ int bypass_traffic;
+
+ char app_symbol[256];
+ char app_device[256];
+};
+
+struct packet_io
+{
+ struct config config;
+
+ struct mr_vdev *mr_dev;
+ struct mr_sendpath *mr_path;
+ struct mr_instance *mr_instance;
+
+ void *cb_args;
+ packet_handle_cb *callback;
+};
+
+static int packet_io_config(const char *profile, struct config *config)
+{
+ MESA_load_profile_int_def(profile, "PACKET_IO", "thread_num", (int *)&(config->thread_num), 1);
+ MESA_load_profile_uint_range(profile, "PACKET_IO", "cpu_mask", MAX_THREAD_NUM, (unsigned int *)config->cpu_mask);
+
+ MESA_load_profile_int_def(profile, "PACKET_IO", "rx_burst_max", (int *)&(config->rx_burst_max), 1);
+ MESA_load_profile_int_def(profile, "PACKET_IO", "bypass_traffic", (int *)&(config->bypass_traffic), 0);
+
+ MESA_load_profile_string_nodef(profile, "PACKET_IO", "app_symbol", config->app_symbol, sizeof(config->app_symbol));
+ MESA_load_profile_string_nodef(profile, "PACKET_IO", "app_device", config->app_device, sizeof(config->app_device));
+
+ config->thread_num = MIN(config->thread_num, MAX_THREAD_NUM);
+
+ if (config->rx_burst_max > MAX_RX_BURST)
+ {
+ LOG_ERROR("%s: invalid rx_burst_max, exceeds limit %d", LOG_PKTIO, MAX_RX_BURST);
+ return -1;
+ }
+
+ if (strlen(config->app_symbol) == 0)
+ {
+ LOG_ERROR("%s: invalid app_symbol in %s", LOG_PKTIO, profile);
+ return -1;
+ }
+
+ if (strlen(config->app_device) == 0)
+ {
+ LOG_ERROR("%s: invalid app_device in %s", LOG_PKTIO, profile);
+ return -1;
+ }
+
+ LOG_DEBUG("%s: PACKET_IO->thread_num : %d", LOG_PKTIO, config->thread_num);
+ LOG_DEBUG("%s: PACKET_IO->rx_burst_max : %d", LOG_PKTIO, config->rx_burst_max);
+ LOG_DEBUG("%s: PACKET_IO->bypass_traffic : %d", LOG_PKTIO, config->bypass_traffic);
+ LOG_DEBUG("%s: PACKET_IO->app_symbol : %s", LOG_PKTIO, config->app_symbol);
+ LOG_DEBUG("%s: PACKET_IO->app_device : %s", LOG_PKTIO, config->app_device);
+
+ return 0;
+}
+
+static int marsio_buff_is_keepalive(char *raw_data, int raw_len)
+{
+ if (raw_data == NULL || raw_len < (int)(sizeof(struct ethhdr)))
+ {
+ return 0;
+ }
+
+ struct ethhdr *eth_hdr = (struct ethhdr *)raw_data;
+ if (eth_hdr->h_proto == 0xAAAA)
+ {
+ return 1;
+ }
+ else
+ {
+ return 0;
+ }
+}
+
+struct packet_io *packet_io_create(const char *profile)
+{
+ int opt = 1;
+ cpu_set_t coremask;
+ struct packet_io *handle = (struct packet_io *)calloc(1, sizeof(struct packet_io));
+ assert(handle != NULL);
+
+ if (packet_io_config(profile, &(handle->config)) != 0)
+ {
+ goto error_out;
+ }
+
+ CPU_ZERO(&coremask);
+ for (int i = 0; i < handle->config.thread_num; i++)
+ {
+ CPU_SET(handle->config.cpu_mask[i], &coremask);
+ }
+
+ handle->mr_instance = marsio_create();
+ if (handle->mr_instance == NULL)
+ {
+ LOG_ERROR("%s: unable to create marsio instance", LOG_PKTIO);
+ goto error_out;
+ }
+
+ if (marsio_option_set(handle->mr_instance, MARSIO_OPT_THREAD_MASK_IN_CPUSET, &coremask, sizeof(cpu_set_t)) != 0)
+ {
+ LOG_ERROR("%s: unable to set MARSIO_OPT_EXIT_WHEN_ERR option for marsio instance", LOG_PKTIO);
+ goto error_out;
+ }
+
+ if (marsio_option_set(handle->mr_instance, MARSIO_OPT_EXIT_WHEN_ERR, &opt, sizeof(opt)) != 0)
+ {
+ LOG_ERROR("%s: unable to set MARSIO_OPT_EXIT_WHEN_ERR option for marsio instance", LOG_PKTIO);
+ goto error_out;
+ }
+
+ if (marsio_init(handle->mr_instance, handle->config.app_symbol) != 0)
+ {
+ LOG_ERROR("%s: unable to initialize marsio instance", LOG_PKTIO);
+ goto error_out;
+ }
+
+ handle->mr_dev = marsio_open_device(handle->mr_instance, handle->config.app_device, handle->config.thread_num, handle->config.thread_num);
+ if (handle->mr_dev == NULL)
+ {
+ LOG_ERROR("%s: unable to open device %s", LOG_PKTIO, handle->config.app_device);
+ goto error_out;
+ }
+
+ handle->mr_path = marsio_sendpath_create_by_vdev(handle->mr_dev);
+ if (handle->mr_path == NULL)
+ {
+ LOG_ERROR("%s: unable to create sendpath for device %s", LOG_PKTIO, handle->config.app_device);
+ goto error_out;
+ }
+
+ return handle;
+
+error_out:
+ packet_io_destory(handle);
+ return NULL;
+}
+
+void packet_io_destory(struct packet_io *handle)
+{
+ if (handle)
+ {
+ if (handle->mr_path)
+ {
+ marsio_sendpath_destory(handle->mr_path);
+ handle->mr_path = NULL;
+ }
+
+ if (handle->mr_dev)
+ {
+ marsio_close_device(handle->mr_dev);
+ handle->mr_dev = NULL;
+ }
+
+ if (handle->mr_instance)
+ {
+ marsio_destory(handle->mr_instance);
+ handle->mr_instance = NULL;
+ }
+
+ free(handle);
+ handle = NULL;
+ }
+}
+
+void packet_io_set_callback(struct packet_io *handle, packet_handle_cb *cb, void *args)
+{
+ handle->callback = cb;
+ handle->cb_args = args;
+}
+
+int packet_io_thread_init(struct packet_io *handle, int thread_index)
+{
+ if (marsio_thread_init(handle->mr_instance) != 0)
+ {
+ LOG_ERROR("%s: unable to init marsio thread %d", LOG_PKTIO, thread_index);
+ return -1;
+ }
+
+ return 0;
+}
+
+void packet_io_thread_wait(struct packet_io *handle, int thread_index, int timeout_ms)
+{
+ struct mr_vdev *vdevs[] = {
+ handle->mr_dev,
+ };
+
+ marsio_poll_wait(handle->mr_instance, vdevs, 1, thread_index, timeout_ms);
+}
+
+int packet_io_thread_polling(struct packet_io *handle, int thread_index)
+{
+ int raw_len;
+ char *raw_data;
+ marsio_buff_t *rx_buff;
+ marsio_buff_t *rx_buffs[MAX_RX_BURST];
+ int nr_recv = marsio_recv_burst(handle->mr_dev, thread_index, rx_buffs, handle->config.rx_burst_max);
+ if (nr_recv <= 0)
+ {
+ return 0;
+ }
+
+ if (handle->config.bypass_traffic == 1)
+ {
+ marsio_send_burst(handle->mr_path, thread_index, rx_buffs, nr_recv);
+ return nr_recv;
+ }
+
+ for (int j = 0; j < nr_recv; j++)
+ {
+ rx_buff = rx_buffs[j];
+ raw_len = marsio_buff_datalen(rx_buff);
+ raw_data = marsio_buff_mtod(rx_buff);
+
+ if (marsio_buff_is_keepalive(raw_data, raw_len))
+ {
+ marsio_send_burst(handle->mr_path, thread_index, &rx_buff, 1);
+ }
+ else if (marsio_buff_is_ctrlbuf(rx_buff))
+ {
+ marsio_send_burst(handle->mr_path, thread_index, &rx_buff, 1);
+ }
+ else
+ {
+ if (handle->callback)
+ {
+ if (handle->callback(raw_data, raw_len, handle->cb_args) == ACTION_BYPASS)
+ {
+ marsio_send_burst(handle->mr_path, thread_index, &rx_buff, 1);
+ }
+ else
+ {
+ marsio_buff_free(handle->mr_instance, &rx_buff, 1, 0, thread_index);
+ }
+ }
+ else
+ {
+ marsio_send_burst(handle->mr_path, thread_index, &rx_buff, 1);
+ }
+ }
+ }
+
+ return nr_recv;
+}
+
+int packet_io_thread_number(struct packet_io *handle)
+{
+ if (handle)
+ {
+ return handle->config.thread_num;
+ }
+ else
+ {
+ return 0;
+ }
+} \ No newline at end of file
diff --git a/common/src/packet_parser.cpp b/common/src/packet_parser.cpp
new file mode 100644
index 0000000..6e2e2c3
--- /dev/null
+++ b/common/src/packet_parser.cpp
@@ -0,0 +1,668 @@
+#include <string.h>
+#include <netinet/ip.h>
+#include <netinet/ip6.h>
+#define __FAVOR_BSD 1
+#include <netinet/tcp.h>
+#include <netinet/ether.h>
+
+#include "log.h"
+#include "packet_parser.h"
+
+#define LOG_PKT_PARSER "PACKET_PARSER"
+
+/******************************************************************************
+ * Struct
+ ******************************************************************************/
+
+struct udp_hdr
+{
+ uint16_t uh_sport; /* source port */
+ uint16_t uh_dport; /* destination port */
+ uint16_t uh_ulen; /* udp length */
+ uint16_t uh_sum; /* udp checksum */
+} __attribute__((__packed__));
+
+struct vlan_hdr
+{
+ uint16_t vlan_cfi;
+ uint16_t protocol;
+} __attribute__((__packed__));
+
+struct vxlan_hdr
+{
+ uint8_t flags[2];
+ uint16_t gdp; // group policy id
+ uint8_t vni[3];
+ uint8_t reserved;
+} __attribute__((__packed__));
+
+struct gtp_hdr
+{
+#if __BYTE_ORDER == __LITTLE_ENDIAN
+ unsigned char flags;
+ unsigned char msg_type;
+ unsigned short len;
+ unsigned int teid;
+#elif __BYTE_ORDER == __BIG_ENDIAN
+ unsigned int teid;
+ unsigned short len;
+ unsigned char msg_type;
+ unsigned char flags;
+#else
+#error "Please check <endian.h>"
+#endif
+} __attribute__((__packed__));
+
+#define GTP_HDR_VER_MASK (0xE0)
+#define GTP_HDR_FLAG_N_PDU (0x01)
+#define GTP_HDR_FLAG_SEQ_NUM (0x02)
+#define GTP_HDR_FLAG_NEXT_EXT_HDR (0x04)
+
+/******************************************************************************
+ * Static API
+ ******************************************************************************/
+
+static int packet_parser_push(struct packet_parser *handler, enum layer_type type, uint16_t hdr_offset, uint16_t hdr_len, uint16_t payload_len);
+
+// parser utils
+static const char *layer2str(enum layer_type type);
+static uint16_t parse_gtphdr_len(const struct gtp_hdr *gtph);
+
+// parser protocol
+static const void *parse_ether(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_ipv4(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_ipv6(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_tcp(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_udp(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_pppoe_ses(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_vxlan(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_vlan8021q(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_gtpv1_u(struct packet_parser *handler, const void *data, uint16_t length);
+static const void *parse_mpls(struct packet_parser *handler, const void *data, uint16_t length);
+
+/******************************************************************************
+ * Public API
+ ******************************************************************************/
+
+void packet_parser_init(struct packet_parser *handler)
+{
+ memset(handler, 0, sizeof(struct packet_parser));
+
+ handler->result.used = 0;
+ handler->result.size = sizeof(handler->result.layers) / sizeof(handler->result.layers[0]);
+ handler->packet_data = NULL;
+ handler->packet_len = 0;
+ handler->packet_id = 0;
+}
+
+// return most inner payload
+const void *packet_parser_parse(struct packet_parser *handler, const void *packet_data, uint16_t packet_len, uint64_t packet_id)
+{
+ handler->packet_data = packet_data;
+ handler->packet_len = packet_len;
+ handler->packet_id = packet_id;
+
+ // TESTED OK BY LWP
+ return parse_ether(handler, handler->packet_data, handler->packet_len);
+}
+
+const struct layer_record *packet_parser_get_most_inner(struct packet_parser *handler, enum layer_type type)
+{
+ struct parser_result *result = &handler->result;
+ for (int16_t i = result->used - 1; i >= 0; i--)
+ {
+ const struct layer_record *layer = &result->layers[i];
+ if (layer->type & type)
+ {
+ return layer;
+ }
+ }
+
+ return NULL;
+}
+
+const struct layer_record *packet_parser_get_most_outer(struct packet_parser *handler, enum layer_type type)
+{
+ struct parser_result *result = &handler->result;
+ for (int16_t i = 0; i <= result->used - 1; i++)
+ {
+ const struct layer_record *layer = &result->layers[i];
+ if (layer->type & type)
+ {
+ return layer;
+ }
+ }
+
+ return NULL;
+}
+
+// return 4: IPv4
+// return 6: IPv6
+uint8_t gtp_next_proto(const char *data)
+{
+ uint16_t hdr_len = parse_gtphdr_len((const struct gtp_hdr *)data);
+ if (hdr_len < 0)
+ {
+ return 0;
+ }
+
+ uint8_t next_proto = (((const uint8_t *)(data + hdr_len))[0]) >> 4;
+ return next_proto;
+}
+
+/******************************************************************************
+ * Private API
+ ******************************************************************************/
+
+static int packet_parser_push(struct packet_parser *handler, enum layer_type type, uint16_t hdr_offset, uint16_t hdr_len, uint16_t payload_len)
+{
+ struct parser_result *result = &handler->result;
+ if (result->used >= result->size)
+ {
+ return -1;
+ }
+
+ result->layers[result->used].type = type;
+ result->layers[result->used].hdr_offset = hdr_offset;
+ result->layers[result->used].hdr_len = hdr_len;
+ result->layers[result->used].pld_len = payload_len;
+ result->used++;
+
+ return 0;
+}
+
+static const char *layer2str(enum layer_type type)
+{
+ switch (type)
+ {
+ case LAYER_TYPE_ETHER:
+ return "ETHER";
+ case LAYER_TYPE_PPP:
+ return "PPP";
+ case LAYER_TYPE_HDLC:
+ return "HDLC";
+ case LAYER_TYPE_VLAN:
+ return "VLAN";
+ case LAYER_TYPE_PPPOE:
+ return "PPPOE";
+ case LAYER_TYPE_MPLS:
+ return "MPLS";
+ case LAYER_TYPE_IPV4:
+ return "IPV4";
+ case LAYER_TYPE_IPV6:
+ return "IPV6";
+ case LAYER_TYPE_UDP:
+ return "UDP";
+ case LAYER_TYPE_TCP:
+ return "TCP";
+ case LAYER_TYPE_G_VXLAN:
+ return "G_VXLAN";
+ case LAYER_TYPE_GTPV1_U:
+ return "GTPV1_U";
+ default:
+ return "UNKNOWN";
+ }
+}
+
+// FROM SAPP
+static uint16_t parse_gtphdr_len(const struct gtp_hdr *gtph)
+{
+ const unsigned char *p_ext_hdr = (unsigned char *)gtph + sizeof(struct gtp_hdr);
+ unsigned char next_hdr_type;
+ unsigned char this_ext_field_cont_len;
+
+ // v0 太古老已废弃，目前仅支持 GTPv1 版本
+ if (((gtph->flags & GTP_HDR_VER_MASK) >> 5) != 1)
+ {
+ return -1;
+ }
+
+ if (gtph->flags & (GTP_HDR_FLAG_SEQ_NUM | GTP_HDR_FLAG_N_PDU | GTP_HDR_FLAG_NEXT_EXT_HDR))
+ {
+ // skip seq field (2 bytes)
+ p_ext_hdr += 2;
+
+ // skip N-PDU field (1 byte)
+ p_ext_hdr++;
+
+ // 解析 GTP 扩展头部字段，参考 wireshark 源码 packet-gtp.c->dissect_gtp_common()
+ next_hdr_type = *p_ext_hdr;
+ if (gtph->flags & GTP_HDR_FLAG_NEXT_EXT_HDR)
+ {
+ while (next_hdr_type != 0)
+ {
+ // 指向长度字段, 以4个字节为单位
+ p_ext_hdr++;
+ this_ext_field_cont_len = *p_ext_hdr * 4 - 2;
+
+ // 指向数据部分第一个字节
+ p_ext_hdr++;
+ p_ext_hdr += this_ext_field_cont_len;
+
+ // 指向下一个头部字段
+ next_hdr_type = *p_ext_hdr;
+ p_ext_hdr++;
+ }
+ }
+ else
+ {
+ p_ext_hdr++;
+ }
+ }
+
+ return (char *)p_ext_hdr - (char *)gtph;
+}
+
+static const void *parse_ether(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct ethhdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_ETHER));
+ return data;
+ }
+
+ struct ethhdr *hdr = (struct ethhdr *)data;
+ uint16_t next_proto = ntohs(hdr->h_proto);
+ uint16_t hdr_len = sizeof(struct ethhdr);
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_ETHER, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_ETHER), payload_len, length);
+ switch (next_proto)
+ {
+ case ETH_P_8021Q:
+ // TESTED OK BY LWP
+ return parse_vlan8021q(handler, payload_data, payload_len);
+ case ETH_P_8021AD:
+ return parse_ether(handler, payload_data, payload_len);
+ case ETH_P_IP:
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case ETH_P_IPV6:
+ // TESTED OK BY LWP
+ return parse_ipv6(handler, payload_data, payload_len);
+ case ETH_P_PPP_SES:
+ return parse_pppoe_ses(handler, payload_data, payload_len);
+ case ETH_P_MPLS_UC:
+ // TESTED OK BY LWP
+ return parse_mpls(handler, payload_data, payload_len);
+ default:
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_ETHER), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_ipv4(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct ip))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV4));
+ return data;
+ }
+
+ struct ip *hdr = (struct ip *)data;
+ uint16_t next_proto = hdr->ip_p;
+ uint16_t hdr_len = (hdr->ip_hl & 0xf) * 4u;
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_IPV4, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV4), payload_len, length);
+ switch (next_proto)
+ {
+ case IPPROTO_TCP:
+ // TESTED OK BY LWP
+ return parse_tcp(handler, payload_data, payload_len);
+ case IPPROTO_UDP:
+ // TESTED OK BY LWP
+ return parse_udp(handler, payload_data, payload_len);
+ case IPPROTO_IPIP:
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case IPPROTO_IPV6:
+ // TESTED OK BY LWP
+ return parse_ipv6(handler, payload_data, payload_len);
+ default:
+ // TODO GRE
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV4), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_ipv6(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct ip6_hdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV6));
+ return data;
+ }
+
+ struct ip6_hdr *hdr = (struct ip6_hdr *)data;
+ uint16_t next_proto = hdr->ip6_nxt;
+ uint16_t hdr_len = sizeof(struct ip6_hdr);
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_IPV6, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV6), payload_len, length);
+ switch (next_proto)
+ {
+ case IPPROTO_TCP:
+ // TESTED OK BY LWP
+ return parse_tcp(handler, payload_data, payload_len);
+ case IPPROTO_UDP:
+ // TESTED OK BY LWP
+ return parse_udp(handler, payload_data, payload_len);
+ case IPPROTO_IPIP:
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case IPPROTO_IPV6:
+ // TESTED OK BY LWP
+ return parse_ipv6(handler, payload_data, payload_len);
+ default:
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_IPV6), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_tcp(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct tcphdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_TCP));
+ return data;
+ }
+
+ struct tcphdr *hdr = (struct tcphdr *)data;
+ uint16_t hdr_len = hdr->th_off << 2;
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_TCP, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_TCP), payload_len, length);
+
+ // TESTED OK BY LWP
+ return payload_data;
+}
+
+static const void *parse_udp(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct udp_hdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_UDP));
+ return data;
+ }
+
+ struct udp_hdr *hdr = (struct udp_hdr *)data;
+ uint16_t hdr_len = sizeof(struct udp_hdr);
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_UDP, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_UDP), payload_len, length);
+ switch (ntohs(hdr->uh_dport))
+ {
+ case 4789: // VXLAN_DPORT
+ // TESTED OK BY LWP
+ return parse_vxlan(handler, payload_data, payload_len);
+ case 2152: // GTP1U_PORT
+ // TESTED OK BY LWP
+ return parse_gtpv1_u(handler, payload_data, payload_len);
+ default:
+ // TESTED OK BY LWP
+ return payload_data;
+ }
+}
+
+static const void *parse_pppoe_ses(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < 8)
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_PPPOE));
+ return data;
+ }
+
+ uint16_t next_proto = *((uint16_t *)data + 3);
+ uint16_t hdr_len = 8;
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_PPPOE, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_PPPOE), payload_len, length);
+ switch (next_proto)
+ {
+ case 0x2100: // PPPOE_TYPE_IPV4
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case 0x5700: // PPPOE_TYPE_IPV6
+ return parse_ipv6(handler, payload_data, payload_len);
+ default:
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_PPPOE), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_vxlan(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct vxlan_hdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_G_VXLAN));
+ return NULL;
+ }
+
+ // struct vxlan_hdr *vxlan_hdr = (struct vxlan_hdr *)data;
+ uint16_t hdr_len = sizeof(struct vxlan_hdr);
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_G_VXLAN, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_G_VXLAN), payload_len, length);
+ // TESTED OK BY LWP
+ return parse_ether(handler, payload_data, payload_len);
+}
+
+static const void *parse_vlan8021q(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct vlan_hdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_VLAN));
+ return NULL;
+ }
+
+ struct vlan_hdr *hdr = (struct vlan_hdr *)data;
+ uint16_t next_proto = ntohs(hdr->protocol);
+ uint16_t hdr_len = sizeof(struct vlan_hdr);
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_VLAN, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_VLAN), payload_len, length);
+ switch (next_proto)
+ {
+ case ETH_P_8021Q:
+ // TESTED OK BY LWP
+ return parse_vlan8021q(handler, payload_data, payload_len);
+ case ETH_P_IP:
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case ETH_P_IPV6:
+ // TESTED OK BY LWP
+ return parse_ipv6(handler, payload_data, payload_len);
+ case ETH_P_PPP_SES:
+ // TESTED OK BY LWP
+ return parse_pppoe_ses(handler, payload_data, payload_len);
+ case ETH_P_MPLS_UC:
+ return parse_mpls(handler, payload_data, payload_len);
+ default:
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_VLAN), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_gtpv1_u(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < sizeof(struct gtp_hdr))
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_GTPV1_U));
+ return NULL;
+ }
+
+ uint16_t hdr_len = parse_gtphdr_len((const struct gtp_hdr *)data);
+ if (hdr_len < 0)
+ {
+ return data;
+ }
+
+ uint8_t next_proto = (((const uint8_t *)((const char *)data + hdr_len))[0]) >> 4;
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_GTPV1_U, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_GTPV1_U), payload_len, length);
+ switch (next_proto)
+ {
+ case 4:
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ case 6:
+ // TESTED OK BY LWP
+ return parse_ipv6(handler, payload_data, payload_len);
+ default:
+ LOG_ERROR("%s: trace id: %lu, layer: %s, stop parse next protocol %d", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_GTPV1_U), next_proto);
+ return payload_data;
+ }
+}
+
+static const void *parse_mpls(struct packet_parser *handler, const void *data, uint16_t length)
+{
+ if (length < 4)
+ {
+ LOG_ERROR("%s: trace id: %lu, layer: %s, err: data not enough", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS));
+ return data;
+ }
+
+#define MPLS_LABEL_MASK (0xFFFFF000)
+#define MPLS_EXP_MASK (0x00000E00)
+#define MPLS_BLS_MASK (0x00000100)
+#define MPLS_TTL_MASK (0x000000FF)
+
+ /*
+ * MPLS Format
+ * 0 1 2 3
+ * 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+ * +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+ * | Label | Exp |S| TTL |
+ * +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+ * Label : Label Value 20 bits
+ * Exp : Experimental Use 3 bits
+ * S : Bottom of Stack 1 bit
+ * TTL : Time to Live 8 bits
+ */
+
+ uint32_t *hdr = (uint32_t *)data;
+ // unsigned int mpls_label = (ntohl(*hdr) & MPLS_LABEL_MASK) >> 12;
+ // unsigned int mpls_exp = (ntohl(*hdr) & MPLS_EXP_MASK) >> 9;
+ unsigned int mpls_bls = (ntohl(*hdr) & MPLS_BLS_MASK) >> 8;
+ // unsigned int mpls_ttl = (ntohl(*hdr) & MPLS_TTL_MASK);
+
+ uint16_t hdr_len = 4;
+ uint16_t hdr_offset = (uintptr_t)data - (uintptr_t)(handler->packet_data);
+ uint16_t payload_len = length - hdr_len;
+ const void *payload_data = (const char *)data + hdr_len;
+
+ if (packet_parser_push(handler, LAYER_TYPE_MPLS, hdr_offset, hdr_len, payload_len) != 0)
+ {
+ return data;
+ }
+
+ if (mpls_bls == 1)
+ {
+ uint8_t ip_version = (((uint8_t *)payload_data)[0]) >> 4;
+ if (ip_version == 0)
+ {
+ /*
+ * PW Ethernet Control Word
+ * 0 1 2 3
+ * 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+ * +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+ * |0 0 0 0| Reserved | Sequence Number |
+ * +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
+ * Reference: https://tools.ietf.org/html/rfc4448
+ */
+ payload_data = (const char *)payload_data + 4;
+ payload_len = payload_len - 4;
+
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS), payload_len, length);
+ return parse_ether(handler, payload_data, payload_len);
+ }
+ else if (ip_version == 4)
+ {
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS), payload_len, length);
+ // TESTED OK BY LWP
+ return parse_ipv4(handler, payload_data, payload_len);
+ }
+ else if (ip_version == 6)
+ {
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS), payload_len, length);
+ return parse_ipv6(handler, payload_data, payload_len);
+ }
+ else
+ {
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS), payload_len, length);
+ // TESTED OK BY LWP
+ return parse_ether(handler, payload_data, payload_len);
+ }
+ }
+ else
+ {
+ LOG_DEBUG("%s: trace id: %lu, layer: %s, payload len: [%u/%u]", LOG_PKT_PARSER, handler->packet_id, layer2str(LAYER_TYPE_MPLS), payload_len, length);
+ // TESTED OK BY LWP
+ return parse_mpls(handler, payload_data, payload_len);
+ }
+} \ No newline at end of file
diff --git a/common/test/CMakeLists.txt b/common/test/CMakeLists.txt
new file mode 100644
index 0000000..c89be7b
--- /dev/null
+++ b/common/test/CMakeLists.txt
@@ -0,0 +1,23 @@
+###############################################################################
+# gtest_packet_parser
+###############################################################################
+
+add_executable(gtest_packet_parser gtest_packet_parser.cpp)
+target_include_directories(gtest_packet_parser PUBLIC ${CMAKE_SOURCE_DIR}/common/include)
+target_link_libraries(gtest_packet_parser common gtest)
+
+###############################################################################
+# gtest_packet_inject
+###############################################################################
+
+add_executable(gtest_packet_inject gtest_packet_inject.cpp)
+target_include_directories(gtest_packet_inject PUBLIC ${CMAKE_SOURCE_DIR}/common/include)
+target_link_libraries(gtest_packet_inject common gtest)
+
+###############################################################################
+# gtest_discover_tests
+###############################################################################
+
+include(GoogleTest)
+gtest_discover_tests(gtest_packet_parser)
+gtest_discover_tests(gtest_packet_inject) \ No newline at end of file
diff --git a/common/test/gtest_packet_inject.cpp b/common/test/gtest_packet_inject.cpp
new file mode 100644
index 0000000..aad0349
--- /dev/null
+++ b/common/test/gtest_packet_inject.cpp
@@ -0,0 +1,178 @@
+#include <gtest/gtest.h>
+
+#include "packet_inject.h"
+
+/******************************************************************************
+ * Pcap file: 2-ETH_IP6_IP4_TCP_SSH.pcap
+ * [Protocols in frame: eth:ethertype:ipv6:ip:tcp:ssh]
+ ******************************************************************************
+ *
+ * Frame 1: 726 bytes on wire (5808 bits), 726 bytes captured (5808 bits)
+ * Ethernet II, Src: EvocInte_36:51:3c (00:22:46:36:51:3c), Dst: EvocInte_36:51:38 (00:22:46:36:51:38)
+ * Destination: EvocInte_36:51:38 (00:22:46:36:51:38)
+ * Source: EvocInte_36:51:3c (00:22:46:36:51:3c)
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2001::192:168:40:134, Dst: 2001::192:168:40:133
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 672
+ * Next Header: IPIP (4)
+ * Hop Limit: 64
+ * Source Address: 2001::192:168:40:134
+ * Destination Address: 2001::192:168:40:133
+ * [Source Teredo Server IPv4: 0.0.0.0]
+ * [Source Teredo Port: 65175]
+ * [Source Teredo Client IPv4: 255.191.254.203]
+ * [Destination Teredo Server IPv4: 0.0.0.0]
+ * [Destination Teredo Port: 65175]
+ * [Destination Teredo Client IPv4: 255.191.254.204]
+ * Internet Protocol Version 4, Src: 1.1.1.1, Dst: 2.2.2.2
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 672
+ * Identification: 0x0968 (2408)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 212
+ * Protocol: TCP (6)
+ * Header Checksum: 0xd4ea [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 1.1.1.1
+ * Destination Address: 2.2.2.2
+ * Transmission Control Protocol, Src Port: 57639, Dst Port: 22, Seq: 1, Ack: 1, Len: 632
+ * Source Port: 57639
+ * Destination Port: 22
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (8)]
+ * [TCP Segment Len: 632]
+ * Sequence Number: 1 (relative sequence number)
+ * Sequence Number (raw): 1508621024
+ * [Next Sequence Number: 633 (relative sequence number)]
+ * Acknowledgment Number: 1 (relative ack number)
+ * Acknowledgment number (raw): 2828957019
+ * 0101 .... = Header Length: 20 bytes (5)
+ * Flags: 0x018 (PSH, ACK)
+ * Window: 28584
+ * [Calculated window size: 28584]
+ * [Window size scaling factor: -1 (unknown)]
+ * Checksum: 0xc51f [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * [Timestamps]
+ * [SEQ/ACK analysis]
+ * TCP payload (632 bytes)
+ * SSH Protocol
+ */
+
+unsigned char data2[] = {
+ 0x00, 0x22, 0x46, 0x36, 0x51, 0x38, 0x00, 0x22, 0x46, 0x36, 0x51, 0x3c, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x02, 0xa0, 0x04, 0x40, 0x20, 0x01, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x01, 0x92, 0x01, 0x68, 0x00, 0x40, 0x01, 0x34, 0x20, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x92, 0x01, 0x68, 0x00, 0x40,
+ 0x01, 0x33, 0x45, 0x00, 0x02, 0xa0, 0x09, 0x68, 0x00, 0x00, 0xd4, 0x06, 0xd4, 0xea, 0x01, 0x01, 0x01, 0x01, 0x02, 0x02, 0x02, 0x02, 0xe1, 0x27, 0x00, 0x16,
+ 0x59, 0xeb, 0xba, 0xe0, 0xa8, 0x9e, 0x75, 0x5b, 0x50, 0x18, 0x6f, 0xa8, 0xc5, 0x1f, 0x00, 0x00, 0x4f, 0xe3, 0xa9, 0x48, 0x9b, 0xbe, 0xa8, 0x07, 0x0e, 0xbb,
+ 0x5b, 0xf1, 0x15, 0x1d, 0xc9, 0xbe, 0xdf, 0x78, 0x89, 0xa2, 0x8f, 0x12, 0x5f, 0xad, 0x51, 0xd5, 0xfa, 0xa7, 0x0b, 0xf2, 0x34, 0x00, 0x5b, 0x77, 0xae, 0xab,
+ 0xe4, 0x49, 0xa7, 0xa5, 0xa7, 0x1f, 0xda, 0x90, 0xcc, 0xe1, 0x8e, 0x9f, 0xe9, 0xee, 0x53, 0x59, 0xa4, 0x17, 0xf8, 0x0d, 0x40, 0xe5, 0x75, 0x97, 0xf0, 0x29,
+ 0xfa, 0x7c, 0xb8, 0x12, 0x7e, 0x93, 0xbc, 0x7e, 0x0a, 0x69, 0x8f, 0x1d, 0x7b, 0x1a, 0x2e, 0xf6, 0xa6, 0x78, 0x67, 0x26, 0xfe, 0x8f, 0xcf, 0x5a, 0x02, 0x7d,
+ 0xbb, 0x1b, 0xdb, 0xc7, 0x71, 0xee, 0xe9, 0xd9, 0xc1, 0x48, 0xbf, 0xc7, 0xcc, 0x00, 0x82, 0x7f, 0x69, 0x52, 0xa7, 0xe1, 0x12, 0xec, 0xf1, 0x93, 0xa8, 0x55,
+ 0x5b, 0x33, 0xd3, 0x35, 0x11, 0x5d, 0xf8, 0x3d, 0x5b, 0x94, 0xc9, 0x67, 0xae, 0xba, 0xc0, 0x4a, 0x8b, 0x25, 0x8d, 0xbf, 0xd4, 0xcc, 0x24, 0xb7, 0x3d, 0x0f,
+ 0x1a, 0x57, 0x20, 0x5c, 0x64, 0x62, 0xf7, 0x3c, 0xff, 0xaf, 0x6b, 0xf2, 0xf3, 0xca, 0xd1, 0xcb, 0x7b, 0x9f, 0xc1, 0x31, 0x25, 0x01, 0xd1, 0x18, 0x78, 0x81,
+ 0xf8, 0xae, 0x61, 0x4b, 0x59, 0xa1, 0xbe, 0x4a, 0x94, 0x12, 0xa3, 0x05, 0x4a, 0x26, 0x85, 0xbd, 0x5e, 0x59, 0xb2, 0xc2, 0x24, 0xec, 0xd6, 0x94, 0x6e, 0xc5,
+ 0x7a, 0xdf, 0x21, 0x21, 0xe4, 0x06, 0x67, 0x89, 0xe0, 0x76, 0x85, 0xa9, 0x00, 0x43, 0xfe, 0x72, 0x8c, 0x10, 0xe4, 0x96, 0x63, 0x1a, 0xe8, 0x84, 0xe1, 0x86,
+ 0xa2, 0xa5, 0x67, 0x31, 0x67, 0x44, 0xca, 0xec, 0xe8, 0xa1, 0x3e, 0x5f, 0x4e, 0x71, 0x5d, 0xd4, 0x34, 0xa9, 0x3d, 0xfa, 0x6a, 0xdb, 0xfb, 0x28, 0x2b, 0x70,
+ 0xcc, 0xf1, 0x3c, 0x7c, 0xf5, 0x39, 0xb5, 0xd0, 0xa2, 0x56, 0x22, 0x96, 0x7e, 0xc5, 0x0e, 0x66, 0x2d, 0xcd, 0x5c, 0x33, 0x43, 0x1c, 0xca, 0x17, 0x77, 0x46,
+ 0xb2, 0x41, 0x06, 0x8a, 0x7c, 0x7c, 0x66, 0x06, 0x18, 0x33, 0x21, 0x16, 0x8f, 0x5a, 0xb7, 0xdd, 0x10, 0xa1, 0xab, 0xe9, 0x66, 0xf7, 0x90, 0x22, 0x2c, 0xbe,
+ 0xdd, 0xad, 0xe1, 0x40, 0xe9, 0x21, 0x53, 0x97, 0x07, 0x97, 0x6b, 0xd6, 0x91, 0x11, 0x44, 0x4e, 0x9d, 0x1f, 0x57, 0x07, 0xed, 0xa2, 0xac, 0x77, 0xc0, 0x84,
+ 0xb7, 0xc5, 0x2b, 0xaa, 0x17, 0xd2, 0xdb, 0x2a, 0x15, 0x47, 0x2b, 0x69, 0xf1, 0xb4, 0xb5, 0x8f, 0x98, 0xcf, 0x26, 0x03, 0xf0, 0x4b, 0x1a, 0xba, 0x94, 0xc4,
+ 0x12, 0xe3, 0xd1, 0x38, 0x0c, 0x2e, 0x87, 0x33, 0x0f, 0xe1, 0xa6, 0xba, 0x75, 0xd0, 0xa4, 0x94, 0x80, 0x49, 0x67, 0xa8, 0x90, 0x31, 0x19, 0xaa, 0xf9, 0x78,
+ 0x0d, 0xdd, 0x64, 0xe3, 0xc7, 0x0e, 0x81, 0xa7, 0x6b, 0x44, 0x0c, 0xb5, 0xa0, 0x25, 0x8a, 0xa2, 0xdc, 0x5e, 0xbc, 0xcd, 0xb4, 0x87, 0x1b, 0x6c, 0x08, 0x38,
+ 0x63, 0xa8, 0xc1, 0xde, 0xe2, 0xa1, 0xa4, 0x19, 0x1e, 0x3c, 0x67, 0x3b, 0xf7, 0x7f, 0x67, 0xfb, 0x50, 0x9a, 0x06, 0x5c, 0xdd, 0xf2, 0x26, 0x2c, 0xb9, 0xd2,
+ 0xbd, 0x80, 0xd5, 0xfc, 0xc5, 0x54, 0x6c, 0xc1, 0xea, 0x76, 0x3e, 0xd4, 0xbb, 0x57, 0x65, 0x6a, 0xf8, 0x8e, 0x3e, 0x93, 0xe5, 0x03, 0xfc, 0xce, 0xf1, 0x1c,
+ 0xf3, 0x10, 0xae, 0x87, 0x78, 0x46, 0x02, 0x63, 0xc5, 0xc0, 0x41, 0xbd, 0xae, 0x46, 0x68, 0x0c, 0x92, 0x22, 0xa4, 0xc0, 0xce, 0xf3, 0xc4, 0xf7, 0x83, 0xa9,
+ 0x22, 0x78, 0x74, 0x7f, 0x2e, 0xc1, 0xc6, 0x3b, 0x72, 0x26, 0x4b, 0x45, 0xbd, 0x1b, 0x9f, 0x66, 0x61, 0x46, 0xbb, 0x0f, 0xf3, 0xc5, 0x65, 0x95, 0xbc, 0xae,
+ 0x8f, 0x37, 0xfd, 0xa3, 0x20, 0xb6, 0xe4, 0xa8, 0xff, 0x45, 0xa1, 0x01, 0xa1, 0x76, 0xb3, 0xad, 0x16, 0x07, 0x39, 0x58, 0x3b, 0x34, 0xe9, 0xe6, 0xc0, 0xee,
+ 0x7f, 0x65, 0x6f, 0x68, 0xf4, 0x45, 0xa4, 0x85, 0xa7, 0x50, 0x63, 0xce, 0x0b, 0x0d, 0xbd, 0xd1, 0x20, 0xc8, 0x41, 0x37, 0x05, 0x1f, 0x81, 0xf3, 0x7c, 0xe7,
+ 0x67, 0x15, 0xce, 0xad, 0x76, 0x95, 0x1a, 0x93, 0x4a, 0xab, 0xc4, 0xea, 0x30, 0x44, 0x13, 0x47, 0xec, 0x79, 0xa2, 0x41, 0x0c, 0xdd, 0x42, 0xdf, 0xbf, 0x02,
+ 0xef, 0x9e, 0x67, 0x7e, 0x1e, 0xb0, 0x2a, 0x7f, 0x97, 0xf3, 0x5a, 0xbc, 0x21, 0x8d, 0xf9, 0xc3, 0x30, 0x45, 0xfe, 0x72, 0x74, 0x04, 0x53, 0x99, 0xe7, 0xd1,
+ 0x2b, 0xb6, 0x3a, 0x9c, 0x84, 0x0e, 0x15, 0x5e, 0x75, 0x3b, 0xc9, 0x0e, 0x94, 0xe6, 0x48, 0x0e, 0x37, 0x07, 0xf8, 0xd9, 0x59, 0x4b, 0x04, 0x50};
+
+TEST(PACKET_INJECT, ETH_IP6_IP4_TCP_SSH)
+{
+ struct ip6_hdr *hdr = (struct ip6_hdr *)(data2 + 14);
+ EXPECT_TRUE(packet_inject_ipv6(&hdr->ip6_dst, (const char *)(data2 + 14), sizeof(data2) - 14) == 0);
+}
+
+/******************************************************************************
+ * Pcap file: 4-ETH_IP4_IP6_TCP.pcap
+ * [Protocols in frame: eth:ethertype:ip:ipv6:tcp]
+ ******************************************************************************
+ *
+ * Frame 1: 106 bytes on wire (848 bits), 106 bytes captured (848 bits)
+ * Ethernet II, Src: JuniperN_45:88:29 (2c:6b:f5:45:88:29), Dst: JuniperN_2a:a2:00 (5c:5e:ab:2a:a2:00)
+ * Destination: JuniperN_2a:a2:00 (5c:5e:ab:2a:a2:00)
+ * Source: JuniperN_45:88:29 (2c:6b:f5:45:88:29)
+ * Type: IPv4 (0x0800)
+ * Internet Protocol Version 4, Src: 210.77.88.163, Dst: 59.66.4.50
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 92
+ * Identification: 0x0b4d (2893)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 59
+ * Protocol: IPv6 (41)
+ * Header Checksum: 0x09c8 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 210.77.88.163
+ * Destination Address: 59.66.4.50
+ * Internet Protocol Version 6, Src: 2001:da8:200:900e:200:5efe:d24d:58a3, Dst: 2600:140e:6::1702:1058
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 32
+ * Next Header: TCP (6)
+ * Hop Limit: 64
+ * Source Address: 2001:da8:200:900e:200:5efe:d24d:58a3
+ * Destination Address: 2600:140e:6::1702:1058
+ * [Source ISATAP IPv4: 210.77.88.163]
+ * Transmission Control Protocol, Src Port: 52556, Dst Port: 80, Seq: 0, Len: 0
+ * Source Port: 52556
+ * Destination Port: 80
+ * [Stream index: 0]
+ * [Conversation completeness: Complete, WITH_DATA (31)]
+ * [TCP Segment Len: 0]
+ * Sequence Number: 0 (relative sequence number)
+ * Sequence Number (raw): 2172673142
+ * [Next Sequence Number: 1 (relative sequence number)]
+ * Acknowledgment Number: 0
+ * Acknowledgment number (raw): 0
+ * 1000 .... = Header Length: 32 bytes (8)
+ * Flags: 0x002 (SYN)
+ * Window: 8192
+ * [Calculated window size: 8192]
+ * Checksum: 0xf757 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (12 bytes), Maximum segment size, No-Operation (NOP), Window scale, No-Operation (NOP), No-Operation (NOP), SACK permitted
+ * [Timestamps]
+ */
+
+unsigned char data4[] = {
+ 0x5c, 0x5e, 0xab, 0x2a, 0xa2, 0x00, 0x2c, 0x6b, 0xf5, 0x45, 0x88, 0x29, 0x08, 0x00, 0x45, 0x00, 0x00, 0x5c, 0x0b, 0x4d, 0x00, 0x00, 0x3b, 0x29, 0x09, 0xc8,
+ 0xd2, 0x4d, 0x58, 0xa3, 0x3b, 0x42, 0x04, 0x32, 0x60, 0x00, 0x00, 0x00, 0x00, 0x20, 0x06, 0x40, 0x20, 0x01, 0x0d, 0xa8, 0x02, 0x00, 0x90, 0x0e, 0x02, 0x00,
+ 0x5e, 0xfe, 0xd2, 0x4d, 0x58, 0xa3, 0x26, 0x00, 0x14, 0x0e, 0x00, 0x06, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x17, 0x02, 0x10, 0x58, 0xcd, 0x4c, 0x00, 0x50,
+ 0x81, 0x80, 0x5c, 0x76, 0x00, 0x00, 0x00, 0x00, 0x80, 0x02, 0x20, 0x00, 0xf7, 0x57, 0x00, 0x00, 0x02, 0x04, 0x04, 0xc4, 0x01, 0x03, 0x03, 0x08, 0x01, 0x01,
+ 0x04, 0x02};
+
+TEST(PACKET_INJECT, ETH_IP4_IP6_TCP)
+{
+ struct ip *hdr = (struct ip *)(data4 + 14);
+ EXPECT_TRUE(packet_inject_ipv4(&hdr->ip_dst, (const char *)(data4 + 14), sizeof(data4) - 14) == 0);
+}
+
+int main(int argc, char **argv)
+{
+ ::testing::InitGoogleTest(&argc, argv);
+ return RUN_ALL_TESTS();
+}
diff --git a/common/test/gtest_packet_parser.cpp b/common/test/gtest_packet_parser.cpp
new file mode 100644
index 0000000..99b5a2b
--- /dev/null
+++ b/common/test/gtest_packet_parser.cpp
@@ -0,0 +1,1525 @@
+#include <gtest/gtest.h>
+
+#include "packet_parser.h"
+
+/******************************************************************************
+ * Pcap file: 1-ETH_VLAN_VLAN_IP4_IP4_UDP.pcap
+ * [Protocols in frame: eth:ethertype:vlan:ethertype:vlan:ethertype:ip:ip:udp:data]
+ ******************************************************************************
+ *
+ * Frame 1: 170 bytes on wire (1360 bits), 170 bytes captured (1360 bits)
+ * Ethernet II, Src: HuaweiTe_3b:b3:9a (a4:c6:4f:3b:b3:9a), Dst: 00:00:00_00:00:04 (00:00:00:00:00:04)
+ * Destination: 00:00:00_00:00:04 (00:00:00:00:00:04)
+ * Source: HuaweiTe_3b:b3:9a (a4:c6:4f:3b:b3:9a)
+ * Type: 802.1Q Virtual LAN (0x8100)
+ * 802.1Q Virtual LAN, PRI: 3, DEI: 0, ID: 1624
+ * 011. .... .... .... = Priority: Critical Applications (3)
+ * ...0 .... .... .... = DEI: Ineligible
+ * .... 0110 0101 1000 = ID: 1624
+ * Type: 802.1Q Virtual LAN (0x8100)
+ * 802.1Q Virtual LAN, PRI: 3, DEI: 0, ID: 505
+ * 011. .... .... .... = Priority: Critical Applications (3)
+ * ...0 .... .... .... = DEI: Ineligible
+ * .... 0001 1111 1001 = ID: 505
+ * Type: IPv4 (0x0800)
+ * Internet Protocol Version 4, Src: 69.67.35.146, Dst: 41.202.46.110
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0xb8 (DSCP: EF PHB, ECN: Not-ECT)
+ * Total Length: 148
+ * Identification: 0xe858 (59480)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 255
+ * Protocol: IPIP (4)
+ * Header Checksum: 0x1148 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 69.67.35.146
+ * Destination Address: 41.202.46.110
+ * Internet Protocol Version 4, Src: 10.10.100.25, Dst: 10.10.101.2
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0xb8 (DSCP: EF PHB, ECN: Not-ECT)
+ * Total Length: 128
+ * Identification: 0x0001 (1)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 254
+ * Protocol: UDP (17)
+ * Header Checksum: 0xde84 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 10.10.100.25
+ * Destination Address: 10.10.101.2
+ * User Datagram Protocol, Src Port: 62367, Dst Port: 17000
+ * Source Port: 62367
+ * Destination Port: 17000
+ * Length: 108
+ * Checksum: 0x4b9a [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 0]
+ * [Timestamps]
+ * [Time since first frame: 0.000000000 seconds]
+ * [Time since previous frame: 0.000000000 seconds]
+ * UDP payload (100 bytes)
+ * Data (100 bytes)
+ */
+
+unsigned char data1[] = {
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x04, 0xa4, 0xc6, 0x4f, 0x3b, 0xb3, 0x9a, 0x81, 0x00, 0x66, 0x58, 0x81, 0x00, 0x61, 0xf9, 0x08, 0x00, 0x45, 0xb8, 0x00, 0x94,
+ 0xe8, 0x58, 0x00, 0x00, 0xff, 0x04, 0x11, 0x48, 0x45, 0x43, 0x23, 0x92, 0x29, 0xca, 0x2e, 0x6e, 0x45, 0xb8, 0x00, 0x80, 0x00, 0x01, 0x00, 0x00, 0xfe, 0x11,
+ 0xde, 0x84, 0x0a, 0x0a, 0x64, 0x19, 0x0a, 0x0a, 0x65, 0x02, 0xf3, 0x9f, 0x42, 0x68, 0x00, 0x6c, 0x4b, 0x9a, 0x00, 0x02, 0x00, 0x00, 0x04, 0x73, 0x6c, 0x10,
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd,
+ 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd,
+ 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd,
+ 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd, 0xab, 0xcd};
+
+TEST(PACKET_PARSER, ETH_VLAN_VLAN_IP4_IP4_UDP)
+{
+ uint64_t packet_id = 1;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data1, sizeof(data1), packet_id);
+
+ // LAYER_TYPE_ETHER OK
+ const struct layer_record *outer_eth_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_ETHER);
+ const struct layer_record *inner_eth_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_ETHER);
+
+ EXPECT_TRUE(outer_eth_record != nullptr);
+ EXPECT_TRUE(inner_eth_record != nullptr);
+ EXPECT_TRUE(outer_eth_record == inner_eth_record);
+
+ EXPECT_TRUE(outer_eth_record->hdr_offset == 0);
+ EXPECT_TRUE(outer_eth_record->hdr_len == 14);
+ EXPECT_TRUE(outer_eth_record->pld_len == 156);
+
+ // LAYER_TYPE_L2 OK
+ const struct layer_record *outer_l2_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2);
+ const struct layer_record *inner_l2_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2);
+
+ EXPECT_TRUE(outer_l2_record != nullptr);
+ EXPECT_TRUE(inner_l2_record != nullptr);
+ EXPECT_TRUE(outer_l2_record == inner_l2_record);
+ EXPECT_TRUE(outer_l2_record == outer_eth_record);
+
+ // LAYER_TYPE_VLAN OK
+ const struct layer_record *outer_vlan_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_VLAN);
+ const struct layer_record *inner_vlan_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_VLAN);
+
+ EXPECT_TRUE(outer_vlan_record != nullptr);
+ EXPECT_TRUE(inner_vlan_record != nullptr);
+
+ EXPECT_TRUE(outer_vlan_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_vlan_record->hdr_len == 4);
+ EXPECT_TRUE(outer_vlan_record->pld_len == 152);
+
+ EXPECT_TRUE(inner_vlan_record->hdr_offset == 18);
+ EXPECT_TRUE(inner_vlan_record->hdr_len == 4);
+ EXPECT_TRUE(inner_vlan_record->pld_len == 148);
+
+ // LAYER_TYPE_L2_TUN OK
+ const struct layer_record *outer_l2_tun_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2_TUN);
+ const struct layer_record *inner_l2_tun_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2_TUN);
+
+ EXPECT_TRUE(outer_l2_tun_record != nullptr);
+ EXPECT_TRUE(inner_l2_tun_record != nullptr);
+ EXPECT_TRUE(outer_l2_tun_record == outer_vlan_record);
+ EXPECT_TRUE(inner_l2_tun_record == inner_vlan_record);
+
+ // LAYER_TYPE_IPV4 OK
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 22);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 128);
+
+ EXPECT_TRUE(inner_ipv4_record->hdr_offset == 42);
+ EXPECT_TRUE(inner_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(inner_ipv4_record->pld_len == 108);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv4_record);
+ EXPECT_TRUE(inner_l3_record == inner_ipv4_record);
+
+ // LAYER_TYPE_UDP OK
+ const struct layer_record *outer_udp_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_UDP);
+ const struct layer_record *inner_udp_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_UDP);
+
+ EXPECT_TRUE(outer_udp_record != nullptr);
+ EXPECT_TRUE(inner_udp_record != nullptr);
+ EXPECT_TRUE(outer_udp_record == inner_udp_record);
+
+ EXPECT_TRUE(outer_udp_record->hdr_offset == 62);
+ EXPECT_TRUE(outer_udp_record->hdr_len == 8);
+ EXPECT_TRUE(outer_udp_record->pld_len == 100);
+
+ // LAYER_TYPE_L4 OK
+ const struct layer_record *outer_l4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L4);
+ const struct layer_record *inner_l4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L4);
+
+ EXPECT_TRUE(outer_l4_record != nullptr);
+ EXPECT_TRUE(inner_l4_record != nullptr);
+ EXPECT_TRUE(outer_l4_record == inner_l4_record);
+ EXPECT_TRUE(outer_l4_record == outer_udp_record);
+}
+
+/******************************************************************************
+ * Pcap file: 2-ETH_IP6_IP4_TCP_SSH.pcap
+ * [Protocols in frame: eth:ethertype:ipv6:ip:tcp:ssh]
+ ******************************************************************************
+ *
+ * Frame 1: 726 bytes on wire (5808 bits), 726 bytes captured (5808 bits)
+ * Ethernet II, Src: EvocInte_36:51:3c (00:22:46:36:51:3c), Dst: EvocInte_36:51:38 (00:22:46:36:51:38)
+ * Destination: EvocInte_36:51:38 (00:22:46:36:51:38)
+ * Source: EvocInte_36:51:3c (00:22:46:36:51:3c)
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2001::192:168:40:134, Dst: 2001::192:168:40:133
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 672
+ * Next Header: IPIP (4)
+ * Hop Limit: 64
+ * Source Address: 2001::192:168:40:134
+ * Destination Address: 2001::192:168:40:133
+ * [Source Teredo Server IPv4: 0.0.0.0]
+ * [Source Teredo Port: 65175]
+ * [Source Teredo Client IPv4: 255.191.254.203]
+ * [Destination Teredo Server IPv4: 0.0.0.0]
+ * [Destination Teredo Port: 65175]
+ * [Destination Teredo Client IPv4: 255.191.254.204]
+ * Internet Protocol Version 4, Src: 1.1.1.1, Dst: 2.2.2.2
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 672
+ * Identification: 0x0968 (2408)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 212
+ * Protocol: TCP (6)
+ * Header Checksum: 0xd4ea [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 1.1.1.1
+ * Destination Address: 2.2.2.2
+ * Transmission Control Protocol, Src Port: 57639, Dst Port: 22, Seq: 1, Ack: 1, Len: 632
+ * Source Port: 57639
+ * Destination Port: 22
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (8)]
+ * [TCP Segment Len: 632]
+ * Sequence Number: 1 (relative sequence number)
+ * Sequence Number (raw): 1508621024
+ * [Next Sequence Number: 633 (relative sequence number)]
+ * Acknowledgment Number: 1 (relative ack number)
+ * Acknowledgment number (raw): 2828957019
+ * 0101 .... = Header Length: 20 bytes (5)
+ * Flags: 0x018 (PSH, ACK)
+ * Window: 28584
+ * [Calculated window size: 28584]
+ * [Window size scaling factor: -1 (unknown)]
+ * Checksum: 0xc51f [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * [Timestamps]
+ * [SEQ/ACK analysis]
+ * TCP payload (632 bytes)
+ * SSH Protocol
+ */
+
+unsigned char data2[] = {
+ 0x00, 0x22, 0x46, 0x36, 0x51, 0x38, 0x00, 0x22, 0x46, 0x36, 0x51, 0x3c, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x02, 0xa0, 0x04, 0x40, 0x20, 0x01, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x01, 0x92, 0x01, 0x68, 0x00, 0x40, 0x01, 0x34, 0x20, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x92, 0x01, 0x68, 0x00, 0x40,
+ 0x01, 0x33, 0x45, 0x00, 0x02, 0xa0, 0x09, 0x68, 0x00, 0x00, 0xd4, 0x06, 0xd4, 0xea, 0x01, 0x01, 0x01, 0x01, 0x02, 0x02, 0x02, 0x02, 0xe1, 0x27, 0x00, 0x16,
+ 0x59, 0xeb, 0xba, 0xe0, 0xa8, 0x9e, 0x75, 0x5b, 0x50, 0x18, 0x6f, 0xa8, 0xc5, 0x1f, 0x00, 0x00, 0x4f, 0xe3, 0xa9, 0x48, 0x9b, 0xbe, 0xa8, 0x07, 0x0e, 0xbb,
+ 0x5b, 0xf1, 0x15, 0x1d, 0xc9, 0xbe, 0xdf, 0x78, 0x89, 0xa2, 0x8f, 0x12, 0x5f, 0xad, 0x51, 0xd5, 0xfa, 0xa7, 0x0b, 0xf2, 0x34, 0x00, 0x5b, 0x77, 0xae, 0xab,
+ 0xe4, 0x49, 0xa7, 0xa5, 0xa7, 0x1f, 0xda, 0x90, 0xcc, 0xe1, 0x8e, 0x9f, 0xe9, 0xee, 0x53, 0x59, 0xa4, 0x17, 0xf8, 0x0d, 0x40, 0xe5, 0x75, 0x97, 0xf0, 0x29,
+ 0xfa, 0x7c, 0xb8, 0x12, 0x7e, 0x93, 0xbc, 0x7e, 0x0a, 0x69, 0x8f, 0x1d, 0x7b, 0x1a, 0x2e, 0xf6, 0xa6, 0x78, 0x67, 0x26, 0xfe, 0x8f, 0xcf, 0x5a, 0x02, 0x7d,
+ 0xbb, 0x1b, 0xdb, 0xc7, 0x71, 0xee, 0xe9, 0xd9, 0xc1, 0x48, 0xbf, 0xc7, 0xcc, 0x00, 0x82, 0x7f, 0x69, 0x52, 0xa7, 0xe1, 0x12, 0xec, 0xf1, 0x93, 0xa8, 0x55,
+ 0x5b, 0x33, 0xd3, 0x35, 0x11, 0x5d, 0xf8, 0x3d, 0x5b, 0x94, 0xc9, 0x67, 0xae, 0xba, 0xc0, 0x4a, 0x8b, 0x25, 0x8d, 0xbf, 0xd4, 0xcc, 0x24, 0xb7, 0x3d, 0x0f,
+ 0x1a, 0x57, 0x20, 0x5c, 0x64, 0x62, 0xf7, 0x3c, 0xff, 0xaf, 0x6b, 0xf2, 0xf3, 0xca, 0xd1, 0xcb, 0x7b, 0x9f, 0xc1, 0x31, 0x25, 0x01, 0xd1, 0x18, 0x78, 0x81,
+ 0xf8, 0xae, 0x61, 0x4b, 0x59, 0xa1, 0xbe, 0x4a, 0x94, 0x12, 0xa3, 0x05, 0x4a, 0x26, 0x85, 0xbd, 0x5e, 0x59, 0xb2, 0xc2, 0x24, 0xec, 0xd6, 0x94, 0x6e, 0xc5,
+ 0x7a, 0xdf, 0x21, 0x21, 0xe4, 0x06, 0x67, 0x89, 0xe0, 0x76, 0x85, 0xa9, 0x00, 0x43, 0xfe, 0x72, 0x8c, 0x10, 0xe4, 0x96, 0x63, 0x1a, 0xe8, 0x84, 0xe1, 0x86,
+ 0xa2, 0xa5, 0x67, 0x31, 0x67, 0x44, 0xca, 0xec, 0xe8, 0xa1, 0x3e, 0x5f, 0x4e, 0x71, 0x5d, 0xd4, 0x34, 0xa9, 0x3d, 0xfa, 0x6a, 0xdb, 0xfb, 0x28, 0x2b, 0x70,
+ 0xcc, 0xf1, 0x3c, 0x7c, 0xf5, 0x39, 0xb5, 0xd0, 0xa2, 0x56, 0x22, 0x96, 0x7e, 0xc5, 0x0e, 0x66, 0x2d, 0xcd, 0x5c, 0x33, 0x43, 0x1c, 0xca, 0x17, 0x77, 0x46,
+ 0xb2, 0x41, 0x06, 0x8a, 0x7c, 0x7c, 0x66, 0x06, 0x18, 0x33, 0x21, 0x16, 0x8f, 0x5a, 0xb7, 0xdd, 0x10, 0xa1, 0xab, 0xe9, 0x66, 0xf7, 0x90, 0x22, 0x2c, 0xbe,
+ 0xdd, 0xad, 0xe1, 0x40, 0xe9, 0x21, 0x53, 0x97, 0x07, 0x97, 0x6b, 0xd6, 0x91, 0x11, 0x44, 0x4e, 0x9d, 0x1f, 0x57, 0x07, 0xed, 0xa2, 0xac, 0x77, 0xc0, 0x84,
+ 0xb7, 0xc5, 0x2b, 0xaa, 0x17, 0xd2, 0xdb, 0x2a, 0x15, 0x47, 0x2b, 0x69, 0xf1, 0xb4, 0xb5, 0x8f, 0x98, 0xcf, 0x26, 0x03, 0xf0, 0x4b, 0x1a, 0xba, 0x94, 0xc4,
+ 0x12, 0xe3, 0xd1, 0x38, 0x0c, 0x2e, 0x87, 0x33, 0x0f, 0xe1, 0xa6, 0xba, 0x75, 0xd0, 0xa4, 0x94, 0x80, 0x49, 0x67, 0xa8, 0x90, 0x31, 0x19, 0xaa, 0xf9, 0x78,
+ 0x0d, 0xdd, 0x64, 0xe3, 0xc7, 0x0e, 0x81, 0xa7, 0x6b, 0x44, 0x0c, 0xb5, 0xa0, 0x25, 0x8a, 0xa2, 0xdc, 0x5e, 0xbc, 0xcd, 0xb4, 0x87, 0x1b, 0x6c, 0x08, 0x38,
+ 0x63, 0xa8, 0xc1, 0xde, 0xe2, 0xa1, 0xa4, 0x19, 0x1e, 0x3c, 0x67, 0x3b, 0xf7, 0x7f, 0x67, 0xfb, 0x50, 0x9a, 0x06, 0x5c, 0xdd, 0xf2, 0x26, 0x2c, 0xb9, 0xd2,
+ 0xbd, 0x80, 0xd5, 0xfc, 0xc5, 0x54, 0x6c, 0xc1, 0xea, 0x76, 0x3e, 0xd4, 0xbb, 0x57, 0x65, 0x6a, 0xf8, 0x8e, 0x3e, 0x93, 0xe5, 0x03, 0xfc, 0xce, 0xf1, 0x1c,
+ 0xf3, 0x10, 0xae, 0x87, 0x78, 0x46, 0x02, 0x63, 0xc5, 0xc0, 0x41, 0xbd, 0xae, 0x46, 0x68, 0x0c, 0x92, 0x22, 0xa4, 0xc0, 0xce, 0xf3, 0xc4, 0xf7, 0x83, 0xa9,
+ 0x22, 0x78, 0x74, 0x7f, 0x2e, 0xc1, 0xc6, 0x3b, 0x72, 0x26, 0x4b, 0x45, 0xbd, 0x1b, 0x9f, 0x66, 0x61, 0x46, 0xbb, 0x0f, 0xf3, 0xc5, 0x65, 0x95, 0xbc, 0xae,
+ 0x8f, 0x37, 0xfd, 0xa3, 0x20, 0xb6, 0xe4, 0xa8, 0xff, 0x45, 0xa1, 0x01, 0xa1, 0x76, 0xb3, 0xad, 0x16, 0x07, 0x39, 0x58, 0x3b, 0x34, 0xe9, 0xe6, 0xc0, 0xee,
+ 0x7f, 0x65, 0x6f, 0x68, 0xf4, 0x45, 0xa4, 0x85, 0xa7, 0x50, 0x63, 0xce, 0x0b, 0x0d, 0xbd, 0xd1, 0x20, 0xc8, 0x41, 0x37, 0x05, 0x1f, 0x81, 0xf3, 0x7c, 0xe7,
+ 0x67, 0x15, 0xce, 0xad, 0x76, 0x95, 0x1a, 0x93, 0x4a, 0xab, 0xc4, 0xea, 0x30, 0x44, 0x13, 0x47, 0xec, 0x79, 0xa2, 0x41, 0x0c, 0xdd, 0x42, 0xdf, 0xbf, 0x02,
+ 0xef, 0x9e, 0x67, 0x7e, 0x1e, 0xb0, 0x2a, 0x7f, 0x97, 0xf3, 0x5a, 0xbc, 0x21, 0x8d, 0xf9, 0xc3, 0x30, 0x45, 0xfe, 0x72, 0x74, 0x04, 0x53, 0x99, 0xe7, 0xd1,
+ 0x2b, 0xb6, 0x3a, 0x9c, 0x84, 0x0e, 0x15, 0x5e, 0x75, 0x3b, 0xc9, 0x0e, 0x94, 0xe6, 0x48, 0x0e, 0x37, 0x07, 0xf8, 0xd9, 0x59, 0x4b, 0x04, 0x50};
+
+TEST(PACKET_PARSER, ETH_IP6_IP4_TCP_SSH)
+{
+ uint64_t packet_id = 2;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data2, sizeof(data2), packet_id);
+
+ // LAYER_TYPE_IPV6 OK
+ const struct layer_record *outer_ipv6_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV6);
+ const struct layer_record *inner_ipv6_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV6);
+
+ EXPECT_TRUE(outer_ipv6_record != nullptr);
+ EXPECT_TRUE(inner_ipv6_record != nullptr);
+ EXPECT_TRUE(outer_ipv6_record == inner_ipv6_record);
+
+ EXPECT_TRUE(outer_ipv6_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(outer_ipv6_record->pld_len == 672);
+
+ // LAYER_TYPE_IPV4 OK
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+ EXPECT_TRUE(outer_ipv4_record == inner_ipv4_record);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 54);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 652);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv6_record);
+ EXPECT_TRUE(inner_l3_record == outer_ipv4_record);
+
+ // LAYER_TYPE_TCP OK
+ const struct layer_record *outer_tcp_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_TCP);
+ const struct layer_record *inner_tcp_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_TCP);
+
+ EXPECT_TRUE(outer_tcp_record != nullptr);
+ EXPECT_TRUE(inner_tcp_record != nullptr);
+ EXPECT_TRUE(outer_tcp_record == inner_tcp_record);
+
+ EXPECT_TRUE(outer_tcp_record->hdr_offset == 74);
+ EXPECT_TRUE(outer_tcp_record->hdr_len == 20);
+ EXPECT_TRUE(outer_tcp_record->pld_len == 632);
+
+ // LAYER_TYPE_L4 OK
+ const struct layer_record *outer_l4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L4);
+ const struct layer_record *inner_l4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L4);
+
+ EXPECT_TRUE(outer_l4_record != nullptr);
+ EXPECT_TRUE(inner_l4_record != nullptr);
+ EXPECT_TRUE(outer_l4_record == inner_l4_record);
+ EXPECT_TRUE(outer_l4_record == outer_tcp_record);
+}
+
+/******************************************************************************
+ * Pcap file: 3-ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS.pcap
+ * [Protocols in frame: eth:ethertype:vlan:ethertype:ipv6:ip:gre:ppp:ip:udp:dns]
+ ******************************************************************************
+ *
+ * Frame 1: 272 bytes on wire (2176 bits), 272 bytes captured (2176 bits)
+ * Ethernet II, Src: Cisco_e6:82:c4 (00:19:06:e6:82:c4), Dst: 10:01:00:00:61:3d (10:01:00:00:61:3d)
+ * Destination: 10:01:00:00:61:3d (10:01:00:00:61:3d)
+ * Source: Cisco_e6:82:c4 (00:19:06:e6:82:c4)
+ * Type: 802.1Q Virtual LAN (0x8100)
+ * 802.1Q Virtual LAN, PRI: 0, DEI: 0, ID: 100
+ * 000. .... .... .... = Priority: Best Effort (default) (0)
+ * ...0 .... .... .... = DEI: Ineligible
+ * .... 0000 0110 0100 = ID: 100
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2607:fcd0:100:2300::b108:2a6b, Dst: 2402:f000:1:8e01::5555
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 214
+ * Next Header: IPIP (4)
+ * Hop Limit: 57
+ * Source Address: 2607:fcd0:100:2300::b108:2a6b
+ * Destination Address: 2402:f000:1:8e01::5555
+ * Internet Protocol Version 4, Src: 192.52.166.154, Dst: 16.0.0.200
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 214
+ * Identification: 0x842f (33839)
+ * 010. .... = Flags: 0x2, Don't fragment
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 64
+ * Protocol: Generic Routing Encapsulation (47)
+ * Header Checksum: 0x3e33 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 192.52.166.154
+ * Destination Address: 16.0.0.200
+ * Generic Routing Encapsulation (PPP)
+ * Flags and Version: 0x3081
+ * Protocol Type: PPP (0x880b)
+ * Payload Length: 178
+ * Call ID: 17
+ * Sequence Number: 538640
+ * Acknowledgment Number: 429725
+ * Point-to-Point Protocol
+ * Address: 0xff
+ * Control: 0x03
+ * Protocol: Internet Protocol version 4 (0x0021)
+ * Internet Protocol Version 4, Src: 8.8.8.8, Dst: 172.16.44.3
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 174
+ * Identification: 0x2f9c (12188)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 50
+ * Protocol: UDP (17)
+ * Header Checksum: 0x7080 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 8.8.8.8
+ * Destination Address: 172.16.44.3
+ * User Datagram Protocol, Src Port: 53, Dst Port: 9879
+ * Source Port: 53
+ * Destination Port: 9879
+ * Length: 154
+ * Checksum: 0x45d9 [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 0]
+ * [Timestamps]
+ * UDP payload (146 bytes)
+ * Domain Name System (response)
+ */
+
+unsigned char data3[] = {
+ 0x10, 0x01, 0x00, 0x00, 0x61, 0x3d, 0x00, 0x19, 0x06, 0xe6, 0x82, 0xc4, 0x81, 0x00, 0x00, 0x64, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x00, 0xd6, 0x04, 0x39,
+ 0x26, 0x07, 0xfc, 0xd0, 0x01, 0x00, 0x23, 0x00, 0x00, 0x00, 0x00, 0x00, 0xb1, 0x08, 0x2a, 0x6b, 0x24, 0x02, 0xf0, 0x00, 0x00, 0x01, 0x8e, 0x01, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x55, 0x55, 0x45, 0x00, 0x00, 0xd6, 0x84, 0x2f, 0x40, 0x00, 0x40, 0x2f, 0x3e, 0x33, 0xc0, 0x34, 0xa6, 0x9a, 0x10, 0x00, 0x00, 0xc8,
+ 0x30, 0x81, 0x88, 0x0b, 0x00, 0xb2, 0x00, 0x11, 0x00, 0x08, 0x38, 0x10, 0x00, 0x06, 0x8e, 0x9d, 0xff, 0x03, 0x00, 0x21, 0x45, 0x00, 0x00, 0xae, 0x2f, 0x9c,
+ 0x00, 0x00, 0x32, 0x11, 0x70, 0x80, 0x08, 0x08, 0x08, 0x08, 0xac, 0x10, 0x2c, 0x03, 0x00, 0x35, 0x26, 0x97, 0x00, 0x9a, 0x45, 0xd9, 0xb4, 0xe2, 0x81, 0x83,
+ 0x00, 0x01, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x35, 0x78, 0x71, 0x74, 0x2d, 0x64, 0x65, 0x74, 0x65, 0x63, 0x74, 0x2d, 0x6d, 0x6f, 0x64, 0x65, 0x32, 0x2d,
+ 0x37, 0x38, 0x63, 0x30, 0x36, 0x64, 0x63, 0x37, 0x2d, 0x30, 0x34, 0x61, 0x37, 0x2d, 0x34, 0x38, 0x35, 0x33, 0x2d, 0x38, 0x34, 0x38, 0x33, 0x2d, 0x61, 0x35,
+ 0x36, 0x32, 0x38, 0x39, 0x37, 0x36, 0x65, 0x32, 0x33, 0x33, 0x00, 0x00, 0x01, 0x00, 0x01, 0x00, 0x00, 0x06, 0x00, 0x01, 0x00, 0x00, 0x02, 0xf0, 0x00, 0x40,
+ 0x01, 0x61, 0x0c, 0x72, 0x6f, 0x6f, 0x74, 0x2d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x73, 0x03, 0x6e, 0x65, 0x74, 0x00, 0x05, 0x6e, 0x73, 0x74, 0x6c, 0x64,
+ 0x0c, 0x76, 0x65, 0x72, 0x69, 0x73, 0x69, 0x67, 0x6e, 0x2d, 0x67, 0x72, 0x73, 0x03, 0x63, 0x6f, 0x6d, 0x00, 0x78, 0x0d, 0x09, 0x09, 0x00, 0x00, 0x07, 0x08,
+ 0x00, 0x00, 0x03, 0x84, 0x00, 0x09, 0x3a, 0x80, 0x00, 0x01, 0x51, 0x80};
+
+TEST(PACKET_PARSER, ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS)
+{
+ uint64_t packet_id = 3;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data3, sizeof(data3), packet_id);
+
+ // LAYER_TYPE_IPV6 OK
+ const struct layer_record *outer_ipv6_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV6);
+ const struct layer_record *inner_ipv6_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV6);
+
+ EXPECT_TRUE(outer_ipv6_record != nullptr);
+ EXPECT_TRUE(inner_ipv6_record != nullptr);
+ EXPECT_TRUE(outer_ipv6_record == inner_ipv6_record);
+
+ EXPECT_TRUE(outer_ipv6_record->hdr_offset == 18);
+ EXPECT_TRUE(outer_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(outer_ipv6_record->pld_len == 214);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv6_record);
+
+ // TODO No Support GRE-PPP-IP4
+}
+
+/******************************************************************************
+ * Pcap file: 4-ETH_IP4_IP6_TCP.pcap
+ * [Protocols in frame: eth:ethertype:ip:ipv6:tcp]
+ ******************************************************************************
+ *
+ * Frame 1: 106 bytes on wire (848 bits), 106 bytes captured (848 bits)
+ * Ethernet II, Src: JuniperN_45:88:29 (2c:6b:f5:45:88:29), Dst: JuniperN_2a:a2:00 (5c:5e:ab:2a:a2:00)
+ * Destination: JuniperN_2a:a2:00 (5c:5e:ab:2a:a2:00)
+ * Source: JuniperN_45:88:29 (2c:6b:f5:45:88:29)
+ * Type: IPv4 (0x0800)
+ * Internet Protocol Version 4, Src: 210.77.88.163, Dst: 59.66.4.50
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 92
+ * Identification: 0x0b4d (2893)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 59
+ * Protocol: IPv6 (41)
+ * Header Checksum: 0x09c8 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 210.77.88.163
+ * Destination Address: 59.66.4.50
+ * Internet Protocol Version 6, Src: 2001:da8:200:900e:200:5efe:d24d:58a3, Dst: 2600:140e:6::1702:1058
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 32
+ * Next Header: TCP (6)
+ * Hop Limit: 64
+ * Source Address: 2001:da8:200:900e:200:5efe:d24d:58a3
+ * Destination Address: 2600:140e:6::1702:1058
+ * [Source ISATAP IPv4: 210.77.88.163]
+ * Transmission Control Protocol, Src Port: 52556, Dst Port: 80, Seq: 0, Len: 0
+ * Source Port: 52556
+ * Destination Port: 80
+ * [Stream index: 0]
+ * [Conversation completeness: Complete, WITH_DATA (31)]
+ * [TCP Segment Len: 0]
+ * Sequence Number: 0 (relative sequence number)
+ * Sequence Number (raw): 2172673142
+ * [Next Sequence Number: 1 (relative sequence number)]
+ * Acknowledgment Number: 0
+ * Acknowledgment number (raw): 0
+ * 1000 .... = Header Length: 32 bytes (8)
+ * Flags: 0x002 (SYN)
+ * Window: 8192
+ * [Calculated window size: 8192]
+ * Checksum: 0xf757 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (12 bytes), Maximum segment size, No-Operation (NOP), Window scale, No-Operation (NOP), No-Operation (NOP), SACK permitted
+ * [Timestamps]
+ */
+
+unsigned char data4[] = {
+ 0x5c, 0x5e, 0xab, 0x2a, 0xa2, 0x00, 0x2c, 0x6b, 0xf5, 0x45, 0x88, 0x29, 0x08, 0x00, 0x45, 0x00, 0x00, 0x5c, 0x0b, 0x4d, 0x00, 0x00, 0x3b, 0x29, 0x09, 0xc8,
+ 0xd2, 0x4d, 0x58, 0xa3, 0x3b, 0x42, 0x04, 0x32, 0x60, 0x00, 0x00, 0x00, 0x00, 0x20, 0x06, 0x40, 0x20, 0x01, 0x0d, 0xa8, 0x02, 0x00, 0x90, 0x0e, 0x02, 0x00,
+ 0x5e, 0xfe, 0xd2, 0x4d, 0x58, 0xa3, 0x26, 0x00, 0x14, 0x0e, 0x00, 0x06, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x17, 0x02, 0x10, 0x58, 0xcd, 0x4c, 0x00, 0x50,
+ 0x81, 0x80, 0x5c, 0x76, 0x00, 0x00, 0x00, 0x00, 0x80, 0x02, 0x20, 0x00, 0xf7, 0x57, 0x00, 0x00, 0x02, 0x04, 0x04, 0xc4, 0x01, 0x03, 0x03, 0x08, 0x01, 0x01,
+ 0x04, 0x02};
+
+TEST(PACKET_PARSER, ETH_IP4_IP6_TCP)
+{
+ uint64_t packet_id = 4;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data4, sizeof(data4), packet_id);
+
+ // LAYER_TYPE_IPV4 OK
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+ EXPECT_TRUE(outer_ipv4_record == inner_ipv4_record);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 72);
+
+ // LAYER_TYPE_IPV6 OK
+ const struct layer_record *outer_ipv6_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV6);
+ const struct layer_record *inner_ipv6_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV6);
+
+ EXPECT_TRUE(outer_ipv6_record != nullptr);
+ EXPECT_TRUE(inner_ipv6_record != nullptr);
+ EXPECT_TRUE(outer_ipv6_record == inner_ipv6_record);
+
+ EXPECT_TRUE(outer_ipv6_record->hdr_offset == 34);
+ EXPECT_TRUE(outer_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(outer_ipv6_record->pld_len == 32);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv4_record);
+ EXPECT_TRUE(inner_l3_record == outer_ipv6_record);
+
+ // LAYER_TYPE_TCP OK
+ const struct layer_record *outer_tcp_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_TCP);
+ const struct layer_record *inner_tcp_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_TCP);
+
+ EXPECT_TRUE(outer_tcp_record != nullptr);
+ EXPECT_TRUE(inner_tcp_record != nullptr);
+ EXPECT_TRUE(outer_tcp_record == inner_tcp_record);
+
+ EXPECT_TRUE(outer_tcp_record->hdr_offset == 74);
+ EXPECT_TRUE(outer_tcp_record->hdr_len == 32);
+ EXPECT_TRUE(outer_tcp_record->pld_len == 0);
+
+ // LAYER_TYPE_L4 OK
+ const struct layer_record *outer_l4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L4);
+ const struct layer_record *inner_l4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L4);
+
+ EXPECT_TRUE(outer_l4_record != nullptr);
+ EXPECT_TRUE(inner_l4_record != nullptr);
+ EXPECT_TRUE(outer_l4_record == inner_l4_record);
+ EXPECT_TRUE(outer_l4_record == outer_tcp_record);
+}
+
+/******************************************************************************
+ * Pcap file: 5-ETH_IP6_IP6_UDP.pcap
+ * [Protocols in frame: eth:ethertype:ipv6:ipv6:udp:data]
+ ******************************************************************************
+ *
+ * Frame 1: 106 bytes on wire (848 bits), 106 bytes captured (848 bits)
+ * Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: Broadcast (ff:ff:ff:ff:ff:ff)
+ * Destination: Broadcast (ff:ff:ff:ff:ff:ff)
+ * Source: 00:00:00_00:00:00 (00:00:00:00:00:00)
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2001:4f8:4:7:2e0:81ff:fe52:ffff, Dst: 2001:4f8:4:7:2e0:81ff:fe52:9a6b
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 52
+ * Next Header: IPv6 (41)
+ * Hop Limit: 64
+ * Source Address: 2001:4f8:4:7:2e0:81ff:fe52:ffff
+ * Destination Address: 2001:4f8:4:7:2e0:81ff:fe52:9a6b
+ * [Source SLAAC MAC: TyanComp_52:ff:ff (00:e0:81:52:ff:ff)]
+ * [Destination SLAAC MAC: TyanComp_52:9a:6b (00:e0:81:52:9a:6b)]
+ * Internet Protocol Version 6, Src: dead::beef, Dst: cafe::babe
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 12
+ * Next Header: UDP (17)
+ * Hop Limit: 64
+ * Source Address: dead::beef
+ * Destination Address: cafe::babe
+ * User Datagram Protocol, Src Port: 30000, Dst Port: 13000
+ * Source Port: 30000
+ * Destination Port: 13000
+ * Length: 12
+ * Checksum: 0x83d2 [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 0]
+ * [Timestamps]
+ * UDP payload (4 bytes)
+ * Data (4 bytes)
+ */
+
+unsigned char data5[] = {
+ 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x00, 0x34, 0x29, 0x40, 0x20, 0x01, 0x04, 0xf8,
+ 0x00, 0x04, 0x00, 0x07, 0x02, 0xe0, 0x81, 0xff, 0xfe, 0x52, 0xff, 0xff, 0x20, 0x01, 0x04, 0xf8, 0x00, 0x04, 0x00, 0x07, 0x02, 0xe0, 0x81, 0xff, 0xfe, 0x52,
+ 0x9a, 0x6b, 0x60, 0x00, 0x00, 0x00, 0x00, 0x0c, 0x11, 0x40, 0xde, 0xad, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xbe, 0xef,
+ 0xca, 0xfe, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xba, 0xbe, 0x75, 0x30, 0x32, 0xc8, 0x00, 0x0c, 0x83, 0xd2, 0x58, 0x58,
+ 0x58, 0x58};
+
+TEST(PACKET_PARSER, ETH_IP6_IP6_UDP)
+{
+ uint64_t packet_id = 5;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data5, sizeof(data5), packet_id);
+
+ // LAYER_TYPE_IPV6 OK
+ const struct layer_record *outer_ipv6_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV6);
+ const struct layer_record *inner_ipv6_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV6);
+
+ EXPECT_TRUE(outer_ipv6_record != nullptr);
+ EXPECT_TRUE(inner_ipv6_record != nullptr);
+
+ EXPECT_TRUE(outer_ipv6_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(outer_ipv6_record->pld_len == 52);
+
+ EXPECT_TRUE(inner_ipv6_record->hdr_offset == 54);
+ EXPECT_TRUE(inner_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(inner_ipv6_record->pld_len == 12);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv6_record);
+ EXPECT_TRUE(inner_l3_record == inner_ipv6_record);
+
+ // LAYER_TYPE_UDP OK
+ const struct layer_record *outer_udp_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_UDP);
+ const struct layer_record *inner_udp_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_UDP);
+
+ EXPECT_TRUE(outer_udp_record != nullptr);
+ EXPECT_TRUE(inner_udp_record != nullptr);
+ EXPECT_TRUE(outer_udp_record == inner_udp_record);
+
+ EXPECT_TRUE(outer_udp_record->hdr_offset == 94);
+ EXPECT_TRUE(outer_udp_record->hdr_len == 8);
+ EXPECT_TRUE(outer_udp_record->pld_len == 4);
+
+ // LAYER_TYPE_L4 OK
+ const struct layer_record *outer_l4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L4);
+ const struct layer_record *inner_l4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L4);
+
+ EXPECT_TRUE(outer_l4_record != nullptr);
+ EXPECT_TRUE(inner_l4_record != nullptr);
+ EXPECT_TRUE(outer_l4_record == inner_l4_record);
+ EXPECT_TRUE(outer_l4_record == outer_udp_record);
+}
+
+/******************************************************************************
+ * Pcap file: 6-ETH_MPLS_IP4_TCP.pcap
+ * [Protocols in frame: eth:ethertype:mpls:ip:tcp]
+ ******************************************************************************
+ *
+ * Frame 1: 70 bytes on wire (560 bits), 70 bytes captured (560 bits)
+ * Ethernet II, Src: Hangzhou_d9:28:cc (00:23:89:d9:28:cc), Dst: HuaweiTe_7f:eb:f7 (d4:6a:a8:7f:eb:f7)
+ * Destination: HuaweiTe_7f:eb:f7 (d4:6a:a8:7f:eb:f7)
+ * Source: Hangzhou_d9:28:cc (00:23:89:d9:28:cc)
+ * Type: MPLS label switched packet (0x8847)
+ * MultiProtocol Label Switching Header, Label: 18, Exp: 6, S: 1, TTL: 254
+ * 0000 0000 0000 0001 0010 .... .... .... = MPLS Label: 18 (0x00012)
+ * .... .... .... .... .... 110. .... .... = MPLS Experimental Bits: 6
+ * .... .... .... .... .... ...1 .... .... = MPLS Bottom Of Label Stack: 1
+ * .... .... .... .... .... .... 1111 1110 = MPLS TTL: 254
+ * Internet Protocol Version 4, Src: 119.40.37.65, Dst: 123.125.29.250
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 52
+ * Identification: 0x02a1 (673)
+ * 010. .... = Flags: 0x2, Don't fragment
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 126
+ * Protocol: TCP (6)
+ * Header Checksum: 0xc442 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 119.40.37.65
+ * Destination Address: 123.125.29.250
+ * Transmission Control Protocol, Src Port: 61853, Dst Port: 80, Seq: 0, Len: 0
+ * Source Port: 61853
+ * Destination Port: 80
+ * [Stream index: 0]
+ * [Conversation completeness: Complete, WITH_DATA (31)]
+ * [TCP Segment Len: 0]
+ * Sequence Number: 0 (relative sequence number)
+ * Sequence Number (raw): 1710561749
+ * [Next Sequence Number: 1 (relative sequence number)]
+ * Acknowledgment Number: 0
+ * Acknowledgment number (raw): 0
+ * 1000 .... = Header Length: 32 bytes (8)
+ * Flags: 0x002 (SYN)
+ * Window: 8192
+ * [Calculated window size: 8192]
+ * Checksum: 0xa777 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (12 bytes), Maximum segment size, No-Operation (NOP), Window scale, No-Operation (NOP), No-Operation (NOP), SACK permitted
+ * [Timestamps]
+ */
+
+unsigned char data6[] = {
+ 0xd4, 0x6a, 0xa8, 0x7f, 0xeb, 0xf7, 0x00, 0x23, 0x89, 0xd9, 0x28, 0xcc, 0x88, 0x47, 0x00, 0x01, 0x2d, 0xfe, 0x45, 0x00, 0x00, 0x34, 0x02, 0xa1, 0x40, 0x00,
+ 0x7e, 0x06, 0xc4, 0x42, 0x77, 0x28, 0x25, 0x41, 0x7b, 0x7d, 0x1d, 0xfa, 0xf1, 0x9d, 0x00, 0x50, 0x65, 0xf5, 0x19, 0xd5, 0x00, 0x00, 0x00, 0x00, 0x80, 0x02,
+ 0x20, 0x00, 0xa7, 0x77, 0x00, 0x00, 0x02, 0x04, 0x05, 0xb4, 0x01, 0x03, 0x03, 0x08, 0x01, 0x01, 0x04, 0x02};
+
+TEST(PACKET_PARSER, ETH_MPLS_IP4_TCP)
+{
+ uint64_t packet_id = 6;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data6, sizeof(data6), packet_id);
+
+ // LAYER_TYPE_MPLS OK
+ const struct layer_record *outer_mpls_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_MPLS);
+ const struct layer_record *inner_mpls_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_MPLS);
+
+ EXPECT_TRUE(outer_mpls_record != nullptr);
+ EXPECT_TRUE(inner_mpls_record != nullptr);
+ EXPECT_TRUE(outer_mpls_record == inner_mpls_record);
+
+ EXPECT_TRUE(outer_mpls_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_mpls_record->hdr_len == 4);
+ EXPECT_TRUE(outer_mpls_record->pld_len == 52);
+
+ // LAYER_TYPE_L2_TUN OK
+ const struct layer_record *outer_l2_tun_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2_TUN);
+ const struct layer_record *inner_l2_tun_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2_TUN);
+
+ EXPECT_TRUE(outer_l2_tun_record != nullptr);
+ EXPECT_TRUE(inner_l2_tun_record != nullptr);
+ EXPECT_TRUE(outer_l2_tun_record == inner_l2_tun_record);
+ EXPECT_TRUE(outer_l2_tun_record == outer_mpls_record);
+
+ // LAYER_TYPE_IPV4 OK
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+ EXPECT_TRUE(outer_ipv4_record == inner_ipv4_record);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 18);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 32);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == inner_l3_record);
+ EXPECT_TRUE(outer_l3_record == outer_ipv4_record);
+}
+
+/******************************************************************************
+ * Pcap file: 7-ETH_MPLS_MPLS_IP4_TCP.pcap
+ * [Protocols in frame: eth:ethertype:mpls:ip:tcp]
+ ******************************************************************************
+ *
+ * Frame 1: 66 bytes on wire (528 bits), 66 bytes captured (528 bits)
+ * Ethernet II, Src: Cisco_05:28:38 (00:30:96:05:28:38), Dst: Cisco_e6:fc:39 (00:30:96:e6:fc:39)
+ * Destination: Cisco_e6:fc:39 (00:30:96:e6:fc:39)
+ * Source: Cisco_05:28:38 (00:30:96:05:28:38)
+ * Type: MPLS label switched packet (0x8847)
+ * MultiProtocol Label Switching Header, Label: 18, Exp: 5, S: 0, TTL: 255
+ * 0000 0000 0000 0001 0010 .... .... .... = MPLS Label: 18 (0x00012)
+ * .... .... .... .... .... 101. .... .... = MPLS Experimental Bits: 5
+ * .... .... .... .... .... ...0 .... .... = MPLS Bottom Of Label Stack: 0
+ * .... .... .... .... .... .... 1111 1111 = MPLS TTL: 255
+ * MultiProtocol Label Switching Header, Label: 16, Exp: 5, S: 1, TTL: 255
+ * 0000 0000 0000 0001 0000 .... .... .... = MPLS Label: 16 (0x00010)
+ * .... .... .... .... .... 101. .... .... = MPLS Experimental Bits: 5
+ * .... .... .... .... .... ...1 .... .... = MPLS Bottom Of Label Stack: 1
+ * .... .... .... .... .... .... 1111 1111 = MPLS TTL: 255
+ * Internet Protocol Version 4, Src: 10.31.0.1, Dst: 10.34.0.1
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0xb0 (DSCP: Unknown, ECN: Not-ECT)
+ * Total Length: 44
+ * Identification: 0x0000 (0)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 255
+ * Protocol: TCP (6)
+ * Header Checksum: 0xa6d9 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 10.31.0.1
+ * Destination Address: 10.34.0.1
+ * Transmission Control Protocol, Src Port: 11001, Dst Port: 23, Seq: 0, Len: 0
+ * Source Port: 11001
+ * Destination Port: 23
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (29)]
+ * [TCP Segment Len: 0]
+ * Sequence Number: 0 (relative sequence number)
+ * Sequence Number (raw): 3481568569
+ * [Next Sequence Number: 1 (relative sequence number)]
+ * Acknowledgment Number: 0
+ * Acknowledgment number (raw): 0
+ * 0110 .... = Header Length: 24 bytes (6)
+ * Flags: 0x002 (SYN)
+ * Window: 4128
+ * [Calculated window size: 4128]
+ * Checksum: 0xf791 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (4 bytes), Maximum segment size
+ * [Timestamps]
+ */
+
+unsigned char data7[] = {
+ 0x00, 0x30, 0x96, 0xe6, 0xfc, 0x39, 0x00, 0x30, 0x96, 0x05, 0x28, 0x38, 0x88, 0x47, 0x00, 0x01, 0x2a, 0xff, 0x00, 0x01, 0x0b, 0xff, 0x45, 0xb0, 0x00, 0x2c,
+ 0x00, 0x00, 0x00, 0x00, 0xff, 0x06, 0xa6, 0xd9, 0x0a, 0x1f, 0x00, 0x01, 0x0a, 0x22, 0x00, 0x01, 0x2a, 0xf9, 0x00, 0x17, 0xcf, 0x84, 0x85, 0x39, 0x00, 0x00,
+ 0x00, 0x00, 0x60, 0x02, 0x10, 0x20, 0xf7, 0x91, 0x00, 0x00, 0x02, 0x04, 0x02, 0x18};
+
+TEST(PACKET_PARSER, ETH_MPLS_MPLS_IP4_TCP)
+{
+ uint64_t packet_id = 7;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data7, sizeof(data7), packet_id);
+
+ // LAYER_TYPE_MPLS OK
+ const struct layer_record *outer_mpls_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_MPLS);
+ const struct layer_record *inner_mpls_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_MPLS);
+
+ EXPECT_TRUE(outer_mpls_record != nullptr);
+ EXPECT_TRUE(inner_mpls_record != nullptr);
+
+ EXPECT_TRUE(outer_mpls_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_mpls_record->hdr_len == 4);
+ EXPECT_TRUE(outer_mpls_record->pld_len == 48);
+
+ EXPECT_TRUE(inner_mpls_record->hdr_offset == 18);
+ EXPECT_TRUE(inner_mpls_record->hdr_len == 4);
+ EXPECT_TRUE(inner_mpls_record->pld_len == 44);
+
+ // LAYER_TYPE_L2_TUN OK
+ const struct layer_record *outer_l2_tun_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2_TUN);
+ const struct layer_record *inner_l2_tun_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2_TUN);
+
+ EXPECT_TRUE(outer_l2_tun_record != nullptr);
+ EXPECT_TRUE(inner_l2_tun_record != nullptr);
+ EXPECT_TRUE(outer_l2_tun_record == outer_mpls_record);
+ EXPECT_TRUE(inner_l2_tun_record == inner_mpls_record);
+}
+
+/******************************************************************************
+ * Pcap file: 8-ETH_VLAN_PPPOE_IP4_TCP.pcap
+ * [Protocols in frame: eth:ethertype:vlan:ethertype:pppoes:ppp:ip:tcp]
+ ******************************************************************************
+ *
+ * Frame 55: 78 bytes on wire (624 bits), 78 bytes captured (624 bits)
+ * Ethernet II, Src: 00:00:00_00:04:46 (00:00:00:00:04:46), Dst: 18:10:04:00:02:27 (18:10:04:00:02:27)
+ * Destination: 18:10:04:00:02:27 (18:10:04:00:02:27)
+ * Source: 00:00:00_00:04:46 (00:00:00:00:04:46)
+ * Type: 802.1Q Virtual LAN (0x8100)
+ * 802.1Q Virtual LAN, PRI: 3, DEI: 0, ID: 1476
+ * 011. .... .... .... = Priority: Critical Applications (3)
+ * ...0 .... .... .... = DEI: Ineligible
+ * .... 0101 1100 0100 = ID: 1476
+ * Type: PPPoE Session (0x8864)
+ * PPP-over-Ethernet Session
+ * 0001 .... = Version: 1
+ * .... 0001 = Type: 1
+ * Code: Session Data (0x00)
+ * Session ID: 0xb4bc
+ * Payload Length: 54
+ * Point-to-Point Protocol
+ * Protocol: Internet Protocol version 4 (0x0021)
+ * Internet Protocol Version 4, Src: 100.65.55.0, Dst: 91.185.14.33
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 52
+ * Identification: 0x4ba7 (19367)
+ * 010. .... = Flags: 0x2, Don't fragment
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 63
+ * Protocol: TCP (6)
+ * Header Checksum: 0xeb01 [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 100.65.55.0
+ * Destination Address: 91.185.14.33
+ * Transmission Control Protocol, Src Port: 34532, Dst Port: 443, Seq: 491, Ack: 54523, Len: 0
+ * Source Port: 34532
+ * Destination Port: 443
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (12)]
+ * [TCP Segment Len: 0]
+ * Sequence Number: 491 (relative sequence number)
+ * Sequence Number (raw): 3064322674
+ * [Next Sequence Number: 491 (relative sequence number)]
+ * Acknowledgment Number: 54523 (relative ack number)
+ * Acknowledgment number (raw): 2083649568
+ * 1000 .... = Header Length: 32 bytes (8)
+ * Flags: 0x010 (ACK)
+ * Window: 4032
+ * [Calculated window size: 4032]
+ * [Window size scaling factor: -1 (unknown)]
+ * Checksum: 0xc361 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (12 bytes), No-Operation (NOP), No-Operation (NOP), Timestamps
+ * [Timestamps]
+ * [SEQ/ACK analysis]
+ */
+
+unsigned char data8[] = {
+ 0x18, 0x10, 0x04, 0x00, 0x02, 0x27, 0x00, 0x00, 0x00, 0x00, 0x04, 0x46, 0x81, 0x00, 0x65, 0xc4, 0x88, 0x64, 0x11, 0x00, 0xb4, 0xbc, 0x00, 0x36, 0x00, 0x21,
+ 0x45, 0x00, 0x00, 0x34, 0x4b, 0xa7, 0x40, 0x00, 0x3f, 0x06, 0xeb, 0x01, 0x64, 0x41, 0x37, 0x00, 0x5b, 0xb9, 0x0e, 0x21, 0x86, 0xe4, 0x01, 0xbb, 0xb6, 0xa5,
+ 0xda, 0x72, 0x7c, 0x31, 0xf8, 0x20, 0x80, 0x10, 0x0f, 0xc0, 0xc3, 0x61, 0x00, 0x00, 0x01, 0x01, 0x08, 0x0a, 0x00, 0x6f, 0xab, 0xdf, 0x9c, 0x61, 0xc7, 0xc5};
+
+TEST(PACKET_PARSER, ETH_VLAN_PPPOE_IP4_TCP)
+{
+ uint64_t packet_id = 8;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data8, sizeof(data8), packet_id);
+
+ // LAYER_TYPE_PPPOE OK
+ const struct layer_record *outer_pppoe_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_PPPOE);
+ const struct layer_record *inner_pppoe_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_PPPOE);
+
+ EXPECT_TRUE(outer_pppoe_record != nullptr);
+ EXPECT_TRUE(inner_pppoe_record != nullptr);
+ EXPECT_TRUE(outer_pppoe_record == inner_pppoe_record);
+
+ EXPECT_TRUE(outer_pppoe_record->hdr_offset == 18);
+ EXPECT_TRUE(outer_pppoe_record->hdr_len == 6 + 2);
+ EXPECT_TRUE(outer_pppoe_record->pld_len == 52);
+
+ // LAYER_TYPE_L2_TUN OK
+ const struct layer_record *outer_l2_tun_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2_TUN);
+ const struct layer_record *inner_l2_tun_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2_TUN);
+
+ EXPECT_TRUE(outer_l2_tun_record != nullptr);
+ EXPECT_TRUE(inner_l2_tun_record != nullptr);
+ EXPECT_TRUE(outer_l2_tun_record != inner_l2_tun_record);
+ EXPECT_TRUE(inner_l2_tun_record == outer_pppoe_record);
+
+ // LAYER_TYPE_IPV4 OK
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+ EXPECT_TRUE(outer_ipv4_record == inner_ipv4_record);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 26);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 32);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == inner_l3_record);
+ EXPECT_TRUE(outer_l3_record == outer_ipv4_record);
+}
+
+/******************************************************************************
+ * Pcap file: 9-ETH_IP6_UDP_GTP_IP6_TCP_TLS.pcap
+ * [Protocols in frame: eth:ethertype:ipv6:udp:gtp:ipv6:tcp:ja3:tls]
+ ******************************************************************************
+ *
+ * Frame 1: 1442 bytes on wire (11536 bits), 1442 bytes captured (11536 bits)
+ * Ethernet II, Src: zte_0e:f5:40 (74:4a:a4:0e:f5:40), Dst: HuaweiTe_40:e9:c2 (ac:b3:b5:40:e9:c2)
+ * Destination: HuaweiTe_40:e9:c2 (ac:b3:b5:40:e9:c2)
+ * Source: zte_0e:f5:40 (74:4a:a4:0e:f5:40)
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2409:8034:4040:5300::105, Dst: 2409:8034:4025::60:61
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 1388
+ * Next Header: UDP (17)
+ * Hop Limit: 127
+ * Source Address: 2409:8034:4040:5300::105
+ * Destination Address: 2409:8034:4025::60:61
+ * User Datagram Protocol, Src Port: 2152, Dst Port: 2152
+ * Source Port: 2152
+ * Destination Port: 2152
+ * Length: 1388
+ * Checksum: 0xeb00 [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 0]
+ * [Timestamps]
+ * UDP payload (1380 bytes)
+ * GPRS Tunneling Protocol
+ * Flags: 0x30
+ * Message Type: T-PDU (0xff)
+ * Length: 1372
+ * TEID: 0x024c3cbd (38550717)
+ * Internet Protocol Version 6, Src: 2409:8c34:4400:700:0:4:0:3, Dst: 2409:8934:5082:2100:ecad:e0e4:530a:c269
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 1332
+ * Next Header: TCP (6)
+ * Hop Limit: 56
+ * Source Address: 2409:8c34:4400:700:0:4:0:3
+ * Destination Address: 2409:8934:5082:2100:ecad:e0e4:530a:c269
+ * Transmission Control Protocol, Src Port: 443, Dst Port: 46582, Seq: 1, Ack: 1, Len: 1312
+ * Source Port: 443
+ * Destination Port: 46582
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (8)]
+ * [TCP Segment Len: 1312]
+ * Sequence Number: 1 (relative sequence number)
+ * Sequence Number (raw): 2198097831
+ * [Next Sequence Number: 1313 (relative sequence number)]
+ * Acknowledgment Number: 1 (relative ack number)
+ * Acknowledgment number (raw): 2264498872
+ * 0101 .... = Header Length: 20 bytes (5)
+ * Flags: 0x010 (ACK)
+ * Window: 529
+ * [Calculated window size: 529]
+ * [Window size scaling factor: -1 (unknown)]
+ * Checksum: 0x2c4b [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * [Timestamps]
+ * [SEQ/ACK analysis]
+ * TCP payload (1312 bytes)
+ * Transport Layer Security
+ */
+
+unsigned char data9[] = {
+ 0xac, 0xb3, 0xb5, 0x40, 0xe9, 0xc2, 0x74, 0x4a, 0xa4, 0x0e, 0xf5, 0x40, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x05, 0x6c, 0x11, 0x7f, 0x24, 0x09, 0x80, 0x34,
+ 0x40, 0x40, 0x53, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x05, 0x24, 0x09, 0x80, 0x34, 0x40, 0x25, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x60,
+ 0x00, 0x61, 0x08, 0x68, 0x08, 0x68, 0x05, 0x6c, 0xeb, 0x00, 0x30, 0xff, 0x05, 0x5c, 0x02, 0x4c, 0x3c, 0xbd, 0x60, 0x00, 0x00, 0x00, 0x05, 0x34, 0x06, 0x38,
+ 0x24, 0x09, 0x8c, 0x34, 0x44, 0x00, 0x07, 0x00, 0x00, 0x00, 0x00, 0x04, 0x00, 0x00, 0x00, 0x03, 0x24, 0x09, 0x89, 0x34, 0x50, 0x82, 0x21, 0x00, 0xec, 0xad,
+ 0xe0, 0xe4, 0x53, 0x0a, 0xc2, 0x69, 0x01, 0xbb, 0xb5, 0xf6, 0x83, 0x04, 0x4f, 0xa7, 0x86, 0xf9, 0x82, 0xb8, 0x50, 0x10, 0x02, 0x11, 0x2c, 0x4b, 0x00, 0x00,
+ 0x17, 0x03, 0x03, 0x3c, 0x8c, 0x87, 0xa0, 0x99, 0x23, 0x5b, 0x53, 0x4a, 0x12, 0x1b, 0xf8, 0xba, 0xe8, 0x83, 0xc2, 0x95, 0xda, 0xb8, 0xea, 0x5b, 0xdc, 0x84,
+ 0x61, 0xa9, 0x86, 0x7e, 0x43, 0xc7, 0x31, 0x44, 0x6e, 0x11, 0xc1, 0x30, 0x21, 0x03, 0xb4, 0x21, 0x4a, 0xee, 0xc9, 0x2e, 0x14, 0xd2, 0x98, 0x63, 0x12, 0xfe,
+ 0x79, 0x58, 0xb3, 0x18, 0xa6, 0x8d, 0x0c, 0x62, 0x67, 0x51, 0xef, 0x02, 0x5a, 0xa8, 0xb3, 0x82, 0x1f, 0xe4, 0x51, 0xba, 0xde, 0xee, 0x83, 0x9c, 0x4e, 0xac,
+ 0x4d, 0xa2, 0xb7, 0x6a, 0x82, 0xe7, 0xbb, 0x00, 0xf7, 0x5a, 0xe7, 0x02, 0x71, 0x7e, 0x7d, 0x6f, 0xf2, 0xe5, 0x47, 0xd0, 0xba, 0x3c, 0x51, 0x09, 0x95, 0xcd,
+ 0xf6, 0xc9, 0x8b, 0x6f, 0xb0, 0x39, 0x11, 0x0d, 0xe9, 0x0d, 0x4d, 0x29, 0xd4, 0xcb, 0x87, 0xba, 0x11, 0xfa, 0x0d, 0x0b, 0x82, 0x95, 0xa5, 0x84, 0x94, 0x48,
+ 0xa2, 0xee, 0xa4, 0xb7, 0xb6, 0x76, 0x13, 0x4d, 0x18, 0x42, 0x91, 0x77, 0xad, 0x82, 0x38, 0xee, 0x34, 0x1c, 0xb7, 0xf6, 0x39, 0xdc, 0xa4, 0x23, 0xa1, 0x7c,
+ 0xa5, 0x0b, 0x7e, 0x4c, 0x8b, 0x81, 0x31, 0x48, 0xea, 0xf4, 0x18, 0x37, 0x09, 0x0a, 0x53, 0x13, 0x05, 0x90, 0x26, 0x10, 0x69, 0xb2, 0xa3, 0x36, 0xbc, 0xa5,
+ 0x83, 0xd8, 0x16, 0x77, 0x98, 0xc8, 0x21, 0x38, 0xd9, 0x88, 0x0c, 0xa7, 0x16, 0x97, 0x4e, 0x20, 0x6d, 0x68, 0xda, 0x1b, 0x3b, 0x4a, 0x62, 0xe0, 0x36, 0x0d,
+ 0xbf, 0x30, 0x71, 0xb1, 0xe9, 0xbe, 0x47, 0x77, 0x99, 0xb9, 0xe6, 0x26, 0xab, 0x81, 0x2e, 0x46, 0xf1, 0x1b, 0x1e, 0xfb, 0xd7, 0x81, 0x60, 0x21, 0x4a, 0x71,
+ 0x85, 0xf7, 0x9c, 0x9c, 0xd4, 0x1c, 0x52, 0xc4, 0x3d, 0x8d, 0x72, 0xf6, 0x7c, 0xd3, 0x58, 0x79, 0x0d, 0x78, 0xd7, 0x7c, 0x29, 0x2b, 0xc3, 0x96, 0x1d, 0xc7,
+ 0x96, 0x50, 0x42, 0xd7, 0xda, 0xeb, 0x29, 0x8e, 0x2a, 0x72, 0x23, 0x57, 0x0f, 0x6f, 0x37, 0x35, 0xb2, 0x42, 0x76, 0x78, 0xbf, 0xbf, 0x8c, 0x3f, 0x31, 0xa2,
+ 0x51, 0xec, 0x9e, 0x0d, 0xfd, 0xf2, 0xaf, 0x71, 0xa0, 0x4f, 0xa9, 0xf6, 0x19, 0xcf, 0x3e, 0x4b, 0xc8, 0xaa, 0x38, 0x06, 0xa1, 0x15, 0xde, 0xde, 0xef, 0x9b,
+ 0x25, 0xa3, 0xcc, 0x47, 0xca, 0x29, 0x30, 0x65, 0x5f, 0xc1, 0x8b, 0x12, 0x63, 0x79, 0xcd, 0x57, 0x4d, 0x99, 0xc0, 0xcd, 0xbe, 0x62, 0xcb, 0xc3, 0xf2, 0x6b,
+ 0x0b, 0x40, 0xc5, 0xee, 0x79, 0x0a, 0xa4, 0x75, 0x56, 0xe7, 0xe7, 0xf2, 0xfd, 0xe0, 0x72, 0x78, 0x04, 0xa2, 0x50, 0x31, 0x09, 0x8b, 0x57, 0xc3, 0x85, 0x4e,
+ 0xc4, 0xae, 0xde, 0x8a, 0xfa, 0xf6, 0x31, 0x06, 0xd2, 0x07, 0x25, 0x40, 0xce, 0x0d, 0xfd, 0x26, 0x98, 0x41, 0xa3, 0xa9, 0xa2, 0x8d, 0x8b, 0x7f, 0x6d, 0x63,
+ 0x87, 0x7e, 0x75, 0x2f, 0x78, 0xc9, 0xd5, 0x04, 0xb2, 0x4f, 0xc9, 0x94, 0xa7, 0x7f, 0xbc, 0x75, 0x7b, 0xb6, 0xfb, 0x2c, 0x46, 0xf6, 0xde, 0x36, 0x31, 0x2a,
+ 0x32, 0x1d, 0x7f, 0x30, 0x9e, 0x4a, 0x84, 0x69, 0x66, 0xac, 0xef, 0xbe, 0xb3, 0x83, 0x8c, 0xb8, 0x30, 0xd2, 0x3f, 0xcf, 0xb5, 0xbb, 0x65, 0xaa, 0xe7, 0x6b,
+ 0x74, 0x48, 0x2c, 0xb2, 0x72, 0x2b, 0x78, 0xaf, 0xd0, 0x71, 0x04, 0xa9, 0xb4, 0x65, 0xd9, 0xfc, 0x74, 0x23, 0xff, 0x89, 0xc1, 0x16, 0x23, 0xac, 0x59, 0x16,
+ 0x89, 0x41, 0xc3, 0xdb, 0xdb, 0x5b, 0x9a, 0x3d, 0x08, 0xc4, 0x12, 0x28, 0xf8, 0x10, 0xa5, 0xad, 0xc6, 0x81, 0xc0, 0x61, 0x48, 0xba, 0x9d, 0xef, 0xc7, 0xf8,
+ 0xad, 0x9a, 0xbd, 0x87, 0xfa, 0x7f, 0xa2, 0x4e, 0x4d, 0xe0, 0x19, 0xd5, 0x47, 0xc7, 0xd0, 0xfb, 0x00, 0x7b, 0xbf, 0x17, 0x80, 0xfe, 0xf5, 0x27, 0xec, 0x94,
+ 0x44, 0x3d, 0x4a, 0x34, 0x49, 0x60, 0xb4, 0x8d, 0x71, 0x6d, 0x9c, 0xf4, 0x4c, 0x33, 0xa9, 0x49, 0x58, 0x58, 0x6f, 0xe1, 0xd1, 0x7d, 0x36, 0x51, 0xf4, 0xd8,
+ 0x0d, 0x0b, 0xfc, 0xeb, 0xae, 0x58, 0x06, 0x08, 0xbf, 0x67, 0x07, 0x28, 0x7e, 0x68, 0x65, 0x79, 0x86, 0xfb, 0x43, 0x0f, 0x0a, 0xef, 0xd0, 0x97, 0x33, 0x10,
+ 0x7a, 0x20, 0xe8, 0x22, 0xe5, 0xdc, 0x0c, 0xa2, 0xa5, 0x50, 0x1b, 0x08, 0x15, 0xc2, 0xec, 0xd2, 0x06, 0x25, 0xd0, 0x3b, 0xfd, 0xe3, 0xa2, 0x6f, 0x41, 0x15,
+ 0x6d, 0x9f, 0x5f, 0xc4, 0x07, 0x5c, 0x99, 0x63, 0xd9, 0xd7, 0xdc, 0x90, 0xc9, 0x8f, 0x3a, 0x4b, 0x6a, 0x84, 0xe8, 0x3c, 0xc7, 0x71, 0x50, 0x71, 0x86, 0x71,
+ 0x7d, 0x54, 0x84, 0x7b, 0xb7, 0xca, 0xd5, 0x42, 0xaf, 0x88, 0xa5, 0xae, 0xa4, 0x9c, 0xfd, 0x71, 0x71, 0x0f, 0x67, 0xaa, 0x1b, 0x61, 0xd7, 0xf4, 0x50, 0x21,
+ 0x9d, 0x80, 0x6e, 0x54, 0xcd, 0xb6, 0xb9, 0x02, 0x3e, 0x59, 0x50, 0xff, 0xf2, 0xda, 0x21, 0x5c, 0x50, 0x6d, 0x64, 0x8c, 0x33, 0x75, 0x2a, 0xa4, 0x56, 0xb3,
+ 0xa8, 0xdb, 0xba, 0xbe, 0x52, 0xd4, 0xe5, 0x29, 0x68, 0xe2, 0x6b, 0x94, 0x6b, 0xb3, 0x90, 0x63, 0x91, 0x1a, 0x95, 0xb5, 0xd7, 0x10, 0x1b, 0xd9, 0x93, 0x4f,
+ 0x33, 0xb6, 0x6a, 0x4e, 0xcd, 0x40, 0x9d, 0x47, 0x76, 0x3e, 0x4b, 0xc7, 0x2f, 0x16, 0x96, 0x64, 0x9d, 0x4e, 0x8c, 0xfb, 0x0f, 0xd2, 0xec, 0x6c, 0xba, 0xf2,
+ 0x9c, 0xca, 0xd2, 0x3e, 0x64, 0x37, 0x32, 0x20, 0xd7, 0x4c, 0xb0, 0xe7, 0xd3, 0x75, 0x51, 0x3a, 0x94, 0xc1, 0xdf, 0x1c, 0xb3, 0x10, 0xd5, 0x1e, 0xcf, 0x7c,
+ 0xb7, 0xab, 0x4a, 0x93, 0xf0, 0x78, 0x58, 0x28, 0x63, 0x10, 0xee, 0xb0, 0xd6, 0x14, 0x81, 0x47, 0xeb, 0x2e, 0xc8, 0x6e, 0x33, 0x7e, 0xf3, 0x2d, 0xc8, 0xdb,
+ 0x29, 0x0c, 0x80, 0xe4, 0x2f, 0x10, 0x07, 0x8e, 0x08, 0x86, 0x97, 0x1b, 0x39, 0x98, 0x39, 0x06, 0xb3, 0x85, 0x53, 0xb7, 0xbb, 0x65, 0x65, 0x85, 0x0e, 0x0a,
+ 0x7d, 0x29, 0x3d, 0x3f, 0x52, 0xc2, 0x7b, 0x2b, 0x30, 0x94, 0x99, 0x6a, 0x4b, 0xad, 0xe9, 0xec, 0xcb, 0xcd, 0xae, 0x97, 0x45, 0x54, 0xd5, 0x00, 0x5e, 0xd8,
+ 0xac, 0xeb, 0x99, 0xdc, 0x58, 0x0b, 0x01, 0xeb, 0x32, 0x22, 0xc4, 0xec, 0x4f, 0xd2, 0x15, 0x03, 0x30, 0x88, 0xc7, 0x28, 0xaf, 0x78, 0xf5, 0x38, 0x84, 0x3b,
+ 0x3b, 0xe9, 0x29, 0x71, 0x50, 0xa3, 0x07, 0x49, 0x3b, 0xc6, 0x97, 0xc6, 0xf9, 0x53, 0x95, 0x51, 0x65, 0x7e, 0xd7, 0xd4, 0xe8, 0x76, 0x6a, 0x6d, 0x37, 0x6b,
+ 0xa5, 0x59, 0xaa, 0x14, 0x18, 0x8c, 0x8d, 0x65, 0x78, 0x67, 0xfb, 0x60, 0x56, 0xab, 0x04, 0xa0, 0xc2, 0x93, 0x46, 0xf1, 0x2b, 0x0d, 0x3b, 0x38, 0x62, 0x62,
+ 0x5e, 0xc8, 0x30, 0xf9, 0x45, 0x28, 0x6f, 0xa1, 0xb1, 0x88, 0xf1, 0x2b, 0x3b, 0xf8, 0xae, 0x91, 0x52, 0xc3, 0x72, 0x86, 0xe4, 0xec, 0xc3, 0x54, 0x86, 0xbf,
+ 0x8f, 0x33, 0xb1, 0x0f, 0x42, 0xc5, 0x9c, 0xb8, 0xc2, 0x67, 0x8b, 0xac, 0x78, 0xd7, 0x63, 0xab, 0x05, 0xc6, 0x6c, 0x37, 0xa1, 0x28, 0xef, 0x95, 0xc9, 0xf5,
+ 0x12, 0x38, 0x54, 0x34, 0x2e, 0x03, 0x6a, 0xaa, 0xa9, 0x97, 0x72, 0x22, 0x9f, 0x20, 0xec, 0x9e, 0x29, 0x09, 0xd8, 0x38, 0xd1, 0x86, 0x82, 0x99, 0xbd, 0x2a,
+ 0x03, 0xe9, 0x3d, 0xbd, 0xea, 0xc5, 0x8b, 0xb0, 0x4c, 0x8b, 0x7e, 0x78, 0x08, 0xef, 0x39, 0xa8, 0xb4, 0x47, 0xce, 0x44, 0xc3, 0x3f, 0x52, 0xe4, 0xbd, 0x9e,
+ 0xf6, 0xed, 0x6f, 0x6c, 0x05, 0x19, 0xa6, 0x0a, 0x1e, 0x48, 0xe3, 0x9b, 0x91, 0x61, 0xef, 0xf5, 0x91, 0x39, 0x70, 0x44, 0x1c, 0x08, 0x2e, 0x2c, 0x6c, 0x27,
+ 0xb9, 0x0e, 0xcc, 0x74, 0x69, 0xa5, 0xf8, 0x19, 0xd6, 0xbf, 0x57, 0x6c, 0x9a, 0x91, 0x74, 0xfd, 0xc2, 0x31, 0x32, 0x12, 0x06, 0xa3, 0x69, 0x71, 0xda, 0x40,
+ 0xa1, 0xf3, 0xb5, 0x9a, 0x43, 0xcc, 0xb4, 0x3c, 0x16, 0x40, 0x65, 0x2b, 0x02, 0xac, 0x5c, 0xae, 0xd6, 0x34, 0x34, 0xe3, 0x69, 0x76, 0x2c, 0xa8, 0xdd, 0x04,
+ 0x92, 0xa6, 0x7a, 0xc0, 0x87, 0x70, 0x8b, 0x85, 0xba, 0x5d, 0xbb, 0x62, 0x70, 0xcc, 0x1f, 0x21, 0x2c, 0x7e, 0xc3, 0x77, 0xcf, 0x23, 0x22, 0xf4, 0x16, 0x8e,
+ 0xf1, 0x3d, 0xdc, 0x33, 0x99, 0x5e, 0xaa, 0xa2, 0x50, 0x68, 0xde, 0x03, 0x44, 0xbb, 0xc7, 0x16, 0x2a, 0xf2, 0x08, 0xeb, 0x3d, 0x12, 0x6d, 0xcb, 0x2a, 0xaf,
+ 0xb4, 0x79, 0xdb, 0x74, 0x5e, 0x54, 0x89, 0x73, 0x0c, 0x48, 0x9c, 0x03, 0x33, 0xd2, 0x92, 0x22, 0xdb, 0x3a, 0xa0, 0x8c, 0xe2, 0x30, 0x6f, 0x39, 0xe4, 0xa9,
+ 0x24, 0x04, 0xbb, 0x85, 0x7d, 0x62, 0xc5, 0xa9, 0x98, 0x92, 0xef, 0xc6, 0xc8, 0xd1, 0x81, 0xad, 0x95, 0x40, 0x27, 0x09, 0xc7, 0x43, 0xcd, 0xb6, 0x94, 0xfc,
+ 0x1c, 0x7d, 0x1c, 0xd3, 0x47, 0xfe, 0x62, 0x9c, 0xfa, 0xeb, 0xfc, 0x02, 0x2e, 0x48, 0x62, 0xcf, 0x63, 0xdb, 0x63, 0xd9, 0x21, 0x86, 0xe8, 0x96, 0x54, 0xeb,
+ 0x6a, 0xa8, 0x78, 0x3c, 0x5b, 0xb6, 0xde, 0xa9, 0x04, 0x48, 0x63, 0xb2, 0x10, 0x02, 0x6a, 0x7f, 0x6d, 0xc8, 0x04, 0xdd, 0x99, 0x25, 0x08, 0xff, 0x80, 0x11,
+ 0x53, 0xfb, 0x7a, 0x07, 0x39, 0xd9, 0x97, 0xca, 0xf0, 0xa7, 0x46, 0x9c, 0xc2, 0xae, 0x2e, 0x05, 0x62, 0xa0, 0xd5, 0x5d, 0x17, 0x0e, 0x5c, 0x7e, 0x9a, 0xb2,
+ 0xb7, 0x9d, 0xd4, 0x4f, 0xe3, 0xac, 0x64, 0xdb, 0x6f, 0x1d, 0xdf, 0xd8, 0x41, 0xd7, 0xd9, 0x50, 0x55, 0x30, 0xeb, 0x4b, 0x19, 0xce, 0x78, 0x1f, 0xa8, 0x1e,
+ 0x87, 0x9c, 0x8f, 0x93, 0x97, 0xd4, 0xa2, 0x28, 0x2c, 0x79, 0x22, 0xc8};
+
+TEST(PACKET_PARSER, ETH_IP6_UDP_GTP_IP6_TCP_TLS)
+{
+ uint64_t packet_id = 9;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data9, sizeof(data9), packet_id);
+
+ // LAYER_TYPE_GTPV1_U OK
+ const struct layer_record *outer_gtp_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_GTPV1_U);
+ const struct layer_record *inner_gtp_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_GTPV1_U);
+
+ EXPECT_TRUE(outer_gtp_record != nullptr);
+ EXPECT_TRUE(inner_gtp_record != nullptr);
+ EXPECT_TRUE(outer_gtp_record == inner_gtp_record);
+
+ EXPECT_TRUE(outer_gtp_record->hdr_offset == 14 + 40 + 8);
+ EXPECT_TRUE(outer_gtp_record->hdr_len == 8);
+ EXPECT_TRUE(outer_gtp_record->pld_len == 1372);
+
+ // LAYER_TYPE_IPV6 OK
+ const struct layer_record *outer_ipv6_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV6);
+ const struct layer_record *inner_ipv6_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV6);
+
+ EXPECT_TRUE(outer_ipv6_record != nullptr);
+ EXPECT_TRUE(inner_ipv6_record != nullptr);
+ EXPECT_TRUE(outer_ipv6_record != inner_ipv6_record);
+
+ EXPECT_TRUE(outer_ipv6_record->hdr_offset == 14);
+ EXPECT_TRUE(outer_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(outer_ipv6_record->pld_len == 1388);
+
+ EXPECT_TRUE(inner_ipv6_record->hdr_offset == 14 + 40 + 8 + 8);
+ EXPECT_TRUE(inner_ipv6_record->hdr_len == 40);
+ EXPECT_TRUE(inner_ipv6_record->pld_len == 1332);
+
+ // LAYER_TYPE_L3 OK
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record == outer_ipv6_record);
+ EXPECT_TRUE(inner_l3_record == inner_ipv6_record);
+}
+
+/******************************************************************************
+ * Pcap file: 10-ETH_IP6_UDP_GTP_IP4_TCP_TLS.pcap
+ * [Protocols in frame: eth:ethertype:ipv6:udp:gtp:ip:tcp:ja3:tls]
+ ******************************************************************************
+ *
+ * Frame 1: 1470 bytes on wire (11760 bits), 1470 bytes captured (11760 bits)
+ * Ethernet II, Src: HuaweiTe_62:ee:70 (60:d7:55:62:ee:70), Dst: zte_0e:f5:1c (74:4a:a4:0e:f5:1c)
+ * Destination: zte_0e:f5:1c (74:4a:a4:0e:f5:1c)
+ * Source: HuaweiTe_62:ee:70 (60:d7:55:62:ee:70)
+ * Type: IPv6 (0x86dd)
+ * Internet Protocol Version 6, Src: 2409:8034:4025::50:a31, Dst: 2409:8034:4040:5301::204
+ * 0110 .... = Version: 6
+ * .... 0000 0000 .... .... .... .... .... = Traffic Class: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * .... 0000 0000 0000 0000 0000 = Flow Label: 0x00000
+ * Payload Length: 1416
+ * Next Header: UDP (17)
+ * Hop Limit: 252
+ * Source Address: 2409:8034:4025::50:a31
+ * Destination Address: 2409:8034:4040:5301::204
+ * User Datagram Protocol, Src Port: 2152, Dst Port: 2152
+ * Source Port: 2152
+ * Destination Port: 2152
+ * Length: 1416
+ * Checksum: 0xc8df [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 0]
+ * [Timestamps]
+ * UDP payload (1408 bytes)
+ * GPRS Tunneling Protocol
+ * Flags: 0x30
+ * Message Type: T-PDU (0xff)
+ * Length: 1400
+ * TEID: 0x6c2a4753 (1814710099)
+ * Internet Protocol Version 4, Src: 10.49.115.138, Dst: 121.196.250.66
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 1400
+ * Identification: 0x0003 (3)
+ * 010. .... = Flags: 0x2, Don't fragment
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 64
+ * Protocol: TCP (6)
+ * Header Checksum: 0x43bb [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 10.49.115.138
+ * Destination Address: 121.196.250.66
+ * Transmission Control Protocol, Src Port: 50081, Dst Port: 443, Seq: 1, Ack: 1, Len: 1348
+ * Source Port: 50081
+ * Destination Port: 443
+ * [Stream index: 0]
+ * [Conversation completeness: Incomplete (8)]
+ * [TCP Segment Len: 1348]
+ * Sequence Number: 1 (relative sequence number)
+ * Sequence Number (raw): 1522577104
+ * [Next Sequence Number: 1349 (relative sequence number)]
+ * Acknowledgment Number: 1 (relative ack number)
+ * Acknowledgment number (raw): 3419365570
+ * 1000 .... = Header Length: 32 bytes (8)
+ * Flags: 0x010 (ACK)
+ * Window: 2038
+ * [Calculated window size: 2038]
+ * [Window size scaling factor: -1 (unknown)]
+ * Checksum: 0xd3c2 [unverified]
+ * [Checksum Status: Unverified]
+ * Urgent Pointer: 0
+ * Options: (12 bytes), No-Operation (NOP), No-Operation (NOP), Timestamps
+ * [Timestamps]
+ * [SEQ/ACK analysis]
+ * TCP payload (1348 bytes)
+ * Transport Layer Security
+ */
+
+unsigned char data10[] = {
+ 0x74, 0x4a, 0xa4, 0x0e, 0xf5, 0x1c, 0x60, 0xd7, 0x55, 0x62, 0xee, 0x70, 0x86, 0xdd, 0x60, 0x00, 0x00, 0x00, 0x05, 0x88, 0x11, 0xfc, 0x24, 0x09, 0x80, 0x34,
+ 0x40, 0x25, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x50, 0x0a, 0x31, 0x24, 0x09, 0x80, 0x34, 0x40, 0x40, 0x53, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x02, 0x04, 0x08, 0x68, 0x08, 0x68, 0x05, 0x88, 0xc8, 0xdf, 0x30, 0xff, 0x05, 0x78, 0x6c, 0x2a, 0x47, 0x53, 0x45, 0x00, 0x05, 0x78, 0x00, 0x03, 0x40, 0x00,
+ 0x40, 0x06, 0x43, 0xbb, 0x0a, 0x31, 0x73, 0x8a, 0x79, 0xc4, 0xfa, 0x42, 0xc3, 0xa1, 0x01, 0xbb, 0x5a, 0xc0, 0xae, 0xd0, 0xcb, 0xcf, 0x60, 0xc2, 0x80, 0x10,
+ 0x07, 0xf6, 0xd3, 0xc2, 0x00, 0x00, 0x01, 0x01, 0x08, 0x0a, 0x85, 0x14, 0x0e, 0xb0, 0xcc, 0x45, 0xf8, 0x5f, 0xef, 0x49, 0x45, 0xa0, 0xbe, 0x21, 0xd6, 0x46,
+ 0x9f, 0xb5, 0x17, 0xb2, 0xfe, 0x61, 0x2d, 0xed, 0x4f, 0x0c, 0x1e, 0xb5, 0xda, 0x91, 0x40, 0x87, 0xab, 0x02, 0x0d, 0x01, 0xc8, 0xf1, 0x24, 0x05, 0x8a, 0x9d,
+ 0x8d, 0xfc, 0xbb, 0x82, 0x24, 0xf5, 0x7d, 0x2d, 0x10, 0x66, 0x30, 0x2a, 0xaa, 0x4a, 0x51, 0x8d, 0xe9, 0x9a, 0x65, 0xcf, 0x89, 0x0c, 0x9e, 0x0d, 0x82, 0xda,
+ 0x5e, 0xd3, 0x98, 0xe3, 0x23, 0xf7, 0x5a, 0xd4, 0x88, 0x94, 0xd2, 0xdf, 0xbe, 0x44, 0x20, 0x2b, 0x21, 0x2d, 0x38, 0xca, 0x29, 0x5e, 0xa3, 0xb7, 0xbb, 0x34,
+ 0x20, 0x42, 0x02, 0x71, 0x04, 0xda, 0xd2, 0xeb, 0xb8, 0x81, 0xa3, 0x48, 0xc8, 0x54, 0xad, 0x42, 0x35, 0xc4, 0x4f, 0x6b, 0x15, 0x50, 0x22, 0x3e, 0x26, 0xb3,
+ 0xfc, 0x30, 0x49, 0x71, 0x6f, 0x41, 0x66, 0xa2, 0x2e, 0xe9, 0xd3, 0x1a, 0x69, 0xa8, 0x87, 0x71, 0x65, 0xa2, 0xc7, 0xc7, 0x2b, 0x25, 0x1d, 0x3f, 0xfb, 0xe6,
+ 0x05, 0xe1, 0x09, 0xb9, 0x76, 0x1d, 0xb9, 0xf9, 0xaf, 0xb4, 0x79, 0xa1, 0x35, 0x05, 0x59, 0x88, 0xa0, 0x07, 0xb5, 0x2d, 0x02, 0x11, 0x0a, 0x89, 0xf1, 0x67,
+ 0xdb, 0xe5, 0x5c, 0x5c, 0xaa, 0x0e, 0x21, 0xa6, 0xa4, 0x1a, 0x9f, 0x9e, 0xc8, 0x2a, 0x36, 0x6f, 0xcc, 0xa3, 0x13, 0x78, 0xf1, 0xbe, 0x34, 0xa0, 0x35, 0xef,
+ 0x1f, 0xf4, 0x79, 0xcb, 0x37, 0x3e, 0x77, 0x14, 0xfb, 0x2e, 0x21, 0x4f, 0x6b, 0xe5, 0xe9, 0x3a, 0x90, 0x76, 0xa8, 0x55, 0x09, 0xb6, 0x68, 0xbf, 0x66, 0xae,
+ 0xf1, 0x55, 0xc0, 0x76, 0x8f, 0x16, 0x86, 0x49, 0x9a, 0x88, 0x01, 0xdb, 0x78, 0x1f, 0xde, 0xc2, 0x33, 0x92, 0xe3, 0x22, 0xc6, 0x8c, 0x20, 0x17, 0xa0, 0xb2,
+ 0x79, 0xf4, 0x60, 0x8e, 0x98, 0x53, 0xcd, 0x8f, 0xb2, 0x8f, 0x80, 0xda, 0x9f, 0xf6, 0x00, 0x0c, 0xf8, 0x6b, 0xdf, 0x7d, 0x93, 0x48, 0x5a, 0x23, 0x35, 0x0e,
+ 0x1b, 0xf7, 0x50, 0x87, 0x93, 0x29, 0xaa, 0xa1, 0xb8, 0x98, 0x9f, 0x89, 0xb2, 0x0a, 0x02, 0x27, 0x95, 0x01, 0x84, 0x5a, 0x09, 0xb8, 0xff, 0x23, 0x02, 0x89,
+ 0xef, 0x1b, 0x64, 0xb2, 0x38, 0x81, 0xc4, 0x36, 0xe3, 0xda, 0xb5, 0x3b, 0x80, 0x45, 0x52, 0x96, 0xab, 0x0e, 0xdb, 0xb6, 0x9c, 0xcb, 0xc4, 0xe5, 0xb9, 0x72,
+ 0x67, 0x57, 0x4b, 0xb9, 0x55, 0xcb, 0x6b, 0xc4, 0xec, 0x46, 0x4d, 0xa3, 0xe0, 0xda, 0xba, 0x70, 0x3d, 0xa6, 0xa7, 0x3f, 0x58, 0xd2, 0x9f, 0xb0, 0x11, 0x66,
+ 0xaf, 0x73, 0x09, 0x60, 0x6e, 0xe0, 0x71, 0xa5, 0x65, 0x41, 0x28, 0x3e, 0x70, 0x1d, 0x25, 0x77, 0x6a, 0x4e, 0xed, 0xb9, 0x27, 0x6c, 0xf0, 0xba, 0x54, 0x8d,
+ 0x77, 0xfb, 0xb6, 0x4e, 0xe2, 0xab, 0x8f, 0xe3, 0xd4, 0x02, 0x65, 0x0a, 0x49, 0xf3, 0xf9, 0xc7, 0x09, 0x76, 0x81, 0xf4, 0xf8, 0x3e, 0x1f, 0x74, 0x30, 0xaf,
+ 0x3b, 0x9e, 0x97, 0x00, 0xde, 0xd8, 0x9a, 0xaf, 0xcc, 0x72, 0xeb, 0x0a, 0xe7, 0xab, 0xc1, 0x53, 0x62, 0x3f, 0x08, 0xba, 0x43, 0x06, 0x13, 0x0a, 0x3b, 0x5c,
+ 0xb4, 0xe0, 0xc8, 0xa6, 0x41, 0x45, 0xaa, 0x1a, 0xc9, 0x88, 0x86, 0x31, 0x25, 0x02, 0x4a, 0x76, 0x66, 0xb6, 0x6d, 0xff, 0x50, 0x1d, 0x3c, 0xf3, 0x2d, 0xfe,
+ 0x7b, 0xb2, 0x75, 0x5d, 0x9a, 0x9a, 0xe5, 0x39, 0x31, 0x4f, 0x7b, 0xa5, 0x6f, 0x94, 0xed, 0x31, 0xd4, 0x61, 0xc7, 0x44, 0x1d, 0x37, 0x19, 0x76, 0x04, 0x0e,
+ 0xbd, 0xc4, 0x9e, 0xe3, 0xdf, 0x94, 0x49, 0x32, 0x65, 0xd0, 0x37, 0x64, 0xb5, 0x2a, 0x61, 0x2d, 0x05, 0xc5, 0xe5, 0x79, 0x3e, 0xcf, 0x5f, 0x77, 0x0a, 0x7c,
+ 0x29, 0x34, 0x1a, 0x45, 0x7e, 0x11, 0x68, 0xb4, 0x3a, 0xf6, 0x5b, 0x23, 0xe4, 0x32, 0xa4, 0x11, 0x1a, 0xba, 0xd6, 0x4a, 0x45, 0x42, 0x29, 0xac, 0xb0, 0x17,
+ 0x05, 0x1b, 0xee, 0xf6, 0x52, 0x6d, 0x8b, 0xb4, 0x3b, 0x63, 0xe2, 0xca, 0xbf, 0x7e, 0xd3, 0xf7, 0x96, 0x75, 0x67, 0x9d, 0x27, 0x15, 0x39, 0xde, 0x5f, 0x66,
+ 0x74, 0x7c, 0x46, 0x01, 0x48, 0xf7, 0x99, 0x33, 0x7d, 0xc6, 0x81, 0xc4, 0x82, 0x09, 0x00, 0x20, 0x3f, 0x5c, 0xe4, 0x51, 0x88, 0x5b, 0xac, 0x31, 0x17, 0x04,
+ 0xa4, 0xac, 0xbf, 0x3d, 0xff, 0xad, 0x51, 0x07, 0x0b, 0xc7, 0x26, 0xa7, 0x9f, 0x83, 0x17, 0xd8, 0x2f, 0x6a, 0x47, 0x96, 0x14, 0x47, 0x68, 0xd4, 0xc0, 0xc0,
+ 0x3b, 0x87, 0x51, 0x30, 0xe9, 0xfa, 0x21, 0x46, 0x80, 0x1a, 0x5a, 0xef, 0x78, 0xd0, 0x3a, 0xac, 0x73, 0x1e, 0x39, 0xba, 0x82, 0x43, 0x5d, 0xef, 0x15, 0x2c,
+ 0x9a, 0xe5, 0xeb, 0x6a, 0xe7, 0x24, 0x12, 0xe6, 0x2a, 0xd2, 0x09, 0xc2, 0x85, 0x69, 0x9d, 0x73, 0x16, 0xb0, 0xad, 0x51, 0xf8, 0x3d, 0x94, 0x6b, 0xb7, 0xb3,
+ 0x7f, 0xb4, 0x9e, 0xc1, 0xdc, 0x31, 0x27, 0xa1, 0x2d, 0xfe, 0x30, 0x15, 0x04, 0x20, 0x82, 0xdc, 0xbd, 0x8b, 0xc5, 0xb4, 0xcf, 0x91, 0x85, 0xae, 0x21, 0x5e,
+ 0x00, 0x10, 0x04, 0x62, 0x8a, 0xe2, 0x66, 0x74, 0xf8, 0x8d, 0x8b, 0x52, 0x17, 0xd9, 0x1a, 0xbd, 0x06, 0x2d, 0x07, 0x6a, 0xf5, 0x8b, 0xdf, 0x85, 0x2e, 0x36,
+ 0xec, 0x15, 0x6f, 0x7e, 0xd2, 0x04, 0x43, 0x6a, 0xd7, 0x60, 0xf5, 0x53, 0x0d, 0x2e, 0x2d, 0xf5, 0x52, 0x4c, 0xcc, 0xe5, 0xf4, 0x47, 0xdd, 0x34, 0xda, 0xc1,
+ 0xfc, 0x60, 0x00, 0xaa, 0x68, 0x01, 0x5c, 0x82, 0x4b, 0xf9, 0x57, 0x54, 0x9d, 0xd5, 0x8b, 0xb6, 0x42, 0x77, 0xd4, 0x47, 0x70, 0x23, 0x4c, 0xad, 0xc5, 0x00,
+ 0x73, 0x9b, 0xbb, 0x65, 0xa7, 0x46, 0x74, 0xcd, 0x2e, 0x61, 0x0f, 0xac, 0xeb, 0x53, 0x5a, 0x87, 0x70, 0xfc, 0x5d, 0x2e, 0xa1, 0xe3, 0x9a, 0x87, 0x01, 0x0f,
+ 0x2e, 0xef, 0x10, 0xe2, 0x82, 0xd8, 0x12, 0xe7, 0xb8, 0x94, 0xa4, 0xdd, 0x5f, 0xea, 0x21, 0x63, 0x26, 0x43, 0xec, 0xc3, 0x54, 0x76, 0xb1, 0xb2, 0x1c, 0x03,
+ 0x4c, 0x5c, 0x22, 0xb5, 0x00, 0x7d, 0x77, 0x3a, 0xb6, 0xbf, 0x50, 0xbd, 0xfd, 0x0a, 0x31, 0x2c, 0xdc, 0xab, 0xe2, 0xc0, 0x0b, 0xb6, 0x66, 0xad, 0x9c, 0xca,
+ 0x94, 0xed, 0xd8, 0x77, 0x1b, 0xf1, 0x94, 0xdd, 0x65, 0x61, 0xda, 0x7b, 0x04, 0x3c, 0x93, 0xcf, 0x96, 0x74, 0x35, 0x8e, 0x41, 0xe1, 0xa4, 0xbc, 0xf2, 0x4f,
+ 0xe9, 0xb8, 0x16, 0x55, 0x05, 0x5a, 0xac, 0x10, 0xd3, 0xdf, 0xea, 0x6a, 0xf8, 0xe0, 0xf3, 0xdf, 0x66, 0x00, 0xab, 0x3d, 0xb9, 0x44, 0x65, 0x34, 0x49, 0x89,
+ 0xf2, 0x1d, 0x09, 0xc9, 0xfc, 0xa5, 0x84, 0xa1, 0x03, 0x5b, 0x7a, 0x5c, 0x7e, 0x21, 0xe9, 0xb4, 0x3a, 0x4c, 0x2b, 0x94, 0x64, 0x1d, 0x9b, 0xa5, 0xbf, 0x7e,
+ 0x1c, 0x97, 0x7e, 0x3d, 0xbe, 0x84, 0xfc, 0xab, 0x6d, 0x2a, 0x50, 0x23, 0x9e, 0x11, 0x3f, 0xe2, 0xa0, 0x68, 0xe7, 0xd5, 0xba, 0x5e, 0x24, 0x8c, 0x4c, 0x46,
+ 0xe6, 0x5b, 0x10, 0xc3, 0x82, 0x32, 0x17, 0x32, 0xdc, 0xec, 0xaa, 0x1e, 0x73, 0xe5, 0x7d, 0xb8, 0x1c, 0x6c, 0x4c, 0x9f, 0x60, 0x7b, 0x66, 0x4c, 0x90, 0x69,
+ 0xc4, 0x23, 0x66, 0x67, 0xce, 0x6d, 0x24, 0x1d, 0xcc, 0x8e, 0x78, 0xa1, 0xa7, 0xde, 0x87, 0x81, 0xac, 0x62, 0x54, 0xbc, 0x47, 0x82, 0x3c, 0xad, 0x92, 0x29,
+ 0xd9, 0xc0, 0xed, 0x0c, 0x11, 0x0e, 0xc5, 0x75, 0xa4, 0xbd, 0xbf, 0xcb, 0x3a, 0xaf, 0x2b, 0x9f, 0xbe, 0xbb, 0xbc, 0x31, 0x07, 0xa7, 0xbe, 0x6c, 0xa9, 0x4e,
+ 0xff, 0x35, 0x80, 0x2f, 0x09, 0x77, 0xe0, 0xc0, 0xdc, 0x9c, 0xc6, 0xa6, 0x63, 0xab, 0x47, 0x74, 0x5f, 0x5c, 0xae, 0x75, 0xbf, 0x42, 0x67, 0x55, 0x89, 0xcf,
+ 0xd3, 0x65, 0x8d, 0x5b, 0x6f, 0x5c, 0xf9, 0xd1, 0x78, 0xa2, 0xfd, 0x4f, 0x54, 0x6a, 0x71, 0x0c, 0x58, 0x13, 0xb0, 0x48, 0x0a, 0x7b, 0xcc, 0x84, 0x61, 0xa7,
+ 0x7d, 0x39, 0xa2, 0xd1, 0xc0, 0xdb, 0x8e, 0x97, 0x20, 0x86, 0x97, 0x20, 0xda, 0xca, 0x56, 0x78, 0x61, 0xc2, 0x2f, 0x36, 0xdb, 0x95, 0xae, 0x7e, 0x8d, 0x97,
+ 0xcb, 0x45, 0x6a, 0x6d, 0x27, 0xaa, 0xab, 0x4e, 0x88, 0x23, 0xb6, 0x6a, 0x8a, 0xca, 0x71, 0xca, 0x39, 0xa2, 0x98, 0x0d, 0x53, 0xa9, 0x38, 0xd5, 0x9c, 0x5d,
+ 0x0e, 0x5e, 0xc9, 0xeb, 0x21, 0xab, 0x00, 0xca, 0xff, 0x92, 0x20, 0x9d, 0x65, 0x9d, 0x8d, 0x49, 0x46, 0xbe, 0x51, 0x97, 0xc1, 0x61, 0x02, 0x9e, 0xa8, 0xb9,
+ 0x2c, 0x27, 0x7d, 0x73, 0xf9, 0x12, 0x16, 0x45, 0x25, 0xbb, 0xb0, 0x51, 0x14, 0x18, 0x07, 0xab, 0xc7, 0x06, 0xc0, 0xe9, 0x1c, 0xf8, 0x6d, 0xe1, 0x80, 0x21,
+ 0x21, 0x68, 0x24, 0xf7, 0x28, 0xb9, 0x07, 0xd4, 0xd7, 0xdf, 0x3e, 0xff, 0xbc, 0xe3, 0xbc, 0x6e, 0x42, 0x76, 0x63, 0xbc, 0x82, 0x0a, 0xf5, 0x99, 0x65, 0x17,
+ 0xd2, 0x38, 0xa9, 0xa8, 0x31, 0xce, 0x1f, 0xf7, 0xef, 0x8d, 0x94, 0xae, 0x99, 0x50, 0x30, 0x12, 0xbd, 0x4b, 0x65, 0x56, 0x59, 0xfb, 0x33, 0x7b, 0x99, 0xc7,
+ 0xe5, 0x80, 0xe6, 0x92, 0x0e, 0x44, 0x1d, 0x17, 0xc2, 0xd0, 0x78, 0x76, 0x9d, 0x5b, 0x7d, 0x3c, 0xb4, 0xf8, 0xcb, 0x2f, 0x83, 0x23, 0x35, 0x49, 0xc0, 0x78,
+ 0x2d, 0x44, 0x05, 0x64, 0x0f, 0xaa, 0x84, 0x9d, 0x3f, 0xac, 0xef, 0x5b, 0x46, 0x44, 0xb8, 0x15, 0xbe, 0x4f, 0xe7, 0x25, 0xb7, 0xa0, 0xc8, 0x0f, 0x70, 0x1a,
+ 0xca, 0x7f, 0xce, 0x79, 0x7b, 0xf5, 0x7e, 0x21, 0x35, 0xc7, 0x0e, 0x99, 0xdc, 0x76, 0xe0, 0x36, 0x09, 0x6e, 0x6d, 0x5f, 0x98, 0x5e, 0xb8, 0xa4, 0x88, 0xea,
+ 0x0b, 0x4b, 0x21, 0xa2, 0x52, 0x86, 0x95, 0x4e, 0x18, 0xac, 0xa2, 0xaf, 0x29, 0x5b, 0xe7, 0x05, 0xa1, 0xc8, 0xe1, 0x80, 0xfa, 0xb6, 0x5a, 0xed, 0x94, 0x32,
+ 0x4f, 0xe9, 0xf5, 0xf0, 0x61, 0x5d, 0x7f, 0xc4, 0xc4, 0xd1, 0x05, 0x54, 0x13, 0xdb};
+
+TEST(PACKET_PARSER, ETH_IP6_UDP_GTP_IP4_TCP_TLS)
+{
+ uint64_t packet_id = 10;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data10, sizeof(data10), packet_id);
+
+ // LAYER_TYPE_IPV4
+ const struct layer_record *outer_ipv4_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_IPV4);
+ const struct layer_record *inner_ipv4_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_IPV4);
+
+ EXPECT_TRUE(outer_ipv4_record != nullptr);
+ EXPECT_TRUE(inner_ipv4_record != nullptr);
+ EXPECT_TRUE(outer_ipv4_record == inner_ipv4_record);
+
+ EXPECT_TRUE(outer_ipv4_record->hdr_offset == 14 + 40 + 8 + 8);
+ EXPECT_TRUE(outer_ipv4_record->hdr_len == 20);
+ EXPECT_TRUE(outer_ipv4_record->pld_len == 1380);
+
+ // LAYER_TYPE_L3
+ const struct layer_record *outer_l3_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L3);
+ const struct layer_record *inner_l3_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L3);
+
+ EXPECT_TRUE(outer_l3_record != nullptr);
+ EXPECT_TRUE(inner_l3_record != nullptr);
+ EXPECT_TRUE(outer_l3_record != inner_l3_record);
+ EXPECT_TRUE(inner_l3_record == outer_ipv4_record);
+}
+
+/******************************************************************************
+ * Pcap file: 11-ETH_IP4_UDP_GVXLAN_ETH_IP4_UDP_DNS.pcap
+ * [Protocols in frame: eth:ethertype:ip:udp:vxlan:eth:ethertype:ip:udp:dns]
+ ******************************************************************************
+ *
+ * Frame 1: 124 bytes on wire (992 bits), 124 bytes captured (992 bits)
+ * Ethernet II, Src: zte_6c:fa:43 (00:1e:73:6c:fa:43), Dst: Shanghai_0d:0a (e4:95:6e:20:0d:0a)
+ * Destination: Shanghai_0d:0a (e4:95:6e:20:0d:0a)
+ * Source: zte_6c:fa:43 (00:1e:73:6c:fa:43)
+ * Type: IPv4 (0x0800)
+ * Internet Protocol Version 4, Src: 10.1.1.1, Dst: 192.168.1.10
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 110
+ * Identification: 0x0000 (0)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 254
+ * Protocol: UDP (17)
+ * Header Checksum: 0xefca [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 10.1.1.1
+ * Destination Address: 192.168.1.10
+ * User Datagram Protocol, Src Port: 50709, Dst Port: 4789
+ * Source Port: 50709
+ * Destination Port: 4789
+ * Length: 90
+ * Checksum: 0x0000 [zero-value ignored]
+ * [Stream index: 0]
+ * [Timestamps]
+ * UDP payload (82 bytes)
+ * Virtual eXtensible Local Area Network
+ * Flags: 0x0800, VXLAN Network ID (VNI)
+ * Group Policy ID: 0
+ * VXLAN Network Identifier (VNI): 458755
+ * Reserved: 0
+ * Ethernet II, Src: WistronI_18:18:41 (3c:97:0e:18:18:41), Dst: DawningI_13:70:7a (e8:61:1f:13:70:7a)
+ * Destination: DawningI_13:70:7a (e8:61:1f:13:70:7a)
+ * Source: WistronI_18:18:41 (3c:97:0e:18:18:41)
+ * Type: IPv4 (0x0800)
+ * Internet Protocol Version 4, Src: 192.168.11.193, Dst: 114.114.114.114
+ * 0100 .... = Version: 4
+ * .... 0101 = Header Length: 20 bytes (5)
+ * Differentiated Services Field: 0x00 (DSCP: CS0, ECN: Not-ECT)
+ * Total Length: 60
+ * Identification: 0x0cb6 (3254)
+ * 000. .... = Flags: 0x0
+ * ...0 0000 0000 0000 = Fragment Offset: 0
+ * Time to Live: 64
+ * Protocol: UDP (17)
+ * Header Checksum: 0xbcad [validation disabled]
+ * [Header checksum status: Unverified]
+ * Source Address: 192.168.11.193
+ * Destination Address: 114.114.114.114
+ * User Datagram Protocol, Src Port: 65290, Dst Port: 53
+ * Source Port: 65290
+ * Destination Port: 53
+ * Length: 40
+ * Checksum: 0x39e4 [unverified]
+ * [Checksum Status: Unverified]
+ * [Stream index: 1]
+ * [Timestamps]
+ * UDP payload (32 bytes)
+ * Domain Name System (query)
+ */
+
+unsigned char data11[] = {
+ 0xe4, 0x95, 0x6e, 0x20, 0x0d, 0x0a, 0x00, 0x1e, 0x73, 0x6c, 0xfa, 0x43, 0x08, 0x00, 0x45, 0x00, 0x00, 0x6e, 0x00, 0x00, 0x00, 0x00, 0xfe, 0x11, 0xef, 0xca,
+ 0x0a, 0x01, 0x01, 0x01, 0xc0, 0xa8, 0x01, 0x0a, 0xc6, 0x15, 0x12, 0xb5, 0x00, 0x5a, 0x00, 0x00, 0x08, 0x00, 0x00, 0x00, 0x07, 0x00, 0x03, 0x00, 0xe8, 0x61,
+ 0x1f, 0x13, 0x70, 0x7a, 0x3c, 0x97, 0x0e, 0x18, 0x18, 0x41, 0x08, 0x00, 0x45, 0x00, 0x00, 0x3c, 0x0c, 0xb6, 0x00, 0x00, 0x40, 0x11, 0xbc, 0xad, 0xc0, 0xa8,
+ 0x0b, 0xc1, 0x72, 0x72, 0x72, 0x72, 0xff, 0x0a, 0x00, 0x35, 0x00, 0x28, 0x39, 0xe4, 0x86, 0x84, 0x01, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x03, 0x77, 0x77, 0x77, 0x06, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x03, 0x63, 0x6f, 0x6d, 0x00, 0x00, 0x01, 0x00, 0x01};
+
+TEST(PACKET_PARSER, ETH_IP4_UDP_GVXLAN_ETH_IP4_UDP_DNS)
+{
+ uint64_t packet_id = 11;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data11, sizeof(data11), packet_id);
+
+ // LAYER_TYPE_G_VXLAN OK
+ const struct layer_record *outer_g_vlan_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_G_VXLAN);
+ const struct layer_record *inner_g_vlan_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_G_VXLAN);
+
+ EXPECT_TRUE(outer_g_vlan_record != nullptr);
+ EXPECT_TRUE(inner_g_vlan_record != nullptr);
+ EXPECT_TRUE(outer_g_vlan_record == inner_g_vlan_record);
+
+ EXPECT_TRUE(outer_g_vlan_record->hdr_offset == 14 + 20 + 8);
+ EXPECT_TRUE(outer_g_vlan_record->hdr_len == 8);
+ EXPECT_TRUE(outer_g_vlan_record->pld_len == 124 - 14 - 20 - 8 - 8);
+
+ // LAYER_TYPE_ETHER OK
+ const struct layer_record *outer_eth_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_ETHER);
+ const struct layer_record *inner_eth_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_ETHER);
+
+ EXPECT_TRUE(outer_eth_record != nullptr);
+ EXPECT_TRUE(inner_eth_record != nullptr);
+ EXPECT_TRUE(outer_eth_record != inner_eth_record);
+
+ EXPECT_TRUE(outer_eth_record->hdr_offset == 0);
+ EXPECT_TRUE(outer_eth_record->hdr_len == 14);
+ EXPECT_TRUE(outer_eth_record->pld_len == 124 - 14);
+
+ EXPECT_TRUE(inner_eth_record->hdr_offset == 14 + 20 + 8 + 8);
+ EXPECT_TRUE(inner_eth_record->hdr_len == 14);
+ EXPECT_TRUE(inner_eth_record->pld_len == 20 + 8 + 32);
+
+ // LAYER_TYPE_L2 OK
+ const struct layer_record *outer_l2_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2);
+ const struct layer_record *inner_l2_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2);
+
+ EXPECT_TRUE(outer_l2_record != nullptr);
+ EXPECT_TRUE(inner_l2_record != nullptr);
+ EXPECT_TRUE(outer_l2_record == outer_eth_record);
+ EXPECT_TRUE(inner_l2_record == inner_eth_record);
+}
+
+/******************************************************************************
+ * Pcap file: 12-ETH_MPLS_MPLS_PWETHCW_ETH_ARP.pcap
+ * [Protocols in frame: eth:ethertype:mpls:pwethheuristic:pwethcw:eth:ethertype:arp]
+ ******************************************************************************
+ *
+ * Frame 1: 90 bytes on wire (720 bits), 90 bytes captured (720 bits)
+ * Ethernet II, Src: cc:01:0d:5c:00:10 (cc:01:0d:5c:00:10), Dst: cc:00:0d:5c:00:10 (cc:00:0d:5c:00:10)
+ * Destination: cc:00:0d:5c:00:10 (cc:00:0d:5c:00:10)
+ * Source: cc:01:0d:5c:00:10 (cc:01:0d:5c:00:10)
+ * Type: MPLS label switched packet (0x8847)
+ * MultiProtocol Label Switching Header, Label: 19, Exp: 0, S: 0, TTL: 254
+ * 0000 0000 0000 0001 0011 .... .... .... = MPLS Label: 19 (0x00013)
+ * .... .... .... .... .... 000. .... .... = MPLS Experimental Bits: 0
+ * .... .... .... .... .... ...0 .... .... = MPLS Bottom Of Label Stack: 0
+ * .... .... .... .... .... .... 1111 1110 = MPLS TTL: 254
+ * MultiProtocol Label Switching Header, Label: 16, Exp: 0, S: 1, TTL: 255
+ * 0000 0000 0000 0001 0000 .... .... .... = MPLS Label: 16 (0x00010)
+ * .... .... .... .... .... 000. .... .... = MPLS Experimental Bits: 0
+ * .... .... .... .... .... ...1 .... .... = MPLS Bottom Of Label Stack: 1
+ * .... .... .... .... .... .... 1111 1111 = MPLS TTL: 255
+ * PW Ethernet Control Word
+ * Sequence Number: 0
+ * Ethernet II, Src: Private_66:68:00 (00:50:79:66:68:00), Dst: Broadcast (ff:ff:ff:ff:ff:ff)
+ * Destination: Broadcast (ff:ff:ff:ff:ff:ff)
+ * Source: Private_66:68:00 (00:50:79:66:68:00)
+ * Type: ARP (0x0806)
+ * Trailer: 00000000000000000000000000000000000000000000
+ * Address Resolution Protocol (request)
+ */
+
+unsigned char data12[] = {
+ 0xcc, 0x00, 0x0d, 0x5c, 0x00, 0x10, 0xcc, 0x01, 0x0d, 0x5c, 0x00, 0x10, 0x88, 0x47, 0x00, 0x01, 0x30, 0xfe, 0x00, 0x01, 0x01, 0xff, 0x00, 0x00, 0x00, 0x00,
+ 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0x00, 0x50, 0x79, 0x66, 0x68, 0x00, 0x08, 0x06, 0x00, 0x01, 0x08, 0x00, 0x06, 0x04, 0x00, 0x01, 0x00, 0x50, 0x79, 0x66,
+ 0x68, 0x00, 0xc0, 0xa8, 0x00, 0x0a, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xc0, 0xa8, 0x00, 0x14, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
+
+TEST(PACKET_PARSER, ETH_MPLS_MPLS_PWETHCW_ETH_ARP)
+{
+ uint64_t packet_id = 12;
+ struct packet_parser handler;
+
+ packet_parser_init(&handler);
+ packet_parser_parse(&handler, (const void *)data12, sizeof(data12), packet_id);
+
+ // LAYER_TYPE_ETHER OK
+ const struct layer_record *outer_eth_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_ETHER);
+ const struct layer_record *inner_eth_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_ETHER);
+
+ EXPECT_TRUE(outer_eth_record != nullptr);
+ EXPECT_TRUE(inner_eth_record != nullptr);
+ EXPECT_TRUE(outer_eth_record != inner_eth_record);
+
+ EXPECT_TRUE(outer_eth_record->hdr_offset == 0);
+ EXPECT_TRUE(outer_eth_record->hdr_len == 14);
+ EXPECT_TRUE(outer_eth_record->pld_len == 76);
+
+ EXPECT_TRUE(inner_eth_record->hdr_offset == 14 + 4 + 4 + 4);
+ EXPECT_TRUE(inner_eth_record->hdr_len == 14);
+ EXPECT_TRUE(inner_eth_record->pld_len == 50);
+
+ // LAYER_TYPE_L2 OK
+ const struct layer_record *outer_l2_record = packet_parser_get_most_outer(&handler, LAYER_TYPE_L2);
+ const struct layer_record *inner_l2_record = packet_parser_get_most_inner(&handler, LAYER_TYPE_L2);
+
+ EXPECT_TRUE(outer_l2_record != nullptr);
+ EXPECT_TRUE(inner_l2_record != nullptr);
+ EXPECT_TRUE(outer_l2_record == outer_eth_record);
+ EXPECT_TRUE(inner_l2_record == inner_eth_record);
+}
+
+int main(int argc, char **argv)
+{
+ ::testing::InitGoogleTest(&argc, argv);
+ return RUN_ALL_TESTS();
+}
diff --git a/common/test/pcap/1-ETH_VLAN_VLAN_IP4_IP4_UDP.pcap b/common/test/pcap/1-ETH_VLAN_VLAN_IP4_IP4_UDP.pcap
new file mode 100644
index 0000000..769ab66
--- /dev/null
+++ b/common/test/pcap/1-ETH_VLAN_VLAN_IP4_IP4_UDP.pcap
Binary files differ
diff --git a/common/test/pcap/10-ETH_IP6_UDP_GTP_IP4_TCP_TLS.pcap b/common/test/pcap/10-ETH_IP6_UDP_GTP_IP4_TCP_TLS.pcap
new file mode 100644
index 0000000..af72b4d
--- /dev/null
+++ b/common/test/pcap/10-ETH_IP6_UDP_GTP_IP4_TCP_TLS.pcap
Binary files differ
diff --git a/common/test/pcap/11-ETH_IP4_UDP_VXLAN_ETH_IP4_UDP_DNS.pcap b/common/test/pcap/11-ETH_IP4_UDP_VXLAN_ETH_IP4_UDP_DNS.pcap
new file mode 100644
index 0000000..29b8962
--- /dev/null
+++ b/common/test/pcap/11-ETH_IP4_UDP_VXLAN_ETH_IP4_UDP_DNS.pcap
Binary files differ
diff --git a/common/test/pcap/12-ETH_MPLS_MPLS_PWETHCW_ETH_ARP.pcap b/common/test/pcap/12-ETH_MPLS_MPLS_PWETHCW_ETH_ARP.pcap
new file mode 100644
index 0000000..50c6085
--- /dev/null
+++ b/common/test/pcap/12-ETH_MPLS_MPLS_PWETHCW_ETH_ARP.pcap
Binary files differ
diff --git a/common/test/pcap/2-ETH_IP6_IP4_TCP_SSH.pcap b/common/test/pcap/2-ETH_IP6_IP4_TCP_SSH.pcap
new file mode 100644
index 0000000..ef8d64a
--- /dev/null
+++ b/common/test/pcap/2-ETH_IP6_IP4_TCP_SSH.pcap
Binary files differ
diff --git a/common/test/pcap/3-ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS.pcap b/common/test/pcap/3-ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS.pcap
new file mode 100644
index 0000000..fb3908e
--- /dev/null
+++ b/common/test/pcap/3-ETH_VLAN_IP6_IP4_GRE_PPP_IP4_UDP_DNS.pcap
Binary files differ
diff --git a/common/test/pcap/4-ETH_IP4_IP6_TCP.pcap.pcap b/common/test/pcap/4-ETH_IP4_IP6_TCP.pcap.pcap
new file mode 100644
index 0000000..6b074e5
--- /dev/null
+++ b/common/test/pcap/4-ETH_IP4_IP6_TCP.pcap.pcap
Binary files differ
diff --git a/common/test/pcap/5-ETH_IP6_IP6_UDP.pcap b/common/test/pcap/5-ETH_IP6_IP6_UDP.pcap
new file mode 100644
index 0000000..c5838fd
--- /dev/null
+++ b/common/test/pcap/5-ETH_IP6_IP6_UDP.pcap
Binary files differ
diff --git a/common/test/pcap/6-ETH_MPLS_IP4_TCP.pcap b/common/test/pcap/6-ETH_MPLS_IP4_TCP.pcap
new file mode 100644
index 0000000..fa52ac9
--- /dev/null
+++ b/common/test/pcap/6-ETH_MPLS_IP4_TCP.pcap
Binary files differ
diff --git a/common/test/pcap/7-ETH_MPLS_MPLS_IP4_TCP.pcap b/common/test/pcap/7-ETH_MPLS_MPLS_IP4_TCP.pcap
new file mode 100644
index 0000000..7578a20
--- /dev/null
+++ b/common/test/pcap/7-ETH_MPLS_MPLS_IP4_TCP.pcap
Binary files differ
diff --git a/common/test/pcap/8-ETH_VLAN_PPPOE_IP4_TCP.pcap b/common/test/pcap/8-ETH_VLAN_PPPOE_IP4_TCP.pcap
new file mode 100644
index 0000000..141b625
--- /dev/null
+++ b/common/test/pcap/8-ETH_VLAN_PPPOE_IP4_TCP.pcap
Binary files differ
diff --git a/common/test/pcap/9-ETH_IP6_UDP_GTP_IP6_TCP_TLS.pcap b/common/test/pcap/9-ETH_IP6_UDP_GTP_IP6_TCP_TLS.pcap
new file mode 100644
index 0000000..1517357
--- /dev/null
+++ b/common/test/pcap/9-ETH_IP6_UDP_GTP_IP6_TCP_TLS.pcap
Binary files differ
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-30 17:37:56 +0000