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

fix: set queuing to 0 after buffer worker termination

This commit is contained in:
Thales Macedo Garitezi 2023-01-12 16:19:02 -03:00
parent 81fc561ed5
commit d6a9d0aa48
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx_resource/src/emqx_resource_worker.erl
View File

@ -238,10 +238,12 @@ blocked(info, Info, _Data) ->
keep_state_and_data. keep_state_and_data.
terminate(_Reason, #{id := Id, index := Index, queue := Q}) -> terminate(_Reason, #{id := Id, index := Index, queue := Q}) ->
emqx_resource_metrics:inflight_set(Id, Index, 0),
emqx_resource_metrics:queuing_set(Id, Index, queue_count(Q)),
gproc_pool:disconnect_worker(Id, {Id, Index}),
replayq:close(Q), replayq:close(Q),
emqx_resource_metrics:inflight_set(Id, Index, 0),
%% since we want volatile queues, this will be 0 after
%% termination.
emqx_resource_metrics:queuing_set(Id, Index, 0),
gproc_pool:disconnect_worker(Id, {Id, Index}),
ok. ok.
code_change(_OldVsn, State, _Extra) -> code_change(_OldVsn, State, _Extra) ->