Home
last modified time | relevance | path

Searched refs:Interest (Results 1 – 25 of 56) sorted by relevance

123

/external/rust/crates/tokio/src/io/driver/
Dinterest.rs14 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 …]
Dregistration.rs3 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>) -…
Dready.rs167 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/
Dinterest.rs17 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 …]
Dio_source.rs13 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
Dpoll.rs1 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/
Dsocket.rs1 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/
Dsource.rs1 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/
Dasync_fd.rs1 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()
Dpoll_evented.rs1 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/
Dudp.rs1 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/
Dtcp_server.rs5 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()
Dudp_server.rs5 use mio::{Events, Interest, Poll, Token};
27 .register(&mut socket, UDP_SOCKET, Interest::READABLE)?; in main()
/external/rust/crates/tokio/src/net/unix/
Dstream.rs2 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/
Dmod.rs26 use crate::{Registry, Token, Interest};
51 _: Interest,
61 _: Interest,
Dselector.rs30 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/
Dsourcefd.rs1 use crate::{event, poll, Interest, Registry, Token};
93 interests: Interest, in register() argument
102 interests: Interest, in reregister() argument
Dwaker.rs4 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()
Dpipe.rs11 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/
Dmod.rs48 use crate::{poll, Interest, Registry, Token};
53 interests: Interest,
98 interests: Interest,
116 interests: Interest,
/external/rust/crates/tokio/src/net/tcp/
Dstream.rs2 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/
Dlistener.rs3 use crate::{event, sys, Interest, Registry, Token};
57 interests: Interest, in register() argument
66 interests: Interest, in reregister() argument
Ddatagram.rs2 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/
Dlistener.rs10 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/
Ddriver.rs5 use crate::io::driver::{Driver as IoDriver, Interest};
79 Interest::READABLE | Interest::WRITABLE, in new()

123