make subsystem errors more specific

Author: drahnr

node/core/av-store/src/lib.rs

@@ -51,13 +51,13 @@ mod columns {
 #[derive(Debug, Error)]
 enum Error {
 	#[error(transparent)]
-	Erasure(erasure::Error),
+	Erasure(#[from]erasure::Error),
 	#[error(transparent)]
-	Io(io::Error),
+	Io(#[from]io::Error),
 	#[error(transparent)]
-	Oneshot(oneshot::Canceled),
+	Oneshot(#[from]oneshot::Canceled),
 	#[error(transparent)]
-	Subsystem(SubsystemError),
+	Subsystem(#[from]SubsystemError),
 }
 
 /// An implementation of the Availability Store subsystem.

node/core/backing/src/lib.rs

@@ -73,15 +73,15 @@ enum Error {
 	CandidateNotFound,
 	#[error("Signature is invalid")]
 	InvalidSignature,
-	#[error("Storing data was not successful")]
-	StoreFailed,
-	#[error(transparent)]
-	Erasure(erasure_coding::Error),
+	#[error("Storing data failed")]
+	StoreFailed(oneshot::Canceled),
+	#[error("Responding to backing request failed")]
+	BackingResponseChannel(oneshot::Canceled),
+	#[error("Obtaining erasure chunks failed")]
+	ObtainErasureChunks(#[from] #[source]erasure_coding::Error),
 	#[error(transparent)]
 	ValidationFailed(ValidationFailed),
 	#[error(transparent)]
-	Oneshot(oneshot::Canceled),
-	#[error(transparent)]
 	Mpsc(mpsc::SendError),
 	#[error(transparent)]
 	UtilError(util::Error),
@@ -472,7 +472,7 @@ impl CandidateBackingJob {
 			CandidateBackingMessage::GetBackedCandidates(_, tx) => {
 				let backed = self.get_backed();
 
-				tx.send(backed).map_err(|_| oneshot::Canceled)?;
+				tx.send(backed).map_err(|e| Error::BackingResponseChannel(e))?;
 			}
 		}
 
@@ -643,7 +643,7 @@ impl CandidateBackingJob {
 			)
 		).await?;
 
-		rx.await?.map_err(|_| Error::StoreFailed)?;
+		rx.await?.map_err(|e| Error::StoreFailed(e))?;
 
 		Ok(())
 	}