diff options
| author | luwenpeng <[email protected]> | 2023-11-08 10:20:27 +0800 |
|---|---|---|
| committer | luwenpeng <[email protected]> | 2023-11-08 10:20:27 +0800 |
| commit | 8fe574633bc7ad96b42f5c8996821fc5afa42e18 (patch) | |
| tree | 862f0f1b795b6010114364ab499bff469284b713 /platform/src | |
| parent | 3627addb85c067afae41adb0f0c2482d4ea7f339 (diff) | |
perf: rename addr_tuple4 to four_tuple
Diffstat (limited to 'platform/src')
| -rw-r--r-- | platform/src/packet_io.cpp | 28 |
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); |
