Home
last modified time | relevance | path

Searched refs:GRPC_OP_SEND_MESSAGE (Results 1 – 25 of 84) sorted by relevance

1234

/external/grpc-grpc/test/core/end2end/tests/
Drequest_with_flags.cc128 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_request_with_flags()
183 int indices[] = {GRPC_OP_SEND_INITIAL_METADATA, GRPC_OP_SEND_MESSAGE, in request_with_flags()
200 flags_for_op[GRPC_OP_SEND_MESSAGE] = flags[i]; in request_with_flags()
Dretry_streaming_after_commit.cc189 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_after_commit()
231 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_after_commit()
244 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_after_commit()
271 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_after_commit()
Dcancel_after_round_trip.cc168 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
206 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
251 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
Dretry_streaming_succeeds_before_replay_finished.cc195 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
234 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
256 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
346 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
Dretry_streaming.cc201 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
240 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
334 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
365 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
Dcancel_after_client_done.cc146 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept_and_writes_closed()
192 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept_and_writes_closed()
Dretry_recv_message.cc169 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_recv_message()
209 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_recv_message()
Dcancel_after_accept.cc173 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept()
210 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept()
Dcompressed_payload.cc167 op->op = GRPC_OP_SEND_MESSAGE; in request_for_disabled_algorithm()
333 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
416 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
448 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
Dstream_compression_compressed_payload.cc167 op->op = GRPC_OP_SEND_MESSAGE; in request_for_disabled_algorithm()
340 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
427 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
457 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
Dstreaming_error_response.cc164 op->op = GRPC_OP_SEND_MESSAGE; in test()
179 op->op = GRPC_OP_SEND_MESSAGE; in test()
Dbinary_metadata.cc157 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
221 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
Dstream_compression_payload.cc152 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
215 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
Dinvoke_large_request.cc151 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_large_request()
214 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_large_request()
Dsimple_metadata.cc151 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
215 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
Dtrailing_metadata.cc159 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
223 op->op = GRPC_OP_SEND_MESSAGE; in test_request_response_with_metadata_and_payload()
Dstream_compression_ping_pong_streaming.cc185 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
214 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
Dpayload.cc149 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
212 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
Dwrite_buffering.cc153 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_request_with_payload()
188 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_request_with_payload()
Dsimple_cacheable_request.cc153 op->op = GRPC_OP_SEND_MESSAGE; in test_cacheable_request_response_with_metadata_and_payload()
217 op->op = GRPC_OP_SEND_MESSAGE; in test_cacheable_request_response_with_metadata_and_payload()
Dping_pong_streaming.cc177 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
206 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
Dload_reporting_hook.cc160 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
223 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload()
/external/grpc-grpc/test/core/fling/
Dclient.cc59 op->op = GRPC_OP_SEND_MESSAGE; in init_ping_pong_request()
113 stream_step_ops[0].op = GRPC_OP_SEND_MESSAGE; in init_ping_pong_stream()
Dserver.cc100 op->op = GRPC_OP_SEND_MESSAGE; in handle_unary_method()
145 write_op.op = GRPC_OP_SEND_MESSAGE; in start_write_op()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_call.c558 case GRPC_OP_SEND_MESSAGE: in grpc_rb_call_check_op_keys_hash_cb()
675 if (st->ops[i].op == GRPC_OP_SEND_MESSAGE) { in grpc_run_batch_stack_cleanup()
705 case GRPC_OP_SEND_MESSAGE: in grpc_run_batch_stack_fill_ops()
759 case GRPC_OP_SEND_MESSAGE: in grpc_run_batch_stack_build_result()
936 UINT2NUM(GRPC_OP_SEND_MESSAGE)); in Init_grpc_op_codes()

1234