From e481bd8bae5f83ccf39ba212d8e68e55db62bb86 Mon Sep 17 00:00:00 2001 From: x Date: Wed, 30 Aug 2023 10:33:01 +0200 Subject: [PATCH] add Error::SeedFailed --- src/error.rs | 3 +++ src/net/session/seedsync_session.rs | 2 +- src/system/stoppable_task.rs | 2 +- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/src/error.rs b/src/error.rs index 1a4ed41dd..48aaca6e7 100644 --- a/src/error.rs +++ b/src/error.rs @@ -140,6 +140,9 @@ pub enum Error { #[error("Channel timed out")] ChannelTimeout, + #[error("Failed to reach any seeds")] + SeedFailed, + #[error("Network service stopped")] NetworkServiceStopped, diff --git a/src/net/session/seedsync_session.rs b/src/net/session/seedsync_session.rs index ff6c6db93..4b3fd0fe4 100644 --- a/src/net/session/seedsync_session.rs +++ b/src/net/session/seedsync_session.rs @@ -111,7 +111,7 @@ impl SeedSyncSession { join_all(tasks).await; if failed.load(Ordering::SeqCst) == settings.seeds.len() { - return Err(Error::ConnectFailed) + return Err(Error::SeedFailed) } // Seed process complete diff --git a/src/system/stoppable_task.rs b/src/system/stoppable_task.rs index f59ad5fe0..a97820a0d 100644 --- a/src/system/stoppable_task.rs +++ b/src/system/stoppable_task.rs @@ -54,7 +54,7 @@ impl StoppableTask { Arc::new(Self { stop_send, stop_recv, stop_barrier: CondVar::new() }) } - /// Stops the task + /// Stops the task. Will return when the process has fully closed. pub async fn stop(&self) { // Ignore any errors from this send let _ = self.stop_send.send(()).await;