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; }