Home
last modified time | relevance | path

Searched refs:GRPC_OP_RECV_MESSAGE (Results 1 – 25 of 73) sorted by relevance

123

/third_party/grpc/test/core/end2end/tests/
Dretry_streaming.cc195 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
240 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
262 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
323 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
334 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
358 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming()
Dretry_streaming_succeeds_before_replay_finished.cc178 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
223 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
245 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
267 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
332 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_succeeds_before_replay_finished()
Dretry_streaming_after_commit.cc177 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_after_commit()
217 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_after_commit()
257 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_after_commit()
289 op->op = GRPC_OP_RECV_MESSAGE; in test_retry_streaming_after_commit()
Dcancel_after_round_trip.cc177 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_round_trip()
195 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_round_trip()
232 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_round_trip()
Dstreaming_error_response.cc142 op->op = GRPC_OP_RECV_MESSAGE; in test()
178 op->op = GRPC_OP_RECV_MESSAGE; in test()
213 op->op = GRPC_OP_RECV_MESSAGE; in test()
Dcancel_after_client_done.cc160 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_accept_and_writes_closed()
177 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_accept_and_writes_closed()
Dcancel_after_accept.cc182 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_accept()
199 op->op = GRPC_OP_RECV_MESSAGE; in test_cancel_after_accept()
Dcall_creds.cc209 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload_and_call_creds()
251 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload_and_call_creds()
447 op->op = GRPC_OP_RECV_MESSAGE; in test_request_with_server_rejecting_client_creds()
Dkeepalive_timeout.cc157 op->op = GRPC_OP_RECV_MESSAGE; in test_keepalive_timeout()
347 op->op = GRPC_OP_RECV_MESSAGE; in test_read_delays_keepalive()
358 op->op = GRPC_OP_RECV_MESSAGE; in test_read_delays_keepalive()
Dpayload.cc163 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
193 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
Dping_pong_streaming.cc182 op->op = GRPC_OP_RECV_MESSAGE; in test_pingpong_streaming()
193 op->op = GRPC_OP_RECV_MESSAGE; in test_pingpong_streaming()
Dbinary_metadata.cc171 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
202 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
Dstream_compression_payload.cc167 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
197 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
Dsimple_metadata.cc165 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
196 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
Dwrite_buffering.cc173 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_request_with_payload()
204 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_request_with_payload()
Dload_reporting_hook.cc174 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
204 op->op = GRPC_OP_RECV_MESSAGE; in request_response_with_payload()
Dtrailing_metadata.cc173 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
204 op->op = GRPC_OP_RECV_MESSAGE; in test_request_response_with_metadata_and_payload()
Dsimple_cacheable_request.cc167 op->op = GRPC_OP_RECV_MESSAGE; in test_cacheable_request_response_with_metadata_and_payload()
198 op->op = GRPC_OP_RECV_MESSAGE; in test_cacheable_request_response_with_metadata_and_payload()
Dstream_compression_ping_pong_streaming.cc193 op->op = GRPC_OP_RECV_MESSAGE; in test_pingpong_streaming()
204 op->op = GRPC_OP_RECV_MESSAGE; in test_pingpong_streaming()
Dinvoke_large_request.cc166 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_large_request()
196 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_large_request()
Dwrite_buffering_at_end.cc170 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_request_with_payload()
199 op->op = GRPC_OP_RECV_MESSAGE; in test_invoke_request_with_payload()
/third_party/grpc/test/core/end2end/fixtures/
Dproxy.cc197 op.op = GRPC_OP_RECV_MESSAGE; in on_p2s_sent_message()
257 op.op = GRPC_OP_RECV_MESSAGE; in on_c2p_sent_message()
366 op.op = GRPC_OP_RECV_MESSAGE; in on_new_call()
374 op.op = GRPC_OP_RECV_MESSAGE; in on_new_call()
/third_party/grpc/test/core/fling/
Dclient.cc67 op->op = GRPC_OP_RECV_MESSAGE; in init_ping_pong_request()
115 stream_step_ops[1].op = GRPC_OP_RECV_MESSAGE; in init_ping_pong_stream()
Dserver.cc97 op->op = GRPC_OP_RECV_MESSAGE; in handle_unary_method()
135 read_op.op = GRPC_OP_RECV_MESSAGE; in start_read_op()
/third_party/grpc/test/core/bad_connection/
Dclose_fd_test.cc251 op->op = GRPC_OP_RECV_MESSAGE; in _test_close_before_server_recv()
284 op->op = GRPC_OP_RECV_MESSAGE; in _test_close_before_server_recv()
426 op->op = GRPC_OP_RECV_MESSAGE; in _test_close_before_server_send()
459 op->op = GRPC_OP_RECV_MESSAGE; in _test_close_before_server_send()
622 op->op = GRPC_OP_RECV_MESSAGE; in _test_close_before_client_send()

123