diff options
| author | yangwei <[email protected]> | 2024-07-09 19:15:35 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-07-09 19:15:35 +0800 |
| commit | 19969f6fc7383b6b3b62fc8a3b13a4ae8dd6dc8b (patch) | |
| tree | b777425cc5fc84ec82c3f447da37165941079df0 /src/plugin_manager/plugin_manager.c | |
| parent | e5991f8529d8adba0c8809051e59ddece28f1fc6 (diff) | |
🐞 fix(message dispatch): update current plugin id before msg_cbv2.1.3
Diffstat (limited to 'src/plugin_manager/plugin_manager.c')
| -rw-r--r-- | src/plugin_manager/plugin_manager.c | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/plugin_manager/plugin_manager.c b/src/plugin_manager/plugin_manager.c index 3eeeb21..07de496 100644 --- a/src/plugin_manager/plugin_manager.c +++ b/src/plugin_manager/plugin_manager.c @@ -551,6 +551,7 @@ static void plugin_manager_session_message_dispatch(struct session *sess) int cur_sub_idx = 0; DL_FOREACH_SAFE(topic->subscribers, sub_elt, sub_tmp) { + plug_mgr_rt->current_session_plugin_id=sub_elt->plugin_idx; if (bitmap_get(plug_mgr_rt->session_mq_status, mq_elt->topic_id, cur_sub_idx) != 0) { plugin_ctx_rt=(plug_mgr_rt->plugin_ctx_array+sub_elt->plugin_idx); |