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

refactor(buffer_worker): rename function 

from reply_after_query to handle_async_reply
This commit is contained in:
Zaiming (Stone) Shi 2023-01-27 15:03:18 +01:00
parent 6a58bafcb0
commit 262c3a2869
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -52,7 +52,7 @@
-export([queue_item_marshaller/1, estimate_size/1]). -export([queue_item_marshaller/1, estimate_size/1]).
-export([reply_after_query/8, batch_reply_after_query/8]). -export([handle_async_reply/8, batch_reply_after_query/8]).
-export([clear_disk_queue_dir/2]). -export([clear_disk_queue_dir/2]).
@ -898,7 +898,7 @@ apply_query_fun(async, Mod, Id, Index, Ref, ?QUERY(_, Request, _, _) = Query, Re
?APPLY_RESOURCE( ?APPLY_RESOURCE(
call_query_async, call_query_async,
begin begin
ReplyFun = fun ?MODULE:reply_after_query/8, ReplyFun = fun ?MODULE:handle_async_reply/8,
Args = [self(), Id, Index, InflightTID, Ref, Query, QueryOpts], Args = [self(), Id, Index, InflightTID, Ref, Query, QueryOpts],
IsRetriable = false, IsRetriable = false,
WorkerMRef = undefined, WorkerMRef = undefined,
@ -936,7 +936,7 @@ apply_query_fun(async, Mod, Id, Index, Ref, [?QUERY(_, _, _, _) | _] = Batch, Re
Batch Batch
). ).
reply_after_query( handle_async_reply(
Pid, Pid,
Id, Id,
Index, Index,