From 657aa9f86f98da83cd713ad8455795bc834fc9bf Mon Sep 17 00:00:00 2001 From: Andy Duplain Date: Fri, 15 May 2026 14:43:18 +0100 Subject: [PATCH] Ensure storage is shutdown. --- common/client-core/surb-storage/src/backend/fs_backend/mod.rs | 4 +++- common/client-core/surb-storage/src/lib.rs | 1 + 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/common/client-core/surb-storage/src/backend/fs_backend/mod.rs b/common/client-core/surb-storage/src/backend/fs_backend/mod.rs index 625913e174..9c0c465433 100644 --- a/common/client-core/surb-storage/src/backend/fs_backend/mod.rs +++ b/common/client-core/surb-storage/src/backend/fs_backend/mod.rs @@ -337,6 +337,8 @@ impl ReplyStorageBackend for Backend { } async fn stop_storage_session(self) -> Result<(), Self::StorageError> { - self.stop_client_use().await + let result = self.stop_client_use().await; + self.shutdown().await; + result } } diff --git a/common/client-core/surb-storage/src/lib.rs b/common/client-core/surb-storage/src/lib.rs index ffd7ad85f6..f88a746ad2 100644 --- a/common/client-core/surb-storage/src/lib.rs +++ b/common/client-core/surb-storage/src/lib.rs @@ -48,6 +48,7 @@ where debug!("Started PersistentReplyStorage"); if let Err(err) = self.backend.start_storage_session().await { error!("failed to start the storage session - {err}"); + self.backend.stop_storage_session().await.ok(); return; }