diff options
| author | yangwei <[email protected]> | 2024-07-09 19:22:03 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-07-09 19:22:03 +0800 |
| commit | bd599decb93fa9fd2955289cd96c362b703b2ad1 (patch) | |
| tree | 0fa617c6ab28d44b240d796bfeb1addaefef571a /include | |
| parent | 19969f6fc7383b6b3b62fc8a3b13a4ae8dd6dc8b (diff) | |
🎈 perf(session_state_update_on_sapp): drop tcp when topic inactive
Diffstat (limited to 'include')
| -rw-r--r-- | include/stellar/session_mq.h | 2 | ||||
| -rw-r--r-- | include/stellar/stellar.h | 3 |
2 files changed, 4 insertions, 1 deletions
diff --git a/include/stellar/session_mq.h b/include/stellar/session_mq.h index cddde81..a3a631a 100644 --- a/include/stellar/session_mq.h +++ b/include/stellar/session_mq.h @@ -22,3 +22,5 @@ int session_mq_publish_message(struct session *sess, int topic_id, void *msg); int session_mq_ignore_message(struct session *sess, int topic_id, int plugin_id); int session_mq_unignore_message(struct session *sess, int topic_id, int plugin_id); + +int session_mq_topic_is_active(struct session *sess, int topic_id);
\ No newline at end of file diff --git a/include/stellar/stellar.h b/include/stellar/stellar.h index 5176239..e9322be 100644 --- a/include/stellar/stellar.h +++ b/include/stellar/stellar.h @@ -14,7 +14,8 @@ typedef void plugin_on_unload_func(void *plugin_env); typedef void *session_ctx_new_func(struct session *sess, void *plugin_env); typedef void session_ctx_free_func(struct session *sess, void *session_ctx, void *plugin_env); -#define TOPIC_TCP "TCP" +//intrinsic topic, publish packet as message +#define TOPIC_TCP "TCP" #define TOPIC_TCP_STREAM "TCP_STREAM" #define TOPIC_UDP "UDP" #define TOPIC_EGRESS "EGRESS" |