Home
last modified time | relevance | path

Searched refs:pollent (Results 1 – 25 of 65) sorted by relevance

123

/external/grpc-grpc/src/core/lib/iomgr/
Dpolling_entity.cc28 grpc_polling_entity pollent; in grpc_polling_entity_create_from_pollset_set() local
29 pollent.pollent.pollset_set = pollset_set; in grpc_polling_entity_create_from_pollset_set()
30 pollent.tag = GRPC_POLLS_POLLSET_SET; in grpc_polling_entity_create_from_pollset_set()
31 return pollent; in grpc_polling_entity_create_from_pollset_set()
36 grpc_polling_entity pollent; in grpc_polling_entity_create_from_pollset() local
37 pollent.pollent.pollset = pollset; in grpc_polling_entity_create_from_pollset()
38 pollent.tag = GRPC_POLLS_POLLSET; in grpc_polling_entity_create_from_pollset()
39 return pollent; in grpc_polling_entity_create_from_pollset()
42 grpc_pollset* grpc_polling_entity_pollset(grpc_polling_entity* pollent) { in grpc_polling_entity_pollset() argument
43 if (pollent->tag == GRPC_POLLS_POLLSET) { in grpc_polling_entity_pollset()
[all …]
Dpolling_entity.h41 } pollent; member
51 grpc_pollset* grpc_polling_entity_pollset(grpc_polling_entity* pollent);
54 grpc_pollset_set* grpc_polling_entity_pollset_set(grpc_polling_entity* pollent);
56 bool grpc_polling_entity_is_empty(const grpc_polling_entity* pollent);
60 void grpc_polling_entity_add_to_pollset_set(grpc_polling_entity* pollent,
65 void grpc_polling_entity_del_from_pollset_set(grpc_polling_entity* pollent,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dpolling_entity.cc28 grpc_polling_entity pollent; in grpc_polling_entity_create_from_pollset_set() local
29 pollent.pollent.pollset_set = pollset_set; in grpc_polling_entity_create_from_pollset_set()
30 pollent.tag = GRPC_POLLS_POLLSET_SET; in grpc_polling_entity_create_from_pollset_set()
31 return pollent; in grpc_polling_entity_create_from_pollset_set()
36 grpc_polling_entity pollent; in grpc_polling_entity_create_from_pollset() local
37 pollent.pollent.pollset = pollset; in grpc_polling_entity_create_from_pollset()
38 pollent.tag = GRPC_POLLS_POLLSET; in grpc_polling_entity_create_from_pollset()
39 return pollent; in grpc_polling_entity_create_from_pollset()
42 grpc_pollset* grpc_polling_entity_pollset(grpc_polling_entity* pollent) { in grpc_polling_entity_pollset() argument
43 if (pollent->tag == GRPC_POLLS_POLLSET) { in grpc_polling_entity_pollset()
[all …]
Dpolling_entity.h41 } pollent; member
51 grpc_pollset* grpc_polling_entity_pollset(grpc_polling_entity* pollent);
54 grpc_pollset_set* grpc_polling_entity_pollset_set(grpc_polling_entity* pollent);
56 bool grpc_polling_entity_is_empty(const grpc_polling_entity* pollent);
60 void grpc_polling_entity_add_to_pollset_set(grpc_polling_entity* pollent,
65 void grpc_polling_entity_del_from_pollset_set(grpc_polling_entity* pollent,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/http/
Dhttpcli.cc58 grpc_polling_entity* pollent; member
92 grpc_polling_entity_del_from_pollset_set(req->pollent, in finish()
230 grpc_polling_entity* pollent, in internal_request_begin() argument
247 req->pollent = pollent; in internal_request_begin()
259 GPR_ASSERT(pollent); in internal_request_begin()
260 grpc_polling_entity_add_to_pollset_set(req->pollent, in internal_request_begin()
269 grpc_polling_entity* pollent, in grpc_httpcli_get() argument
278 internal_request_begin(context, pollent, resource_quota, request, deadline, in grpc_httpcli_get()
284 grpc_polling_entity* pollent, in grpc_httpcli_post() argument
297 context, pollent, resource_quota, request, deadline, on_done, response, in grpc_httpcli_post()
Dhttpcli.h83 grpc_polling_entity* pollent,
103 grpc_polling_entity* pollent,
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.cc53 grpc_polling_entity* pollent; member
88 grpc_polling_entity_del_from_pollset_set(req->pollent, in finish()
227 grpc_polling_entity* pollent, in internal_request_begin() argument
243 req->pollent = pollent; in internal_request_begin()
255 GPR_ASSERT(pollent); in internal_request_begin()
256 grpc_polling_entity_add_to_pollset_set(req->pollent, in internal_request_begin()
265 grpc_polling_entity* pollent, in grpc_httpcli_get() argument
274 internal_request_begin(context, pollent, resource_quota, request, deadline, in grpc_httpcli_get()
281 grpc_polling_entity* pollent, in grpc_httpcli_post() argument
294 context, pollent, resource_quota, request, deadline, on_done, response, in grpc_httpcli_post()
Dhttpcli.h84 grpc_polling_entity* pollent,
105 grpc_polling_entity* pollent,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/composite/
Dcomposite_credentials.cc45 grpc_polling_entity* pollent, grpc_auth_metadata_context auth_md_context, in grpc_composite_call_credentials_metadata_context()
49 pollent(pollent), in grpc_composite_call_credentials_metadata_context()
59 grpc_polling_entity* pollent; member
76 ctx->pollent, ctx->auth_md_context, ctx->md_array, in composite_call_metadata_cb()
92 grpc_polling_entity* pollent, grpc_auth_metadata_context auth_md_context, in get_request_metadata() argument
97 this, pollent, auth_md_context, md_array, on_request_metadata); in get_request_metadata()
102 ctx->pollent, ctx->auth_md_context, ctx->md_array, in get_request_metadata()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/external/
Dexternal_account_credentials.h63 grpc_polling_entity* pollent, grpc_millis deadline) in HTTPRequestContext()
65 pollent(pollent), in HTTPRequestContext()
72 grpc_polling_entity* pollent; member
94 grpc_polling_entity* pollent, grpc_iomgr_cb_func cb,
/external/grpc-grpc/src/core/lib/security/credentials/oauth2/
Doauth2_credentials.cc113 grpc_pollset_set_destroy(grpc_polling_entity_pollset_set(&c->pollent)); in oauth2_token_fetcher_destruct()
242 pending_request->pollent, grpc_polling_entity_pollset_set(&c->pollent)); in on_oauth2_token_fetcher_http_response()
253 grpc_call_credentials* creds, grpc_polling_entity* pollent, in oauth2_token_fetcher_get_request_metadata() argument
283 pending_request->pollent = pollent; in oauth2_token_fetcher_get_request_metadata()
285 pollent, grpc_polling_entity_pollset_set(&c->pollent)); in oauth2_token_fetcher_get_request_metadata()
297 &c->httpcli_context, &c->pollent, in oauth2_token_fetcher_get_request_metadata()
342 c->pollent = in init_oauth2_token_fetcher()
357 grpc_httpcli_context* httpcli_context, grpc_polling_entity* pollent, in compute_engine_fetch_oauth2() argument
372 httpcli_context, pollent, resource_quota, &request, deadline, in compute_engine_fetch_oauth2()
408 grpc_httpcli_context* httpcli_context, grpc_polling_entity* pollent, in refresh_token_fetch_oauth2() argument
[all …]
Doauth2_credentials.h59 grpc_polling_entity* pollent,
66 grpc_polling_entity* pollent; member
79 grpc_polling_entity pollent; member
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/oauth2/
Doauth2_credentials.h68 grpc_polling_entity* pollent; member
77 bool get_request_metadata(grpc_polling_entity* pollent,
93 grpc_polling_entity* pollent, grpc_iomgr_cb_func cb,
123 grpc_polling_entity* pollent, grpc_iomgr_cb_func cb,
137 bool get_request_metadata(grpc_polling_entity* pollent,
Doauth2_credentials.cc267 pending_request->pollent, grpc_polling_entity_pollset_set(&pollent_)); in on_http_response()
278 grpc_polling_entity* pollent, grpc_auth_metadata_context /*context*/, in get_request_metadata() argument
306 pending_request->pollent = pollent; in get_request_metadata()
308 pollent, grpc_polling_entity_pollset_set(&pollent_)); in get_request_metadata()
382 grpc_polling_entity* pollent, in fetch_oauth2() argument
399 grpc_httpcli_get(http_context, pollent, resource_quota, &request, deadline, in fetch_oauth2()
439 grpc_httpcli_context* httpcli_context, grpc_polling_entity* pollent, in fetch_oauth2() argument
459 grpc_httpcli_post(httpcli_context, pollent, resource_quota, &request, in fetch_oauth2()
563 grpc_polling_entity* pollent, in fetch_oauth2() argument
592 http_context, pollent, resource_quota, &request, body, body_length, in fetch_oauth2()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/google_default/
Dgoogle_default_credentials.cc75 grpc_polling_entity pollent; member
157 grpc_pollset_kick(grpc_polling_entity_pollset(&detector->pollent), in on_metadata_server_detection_http_response()
177 detector.pollent = grpc_polling_entity_create_from_pollset(pollset); in is_metadata_server_reachable()
187 &context, &detector.pollent, resource_quota, &request, in is_metadata_server_reachable()
201 grpc_pollset_work(grpc_polling_entity_pollset(&detector.pollent), in is_metadata_server_reachable()
210 grpc_polling_entity_pollset(&detector.pollent), in is_metadata_server_reachable()
212 grpc_pollset_shutdown(grpc_polling_entity_pollset(&detector.pollent), in is_metadata_server_reachable()
216 gpr_free(grpc_polling_entity_pollset(&detector.pollent)); in is_metadata_server_reachable()
/external/grpc-grpc/src/core/lib/security/credentials/composite/
Dcomposite_credentials.cc37 grpc_polling_entity* pollent; member
62 inner_creds, ctx->pollent, ctx->auth_md_context, ctx->md_array, in composite_call_metadata_cb()
77 grpc_call_credentials* creds, grpc_polling_entity* pollent, in composite_call_get_request_metadata() argument
87 ctx->pollent = pollent; in composite_call_get_request_metadata()
98 inner_creds, ctx->pollent, ctx->auth_md_context, ctx->md_array, in composite_call_get_request_metadata()
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc55 grpc_polling_entity* pollent; member
211 GPR_ASSERT(calld->pollent != nullptr); in send_security_metadata()
217 calld->creds, calld->pollent, calld->auth_md_context, in send_security_metadata()
346 grpc_polling_entity* pollent) { in set_pollset_or_pollset_set() argument
348 calld->pollent = pollent; in set_pollset_or_pollset_set()
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.cc60 grpc_polling_entity* pollent) { in SetPollsetOrPollsetSet() argument
61 grpc_call_stack_ignore_set_pollset_or_pollset_set(elem, pollent); in SetPollsetOrPollsetSet()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.cc61 grpc_polling_entity* pollent) { in SetPollsetOrPollsetSet() argument
62 grpc_call_stack_ignore_set_pollset_or_pollset_set(elem, pollent); in SetPollsetOrPollsetSet()
/external/grpc-grpc/src/core/lib/channel/
Dchannel_stack.h122 grpc_polling_entity* pollent);
224 grpc_polling_entity* pollent);
254 grpc_call_element* elem, grpc_polling_entity* pollent);
Dchannel_stack.cc191 grpc_polling_entity* pollent) { in grpc_call_stack_set_pollset_or_pollset_set() argument
200 call_elems[i].filter->set_pollset_or_pollset_set(&call_elems[i], pollent); in grpc_call_stack_set_pollset_or_pollset_set()
205 grpc_call_element* elem, grpc_polling_entity* pollent) {} in grpc_call_stack_ignore_set_pollset_or_pollset_set() argument
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dchannel_stack.h131 grpc_polling_entity* pollent);
232 grpc_polling_entity* pollent);
274 grpc_call_element* elem, grpc_polling_entity* pollent);
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc107 grpc_polling_entity* pollent = nullptr; member
310 GPR_ASSERT(calld->pollent != nullptr); in send_security_metadata()
316 calld->pollent, calld->auth_md_context, &calld->md_array, in send_security_metadata()
413 grpc_call_element* elem, grpc_polling_entity* pollent) { in client_auth_set_pollset_or_pollset_set() argument
415 calld->pollent = pollent; in client_auth_set_pollset_or_pollset_set()
/external/grpc-grpc/src/core/lib/security/credentials/
Dcredentials.h164 grpc_polling_entity* pollent,
188 grpc_call_credentials* creds, grpc_polling_entity* pollent,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.cc148 grpc_polling_entity* pollent) { argument
151 if ((pollset = grpc_polling_entity_pollset(pollent)) != nullptr) {
153 } else if ((pollset_set = grpc_polling_entity_pollset_set(pollent)) !=

123