diff options
| -rw-r--r-- | src/plugin_manager/plugin_manager.c | 3 | ||||
| -rw-r--r-- | src/stellar_on_sapp/stellar_on_sapp_api.c | 2 |
2 files changed, 4 insertions, 1 deletions
diff --git a/src/plugin_manager/plugin_manager.c b/src/plugin_manager/plugin_manager.c index 3f3fead..9f9d8cf 100644 --- a/src/plugin_manager/plugin_manager.c +++ b/src/plugin_manager/plugin_manager.c @@ -889,7 +889,8 @@ void stellar_session_plugin_dettach_current_session(struct session *sess) if(session_plugin_schema==NULL)return; struct stellar_mq_topic_schema *topic=NULL; unsigned int plugin_subscriber_num = utarray_len(session_plugin_schema->registed_session_mq_subscriber_info); - //FIXME: maybe no need to clear session_mq_status, check plugin_ctx before message dispatch + //Won't Do: maybe no need to clear session_mq_status, check plugin_ctx before message dispatch + //allow plugin register with null ctx_new and ctx_free if(plug_mgr_rt->session_mq_status) { for(unsigned int i=0; i < plugin_subscriber_num; i++) diff --git a/src/stellar_on_sapp/stellar_on_sapp_api.c b/src/stellar_on_sapp/stellar_on_sapp_api.c index 72935c6..d6ec43a 100644 --- a/src/stellar_on_sapp/stellar_on_sapp_api.c +++ b/src/stellar_on_sapp/stellar_on_sapp_api.c @@ -197,6 +197,8 @@ void packet_update_on_sapp(struct stellar *st, struct streaminfo *pstream, void } //FIXME: defer TCP/UDP packet on session update plugin_manager_on_packet_ingress(st->plug_mgr, &pkt); + + // TODO: create transient icmp session } inline int polling_on_sapp(struct stellar *st) |