diff options
| author | fengweihao <[email protected]> | 2024-07-26 16:50:51 +0800 |
|---|---|---|
| committer | fengweihao <[email protected]> | 2024-07-26 16:50:51 +0800 |
| commit | 83f51432b1b86d6d35eb5c3e10e6cbca29a1a45a (patch) | |
| tree | 923c63905a9746f8979d58de3885a80ef025adae /common/src/tfe_packet_io.cpp | |
| parent | a59b9390336dafa0ee1f05e74e52411d175b9843 (diff) | |
TSG-21854 TFE使用fieldstat4序列化Manipulation Policy的metric并输出到kafka
Diffstat (limited to 'common/src/tfe_packet_io.cpp')
| -rw-r--r-- | common/src/tfe_packet_io.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/common/src/tfe_packet_io.cpp b/common/src/tfe_packet_io.cpp index 9950347..32e1250 100644 --- a/common/src/tfe_packet_io.cpp +++ b/common/src/tfe_packet_io.cpp @@ -35,7 +35,6 @@ #include "dablooms.h" #include "timestamp.h" #include "tfe_dp_trace.h" -#include "metrics.h" /****************************************************************************** * Struct @@ -1350,7 +1349,7 @@ static int handle_session_closing(struct metadata *meta, marsio_buff_t *rx_buff, if (node) { struct session_ctx *s_ctx = (struct session_ctx *)node->val_data; - metrics_single_session_output(node, thread); + tfe_fieldstat_intercept_incrby(thread->ref_acceptor_ctx->metrics, s_ctx, thread->thread_index); TFE_LOG_INFO(logger, "%s: session %lu closing", LOG_TAG_PKTIO, s_ctx->session_id); tfe_dp_telemetry_on_ctrl_pkt(packet_io->instance, rx_buff, s_ctx->policy_ids, meta->session_id, "closing", NULL, NULL); session_table_delete_by_id(thread->session_table, meta->session_id); |