Home
last modified time | relevance | path

Searched refs:grpc_cq_pollset (Results 1 – 13 of 13) sorted by relevance

/third_party/grpc/src/core/tsi/alts/handshaker/
Dalts_shared_resource.cc66 grpc_cq_pollset(g_alts_resource_dedicated.cq)); in grpc_alts_shared_resource_dedicated_start()
75 grpc_cq_pollset(g_alts_resource_dedicated.cq)); in grpc_alts_shared_resource_dedicated_shutdown()
/third_party/grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc127 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(w->cq)), in partly_done()
259 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(cq)), &w->state, in grpc_channel_watch_connectivity_state()
/third_party/grpc/src/core/lib/surface/
Dchannel_ping.cc61 op->bind_pollset = grpc_cq_pollset(cq); in grpc_channel_ping()
Dcompletion_queue.h85 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cq);
Dserver.cc567 pollsets_.push_back(grpc_cq_pollset(cq)); in Start()
618 if (grpc_cq_pollset(cqs_[cq_idx]) == accepting_pollset) break; in SetupTransport()
Dcall.cc468 grpc_polling_entity_create_from_pollset(grpc_cq_pollset(args->cq)); in grpc_call_create()
508 call->pollent = grpc_polling_entity_create_from_pollset(grpc_cq_pollset(cq)); in grpc_call_set_completion_queue()
Dcompletion_queue.cc1433 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cq) { function
/third_party/grpc/test/core/bad_client/
Dbad_client.cc218 grpc_endpoint_add_to_pollset(sfd.client, grpc_cq_pollset(client_cq)); in grpc_run_bad_client_test()
219 grpc_endpoint_add_to_pollset(sfd.server, grpc_cq_pollset(a.cq)); in grpc_run_bad_client_test()
/third_party/grpc/test/core/end2end/fixtures/
Dh2_sockpair.cc48 grpc_endpoint_add_to_pollset(sfd->server, grpc_cq_pollset(f->cq)); in server_setup_transport()
Dh2_sockpair+trace.cc54 grpc_endpoint_add_to_pollset(sfd->server, grpc_cq_pollset(f->cq)); in server_setup_transport()
Dh2_sockpair_1byte.cc48 grpc_endpoint_add_to_pollset(sfd->server, grpc_cq_pollset(f->cq)); in server_setup_transport()
/third_party/grpc/test/core/bad_connection/
Dclose_fd_test.cc75 grpc_endpoint_add_to_pollset(g_ctx.ep->server, grpc_cq_pollset(g_ctx.cq)); in server_setup_transport()
84 grpc_cq_pollset(g_ctx.client_cq)); in client_setup_transport()
/third_party/grpc/test/core/surface/
Dcompletion_queue_test.cc104 GPR_ASSERT(grpc_cq_pollset(cq) != nullptr); in test_pollset_conversion()