Lines Matching refs:CompletionQueue
253 CompletionQueue cq_;
280 SyncRequestThreadManager(Server* server, CompletionQueue* server_cq,
299 case CompletionQueue::TIMEOUT:
301 case CompletionQueue::SHUTDOWN:
303 case CompletionQueue::GOT_EVENT:
379 CompletionQueue* server_cq_;
606 CompletionQueue shutdown_cq;
614 CompletionQueue::NextStatus status =
619 if (status == CompletionQueue::NextStatus::TIMEOUT) {
672 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
708 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
724 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq,
