Lines Matching refs:cq
35 CompletionQueue cq; in TEST() local
38 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
43 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
51 CompletionQueue cq; in TEST() local
56 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
61 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
74 CompletionQueue cq; in TEST() local
75 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
80 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
149 CompletionQueue cq; in TEST() local
156 std::thread t1([&alarm, &cq, &junk] { in TEST()
157 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
160 std::thread t2([&cq, &ok, &output_tag, &status] { in TEST()
162 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
173 CompletionQueue cq; in TEST() local
175 Alarm alarm(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
180 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
188 CompletionQueue cq; in TEST() local
191 first.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
196 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
203 CompletionQueue cq; in TEST() local
206 first.Set(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
213 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
221 CompletionQueue cq; in TEST() local
226 alarm.Set(&cq, one_sec_deadline, junk); in TEST()
231 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
239 CompletionQueue cq; in TEST() local
242 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(0), junk); in TEST()
247 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
255 CompletionQueue cq; in TEST() local
258 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(-1), junk); in TEST()
263 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
271 CompletionQueue cq; in TEST() local
274 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(10), junk); in TEST()
280 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
328 CompletionQueue cq; in TEST() local
332 alarm.Set(&cq, grpc_timeout_seconds_to_deadline(10), junk); in TEST()
338 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
366 CompletionQueue cq; in TEST() local