| /external/rust/android-crates-io/crates/h2/src/proto/streams/ |
| D | stream.rs | 19 pub(super) struct Stream { struct
21 pub id: StreamId, argument
24 pub state: State,
28 pub is_counted: bool,
31 pub ref_count: usize,
35 pub next_pending_send: Option<store::Key>,
38 pub is_pending_send: bool,
41 pub send_flow: FlowControl,
44 pub requested_send_capacity: WindowSize,
48 pub buffered_send_data: usize,
[all …]
|
| /external/swiftshader/src/Device/ |
| D | Stream.hpp | 22 struct Stream struct
24 const void *buffer = nullptr;
25 unsigned int robustnessSize = 0;
26 VkVertexInputRate inputRate = VK_VERTEX_INPUT_RATE_VERTEX;
27 unsigned int vertexStride = 0;
28 unsigned int instanceStride = 0;
29 VkFormat format = VK_FORMAT_UNDEFINED;
30 unsigned int offset = 0;
31 unsigned int binding = 0;
|
| /external/openscreen/cast/streaming/ |
| D | offer_messages.h | 46 struct Stream { struct
50 Stream::Type type, argument
77 struct AudioStream { argument
82 Stream stream; argument
|
| /external/rust/android-crates-io/crates/combine/src/stream/ |
| D | buffered.rs | 28 pub struct Stream<Input> struct
38 impl<Input> ResetStream for Stream<Input> argument
62 impl<Input> Stream<Input> impl
80 impl<Input> Positioned for Stream<Input> implementation
102 impl<Input> StreamOnce for Stream<Input> implementation
|
| D | state.rs | 7 pub struct Stream<S, U> { struct
12 impl<S, U> Positioned for Stream<S, U> argument
22 impl<S, U> ResetStream for Stream<S, U> implementation
39 impl<S, U> StreamOnce for Stream<S, U> implementation
58 impl<S, U> RangeStreamOnce for Stream<S, U> implementation
|
| D | span.rs | 38 pub struct Stream<S, E>(pub S, PhantomData<fn(E) -> E>); struct
40 impl<S, E> From<S> for Stream<S, E> { implementation
46 impl<S, E> ResetStream for Stream<S, E> implementation
71 impl<S, E> StreamOnce for Stream<S, E> implementation
97 impl<S, E> RangeStreamOnce for Stream<S, E> implementation
144 impl<S, E> Positioned for Stream<S, E> implementation
|
| /external/cronet/stable/third_party/llvm-libc/src/benchmarks/automemcpy/lib/ |
| D | CodeGen.cpp | 180 static raw_ostream &operator<<(raw_ostream &Stream, const ElementType &E) { in operator <<()
183 static raw_ostream &operator<<(raw_ostream &Stream, const Individual &O) { in operator <<()
186 static raw_ostream &operator<<(raw_ostream &Stream, const Overlap &O) { in operator <<()
189 static raw_ostream &operator<<(raw_ostream &Stream, const Loop &O) { in operator <<()
192 static raw_ostream &operator<<(raw_ostream &Stream, const AlignedLoop &O) { in operator <<()
196 static raw_ostream &operator<<(raw_ostream &Stream, const Accelerator &O) { in operator <<()
212 static raw_ostream &operator<<(raw_ostream &Stream, const Zero &O) { in operator <<()
220 static raw_ostream &operator<<(raw_ostream &Stream, const IfEq<T> &O) { in operator <<()
226 static raw_ostream &operator<<(raw_ostream &Stream, const IfLt<T> &O) { in operator <<()
234 static raw_ostream &operator<<(raw_ostream &Stream, in operator <<()
[all …]
|
| /external/cronet/tot/third_party/llvm-libc/src/benchmarks/automemcpy/lib/ |
| D | CodeGen.cpp | 180 static raw_ostream &operator<<(raw_ostream &Stream, const ElementType &E) { in operator <<()
183 static raw_ostream &operator<<(raw_ostream &Stream, const Individual &O) { in operator <<()
186 static raw_ostream &operator<<(raw_ostream &Stream, const Overlap &O) { in operator <<()
189 static raw_ostream &operator<<(raw_ostream &Stream, const Loop &O) { in operator <<()
192 static raw_ostream &operator<<(raw_ostream &Stream, const AlignedLoop &O) { in operator <<()
196 static raw_ostream &operator<<(raw_ostream &Stream, const Accelerator &O) { in operator <<()
212 static raw_ostream &operator<<(raw_ostream &Stream, const Zero &O) { in operator <<()
220 static raw_ostream &operator<<(raw_ostream &Stream, const IfEq<T> &O) { in operator <<()
226 static raw_ostream &operator<<(raw_ostream &Stream, const IfLt<T> &O) { in operator <<()
234 static raw_ostream &operator<<(raw_ostream &Stream, in operator <<()
[all …]
|
| /external/pigweed/pw_grpc/public/pw_grpc/ |
| D | pw_rpc_handler.h | 51 struct Stream { struct
52 StreamId id; argument
62 Result<Stream> LookupStream(StreamId id); argument
|
| D | connection.h | 180 struct Stream { struct
181 StreamId id; argument
182 bool half_closed;
183 bool started_response;
184 int32_t send_window;
187 multibuf::MultiBuf response_queue;
190 std::byte* assembly_buffer;
191 union {
206 void Reset() { in Reset()
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/ |
| D | externally_locked_stream.hpp | 37 stream_guard(externally_locked_stream<Stream, RecursiveMutex>& mtx) : in stream_guard()
43 stream_guard(externally_locked_stream<Stream, RecursiveMutex>& mtx, adopt_lock_t) : in stream_guard()
122 …inline const stream_guard<Stream, RecursiveMutex>& operator<<(const stream_guard<Stream, Recursive… in operator <<()
129 …inline const stream_guard<Stream, RecursiveMutex>& operator<<(const stream_guard<Stream, Recursive… in operator <<() argument
136 …inline const stream_guard<Stream, RecursiveMutex>& operator>>(const stream_guard<Stream, Recursive… in operator >>()
143 …inline stream_guard<Stream, RecursiveMutex> operator<<(externally_locked_stream<Stream, RecursiveM… in operator <<()
151 …rd<Stream, RecursiveMutex> operator<<(externally_locked_stream<Stream, RecursiveMutex>& mtx, Strea… in operator <<() argument
159 …inline stream_guard<Stream, RecursiveMutex> operator>>(externally_locked_stream<Stream, RecursiveM… in operator >>()
|
| /external/mtools/ |
| D | stream.c | 34 void init_head(Stream_t *Stream, struct Class_t *Class, Stream_t *Next) in init_head()
41 int flush_stream(Stream_t *Stream) in flush_stream()
53 Stream_t *copy_stream(Stream_t *Stream) in copy_stream()
60 int free_stream(Stream_t **Stream) in free_stream()
83 int set_geom_pass_through(Stream_t *Stream, device_t *dev, device_t *orig_dev) in set_geom_pass_through()
95 int get_data_pass_through(Stream_t *Stream, time_t *date, mt_off_t *size, in get_data_pass_through()
101 ssize_t pread_pass_through(Stream_t *Stream, char *buf, in pread_pass_through()
107 ssize_t pwrite_pass_through(Stream_t *Stream, char *buf, in pwrite_pass_through()
113 doscp_t *get_dosConvert_pass_through(Stream_t *Stream) in get_dosConvert_pass_through()
|
| D | file.c | 67 static File_t *getUnbufferedFile(Stream_t *Stream) in getUnbufferedFile()
79 Fs_t *getFs(Stream_t *Stream) in getFs()
84 struct dirCache_t **getDirCacheP(Stream_t *Stream) in getDirCacheP()
89 direntry_t *getDirentry(Stream_t *Stream) in getDirentry()
183 Stream_t *Stream = GetFs(Dir); in countBlocks() local
194 Stream_t *Stream = GetFs(Dir); in countBytes() local
201 void printFat(Stream_t *Stream) in printFat()
243 void printFatWithOffset(Stream_t *Stream, off_t offset) { in printFatWithOffset()
406 static ssize_t read_file(Stream_t *Stream, char *buf, size_t ilen) in read_file()
426 static ssize_t write_file(Stream_t *Stream, char *buf, size_t ilen) in write_file()
[all …]
|
| D | fat.c | 65 static FatMap_t *GetFatMap(Fs_t *Stream) in GetFatMap()
86 static __inline__ int locate(Fs_t *Stream, uint32_t offset, in locate()
235 static unsigned char *getAddress(Fs_t *Stream, in getAddress()
260 static int readByte(Fs_t *Stream, unsigned int start) in readByte()
289 static unsigned int fat12_decode(Fs_t *Stream, unsigned int num) in fat12_decode()
311 static void fat12_encode(Fs_t *Stream, unsigned int num, unsigned int code) in fat12_encode()
337 static unsigned int fat16_decode(Fs_t *Stream, unsigned int num) in fat16_decode()
345 static void fat16_encode(Fs_t *Stream, unsigned int num, unsigned int code) in fat16_encode()
362 static unsigned int fast_fat16_decode(Fs_t *Stream, unsigned int num) in fast_fat16_decode()
372 static void fast_fat16_encode(Fs_t *Stream, unsigned int num, unsigned int code) in fast_fat16_encode()
[all …]
|
| D | force_io.c | 30 static ssize_t force_pio(Stream_t *Stream, in force_pio()
54 static ssize_t write_wrapper(Stream_t *Stream, char *buf, in write_wrapper()
60 ssize_t force_write(Stream_t *Stream, char *buf, size_t len) in force_write()
65 ssize_t force_pwrite(Stream_t *Stream, char *buf, mt_off_t start, size_t len) in force_pwrite()
71 ssize_t force_pread(Stream_t *Stream, char *buf, mt_off_t start, size_t len) in force_pread()
|
| D | plain_io.c | 101 static ssize_t file_read(Stream_t *Stream, char *buf, size_t len) in file_read()
107 static ssize_t file_write(Stream_t *Stream, char *buf, size_t len) in file_write()
113 static ssize_t file_pread(Stream_t *Stream, char *buf, in file_pread()
120 static ssize_t file_pwrite(Stream_t *Stream, char *buf, in file_pwrite()
137 static int file_free(Stream_t *Stream) in file_free()
172 static int file_geom(Stream_t *Stream, struct device *dev, in file_geom()
200 static int file_data(Stream_t *Stream, time_t *date, mt_off_t *size, in file_data()
453 int get_fd(Stream_t *Stream) in get_fd()
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | streams.rs | 54 pub struct Stream { struct
56 receiver: Receiver<Box<StreamMsg>>, argument
61 current_state: StreamState, argument
75 impl Stream { argument
335 impl Drop for Stream { implementation
|
| /external/libbrillo/brillo/streams/ |
| D | stream_test.cc | 92 TEST(Stream, TruncateBlocking) { in TEST() argument
99 TEST(Stream, SetPosition) { in TEST() argument
117 TEST(Stream, ReadAsync) { in TEST() argument
166 TEST(Stream, ReadAsync_DontWaitForData) { in TEST() argument
206 TEST(Stream, ReadAllAsync) { in TEST() argument
255 TEST(Stream, ReadAllAsync_EOS) { in TEST() argument
289 TEST(Stream, ReadBlocking) { in TEST() argument
342 TEST(Stream, ReadAllBlocking) { in TEST() argument
369 TEST(Stream, WriteAsync) { in TEST() argument
408 TEST(Stream, WriteAllAsync) { in TEST() argument
[all …]
|
| /external/rust/android-crates-io/crates/winnow/src/combinator/ |
| D | core.rs | 11 Input: Stream, in rest()
22 Input: Stream, in rest_len()
49 pub fn opt<Input: Stream, Output, Error, ParseNext>( in opt()
95 Input: Stream, in cond()
133 Input: Stream, in peek()
176 Input: Stream, in eof()
214 Input: Stream, in not()
291 Input: Stream, in cut_err()
308 Input: Stream, in backtrack_err()
338 Input: Stream, in todo()
[all …]
|
| /external/pigweed/pw_stream/ |
| D | stream_test.cc | 147 TEST(Stream, NonSeekableReader) { in TEST() argument
154 TEST(Stream, RelativeSeekableReader) { in TEST() argument
161 TEST(Stream, SeekableReader) { in TEST() argument
165 TEST(Stream, NonSeekableWriter) { in TEST() argument
172 TEST(Stream, RelativeSeekableWriter) { in TEST() argument
179 TEST(Stream, SeekableWriter) { in TEST() argument
183 TEST(Stream, NonSeekableReaderWriter) { in TEST() argument
190 TEST(Stream, RelativeSeekableReaderWriter) { in TEST() argument
197 TEST(Stream, SeekableReaderWriter) { in TEST() argument
232 TEST(Stream, ReadExact_Works) { in TEST() argument
[all …]
|
| /external/rust/android-crates-io/crates/winnow/src/token/ |
| D | mod.rs | 60 Input: StreamIsPartial + Stream, in any()
78 I: Stream, in any_()
272 Input: StreamIsPartial + Stream, in one_of()
325 Input: StreamIsPartial + Stream, in none_of()
491 Input: StreamIsPartial + Stream, in take_while()
527 fn take_till0<P, I: StreamIsPartial + Stream, E: ParserError<I>, const PARTIAL: bool>( in take_till0() argument
544 fn take_till1<P, I: StreamIsPartial + Stream, E: ParserError<I>, const PARTIAL: bool>( in take_till1() argument
574 I: Stream, in take_till_m_n()
683 Input: StreamIsPartial + Stream, in take_till()
794 Input: StreamIsPartial + Stream, in take()
[all …]
|
| /external/rust/android-crates-io/crates/quiche/src/h3/ |
| D | stream.rs | 121 pub struct Stream { struct
123 id: u64,
126 ty: Option<Type>,
129 state: State,
132 state_buf: Vec<u8>,
135 state_len: usize,
161 impl Stream { argument
166 pub fn new(id: u64, is_local: bool) -> Stream { in new()
638 fn open_uni(b: &mut octets::OctetsMut, ty: u64) -> Result<Stream> { in open_uni()
648 stream: &mut Stream, ty: u64, cursor: &mut std::io::Cursor<Vec<u8>>, in parse_uni()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/ObjectYAML/ |
| D | MinidumpYAML.h | 27 struct Stream { struct
28 enum class StreamKind { argument
39 Stream(StreamKind Kind, minidump::StreamType Type) : Kind(Kind), Type(Type) {} in Stream() function
42 const StreamKind Kind; argument
43 const minidump::StreamType Type; argument
67 : Stream(EntryT::Kind, EntryT::Type), Entries(std::move(Entries)) {} in Stream() function
153 : Stream(StreamKind::RawContent, Type), Content(Content), in Stream() function
190 : Stream(StreamKind::TextContent, Type), Text(Text) {} in Stream() function
|
| /external/swiftshader/third_party/llvm-16.0/llvm/include/llvm/ObjectYAML/ |
| D | MinidumpYAML.h | 27 struct Stream { struct
28 enum class StreamKind { argument
39 Stream(StreamKind Kind, minidump::StreamType Type) : Kind(Kind), Type(Type) {} in Stream() argument
42 const StreamKind Kind; argument
43 const minidump::StreamType Type; argument
67 : Stream(EntryT::Kind, EntryT::Type), Entries(std::move(Entries)) {} in Stream() function
153 : Stream(StreamKind::RawContent, Type), Content(Content), in Stream() function
190 : Stream(StreamKind::TextContent, Type), Text(Text) {} in Stream() function
|
| /external/clang/lib/Frontend/ |
| D | SerializedDiagnosticReader.cpp | 32 llvm::BitstreamCursor Stream(StreamFile); in readDiagnostics() local
77 llvm::BitstreamCursor &Stream, unsigned &BlockOrRecordID) { in skipUntilRecordOrBlock()
111 SerializedDiagnosticReader::readMetaBlock(llvm::BitstreamCursor &Stream) { in readMetaBlock()
149 SerializedDiagnosticReader::readDiagnosticBlock(llvm::BitstreamCursor &Stream) { in readDiagnosticBlock()
|