| /third_party/grpc/test/core/end2end/tests/ |
| D | resource_quota_server.cc | 155 grpc_byte_buffer** request_payload_recv = static_cast<grpc_byte_buffer**>( in resource_quota_server() local
177 request_payload_recv[i] = nullptr; in resource_quota_server()
288 op->data.recv_message.recv_message = &request_payload_recv[call_id]; in resource_quota_server()
310 if (request_payload_recv[call_id] != nullptr) { in resource_quota_server()
311 grpc_byte_buffer_destroy(request_payload_recv[call_id]); in resource_quota_server()
312 request_payload_recv[call_id] = nullptr; in resource_quota_server()
315 GPR_ASSERT(request_payload_recv[call_id] == nullptr); in resource_quota_server()
377 free(request_payload_recv); in resource_quota_server()
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 120 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished() local
224 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
300 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming_succeeds_before_replay_finished()
301 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming_succeeds_before_replay_finished()
302 request_payload_recv = nullptr; in test_retry_streaming_succeeds_before_replay_finished()
333 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_succeeds_before_replay_finished()
377 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming_succeeds_before_replay_finished()
378 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming_succeeds_before_replay_finished()
|
| D | retry_streaming.cc | 129 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming() local
241 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
295 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming()
296 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming()
297 request_payload_recv = nullptr; in test_retry_streaming()
324 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
419 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming()
420 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming()
|
| D | cancel_after_round_trip.cc | 111 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_round_trip() local
196 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_round_trip()
218 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_round_trip()
220 request_payload_recv = nullptr; in test_cancel_after_round_trip()
274 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_round_trip()
|
| D | request_with_payload.cc | 102 grpc_byte_buffer* request_payload_recv = nullptr; in test_invoke_request_with_payload() local
166 op->data.recv_message.recv_message = &request_payload_recv; in test_invoke_request_with_payload()
204 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_invoke_request_with_payload()
218 grpc_byte_buffer_destroy(request_payload_recv); in test_invoke_request_with_payload()
|
| D | compressed_payload.cc | 120 grpc_byte_buffer* request_payload_recv = nullptr; in request_for_disabled_algorithm() local
222 op->data.recv_message.recv_message = &request_payload_recv; in request_for_disabled_algorithm()
271 grpc_byte_buffer_destroy(request_payload_recv); in request_for_disabled_algorithm()
300 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template_inner() local
452 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template_inner()
463 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template_inner()
464 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template_inner()
465 GPR_ASSERT(request_payload_recv->data.raw.compression == in request_with_payload_template_inner()
511 grpc_byte_buffer_destroy(request_payload_recv); in request_with_payload_template_inner()
|
| D | workaround_cronet_compression.cc | 117 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template() local
269 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template()
279 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template()
280 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template()
281 GPR_ASSERT(request_payload_recv->data.raw.compression == in request_with_payload_template()
315 grpc_byte_buffer_destroy(request_payload_recv); in request_with_payload_template()
|
| D | stream_compression_compressed_payload.cc | 116 grpc_byte_buffer* request_payload_recv = nullptr; in request_for_disabled_algorithm() local
207 op->data.recv_message.recv_message = &request_payload_recv; in request_for_disabled_algorithm()
256 grpc_byte_buffer_destroy(request_payload_recv); in request_for_disabled_algorithm()
292 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template() local
443 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template()
454 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template()
455 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template()
488 grpc_byte_buffer_destroy(request_payload_recv); in request_with_payload_template()
|
| D | large_metadata.cc | 109 grpc_byte_buffer* request_payload_recv = nullptr; in test_request_with_large_metadata() local
182 op->data.recv_message.recv_message = &request_payload_recv; in test_request_with_large_metadata()
222 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_request_with_large_metadata()
239 grpc_byte_buffer_destroy(request_payload_recv); in test_request_with_large_metadata()
|
| D | filter_call_init_fails.cc | 113 grpc_byte_buffer* request_payload_recv = nullptr; in test_server_channel_filter() local
185 grpc_byte_buffer_destroy(request_payload_recv); in test_server_channel_filter()
208 grpc_byte_buffer* request_payload_recv = nullptr; in test_client_channel_filter() local
274 grpc_byte_buffer_destroy(request_payload_recv); in test_client_channel_filter()
297 grpc_byte_buffer* request_payload_recv = nullptr; in test_client_subchannel_filter() local
387 grpc_byte_buffer_destroy(request_payload_recv); in test_client_subchannel_filter()
|
| D | payload.cc | 123 grpc_byte_buffer* request_payload_recv = nullptr; in request_response_with_payload() local
194 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
237 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in request_response_with_payload()
254 grpc_byte_buffer_destroy(request_payload_recv); in request_response_with_payload()
|
| D | client_streaming.cc | 106 grpc_byte_buffer* request_payload_recv = nullptr; in test_client_streaming() local
179 op->data.recv_message.recv_message = &request_payload_recv; in test_client_streaming()
189 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_client_streaming()
190 grpc_byte_buffer_destroy(request_payload_recv); in test_client_streaming()
|
| D | simple_metadata.cc | 124 grpc_byte_buffer* request_payload_recv = nullptr; in test_request_response_with_metadata_and_payload() local
197 op->data.recv_message.recv_message = &request_payload_recv; in test_request_response_with_metadata_and_payload()
240 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_request_response_with_metadata_and_payload()
260 grpc_byte_buffer_destroy(request_payload_recv); in test_request_response_with_metadata_and_payload()
|
| D | simple_cacheable_request.cc | 126 grpc_byte_buffer* request_payload_recv = nullptr; in test_cacheable_request_response_with_metadata_and_payload() local
199 op->data.recv_message.recv_message = &request_payload_recv; in test_cacheable_request_response_with_metadata_and_payload()
247 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_cacheable_request_response_with_metadata_and_payload()
267 grpc_byte_buffer_destroy(request_payload_recv); in test_cacheable_request_response_with_metadata_and_payload()
|
| D | binary_metadata.cc | 130 grpc_byte_buffer* request_payload_recv = nullptr; in test_request_response_with_metadata_and_payload() local
203 op->data.recv_message.recv_message = &request_payload_recv; in test_request_response_with_metadata_and_payload()
280 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_request_response_with_metadata_and_payload()
308 grpc_byte_buffer_destroy(request_payload_recv); in test_request_response_with_metadata_and_payload()
|
| D | trailing_metadata.cc | 132 grpc_byte_buffer* request_payload_recv = nullptr; in test_request_response_with_metadata_and_payload() local
205 op->data.recv_message.recv_message = &request_payload_recv; in test_request_response_with_metadata_and_payload()
248 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, "hello world")); in test_request_response_with_metadata_and_payload()
270 grpc_byte_buffer_destroy(request_payload_recv); in test_request_response_with_metadata_and_payload()
|
| D | stream_compression_payload.cc | 127 grpc_byte_buffer* request_payload_recv = nullptr; in request_response_with_payload() local
198 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
241 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in request_response_with_payload()
258 grpc_byte_buffer_destroy(request_payload_recv); in request_response_with_payload()
|
| D | retry_streaming_after_commit.cc | 119 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming_after_commit() local
218 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming_after_commit()
325 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming_after_commit()
326 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming_after_commit()
|
| D | cancel_after_client_done.cc | 109 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_accept_and_writes_closed() local
178 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_accept_and_writes_closed()
217 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_accept_and_writes_closed()
|
| D | cancel_after_accept.cc | 111 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_accept() local
200 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_accept()
239 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_accept()
|
| D | invoke_large_request.cc | 126 grpc_byte_buffer* request_payload_recv = nullptr; in test_invoke_large_request() local
197 op->data.recv_message.recv_message = &request_payload_recv; in test_invoke_large_request()
254 grpc_byte_buffer_destroy(request_payload_recv); in test_invoke_large_request()
|
| D | load_reporting_hook.cc | 132 grpc_byte_buffer* request_payload_recv = nullptr; in request_response_with_payload() local
205 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
261 grpc_byte_buffer_destroy(request_payload_recv); in request_response_with_payload()
|
| D | stream_compression_ping_pong_streaming.cc | 116 grpc_byte_buffer* request_payload_recv; in test_pingpong_streaming() local
205 op->data.recv_message.recv_message = &request_payload_recv; in test_pingpong_streaming()
231 grpc_byte_buffer_destroy(request_payload_recv); in test_pingpong_streaming()
|
| /third_party/grpc/test/core/bad_connection/ |
| D | close_fd_test.cc | 212 grpc_byte_buffer* request_payload_recv = nullptr; in _test_close_before_server_recv() local
285 op->data.recv_message.recv_message = &request_payload_recv; in _test_close_before_server_recv()
349 grpc_byte_buffer_destroy(request_payload_recv); in _test_close_before_server_recv()
386 grpc_byte_buffer* request_payload_recv = nullptr; in _test_close_before_server_send() local
460 op->data.recv_message.recv_message = &request_payload_recv; in _test_close_before_server_send()
547 grpc_byte_buffer_destroy(request_payload_recv); in _test_close_before_server_send()
583 grpc_byte_buffer* request_payload_recv = nullptr; in _test_close_before_client_send() local
675 grpc_byte_buffer_destroy(request_payload_recv); in _test_close_before_client_send()
|
| /third_party/grpc/test/core/bad_client/tests/ |
| D | duplicate_header.cc | 59 grpc_byte_buffer* request_payload_recv = nullptr; in verifier() local
86 op->data.recv_message.recv_message = &request_payload_recv; in verifier()
|