1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
use crossbeam_channel::RecvError;
use crossbeam_channel::SendError;
use std::error::Error;
use thiserror::Error;
pub type OCLStreamResult<T> = Result<T, OCLStreamError>;
#[derive(Error, Debug)]
pub enum OCLStreamError {
#[error("OpenCL Error {0}")]
OCLError(String),
#[error("Stream Receive Error")]
RecvError(#[from] RecvError),
#[error("Stream Send Error")]
SendError(#[from] Box<dyn Error + Send + Sync>),
}
impl From<ocl::Error> for OCLStreamError {
fn from(e: ocl::Error) -> Self {
Self::OCLError(format!("{}", e))
}
}
impl<T: 'static> From<SendError<T>> for OCLStreamError
where
T: Send + Sync,
{
fn from(e: SendError<T>) -> Self {
Self::SendError(Box::new(e))
}
}