Home
last modified time | relevance | path

Searched refs:was_cancelled (Results 1 – 25 of 71) sorted by relevance

123

/third_party/grpc/test/core/end2end/tests/
Dmax_connection_age.cc110 int was_cancelled = 2; in test_max_age_forcibly_close() local
189 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_age_forcibly_close()
209 GPR_ASSERT(was_cancelled == 1); in test_max_age_forcibly_close()
252 int was_cancelled = 2; in test_max_age_gracefully_close() local
322 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_age_gracefully_close()
345 GPR_ASSERT(was_cancelled == 0); in test_max_age_gracefully_close()
Dmax_message_length.cc126 int was_cancelled = 2; in test_max_message_length_on_request() local
242 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_message_length_on_request()
260 GPR_ASSERT(was_cancelled == 1); in test_max_message_length_on_request()
317 int was_cancelled = 2; in test_max_message_length_on_response() local
429 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_message_length_on_response()
511 int was_cancelled = 2; in test_max_receive_message_length_on_compressed_request() local
584 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_receive_message_length_on_compressed_request()
622 GPR_ASSERT(was_cancelled == 1); in test_max_receive_message_length_on_compressed_request()
669 int was_cancelled = 2; in test_max_receive_message_length_on_compressed_response() local
748 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_receive_message_length_on_compressed_response()
Dresource_quota_server.cc157 int* was_cancelled = static_cast<int*>(malloc(sizeof(int) * NUM_CALLS)); in resource_quota_server() local
178 was_cancelled[i] = 0; in resource_quota_server()
321 op->data.recv_close_on_server.cancelled = &was_cancelled[call_id]; in resource_quota_server()
346 if (was_cancelled[call_id]) { in resource_quota_server()
378 free(was_cancelled); in resource_quota_server()
Dshutdown_finishes_calls.cc92 int was_cancelled = 2; in test_early_server_shutdown_finishes_inflight_calls() local
143 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_early_server_shutdown_finishes_inflight_calls()
171 GPR_ASSERT(was_cancelled == 1); in test_early_server_shutdown_finishes_inflight_calls()
Dretry_too_many_attempts.cc120 int was_cancelled = 2; in test_retry_too_many_attempts() local
215 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_too_many_attempts()
256 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_too_many_attempts()
269 GPR_ASSERT(was_cancelled == 0); in test_retry_too_many_attempts()
Dretry_server_pushback_disabled.cc121 int was_cancelled = 2; in test_retry_server_pushback_disabled() local
221 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_server_pushback_disabled()
263 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_server_pushback_disabled()
276 GPR_ASSERT(was_cancelled == 0); in test_retry_server_pushback_disabled()
Dserver_finishes_request.cc102 int was_cancelled = 2; in simple_request_body() local
161 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
176 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Dgraceful_server_shutdown.cc99 int was_cancelled = 2; in test_early_server_shutdown_finishes_inflight_calls() local
167 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_early_server_shutdown_finishes_inflight_calls()
184 GPR_ASSERT(was_cancelled == 0); in test_early_server_shutdown_finishes_inflight_calls()
Ddisappearing_server.cc85 int was_cancelled = 2; in do_request_and_shutdown_server() local
152 op->data.recv_close_on_server.cancelled = &was_cancelled; in do_request_and_shutdown_server()
176 GPR_ASSERT(was_cancelled == 0); in do_request_and_shutdown_server()
Dmax_concurrent_streams.cc100 int was_cancelled = 2; in simple_request_body() local
163 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
178 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
217 int was_cancelled; in test_max_concurrent_streams() local
360 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_concurrent_streams()
399 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_concurrent_streams()
461 int was_cancelled; in test_max_concurrent_streams_with_timeout_on_first() local
594 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_concurrent_streams_with_timeout_on_first()
656 int was_cancelled; in test_max_concurrent_streams_with_timeout_on_second() local
788 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_max_concurrent_streams_with_timeout_on_second()
Dbad_ping.cc109 int was_cancelled = 2; in test_bad_ping() local
187 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_bad_ping()
208 GPR_ASSERT(was_cancelled == 1); in test_bad_ping()
268 int was_cancelled = 2; in test_pings_without_data() local
343 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_pings_without_data()
Dretry_server_pushback_delay.cc120 int was_cancelled = 2; in test_retry_server_pushback_delay() local
221 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_server_pushback_delay()
275 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_server_pushback_delay()
288 GPR_ASSERT(was_cancelled == 0); in test_retry_server_pushback_delay()
Dretry.cc120 int was_cancelled = 2; in test_retry() local
222 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry()
282 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry()
295 GPR_ASSERT(was_cancelled == 0); in test_retry()
Dregistered_call.cc103 int was_cancelled = 2; in simple_request_body() local
165 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
180 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Dhigh_initial_seqno.cc107 int was_cancelled = 2; in simple_request_body() local
170 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
185 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Dcall_host_override.cc112 int was_cancelled = 2; in test_invoke_simple_request() local
192 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_invoke_simple_request()
209 GPR_ASSERT(was_cancelled == 0); in test_invoke_simple_request()
Ddefault_host.cc103 int was_cancelled = 2; in test_invoke_simple_request() local
181 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_invoke_simple_request()
204 GPR_ASSERT(was_cancelled == 0); in test_invoke_simple_request()
Dretry_exceeds_buffer_size_in_initial_batch.cc123 int was_cancelled = 2; in test_retry_exceeds_buffer_size_in_initial_batch() local
222 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_exceeds_buffer_size_in_initial_batch()
235 GPR_ASSERT(was_cancelled == 0); in test_retry_exceeds_buffer_size_in_initial_batch()
Dno_error_on_hotpath.cc104 int was_cancelled = 2; in simple_request_body() local
178 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
194 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Dproxy_auth.cc107 int was_cancelled = 2; in simple_request_body() local
185 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
201 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Dretry_disabled.cc121 int was_cancelled = 2; in test_retry_disabled() local
219 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_retry_disabled()
232 GPR_ASSERT(was_cancelled == 0); in test_retry_disabled()
Didempotent_request.cc103 int was_cancelled = 2; in simple_request_body() local
181 op->data.recv_close_on_server.cancelled = &was_cancelled; in simple_request_body()
197 GPR_ASSERT(was_cancelled == 0); in simple_request_body()
Drequest_with_payload.cc107 int was_cancelled = 2; in test_invoke_request_with_payload() local
180 op->data.recv_close_on_server.cancelled = &was_cancelled; in test_invoke_request_with_payload()
203 GPR_ASSERT(was_cancelled == 0); in test_invoke_request_with_payload()
/third_party/grpc/test/core/bad_client/tests/
Dduplicate_header.cc64 int was_cancelled = 2; in verifier() local
100 op->data.recv_close_on_server.cancelled = &was_cancelled; in verifier()
/third_party/grpc/test/core/fling/
Dserver.cc58 static int was_cancelled = 2; variable
112 op->data.recv_close_on_server.cancelled = &was_cancelled; in handle_unary_method()
162 status_op[1].data.recv_close_on_server.cancelled = &was_cancelled; in start_send_status()

123