yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(emqx_connection): handle socket activation error return

This commit is contained in:
Zaiming (Stone) Shi 2023-11-20 16:51:39 +01:00
parent 010dc2b271
commit 8ec3b1db5d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_connection.erl
View File

@ -555,7 +555,7 @@ handle_msg({quic, Data, _Stream, #{len := Len}}, State) when is_binary(Data) ->
handle_msg(check_cache, #state{limiter_buffer = Cache} = State) -> handle_msg(check_cache, #state{limiter_buffer = Cache} = State) ->
case queue:peek(Cache) of case queue:peek(Cache) of
empty -> empty ->
activate_socket(State); handle_info(activate_socket, State);
{value, #pending_req{need = Needs, data = Data, next = Next}} -> {value, #pending_req{need = Needs, data = Data, next = Next}} ->
State2 = State#state{limiter_buffer = queue:drop(Cache)}, State2 = State#state{limiter_buffer = queue:drop(Cache)},
check_limiter(Needs, Data, Next, [check_cache], State2) check_limiter(Needs, Data, Next, [check_cache], State2)