summaryrefslogtreecommitdiff
path: root/platform/src
diff options
context:
space:
mode:
authorluwenpeng <[email protected]>2023-11-08 10:20:27 +0800
committerluwenpeng <[email protected]>2023-11-08 10:20:27 +0800
commit8fe574633bc7ad96b42f5c8996821fc5afa42e18 (patch)
tree862f0f1b795b6010114364ab499bff469284b713 /platform/src
parent3627addb85c067afae41adb0f0c2482d4ea7f339 (diff)
perf: rename addr_tuple4 to four_tuple
Diffstat (limited to 'platform/src')
-rw-r--r--platform/src/packet_io.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/platform/src/packet_io.cpp b/platform/src/packet_io.cpp
index 60dff88..de85072 100644
--- a/platform/src/packet_io.cpp
+++ b/platform/src/packet_io.cpp
@@ -347,17 +347,17 @@ static int is_uplink_keepalive_packet(marsio_buff_t *rx_buff)
// return NULL
static struct session_ctx *data_packet_search_session(struct session_table *table, const char *raw_data, int raw_len, uint64_t session_id)
{
- struct addr_tuple4 inner_addr;
- struct addr_tuple4 reverse_addr;
+ struct four_tuple inner_addr;
+ struct four_tuple reverse_addr;
struct data_packet data_pkt;
- memset(&inner_addr, 0, sizeof(struct addr_tuple4));
- memset(&reverse_addr, 0, sizeof(struct addr_tuple4));
+ memset(&inner_addr, 0, sizeof(struct four_tuple));
+ memset(&reverse_addr, 0, sizeof(struct four_tuple));
data_packet_parse(&data_pkt, (const void *)raw_data, raw_len, 0);
data_packet_get_innermost_tuple4(&data_pkt, &inner_addr);
- addr_tuple4_reverse(&inner_addr, &reverse_addr);
+ four_tuple_reverse(&inner_addr, &reverse_addr);
struct session_node *node = session_table_search_by_id(table, session_id);
if (node == NULL)
@@ -366,9 +366,9 @@ static struct session_ctx *data_packet_search_session(struct session_table *tabl
}
struct session_ctx *session_ctx = (struct session_ctx *)node->value;
- if (memcmp(&session_ctx->inner_tuple4, &inner_addr, sizeof(struct addr_tuple4)) != 0 && memcmp(&session_ctx->inner_tuple4, &reverse_addr, sizeof(struct addr_tuple4)) != 0)
+ if (memcmp(&session_ctx->inner_tuple4, &inner_addr, sizeof(struct four_tuple)) != 0 && memcmp(&session_ctx->inner_tuple4, &reverse_addr, sizeof(struct four_tuple)) != 0)
{
- char *addr_str = addr_tuple4_to_str(&inner_addr);
+ char *addr_str = four_tuple_to_string(&inner_addr);
LOG_ERROR("%s: unexpected raw packet, session %lu expected address tuple4 is %s, but current packet's address tuple4 is %s, bypass !!!", LOG_TAG_PKTIO, session_ctx->session_id, session_ctx->session_addr, addr_str);
free(addr_str);
return NULL;
@@ -381,10 +381,10 @@ static struct session_ctx *data_packet_search_session(struct session_table *tabl
// return NULL
static struct session_ctx *inject_packet_search_session(struct session_table *table, const char *raw_data, int raw_len)
{
- struct addr_tuple4 inner_addr;
+ struct four_tuple inner_addr;
struct data_packet data_pkt;
- memset(&inner_addr, 0, sizeof(struct addr_tuple4));
+ memset(&inner_addr, 0, sizeof(struct four_tuple));
data_packet_parse(&data_pkt, (const void *)raw_data, raw_len, 0);
@@ -393,7 +393,7 @@ static struct session_ctx *inject_packet_search_session(struct session_table *ta
struct session_node *node = session_table_search_by_addr(table, &inner_addr);
if (node == NULL)
{
- char *addr_str = addr_tuple4_to_str(&inner_addr);
+ char *addr_str = four_tuple_to_string(&inner_addr);
LOG_ERROR("%s: unexpected inject packet, unable to find session %s from session table, drop !!!", LOG_TAG_PKTIO, addr_str);
free(addr_str);
return NULL;
@@ -914,21 +914,21 @@ static void handle_session_opening(struct metadata *meta, struct control_packet
#endif
struct data_packet data_pkt;
- struct addr_tuple4 inner_tuple4;
+ struct four_tuple inner_tuple4;
const void *payload = data_packet_parse(&data_pkt, (const void *)meta->raw_data, meta->raw_len, meta->session_id);
data_packet_get_innermost_tuple4(&data_pkt, &inner_tuple4);
uint16_t real_offset = (char *)payload - meta->raw_data;
if (real_offset != meta->l7offset)
{
- char *addr_str = addr_tuple4_to_str(&inner_tuple4);
+ char *addr_str = four_tuple_to_string(&inner_tuple4);
LOG_ERROR("%s: incorrect dataoffset %d in the control zone of session %lu %s, the expect value is %d", LOG_TAG_PKTIO, meta->l7offset, meta->session_id, addr_str, real_offset);
free(addr_str);
}
struct session_ctx *session_ctx = session_ctx_new();
session_ctx->session_id = meta->session_id;
- session_ctx->session_addr = addr_tuple4_to_str(&inner_tuple4);
- addr_tuple4_copy(&session_ctx->inner_tuple4, &inner_tuple4);
+ session_ctx->session_addr = four_tuple_to_string(&inner_tuple4);
+ four_tuple_copy(&session_ctx->inner_tuple4, &inner_tuple4);
metadata_deep_copy(session_ctx->ctrl_meta, meta);
session_ctx->chainings.chaining_raw = selected_chaining_create(chaining_size, session_ctx->session_id, session_ctx->session_addr);
session_ctx->chainings.chaining_decrypted = selected_chaining_create(chaining_size, session_ctx->session_id, session_ctx->session_addr);