Searched refs:cancel (Results 1 - 12 of 12) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | join_handle.rs | 33 /// It could be used to join the corresponding task or cancel it.
68 pub fn cancel(&self) { in cancel() functions
70 self.raw.cancel(); in cancel()
137 /// A handle to cancel the spawned task.
154 pub fn cancel(&self) { in cancel() functions
155 unsafe { self.raw.cancel() } in cancel()
198 handle2.cancel(); in ut_test_join_handle_is_finished()
209 let cancel = handle.get_cancel_handle(); in ut_test_cancel_handle()
210 while !cancel.is_finished() { in ut_test_cancel_handle()
213 handle.cancel(); in ut_test_cancel_handle()
[all...] |
| H A D | join_set.rs | 153 /// cancel_handle.cancel();
173 let cancel = handle.get_cancel_handle(); in spawn_inner()
187 cancel in spawn_inner()
245 unsafe { (*item.handle.get()).cancel() } in cancel_all()
248 unsafe { (*item.handle.get()).cancel() } in cancel_all()
429 (*item.handle.get()).cancel(); in drop()
435 (*item.handle.get()).cancel(); in drop()
|
| H A D | raw.rs | 49 /// Task cancel method
50 pub(crate) cancel: unsafe fn(NonNull<Header>),
88 cancel: default_cancel,
133 pub(crate) unsafe fn cancel(self) {
135 (vir_table.cancel)(self.ptr)
360 unsafe fn cancel<T, S>(ptr: NonNull<Header>) in cancel() functions
383 cancel: cancel::<T, S>, in create_vtable()
432 cancel: ffrt_cancel::<T, S>, in create_ffrt_vtable()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | task_cancel.rs | 39 task.cancel(); in sdv_task_cancel_simple()
59 task.cancel(); in sdv_task_cancel_failed()
86 /// SDV test cases for multi cancel.
89 /// 1. In a loop, create a long-time task and then cancel it.
100 handle.cancel(); in sdv_task_cancel_multiple()
|
| H A D | tcp_test.rs | 504 client.cancel(); in sdv_tcp_cancel()
505 server.cancel(); in sdv_tcp_cancel()
594 client.cancel(); in sdv_tcp_unexpected_eof()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | selector.rs | 314 /// After calling the system api to cancel the sock, set it to Cancelled.
413 // events that the user is interested in. Therefore, cancel the pending in update_while_pending()
416 if let Err(e) = self.cancel() { in update_while_pending()
503 // must system call to cancel socket.
506 drop(self.cancel());
512 /// Only can cancel SockState of SockPollStatus::Pending, Set to
514 fn cancel(&mut self) -> io::Result<()> { in cancel() functions
517 unreachable!("Invalid poll status during cancel, {:#?}", self); in cancel()
521 self.afd.cancel(&mut *self.iosb)?; in cancel()
525 // cancel in cancel()
[all...] |
| H A D | afd.rs | 168 /// System call to cancel File HANDLE.
169 pub(crate) unsafe fn cancel(&self, iosb: *mut IO_STATUS_BLOCK) -> io::Result<()> {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | sleep.rs | 121 fn cancel(&mut self) { in cancel() functions
221 fn cancel(&mut self) { in cancel() functions
272 // is invalid. need to cancel the `TimerHandle` operation during `Sleep` in drop()
274 self.cancel() in drop()
|
| H A D | wheel.rs | 237 pub(crate) fn cancel(&mut self, clock_entry: NonNull<Clock>) {
241 self.levels[level].cancel(clock_entry);
354 pub(crate) fn cancel(&mut self, clock_entry: NonNull<Clock>) {
|
| H A D | driver.rs | 60 lock.cancel(clock_entry);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | async_pool.rs | 95 pub(crate) fn cancel(&self) {
566 self.exe_mng_info.cancel(); in release_wait()
755 /// UT test cases for ExecutorMngInfo::cancel()
778 executor_mng_info.cancel(); in ut_executor_mng_info_cancel()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 406 handle.cancel(); in drop()
869 handle.cancel(); in drop()
|
Completed in 8 milliseconds