/external/rust/crates/tokio/src/io/driver/ |
D | interest.rs | 14 pub struct Interest(mio::Interest); struct 16 impl Interest { implementation 20 pub const READABLE: Interest = Interest(mio::Interest::READABLE); 25 pub const WRITABLE: Interest = Interest(mio::Interest::WRITABLE); 74 pub const fn add(self, other: Interest) -> Interest { in add() argument 75 Interest(self.0.add(other.0)) in add() 79 pub(crate) const fn to_mio(self) -> mio::Interest { in to_mio() argument 85 Interest::READABLE => Ready::READABLE | Ready::READ_CLOSED, in mask() 86 Interest::WRITABLE => Ready::WRITABLE | Ready::WRITE_CLOSED, in mask() 92 impl ops::BitOr for Interest { implementation [all …]
|
D | registration.rs | 3 use crate::io::driver::{Direction, Handle, Interest, ReadyEvent, ScheduledIo}; 71 interest: Interest, in new_with_interest_and_handle() argument 190 interest: Interest, in try_io() argument 229 pub(crate) async fn readiness(&self, interest: Interest) -> io::Result<ReadyEvent> { 248 …pub(crate) async fn async_io<R>(&self, interest: Interest, mut f: impl FnMut() -> io::Result<R>) -…
|
D | ready.rs | 167 use crate::io::Interest; 170 pub(crate) fn from_interest(interest: Interest) -> Ready { 186 pub(crate) fn intersection(self, interest: Interest) -> Ready { 190 pub(crate) fn satisfies(self, interest: Interest) -> bool {
|
/external/rust/crates/mio/src/ |
D | interest.rs | 17 pub struct Interest(NonZeroU8); struct 36 impl Interest { impl 38 pub const READABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(READABLE) }); 41 pub const WRITABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(WRITABLE) }); 50 pub const AIO: Interest = Interest(unsafe { NonZeroU8::new_unchecked(AIO) }); 54 pub const LIO: Interest = Interest(unsafe { NonZeroU8::new_unchecked(LIO) }); 69 pub const fn add(self, other: Interest) -> Interest { in add() argument 70 Interest(unsafe { NonZeroU8::new_unchecked(self.0.get() | other.0.get()) }) in add() 93 pub fn remove(self, other: Interest) -> Option<Interest> { in remove() argument 94 NonZeroU8::new(self.0.get() & !other.0.get()).map(Interest) in remove() [all …]
|
D | io_source.rs | 13 use crate::{event, Interest, Registry, Token}; 141 interests: Interest, in register() argument 152 interests: Interest, in reregister() argument 175 interests: Interest, in register() argument 187 interests: Interest, in reregister() argument
|
D | poll.rs | 1 use crate::{event, sys, Events, Interest, Token}; 474 pub fn register<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in register() 542 pub fn reregister<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in reregister()
|
/external/rust/crates/tokio/src/net/unix/datagram/ |
D | socket.rs | 1 use crate::io::{Interest, PollEvented, ReadBuf, Ready}; 160 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready() 211 self.ready(Interest::WRITABLE).await?; in writable() 267 self.ready(Interest::READABLE).await?; in readable() 520 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send() 565 .try_io(Interest::WRITABLE, || self.io.send(buf)) in try_send() 611 .try_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in try_send_to() 643 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv() 694 .try_io(Interest::READABLE, || self.io.recv(buf)) in try_recv() 740 let (n, addr) = self.io.registration().try_io(Interest::READABLE, || { [all …]
|
/external/rust/crates/mio/src/event/ |
D | source.rs | 1 use crate::{Interest, Registry, Token}; 87 interests: Interest, in register() argument 101 interests: Interest, in reregister() argument 122 interests: Interest, in register() argument 131 interests: Interest, in reregister() argument
|
/external/rust/crates/tokio/src/io/ |
D | async_fd.rs | 1 use crate::io::driver::{Handle, Interest, ReadyEvent, Registration}; 166 const ALL_INTEREST: Interest = Interest::READABLE.add(Interest::WRITABLE); 185 pub fn with_interest(inner: T, interest: Interest) -> io::Result<Self> in with_interest() 195 interest: Interest, in new_with_handle_and_interest() argument 392 async fn readiness(&self, interest: Interest) -> io::Result<AsyncFdReadyGuard<'_, T>> { in readiness() 403 interest: Interest, in readiness_mut() argument 423 self.readiness(Interest::READABLE).await in readable() 434 self.readiness_mut(Interest::READABLE).await in readable_mut() 447 self.readiness(Interest::WRITABLE).await in writable() 458 self.readiness_mut(Interest::WRITABLE).await in writable_mut()
|
D | poll_evented.rs | 1 use crate::io::driver::{Handle, Interest, Registration}; 88 PollEvented::new_with_interest(io, Interest::READABLE | Interest::WRITABLE) in new() 107 pub(crate) fn new_with_interest(io: E, interest: Interest) -> io::Result<Self> { in new_with_interest() 113 interest: Interest, in new_with_interest_and_handle() argument
|
/external/rust/crates/tokio/src/net/ |
D | udp.rs | 1 use crate::io::{Interest, PollEvented, ReadBuf, Ready}; 379 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready() 428 self.ready(Interest::WRITABLE).await?; in writable() 466 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send() 550 .try_io(Interest::WRITABLE, || self.io.send(buf)) in try_send() 602 self.ready(Interest::READABLE).await?; in readable() 639 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv() 737 .try_io(Interest::READABLE, || self.io.recv(buf)) in try_recv() 789 self.io.registration().try_io(Interest::READABLE, || { 853 self.io.registration().try_io(Interest::READABLE, || { [all …]
|
/external/rust/crates/mio/examples/ |
D | tcp_server.rs | 5 use mio::{Events, Interest, Poll, Registry, Token}; 30 .register(&mut server, SERVER, Interest::READABLE)?; in main() 71 Interest::READABLE.add(Interest::WRITABLE), in main() 115 registry.reregister(connection, event.token(), Interest::READABLE)? in handle_connection_event()
|
D | udp_server.rs | 5 use mio::{Events, Interest, Poll, Token}; 27 .register(&mut socket, UDP_SOCKET, Interest::READABLE)?; in main()
|
/external/rust/crates/tokio/src/net/unix/ |
D | stream.rs | 2 use crate::io::{AsyncRead, AsyncWrite, Interest, PollEvented, ReadBuf, Ready}; 119 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready() 170 self.ready(Interest::READABLE).await?; in readable() 271 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read() 335 self.io.registration().try_io(Interest::READABLE, || { 397 self.ready(Interest::WRITABLE).await?; in writable() 487 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write()
|
/external/rust/crates/mio/src/sys/shell/ |
D | mod.rs | 26 use crate::{Registry, Token, Interest}; 51 _: Interest, 61 _: Interest,
|
D | selector.rs | 30 use crate::{Interest, Token}; 33 pub fn register(&self, _: RawFd, _: Token, _: Interest) -> io::Result<()> { 37 pub fn reregister(&self, _: RawFd, _: Token, _: Interest) -> io::Result<()> {
|
/external/rust/crates/mio/src/sys/unix/ |
D | sourcefd.rs | 1 use crate::{event, poll, Interest, Registry, Token}; 93 interests: Interest, in register() argument 102 interests: Interest, in reregister() argument
|
D | waker.rs | 4 use crate::{Interest, Token}; 28 .register(fd, token, Interest::READABLE) in new() 110 use crate::{Interest, Token}; 135 .register(fds[0], token, Interest::READABLE) in new()
|
D | pipe.rs | 11 use crate::{event, Interest, Registry, Token}; 226 interests: Interest, in register() argument 235 interests: Interest, in reregister() argument 323 interests: Interest, in register() argument 332 interests: Interest, in reregister() argument
|
/external/rust/crates/mio/src/sys/windows/ |
D | mod.rs | 48 use crate::{poll, Interest, Registry, Token}; 53 interests: Interest, 98 interests: Interest, 116 interests: Interest,
|
/external/rust/crates/tokio/src/net/tcp/ |
D | stream.rs | 2 use crate::io::{AsyncRead, AsyncWrite, Interest, PollEvented, ReadBuf, Ready}; 413 pub async fn ready(&self, interest: Interest) -> io::Result<Ready> { in ready() 462 self.ready(Interest::READABLE).await?; in readable() 563 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read() 625 self.io.registration().try_io(Interest::READABLE, || { 685 self.ready(Interest::WRITABLE).await?; in writable() 775 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write() 818 .async_io(Interest::READABLE, || self.io.peek(buf)) in peek()
|
/external/rust/crates/mio/src/net/uds/ |
D | listener.rs | 3 use crate::{event, sys, Interest, Registry, Token}; 57 interests: Interest, in register() argument 66 interests: Interest, in reregister() argument
|
D | datagram.rs | 2 use crate::{event, sys, Interest, Registry, Token}; 118 interests: Interest, in register() argument 127 interests: Interest, in reregister() argument
|
/external/rust/crates/mio/src/net/tcp/ |
D | listener.rs | 10 use crate::{event, sys, Interest, Registry, Token}; 132 interests: Interest, in register() argument 141 interests: Interest, in reregister() argument
|
/external/rust/crates/tokio/src/signal/unix/ |
D | driver.rs | 5 use crate::io::driver::{Driver as IoDriver, Interest}; 79 Interest::READABLE | Interest::WRITABLE, in new()
|