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

Merge pull request #12705 from thalesmg/ds-fix-call-timeout-m-20240314 

fix(ds): use `infinity` timeout when storing batches
This commit is contained in:
Thales Macedo Garitezi 2024-03-14 12:56:41 -03:00 committed by GitHub
parent 657e87c2ea 2ebc8dcc55
commit 2cc3377edc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
apps/emqx_durable_storage/src/emqx_ds_replication_layer_egress.erl
View File

@ -70,20 +70,28 @@ store_batch(DB, Messages, Opts) ->
lists:foreach( lists:foreach(
fun(Message) -> fun(Message) ->
Shard = emqx_ds_replication_layer:shard_of_message(DB, Message, clientid), Shard = emqx_ds_replication_layer:shard_of_message(DB, Message, clientid),
gen_server:call(?via(DB, Shard), #enqueue_req{ gen_server:call(
message = Message, ?via(DB, Shard),
sync = Sync #enqueue_req{
}) message = Message,
sync = Sync
},
infinity
)
end, end,
Messages Messages
); );
true -> true ->
maps:foreach( maps:foreach(
fun(Shard, Batch) -> fun(Shard, Batch) ->
gen_server:call(?via(DB, Shard), #enqueue_atomic_req{ gen_server:call(
batch = Batch, ?via(DB, Shard),
sync = Sync #enqueue_atomic_req{
}) batch = Batch,
sync = Sync
},
infinity
)
end, end,
maps:groups_from_list( maps:groups_from_list(
fun(Message) -> fun(Message) ->