| /external/grpc-grpc/test/core/end2end/tests/ |
| D | retry_streaming.cc | 158 cq_verifier* cqv = cq_verifier_create(f.cq); in test_retry_streaming() local
206 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_retry_streaming()
207 cq_verify(cqv); in test_retry_streaming()
214 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_retry_streaming()
215 cq_verify(cqv); in test_retry_streaming()
234 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_retry_streaming()
235 cq_verify(cqv); in test_retry_streaming()
245 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_retry_streaming()
246 cq_verify(cqv); in test_retry_streaming()
256 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_retry_streaming()
[all …]
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 152 cq_verifier* cqv = cq_verifier_create(f.cq); in test_retry_streaming_succeeds_before_replay_finished() local
200 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_retry_streaming_succeeds_before_replay_finished()
201 cq_verify(cqv); in test_retry_streaming_succeeds_before_replay_finished()
208 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_retry_streaming_succeeds_before_replay_finished()
209 cq_verify(cqv); in test_retry_streaming_succeeds_before_replay_finished()
228 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_retry_streaming_succeeds_before_replay_finished()
229 cq_verify(cqv); in test_retry_streaming_succeeds_before_replay_finished()
239 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_retry_streaming_succeeds_before_replay_finished()
240 cq_verify(cqv); in test_retry_streaming_succeeds_before_replay_finished()
250 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_retry_streaming_succeeds_before_replay_finished()
[all …]
|
| D | retry_streaming_after_commit.cc | 151 cq_verifier* cqv = cq_verifier_create(f.cq); in test_retry_streaming_after_commit() local
194 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_retry_streaming_after_commit()
195 cq_verify(cqv); in test_retry_streaming_after_commit()
202 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_retry_streaming_after_commit()
203 cq_verify(cqv); in test_retry_streaming_after_commit()
222 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_retry_streaming_after_commit()
223 cq_verify(cqv); in test_retry_streaming_after_commit()
236 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_retry_streaming_after_commit()
238 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_retry_streaming_after_commit()
239 cq_verify(cqv); in test_retry_streaming_after_commit()
[all …]
|
| D | bad_ping.cc | 68 cq_verifier* cqv = cq_verifier_create(f.cq); in test_bad_ping() local
153 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_bad_ping()
154 cq_verify(cqv); in test_bad_ping()
164 CQ_EXPECT_COMPLETION(cqv, tag(200 + i), 1); in test_bad_ping()
166 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_bad_ping()
168 cq_verify(cqv); in test_bad_ping()
195 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_bad_ping()
196 cq_verify(cqv); in test_bad_ping()
199 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), 1); in test_bad_ping()
200 cq_verify(cqv); in test_bad_ping()
[all …]
|
| D | max_connection_age.cc | 82 cq_verifier* cqv = cq_verifier_create(f.cq); in test_max_age_forcibly_close() local
154 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_max_age_forcibly_close()
155 cq_verify(cqv); in test_max_age_forcibly_close()
163 cq_verify_empty_timeout(cqv, CQ_MAX_CONNECTION_AGE_WAIT_TIME_S); in test_max_age_forcibly_close()
167 CQ_EXPECT_COMPLETION(cqv, tag(1), true); in test_max_age_forcibly_close()
168 cq_verify(cqv); in test_max_age_forcibly_close()
196 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_max_age_forcibly_close()
197 cq_verify(cqv); in test_max_age_forcibly_close()
200 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), true); in test_max_age_forcibly_close()
201 cq_verify(cqv); in test_max_age_forcibly_close()
[all …]
|
| D | connectivity.cc | 51 cq_verifier* cqv = cq_verifier_create(f.cq); in test_connectivity() local
97 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test_connectivity()
98 cq_verify(cqv); in test_connectivity()
107 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_connectivity()
108 cq_verify(cqv); in test_connectivity()
125 CQ_EXPECT_COMPLETION(cqv, tag(4), 1); in test_connectivity()
126 cq_verify(cqv); in test_connectivity()
143 CQ_EXPECT_COMPLETION(cqv, tag(5), 1); in test_connectivity()
144 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), 1); in test_connectivity()
145 cq_verify(cqv); in test_connectivity()
[all …]
|
| D | write_buffering.cc | 99 cq_verifier* cqv = cq_verifier_create(f.cq); in test_invoke_request_with_payload() local
147 CQ_EXPECT_COMPLETION(cqv, tag(1), true); /* send message is buffered */ in test_invoke_request_with_payload()
148 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_invoke_request_with_payload()
149 cq_verify(cqv); in test_invoke_request_with_payload()
180 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_invoke_request_with_payload()
181 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_invoke_request_with_payload()
182 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_invoke_request_with_payload()
183 cq_verify(cqv); in test_invoke_request_with_payload()
197 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_invoke_request_with_payload()
198 CQ_EXPECT_COMPLETION(cqv, tag(4), true); in test_invoke_request_with_payload()
[all …]
|
| D | write_buffering_at_end.cc | 96 cq_verifier* cqv = cq_verifier_create(f.cq); in test_invoke_request_with_payload() local
144 CQ_EXPECT_COMPLETION(cqv, tag(1), true); /* send message is buffered */ in test_invoke_request_with_payload()
145 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_invoke_request_with_payload()
146 cq_verify(cqv); in test_invoke_request_with_payload()
177 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_invoke_request_with_payload()
178 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_invoke_request_with_payload()
179 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_invoke_request_with_payload()
180 cq_verify(cqv); in test_invoke_request_with_payload()
192 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_invoke_request_with_payload()
193 CQ_EXPECT_COMPLETION(cqv, tag(4), true); in test_invoke_request_with_payload()
[all …]
|
| D | ping.cc | 35 cq_verifier* cqv = cq_verifier_create(f.cq); in test_ping() local
65 CQ_EXPECT_COMPLETION(cqv, tag(0), 0); in test_ping()
79 CQ_EXPECT_COMPLETION(cqv, tag(99), 1); in test_ping()
80 cq_verify(cqv); in test_ping()
89 CQ_EXPECT_COMPLETION(cqv, tag(i), 1); in test_ping()
90 cq_verify(cqv); in test_ping()
94 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), 1); in test_ping()
95 cq_verify(cqv); in test_ping()
108 cq_verifier_destroy(cqv); in test_ping()
|
| D | max_concurrent_streams.cc | 90 cq_verifier* cqv = cq_verifier_create(f.cq); in simple_request_body() local
144 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in simple_request_body()
145 cq_verify(cqv); in simple_request_body()
171 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in simple_request_body()
172 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in simple_request_body()
173 cq_verify(cqv); in simple_request_body()
189 cq_verifier_destroy(cqv); in simple_request_body()
202 cq_verifier* cqv; in test_max_concurrent_streams() local
229 cqv = cq_verifier_create(f.cq); in test_max_concurrent_streams()
376 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_max_concurrent_streams()
[all …]
|
| D | max_connection_idle.cc | 49 cq_verifier* cqv = cq_verifier_create(f->cq); in simple_request_body() local
109 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in simple_request_body()
110 cq_verify(cqv); in simple_request_body()
145 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in simple_request_body()
146 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in simple_request_body()
147 cq_verify(cqv); in simple_request_body()
164 cq_verifier_destroy(cqv); in simple_request_body()
170 cq_verifier* cqv = cq_verifier_create(f.cq); in test_max_connection_idle() local
198 CQ_EXPECT_COMPLETION(cqv, tag(99), 1); in test_max_connection_idle()
199 cq_verify(cqv); in test_max_connection_idle()
[all …]
|
| D | streaming_error_response.cc | 104 cq_verifier* cqv = cq_verifier_create(f.cq); in test() local
156 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test()
157 cq_verify(cqv); in test()
171 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test()
173 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test()
175 cq_verify(cqv); in test()
186 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in test()
198 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test()
199 cq_verify(cqv); in test()
217 CQ_EXPECT_COMPLETION(cqv, tag(104), 1); in test()
[all …]
|
| D | compressed_payload.cc | 118 cq_verifier* cqv; in request_for_disabled_algorithm() local
137 cqv = cq_verifier_create(f.cq); in request_for_disabled_algorithm()
192 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in request_for_disabled_algorithm()
193 CQ_EXPECT_COMPLETION(cqv, tag(1), true); in request_for_disabled_algorithm()
194 cq_verify(cqv); in request_for_disabled_algorithm()
211 CQ_EXPECT_COMPLETION(cqv, tag(102), false); in request_for_disabled_algorithm()
223 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in request_for_disabled_algorithm()
224 cq_verify(cqv); in request_for_disabled_algorithm()
250 cq_verifier_destroy(cqv); in request_for_disabled_algorithm()
296 cq_verifier* cqv; in request_with_payload_template() local
[all …]
|
| D | stream_compression_compressed_payload.cc | 118 cq_verifier* cqv; in request_for_disabled_algorithm() local
137 cqv = cq_verifier_create(f.cq); in request_for_disabled_algorithm()
192 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in request_for_disabled_algorithm()
193 CQ_EXPECT_COMPLETION(cqv, tag(1), true); in request_for_disabled_algorithm()
194 cq_verify(cqv); in request_for_disabled_algorithm()
211 CQ_EXPECT_COMPLETION(cqv, tag(102), false); in request_for_disabled_algorithm()
223 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in request_for_disabled_algorithm()
224 cq_verify(cqv); in request_for_disabled_algorithm()
250 cq_verifier_destroy(cqv); in request_for_disabled_algorithm()
298 cq_verifier* cqv; in request_with_payload_template() local
[all …]
|
| D | ping_pong_streaming.cc | 93 cq_verifier* cqv = cq_verifier_create(f.cq); in test_pingpong_streaming() local
152 CQ_EXPECT_COMPLETION(cqv, tag(100), 1); in test_pingpong_streaming()
153 cq_verify(cqv); in test_pingpong_streaming()
201 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_pingpong_streaming()
202 cq_verify(cqv); in test_pingpong_streaming()
214 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in test_pingpong_streaming()
215 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test_pingpong_streaming()
216 cq_verify(cqv); in test_pingpong_streaming()
251 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_pingpong_streaming()
252 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_pingpong_streaming()
[all …]
|
| D | stream_compression_ping_pong_streaming.cc | 101 cq_verifier* cqv = cq_verifier_create(f.cq); in test_pingpong_streaming() local
160 CQ_EXPECT_COMPLETION(cqv, tag(100), 1); in test_pingpong_streaming()
161 cq_verify(cqv); in test_pingpong_streaming()
209 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_pingpong_streaming()
210 cq_verify(cqv); in test_pingpong_streaming()
222 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in test_pingpong_streaming()
223 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test_pingpong_streaming()
224 cq_verify(cqv); in test_pingpong_streaming()
259 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_pingpong_streaming()
260 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_pingpong_streaming()
[all …]
|
| D | disappearing_server.cc | 73 cq_verifier* cqv) { in do_request_and_shutdown_server() argument
129 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in do_request_and_shutdown_server()
130 cq_verify(cqv); in do_request_and_shutdown_server()
160 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in do_request_and_shutdown_server()
161 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in do_request_and_shutdown_server()
162 CQ_EXPECT_COMPLETION(cqv, tag(1000), 1); in do_request_and_shutdown_server()
163 cq_verify(cqv); in do_request_and_shutdown_server()
182 cq_verifier* cqv = cq_verifier_create(f.cq); in disappearing_server_test() local
190 do_request_and_shutdown_server(config, &f, cqv); in disappearing_server_test()
195 do_request_and_shutdown_server(config, &f, cqv); in disappearing_server_test()
[all …]
|
| D | max_message_length.cc | 111 cq_verifier* cqv; in test_max_message_length_on_request() local
181 cqv = cq_verifier_create(f.cq); in test_max_message_length_on_request()
227 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_max_message_length_on_request()
228 cq_verify(cqv); in test_max_message_length_on_request()
236 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_max_message_length_on_request()
237 cq_verify(cqv); in test_max_message_length_on_request()
255 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_max_message_length_on_request()
256 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_max_message_length_on_request()
257 cq_verify(cqv); in test_max_message_length_on_request()
281 cq_verifier_destroy(cqv); in test_max_message_length_on_request()
[all …]
|
| D | workaround_cronet_compression.cc | 124 cq_verifier* cqv; in request_with_payload_template() local
155 cqv = cq_verifier_create(f.cq); in request_with_payload_template()
200 CQ_EXPECT_COMPLETION(cqv, tag(100), true); in request_with_payload_template()
201 cq_verify(cqv); in request_with_payload_template()
263 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in request_with_payload_template()
264 cq_verify(cqv); in request_with_payload_template()
281 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in request_with_payload_template()
282 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in request_with_payload_template()
283 cq_verify(cqv); in request_with_payload_template()
330 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in request_with_payload_template()
[all …]
|
| D | graceful_server_shutdown.cc | 89 cq_verifier* cqv = cq_verifier_create(f.cq); in test_early_server_shutdown_finishes_inflight_calls() local
144 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_early_server_shutdown_finishes_inflight_calls()
145 cq_verify(cqv); in test_early_server_shutdown_finishes_inflight_calls()
149 cq_verify_empty(cqv); in test_early_server_shutdown_finishes_inflight_calls()
175 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_early_server_shutdown_finishes_inflight_calls()
176 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), 1); in test_early_server_shutdown_finishes_inflight_calls()
177 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_early_server_shutdown_finishes_inflight_calls()
178 cq_verify(cqv); in test_early_server_shutdown_finishes_inflight_calls()
194 cq_verifier_destroy(cqv); in test_early_server_shutdown_finishes_inflight_calls()
|
| D | shutdown_finishes_calls.cc | 82 cq_verifier* cqv = cq_verifier_create(f.cq); in test_early_server_shutdown_finishes_inflight_calls() local
137 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_early_server_shutdown_finishes_inflight_calls()
138 cq_verify(cqv); in test_early_server_shutdown_finishes_inflight_calls()
162 CQ_EXPECT_COMPLETION(cqv, tag(1000), 1); in test_early_server_shutdown_finishes_inflight_calls()
163 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_early_server_shutdown_finishes_inflight_calls()
164 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_early_server_shutdown_finishes_inflight_calls()
165 cq_verify(cqv); in test_early_server_shutdown_finishes_inflight_calls()
184 cq_verifier_destroy(cqv); in test_early_server_shutdown_finishes_inflight_calls()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | goaway_server_test.cc | 135 cq_verifier* cqv; in main() local
170 cqv = cq_verifier_create(cq); in main()
238 CQ_EXPECT_COMPLETION(cqv, tag(0x101), 1); in main()
239 CQ_EXPECT_COMPLETION(cqv, tag(0x301), 1); in main()
240 cq_verify(cqv); in main()
263 CQ_EXPECT_COMPLETION(cqv, tag(0x9999), 1); in main()
264 cq_verify(cqv); in main()
265 cq_verify_empty(cqv); in main()
313 CQ_EXPECT_COMPLETION(cqv, tag(0x201), 1); in main()
314 CQ_EXPECT_COMPLETION(cqv, tag(0x401), 1); in main()
[all …]
|
| /external/grpc-grpc/test/core/bad_client/tests/ |
| D | duplicate_header.cc | 62 cq_verifier* cqv = cq_verifier_create(cq); in verifier() local
72 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in verifier()
73 cq_verify(cqv); in verifier()
94 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in verifier()
95 cq_verify(cqv); in verifier()
116 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in verifier()
121 cq_verifier_destroy(cqv); in verifier()
|
| D | large_metadata.cc | 101 cq_verifier* cqv = cq_verifier_create(cq); in server_verifier_sends_too_much_metadata() local
110 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in server_verifier_sends_too_much_metadata()
111 cq_verify(cqv); in server_verifier_sends_too_much_metadata()
131 CQ_EXPECT_COMPLETION(cqv, tag(102), 0); // Operation fails. in server_verifier_sends_too_much_metadata()
132 cq_verify(cqv); in server_verifier_sends_too_much_metadata()
138 cq_verifier_destroy(cqv); in server_verifier_sends_too_much_metadata()
|
| /external/grpc-grpc/test/core/surface/ |
| D | lame_client_test.cc | 68 cq_verifier* cqv; in main() local
101 cqv = cq_verifier_create(cq); in main()
120 CQ_EXPECT_COMPLETION(cqv, tag(1), 0); in main()
121 cq_verify(cqv); in main()
137 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in main()
138 cq_verify(cqv); in main()
146 cq_verifier_destroy(cqv); in main()
|