Home
last modified time | relevance | path

Searched refs:cqv (Results 1 – 25 of 97) sorted by relevance

1234

/third_party/grpc/test/core/end2end/tests/
Dretry_streaming_succeeds_before_replay_finished.cc152 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 …]
Dretry_streaming.cc166 cq_verifier* cqv = cq_verifier_create(f.cq); in test_retry_streaming() local
217 CQ_EXPECT_COMPLETION(cqv, tag(2), true); in test_retry_streaming()
218 cq_verify(cqv); in test_retry_streaming()
225 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in test_retry_streaming()
226 cq_verify(cqv); in test_retry_streaming()
245 CQ_EXPECT_COMPLETION(cqv, tag(102), true); in test_retry_streaming()
246 cq_verify(cqv); in test_retry_streaming()
256 CQ_EXPECT_COMPLETION(cqv, tag(3), true); in test_retry_streaming()
257 cq_verify(cqv); in test_retry_streaming()
267 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in test_retry_streaming()
[all …]
Dbad_ping.cc68 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 …]
Dretry_streaming_after_commit.cc151 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 …]
Dmax_connection_age.cc82 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 …]
Dclient_streaming.cc96 cq_verifier* cqv = cq_verifier_create(f.cq); in test_client_streaming() local
143 CQ_EXPECT_COMPLETION(cqv, tag(100), 1); in test_client_streaming()
144 cq_verify(cqv); in test_client_streaming()
157 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_client_streaming()
158 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_client_streaming()
159 cq_verify(cqv); in test_client_streaming()
186 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_client_streaming()
187 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in test_client_streaming()
188 cq_verify(cqv); in test_client_streaming()
207 CQ_EXPECT_COMPLETION(cqv, tag(104), 1); in test_client_streaming()
[all …]
Dwrite_buffering.cc99 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 …]
Dwrite_buffering_at_end.cc96 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 …]
Dmax_concurrent_streams.cc90 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 …]
Dping.cc35 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()
Dmax_connection_idle.cc49 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 …]
Dstreaming_error_response.cc105 cq_verifier* cqv = cq_verifier_create(f.cq); in test() local
160 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test()
161 cq_verify(cqv); in test()
186 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test()
188 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test()
191 CQ_EXPECT_COMPLETION(cqv, tag(4), 1); in test()
193 cq_verify(cqv); in test()
208 CQ_EXPECT_COMPLETION_ANY_STATUS(cqv, tag(103)); in test()
220 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test()
221 cq_verify(cqv); in test()
[all …]
Dkeepalive_timeout.cc121 cq_verifier* cqv = cq_verifier_create(f.cq); in test_keepalive_timeout() local
167 CQ_EXPECT_COMPLETION(cqv, tag(101), 1); in test_keepalive_timeout()
168 cq_verify(cqv); in test_keepalive_timeout()
182 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_keepalive_timeout()
183 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_keepalive_timeout()
184 cq_verify(cqv); in test_keepalive_timeout()
197 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_keepalive_timeout()
198 cq_verify(cqv); in test_keepalive_timeout()
218 cq_verifier_destroy(cqv); in test_keepalive_timeout()
258 cq_verifier* cqv = cq_verifier_create(f.cq); in test_read_delays_keepalive() local
[all …]
Ddisappearing_server.cc73 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()
171 cq_verify_empty(cqv); in do_request_and_shutdown_server()
190 cq_verifier* cqv = cq_verifier_create(f.cq); in disappearing_server_test() local
198 do_request_and_shutdown_server(config, &f, cqv); in disappearing_server_test()
[all …]
Dmax_message_length.cc111 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 …]
Dstream_compression_compressed_payload.cc122 cq_verifier* cqv; in request_for_disabled_algorithm() local
141 cqv = cq_verifier_create(f.cq); in request_for_disabled_algorithm()
196 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in request_for_disabled_algorithm()
197 CQ_EXPECT_COMPLETION(cqv, tag(1), true); in request_for_disabled_algorithm()
198 cq_verify(cqv); in request_for_disabled_algorithm()
215 CQ_EXPECT_COMPLETION(cqv, tag(102), false); in request_for_disabled_algorithm()
227 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in request_for_disabled_algorithm()
228 cq_verify(cqv); in request_for_disabled_algorithm()
252 cq_verifier_destroy(cqv); in request_for_disabled_algorithm()
300 cq_verifier* cqv; in request_with_payload_template() local
[all …]
Dping_pong_streaming.cc93 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 …]
Dstream_compression_ping_pong_streaming.cc104 cq_verifier* cqv = cq_verifier_create(f.cq); in test_pingpong_streaming() local
163 CQ_EXPECT_COMPLETION(cqv, tag(100), 1); in test_pingpong_streaming()
164 cq_verify(cqv); in test_pingpong_streaming()
212 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in test_pingpong_streaming()
213 cq_verify(cqv); in test_pingpong_streaming()
225 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in test_pingpong_streaming()
226 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test_pingpong_streaming()
227 cq_verify(cqv); in test_pingpong_streaming()
262 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in test_pingpong_streaming()
263 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_pingpong_streaming()
[all …]
Dconnectivity.cc62 cq_verifier* cqv = cq_verifier_create(f.cq); in test_connectivity() local
108 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in test_connectivity()
109 cq_verify(cqv); in test_connectivity()
118 CQ_EXPECT_COMPLETION(cqv, tag(3), 1); in test_connectivity()
119 cq_verify(cqv); in test_connectivity()
136 CQ_EXPECT_COMPLETION(cqv, tag(4), 1); in test_connectivity()
137 cq_verify(cqv); in test_connectivity()
154 CQ_EXPECT_COMPLETION(cqv, tag(5), 1); in test_connectivity()
155 CQ_EXPECT_COMPLETION(cqv, tag(0xdead), 1); in test_connectivity()
156 cq_verify(cqv); in test_connectivity()
[all …]
Dcompressed_payload.cc126 cq_verifier* cqv; in request_for_disabled_algorithm() local
156 cqv = cq_verifier_create(f.cq); in request_for_disabled_algorithm()
211 CQ_EXPECT_COMPLETION(cqv, tag(101), true); in request_for_disabled_algorithm()
212 CQ_EXPECT_COMPLETION(cqv, tag(1), true); in request_for_disabled_algorithm()
213 cq_verify(cqv); in request_for_disabled_algorithm()
230 CQ_EXPECT_COMPLETION(cqv, tag(102), false); in request_for_disabled_algorithm()
242 CQ_EXPECT_COMPLETION(cqv, tag(103), true); in request_for_disabled_algorithm()
243 cq_verify(cqv); in request_for_disabled_algorithm()
267 cq_verifier_destroy(cqv); in request_for_disabled_algorithm()
308 cq_verifier* cqv; in request_with_payload_template_inner() local
[all …]
Dgraceful_server_shutdown.cc89 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()
Dworkaround_cronet_compression.cc125 cq_verifier* cqv; in request_with_payload_template() local
168 cqv = cq_verifier_create(f.cq); in request_with_payload_template()
213 CQ_EXPECT_COMPLETION(cqv, tag(100), true); in request_with_payload_template()
214 cq_verify(cqv); in request_with_payload_template()
276 CQ_EXPECT_COMPLETION(cqv, tag(102), 1); in request_with_payload_template()
277 cq_verify(cqv); in request_with_payload_template()
295 CQ_EXPECT_COMPLETION(cqv, tag(103), 1); in request_with_payload_template()
296 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in request_with_payload_template()
297 cq_verify(cqv); in request_with_payload_template()
346 CQ_EXPECT_COMPLETION(cqv, tag(1), 1); in request_with_payload_template()
[all …]
/third_party/grpc/test/core/end2end/
Dgoaway_server_test.cc150 cq_verifier* cqv; in main() local
187 cqv = cq_verifier_create(cq); in main()
264 CQ_EXPECT_COMPLETION(cqv, tag(0x101), 1); in main()
265 CQ_EXPECT_COMPLETION(cqv, tag(0x301), 1); in main()
266 cq_verify(cqv); in main()
289 CQ_EXPECT_COMPLETION(cqv, tag(0x9999), 1); in main()
290 cq_verify(cqv); in main()
291 cq_verify_empty(cqv); in main()
338 CQ_EXPECT_COMPLETION(cqv, tag(0x201), 1); in main()
339 CQ_EXPECT_COMPLETION(cqv, tag(0x401), 1); in main()
[all …]
/third_party/grpc/test/core/bad_client/tests/
Dduplicate_header.cc62 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()
/third_party/grpc/test/core/surface/
Dlame_client_test.cc62 cq_verifier* cqv; in main() local
95 cqv = cq_verifier_create(cq); in main()
114 CQ_EXPECT_COMPLETION(cqv, tag(1), 0); in main()
115 cq_verify(cqv); in main()
131 CQ_EXPECT_COMPLETION(cqv, tag(2), 1); in main()
132 cq_verify(cqv); in main()
140 cq_verifier_destroy(cqv); in main()

1234