Home
last modified time | relevance | path

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

123

/external/rust/crates/tokio/src/io/
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);
44 ready |= Ready::READABLE; in from_mio()
48 ready |= Ready::READABLE; in from_mio()
53 ready |= Ready::READABLE; in from_mio()
98 self.contains(Ready::READABLE) || self.is_read_closed() in is_readable()
185 ready |= Ready::READABLE;
Dinterest.rs26 pub const AIO: Interest = Interest(mio::Interest::READABLE);
34 pub const LIO: Interest = Interest(mio::Interest::READABLE);
40 pub const READABLE: Interest = Interest(mio::Interest::READABLE); constant
105 Interest::READABLE => Ready::READABLE | Ready::READ_CLOSED, in mask()
Dasync_fd.rs169 const ALL_INTEREST: Interest = Interest::READABLE.add(Interest::WRITABLE);
439 self.readiness(Interest::READABLE).await in readable()
450 self.readiness_mut(Interest::READABLE).await in readable_mut()
/external/python/bumble/examples/
Dkeyboard.py245 Characteristic.READABLE | Characteristic.WRITEABLE,
250 Descriptor.READABLE,
262 Characteristic.READABLE | Characteristic.WRITEABLE,
267 Descriptor.READABLE,
282 Characteristic.READABLE,
293 Characteristic.READABLE,
299 Characteristic.READABLE,
313 Characteristic.READABLE,
326 Characteristic.READABLE,
Drun_gatt_server.py94 Descriptor.READABLE,
100 Characteristic.READABLE,
113 Characteristic.READABLE | Characteristic.WRITEABLE,
119 Characteristic.READABLE | Characteristic.WRITEABLE,
127 Characteristic.READABLE,
Drun_notifier.py78 Characteristic.READABLE,
84 Characteristic.READABLE,
90 Characteristic.READABLE,
Drun_asha_sink.py105 Characteristic.READABLE,
137 Characteristic.READABLE,
149 Characteristic.READABLE,
Drun_controller.py78 Descriptor.READABLE,
84 Characteristic.READABLE,
Drun_gatt_client_and_server.py68 Descriptor.READABLE,
74 Characteristic.READABLE,
/external/rust/crates/mio/src/
Dinterest.rs20 const READABLE: u8 = 0b0001; constant
29 pub const READABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(READABLE) }); constant
94 (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.rs323 self.ready(Interest::READABLE).await?; in readable()
752 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv()
803 .try_io(Interest::READABLE, || self.io.recv(buf)) in try_recv()
849 let (n, addr) = self.io.registration().try_io(Interest::READABLE, || {
912 self.io.registration().try_io(Interest::READABLE, || {
1023 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
1216 .try_io(Interest::READABLE, || self.io.recv_from(buf))?; in try_recv_from()
/external/python/bumble/bumble/profiles/
Ddevice_information_service.py66 Characteristic(uuid, Characteristic.READ, Characteristic.READABLE, field)
83 Characteristic.READABLE,
93 Characteristic.READABLE,
Dasha_service.py107 Characteristic.READABLE,
130 Characteristic.READABLE,
155 Characteristic.READABLE,
/external/rust/crates/tokio/src/net/
Dudp.rs703 self.ready(Interest::READABLE).await?; in readable()
780 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv()
878 .try_io(Interest::READABLE, || self.io.recv(buf)) in try_recv()
930 self.io.registration().try_io(Interest::READABLE, || {
994 self.io.registration().try_io(Interest::READABLE, || {
1183 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
1277 .try_io(Interest::READABLE, || self.io.recv_from(buf)) in try_recv_from()
1355 .async_io(Interest::READABLE, || self.io.peek_from(buf)) in peek_from()
/external/python/bumble/bumble/
Dgap.py45 Characteristic.READABLE,
52 Characteristic.READABLE,
/external/rust/crates/tokio/src/net/windows/
Dnamed_pipe.rs354 self.ready(Interest::READABLE).await?; in readable()
458 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read()
536 .try_io(Interest::READABLE, || (&*self.io).read_vectored(bufs)) in try_read_vectored()
599 self.io.registration().try_io(Interest::READABLE, || {
1109 self.ready(Interest::READABLE).await?; in readable()
1212 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read()
1289 .try_io(Interest::READABLE, || (&*self.io).read_vectored(bufs)) in try_read_vectored()
1352 self.io.registration().try_io(Interest::READABLE, || {
/external/python/bumble/tests/
Dgatt_test.py118 Characteristic.READABLE,
147 Characteristic.READABLE | Characteristic.WRITEABLE,
243 Characteristic.READABLE | Characteristic.WRITEABLE,
288 Characteristic.READABLE,
424 Characteristic.READABLE | Characteristic.WRITEABLE,
441 Characteristic.READABLE | Characteristic.WRITEABLE,
504 Characteristic.READABLE | Characteristic.WRITEABLE,
548 Characteristic.READABLE,
564 Characteristic.READABLE,
580 Characteristic.READABLE,
[all …]
Dself_test.py167 Characteristic.READABLE,
173 Characteristic.READABLE | Characteristic.WRITEABLE,
179 Characteristic.READABLE | Characteristic.WRITEABLE,
185 Characteristic.READABLE,
238 Characteristic.READABLE,
/external/rust/crates/mio/examples/
Dtcp_server.rs31 .register(&mut server, SERVER, Interest::READABLE)?; in main()
72 Interest::READABLE.add(Interest::WRITABLE), in main()
118 registry.reregister(connection, event.token(), Interest::READABLE)? in handle_connection_event()
Dtcp_listenfd_server.rs63 .register(&mut server, SERVER, Interest::READABLE)?; in main()
143 registry.reregister(connection, event.token(), Interest::READABLE)? in handle_connection_event()
/external/rust/crates/tokio/src/net/tcp/
Dstream.rs510 self.ready(Interest::READABLE).await?; in readable()
615 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read()
693 .try_io(Interest::READABLE, || (&*self.io).read_vectored(bufs)) in try_read_vectored()
755 self.io.registration().try_io(Interest::READABLE, || {
1059 .async_io(Interest::READABLE, || self.io.peek(buf)) in peek()
/external/rust/crates/tokio/src/net/unix/
Dstream.rs196 self.ready(Interest::READABLE).await?; in readable()
301 .try_io(Interest::READABLE, || (&*self.io).read(buf)) in try_read()
379 .try_io(Interest::READABLE, || (&*self.io).read_vectored(bufs)) in try_read_vectored()
443 self.io.registration().try_io(Interest::READABLE, || {
/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/mio/src/sys/unix/
Dwaker.rs26 selector.register(fd, token, Interest::READABLE)?; in new()
128 selector.register(fds[0], token, Interest::READABLE)?; in new()

123