Home
last modified time | relevance | path

Searched full:work_serializer (Results 1 – 25 of 79) sorted by relevance

1234

/third_party/grpc/src/core/util/
Dwork_serializer.cc17 #include "src/core/util/work_serializer.h"
137 GRPC_TRACE_LOG(work_serializer, INFO) in Run()
149 GRPC_TRACE_LOG(work_serializer, INFO) << " Executing immediately"; in Run()
162 GRPC_TRACE_LOG(work_serializer, INFO) in Run()
172 GRPC_TRACE_LOG(work_serializer, INFO) in Schedule()
180 GRPC_TRACE_LOG(work_serializer, INFO) << "WorkSerializer::Orphan() " << this; in Orphan()
184 GRPC_TRACE_LOG(work_serializer, INFO) << " Destroying"; in Orphan()
192 GRPC_TRACE_LOG(work_serializer, INFO) in DrainQueue()
212 GRPC_TRACE_LOG(work_serializer, INFO) in DrainQueueOwned()
219 GRPC_TRACE_LOG(work_serializer, INFO) << " Queue Drained. Destroying"; in DrainQueueOwned()
[all …]
Dwork_serializer.h76 // work_serializer.Run(
77 // []() ABSL_EXCLUSIVE_LOCKS_REQUIRED(work_serializer) {
81 // void callback() ABSL_EXCLUSIVE_LOCKS_REQUIRED(work_serializer) { ... }
/third_party/grpc/test/core/ext/filters/event_engine_client_channel_resolver/
Dresolver_fuzzer.cc41 #include "src/core/util/work_serializer.h"
242 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in ConstructResolverArgs() argument
249 resolver_args.work_serializer = std::move(work_serializer); in ConstructResolverArgs()
272 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(engine); in DEFINE_PROTO_FUZZER() local
278 &done_resolving, work_serializer); in DEFINE_PROTO_FUZZER()
280 work_serializer->Run( in DEFINE_PROTO_FUZZER()
282 *work_serializer) { resolver_ptr->StartLocked(); }, in DEFINE_PROTO_FUZZER()
/third_party/grpc/test/core/resolver/
Ddns_resolver_test.cc38 #include "src/core/util/work_serializer.h"
60 args.work_serializer = *g_work_serializer; in test_succeeds()
79 args.work_serializer = *g_work_serializer; in test_fails()
88 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>( in TEST() local
90 g_work_serializer = &work_serializer; in TEST()
Dsockaddr_resolver_test.cc36 #include "src/core/util/work_serializer.h"
58 args.work_serializer = *g_work_serializer; in test_succeeds()
81 args.work_serializer = *g_work_serializer; in test_fails()
89 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>( in TEST() local
91 g_work_serializer = &work_serializer; in TEST()
Dfake_resolver_test.cc51 #include "src/core/util/work_serializer.h"
90 std::shared_ptr<WorkSerializer> work_serializer, in BuildFakeResolver() argument
98 args.work_serializer = std::move(work_serializer); in BuildFakeResolver()
/third_party/grpc/src/core/load_balancing/
Dhealth_check_client.h26 #include "src/core/util/work_serializer.h"
41 // work_serializer(), channel_args,
46 std::shared_ptr<WorkSerializer> work_serializer, const ChannelArgs& args,
Dendpoint_list.h40 #include "src/core/util/work_serializer.h"
66 policy<MyLbPolicy>()->work_serializer(), errors);
75 std::shared_ptr<WorkSerializer> work_serializer,
78 absl::Status status = Init(addresses, args, std::move(work_serializer));
130 std::shared_ptr<WorkSerializer> work_serializer);
Dhealth_check_client_internal.h43 #include "src/core/util/work_serializer.h"
159 std::shared_ptr<WorkSerializer> work_serializer, in HealthWatcher() argument
163 : work_serializer_(std::move(work_serializer)), in HealthWatcher()
Dendpoint_list.cc91 std::shared_ptr<WorkSerializer> work_serializer) { in Init() argument
96 lb_policy_args.work_serializer = std::move(work_serializer); in Init()
Dlb_policy.cc39 work_serializer_(std::move(args.work_serializer)), in LoadBalancingPolicy()
82 parent->work_serializer()->Run( in Pick()
Dlb_policy.h53 #include "src/core/util/work_serializer.h"
90 /// work_serializer passed to the constructor.
382 /// The work_serializer under which all LB policy calls will be run.
383 std::shared_ptr<WorkSerializer> work_serializer; member
434 // Note: This must be invoked while holding the work_serializer.
481 std::shared_ptr<WorkSerializer> work_serializer() const { in work_serializer() function
Dhealth_check_client.cc59 #include "src/core/util/work_serializer.h"
72 std::shared_ptr<WorkSerializer> work_serializer) in AsyncWorkSerializerDrainer() argument
73 : work_serializer_(std::move(work_serializer)) { in AsyncWorkSerializerDrainer()
483 std::shared_ptr<WorkSerializer> work_serializer, const ChannelArgs& args, in MakeHealthCheckWatcher() argument
494 return std::make_unique<HealthWatcher>(std::move(work_serializer), in MakeHealthCheckWatcher()
/third_party/grpc/src/core/resolver/
Dresolver_registry.h87 /// \a args, \a pollset_set, and \a work_serializer are passed to the
90 /// name resolution process. \a work_serializer is the work_serializer under
96 std::shared_ptr<WorkSerializer> work_serializer,
Dresolver_registry.cc89 std::shared_ptr<WorkSerializer> work_serializer, in CreateResolver() argument
98 resolver_args.work_serializer = std::move(work_serializer); in CreateResolver()
Dresolver_factory.h46 /// The work_serializer under which all resolver calls will be run.
47 std::shared_ptr<WorkSerializer> work_serializer; member
Dpolling_resolver.h36 #include "src/core/util/work_serializer.h"
70 WorkSerializer* work_serializer() { return work_serializer_.get(); } in work_serializer() function
Dresolver.h48 /// work_serializer passed to the constructor.
118 // Note: This must be invoked while holding the work_serializer.
/third_party/grpc/src/core/lib/transport/
Dconnectivity_state.h33 #include "src/core/util/work_serializer.h"
73 // If \a work_serializer is nullptr, then the notification will be scheduled
76 std::shared_ptr<WorkSerializer> work_serializer = nullptr)
77 : work_serializer_(std::move(work_serializer)) {} in work_serializer_() argument
Dconnectivity_state.cc58 const std::shared_ptr<WorkSerializer>& work_serializer) in Notifier() argument
60 if (work_serializer != nullptr) { in Notifier()
61 work_serializer->Run( in Notifier()
/third_party/grpc/test/core/client_channel/
Dbm_client_channel.cc118 std::shared_ptr<WorkSerializer> work_serializer) in TestResolver() argument
121 work_serializer_(std::move(work_serializer)) {} in TestResolver()
154 std::move(args.work_serializer)); in CreateResolver()
/third_party/grpc/tools/run_tests/sanity/
Dcpp_banned_constructs.sh29 grep -Ev 'include/grpcpp/impl/sync.h|src/core/util/work_serializer.cc' | \
39 grep -Ev 'include/grpcpp/impl/sync.h|src/core/util/work_serializer.cc' | \
/third_party/grpc/test/cpp/interop/
Drpc_behavior_lb_policy.cc71 delegate_args.work_serializer = work_serializer(); in RpcBehaviorLbPolicy()
/third_party/grpc/src/core/load_balancing/round_robin/
Dround_robin.cc50 #include "src/core/util/work_serializer.h"
83 policy<RoundRobin>()->work_serializer(), errors); in RoundRobinEndpointList()
93 std::shared_ptr<WorkSerializer> work_serializer, in RoundRobinEndpoint() argument
96 absl::Status status = Init(addresses, args, std::move(work_serializer)); in RoundRobinEndpoint()
/third_party/grpc/src/core/load_balancing/grpclb/
Dgrpclb.cc143 #include "src/core/util/work_serializer.h"
332 lb_policy_->work_serializer()->Run( in Orphaned()
404 // plane work_serializer.
485 : AsyncConnectivityStateWatcherInterface(parent->work_serializer()), in StateWatcher()
1026 grpclb_policy()->work_serializer()->Run( in ScheduleNextClientLoadReportLocked()
1099 lb_calld->grpclb_policy()->work_serializer()->Run( in ClientLoadReportDone()
1118 lb_calld->grpclb_policy()->work_serializer()->Run( in OnInitialRequestSent()
1137 lb_calld->grpclb_policy()->work_serializer()->Run( in OnBalancerMessageReceived()
1295 lb_calld->grpclb_policy()->work_serializer()->Run( in OnBalancerStatusReceived()
1566 self_ptr->work_serializer()->Run( in UpdateLocked()
[all …]

1234