Searched refs:async_process (Results 1 – 10 of 10) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 327 .async_process(Interest::WRITABLE, || self.source.send(buf)) in send()
349 .async_process(Interest::WRITABLE, || { in send_to()
371 .async_process(Interest::READABLE, || self.source.recv(buf)) in recv()
393 .async_process(Interest::READABLE, || self.source.recv_from(buf)) in recv_from()
|
| H A D | listener.rs | 69 .async_process(Interest::READABLE, || self.source.accept()) in accept()
|
| H A D | stream.rs | 59 .async_process( in connect()
|
| /ohos5.0/foundation/ai/ai_engine/test/ |
| H A D | CMakeLists.txt | 34 function/async_process/async_process_function_test.cpp
44 performance/delay/async_process/async_process_delay_test.cpp
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 236 .async_process(Interest::WRITABLE, || self.source.send_to(buf, addr)) in send_to()
347 .async_process(Interest::READABLE, || self.source.recv_from(buf)) in recv_from()
409 .async_process(Interest::READABLE, || self.source.peek_from(buf)) in peek_from()
959 .async_process(Interest::WRITABLE, || self.source.send(buf)) in send()
1079 .async_process(Interest::READABLE, || self.source.recv(buf)) in recv()
1213 .async_process(Interest::READABLE, || self.source.peek(buf)) in peek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 105 .async_process( in connect_inner()
529 .async_process(Interest::READABLE, || self.source.peek(buf)) in peek()
|
| H A D | listener.rs | 102 .async_process(Interest::READABLE, || self.source.accept()) in accept()
|
| /ohos5.0/foundation/ai/ai_engine/test/performance/ |
| H A D | BUILD.gn | 45 "delay/async_process/async_process_delay_test.cpp",
|
| /ohos5.0/foundation/ai/ai_engine/test/function/ |
| H A D | BUILD.gn | 50 "async_process/async_process_function_test.cpp",
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 78 pub(crate) async fn async_process<F, R>(&self, interest: Interest, mut op: F) -> io::Result<R> in async_process() method
|