Home
last modified time | relevance | path

Searched refs:readiness (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dschedule_io.rs168 pub(crate) async fn readiness(&self, interest: Interest) -> io::Result<ReadyEvent> { in readiness() method
333 let readiness = Ready::from_usize(status_bit.get_by_mask(READINESS)); in poll_init() localVariable
334 let ready = readiness.intersection(interest); in poll_init()
346 let mut readiness = Ready::from_usize(status_bit.get_by_mask(READINESS)); in poll_init() localVariable
349 readiness = Ready::ALL; in poll_init()
352 let ready = readiness.intersection(interest); in poll_init()
H A Dasync_source.rs83 let ready = self.entry.readiness(interest).await?; in async_process()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dstream.rs155 self.source.entry.readiness(Interest::READABLE).await?; in readable()
222 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs509 self.source.entry.readiness(Interest::READABLE).await?; in readable()
533 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
1277 self.source.entry.readiness(Interest::READABLE).await?; in readable()
1309 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs99 let event = self.source.entry.readiness(interest).await?; in ready()
H A Dstream.rs169 let event = self.source.entry.readiness(interest).await?; in ready()