| /third_party/grpc/src/core/lib/surface/ |
| D | byte_buffer.cc | 28 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()
|
| D | server.h | 66 grpc_byte_buffer** optional_payload;
157 grpc_byte_buffer** optional_payload,
295 grpc_byte_buffer* payload_ = nullptr;
352 grpc_byte_buffer** optional_payload, RegisteredMethod* rm);
355 grpc_byte_buffer** optional_payload, RegisteredMethod* rm);
|
| /third_party/grpc/include/grpc/impl/codegen/ |
| D | byte_buffer.h | 34 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* bb);
65 grpc_byte_buffer* buffer);
94 GRPCAPI grpc_byte_buffer* grpc_raw_byte_buffer_from_reader(
|
| D | byte_buffer_reader.h | 26 struct grpc_byte_buffer;
29 struct grpc_byte_buffer* buffer_in;
30 struct grpc_byte_buffer* buffer_out;
|
| D | grpc_types.h | 40 typedef struct grpc_byte_buffer { struct
52 } grpc_byte_buffer; typedef
605 struct grpc_byte_buffer;
637 struct grpc_byte_buffer* send_message;
662 struct grpc_byte_buffer** recv_message;
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | byte_buffer.h | 44 void* UnaryDeserializeHelper(grpc_call*, grpc_byte_buffer*, ::grpc::Status*,
78 static_assert(std::is_same<decltype(buffer_), grpc_byte_buffer*>::value, in ByteBuffer()
81 static_assert(sizeof(ByteBuffer) == sizeof(grpc_byte_buffer*), in ByteBuffer()
151 grpc_byte_buffer* tmp = other->buffer_; in Swap()
167 friend void* internal::UnaryDeserializeHelper(grpc_call*, grpc_byte_buffer*,
184 grpc_byte_buffer* buffer_;
187 void set_buffer(grpc_byte_buffer* buf) { in set_buffer()
194 grpc_byte_buffer* c_buffer() { return buffer_; } in c_buffer()
195 grpc_byte_buffer** c_buffer_ptr() { return &buffer_; } in c_buffer_ptr()
205 operator grpc_byte_buffer*() { return bbuf_->buffer_; }
[all …]
|
| D | core_codegen_interface.h | 84 virtual grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb) = 0;
85 virtual void grpc_byte_buffer_destroy(grpc_byte_buffer* bb) = 0;
86 virtual size_t grpc_byte_buffer_length(grpc_byte_buffer* bb)
90 grpc_byte_buffer* buffer)
99 virtual grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slice,
|
| D | core_codegen.h | 78 grpc_byte_buffer* grpc_byte_buffer_copy(grpc_byte_buffer* bb) override;
79 void grpc_byte_buffer_destroy(grpc_byte_buffer* bb) override;
80 size_t grpc_byte_buffer_length(grpc_byte_buffer* bb) override;
83 grpc_byte_buffer* buffer) override;
91 grpc_byte_buffer* grpc_raw_byte_buffer_create(grpc_slice* slice,
|
| /third_party/grpc/test/core/surface/ |
| D | byte_buffer_reader_test.cc | 38 grpc_byte_buffer* buffer; in test_read_one_slice()
60 grpc_byte_buffer* buffer; in test_read_one_slice_malloc()
83 grpc_byte_buffer* buffer; in test_read_none_compressed_slice()
105 grpc_byte_buffer* buffer; in test_peek_one_slice()
127 grpc_byte_buffer* buffer; in test_peek_one_slice_malloc()
150 grpc_byte_buffer* buffer; in test_peek_none_compressed_slice()
172 grpc_byte_buffer *buffer, *buffer_from_reader; in test_byte_buffer_from_reader()
199 grpc_byte_buffer* buffer; in test_readall()
233 grpc_byte_buffer* buffer; in test_byte_buffer_copy()
234 grpc_byte_buffer* copied_buffer; in test_byte_buffer_copy()
|
| /third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/ |
| D | NSData+GRPC.m | 27 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)
|
| D | NSData+GRPC.h | 21 struct grpc_byte_buffer;
24 + (instancetype)grpc_dataWithByteBuffer:(struct grpc_byte_buffer *)buffer;
25 - (struct grpc_byte_buffer *)grpc_byteBuffer;
|
| /third_party/grpc/src/cpp/common/ |
| D | core_codegen.cc | 36 struct grpc_byte_buffer;
97 grpc_byte_buffer* CoreCodegen::grpc_byte_buffer_copy(grpc_byte_buffer* bb) { in grpc_byte_buffer_copy()
101 void CoreCodegen::grpc_byte_buffer_destroy(grpc_byte_buffer* bb) { in grpc_byte_buffer_destroy()
105 size_t CoreCodegen::grpc_byte_buffer_length(grpc_byte_buffer* bb) { in grpc_byte_buffer_length()
131 grpc_byte_buffer* buffer) { in grpc_byte_buffer_reader_init()
150 grpc_byte_buffer* CoreCodegen::grpc_raw_byte_buffer_create(grpc_slice* slice, in grpc_raw_byte_buffer_create()
|
| /third_party/grpc/src/php/ext/grpc/ |
| D | byte_buffer.c | 27 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 zend_string* byte_buffer_to_zend_string(grpc_byte_buffer *buffer) { in byte_buffer_to_zend_string()
|
| D | byte_buffer.h | 24 grpc_byte_buffer *string_to_byte_buffer(char *string, size_t length);
26 zend_string* byte_buffer_to_zend_string(grpc_byte_buffer *buffer);
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_byte_buffer.c | 29 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()
|
| D | rb_byte_buffer.h | 27 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);
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_private.h | 47 grpc_byte_buffer* alts_handshaker_client_get_send_buffer_for_testing(
50 grpc_byte_buffer** alts_handshaker_client_get_recv_buffer_addr_for_testing(
66 grpc_byte_buffer* recv_buffer, grpc_status_code status);
|
| D | alts_handshaker_client.cc | 72 grpc_byte_buffer* send_buffer = nullptr;
73 grpc_byte_buffer* recv_buffer = nullptr;
199 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response()
468 static grpc_byte_buffer* get_serialized_handshaker_req( in get_serialized_handshaker_req()
476 grpc_byte_buffer* byte_buffer = grpc_raw_byte_buffer_create(&slice, 1); in get_serialized_handshaker_req()
482 static grpc_byte_buffer* get_serialized_start_client( in get_serialized_start_client()
528 grpc_byte_buffer* buffer = get_serialized_start_client(c); in handshaker_client_start_client()
545 static grpc_byte_buffer* get_serialized_start_server( in get_serialized_start_server()
587 grpc_byte_buffer* buffer = get_serialized_start_server(c, bytes_received); in handshaker_client_start_server()
602 static grpc_byte_buffer* get_serialized_next(grpc_slice* bytes_received) { in get_serialized_next()
[all …]
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | retry_streaming_after_commit.cc | 111 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()
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 112 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()
|
| D | retry_streaming.cc | 121 grpc_byte_buffer* request_payload = in test_retry_streaming()
123 grpc_byte_buffer* request2_payload = in test_retry_streaming()
125 grpc_byte_buffer* request3_payload = in test_retry_streaming()
127 grpc_byte_buffer* response_payload = in test_retry_streaming()
129 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming()
130 grpc_byte_buffer* request2_payload_recv = nullptr; in test_retry_streaming()
131 grpc_byte_buffer* request3_payload_recv = nullptr; in test_retry_streaming()
132 grpc_byte_buffer* response_payload_recv = nullptr; in test_retry_streaming()
|
| D | resource_quota_server.cc | 153 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()
|
| D | cancel_after_round_trip.cc | 111 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_round_trip()
112 grpc_byte_buffer* response_payload_recv = nullptr; in test_cancel_after_round_trip()
117 grpc_byte_buffer* request_payload = in test_cancel_after_round_trip()
119 grpc_byte_buffer* response_payload1 = in test_cancel_after_round_trip()
121 grpc_byte_buffer* response_payload2 = in test_cancel_after_round_trip()
|
| /third_party/grpc/test/core/bad_connection/ |
| D | close_fd_test.cc | 199 grpc_byte_buffer* request_payload = in _test_close_before_server_recv()
201 grpc_byte_buffer* response_payload = in _test_close_before_server_recv()
212 grpc_byte_buffer* request_payload_recv = nullptr; in _test_close_before_server_recv()
213 grpc_byte_buffer* response_payload_recv = nullptr; in _test_close_before_server_recv()
373 grpc_byte_buffer* request_payload = in _test_close_before_server_send()
375 grpc_byte_buffer* response_payload = in _test_close_before_server_send()
386 grpc_byte_buffer* request_payload_recv = nullptr; in _test_close_before_server_send()
387 grpc_byte_buffer* response_payload_recv = nullptr; in _test_close_before_server_send()
570 grpc_byte_buffer* request_payload = in _test_close_before_client_send()
572 grpc_byte_buffer* response_payload = in _test_close_before_client_send()
[all …]
|
| /third_party/grpc/test/core/end2end/ |
| D | cq_verifier.h | 59 int byte_buffer_eq_slice(grpc_byte_buffer* bb, grpc_slice b);
60 int byte_buffer_eq_string(grpc_byte_buffer* byte_buffer, const char* string);
|