| /external/rust/crates/tokio/src/io/ |
| D | read_buf.rs | 27 pub struct ReadBuf<'a> { struct
33 impl<'a> ReadBuf<'a> { argument
36 pub fn new(buf: &'a mut [u8]) -> ReadBuf<'a> { in new()
39 ReadBuf { in new()
50 pub fn uninit(buf: &'a mut [MaybeUninit<u8>]) -> ReadBuf<'a> { in uninit()
51 ReadBuf { in uninit()
86 pub fn take(&mut self, n: usize) -> ReadBuf<'_> { in take()
89 unsafe { ReadBuf::uninit(&mut self.unfilled_mut()[..max]) } in take()
277 impl fmt::Debug for ReadBuf<'_> { implementation
|
| D | async_read.rs | 1 use super::ReadBuf;
56 buf: &mut ReadBuf<'_>, in poll_read()
65 buf: &mut ReadBuf<'_>,
88 buf: &mut ReadBuf<'_>, in poll_read()
98 buf: &mut ReadBuf<'_>, in poll_read()
112 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | stdin.rs | 2 use crate::io::{AsyncRead, ReadBuf};
69 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | blocking.rs | 2 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
56 dst: &mut ReadBuf<'_>, in poll_read()
206 pub(crate) fn copy_to(&mut self, dst: &mut ReadBuf<'_>) -> usize { in copy_to()
232 pub(crate) fn ensure_capacity_for(&mut self, bytes: &ReadBuf<'_>) { in ensure_capacity_for()
|
| /external/rust/crates/tokio/src/io/util/ |
| D | read_buf.rs | 11 pub(crate) fn read_buf<'a, R, B>(reader: &'a mut R, buf: &'a mut B) -> ReadBuf<'a, R, B> in read_buf()
16 ReadBuf { in read_buf()
27 pub struct ReadBuf<'a, R, B> {
35 impl<R, B> Future for ReadBuf<'_, R, B> implementation
43 use crate::io::ReadBuf; in poll()
55 let mut buf = ReadBuf::uninit(dst); in poll()
|
| D | vec_with_initialized.rs | 1 use crate::io::ReadBuf;
71 pub(crate) fn get_read_buf<'a>(&'a mut self) -> ReadBuf<'a> { in get_read_buf()
86 let mut read_buf = ReadBuf::uninit(slice); in get_read_buf()
126 pub(crate) fn into_read_buf_parts(rb: ReadBuf<'_>) -> ReadBufParts { in into_read_buf_parts()
|
| D | read_exact.rs | 1 use crate::io::{AsyncRead, ReadBuf};
22 buf: ReadBuf::new(buf), in read_exact()
36 buf: ReadBuf<'a>,
|
| D | repeat.rs | 1 use crate::io::{AsyncRead, ReadBuf};
54 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | empty.rs | 1 use crate::io::{AsyncBufRead, AsyncRead, ReadBuf};
54 _: &mut ReadBuf<'_>, in poll_read()
|
| D | read.rs | 1 use crate::io::{AsyncRead, ReadBuf};
51 let mut buf = ReadBuf::new(*me.buf); in poll()
|
| D | mem.rs | 3 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
101 buf: &mut ReadBuf<'_>, in poll_read()
166 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | buf_reader.rs | 2 use crate::io::{AsyncBufRead, AsyncRead, AsyncWrite, ReadBuf};
102 buf: &mut ReadBuf<'_>, in poll_read()
130 let mut buf = ReadBuf::new(me.buf); in poll_fill_buf()
|
| D | read_int.rs | 1 use crate::io::{AsyncRead, ReadBuf};
57 let mut buf = ReadBuf::new(&mut me.buf[*me.read as usize..]);
115 let mut buf = ReadBuf::new(&mut buf);
|
| D | take.rs | 1 use crate::io::{AsyncBufRead, AsyncRead, ReadBuf};
81 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | async_read_ext.rs | 3 use crate::io::util::read_buf::{read_buf, ReadBuf};
223 fn read_buf<'a, B>(&'a mut self, buf: &'a mut B) -> ReadBuf<'a, Self, B>
|
| /external/flatbuffers/java/com/google/flatbuffers/ |
| D | FlexBuffers.java | 103 private static final ReadBuf EMPTY_BB = new ArrayReadWriteBuf(new byte[] {0}, 1);
154 private static int indirect(ReadBuf bb, int offset, int byteWidth) { in indirect()
160 private static long readUInt(ReadBuf buff, int end, int byteWidth) { in readUInt()
171 private static int readInt(ReadBuf buff, int end, int byteWidth) { in readInt()
176 private static long readLong(ReadBuf buff, int end, int byteWidth) { in readLong()
186 private static double readDouble(ReadBuf buff, int end, int byteWidth) { in readDouble()
211 public static Reference getRoot(ReadBuf buffer) { in getRoot()
227 private ReadBuf bb;
233 Reference(ReadBuf bb, int end, int parentWidth, int packedType) { in Reference()
237 Reference(ReadBuf bb, int end, int parentWidth, int byteWidth, int type) { in Reference()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | io_read.rs | 4 use tokio::io::{AsyncRead, AsyncReadExt, ReadBuf};
22 buf: &mut ReadBuf<'_>, in read()
46 buf: &mut ReadBuf<'_>, in poll_read()
48 *buf = ReadBuf::new(Box::leak(vec![0; buf.capacity()].into_boxed_slice())); in poll_read()
|
| D | io_copy.rs | 4 use tokio::io::{self, AsyncRead, ReadBuf};
18 buf: &mut ReadBuf<'_>, in copy()
|
| D | io_read_buf.rs | 4 use tokio::io::{AsyncRead, AsyncReadExt, ReadBuf};
21 buf: &mut ReadBuf<'_>, in read_buf()
|
| D | udp.rs | 7 use tokio::{io::ReadBuf, net::UdpSocket};
40 let mut read = ReadBuf::new(&mut recv_buf); in send_recv_poll()
72 let mut read = ReadBuf::new(&mut recv_buf); in send_to_recv_from_poll()
117 let mut read = ReadBuf::new(&mut recv_buf); in send_to_peek_from_poll()
124 let mut read = ReadBuf::new(&mut recv_buf); in send_to_peek_from_poll()
129 let mut read = ReadBuf::new(&mut recv_buf); in send_to_peek_from_poll()
203 let mut read = ReadBuf::new(&mut recv_buf); in split_chan_poll()
215 let mut read = ReadBuf::new(&mut recv_buf); in split_chan_poll()
|
| D | io_read_to_end.rs | 6 use tokio::io::{AsyncRead, AsyncReadExt, ReadBuf};
35 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | io_split.rs | 4 use tokio::io::{split, AsyncRead, AsyncWrite, ReadBuf, ReadHalf, WriteHalf};
16 buf: &mut ReadBuf<'_>, in poll_read()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | split.rs | 12 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
89 buf: &mut ReadBuf<'_>, in poll_peek()
134 let mut buf = ReadBuf::new(buf); in peek()
143 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | split_owned.rs | 12 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
144 buf: &mut ReadBuf<'_>, in poll_peek()
189 let mut buf = ReadBuf::new(buf); in peek()
198 buf: &mut ReadBuf<'_>, in poll_read()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | split.rs | 11 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
54 buf: &mut ReadBuf<'_>, in poll_read()
|