Home
last modified time | relevance | path

Searched refs:grpc_byte_buffer (Results 1 – 25 of 109) sorted by relevance

12345

/external/grpc-grpc/src/core/lib/surface/
Dbyte_buffer.cc28 grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slices, in grpc_raw_byte_buffer_create()
34 grpc_byte_buffer* grpc_raw_compressed_byte_buffer_create( in grpc_raw_compressed_byte_buffer_create()
38 grpc_byte_buffer* bb = in grpc_raw_compressed_byte_buffer_create()
39 static_cast<grpc_byte_buffer*>(gpr_malloc(sizeof(grpc_byte_buffer))); in grpc_raw_compressed_byte_buffer_create()
50 grpc_byte_buffer* grpc_raw_byte_buffer_from_reader( in grpc_raw_byte_buffer_from_reader()
52 grpc_byte_buffer* bb = in grpc_raw_byte_buffer_from_reader()
53 static_cast<grpc_byte_buffer*>(gpr_malloc(sizeof(grpc_byte_buffer))); in grpc_raw_byte_buffer_from_reader()
65 grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb) { in grpc_byte_buffer_copy()
75 void grpc_byte_buffer_destroy(grpc_byte_buffer* bb) { in grpc_byte_buffer_destroy()
86 size_t grpc_byte_buffer_length(grpc_byte_buffer* bb) { in grpc_byte_buffer_length()
/external/grpc-grpc/include/grpc/impl/codegen/
Dbyte_buffer.h34 GRPCAPI grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slices,
43 GRPCAPI grpc_byte_buffer* grpc_raw_compressed_byte_buffer_create(
50 GRPCAPI grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb);
53 GRPCAPI size_t grpc_byte_buffer_length(grpc_byte_buffer* bb);
56 GRPCAPI void grpc_byte_buffer_destroy(grpc_byte_buffer* byte_buffer);
65 grpc_byte_buffer* buffer);
81 GRPCAPI grpc_byte_buffer* grpc_raw_byte_buffer_from_reader(
Dbyte_buffer_reader.h26 struct grpc_byte_buffer;
29 struct grpc_byte_buffer* buffer_in;
30 struct grpc_byte_buffer* buffer_out;
Dgrpc_types.h40 typedef struct grpc_byte_buffer { struct
52 } grpc_byte_buffer; argument
532 struct grpc_byte_buffer;
564 struct grpc_byte_buffer* send_message;
589 struct grpc_byte_buffer** recv_message;
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dbyte_buffer.h72 static_assert(std::is_same<decltype(buffer_), grpc_byte_buffer*>::value, in ByteBuffer()
75 static_assert(sizeof(ByteBuffer) == sizeof(grpc_byte_buffer*), in ByteBuffer()
129 grpc_byte_buffer* tmp = other->buffer_; in Swap()
157 grpc_byte_buffer* buffer_;
160 void set_buffer(grpc_byte_buffer* buf) { in set_buffer()
167 grpc_byte_buffer* c_buffer() { return buffer_; } in c_buffer()
168 grpc_byte_buffer** c_buffer_ptr() { return &buffer_; } in c_buffer_ptr()
175 operator grpc_byte_buffer*() { return bbuf_->buffer_; }
176 operator grpc_byte_buffer**() { return &bbuf_->buffer_; }
Dcore_codegen_interface.h82 virtual grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb) = 0;
83 virtual void grpc_byte_buffer_destroy(grpc_byte_buffer* bb) = 0;
84 virtual size_t grpc_byte_buffer_length(grpc_byte_buffer* bb)
88 grpc_byte_buffer* buffer)
95 virtual grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slice,
Dcore_codegen.h74 grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb) override;
75 void grpc_byte_buffer_destroy(grpc_byte_buffer* bb) override;
76 size_t grpc_byte_buffer_length(grpc_byte_buffer* bb) override;
79 grpc_byte_buffer* buffer) override;
85 grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slice,
/external/grpc-grpc/test/core/surface/
Dbyte_buffer_reader_test.cc39 grpc_byte_buffer* buffer; in test_read_one_slice()
61 grpc_byte_buffer* buffer; in test_read_one_slice_malloc()
84 grpc_byte_buffer* buffer; in test_read_none_compressed_slice()
106 grpc_byte_buffer* buffer; in test_read_corrupted_slice()
123 grpc_byte_buffer* buffer; in read_compressed_slice()
175 grpc_byte_buffer *buffer, *buffer_from_reader; in test_byte_buffer_from_reader()
202 grpc_byte_buffer* buffer; in test_readall()
236 grpc_byte_buffer* buffer; in test_byte_buffer_copy()
237 grpc_byte_buffer* copied_buffer; in test_byte_buffer_copy()
/external/grpc-grpc/src/objective-c/GRPCClient/private/
DNSData+GRPC.m27 static void MallocAndCopyByteBufferToCharArray(grpc_byte_buffer *buffer, size_t *length,
54 static grpc_byte_buffer *CopyCharArrayToNewByteBuffer(const char *array, size_t length) {
56 grpc_byte_buffer *buffer = grpc_raw_byte_buffer_create(&slice, 1);
62 + (instancetype)grpc_dataWithByteBuffer:(grpc_byte_buffer *)buffer { argument
70 // TODO(jcanizales): grpc_byte_buffer is reference-counted, so we can
72 // that wraps the grpc_byte_buffer. Then enumerateByteRangesUsingBlock:
81 - (grpc_byte_buffer *)grpc_byteBuffer {
82 // Some implementations of NSData, as well as grpc_byte_buffer, support O(1)
DNSData+GRPC.h21 struct grpc_byte_buffer;
24 + (instancetype)grpc_dataWithByteBuffer:(struct grpc_byte_buffer *)buffer;
25 - (struct grpc_byte_buffer *)grpc_byteBuffer;
/external/grpc-grpc/src/cpp/common/
Dcore_codegen.cc36 struct grpc_byte_buffer;
93 grpc_byte_buffer* CoreCodegen::grpc_byte_buffer_copy(grpc_byte_buffer* bb) { in grpc_byte_buffer_copy()
97 void CoreCodegen::grpc_byte_buffer_destroy(grpc_byte_buffer* bb) { in grpc_byte_buffer_destroy()
101 size_t CoreCodegen::grpc_byte_buffer_length(grpc_byte_buffer* bb) { in grpc_byte_buffer_length()
117 grpc_byte_buffer* buffer) { in grpc_byte_buffer_reader_init()
131 grpc_byte_buffer* CoreCodegen::grpc_raw_byte_buffer_create(grpc_slice* slice, in grpc_raw_byte_buffer_create()
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc85 static grpc_byte_buffer* get_serialized_start_client(alts_tsi_event* event) { in get_serialized_start_client()
109 grpc_byte_buffer* buffer = nullptr; in get_serialized_start_client()
125 grpc_byte_buffer* buffer = get_serialized_start_client(event); in handshaker_client_start_client()
139 static grpc_byte_buffer* get_serialized_start_server( in get_serialized_start_server()
157 grpc_byte_buffer* buffer = nullptr; in get_serialized_start_server()
173 grpc_byte_buffer* buffer = get_serialized_start_server(event, bytes_received); in handshaker_client_start_server()
187 static grpc_byte_buffer* get_serialized_next(grpc_slice* bytes_received) { in get_serialized_next()
195 grpc_byte_buffer* buffer = nullptr; in get_serialized_next()
211 grpc_byte_buffer* buffer = get_serialized_next(bytes_received); in handshaker_client_next()
Dalts_tsi_event.h45 grpc_byte_buffer* send_buffer;
46 grpc_byte_buffer* recv_buffer;
/external/grpc-grpc/src/php/ext/grpc/
Dbyte_buffer.c27 grpc_byte_buffer *string_to_byte_buffer(char *string, size_t length) { in string_to_byte_buffer()
29 grpc_byte_buffer *buffer = grpc_raw_byte_buffer_create(&slice, 1); in string_to_byte_buffer()
34 void byte_buffer_to_string(grpc_byte_buffer *buffer, char **out_string, in byte_buffer_to_string()
Dbyte_buffer.h24 grpc_byte_buffer *string_to_byte_buffer(char *string, size_t length);
26 void byte_buffer_to_string(grpc_byte_buffer *buffer, char **out_string,
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_byte_buffer.c29 grpc_byte_buffer* grpc_rb_s_to_byte_buffer(char* string, size_t length) { in grpc_rb_s_to_byte_buffer()
31 grpc_byte_buffer* buffer = grpc_raw_byte_buffer_create(&slice, 1); in grpc_rb_s_to_byte_buffer()
36 VALUE grpc_rb_byte_buffer_to_s(grpc_byte_buffer* buffer) { in grpc_rb_byte_buffer_to_s()
Drb_byte_buffer.h27 grpc_byte_buffer* grpc_rb_s_to_byte_buffer(char* string, size_t length);
30 VALUE grpc_rb_byte_buffer_to_s(grpc_byte_buffer* buffer);
/external/grpc-grpc/test/core/end2end/tests/
Dretry_streaming_after_commit.cc111 grpc_byte_buffer* request_payload = in test_retry_streaming_after_commit()
113 grpc_byte_buffer* request2_payload = in test_retry_streaming_after_commit()
115 grpc_byte_buffer* response_payload = in test_retry_streaming_after_commit()
117 grpc_byte_buffer* response2_payload = in test_retry_streaming_after_commit()
119 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming_after_commit()
120 grpc_byte_buffer* request2_payload_recv = nullptr; in test_retry_streaming_after_commit()
121 grpc_byte_buffer* response_payload_recv = nullptr; in test_retry_streaming_after_commit()
122 grpc_byte_buffer* response2_payload_recv = nullptr; in test_retry_streaming_after_commit()
Dretry_streaming_succeeds_before_replay_finished.cc112 grpc_byte_buffer* request_payload = in test_retry_streaming_succeeds_before_replay_finished()
114 grpc_byte_buffer* request2_payload = in test_retry_streaming_succeeds_before_replay_finished()
116 grpc_byte_buffer* request3_payload = in test_retry_streaming_succeeds_before_replay_finished()
118 grpc_byte_buffer* response_payload = in test_retry_streaming_succeeds_before_replay_finished()
120 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished()
121 grpc_byte_buffer* request2_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished()
122 grpc_byte_buffer* request3_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished()
123 grpc_byte_buffer* response_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished()
Dretry_streaming.cc118 grpc_byte_buffer* request_payload = in test_retry_streaming()
120 grpc_byte_buffer* request2_payload = in test_retry_streaming()
122 grpc_byte_buffer* request3_payload = in test_retry_streaming()
124 grpc_byte_buffer* response_payload = in test_retry_streaming()
126 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming()
127 grpc_byte_buffer* request2_payload_recv = nullptr; in test_retry_streaming()
128 grpc_byte_buffer* request3_payload_recv = nullptr; in test_retry_streaming()
129 grpc_byte_buffer* response_payload_recv = nullptr; in test_retry_streaming()
Dresource_quota_server.cc153 grpc_byte_buffer** request_payload = static_cast<grpc_byte_buffer**>( in resource_quota_server()
154 malloc(sizeof(grpc_byte_buffer*) * NUM_CALLS)); in resource_quota_server()
155 grpc_byte_buffer** request_payload_recv = static_cast<grpc_byte_buffer**>( in resource_quota_server()
156 malloc(sizeof(grpc_byte_buffer*) * NUM_CALLS)); in resource_quota_server()
Dcancel_after_round_trip.cc112 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_round_trip()
113 grpc_byte_buffer* response_payload_recv = nullptr; in test_cancel_after_round_trip()
118 grpc_byte_buffer* request_payload = in test_cancel_after_round_trip()
120 grpc_byte_buffer* response_payload1 = in test_cancel_after_round_trip()
122 grpc_byte_buffer* response_payload2 = in test_cancel_after_round_trip()
Dretry_disabled.cc112 grpc_byte_buffer* request_payload = in test_retry_disabled()
114 grpc_byte_buffer* response_payload = in test_retry_disabled()
116 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_disabled()
117 grpc_byte_buffer* response_payload_recv = nullptr; in test_retry_disabled()
/external/grpc-grpc/test/core/end2end/
Dcq_verifier.h55 int byte_buffer_eq_slice(grpc_byte_buffer* bb, grpc_slice b);
56 int byte_buffer_eq_string(grpc_byte_buffer* byte_buffer, const char* string);
Dcq_verifier.cc131 int raw_byte_buffer_eq_slice(grpc_byte_buffer* rbb, grpc_slice b) { in raw_byte_buffer_eq_slice()
147 int byte_buffer_eq_slice(grpc_byte_buffer* bb, grpc_slice b) { in byte_buffer_eq_slice()
149 grpc_byte_buffer* rbb; in byte_buffer_eq_slice()
162 int byte_buffer_eq_string(grpc_byte_buffer* bb, const char* str) { in byte_buffer_eq_string()
164 grpc_byte_buffer* rbb; in byte_buffer_eq_string()

12345