Lines Matching defs:cq_
112 cq_->Shutdown();
113 while (cq_->Next(&ignored_tag, &ignored_ok))
126 cq_ = builder.AddCompletionQueue();
138 std::unique_ptr<ServerCompletionQueue> cq_;
177 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get()));
178 service->RequestEcho(&srv_ctx_, &recv_request_, &response_writer, cq_.get(),
179 cq_.get(), tag(2));
181 Verifier().Expect(2, true).Verify(cq_.get());
185 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
202 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get()));
204 cq_.get(), cq_.get(), tag(2));
206 Verifier().Expect(2, true).Verify(cq_.get());
213 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
231 stub_->AsyncRequestStream(&cli_ctx_, &recv_response_, cq_.get(), tag(1)));
233 service->RequestRequestStream(&srv_ctx_, &srv_stream, cq_.get(), cq_.get(),
236 Verifier().Expect(2, true).Expect(1, true).Verify(cq_.get());
240 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
246 Verifier().Expect(5, true).Expect(6, true).Verify(cq_.get());
252 Verifier().Expect(7, true).Expect(8, false).Verify(cq_.get());
259 Verifier().Expect(9, true).Expect(10, true).Verify(cq_.get());
276 stub_->AsyncResponseStream(&cli_ctx_, send_request_, cq_.get(), tag(1)));
279 cq_.get(), cq_.get(), tag(2));
281 Verifier().Expect(1, true).Expect(2, true).Verify(cq_.get());
289 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
294 Verifier().Expect(5, true).Expect(6, true).Verify(cq_.get());
299 Verifier().Expect(7, true).Expect(8, false).Verify(cq_.get());
302 Verifier().Expect(9, true).Verify(cq_.get());
319 cli_stream(stub_->AsyncBidiStream(&cli_ctx_, cq_.get(), tag(1)));
321 service->RequestBidiStream(&srv_ctx_, &srv_stream, cq_.get(), cq_.get(),
324 Verifier().Expect(1, true).Expect(2, true).Verify(cq_.get());
328 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
336 Verifier().Expect(5, true).Expect(6, true).Verify(cq_.get());
341 Verifier().Expect(7, true).Expect(8, false).Verify(cq_.get());
345 Verifier().Expect(9, true).Expect(10, true).Verify(cq_.get());
