| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_server.rs | 28 let poll = Poll::new()?; in main() localVariable
33 poll.register(&mut server, SERVER, Interest::READABLE)?; in main()
39 poll.poll(&mut events, None)?; in main()
48 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in main()
58 poll.deregister(connection)?; in main()
59 poll.register(connection, event.token(), Interest::READABLE)?; in main()
64 poll.deregister(connection)?; in main()
65 poll.register(connection, event.token(), Interest::READABLE)?; in main()
74 poll.deregister(connection)?; in main()
84 poll.deregister(connection)?; in main()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 70 let poll = Poll::new()?; in server() localVariable
73 poll.register(&mut server, SERVER, Interest::READABLE)?; in server()
79 poll.poll(&mut events, None)?; in server()
86 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in server()
94 poll.deregister(connection)?; in server()
95 poll.register(connection, event.token(), Interest::READABLE)?; in server()
99 poll.deregister(connection)?; in server()
100 poll.register(connection, event.token(), Interest::READABLE)?; in server()
107 Ok(0) => poll.deregister(connection)?, in server()
116 poll.deregister(connection)?; in server()
|
| /ohos5.0/foundation/communication/nfc/services/src/nci_adapter/nci_native_default/src/ |
| H A D | tag_host.cpp | 307 std::string poll = tagPollBytes_[index]; in DoTargetTypeIso144433a() local
313 pacMap.PutStringValue(KITS::TagInfo::ATQA, poll); in DoTargetTypeIso144433a()
314 DebugLog("DoTargetTypeIso144433a ATQA: %{public}s", poll.c_str()); in DoTargetTypeIso144433a()
319 std::string poll = tagPollBytes_[index]; in DoTargetTypeIso144433b() local
320 if (poll.empty()) { in DoTargetTypeIso144433b()
325 if (KITS::NfcSdkCommon::GetHexStrBytesLen(poll) < in DoTargetTypeIso144433b()
362 std::string poll = tagPollBytes_[index]; in DoTargetTypeV() local
363 if (poll.empty()) { in DoTargetTypeV()
382 std::string poll = tagPollBytes_[index]; in DoTargetTypeF() local
383 if (poll.empty()) { in DoTargetTypeF()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | waker.rs | 27 pub fn new(poll: &Poll, token: Token) -> io::Result<Self> { in new()
28 WakerInner::new(poll.selector(), token).map(|inner| Waker { inner }) in new()
48 let poll = Poll::new().unwrap(); in ut_waker_debug_info() localVariable
49 let waker = Waker::new(&poll, Token::from_usize(0)).unwrap(); in ut_waker_debug_info()
|
| H A D | poll.rs | 37 pub fn poll(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll() method
81 let poll = Poll::new().unwrap(); in ut_poll_debug_info() localVariable
82 let fmt = format!("{:?}", poll); in ut_poll_debug_info()
|
| H A D | lib.rs | 16 mod poll; module
17 pub use poll::Poll;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | write_task.rs | 58 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
98 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
140 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
202 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| H A D | read_task.rs | 61 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end() localVariable
117 match poll { in poll_read_to_end()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
211 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
246 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
330 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
366 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 61 poll: Arc<Poll>, field
197 let poll = in initialize() localVariable
199 let waker = ylong_io::Waker::new(&poll, WAKE_TOKEN) in initialize()
201 let arc_poll = Arc::new(poll); in initialize()
220 poll: arc_poll, in initialize()
256 match self.poll.poll(&mut events, time_out) { in drive()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timeout.rs | 72 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
76 if let Poll::Ready(result) = value.poll(cx) { in poll()
81 match sleep.poll(cx) { in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 20 match $fut.as_mut().poll($cx) {
96 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
100 FutureDone::Pending(fut) => match Pin::new_unchecked(fut).poll(cx) { in poll()
171 if fut.as_mut().poll(cx).is_pending() { in ut_future_done_test()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | timeout.rs | 43 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
47 if let Poll::Ready(()) = delay.as_mut().poll(cx) { in poll()
51 match Pin::new(&mut this.future).poll(cx) { in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 67 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
72 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll()
78 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll()
406 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_seek()
463 let (mut file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
472 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
481 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
530 if let Poll::Ready(Err(e)) = Pin::new(state).poll(cx) { in poll_write()
559 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_flush()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
| H A D | epoll_io_waiter_mingw.cpp | 108 void EpollIoWaiter::OnPoll(uv_poll_t *poll, int status, int events) in OnPoll() argument
111 auto &that = GetInstance(poll); in OnPoll()
118 if (&p == poll) { in OnPoll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | addr.rs | 63 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
68 let poll = Pin::new(&mut task).poll(cx)?; in poll() localVariable
69 if poll.is_pending() { in poll()
72 poll in poll()
|
| /ohos5.0/base/startup/init/interfaces/innerkits/fd_holder/ |
| H A D | fd_holder.c | 47 STATIC int BuildSendData(char *buffer, size_t size, const char *serviceName, bool hold, bool poll) in BuildSendData() argument
53 if (!hold && poll) { in BuildSendData()
63 if (!poll) { in BuildSendData()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | yield_now.rs | 45 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
67 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos/osal/src/ |
| H A D | osal_cdev.c | 112 return dev->opsImpl->poll(filep, fds); in OsalCdevPoll()
120 fops->poll = src->poll != NULL ? OsalCdevPoll : NULL; in AssignFileOps()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | timer_test.rs | 101 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
107 if Pin::new(&mut sleep).poll(cx).is_pending() { in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 81 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
82 Pin::new(&mut self.inner).poll(cx).map(|res| match res { in poll()
|
| /ohos5.0/docs/zh-cn/application-dev/graphics/ |
| H A D | native-window-guidelines.md | 35 #include <sys/poll.h>
144 5. **将生产的内容写入OHNativeWindowBuffer，在这之前需要等待releaseFenceFd可用（注意releaseFenceFd不等于-1才需要调用poll）。如果没有等待re…
153 retCode = poll(&pollfds, 1, timeout);
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/osal/src/ |
| H A D | osal_cdev.c | 177 return dev->opsImpl->poll(filep, pollTable); in OsalCdevPoll()
203 fops->poll = src->poll != NULL ? OsalCdevPoll : NULL; in AssignFileOps()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
158 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 54 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() method
143 match task.as_mut().poll(cx) { in poll_blocked_task()
219 match task.as_mut().poll(cx) { in transmit_message()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
127 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() function
|