From 4580906405757caae438cc5260c2e0b18f651cb4 Mon Sep 17 00:00:00 2001 From: ieQu1 <99872536+ieQu1@users.noreply.github.com> Date: Tue, 21 May 2024 17:40:18 +0200 Subject: [PATCH] fix(ds): Use erpc instead of gen_rpc for `delete_next' --- apps/emqx_durable_storage/src/proto/emqx_ds_proto_v4.erl | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/apps/emqx_durable_storage/src/proto/emqx_ds_proto_v4.erl b/apps/emqx_durable_storage/src/proto/emqx_ds_proto_v4.erl index 62ea33c3e..a53791feb 100644 --- a/apps/emqx_durable_storage/src/proto/emqx_ds_proto_v4.erl +++ b/apps/emqx_durable_storage/src/proto/emqx_ds_proto_v4.erl @@ -179,8 +179,7 @@ make_delete_iterator(Node, DB, Shard, Stream, TopicFilter, StartTime) -> | {ok, end_of_stream} | {error, _}. delete_next(Node, DB, Shard, Iter, Selector, BatchSize) -> - emqx_rpc:call( - Shard, + erpc:call( Node, emqx_ds_replication_layer, do_delete_next_v4,