| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/resolver/fake/ |
| H A D | fake_resolver.cc | 92 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in FakeResolver()
124 work_serializer()->Run([this]() { ReturnReresolutionResult(); }, in RequestReresolutionLocked()
239 resolver->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetResponse()
253 resolver->work_serializer()->Run( in SetReresolutionResponse()
266 resolver->work_serializer()->Run( in UnsetReresolutionResponse()
279 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailure()
293 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailureOnReresolution()
305 resolver_->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetFakeResolver()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/resolver/fake/ |
| H A D | fake_resolver.cc | 92 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in FakeResolver()
124 work_serializer()->Run([this]() { ReturnReresolutionResult(); }, in RequestReresolutionLocked()
239 resolver->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetResponse()
253 resolver->work_serializer()->Run( in SetReresolutionResponse()
266 resolver->work_serializer()->Run( in UnsetReresolutionResponse()
279 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailure()
293 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailureOnReresolution()
305 resolver_->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetFakeResolver()
|
| /dports/devel/grpc134/grpc-1.34.1/test/core/client_channel/resolvers/ |
| H A D | dns_resolver_test.cc | 47 args.work_serializer = *g_work_serializer; in test_succeeds()
64 args.work_serializer = *g_work_serializer; in test_fails()
76 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
77 g_work_serializer = &work_serializer; in main()
|
| H A D | sockaddr_resolver_test.cc | 49 args.work_serializer = *g_work_serializer; in test_succeeds()
70 args.work_serializer = *g_work_serializer; in test_fails()
82 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
83 g_work_serializer = &work_serializer; in main()
|
| H A D | fake_resolver_test.cc | 69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in build_fake_resolver() argument
80 args.work_serializer = std::move(work_serializer); in build_fake_resolver()
111 std::shared_ptr<grpc_core::WorkSerializer> work_serializer = in test_fake_resolver() local
119 work_serializer, response_generator.get(), in test_fake_resolver()
|
| H A D | dns_resolver_cooldown_test.cc | 48 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
100 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in test_dns_lookup_ares_locked() argument
104 std::move(work_serializer)); in test_dns_lookup_ares_locked()
289 args.work_serializer = *g_work_serializer; in start_test_under_work_serializer()
325 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
326 g_work_serializer = &work_serializer; in main()
|
| /dports/devel/grpc130/grpc-1.30.2/test/core/client_channel/resolvers/ |
| H A D | dns_resolver_test.cc | 47 args.work_serializer = *g_work_serializer; in test_succeeds()
64 args.work_serializer = *g_work_serializer; in test_fails()
76 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
77 g_work_serializer = &work_serializer; in main()
|
| H A D | sockaddr_resolver_test.cc | 49 args.work_serializer = *g_work_serializer; in test_succeeds()
70 args.work_serializer = *g_work_serializer; in test_fails()
82 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
83 g_work_serializer = &work_serializer; in main()
|
| H A D | fake_resolver_test.cc | 66 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in build_fake_resolver() argument
77 args.work_serializer = std::move(work_serializer); in build_fake_resolver()
110 std::shared_ptr<grpc_core::WorkSerializer> work_serializer = in test_fake_resolver() local
118 work_serializer, response_generator.get(), in test_fake_resolver()
|
| H A D | dns_resolver_cooldown_test.cc | 48 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
100 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in test_dns_lookup_ares_locked() argument
104 std::move(work_serializer)); in test_dns_lookup_ares_locked()
289 args.work_serializer = *g_work_serializer; in start_test_under_work_serializer()
325 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
326 g_work_serializer = &work_serializer; in main()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver.cc | 69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
148 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
166 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
174 grpc_core::NewGrpcPolledFdFactory((*ev_driver)->work_serializer); in grpc_ares_ev_driver_create_locked()
237 driver->work_serializer->Run( in on_timeout()
256 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
334 fdn->ev_driver->work_serializer->Run( in on_readable()
364 fdn->ev_driver->work_serializer->Run( in on_writable()
390 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
|
| H A D | grpc_ares_ev_driver_libuv.cc | 45 std::shared_ptr<WorkSerializer> work_serializer) in GrpcPolledFdLibuv() argument
46 : as_(as), work_serializer_(std::move(work_serializer)) { in GrpcPolledFdLibuv()
163 std::shared_ptr<WorkSerializer> work_serializer) override { in NewGrpcPolledFdLocked() argument
164 return new GrpcPolledFdLibuv(as, std::move(work_serializer)); in NewGrpcPolledFdLocked()
171 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
|
| H A D | grpc_ares_ev_driver.h | 46 std::shared_ptr<grpc_core::WorkSerializer> work_serializer,
93 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
99 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_ev_driver.cc | 71 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
150 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
167 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
175 grpc_core::NewGrpcPolledFdFactory((*ev_driver)->work_serializer); in grpc_ares_ev_driver_create_locked()
238 driver->work_serializer->Run( in on_timeout()
257 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
335 fdn->ev_driver->work_serializer->Run( in on_readable()
365 fdn->ev_driver->work_serializer->Run( in on_writable()
391 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
|
| H A D | grpc_ares_ev_driver_libuv.cc | 47 std::shared_ptr<WorkSerializer> work_serializer) in GrpcPolledFdLibuv() argument
50 work_serializer_(std::move(work_serializer)) { in GrpcPolledFdLibuv()
165 std::shared_ptr<WorkSerializer> work_serializer) override { in NewGrpcPolledFdLocked() argument
166 return new GrpcPolledFdLibuv(as, std::move(work_serializer)); in NewGrpcPolledFdLocked()
173 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
|
| H A D | grpc_ares_ev_driver.h | 46 std::shared_ptr<grpc_core::WorkSerializer> work_serializer,
93 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
99 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| /dports/devel/grpc/grpc-1.42.0/test/core/client_channel/resolvers/ |
| H A D | dns_resolver_test.cc | 50 args.work_serializer = *g_work_serializer; in test_succeeds()
69 args.work_serializer = *g_work_serializer; in test_fails()
80 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
81 g_work_serializer = &work_serializer; in main()
|
| H A D | sockaddr_resolver_test.cc | 53 args.work_serializer = *g_work_serializer; in test_succeeds()
76 args.work_serializer = *g_work_serializer; in test_fails()
87 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
88 g_work_serializer = &work_serializer; in main()
|
| H A D | fake_resolver_test.cc | 69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in build_fake_resolver() argument
80 args.work_serializer = std::move(work_serializer); in build_fake_resolver()
111 std::shared_ptr<grpc_core::WorkSerializer> work_serializer = in test_fake_resolver() local
119 work_serializer, response_generator.get(), in test_fake_resolver()
|
| H A D | dns_resolver_cooldown_test.cc | 46 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
105 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in test_dns_lookup_ares_locked() argument
109 std::move(work_serializer)); in test_dns_lookup_ares_locked()
306 args.work_serializer = *g_work_serializer; in start_test_under_work_serializer()
341 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
342 g_work_serializer = &work_serializer; in main()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_wrapper.cc | 90 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
264 driver->work_serializer->Run( in on_timeout()
276 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
359 fdn->ev_driver->work_serializer->Run( in on_readable()
389 fdn->ev_driver->work_serializer->Run( in on_writable()
505 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
520 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
810 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
1070 std::move(work_serializer)); in grpc_dns_lookup_ares_locked_impl()
1118 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
[all …]
|
| H A D | grpc_ares_ev_driver.h | 63 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_wrapper.cc | 90 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
264 driver->work_serializer->Run( in on_timeout()
276 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
359 fdn->ev_driver->work_serializer->Run( in on_readable()
389 fdn->ev_driver->work_serializer->Run( in on_writable()
505 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
520 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
810 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
1070 std::move(work_serializer)); in grpc_dns_lookup_ares_locked_impl()
1118 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
[all …]
|
| H A D | grpc_ares_ev_driver.h | 63 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| H A D | grpc_ares_wrapper.cc | 90 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
264 driver->work_serializer->Run( in on_timeout()
276 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
359 fdn->ev_driver->work_serializer->Run( in on_readable()
389 fdn->ev_driver->work_serializer->Run( in on_writable()
505 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
520 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
810 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
1070 std::move(work_serializer)); in grpc_dns_lookup_ares_locked_impl()
1118 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
[all …]
|