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

refactor(buffer_worker): no need to return after collect into buf queue

This commit is contained in:
Zaiming (Stone) Shi 2023-01-26 14:50:40 +01:00
parent 25b4821adc
commit ed28789164
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqx_resource/src/emqx_resource_buffer_worker.erl
View File

@ -243,7 +243,7 @@ blocked(cast, flush, Data) ->
blocked(state_timeout, unblock, St) -> blocked(state_timeout, unblock, St) ->
resume_from_blocked(St); resume_from_blocked(St);
blocked(info, ?SEND_REQ(_ReqFrom, {query, _Request, _Opts}) = Request0, Data0) -> blocked(info, ?SEND_REQ(_ReqFrom, {query, _Request, _Opts}) = Request0, Data0) ->
{_Queries, Data} = collect_and_enqueue_query_requests(Request0, Data0), Data = collect_and_enqueue_query_requests(Request0, Data0),
{keep_state, Data}; {keep_state, Data};
blocked(info, {flush, _Ref}, _Data) -> blocked(info, {flush, _Ref}, _Data) ->
keep_state_and_data; keep_state_and_data;
@ -412,7 +412,7 @@ retry_inflight_sync(Ref, QueryOrBatch, Data0) ->
-spec handle_query_requests(?SEND_REQ(request_from(), request()), data()) -> -spec handle_query_requests(?SEND_REQ(request_from(), request()), data()) ->
gen_statem:event_handler_result(state(), data()). gen_statem:event_handler_result(state(), data()).
handle_query_requests(Request0, Data0) -> handle_query_requests(Request0, Data0) ->
{_Queries, Data} = collect_and_enqueue_query_requests(Request0, Data0), Data = collect_and_enqueue_query_requests(Request0, Data0),
maybe_flush(Data). maybe_flush(Data).
collect_and_enqueue_query_requests(Request0, Data0) -> collect_and_enqueue_query_requests(Request0, Data0) ->
@ -438,8 +438,7 @@ collect_and_enqueue_query_requests(Request0, Data0) ->
Requests Requests
), ),
{_Overflow, NewQ} = append_queue(Id, Index, Q, Queries), {_Overflow, NewQ} = append_queue(Id, Index, Q, Queries),
Data = Data0#{queue := NewQ}, Data0#{queue := NewQ}.
{Queries, Data}.
maybe_flush(Data0) -> maybe_flush(Data0) ->
#{ #{