Searched defs:ScheduleError (Results 1 – 5 of 5) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | error.rs | 20 pub struct ScheduleError { struct
24 impl Debug for ScheduleError { implementation
30 impl Display for ScheduleError { implementation
92 impl From<ErrorKind> for ScheduleError { implementation
111 impl ScheduleError { implementation
132 fn _new(kind: ErrorKind, error: Box<dyn std::error::Error + Send + Sync>) -> ScheduleError { in _new()
194 impl std::error::Error for ScheduleError {} implementation
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | task_handle.rs | 59 fn finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in finish() argument
89 pub(crate) fn get_result(self, out: &mut Poll<std::result::Result<T::Output, ScheduleError>>) { in get_result() argument
243 fn get_canceled(&self) -> ScheduleError { in get_canceled()
340 fn ffrt_get_canceled(&self) -> ScheduleError { in ffrt_get_canceled()
|
| H A D | join_set.rs | 209 pub async fn join_next(&mut self) -> Option<Result<R, ScheduleError>> { in join_next() argument
215 pub async fn join_all(&mut self) -> Result<(), ScheduleError> { in join_all() argument
284 fn poll_join_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<R, ScheduleError>>> { in poll_join_next() argument
|
| H A D | raw.rs | 231 fn turning_to_store_data(&self, output: std::result::Result<T::Output, ScheduleError>) { in turning_to_store_data() argument
238 pub(crate) fn turning_to_get_data(&self) -> Result<T::Output, ScheduleError> { in turning_to_get_data() argument
264 pub(crate) fn send_result(&self, output: Result<T::Output, ScheduleError>) { in send_result() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | blocking_pool.rs | 170 pub fn create_permanent_threads(&self) -> Result<(), ScheduleError> { in create_permanent_threads() argument
|