Home
last modified time | relevance | path

Searched refs:READABLE (Results 1 – 25 of 35) sorted by relevance

12

/external/rust/crates/tokio/src/io/driver/
Dready.rs6 const READABLE: usize = 0b0_01; constant
23 pub const READABLE: Ready = Ready(READABLE); constant
35 pub const ALL: Ready = Ready(READABLE | WRITABLE | READ_CLOSED | WRITE_CLOSED);
42 ready |= Ready::READABLE; in from_mio()
87 self.contains(Ready::READABLE) || self.is_read_closed() in is_readable()
174 ready |= Ready::READABLE;
Dinterest.rs20 pub const READABLE: Interest = Interest(mio::Interest::READABLE); constant
85 Interest::READABLE => Ready::READABLE | Ready::READ_CLOSED, in mask()
/external/rust/crates/mio/src/
Dinterest.rs20 const READABLE: u8 = 0b0_001; constant
38 pub const READABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(READABLE) }); constant
99 (self.0.get() & READABLE) != 0 in is_readable()
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/system/impl/
DWatcherImplTest.java125 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testCorrectResult()
147 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testClosingPeerHandle()
171 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testClosingWatchedHandle()
197 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult)); in testInvalidHandle()
214 mWatcher.start(InvalidHandle.INSTANCE, Core.HandleSignals.READABLE, watcherResult)); in testDefaultInvalidHandle()
234 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testCancel()
264 mWatcher.start(handles.first, Core.HandleSignals.READABLE, watcherResult); in testImmediateCancelOnInvalidHandle()
/external/rust/crates/tokio/src/net/unix/datagram/
Dsocket.rs267 self.ready(Interest::READABLE).await?; in readable()
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, || {
803 self.io.registration().try_io(Interest::READABLE, || {
901 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
1094 .try_io(Interest::READABLE, || self.io.recv_from(buf))?; in try_recv_from()
/external/rust/crates/tokio/src/net/
Dudp.rs602 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, || {
1029 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
1123 .try_io(Interest::READABLE, || self.io.recv_from(buf)) in try_recv_from()
1159 .async_io(Interest::READABLE, || self.io.peek_from(buf)) in peek_from()
/external/rust/crates/mio/examples/
Dtcp_server.rs30 .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.rs27 .register(&mut socket, UDP_SOCKET, Interest::READABLE)?; in main()
/external/python/cpython2/Modules/_multiprocessing/
Dconnection.h17 #define READABLE 1 macro
21 if (!(self->flags & READABLE)) { \
70 self->flags |= READABLE; in connection_new()
421 return PyBool_FromLong((long)(self->flags & READABLE)); in connection_readable()
/external/rust/crates/tokio/src/net/tcp/
Dstream.rs462 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, || {
818 .async_io(Interest::READABLE, || self.io.peek(buf)) in peek()
Dlistener.rs153 .async_io(Interest::READABLE, || self.io.accept()) in accept()
/external/rust/crates/tokio/src/net/unix/
Dstream.rs170 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, || {
Dlistener.rs135 .async_io(Interest::READABLE, || self.io.accept()) in accept()
/external/rust/crates/mio/src/sys/unix/
Dwaker.rs28 .register(fd, token, Interest::READABLE) in new()
135 .register(fds[0], token, Interest::READABLE) in new()
/external/rust/crates/tokio/src/io/
Dasync_fd.rs166 const ALL_INTEREST: Interest = Interest::READABLE.add(Interest::WRITABLE);
423 self.readiness(Interest::READABLE).await in readable()
434 self.readiness_mut(Interest::READABLE).await in readable_mut()
Dpoll_evented.rs88 PollEvented::new_with_interest(io, Interest::READABLE | Interest::WRITABLE) in new()
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/
DCore.java40 public static final HandleSignals READABLE = field in Core.HandleSignals
/external/rust/crates/tokio/tests/
Dtcp_stream.rs99 let ready = server.ready(Interest::READABLE).await.unwrap(); in try_read_write()
306 let ready = server.ready(Interest::READABLE).await.unwrap(); in try_read_buf()
Duds_stream.rs134 let ready = server.ready(Interest::READABLE).await?; in try_read_write()
326 let ready = server.ready(Interest::READABLE).await?; in try_read_buf()
/external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
DExecutorFactory.java77 mWatcher.start(mReadHandle, Core.HandleSignals.READABLE, this); in PipedExecutor()
DConnector.java88 mWatcher.start(mMessagePipeHandle, Core.HandleSignals.READABLE, mWatcherCallback); in start()
/external/rust/crates/tokio/src/signal/unix/
Ddriver.rs79 Interest::READABLE | Interest::WRITABLE, in new()
/external/rust/crates/mio/
DREADME.md64 .register(&mut server, SERVER, Interest::READABLE)?;
70 .register(&mut client, CLIENT, Interest::READABLE | Interest::WRITABLE)?;
/external/python/cpython2/Demo/tkinter/guido/
DShellWindow.py32 self.tk.createfilehandler(self.fromchild, READABLE,
DManPage.py48 self.tk.createfilehandler(fp, _tkinter.READABLE,

12