diff options
| author | liuxueli <[email protected]> | 2023-02-16 10:20:46 +0800 |
|---|---|---|
| committer | liuxueli <[email protected]> | 2023-02-16 10:20:46 +0800 |
| commit | 96f9ce34caf15f1b271a4dab5f4307bd99067e1c (patch) | |
| tree | 8501ff69da55ffdde9d4b2425072f5f3e729531c | |
| parent | ffb443ed7e09dcb7c4f9e115223aa24ce94c452b (diff) | |
收到上层业务返回drop pkt状态时,不关闭对流的处理v2.0.5
| -rw-r--r-- | src/quic_entry.cpp | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/quic_entry.cpp b/src/quic_entry.cpp index 6c7a7c2..dfa5566 100644 --- a/src/quic_entry.cpp +++ b/src/quic_entry.cpp @@ -173,14 +173,11 @@ extern "C" unsigned char QUIC_ENTRY(struct streaminfo *pstream, void**pme, int t context=(struct quic_context *)*pme; } - 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); - } + state=quic_analyze_entry(pstream, context, thread_seq, a_packet); - if(state&APP_STATE_DROPME || state&APP_STATE_DROPPKT || pstream->opstate==OP_STATE_CLOSE) - { + if(state&APP_STATE_DROPME || pstream->opstate==OP_STATE_CLOSE) + { + quic_call_business_plug(pstream, context, NULL, 0, QUIC_INTEREST_KEY_MASK, a_packet); quic_free_context(pme, thread_seq); *pme=NULL; return state; |
