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