feat(session_manager): init return with handle

This commit is contained in:
yangwei
2022-07-24 23:22:52 +08:00
parent 6f558132a1
commit ba866fef10
4 changed files with 18 additions and 14 deletions

View File

@@ -6,6 +6,7 @@
struct stellar_event_base_loop_arg
{
struct packet_io_device *dev;
struct session_manager_handle *s_mgr;
int thread_id;
};
@@ -18,11 +19,11 @@ void stellar_event_base_loop(struct stellar_event_base_loop_arg *arg)
int fetch_num = packet_io_rx(arg->dev, arg->thread_id, &rx_pkt, 1);
if(fetch_num > 0)
{
event = session_manager_commit(rx_pkt);
event = session_manager_commit(arg->s_mgr, rx_pkt);
while(event)
{
plugin_manager_dispatch(event);
event = session_manager_fetch_event();
event = session_manager_fetch_event(arg->s_mgr);
}
//clean session_manager event queue
@@ -48,8 +49,8 @@ struct packet_io_device *packet_io_init(int worker_thread_num, const char *insta
int main(int argc, char ** argv)
{
//config_manager_init
//config_init
struct session_manager_handle *h = session_manager_init();
plugin_session_event_register("HTTP", http_decoder, nullptr);
//packet_io_init

View File

@@ -5,6 +5,12 @@ struct session_manager
struct stellar_session **tcp_table, **udp_table;
};
struct session_manager_handle *session_manager_init()
{
return nullptr;
}
void session_manager_trigger_event(struct stellar_session *s,
stellar_session_event_type type,
struct stellar_session_event_extras *info)
@@ -18,13 +24,13 @@ struct stellar_session *session_manager_session_derive(const struct stellar_sess
return nullptr;
}
struct stellar_event *session_manager_commit(struct stellar_packet *p)
struct stellar_event *session_manager_commit(struct session_manager_handle *h, struct stellar_packet *p)
{
return nullptr;
};
struct stellar_event *session_manager_fetch_event()
struct stellar_event *session_manager_fetch_event(struct session_manager_handle *h)
{
return nullptr;
}

View File

@@ -12,8 +12,11 @@ struct stellar_session_event_data
struct stellar_plugin_data *plugin_data;
};
struct stellar_event *session_manager_commit(struct stellar_packet *pkt);
struct stellar_event *session_manager_fetch_event();
struct session_manager_handle;
struct session_manager_handle *session_manager_init();
struct stellar_event *session_manager_commit(struct session_manager_handle *s_mgr, struct stellar_packet *pkt);
struct stellar_event *session_manager_fetch_event(struct session_manager_handle *s_mgr);
struct stellar_session
{