summaryrefslogtreecommitdiff
path: root/decoders
diff options
context:
space:
mode:
authorluwenpeng <[email protected]>2024-11-01 15:36:18 +0800
committerluwenpeng <[email protected]>2024-11-01 15:36:18 +0800
commitda9e15264da6e15328c86c78cf672a9425d13e61 (patch)
tree2f99b9173b9d4692c80e24a6cf30a82233dbc171 /decoders
parentc05d3fe2d50896c7aa917ca1cb9c769f016da5c3 (diff)
rename session_get0_current_packet() to session_get_current_packet()
Diffstat (limited to 'decoders')
-rw-r--r--decoders/lpi_plus/lpip_module.c2
-rw-r--r--decoders/session_flags/session_flags.cpp4
-rw-r--r--decoders/socks/socks_decoder.cpp2
-rw-r--r--decoders/stratum/stratum_decoder.cpp2
4 files changed, 5 insertions, 5 deletions
diff --git a/decoders/lpi_plus/lpip_module.c b/decoders/lpi_plus/lpip_module.c
index 6bffeec..df0e991 100644
--- a/decoders/lpi_plus/lpip_module.c
+++ b/decoders/lpi_plus/lpip_module.c
@@ -62,7 +62,7 @@ static void lpi_plus_get_host_order_port(struct session *sess __unused, unsigned
*dport=0;
//get host order port from stellar session api
- const struct packet *pkt = session_get0_current_packet(sess);
+ const struct packet *pkt = session_get_current_packet(sess);
enum flow_type flow_type=session_get_flow_type(sess);
if(pkt && (flow_type==FLOW_TYPE_C2S || flow_type==FLOW_TYPE_S2C))
{
diff --git a/decoders/session_flags/session_flags.cpp b/decoders/session_flags/session_flags.cpp
index 5abee7e..19aa222 100644
--- a/decoders/session_flags/session_flags.cpp
+++ b/decoders/session_flags/session_flags.cpp
@@ -281,7 +281,7 @@ static void flow_stat_update(struct session *session, struct flow_stat *flow, ui
flow->delta_pkts++;
flow->delta_bytes += bytes;
- const struct packet *pkt = session_get0_current_packet(session);
+ const struct packet *pkt = session_get_current_packet(session);
size_t payload_len = packet_get_payload_len(pkt);
if (payload_len > 0)
@@ -610,7 +610,7 @@ static void session_flags_calculate_random_looking(struct session_flags_plugin_i
int udp_topic_id = sf_plugin_info->udp_topic_id;
- const struct packet *pkt = session_get0_current_packet(session);
+ const struct packet *pkt = session_get_current_packet(session);
size_t payload_len = packet_get_payload_len(pkt);
const char *payload = packet_get_payload(pkt);
diff --git a/decoders/socks/socks_decoder.cpp b/decoders/socks/socks_decoder.cpp
index 233c077..cc7f323 100644
--- a/decoders/socks/socks_decoder.cpp
+++ b/decoders/socks/socks_decoder.cpp
@@ -456,7 +456,7 @@ void socks_decoder_on_message(struct session *sess, int topic_id, const void *ms
session_exdata_set(sess, socks_decoder_info->sess_exdata_idx, socks_tunel_stream);
}
- pkt = session_get0_current_packet(sess);
+ pkt = session_get_current_packet(sess);
payload = packet_get_payload(pkt);
payload_len = packet_get_payload_len(pkt);
diff --git a/decoders/stratum/stratum_decoder.cpp b/decoders/stratum/stratum_decoder.cpp
index 3267817..76ad251 100644
--- a/decoders/stratum/stratum_decoder.cpp
+++ b/decoders/stratum/stratum_decoder.cpp
@@ -236,7 +236,7 @@ void stratum_decoder_tcp_on_msg_cb(struct session *sess, int topic_id, const voi
struct stratum_decoder_info *stratum_decoder_info = (struct stratum_decoder_info *)plugin_env;
- const struct packet *pkt = session_get0_current_packet(sess);
+ const struct packet *pkt = session_get_current_packet(sess);
const char *payload = packet_get_payload(pkt);
size_t payload_len = packet_get_payload_len(pkt);