| /external/rust/crates/futures-util/src/io/ |
| D | write_all_vectored.rs | 5 use futures_io::IoSlice;
16 bufs: &'a mut [IoSlice<'a>],
22 pub(super) fn new(writer: &'a mut W, bufs: &'a mut [IoSlice<'a>]) -> Self { in new()
23 Self { writer, bufs: IoSlice::advance(bufs, 0) } in new()
37 this.bufs = IoSlice::advance(mem::take(&mut this.bufs), n); in poll()
53 use crate::io::{AsyncWrite, AsyncWriteExt, IoSlice};
79 self.poll_write_vectored(cx, &[IoSlice::new(buf)]) in poll_write()
85 bufs: &[IoSlice<'_>], in poll_write_vectored()
134 let bufs = &[IoSlice::new(&[2, 2, 2])]; in test_writer_read_from_one_buf()
138 let bufs = &[IoSlice::new(&[3]), IoSlice::new(&[4, 4])]; in test_writer_read_from_one_buf()
[all …]
|
| D | write_vectored.rs | 4 use std::io::{self, IoSlice};
12 bufs: &'a [IoSlice<'a>],
18 pub(super) fn new(writer: &'a mut W, bufs: &'a [IoSlice<'a>]) -> Self { in new()
|
| D | sink.rs | 2 use futures_io::{AsyncWrite, IoSlice};
48 bufs: &[IoSlice<'_>], in poll_write_vectored()
|
| D | allow_std.rs | 4 use futures_io::{AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead, IoSlice, IoSliceMut, SeekFrom};
67 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
88 fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored()
|
| D | cursor.rs | 4 use futures_io::{AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, IoSlice, IoSliceMut, SeekFrom};
208 fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>])
|
| D | mod.rs | 29 pub use std::io::{Error, ErrorKind, IoSlice, IoSliceMut, Result, SeekFrom};
457 fn write_vectored<'a>(&'a mut self, bufs: &'a [IoSlice<'a>]) -> WriteVectored<'a, Self> in write_vectored()
536 bufs: &'a mut [IoSlice<'a>], in write_all_vectored()
|
| D | buf_writer.rs | 3 use futures_io::{AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, IoSlice, SeekFrom};
111 bufs: &[IoSlice<'_>], in poll_write_vectored()
|
| D | split.rs | 4 use futures_io::{AsyncRead, AsyncWrite, IoSlice, IoSliceMut};
78 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored()
|
| /external/rust/crates/bytes/tests/ |
| D | test_chain.rs | 5 use std::io::IoSlice;
59 IoSlice::new(b1), in vectored_read()
60 IoSlice::new(b2), in vectored_read()
61 IoSlice::new(b3), in vectored_read()
62 IoSlice::new(b4), in vectored_read()
80 IoSlice::new(b1), in vectored_read()
81 IoSlice::new(b2), in vectored_read()
82 IoSlice::new(b3), in vectored_read()
83 IoSlice::new(b4), in vectored_read()
101 IoSlice::new(b1), in vectored_read()
[all …]
|
| D | test_buf.rs | 5 use std::io::IoSlice;
54 let mut dst = [IoSlice::new(b1), IoSlice::new(b2)]; in test_bufs_vec()
|
| /external/rust/crates/tokio/src/io/ |
| D | async_write.rs | 1 use std::io::{self, IoSlice};
157 bufs: &[IoSlice<'_>], in poll_write_vectored()
194 bufs: &[IoSlice<'_>],
237 bufs: &[IoSlice<'_>], in poll_write_vectored()
268 bufs: &[IoSlice<'_>], in poll_write_vectored()
298 bufs: &[IoSlice<'_>], in poll_write_vectored()
328 bufs: &[IoSlice<'_>], in poll_write_vectored()
358 bufs: &[IoSlice<'_>], in poll_write_vectored()
388 bufs: &[IoSlice<'_>], in poll_write_vectored()
|
| /external/rust/crates/tokio/src/io/util/ |
| D | write_vectored.rs | 8 use std::{future::Future, io::IoSlice};
16 bufs: &'a [IoSlice<'b>],
25 bufs: &'a [IoSlice<'b>], in write_vectored()
|
| D | async_write_ext.rs | 16 use std::io::IoSlice;
155 … fn write_vectored<'a, 'b>(&'a mut self, bufs: &'a [IoSlice<'b>]) -> WriteVectored<'a, 'b, Self>
|
| /external/rust/crates/futures/tests/ |
| D | io_write.rs | 78 io::IoSlice::new(&[]), in write_vectored_first_non_empty()
79 io::IoSlice::new(&[]), in write_vectored_first_non_empty()
80 io::IoSlice::new(b"four") in write_vectored_first_non_empty()
|
| /external/crosvm/sys_util/src/ |
| D | sock_ctrl_msg.rs | 9 use std::io::{IoSlice, IoSliceMut};
279 let slices: Vec<IoSlice> = bufs.iter().map(|&b| IoSlice::new(b)).collect(); in send_bufs_with_fds()
376 unsafe impl<'a> AsIobuf for IoSlice<'a> { implementation
474 let ioslice = IoSlice::new(&send_buf); in send_recv_no_fd()
510 let ioslice = IoSlice::new([].as_ref()); in send_recv_only_fd()
538 let ioslice = IoSlice::new([237].as_ref()); in send_recv_with_fd()
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 37 pub use io::{Error, ErrorKind, Result, IoSlice, IoSliceMut, SeekFrom};
178 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored()
401 … fn poll_write_vectored(mut self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>])
436 fn poll_write_vectored(self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>]) in poll_write_vectored()
459 … fn poll_write_vectored(mut self: Pin<&mut Self>, _: &mut Context<'_>, bufs: &[IoSlice<'_>])
|
| /external/rust/crates/mio/src/net/uds/ |
| D | stream.rs | 5 use std::io::{self, IoSlice, IoSliceMut, Read, Write};
99 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
113 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
|
| /external/rust/crates/bytes/src/buf/ |
| D | buf_impl.rs | 8 use std::io::IoSlice;
160 fn chunks_vectored<'a>(&'a self, dst: &mut [IoSlice<'a>]) -> usize { in chunks_vectored()
166 dst[0] = IoSlice::new(self.chunk()); in chunks_vectored()
916 fn chunks_vectored<'b>(&'b self, dst: &mut [IoSlice<'b>]) -> usize {
|
| D | chain.rs | 5 use std::io::IoSlice;
168 fn chunks_vectored<'a>(&'a self, dst: &mut [IoSlice<'a>]) -> usize { in chunks_vectored()
|
| /external/rust/crates/mio/src/net/tcp/ |
| D | stream.rs | 2 use std::io::{self, IoSlice, IoSliceMut, Read, Write};
200 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
214 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 6 use std::io::{self, IoSlice, IoSliceMut, Read, Write};
250 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
264 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
|
| /external/crosvm/base/src/ |
| D | tube.rs | 5 use std::io::{self, IoSlice};
77 .send_with_fds(&[IoSlice::new(&msg_json)], &msg_descriptors) in send()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | split.rs | 72 bufs: &[io::IoSlice<'_>], in poll_write_vectored()
|
| D | stream.rs | 667 bufs: &[io::IoSlice<'_>], in poll_write_vectored()
718 bufs: &[io::IoSlice<'_>], in poll_write_vectored_priv()
|
| /external/adhd/cras/client/libcras/src/ |
| D | cras_server_socket.rs | 69 let ioslice = io::IoSlice::new(message.as_slice()); in send_server_message_with_fds()
|