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

fix(dsrepl): Retry sending ra commands to the leader

This commit is contained in:
ieQu1 2024-05-24 19:07:12 +02:00
parent 53620e8439
commit 66ec2e6ad0
No known key found for this signature in database
GPG Key ID: 488654DF3FED6FDE
1 changed files with 8 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl
View File

@ -609,13 +609,7 @@ ra_add_generation(DB, Shard) ->
?tag => add_generation,
?since => emqx_ds:timestamp_us()
},
Servers = emqx_ds_replication_layer_shard:servers(DB, Shard, leader_preferred),
case ra:process_command(Servers, Command, ?RA_TIMEOUT) of
{ok, Result, _Leader} ->
Result;
Error ->
error(Error, [DB, Shard])
end.
ra_command(DB, Shard, Command, 10).
ra_update_config(DB, Shard, Opts) ->
Command = #{
@ -623,20 +617,20 @@ ra_update_config(DB, Shard, Opts) ->
?config => Opts,
?since => emqx_ds:timestamp_us()
},
Servers = emqx_ds_replication_layer_shard:servers(DB, Shard, leader_preferred),
case ra:process_command(Servers, Command, ?RA_TIMEOUT) of
{ok, Result, _Leader} ->
Result;
Error ->
error(Error, [DB, Shard])
end.
ra_command(DB, Shard, Command, 10).
ra_drop_generation(DB, Shard, GenId) ->
Command = #{?tag => drop_generation, ?generation => GenId},
ra_command(DB, Shard, Command, 10).
ra_command(DB, Shard, Command, Retries) ->
Servers = emqx_ds_replication_layer_shard:servers(DB, Shard, leader_preferred),
case ra:process_command(Servers, Command, ?RA_TIMEOUT) of
{ok, Result, _Leader} ->
Result;
_Error when Retries > 0 ->
timer:sleep(?RA_TIMEOUT),
ra_command(DB, Shard, Command, Retries - 1);
Error ->
error(Error, [DB, Shard])
end.