| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | byte_buffer_reader.cc | 53 grpc_slice_buffer* slice_buffer; in grpc_byte_buffer_reader_peek() local
54 slice_buffer = &reader->buffer_out->data.raw.slice_buffer; in grpc_byte_buffer_reader_peek()
55 if (reader->current.index < slice_buffer->count) { in grpc_byte_buffer_reader_peek()
56 *slice = &slice_buffer->slices[reader->current.index]; in grpc_byte_buffer_reader_peek()
70 grpc_slice_buffer* slice_buffer; in grpc_byte_buffer_reader_next() local
71 slice_buffer = &reader->buffer_out->data.raw.slice_buffer; in grpc_byte_buffer_reader_next()
72 if (reader->current.index < slice_buffer->count) { in grpc_byte_buffer_reader_next()
74 slice_buffer->slices[reader->current.index]); in grpc_byte_buffer_reader_next()
|
| D | byte_buffer.cc | 42 grpc_slice_buffer_init(&bb->data.raw.slice_buffer); in grpc_raw_compressed_byte_buffer_create()
45 grpc_slice_buffer_add(&bb->data.raw.slice_buffer, slices[i]); in grpc_raw_compressed_byte_buffer_create()
57 grpc_slice_buffer_init(&bb->data.raw.slice_buffer); in grpc_raw_byte_buffer_from_reader()
60 grpc_slice_buffer_add(&bb->data.raw.slice_buffer, slice); in grpc_raw_byte_buffer_from_reader()
69 bb->data.raw.slice_buffer.slices, bb->data.raw.slice_buffer.count, in grpc_byte_buffer_copy()
80 grpc_slice_buffer_destroy_internal(&bb->data.raw.slice_buffer); in grpc_byte_buffer_destroy()
89 return bb->data.raw.slice_buffer.length; in grpc_byte_buffer_length()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | byte_buffer.cc | 42 grpc_slice_buffer_init(&bb->data.raw.slice_buffer); in grpc_raw_compressed_byte_buffer_create()
45 grpc_slice_buffer_add(&bb->data.raw.slice_buffer, slices[i]); in grpc_raw_compressed_byte_buffer_create()
57 grpc_slice_buffer_init(&bb->data.raw.slice_buffer); in grpc_raw_byte_buffer_from_reader()
60 grpc_slice_buffer_add(&bb->data.raw.slice_buffer, slice); in grpc_raw_byte_buffer_from_reader()
69 bb->data.raw.slice_buffer.slices, bb->data.raw.slice_buffer.count, in grpc_byte_buffer_copy()
80 grpc_slice_buffer_destroy_internal(&bb->data.raw.slice_buffer); in grpc_byte_buffer_destroy()
89 return bb->data.raw.slice_buffer.length; in grpc_byte_buffer_length()
|
| D | byte_buffer_reader.cc | 59 &reader->buffer_in->data.raw.slice_buffer, in grpc_byte_buffer_reader_init()
98 grpc_slice_buffer* slice_buffer; in grpc_byte_buffer_reader_next() local
99 slice_buffer = &reader->buffer_out->data.raw.slice_buffer; in grpc_byte_buffer_reader_next()
100 if (reader->current.index < slice_buffer->count) { in grpc_byte_buffer_reader_next()
102 slice_buffer->slices[reader->current.index]); in grpc_byte_buffer_reader_next()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 196 grpc_slice_buffer slice_buffer; in EncodeRequest() local
197 grpc_slice_buffer_init(&slice_buffer); in EncodeRequest()
198 grpc_slice_buffer_add(&slice_buffer, request_slice); in EncodeRequest()
199 send_message->Init(&slice_buffer, 0); in EncodeRequest()
200 grpc_slice_buffer_destroy_internal(&slice_buffer); in EncodeRequest()
205 bool DecodeResponse(grpc_slice_buffer* slice_buffer, grpc_error** error) { in DecodeResponse() argument
207 if (slice_buffer->length == 0) { in DecodeResponse()
215 if (slice_buffer->count == 1) { in DecodeResponse()
216 recv_message = GRPC_SLICE_START_PTR(slice_buffer->slices[0]); in DecodeResponse()
218 recv_message = static_cast<uint8_t*>(gpr_malloc(slice_buffer->length)); in DecodeResponse()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | byte_stream.cc | 37 SliceBufferByteStream::SliceBufferByteStream(grpc_slice_buffer* slice_buffer, in SliceBufferByteStream() argument
39 : ByteStream(static_cast<uint32_t>(slice_buffer->length), flags) { in SliceBufferByteStream()
40 GPR_ASSERT(slice_buffer->length <= UINT32_MAX); in SliceBufferByteStream()
42 grpc_slice_buffer_swap(slice_buffer, &backing_buffer_); in SliceBufferByteStream()
|
| D | byte_stream.h | 93 SliceBufferByteStream(grpc_slice_buffer* slice_buffer, uint32_t flags);
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | byte_stream.cc | 37 SliceBufferByteStream::SliceBufferByteStream(grpc_slice_buffer* slice_buffer, in SliceBufferByteStream() argument
39 : ByteStream(static_cast<uint32_t>(slice_buffer->length), flags) { in SliceBufferByteStream()
40 GPR_ASSERT(slice_buffer->length <= UINT32_MAX); in SliceBufferByteStream()
42 grpc_slice_buffer_swap(slice_buffer, &backing_buffer_); in SliceBufferByteStream()
|
| D | byte_stream.h | 91 SliceBufferByteStream(grpc_slice_buffer* slice_buffer, uint32_t flags);
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | endpoint_tests.cc | 278 grpc_slice_buffer slice_buffer; in multiple_shutdown_test() local
279 grpc_slice_buffer_init(&slice_buffer); in multiple_shutdown_test()
283 grpc_endpoint_read(f.client_ep, &slice_buffer, in multiple_shutdown_test()
290 grpc_endpoint_read(f.client_ep, &slice_buffer, in multiple_shutdown_test()
294 grpc_slice_buffer_add(&slice_buffer, grpc_slice_from_copied_string("a")); in multiple_shutdown_test()
295 grpc_endpoint_write(f.client_ep, &slice_buffer, in multiple_shutdown_test()
304 grpc_slice_buffer_destroy_internal(&slice_buffer); in multiple_shutdown_test()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | frame_goaway.cc | 153 grpc_slice_buffer* slice_buffer) { in grpc_chttp2_goaway_append() argument
184 grpc_slice_buffer_add(slice_buffer, header); in grpc_chttp2_goaway_append()
185 grpc_slice_buffer_add(slice_buffer, debug_data); in grpc_chttp2_goaway_append()
|
| D | frame_goaway.h | 60 grpc_slice_buffer* slice_buffer);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | frame_goaway.cc | 153 grpc_slice_buffer* slice_buffer) { in grpc_chttp2_goaway_append() argument
184 grpc_slice_buffer_add(slice_buffer, header); in grpc_chttp2_goaway_append()
185 grpc_slice_buffer_add(slice_buffer, debug_data); in grpc_chttp2_goaway_append()
|
| D | frame_goaway.h | 60 grpc_slice_buffer* slice_buffer);
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | proto_buffer_writer.h | 70 slice_buffer_ = &bp->data.raw.slice_buffer; in ProtoBufferWriter()
148 grpc_slice_buffer* slice_buffer() { return slice_buffer_; } in slice_buffer() function
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | proto_buffer_writer.h | 70 slice_buffer_ = &bp->data.raw.slice_buffer; in ProtoBufferWriter()
148 grpc_slice_buffer* slice_buffer() { return slice_buffer_; } in slice_buffer() function
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | proto_buffer_writer.h | 70 slice_buffer_ = &bp->data.raw.slice_buffer; in ProtoBufferWriter()
148 grpc_slice_buffer* slice_buffer() { return slice_buffer_; } in slice_buffer() function
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 288 static char* slice_buffer_to_string(grpc_slice_buffer* slice_buffer) { in slice_buffer_to_string() argument
290 static_cast<char*>(gpr_malloc(slice_buffer->length + 1)); in slice_buffer_to_string()
292 for (size_t i = 0; i < slice_buffer->count; ++i) { in slice_buffer_to_string()
294 GRPC_SLICE_START_PTR(slice_buffer->slices[i]), in slice_buffer_to_string()
295 GRPC_SLICE_LENGTH(slice_buffer->slices[i])); in slice_buffer_to_string()
296 offset += GRPC_SLICE_LENGTH(slice_buffer->slices[i]); in slice_buffer_to_string()
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 238 static char* slice_buffer_to_string(grpc_slice_buffer* slice_buffer) { in slice_buffer_to_string() argument
240 static_cast<char*>(gpr_malloc(slice_buffer->length + 1)); in slice_buffer_to_string()
242 for (size_t i = 0; i < slice_buffer->count; ++i) { in slice_buffer_to_string()
244 GRPC_SLICE_START_PTR(slice_buffer->slices[i]), in slice_buffer_to_string()
245 GRPC_SLICE_LENGTH(slice_buffer->slices[i])); in slice_buffer_to_string()
246 offset += GRPC_SLICE_LENGTH(slice_buffer->slices[i]); in slice_buffer_to_string()
|
| /external/grpc-grpc/test/core/surface/ |
| D | byte_buffer_reader_test.cc | 189 GPR_ASSERT(buffer_from_reader->data.raw.slice_buffer.count == 1); in test_byte_buffer_from_reader()
191 buffer_from_reader->data.raw.slice_buffer.slices[0]), in test_byte_buffer_from_reader()
|
| /external/perfetto/src/trace_processor/importers/proto/ |
| D | graphics_frame_event_parser.cc | 228 char slice_buffer[4096]; in CreatePhaseEvent() local
232 base::StringWriter slice_name(slice_buffer, base::ArraySize(slice_buffer)); in CreatePhaseEvent()
|
| /external/flatbuffers/include/flatbuffers/ |
| D | grpc.h | 298 (buffer->data.raw.slice_buffer.count == 1)) { in Deserialize()
300 grpc_slice slice = buffer->data.raw.slice_buffer.slices[0]; in Deserialize()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | cq_verifier.cc | 137 a = merge_slices(rbb->data.raw.slice_buffer.slices, in raw_byte_buffer_eq_slice()
138 rbb->data.raw.slice_buffer.count); in raw_byte_buffer_eq_slice()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/ |
| D | module.modulemap | 45 header "slice_buffer.h"
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/ |
| D | module.modulemap | 45 header "slice_buffer.h"
|