Searched refs:grpc_cq_pollset (Results 1 – 11 of 11) sorted by relevance
120 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(w->cq)), in partly_done()243 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(cq)), &w->state, in grpc_channel_watch_connectivity_state()
62 op->bind_pollset = grpc_cq_pollset(cq); in grpc_channel_ping()
82 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cc);
1071 grpc_cq_pollset(server->cqs[i]); in grpc_server_start()1118 if (grpc_cq_pollset(s->cqs[cq_idx]) == accepting_pollset) break; in grpc_server_setup_transport()
428 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(args->cq)); in grpc_call_create()468 call->pollent = grpc_polling_entity_create_from_pollset(grpc_cq_pollset(cq)); in grpc_call_set_completion_queue()
1395 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cq) { function
217 grpc_endpoint_add_to_pollset(sfd.client, grpc_cq_pollset(client_cq)); in grpc_run_bad_client_test()218 grpc_endpoint_add_to_pollset(sfd.server, grpc_cq_pollset(a.cq)); in grpc_run_bad_client_test()
48 grpc_endpoint_add_to_pollset(sfd->server, grpc_cq_pollset(f->cq)); in server_setup_transport()
54 grpc_endpoint_add_to_pollset(sfd->server, grpc_cq_pollset(f->cq)); in server_setup_transport()
103 GPR_ASSERT(grpc_cq_pollset(cq) != nullptr); in test_pollset_conversion()