Home
last modified time | relevance | path

Searched refs:grpc_slice_buffer (Results 1 – 25 of 94) sorted by relevance

1234

/external/grpc-grpc/include/grpc/
Dslice_buffer.h31 GPRAPI void grpc_slice_buffer_init(grpc_slice_buffer* sb);
33 GPRAPI void grpc_slice_buffer_destroy(grpc_slice_buffer* sb);
37 GPRAPI void grpc_slice_buffer_add(grpc_slice_buffer* sb, grpc_slice slice);
45 GPRAPI size_t grpc_slice_buffer_add_indexed(grpc_slice_buffer* sb,
47 GPRAPI void grpc_slice_buffer_addn(grpc_slice_buffer* sb, grpc_slice* slices,
51 GPRAPI uint8_t* grpc_slice_buffer_tiny_add(grpc_slice_buffer* sb, size_t len);
53 GPRAPI void grpc_slice_buffer_pop(grpc_slice_buffer* sb);
55 GPRAPI void grpc_slice_buffer_reset_and_unref(grpc_slice_buffer* sb);
57 GPRAPI void grpc_slice_buffer_swap(grpc_slice_buffer* a, grpc_slice_buffer* b);
59 GPRAPI void grpc_slice_buffer_move_into(grpc_slice_buffer* src,
[all …]
/external/grpc-grpc/src/core/tsi/
Dtransport_security_grpc.h43 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* unprotected_slices,
44 grpc_slice_buffer* protected_slices);
53 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* protected_slices,
54 grpc_slice_buffer* unprotected_slices);
62 grpc_slice_buffer* unprotected_slices,
63 grpc_slice_buffer* protected_slices);
65 grpc_slice_buffer* protected_slices,
66 grpc_slice_buffer* unprotected_slices);
Dtransport_security_grpc.cc42 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* unprotected_slices, in tsi_zero_copy_grpc_protector_protect()
43 grpc_slice_buffer* protected_slices) { in tsi_zero_copy_grpc_protector_protect()
53 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* protected_slices, in tsi_zero_copy_grpc_protector_unprotect()
54 grpc_slice_buffer* unprotected_slices) { in tsi_zero_copy_grpc_protector_unprotect()
/external/grpc-grpc/test/core/compression/
Dmessage_compress_test.cc46 grpc_slice_buffer input; in assert_passthrough()
47 grpc_slice_buffer compressed_raw; in assert_passthrough()
48 grpc_slice_buffer compressed; in assert_passthrough()
49 grpc_slice_buffer output; in assert_passthrough()
148 grpc_slice_buffer input; in test_tiny_data_compress()
149 grpc_slice_buffer output; in test_tiny_data_compress()
170 grpc_slice_buffer input; in test_bad_decompression_data_crc()
171 grpc_slice_buffer corrupted; in test_bad_decompression_data_crc()
172 grpc_slice_buffer output; in test_bad_decompression_data_crc()
200 grpc_slice_buffer input; in test_bad_decompression_data_trailing_garbage()
[all …]
/external/grpc-grpc/src/core/lib/compression/
Dmessage_compress.cc34 static int zlib_body(z_stream* zs, grpc_slice_buffer* input, in zlib_body()
35 grpc_slice_buffer* output, in zlib_body()
89 static int zlib_compress(grpc_slice_buffer* input, grpc_slice_buffer* output, in zlib_compress()
114 static int zlib_decompress(grpc_slice_buffer* input, grpc_slice_buffer* output, in zlib_decompress()
138 static int copy(grpc_slice_buffer* input, grpc_slice_buffer* output) { in copy()
147 grpc_slice_buffer* input, grpc_slice_buffer* output) { in compress_inner()
165 grpc_slice_buffer* input, grpc_slice_buffer* output) { in grpc_msg_compress()
174 grpc_slice_buffer* input, grpc_slice_buffer* output) { in grpc_msg_decompress()
Dstream_compression.h54 bool (*compress)(grpc_stream_compression_context* ctx, grpc_slice_buffer* in,
55 grpc_slice_buffer* out, size_t* output_size,
58 grpc_slice_buffer* in, grpc_slice_buffer* out,
80 grpc_slice_buffer* in, grpc_slice_buffer* out,
92 grpc_slice_buffer* in, grpc_slice_buffer* out,
Dstream_compression_identity.cc33 static void grpc_stream_compression_pass_through(grpc_slice_buffer* in, in grpc_stream_compression_pass_through()
34 grpc_slice_buffer* out, in grpc_stream_compression_pass_through()
51 grpc_slice_buffer* in, in grpc_stream_compress_identity()
52 grpc_slice_buffer* out, in grpc_stream_compress_identity()
64 grpc_stream_compression_context* ctx, grpc_slice_buffer* in, in grpc_stream_decompress_identity()
65 grpc_slice_buffer* out, size_t* output_size, size_t max_output_size, in grpc_stream_decompress_identity()
Dmessage_compress.h32 grpc_slice_buffer* input, grpc_slice_buffer* output);
38 grpc_slice_buffer* input, grpc_slice_buffer* output);
Dstream_compression.cc30 grpc_slice_buffer* in, grpc_slice_buffer* out, in grpc_stream_compress()
38 grpc_slice_buffer* in, grpc_slice_buffer* out, in grpc_stream_decompress()
Dstream_compression_gzip.cc38 grpc_slice_buffer* in, grpc_slice_buffer* out, in gzip_flate()
138 grpc_slice_buffer* in, in grpc_stream_compress_gzip()
139 grpc_slice_buffer* out, in grpc_stream_compress_gzip()
168 grpc_slice_buffer* in, in grpc_stream_decompress_gzip()
169 grpc_slice_buffer* out, in grpc_stream_decompress_gzip()
/external/grpc-grpc/src/core/lib/slice/
Dslice_buffer.cc35 static void maybe_embiggen(grpc_slice_buffer* sb) { in maybe_embiggen()
63 void grpc_slice_buffer_init(grpc_slice_buffer* sb) { in grpc_slice_buffer_init()
70 void grpc_slice_buffer_destroy_internal(grpc_slice_buffer* sb) { in grpc_slice_buffer_destroy_internal()
77 void grpc_slice_buffer_destroy(grpc_slice_buffer* sb) { in grpc_slice_buffer_destroy()
86 uint8_t* grpc_slice_buffer_tiny_add(grpc_slice_buffer* sb, size_t n) { in grpc_slice_buffer_tiny_add()
111 size_t grpc_slice_buffer_add_indexed(grpc_slice_buffer* sb, grpc_slice s) { in grpc_slice_buffer_add_indexed()
120 void grpc_slice_buffer_add(grpc_slice_buffer* sb, grpc_slice s) { in grpc_slice_buffer_add()
158 void grpc_slice_buffer_addn(grpc_slice_buffer* sb, grpc_slice* s, size_t n) { in grpc_slice_buffer_addn()
165 void grpc_slice_buffer_pop(grpc_slice_buffer* sb) { in grpc_slice_buffer_pop()
172 void grpc_slice_buffer_reset_and_unref_internal(grpc_slice_buffer* sb) { in grpc_slice_buffer_reset_and_unref_internal()
[all …]
Dslice_internal.h29 void grpc_slice_buffer_reset_and_unref_internal(grpc_slice_buffer* sb);
30 void grpc_slice_buffer_partial_unref_internal(grpc_slice_buffer* sb,
32 void grpc_slice_buffer_destroy_internal(grpc_slice_buffer* sb);
/external/grpc-grpc/src/core/tsi/alts/zero_copy_frame_protector/
Dalts_grpc_record_protocol_common.h36 grpc_slice_buffer* unprotected_slices,
37 grpc_slice_buffer* protected_slices);
39 grpc_slice_buffer* protected_slices,
40 grpc_slice_buffer* unprotected_slices);
51 grpc_slice_buffer header_sb;
65 alts_grpc_record_protocol* rp, const grpc_slice_buffer* sb);
72 void alts_grpc_record_protocol_copy_slice_buffer(const grpc_slice_buffer* src,
Dalts_grpc_record_protocol.h50 alts_grpc_record_protocol* self, grpc_slice_buffer* unprotected_slices,
51 grpc_slice_buffer* protected_slices);
68 alts_grpc_record_protocol* self, grpc_slice_buffer* protected_slices,
69 grpc_slice_buffer* unprotected_slices);
Dalts_grpc_record_protocol_common.cc36 const grpc_slice_buffer* sb) { in ensure_iovec_buf_size()
51 alts_grpc_record_protocol* rp, const grpc_slice_buffer* sb) { in alts_grpc_record_protocol_convert_slice_buffer_to_iovec()
60 void alts_grpc_record_protocol_copy_slice_buffer(const grpc_slice_buffer* src, in alts_grpc_record_protocol_copy_slice_buffer()
124 alts_grpc_record_protocol* self, grpc_slice_buffer* unprotected_slices, in alts_grpc_record_protocol_protect()
125 grpc_slice_buffer* protected_slices) { in alts_grpc_record_protocol_protect()
138 alts_grpc_record_protocol* self, grpc_slice_buffer* protected_slices, in alts_grpc_record_protocol_unprotect()
139 grpc_slice_buffer* unprotected_slices) { in alts_grpc_record_protocol_unprotect()
Dalts_zero_copy_grpc_protector.cc55 grpc_slice_buffer unprotected_staging_sb;
56 grpc_slice_buffer protected_sb;
57 grpc_slice_buffer protected_staging_sb;
67 static bool read_frame_size(const grpc_slice_buffer* sb, in read_frame_size()
150 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* unprotected_slices, in alts_zero_copy_grpc_protector_protect()
151 grpc_slice_buffer* protected_slices) { in alts_zero_copy_grpc_protector_protect()
176 tsi_zero_copy_grpc_protector* self, grpc_slice_buffer* protected_slices, in alts_zero_copy_grpc_protector_unprotect()
177 grpc_slice_buffer* unprotected_slices) { in alts_zero_copy_grpc_protector_unprotect()
Dalts_grpc_integrity_only_record_protocol.cc36 grpc_slice_buffer data_sb;
43 alts_grpc_record_protocol* rp, grpc_slice_buffer* unprotected_slices, in alts_grpc_integrity_only_extra_copy_protect()
44 grpc_slice_buffer* protected_slices) { in alts_grpc_integrity_only_extra_copy_protect()
79 alts_grpc_record_protocol* rp, grpc_slice_buffer* unprotected_slices, in alts_grpc_integrity_only_protect()
80 grpc_slice_buffer* protected_slices) { in alts_grpc_integrity_only_protect()
121 alts_grpc_record_protocol* rp, grpc_slice_buffer* protected_slices, in alts_grpc_integrity_only_unprotect()
122 grpc_slice_buffer* unprotected_slices) { in alts_grpc_integrity_only_unprotect()
/external/grpc-grpc/test/core/tsi/alts/zero_copy_frame_protector/
Dalts_zero_copy_grpc_protector_test.cc47 grpc_slice_buffer original_sb;
48 grpc_slice_buffer duplicate_sb;
49 grpc_slice_buffer staging_sb;
50 grpc_slice_buffer protected_sb;
51 grpc_slice_buffer unprotected_sb;
56 static void create_random_slice_buffer(grpc_slice_buffer* sb, in create_random_slice_buffer()
57 grpc_slice_buffer* dup_sb, in create_random_slice_buffer()
68 static uint8_t* pointer_to_nth_byte(grpc_slice_buffer* sb, size_t index) { in pointer_to_nth_byte()
83 static bool are_slice_buffers_equal(grpc_slice_buffer* first, in are_slice_buffers_equal()
84 grpc_slice_buffer* second) { in are_slice_buffers_equal()
Dalts_grpc_record_protocol_test.cc47 grpc_slice_buffer original_sb;
48 grpc_slice_buffer duplicate_sb;
49 grpc_slice_buffer protected_sb;
50 grpc_slice_buffer unprotected_sb;
55 static void create_random_slice_buffer(grpc_slice_buffer* sb) { in create_random_slice_buffer()
66 static uint8_t* pointer_to_nth_byte(grpc_slice_buffer* sb, size_t index) { in pointer_to_nth_byte()
81 static bool are_slice_buffers_equal(grpc_slice_buffer* first, in are_slice_buffers_equal()
82 grpc_slice_buffer* second) { in are_slice_buffers_equal()
100 static void alter_random_byte(grpc_slice_buffer* sb) { in alter_random_byte()
381 grpc_slice_buffer temp_sb; in input_check()
/external/grpc-grpc/src/core/lib/iomgr/
Dendpoint.h39 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb);
40 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
57 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices,
78 void grpc_endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* slices,
/external/grpc-grpc/test/core/slice/
Dslice_string_helpers_test.cc64 grpc_slice_buffer* parts; in test_strsplit()
70 static_cast<grpc_slice_buffer*>(gpr_malloc(sizeof(grpc_slice_buffer))); in test_strsplit()
131 grpc_slice_buffer* parts; in test_strsplit_nospace()
137 static_cast<grpc_slice_buffer*>(gpr_malloc(sizeof(grpc_slice_buffer))); in test_strsplit_nospace()
/external/grpc-grpc/test/core/util/
Dslice_splitter.h45 grpc_slice_buffer* dst);
46 void grpc_split_slice_buffer(grpc_slice_split_mode mode, grpc_slice_buffer* src,
47 grpc_slice_buffer* dst);
/external/grpc-grpc/src/core/lib/transport/
Dbyte_stream.h91 SliceBufferByteStream(grpc_slice_buffer* slice_buffer, uint32_t flags);
102 grpc_slice_buffer backing_buffer_;
153 grpc_slice_buffer* cache_buffer() { return &cache_buffer_; } in cache_buffer()
159 grpc_slice_buffer cache_buffer_;
/external/grpc-grpc/test/core/bad_client/
Dbad_client.h38 grpc_slice_buffer* incoming, void* arg);
79 bool client_connection_preface_validator(grpc_slice_buffer* incoming,
85 bool rst_stream_client_validator(grpc_slice_buffer* incoming, void* arg);
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dframe_data.h74 void grpc_chttp2_encode_data(uint32_t id, grpc_slice_buffer* inbuf,
77 grpc_slice_buffer* outbuf);
81 grpc_slice_buffer* slices, grpc_slice* slice_out,

1234