diff options
Diffstat (limited to 'src/quic_entry.cpp')
| -rw-r--r-- | src/quic_entry.cpp | 22 |
1 files changed, 6 insertions, 16 deletions
diff --git a/src/quic_entry.cpp b/src/quic_entry.cpp index 5881c2a..4e9f6b1 100644 --- a/src/quic_entry.cpp +++ b/src/quic_entry.cpp @@ -172,22 +172,11 @@ extern "C" unsigned char QUIC_ENTRY(struct streaminfo *pstream, void**pme, int t quic_init_context(pme, thread_seq); context=(struct quic_context *)*pme; } - - switch(pstream->opstate) - { - case OP_STATE_PENDING: - state=quic_analyze_entry(pstream, context, thread_seq, a_packet); - break; - case OP_STATE_DATA: - state=quic_call_business_plug(pstream, context, (char *)pstream->pudpdetail->pdata, pstream->pudpdetail->datalen, QUIC_APPLICATION_DATA_MASK, a_packet); - break; - case OP_STATE_CLOSE: - if(pstream->pudpdetail->pdata!=NULL && pstream->pudpdetail->datalen>0) - { - state=quic_call_business_plug(pstream, context, (char *)pstream->pudpdetail->pdata, pstream->pudpdetail->datalen, QUIC_APPLICATION_DATA_MASK, a_packet); - } - state=quic_call_business_plug(pstream, context, NULL, 0, QUIC_INTEREST_KEY_MASK, a_packet); - break; + + state=quic_analyze_entry(pstream, context, thread_seq, a_packet); + if(pstream->opstate==OP_STATE_CLOSE) + { + state=quic_call_business_plug(pstream, context, NULL, 0, QUIC_INTEREST_KEY_MASK, a_packet); } if(state&APP_STATE_DROPME || state&APP_STATE_DROPPKT || pstream->opstate==OP_STATE_CLOSE) @@ -214,6 +203,7 @@ extern "C" int QUIC_INIT(void) MESA_load_profile_string_def(g_quic_proto_conffile, "QUIC", "LOG_PATH", g_quic_param.log_path, sizeof(g_quic_param.log_path), "./log/quic/quic"); MESA_load_profile_int_def(g_quic_proto_conffile, "QUIC", "DECRYPTED_SWITCH", &g_quic_param.decrypted_switch, 2); + MESA_load_profile_int_def(g_quic_proto_conffile, "QUIC", "MAX_PARSE_PKT_NUM", &g_quic_param.max_parse_pkt_num, 3); MESA_load_profile_string_def(g_quic_proto_conffile, "QUIC", "QUIC_PORT_LIST", buff, sizeof(buff), "443;8443;"); g_quic_param.quic_port_num=parse_quic_port(buff, g_quic_param.quic_port_list, SUPPORT_QUIC_PORT_NUM); |