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;