| /third_party/grpc/test/core/end2end/ |
| D | invalid_call_argument_test.cc | 100 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(g_state.call, g_state.ops, in prepare_test()
149 grpc_call_start_batch(g_state.call, nullptr, 0, nullptr, tag(1))); in test_non_null_reserved_on_start_batch()
166 grpc_call_start_batch(g_state.call, g_state.ops, in test_non_null_reserved_on_op()
184 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(g_state.call, g_state.ops, in test_send_initial_metadata_more_than_once()
197 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_initial_metadata_more_than_once()
216 grpc_call_start_batch(g_state.call, g_state.ops, in test_too_many_metadata()
240 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_null_message()
272 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_messages_at_the_same_time()
295 grpc_call_start_batch(g_state.call, g_state.ops, in test_send_server_status_from_client()
313 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 | 231 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call1, ops, in main()
244 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call1, ops, in main()
281 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(server_call1, ops, in main()
306 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call2, ops, in main()
319 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(call2, ops, in main()
349 GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(server_call2, ops, in main()
|
| /third_party/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_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 | retry_streaming.cc | 203 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), nullptr); in test_retry_streaming()
215 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(2), nullptr); in test_retry_streaming()
243 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), nullptr); in test_retry_streaming()
254 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(3), nullptr); in test_retry_streaming()
265 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), nullptr); in test_retry_streaming()
284 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(104), nullptr); in test_retry_streaming()
326 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(202), nullptr); in test_retry_streaming()
337 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(203), nullptr); in test_retry_streaming()
350 error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(4), nullptr); in test_retry_streaming()
361 error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(204), nullptr); in test_retry_streaming()
[all …]
|
| D | client_streaming.cc | 135 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_client_streaming()
153 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in test_client_streaming()
171 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), in test_client_streaming()
183 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_client_streaming()
204 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_client_streaming()
221 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(103), in test_client_streaming()
242 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_client_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 | streaming_error_response.cc | 153 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test()
171 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test()
181 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(4), in test()
200 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test()
216 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test()
235 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test()
253 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test()
|
| D | stream_compression_ping_pong_streaming.cc | 155 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_pingpong_streaming()
178 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in test_pingpong_streaming()
198 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_pingpong_streaming()
209 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
222 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_pingpong_streaming()
244 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_pingpong_streaming()
258 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_pingpong_streaming()
|
| 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 | keepalive_timeout.cc | 160 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_keepalive_timeout()
178 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_keepalive_timeout()
193 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_keepalive_timeout()
309 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_read_delays_keepalive()
332 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in test_read_delays_keepalive()
352 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_read_delays_keepalive()
363 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_read_delays_keepalive()
376 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in test_read_delays_keepalive()
400 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in test_read_delays_keepalive()
414 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(104), in test_read_delays_keepalive()
|
| D | stream_compression_compressed_payload.cc | 192 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_for_disabled_algorithm()
211 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in request_for_disabled_algorithm()
223 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in request_for_disabled_algorithm()
347 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template()
377 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template()
418 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template()
434 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
447 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
464 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
475 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 | 207 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_for_disabled_algorithm()
226 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in request_for_disabled_algorithm()
238 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in request_for_disabled_algorithm()
363 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template_inner()
392 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template_inner()
428 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template_inner()
443 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), in request_with_payload_template_inner()
456 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template_inner()
476 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template_inner()
487 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in request_with_payload_template_inner()
[all …]
|
| D | workaround_cronet_compression.cc | 205 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in request_with_payload_template()
242 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(101), in request_with_payload_template()
262 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in request_with_payload_template()
273 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
292 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), in request_with_payload_template()
328 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(3), in request_with_payload_template()
342 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 | 182 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_cancel_after_round_trip()
210 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_cancel_after_round_trip()
237 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(2), in test_cancel_after_round_trip()
255 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(103), in test_cancel_after_round_trip()
|
| D | max_message_length.cc | 222 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_max_message_length_on_request()
251 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_max_message_length_on_request()
410 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_max_message_length_on_response()
446 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_max_message_length_on_response()
570 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_max_receive_message_length_on_compressed_request()
609 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_max_receive_message_length_on_compressed_request()
727 error = grpc_call_start_batch(c, ops, static_cast<size_t>(op - ops), tag(1), in test_max_receive_message_length_on_compressed_response()
765 error = grpc_call_start_batch(s, ops, static_cast<size_t>(op - ops), tag(102), in test_max_receive_message_length_on_compressed_response()
|
| 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()
|
| /third_party/grpc/test/core/end2end/fixtures/ |
| D | proxy.cc | 174 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_recv_initial_metadata()
202 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_sent_message()
227 err = grpc_call_start_batch( in on_c2p_recv_msg()
235 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_c2p_recv_msg()
262 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_c2p_sent_message()
281 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_recv_msg()
312 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_p2s_status()
351 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_new_call()
361 err = grpc_call_start_batch(pc->p2s, &op, 1, in on_new_call()
370 err = grpc_call_start_batch(pc->c2p, &op, 1, in on_new_call()
[all …]
|
| /third_party/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()
|
| /third_party/grpc/test/core/iomgr/ |
| D | stranded_event_test.cc | 103 grpc_call_error error = grpc_call_start_batch( in StartCall()
125 grpc_call_error error = grpc_call_start_batch( in SendMessage()
146 grpc_call_error error = grpc_call_start_batch( in ReceiveMessage()
168 grpc_call_error error = grpc_call_start_batch( in ReceiveInitialMetadata()
200 grpc_call_error error = grpc_call_start_batch( in FinishCall()
264 error = grpc_call_start_batch(call, ops, static_cast<size_t>(op - ops), tag, in AcceptThread()
|
| /third_party/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()
|
| /third_party/grpc/test/core/surface/ |
| D | lame_client_test.cc | 109 error = grpc_call_start_batch(call, ops, static_cast<size_t>(op - ops), in main()
126 error = grpc_call_start_batch(call, ops, static_cast<size_t>(op - ops), in main()
|