summaryrefslogtreecommitdiff
path: root/common/src/tfe_metrics.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/src/tfe_metrics.cpp')
-rw-r--r--common/src/tfe_metrics.cpp176
1 files changed, 0 insertions, 176 deletions
diff --git a/common/src/tfe_metrics.cpp b/common/src/tfe_metrics.cpp
deleted file mode 100644
index aebf9dd..0000000
--- a/common/src/tfe_metrics.cpp
+++ /dev/null
@@ -1,176 +0,0 @@
-#include <stdlib.h>
-#include <string.h>
-#include <assert.h>
-#include <MESA/MESA_prof_load.h>
-
-#include "tfe_proxy.h"
-#include "tfe_metrics.h"
-
-enum SCE_STAT_FIELD
-{
- // hit block policy
- STAT_HIT_POLICY_PKT,
- STAT_HIT_POLICY_B,
-
- // dev nf interface
- STAT_RAW_PKT_RX_PKT,
- STAT_RAW_PKT_RX_B,
-
- STAT_RAW_PKT_TX_PKT,
- STAT_RAW_PKT_TX_B,
-
- STAT_DECRYPTED_TX_PKT,
- STAT_DECRYPTED_TX_B,
- STAT_DECRYPTED_RX_PKT,
- STAT_DECRYPTED_RX_B,
-
- // control packet
- STAT_CONTROL_RX_PKT,
- STAT_CONTROL_RX_B,
- STAT_CONTROL_TX_PKT,
- STAT_CONTROL_TX_B,
-
- STAT_TAP_RX_PKT,
- STAT_TAP_RX_B,
- STAT_TAP_TX_PKT,
- STAT_TAP_TX_B,
-
- STAT_TAP_C_RX_PKT,
- STAT_TAP_C_RX_B,
- STAT_TAP_C_TX_PKT,
- STAT_TAP_C_TX_B,
-
- STAT_TAP_S_RX_PKT,
- STAT_TAP_S_RX_B,
- STAT_TAP_S_TX_PKT,
- STAT_TAP_S_TX_B,
-
- STAT_CTRL_PKT_OPENING,
- STAT_CTRL_PKT_ACTIVE,
- STAT_CTRL_PKT_CLOSING,
- STAT_CTRL_PKT_RESETALL,
- STAT_CTRL_PKT_ERROR,
-
- // send log
- STAT_SEND_LOG,
-
- // max
- STAT_MAX,
-};
-
-static const char *stat_map[] =
-{
- // hit policy
- [STAT_HIT_POLICY_PKT] = "hit_policy_pkt",
- [STAT_HIT_POLICY_B] = "hit_policy_B",
-
- // dev nf interface
- [STAT_RAW_PKT_RX_PKT] = "raw_rx_pkt",
- [STAT_RAW_PKT_RX_B] = "raw_rx_B",
-
- [STAT_RAW_PKT_TX_PKT] = "raw_tx_pkt",
- [STAT_RAW_PKT_TX_B] = "raw_tx_B",
-
- // decrypted
- [STAT_DECRYPTED_TX_PKT] = "decrypt_tx_pkt",
- [STAT_DECRYPTED_TX_B] = "decrypt_tx_B",
- [STAT_DECRYPTED_RX_PKT] = "decrypt_rx_pkt",
- [STAT_DECRYPTED_RX_B] = "decrypt_rx_B",
-
- // control packet
- [STAT_CONTROL_RX_PKT] = "ctrl_rx_pkt",
- [STAT_CONTROL_RX_B] = "ctrl_rx_B",
- [STAT_CONTROL_TX_PKT] = "ctrl_tx_pkt",
- [STAT_CONTROL_TX_B] = "ctrl_tx_B",
-
- // tap packet
- [STAT_TAP_RX_PKT] = "tap_rx_pkt",
- [STAT_TAP_RX_B] = "tap_rx_B",
- [STAT_TAP_TX_PKT] = "tap_tx_pkt",
- [STAT_TAP_TX_B] = "tap_tx_B",
- [STAT_TAP_C_RX_PKT] = "tap_c_rx_pkt",
- [STAT_TAP_C_RX_B] = "tap_c_rx_B",
- [STAT_TAP_C_TX_PKT] = "tap_c_tx_pkt",
- [STAT_TAP_C_TX_B] = "tap_c_tx_B",
- [STAT_TAP_S_RX_PKT] = "tap_s_rx_pkt",
- [STAT_TAP_S_RX_B] = "tap_s_rx_B",
- [STAT_TAP_S_TX_PKT] = "tap_s_tx_pkt",
- [STAT_TAP_S_TX_B] = "tap_s_tx_B",
-
- [STAT_CTRL_PKT_OPENING] = "ctrl_pkt_open",
- [STAT_CTRL_PKT_ACTIVE] = "ctrl_pkt_avtive",
- [STAT_CTRL_PKT_CLOSING] = "ctrl_pkt_close",
- [STAT_CTRL_PKT_RESETALL] = "ctrl_pkt_reset",
- [STAT_CTRL_PKT_ERROR] = "ctrl_pkt_error",
-
- // send log
- [STAT_SEND_LOG] = "send_log",
-
- [STAT_MAX] = NULL
-};
-
-struct global_metrics *global_metrics_create()
-{
- struct global_metrics *metrics = (struct global_metrics *)calloc(1, sizeof(struct global_metrics));
-
- metrics->fs_handle=tfe_proxy_get_fs_handle();
- for (int i = 0; i < STAT_MAX; i++)
- {
- metrics->fs_id[i] = FS_register(metrics->fs_handle, FS_STYLE_FIELD, FS_CALC_CURRENT, stat_map[i]);
- }
-
- return metrics;
-}
-
-void global_metrics_destory(struct global_metrics *metrics)
-{
- if (metrics)
- {
- free(metrics);
- metrics = NULL;
- }
-}
-
-void global_metrics_dump(struct global_metrics *metrics)
-{
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_HIT_POLICY_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->hit_policy.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_HIT_POLICY_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->hit_policy.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_RAW_PKT_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->raw_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_RAW_PKT_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->raw_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_RAW_PKT_TX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->raw_pkt_tx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_RAW_PKT_TX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->raw_pkt_tx.n_bytes), 0, __ATOMIC_RELAXED));
-
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_DECRYPTED_TX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->decrypt_tx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_DECRYPTED_TX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->decrypt_tx.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_DECRYPTED_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->decrypt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_DECRYPTED_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->decrypt_rx.n_bytes), 0, __ATOMIC_RELAXED));
-
- // control packet
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CONTROL_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CONTROL_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CONTROL_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CONTROL_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_TX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_TX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_C_RX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_C_RX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_C_TX_PKT], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_pkts), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_TAP_C_TX_B], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_rx.n_bytes), 0, __ATOMIC_RELAXED));
-
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CTRL_PKT_OPENING], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_opening_num), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CTRL_PKT_ACTIVE], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_active_num), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CTRL_PKT_CLOSING], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_closing_num), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CTRL_PKT_RESETALL], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_resetall_num), 0, __ATOMIC_RELAXED));
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_CTRL_PKT_ERROR], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->ctrl_pkt_error_num), 0, __ATOMIC_RELAXED));
-
- // send log
- FS_operate(metrics->fs_handle, metrics->fs_id[STAT_SEND_LOG], 0, FS_OP_SET, __atomic_fetch_add(&(metrics->send_log), 0, __ATOMIC_RELAXED));
-}
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-30 16:04:25 +0000