Home
last modified time | relevance | path

Searched refs:grpc_combiner_scheduler (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc75 &c, DoNothing, nullptr, grpc_combiner_scheduler(combiner))); in BM_ClosureInitAgainstCombiner()
247 GRPC_CLOSURE_INIT(&c, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSchedOnCombiner()
264 GRPC_CLOSURE_INIT(&c1, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSched2OnCombiner()
265 GRPC_CLOSURE_INIT(&c2, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSched2OnCombiner()
284 GRPC_CLOSURE_INIT(&c1, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSched3OnCombiner()
285 GRPC_CLOSURE_INIT(&c2, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSched3OnCombiner()
286 GRPC_CLOSURE_INIT(&c3, DoNothing, nullptr, grpc_combiner_scheduler(combiner)); in BM_ClosureSched3OnCombiner()
307 grpc_combiner_scheduler(combiner1)); in BM_ClosureSched2OnTwoCombiners()
309 grpc_combiner_scheduler(combiner2)); in BM_ClosureSched2OnTwoCombiners()
332 grpc_combiner_scheduler(combiner1)); in BM_ClosureSched4OnTwoCombiners()
[all …]
/external/grpc-grpc/test/core/client_channel/resolvers/
Dfake_resolver_test.cc132 on_resolution_cb, &on_res_arg, grpc_combiner_scheduler(combiner)); in test_fake_resolver()
145 grpc_combiner_scheduler(combiner)); in test_fake_resolver()
159 grpc_combiner_scheduler(combiner)); in test_fake_resolver()
175 grpc_combiner_scheduler(combiner)); in test_fake_resolver()
188 grpc_combiner_scheduler(combiner)); in test_fake_resolver()
200 grpc_combiner_scheduler(combiner)); in test_fake_resolver()
Ddns_resolver_cooldown_test.cc207 grpc_combiner_scheduler(g_combiner))); in on_first_resolution()
245 grpc_combiner_scheduler(g_combiner))); in start_test_under_combiner()
257 grpc_combiner_scheduler(g_combiner)), in test_cooldown()
Ddns_resolver_connectivity_test.cc139 grpc_combiner_scheduler(combiner)), in call_resolver_next_after_locking()
/external/grpc-grpc/test/core/iomgr/
Dcombiner_test.cc47 grpc_combiner_scheduler(lock)), in test_execute_one()
83 check_one, c, grpc_combiner_scheduler(args->lock)), in execute_many_loop()
92 grpc_combiner_scheduler(args->lock)), in execute_many_loop()
138 GRPC_CLOSURE_CREATE(add_finally, lock, grpc_combiner_scheduler(lock)), in test_execute_finally()
/external/grpc-grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc482 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
484 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
486 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
488 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
490 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
492 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
494 grpc_combiner_scheduler(conn->proxy->combiner)); in on_accept()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc165 grpc_combiner_scheduler(resolver_->combiner())), in SetResponse()
188 grpc_combiner_scheduler(resolver_->combiner())), in SetReresolutionResponse()
208 grpc_combiner_scheduler(resolver_->combiner())), in SetFailure()
/external/grpc-grpc/src/core/lib/iomgr/
Dresource_quota.cc642 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_quota_create()
758 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_user_create()
761 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_user_create()
764 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_user_create()
767 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_user_create()
769 grpc_combiner_scheduler(resource_quota->combiner)); in grpc_resource_user_create()
827 grpc_combiner_scheduler(resource_user->resource_quota->combiner)), in grpc_resource_user_shutdown()
Dcombiner.h58 grpc_closure_scheduler* grpc_combiner_scheduler(grpc_combiner* lock);
Dcombiner.cc336 grpc_combiner_scheduler(lock)), in combiner_finally_exec()
368 grpc_closure_scheduler* grpc_combiner_scheduler(grpc_combiner* combiner) { in grpc_combiner_scheduler() function
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc530 this, grpc_combiner_scheduler(grpclb_policy()->combiner())); in BalancerCallState()
533 grpc_combiner_scheduler(grpclb_policy()->combiner())); in BalancerCallState()
536 grpc_combiner_scheduler(grpclb_policy()->combiner())); in BalancerCallState()
642 grpc_combiner_scheduler(grpclb_policy()->combiner())); in ScheduleNextClientLoadReportLocked()
708 this, grpc_combiner_scheduler(grpclb_policy()->combiner())); in SendClientLoadReportLocked()
1040 grpc_combiner_scheduler(args.combiner)); in GrpcLb()
1043 grpc_combiner_scheduler(args.combiner)); in GrpcLb()
1046 grpc_combiner_scheduler(args.combiner)); in GrpcLb()
1374 grpc_combiner_scheduler(combiner())); in StartPickingLocked()
1433 this, grpc_combiner_scheduler(combiner())); in StartBalancerCallRetryTimerLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dresolver.h98 grpc_combiner_scheduler(combiner_)), in Orphan()
Dlb_policy.h162 grpc_combiner_scheduler(combiner_)), in Orphan()
Dclient_channel.cc210 grpc_combiner_scheduler(chand->combiner)); in watch_lb_policy_locked()
421 grpc_combiner_scheduler(chand->combiner)); in create_new_lb_policy_locked()
653 op, grpc_combiner_scheduler(chand->combiner)), in cc_start_transport_op()
689 grpc_combiner_scheduler(chand->combiner)); in cc_init_channel_elem()
1426 grpc_combiner_scheduler(chand->combiner)); in do_retry()
2797 grpc_combiner_scheduler(chand->combiner)); in StartLocked()
2822 grpc_combiner_scheduler(chand->combiner))); in StartLocked()
2948 grpc_combiner_scheduler(chand->combiner)); in ResolverResultWaiter()
2952 this, grpc_combiner_scheduler(chand->combiner)); in ResolverResultWaiter()
3183 elem, grpc_combiner_scheduler(chand->combiner)), in cc_start_transport_stream_op_batch()
[all …]
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc393 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
395 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
398 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
400 t, grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
402 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
404 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
407 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
409 t, grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
412 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
415 grpc_combiner_scheduler(t->combiner)); in init_transport_closures()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver.cc261 grpc_combiner_scheduler(ev_driver->combiner)); in grpc_ares_notify_on_event_locked()
263 grpc_combiner_scheduler(ev_driver->combiner)); in grpc_ares_notify_on_event_locked()
Ddns_resolver_ares.cc157 grpc_combiner_scheduler(combiner())); in AresDnsResolver()
159 grpc_combiner_scheduler(combiner())); in AresDnsResolver()
Dgrpc_ares_ev_driver_windows.cc81 grpc_combiner_scheduler(combiner_)); in GrpcPolledFdWindows()
84 grpc_combiner_scheduler(combiner_)); in GrpcPolledFdWindows()
Dgrpc_ares_wrapper.cc670 grpc_combiner_scheduler(r->combiner)), in grpc_resolve_address_ares_impl()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/native/
Ddns_resolver.cc131 grpc_combiner_scheduler(args.combiner)); in NativeDnsResolver()
133 grpc_combiner_scheduler(args.combiner)); in NativeDnsResolver()
/external/grpc-grpc/test/cpp/naming/
Dcancel_ares_query_test.cc188 grpc_combiner_scheduler(args->lock)); in TestCancelActiveDNSQuery()
Dresolver_component_test.cc451 grpc_combiner_scheduler(args.lock)); in RunResolvesRelevantRecordsTest()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h291 this, grpc_combiner_scheduler(combiner)); in SubchannelData()