From 30a227bd3832e8749b008ab6ab847de55f82e85a Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Fri, 13 Jan 2023 10:26:11 -0300 Subject: [PATCH] refactor: rename `resume` state timeout to `unblock` --- apps/emqx_resource/src/emqx_resource_worker.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl index d3b797fd5..4e9e75085 100644 --- a/apps/emqx_resource/src/emqx_resource_worker.erl +++ b/apps/emqx_resource/src/emqx_resource_worker.erl @@ -206,12 +206,12 @@ running(info, Info, _St) -> blocked(enter, _, #{resume_interval := ResumeT} = _St) -> ?tp(resource_worker_enter_blocked, #{}), - {keep_state_and_data, {state_timeout, ResumeT, resume}}; + {keep_state_and_data, {state_timeout, ResumeT, unblock}}; blocked(cast, block, _St) -> keep_state_and_data; blocked(cast, resume, St) -> resume_from_blocked(St); -blocked(state_timeout, resume, St) -> +blocked(state_timeout, unblock, St) -> resume_from_blocked(St); blocked(info, ?SEND_REQ(_ReqFrom, {query, _Request, _Opts}) = Request0, Data0) -> #{id := Id} = Data0, @@ -310,7 +310,7 @@ retry_inflight_sync(Ref, QueryOrBatch, Data0) -> {true, PostFn} -> PostFn(), ?tp(resource_worker_retry_inflight_failed, #{query_or_batch => QueryOrBatch}), - {keep_state, Data0, {state_timeout, ResumeT, resume}}; + {keep_state, Data0, {state_timeout, ResumeT, unblock}}; %% Send ok or failed but the resource is working {false, PostFn} -> IsAcked = ack_inflight(InflightTID, Ref, Id, Index),