Home
last modified time | relevance | path

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

1234

/third_party/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()
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()
Dcancel_after_round_trip.cc167 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
205 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
250 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_round_trip()
Dretry_streaming.cc212 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
251 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
345 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
376 op->op = GRPC_OP_SEND_MESSAGE; in test_retry_streaming()
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_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()
Dstream_compression_compressed_payload.cc171 op->op = GRPC_OP_SEND_MESSAGE; in request_for_disabled_algorithm()
342 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
429 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
459 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template()
Dcancel_after_accept.cc172 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept()
209 op->op = GRPC_OP_SEND_MESSAGE; in test_cancel_after_accept()
Dfilter_call_init_fails.cc138 op->op = GRPC_OP_SEND_MESSAGE; in test_server_channel_filter()
232 op->op = GRPC_OP_SEND_MESSAGE; in test_client_channel_filter()
321 op->op = GRPC_OP_SEND_MESSAGE; in test_client_subchannel_filter()
Dcompressed_payload.cc186 op->op = GRPC_OP_SEND_MESSAGE; in request_for_disabled_algorithm()
358 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template_inner()
438 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template_inner()
471 op->op = GRPC_OP_SEND_MESSAGE; in request_with_payload_template_inner()
Dkeepalive_timeout.cc175 op->op = GRPC_OP_SEND_MESSAGE; in test_keepalive_timeout()
342 op->op = GRPC_OP_SEND_MESSAGE; in test_read_delays_keepalive()
371 op->op = GRPC_OP_SEND_MESSAGE; in test_read_delays_keepalive()
Dcall_creds.cc195 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload_and_call_creds()
270 op->op = GRPC_OP_SEND_MESSAGE; in request_response_with_payload_and_call_creds()
433 op->op = GRPC_OP_SEND_MESSAGE; in test_request_with_server_rejecting_client_creds()
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()
Dinvoke_large_request.cc152 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_large_request()
215 op->op = GRPC_OP_SEND_MESSAGE; in test_invoke_large_request()
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()
Dclient_streaming.cc166 op->op = GRPC_OP_SEND_MESSAGE; in test_client_streaming()
216 op->op = GRPC_OP_SEND_MESSAGE; in test_client_streaming()
Dstream_compression_ping_pong_streaming.cc188 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
217 op->op = GRPC_OP_SEND_MESSAGE; in test_pingpong_streaming()
Dstreaming_error_response.cc168 op->op = GRPC_OP_SEND_MESSAGE; in test()
197 op->op = GRPC_OP_SEND_MESSAGE; in test()
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()
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()
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()
/third_party/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()
/third_party/grpc/src/ruby/ext/grpc/
Drb_call.c559 case GRPC_OP_SEND_MESSAGE: in grpc_rb_call_check_op_keys_hash_cb()
677 if (st->ops[i].op == GRPC_OP_SEND_MESSAGE) { in grpc_run_batch_stack_cleanup()
707 case GRPC_OP_SEND_MESSAGE: in grpc_run_batch_stack_fill_ops()
763 case GRPC_OP_SEND_MESSAGE: in grpc_run_batch_stack_build_result()
945 UINT2NUM(GRPC_OP_SEND_MESSAGE)); in Init_grpc_op_codes()

1234