Home
last modified time | relevance | path

Searched refs:WRITABLE (Results 1 – 25 of 29) sorted by relevance

12

/external/rust/crates/tokio/src/io/
Dready.rs7 const WRITABLE: usize = 0b0_10; constant
26 pub const WRITABLE: Ready = Ready(WRITABLE); constant
35 pub const ALL: Ready = Ready(READABLE | WRITABLE | READ_CLOSED | WRITE_CLOSED);
57 ready |= Ready::WRITABLE; in from_mio()
114 self.contains(Ready::WRITABLE) || self.is_write_closed() in is_writable()
190 ready |= Ready::WRITABLE;
Dinterest.rs45 pub const WRITABLE: Interest = Interest(mio::Interest::WRITABLE); constant
106 Interest::WRITABLE => Ready::WRITABLE | Ready::WRITE_CLOSED, in mask()
Dasync_fd.rs169 const ALL_INTEREST: Interest = Interest::READABLE.add(Interest::WRITABLE);
463 self.readiness(Interest::WRITABLE).await in writable()
474 self.readiness_mut(Interest::WRITABLE).await in writable_mut()
Dpoll_evented.rs86 PollEvented::new_with_interest(io, Interest::READABLE | Interest::WRITABLE) in new()
/external/python/cpython2/Modules/_multiprocessing/
Dconnection.h18 #define WRITABLE 2 macro
27 if (!(self->flags & WRITABLE)) { \
72 self->flags |= WRITABLE; in connection_new()
166 if ((self->flags & WRITABLE) == 0) { in connection_recvbytes()
172 self->flags = WRITABLE; in connection_recvbytes()
220 if ((self->flags & WRITABLE) == 0) { in connection_recvbytes_into()
226 self->flags = WRITABLE; in connection_recvbytes_into()
306 if ((self->flags & WRITABLE) == 0) { in connection_recv_obj()
312 self->flags = WRITABLE; in connection_recv_obj()
427 return PyBool_FromLong((long)(self->flags & WRITABLE)); in connection_writable()
/external/rust/crates/mio/src/
Dinterest.rs21 const WRITABLE: u8 = 0b0010; constant
32 pub const WRITABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(WRITABLE) }); constant
99 (self.0.get() & WRITABLE) != 0 in is_writable()
/external/crosvm/third_party/vmm_vhost/src/
Dmaster.rs907 .set_config(0x100, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_set_config_negative()
919 .set_config(0, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_set_config_negative()
924 VhostUserConfigFlags::WRITABLE, in test_master_set_config_negative()
929 .set_config(0x1000, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_set_config_negative()
939 .set_config(VHOST_USER_CONFIG_SIZE, VhostUserConfigFlags::WRITABLE, &buf) in test_master_set_config_negative()
942 .set_config(VHOST_USER_CONFIG_SIZE, VhostUserConfigFlags::WRITABLE, &[]) in test_master_set_config_negative()
969 .get_config(0x100, 4, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_get_config_negative0()
976 .get_config(0x100, 4, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_get_config_negative0()
991 .get_config(0x100, 4, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_get_config_negative1()
998 .get_config(0x100, 4, VhostUserConfigFlags::WRITABLE, &buf[0..4]) in test_master_get_config_negative1()
[all …]
Dlib.rs428 .set_config(0x100, VhostUserConfigFlags::WRITABLE, &[0xa5u8]) in test_master_slave_process()
Dmessage.rs706 const WRITABLE = 0x1; constant
1447 VhostUserConfig::new(0, VHOST_USER_CONFIG_SIZE, VhostUserConfigFlags::WRITABLE); in check_user_config_msg()
/external/rust/crates/tokio/src/net/unix/datagram/
Dsocket.rs227 self.ready(Interest::WRITABLE).await?; in writable()
622 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send()
667 .try_io(Interest::WRITABLE, || self.io.send(buf)) in try_send()
713 .try_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in try_send_to()
975 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target.as_ref())) in send_to()
/external/rust/crates/tokio/src/net/windows/
Dnamed_pipe.rs195 .async_io(Interest::WRITABLE, || self.io.connect()) in connect()
661 self.ready(Interest::WRITABLE).await?; in writable()
750 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write()
812 .try_io(Interest::WRITABLE, || (&*self.io).write_vectored(buf)) in try_write_vectored()
1413 self.ready(Interest::WRITABLE).await?; in writable()
1501 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write()
1562 .try_io(Interest::WRITABLE, || (&*self.io).write_vectored(buf)) in try_write_vectored()
/external/rust/crates/tokio/src/net/
Dudp.rs483 self.ready(Interest::WRITABLE).await?; in writable()
560 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send()
644 .try_io(Interest::WRITABLE, || self.io.send(buf)) in try_send()
1138 .try_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in try_send_to()
1144 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in send_to_addr()
/external/rust/crates/tokio/src/net/unix/
Dstream.rs512 self.ready(Interest::WRITABLE).await?; in writable()
602 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write()
664 .try_io(Interest::WRITABLE, || (&*self.io).write_vectored(buf)) in try_write_vectored()
/external/libwebsockets/lib/misc/threadpool/
DREADME.md125 LWS_TP_RETURN_SYNC|Task wants to trigger a WRITABLE callback and block until lws service thread res…
139 cause a WRITABLE callback on the associated wsi in the lws service thread
147 In the WRITABLE callback, in lws service thread context, the buffer can be
151 If the WRITABLE callback determines that the task should stop, it can just call
167 #### Protecting against WRITABLE and / or SYNC duplication
/external/rust/crates/tokio/src/net/tcp/
Dstream.rs822 self.ready(Interest::WRITABLE).await?; in writable()
912 .try_io(Interest::WRITABLE, || (&*self.io).write(buf)) in try_write()
974 .try_io(Interest::WRITABLE, || (&*self.io).write_vectored(bufs)) in try_write_vectored()
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/
DCore.java42 public static final HandleSignals WRITABLE = field in Core.HandleSignals
/external/rust/crates/mio/examples/
Dtcp_server.rs72 Interest::READABLE.add(Interest::WRITABLE), in main()
Dtcp_listenfd_server.rs98 .register(&mut connection, token, Interest::WRITABLE)?; in main()
/external/rust/crates/tokio/src/runtime/io/
Dmod.rs323 Direction::Write => Ready::WRITABLE | Ready::WRITE_CLOSED, in mask()
/external/rust/crates/tokio/tests/
Dnet_named_pipe.rs269 interest |= Interest::WRITABLE; in test_named_pipe_multi_client_ready()
Dtcp_stream.rs387 let mut ready_fut = task::spawn(client.ready(Interest::WRITABLE)); in write_closed()
/external/rust/crates/mio/
DREADME.md69 .register(&mut client, CLIENT, Interest::READABLE | Interest::WRITABLE)?;
/external/crosvm/devices/src/virtio/vhost/user/vmm/
Dhandler.rs155 VhostUserConfigFlags::WRITABLE, in read_config()
/external/python/cpython2/Doc/library/
Dtkinter.rst847 mask = Tkinter.READABLE | Tkinter.WRITABLE
880 WRITABLE
/external/python/cpython2/Modules/_ctypes/libffi/doc/
Dlibffi.info418 -- Function: void ffi_closure_free (void *WRITABLE)

12