Home
last modified time | relevance | path

Searched defs:ready (Results 1 – 8 of 8) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
Dready.rs33 pub(crate) ready: Ready, field
51 let mut ready = Ready::EMPTY; in from_event() localVariable
100 let mut ready = Ready::EMPTY; in from_interest() localVariable
196 let mut ready = Ready::EMPTY; localVariable
248 let ready = Ready::from_event(&event); in ut_ready_from_event() localVariable
259 let ready = Ready::from_event(&event); in ut_ready_from_event() localVariable
270 let ready = Ready::from_event(&event); in ut_ready_from_event() localVariable
281 let ready = Ready::from_event(&event); in ut_ready_from_event() localVariable
293 let ready = Ready::from_usize(0x01); in ut_ready_from_usize() localVariable
305 let ready = Ready::from_usize(0x00); in ut_ready_is_empty() localVariable
[all …]
Dasync_source.rs83 let ready = self.entry.readiness(interest).await?; in async_process() localVariable
110 let ready = self.entry.poll_readiness(cx, interest); localVariable
126 let ready = poll_ready!(self.poll_ready(cx, interest))?; localVariable
Dmod.rs25 pub(crate) mod ready; module
Dschedule_io.rs136 let ready = Ready::from_usize(curr_bit.get_by_mask(READINESS)).intersection(interest); in poll_readiness() localVariable
163 let ready = Ready::from_usize(status_bit.get_by_mask(READINESS)).intersection(interest); in get_readiness() localVariable
334 let ready = readiness.intersection(interest); in poll_init() localVariable
352 let ready = readiness.intersection(interest); in poll_init() localVariable
Ddriver.rs273 let ready = Ready::from_event(event); in drive() localVariable
346 let ready = crate::net::ready::from_event_inner(ready as i32); in ffrt_dispatch_event() localVariable
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
Dsplit.rs25 macro_rules! ready { macro
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
Ddatagram.rs98 pub async fn ready(&self, interest: Interest) -> Result<Ready> { in ready() method
Dstream.rs168 pub async fn ready(&self, interest: Interest) -> Result<Ready> { in ready() method