🦄 refactor(stellar api): split exdata and mq

1 files changed, 10 insertions, 10 deletions

diff --git a/infra/stellar_core.c b/infra/stellar_core.c
index ac307aa..f72574e 100644
--- a/infra/stellar_core.c
+++ b/infra/stellar_core.c
@@ -109,7 +109,7 @@ static inline void clean_session(struct session_manager *sess_mgr, uint64_t now_
     for (uint64_t j = 0; j < nr_sess_cleaned; j++)
     {
         sess = cleaned_sess[j];
-        session_exdata_runtime_free(session_get_user_data(sess));
+        //session_exdata_runtime_free(session_get_user_data(sess));
         session_manager_free_session(sess_mgr, sess);
     }
 }
@@ -183,7 +183,7 @@ static void *worker_thread(void *arg)
             defraged_pkt = NULL;
             pkt = &packets[i];
 
-            plugin_manager_on_packet_input(plug_mgr, pkt);
+            //plugin_manager_on_packet_input(plug_mgr, pkt);
             if (packet_is_fragment(pkt))
             {
                 defraged_pkt = ip_reassembly_packet(ip_reass, pkt, now_ms);
@@ -194,7 +194,7 @@ static void *worker_thread(void *arg)
                 else
                 {
                     pkt = defraged_pkt;
-                    plugin_manager_on_packet_input(plug_mgr, defraged_pkt);
+                    //plugin_manager_on_packet_input(plug_mgr, defraged_pkt);
                 }
             }
 
@@ -206,8 +206,8 @@ static void *worker_thread(void *arg)
                 {
                     goto fast_path;
                 }
-                struct exdata_runtime *per_sess_exdata=session_exdata_runtime_new(st);
-                session_set_user_data(sess, per_sess_exdata);
+                //struct exdata_runtime *per_sess_exdata=session_exdata_runtime_new(st);
+                //session_set_user_data(sess, per_sess_exdata);
             }
             else
             {
@@ -220,12 +220,12 @@ static void *worker_thread(void *arg)
         fast_path:
             if (pkt == defraged_pkt)
             {
-                plugin_manager_on_packet_output(plug_mgr, defraged_pkt);
-                plugin_manager_on_packet_output(plug_mgr, &packets[i]);
+                //plugin_manager_on_packet_output(plug_mgr, defraged_pkt);
+                //plugin_manager_on_packet_output(plug_mgr, &packets[i]);
             }
             else
             {
-                plugin_manager_on_packet_output(plug_mgr, pkt);
+                //plugin_manager_on_packet_output(plug_mgr, pkt);
             }
 
             if (sess)
@@ -272,7 +272,7 @@ static void *worker_thread(void *arg)
     idle_tasks:
         clean_session(sess_mgr, now_ms);
         ip_reassembly_expire(ip_reass, now_ms);
-        plugin_manager_on_polling(plug_mgr);
+        //plugin_manager_on_polling(plug_mgr);
         stellar_stat_merge(runtime->stat, &thr_stat, thr_idx, now_ms);
 
         if (nr_pkt_received == 0)
@@ -448,7 +448,7 @@ struct stellar *stellar_new(const char *stellar_cfg_file, const char *plugin_cfg
         CORE_LOG_ERROR("unable to create stellar stat");
         goto error_out;
     }
-    runtime->plug_mgr = plugin_manager_init(st, plugin_cfg_file, MAX_MSG_PER_STAGE);
+    runtime->plug_mgr = plugin_manager_init(st, plugin_cfg_file);
     if (runtime->plug_mgr == NULL)
     {
         CORE_LOG_ERROR("unable to create plugin manager");