From 09905d78cd86f459c1b1cf6958ee230f748c0419 Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Tue, 5 Mar 2024 20:26:53 +0100 Subject: [PATCH] chore(ds): make error handling slightly simpler Co-Authored-By: Thales Macedo Garitezi --- apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl b/apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl index 1b5f21a11..1738867b5 100644 --- a/apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl +++ b/apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl @@ -171,9 +171,8 @@ drop_db(DB) -> -spec store_batch(emqx_ds:db(), [emqx_types:message(), ...], emqx_ds:message_store_opts()) -> emqx_ds:store_batch_result(). store_batch(DB, Messages, Opts) -> - try emqx_ds_replication_layer_egress:store_batch(DB, Messages, Opts) of - ok -> - ok + try + emqx_ds_replication_layer_egress:store_batch(DB, Messages, Opts) catch error:{Reason, _Call} when Reason == timeout; Reason == noproc -> {error, recoverable, Reason}