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

refactor: enter running state directly 

now that we don't have the possibility of dirty disk queues (we always
use volatile replayq), we will never resume old work.
This commit is contained in:
Thales Macedo Garitezi 2023-01-16 18:09:05 -03:00
parent bd0e2a74ba
commit b5aaef084c
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -189,7 +189,7 @@ init({Id, Index, Opts}) ->
tref => undefined tref => undefined
}, },
?tp(resource_worker_init, #{id => Id, index => Index}), ?tp(resource_worker_init, #{id => Id, index => Index}),
{ok, blocked, Data, {next_event, cast, resume}}. {ok, running, Data}.
running(enter, _, St) -> running(enter, _, St) ->
?tp(resource_worker_enter_running, #{}), ?tp(resource_worker_enter_running, #{}),

2
apps/emqx_resource/test/emqx_resource_SUITE.erl
View File

@ -1200,7 +1200,7 @@ t_delete_and_re_create_with_same_name(_Config) ->
resume_interval => 1_000 resume_interval => 1_000
} }
), ),
#{?snk_kind := resource_worker_enter_blocked}, #{?snk_kind := resource_worker_enter_running},
5_000 5_000
), ),