Lines Matching refs:cq
39 CompletionQueue cq; in BM_CreateDestroyCpp() local
51 CompletionQueue cq(core_cq); in BM_CreateDestroyCpp2() local
86 CompletionQueue cq; in BM_Pass1Cpp() local
87 grpc_completion_queue* c_cq = cq.cq(); in BM_Pass1Cpp()
98 cq.Next(&tag, &ok); in BM_Pass1Cpp()
107 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_Pass1Core() local
112 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pass1Core()
113 grpc_cq_end_op(cq, nullptr, GRPC_ERROR_NONE, DoneWithCompletionOnStack, in BM_Pass1Core()
116 grpc_completion_queue_next(cq, deadline, nullptr); in BM_Pass1Core()
118 grpc_completion_queue_destroy(cq); in BM_Pass1Core()
126 grpc_completion_queue* cq = grpc_completion_queue_create_for_pluck(nullptr); in BM_Pluck1Core() local
131 GPR_ASSERT(grpc_cq_begin_op(cq, nullptr)); in BM_Pluck1Core()
132 grpc_cq_end_op(cq, nullptr, GRPC_ERROR_NONE, DoneWithCompletionOnStack, in BM_Pluck1Core()
135 grpc_completion_queue_pluck(cq, nullptr, deadline, nullptr); in BM_Pluck1Core()
137 grpc_completion_queue_destroy(cq); in BM_Pluck1Core()
145 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_EmptyCore() local
148 grpc_completion_queue_next(cq, deadline, nullptr); in BM_EmptyCore()
150 grpc_completion_queue_destroy(cq); in BM_EmptyCore()