| /external/grpc-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 | 126 grpc_byte_buffer* request_payload_recv = nullptr; in test_retry_streaming() local
230 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
284 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming()
285 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming()
286 request_payload_recv = nullptr; in test_retry_streaming()
313 op->data.recv_message.recv_message = &request_payload_recv; in test_retry_streaming()
396 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in test_retry_streaming()
397 grpc_byte_buffer_destroy(request_payload_recv); in test_retry_streaming()
|
| D | compressed_payload.cc | 112 grpc_byte_buffer* request_payload_recv = nullptr; in request_for_disabled_algorithm() local
203 op->data.recv_message.recv_message = &request_payload_recv; in request_for_disabled_algorithm()
254 grpc_byte_buffer_destroy(request_payload_recv); in request_for_disabled_algorithm()
288 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template() local
430 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template()
441 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template()
442 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template()
443 GPR_ASSERT(request_payload_recv->data.raw.compression == in request_with_payload_template()
486 grpc_byte_buffer_destroy(request_payload_recv); in request_with_payload_template()
|
| D | cancel_after_round_trip.cc | 112 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_round_trip() local
197 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_round_trip()
219 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_round_trip()
221 request_payload_recv = nullptr; in test_cancel_after_round_trip()
275 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_round_trip()
|
| D | workaround_cronet_compression.cc | 116 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template() local
256 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template()
266 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template()
267 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template()
268 GPR_ASSERT(request_payload_recv->data.raw.compression == in request_with_payload_template()
299 grpc_byte_buffer_destroy(request_payload_recv); in request_with_payload_template()
|
| 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 | stream_compression_compressed_payload.cc | 112 grpc_byte_buffer* request_payload_recv = nullptr; in request_for_disabled_algorithm() local
203 op->data.recv_message.recv_message = &request_payload_recv; in request_for_disabled_algorithm()
254 grpc_byte_buffer_destroy(request_payload_recv); in request_for_disabled_algorithm()
290 grpc_byte_buffer* request_payload_recv = nullptr; in request_with_payload_template() local
441 op->data.recv_message.recv_message = &request_payload_recv; in request_with_payload_template()
452 GPR_ASSERT(request_payload_recv->type == GRPC_BB_RAW); in request_with_payload_template()
453 GPR_ASSERT(byte_buffer_eq_string(request_payload_recv, request_str)); in request_with_payload_template()
486 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 | 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 | 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 | 126 grpc_byte_buffer* request_payload_recv = nullptr; in request_response_with_payload() local
197 op->data.recv_message.recv_message = &request_payload_recv; in request_response_with_payload()
240 GPR_ASSERT(byte_buffer_eq_slice(request_payload_recv, request_payload_slice)); in request_response_with_payload()
257 grpc_byte_buffer_destroy(request_payload_recv); in request_response_with_payload()
|
| 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 | 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 | 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 | network_status_change.cc | 105 grpc_byte_buffer* request_payload_recv = nullptr; in test_invoke_network_status_change() local
168 op->data.recv_message.recv_message = &request_payload_recv; in test_invoke_network_status_change()
223 grpc_byte_buffer_destroy(request_payload_recv); in test_invoke_network_status_change()
|
| 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 | 112 grpc_byte_buffer* request_payload_recv = nullptr; in test_cancel_after_accept() local
201 op->data.recv_message.recv_message = &request_payload_recv; in test_cancel_after_accept()
240 grpc_byte_buffer_destroy(request_payload_recv); in test_cancel_after_accept()
|
| D | stream_compression_ping_pong_streaming.cc | 113 grpc_byte_buffer* request_payload_recv; in test_pingpong_streaming() local
202 op->data.recv_message.recv_message = &request_payload_recv; in test_pingpong_streaming()
228 grpc_byte_buffer_destroy(request_payload_recv); in test_pingpong_streaming()
|
| 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 | invoke_large_request.cc | 125 grpc_byte_buffer* request_payload_recv = nullptr; in test_invoke_large_request() local
196 op->data.recv_message.recv_message = &request_payload_recv; in test_invoke_large_request()
253 grpc_byte_buffer_destroy(request_payload_recv); in test_invoke_large_request()
|
| D | ping_pong_streaming.cc | 105 grpc_byte_buffer* request_payload_recv; in test_pingpong_streaming() local
194 op->data.recv_message.recv_message = &request_payload_recv; in test_pingpong_streaming()
220 grpc_byte_buffer_destroy(request_payload_recv); in test_pingpong_streaming()
|
| /external/grpc-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()
|