| /external/grpc-grpc/test/core/end2end/ |
| D | invalid_call_argument_test.cc | 101 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(g_state.call, g_state.ops, in prepare_test()
150 grpc_call_start_batch(g_state.call, nullptr, 0, nullptr, tag(1))); in test_non_null_reserved_on_start_batch()
167 grpc_call_start_batch(g_state.call, g_state.ops, in test_non_null_reserved_on_op()
185 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(g_state.call, g_state.ops, in test_send_initial_metadata_more_than_once()
198 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_initial_metadata_more_than_once()
217 grpc_call_start_batch(g_state.call, g_state.ops, in test_too_many_metadata()
241 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_null_message()
273 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_messages_at_the_same_time()
296 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_server_status_from_client()
314 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(g_state.call, g_state.ops, in test_receive_initial_metadata_twice_at_client()
[all …]
|
| D | goaway_server_test.cc | 204 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call1, ops, in main()
217 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call1, ops, in main()
255 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(server_call1, ops, in main()
280 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call2, ops, in main()
293 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call2, ops, in main()
324 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(server_call2, ops, in main()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | write_buffering.cc | 129 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_invoke_request_with_payload()
140 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_invoke_request_with_payload()
157 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_invoke_request_with_payload()
166 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_invoke_request_with_payload()
176 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_invoke_request_with_payload()
192 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(4), in test_invoke_request_with_payload()
207 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_invoke_request_with_payload()
227 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(4), in test_invoke_request_with_payload()
245 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(105), in test_invoke_request_with_payload()
|
| D | write_buffering_at_end.cc | 126 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_invoke_request_with_payload()
137 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_invoke_request_with_payload()
154 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_invoke_request_with_payload()
163 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_invoke_request_with_payload()
173 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_invoke_request_with_payload()
187 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(4), in test_invoke_request_with_payload()
202 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_invoke_request_with_payload()
218 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(4), in test_invoke_request_with_payload()
236 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(105), in test_invoke_request_with_payload()
|
| D | retry_streaming.cc | 192 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_streaming()
204 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(2), nullptr); in test_retry_streaming()
232 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_streaming()
243 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(3), nullptr); in test_retry_streaming()
254 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), nullptr); in test_retry_streaming()
273 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(104), nullptr); in test_retry_streaming()
315 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(202), nullptr); in test_retry_streaming()
326 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(203), nullptr); in test_retry_streaming()
339 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(4), nullptr); in test_retry_streaming()
350 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(204), nullptr); in test_retry_streaming()
[all …]
|
| D | retry_streaming_after_commit.cc | 180 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(2), nullptr); in test_retry_streaming_after_commit()
192 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(3), nullptr); in test_retry_streaming_after_commit()
220 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_streaming_after_commit()
234 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), nullptr); in test_retry_streaming_after_commit()
249 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(4), nullptr); in test_retry_streaming_after_commit()
260 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(104), nullptr); in test_retry_streaming_after_commit()
281 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(105), nullptr); in test_retry_streaming_after_commit()
292 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(5), nullptr); in test_retry_streaming_after_commit()
305 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_streaming_after_commit()
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 186 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
198 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(2), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
226 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
237 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(3), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
248 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
259 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(4), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
270 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(104), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
289 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(105), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
335 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(202), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
356 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(205), nullptr); in test_retry_streaming_succeeds_before_replay_finished()
|
| D | max_concurrent_streams.cc | 136 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in simple_request_body()
167 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in simple_request_body()
271 error = grpc_call_start_batch(c1, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
290 error = grpc_call_start_batch(c1, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
305 error = grpc_call_start_batch(c2, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
324 error = grpc_call_start_batch(c2, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
372 error = grpc_call_start_batch(s1, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
410 error = grpc_call_start_batch(s2, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams()
513 error = grpc_call_start_batch(c1, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams_with_timeout_on_first()
532 error = grpc_call_start_batch(c1, ops, static_cast<size_t>(op - ops), in test_max_concurrent_streams_with_timeout_on_first()
[all …]
|
| D | stream_compression_ping_pong_streaming.cc | 152 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_pingpong_streaming()
175 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in test_pingpong_streaming()
195 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_pingpong_streaming()
206 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
219 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
241 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_pingpong_streaming()
255 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_pingpong_streaming()
|
| D | ping_pong_streaming.cc | 144 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_pingpong_streaming()
167 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in test_pingpong_streaming()
187 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_pingpong_streaming()
198 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
211 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
233 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_pingpong_streaming()
247 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_pingpong_streaming()
|
| D | stream_compression_compressed_payload.cc | 188 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_for_disabled_algorithm()
207 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in request_for_disabled_algorithm()
219 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in request_for_disabled_algorithm()
345 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template()
375 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template()
416 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template()
432 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
445 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
462 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
473 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in request_with_payload_template()
[all …]
|
| D | compressed_payload.cc | 188 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_for_disabled_algorithm()
207 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in request_for_disabled_algorithm()
219 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in request_for_disabled_algorithm()
338 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template()
368 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template()
405 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template()
421 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
434 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
453 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
464 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in request_with_payload_template()
[all …]
|
| D | streaming_error_response.cc | 149 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test()
167 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test()
182 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test()
194 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test()
213 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test()
231 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test()
|
| D | workaround_cronet_compression.cc | 192 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template()
229 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template()
249 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template()
260 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
278 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
312 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in request_with_payload_template()
326 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in request_with_payload_template()
|
| D | cancel_after_round_trip.cc | 183 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_cancel_after_round_trip()
211 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_cancel_after_round_trip()
238 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_cancel_after_round_trip()
256 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_cancel_after_round_trip()
|
| D | keepalive_timeout.cc | 156 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_keepalive_timeout()
174 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_keepalive_timeout()
189 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_keepalive_timeout()
|
| D | network_status_change.cc | 151 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_invoke_network_status_change()
172 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_invoke_network_status_change()
196 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_invoke_network_status_change()
|
| D | request_with_payload.cc | 148 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_invoke_request_with_payload()
170 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_invoke_request_with_payload()
192 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_invoke_request_with_payload()
|
| D | retry_non_retriable_status_before_recv_trailing_metadata_started.cc | 182 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_non_retriable_status_before_recv_trailing_metadata_started()
214 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_non_retriable_status_before_recv_trailing_metadata_started()
228 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(2), nullptr); in test_retry_non_retriable_status_before_recv_trailing_metadata_started()
|
| D | large_metadata.cc | 161 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_request_with_large_metadata()
186 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_request_with_large_metadata()
210 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_request_with_large_metadata()
|
| D | retry_recv_initial_metadata.cc | 185 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_recv_initial_metadata()
211 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_recv_initial_metadata()
227 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), nullptr); in test_retry_recv_initial_metadata()
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| D | proxy.cc | 175 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_recv_initial_metadata()
203 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_sent_message()
228 err = grpc_call_start_batch( in on_c2p_recv_msg()
236 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_c2p_recv_msg()
263 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_c2p_sent_message()
282 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_recv_msg()
313 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_status()
352 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_new_call()
362 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_new_call()
371 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_new_call()
[all …]
|
| /external/grpc-grpc/test/core/fling/ |
| D | server.cc | 115 error = grpc_call_start_batch(call, unary_ops, in handle_unary_method()
127 error = grpc_call_start_batch(call, &metadata_send_op, 1, tagarg, nullptr); in send_initial_metadata()
137 error = grpc_call_start_batch(call, &read_op, 1, tag(t), nullptr); in start_read_op()
150 error = grpc_call_start_batch(call, &write_op, 1, tagarg, nullptr); in start_write_op()
164 error = grpc_call_start_batch(call, status_op, 2, tagarg, nullptr); in start_send_status()
|
| D | client.cc | 84 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call, ops, in step_ping_pong_request()
107 error = grpc_call_start_batch(call, stream_init_ops, 2, (void*)1, nullptr); in init_ping_pong_stream()
122 error = grpc_call_start_batch(call, stream_step_ops, 2, (void*)1, nullptr); in step_ping_pong_stream()
|
| /external/grpc-grpc/test/core/bad_client/tests/ |
| D | duplicate_header.cc | 90 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in verifier()
112 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in verifier()
|