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_session_table.cpp | |
| parent | a59b9390336dafa0ee1f05e74e52411d175b9843 (diff) | |
TSG-21854 TFE使用fieldstat4序列化Manipulation Policy的metric并输出到kafka
Diffstat (limited to 'common/src/tfe_session_table.cpp')
| -rw-r--r-- | common/src/tfe_session_table.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/common/src/tfe_session_table.cpp b/common/src/tfe_session_table.cpp index 237537b..d9fac5e 100644 --- a/common/src/tfe_session_table.cpp +++ b/common/src/tfe_session_table.cpp @@ -212,7 +212,7 @@ struct session_node *session_table_search_by_addr(struct session_table *table, c return temp; } -void session_foreach(struct session_table *table, void (*func)(struct session_node *, void *), void *ctx) +void session_foreach(struct session_table *table, struct fieldstat_easy_intercept *metrics, int (*func)(struct fieldstat_easy_intercept *, void *, int), int thread_index) { struct session_node *temp = NULL; struct session_node *node = NULL; @@ -222,7 +222,7 @@ void session_foreach(struct session_table *table, void (*func)(struct session_no HASH_ITER(hh1, table->root_by_id, node, temp) { - func(node, ctx); + func(metrics, node->val_data, thread_index); } return; }
\ No newline at end of file |