summaryrefslogtreecommitdiff
path: root/infra/session_manager
diff options
context:
space:
mode:
authorlijia <[email protected]>2024-10-18 16:47:51 +0800
committerlijia <[email protected]>2024-11-07 18:30:58 +0800
commite734af76d81b07090c618b1c4af3b2fdd6b592f3 (patch)
treec9b894fb0eaa9c56bd5f04bfab5628a97592091d /infra/session_manager
parent99a68d5c9efe500ab339165a2af515a0a7355ada (diff)
rebase onto develop-2.0
Diffstat (limited to 'infra/session_manager')
-rw-r--r--infra/session_manager/session_manager.c10
-rw-r--r--infra/session_manager/session_manager_rte.h1
2 files changed, 11 insertions, 0 deletions
diff --git a/infra/session_manager/session_manager.c b/infra/session_manager/session_manager.c
index 21fb779..3691805 100644
--- a/infra/session_manager/session_manager.c
+++ b/infra/session_manager/session_manager.c
@@ -593,5 +593,15 @@ void session_manager_on_thread_exit(struct module_manager *mod_mgr, int thread_i
{
struct session_manager *sess_mgr = module_get_ctx(mod);
assert(sess_mgr);
+ assert(thread_id < (int)sess_mgr->cfg->thread_num);
+
session_manager_clean(sess_mgr, thread_id);
+}
+
+// temp add for show session command
+struct session_manager_rte *session_manager_get_runtime(struct session_manager *sess_mgr, uint16_t thread_id)
+{
+ assert(sess_mgr);
+ assert(thread_id < sess_mgr->cfg->thread_num);
+ return sess_mgr->rte[thread_id];
} \ No newline at end of file
diff --git a/infra/session_manager/session_manager_rte.h b/infra/session_manager/session_manager_rte.h
index de8c09c..f04dceb 100644
--- a/infra/session_manager/session_manager_rte.h
+++ b/infra/session_manager/session_manager_rte.h
@@ -7,6 +7,7 @@ extern "C"
#include "tuple.h"
#include "stellar/session.h"
+#include "session_manager_cfg.h"
enum session_scan_flags
{