| /third_party/boost/boost/asio/ |
| D | basic_io_object.hpp | 83 return service_.get_io_context(); in get_io_context()
97 return service_.get_io_context(); in get_io_service()
107 return service_.get_io_context().get_executor(); in get_executor()
117 : service_(boost::asio::use_service<IoObjectService>(io_context)) in basic_io_object()
119 service_.construct(implementation_); in basic_io_object()
156 service_.destroy(implementation_); in ~basic_io_object()
162 return service_; in get_service()
168 return service_; in get_service()
188 service_type& service_; member in boost::asio::basic_io_object
206 return service_->get_io_context(); in get_io_context()
[all …]
|
| D | io_context_strand.hpp | 101 : service_(boost::asio::use_service< in strand()
104 service_.construct(impl_); in strand()
121 return service_.get_io_context(); in context()
161 service_.dispatch(impl_, tmp); in dispatch()
212 service_.post(impl_, tmp); in post()
259 service_.post(impl_, tmp); in defer()
306 return service_.running_in_this_thread(impl_); in running_in_this_thread()
344 self->service_.dispatch(self->impl_, handler2.value); in operator ()()
361 self->service_.post(self->impl_, handler2.value); in operator ()()
366 boost::asio::detail::strand_service& service_; member in boost::asio::io_context::strand
|
| /third_party/boost/libs/asio/include/boost/asio/ |
| D | basic_io_object.hpp | 83 return service_.get_io_context(); in get_io_context()
97 return service_.get_io_context(); in get_io_service()
107 return service_.get_io_context().get_executor(); in get_executor()
117 : service_(boost::asio::use_service<IoObjectService>(io_context)) in basic_io_object()
119 service_.construct(implementation_); in basic_io_object()
156 service_.destroy(implementation_); in ~basic_io_object()
162 return service_; in get_service()
168 return service_; in get_service()
188 service_type& service_; member in boost::asio::basic_io_object
206 return service_->get_io_context(); in get_io_context()
[all …]
|
| D | io_context_strand.hpp | 101 : service_(boost::asio::use_service< in strand()
104 service_.construct(impl_); in strand()
121 return service_.get_io_context(); in context()
161 service_.dispatch(impl_, tmp); in dispatch()
212 service_.post(impl_, tmp); in post()
259 service_.post(impl_, tmp); in defer()
306 return service_.running_in_this_thread(impl_); in running_in_this_thread()
344 self->service_.dispatch(self->impl_, handler2.value); in operator ()()
361 self->service_.post(self->impl_, handler2.value); in operator ()()
366 boost::asio::detail::strand_service& service_; member in boost::asio::io_context::strand
|
| /third_party/grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 480 for (auto& backend : backends_) backend->service_.ResetCounters(); in ResetBackendCounters()
486 client_stats += balancer->service_.WaitForLoadReport(); in WaitForLoadReports()
494 if (backends_[i]->service_.request_count() == 0) return false; in SeenAllBackends()
539 } while (backends_[backend_idx]->service_.request_count() == 0); in WaitForBackend()
627 balancers_[i]->service_.add_response(response, delay_ms); in ScheduleResponseForBalancer()
672 service_(std::forward<Args>(args)...) {} in ServerThread()
678 service_.Start(); in Start()
701 builder.RegisterService(&service_); in Serve()
709 service_.Shutdown(); in Shutdown()
718 T service_; member
[all …]
|
| D | client_lb_end2end_test.cc | 336 MyTestServiceImpl service_; member
366 builder.RegisterService(&service_); in Serve()
386 for (const auto& server : servers_) server->service_.ResetCounters(); in ResetCounters()
399 } while (servers_[server_idx]->service_.request_count() == 0); in WaitForServer()
432 if (server->service_.request_count() == 0) return false; in SeenAllServers()
443 if (servers[i]->service_.request_count() == 1) { in UpdateConnectionOrder()
498 const int request_count = servers_[i]->service_.request_count(); in TEST_F()
707 EXPECT_EQ(servers_[0]->service_.request_count(), 1); in TEST_F()
718 servers_[0]->service_.ResetCounters(); in TEST_F()
726 EXPECT_EQ(servers_[0]->service_.request_count(), 0); in TEST_F()
[all …]
|
| D | server_builder_plugin_test.cc | 48 TestServerBuilderPlugin() : service_(new TestServiceImpl()) { in TestServerBuilderPlugin()
60 si->RegisterService(service_); in InitServer()
72 return service_->has_async_methods(); in has_async_methods()
79 return service_->has_synchronous_methods(); in has_sync_methods()
95 std::shared_ptr<TestServiceImpl> service_; member in grpc::testing::TestServerBuilderPlugin
211 TestServiceImpl service_; member in grpc::testing::ServerBuilderPluginTest
|
| D | server_crash_test.cc | 108 builder.RegisterService(&service_); in CreateServerAndClient()
114 bool HadOneBidiStream() { return service_.bidi_stream_count() == 1; } in HadOneBidiStream()
116 bool HadOneResponseStream() { return service_.response_stream_count() == 1; } in HadOneResponseStream()
120 ServiceImpl service_; member in grpc::testing::__anon11d024890111::CrashTest
|
| D | nonblocking_test.cc | 112 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
113 builder.RegisterService(service_.get()); in BuildAndStartServer()
143 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
178 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_; member in grpc::testing::__anon8ea606960211::NonblockingTest
|
| D | thread_stress_test.cc | 146 this->SetUpStart(&builder, &service_); in SetUp()
155 TestServiceImpl service_; member in grpc::testing::CommonStressTestSyncServer
164 this->SetUpStart(&builder, &service_); in SetUp()
175 TestServiceImpl service_; member in grpc::testing::CommonStressTestSyncServerLowThreadCount
185 this->SetUpStart(&builder, &service_); in SetUp()
246 service_.RequestEcho(contexts_[i].srv_ctx.get(), in RefreshContext()
260 ::grpc::testing::EchoTestService::AsyncService service_;
|
| D | shutdown_test.cc | 63 ShutdownTest() : shutdown_(false), service_(&ev_) { gpr_event_init(&ev_); } in ShutdownTest()
77 builder.RegisterService(&service_); in SetUpServer()
116 TestServiceImpl service_; member in grpc::testing::ShutdownTest
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | io_object_impl.hpp | 48 : service_(&boost::asio::use_service<IoObjectService>( in io_object_impl()
52 service_->construct(implementation_); in io_object_impl()
58 : service_(&boost::asio::use_service<IoObjectService>(context)), in io_object_impl()
61 service_->construct(implementation_); in io_object_impl()
67 : service_(&other.get_service()), in io_object_impl()
70 service_->move_construct(implementation_, other.implementation_); in io_object_impl()
76 : service_(&boost::asio::use_service<IoObjectService>( in io_object_impl()
80 service_->converting_move_construct(implementation_, in io_object_impl()
88 service_->destroy(implementation_); in ~io_object_impl()
97 service_->move_assign(implementation_, in operator =()
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | io_object_impl.hpp | 48 : service_(&boost::asio::use_service<IoObjectService>( in io_object_impl()
52 service_->construct(implementation_); in io_object_impl()
58 : service_(&boost::asio::use_service<IoObjectService>(context)), in io_object_impl()
61 service_->construct(implementation_); in io_object_impl()
67 : service_(&other.get_service()), in io_object_impl()
70 service_->move_construct(implementation_, other.implementation_); in io_object_impl()
76 : service_(&boost::asio::use_service<IoObjectService>( in io_object_impl()
80 service_->converting_move_construct(implementation_, in io_object_impl()
88 service_->destroy(implementation_); in ~io_object_impl()
97 service_->move_assign(implementation_, in operator =()
[all …]
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporting_service_server_builder_plugin.cc | 29 if (service_ != nullptr) { in has_sync_methods()
30 return service_->has_synchronous_methods(); in has_sync_methods()
36 if (service_ != nullptr) { in has_async_methods()
37 return service_->has_async_methods(); in has_async_methods()
45 service_ = std::make_shared<LoadReporterAsyncServiceImpl>(std::move(cq)); in UpdateServerBuilder()
50 si->RegisterService(service_); in InitServer()
55 service_->StartThread(); in Finish()
56 service_.reset(); in Finish()
|
| D | load_reporter_async_service_impl.cc | 147 service_(service), in ReportLoadHandler()
170 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
172 grpc_core::ReleasableMutexLock lock(&service_->cq_shutdown_mu_); in OnRequestDelivered()
173 if (service_->shutdown_) { in OnRequestDelivered()
189 service_, lb_id_.c_str(), this); in OnRequestDelivered()
200 service_, lb_id_.c_str(), this, static_cast<int>(done_notified_), in OnReadDone()
225 service_, load_balanced_hostname_.c_str(), in OnReadDone()
230 grpc_core::ReleasableMutexLock lock(&service_->cq_shutdown_mu_); in OnReadDone()
231 if (service_->shutdown_) { in OnReadDone()
247 service_, lb_id_.c_str(), this); in OnReadDone()
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/services/ |
| D | basic_logger.hpp | 43 : service_(boost::asio::use_service<Service>(context)), in basic_logger()
44 impl_(service_.null()) in basic_logger()
46 service_.create(impl_, identifier); in basic_logger()
52 service_.destroy(impl_); in ~basic_logger()
58 service_.use_file(impl_, file); in use_file()
64 service_.log(impl_, message); in log()
69 service_type& service_; member in services::basic_logger
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/services/ |
| D | basic_logger.hpp | 43 : service_(boost::asio::use_service<Service>(context)), in basic_logger()
44 impl_(service_.null()) in basic_logger()
46 service_.create(impl_, identifier); in basic_logger()
52 service_.destroy(impl_); in ~basic_logger()
58 service_.use_file(impl_, file); in use_file()
64 service_.log(impl_, message); in log()
69 service_type& service_; member in services::basic_logger
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 60 builder.RegisterService(&service_); in Run()
80 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) { in CallData()
95 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
101 new CallData(service_, cq_); in Proceed()
122 Greeter::AsyncService* service_; member in ServerImpl::CallData
146 new CallData(&service_, cq_.get()); in HandleRpcs()
162 Greeter::AsyncService service_; member in ServerImpl
|
| /third_party/grpc/src/cpp/server/health/ |
| D | default_health_check_service.cc | 291 : cq_(cq), database_(database), service_(service), writer_(&ctx_) {} in CheckCallHandler()
301 CreateAndStart(cq_, database_, service_); in OnCallReceived()
303 gpr_log(GPR_DEBUG, "[HCS %p] Health check started for handler %p", service_, in OnCallReceived()
308 if (!service_->DecodeRequest(request_, &service_name)) { in OnCallReceived()
314 } else if (!service_->EncodeResponse(serving_status, &response)) { in OnCallReceived()
320 grpc_core::MutexLock lock(&service_->cq_shutdown_mu_); in OnCallReceived()
321 if (!service_->shutdown_) { in OnCallReceived()
339 service_, this); in OnFinishDone()
379 : cq_(cq), database_(database), service_(service), stream_(&ctx_) {} in WatchCallHandler()
395 CreateAndStart(cq_, database_, service_); in OnCallReceived()
[all …]
|
| /third_party/grpc/src/compiler/ |
| D | protobuf_plugin.h | 108 : service_(service) {} in ProtoBufService()
110 std::string name() const { return service_->name(); } in name()
112 int method_count() const { return service_->method_count(); } in method_count()
115 new ProtoBufMethod(service_->method(i))); in method()
119 return GetCommentsHelper(service_, true, prefix); in GetLeadingComments()
123 return GetCommentsHelper(service_, false, prefix); in GetTrailingComments()
127 return grpc_python_generator::get_all_comments(service_); in GetAllComments()
131 const grpc::protobuf::ServiceDescriptor* service_;
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | method_handler.h | 105 : func_(func), service_(service) {} in RpcMethodHandler()
112 return func_(service_, in RunHandler()
136 ServiceType* service_; variable
148 : func_(func), service_(service) {} in ClientStreamingHandler()
156 return func_(service_, in RunHandler()
184 ServiceType* service_; variable
196 : func_(func), service_(service) {} in ServerStreamingHandler()
205 return func_(service_, in RunHandler()
251 ServiceType* service_; variable
|
| D | service_type.h | 105 explicit experimental_type(Service* service) : service_(service) {} in experimental_type()
108 service_->MarkMethodCallbackInternal(index, handler); in MarkMethodCallback()
112 service_->MarkMethodRawCallbackInternal(index, handler); in MarkMethodRawCallback()
116 return service_->GetHandlerInternal(index); in GetHandler()
120 Service* service_;
|
| /third_party/flatbuffers/src/ |
| D | idl_gen_grpc.cpp | 114 FlatBufService(const ServiceDef *service) : service_(service) {} in FlatBufService()
121 return service_->doc_comment; in GetAllComments()
125 return service_->defined_namespace->components; in namespace_parts()
128 std::string name() const { return service_->name; } in name()
130 return service_->Definition::attributes.Lookup("private") ? true : false; in is_internal()
134 return static_cast<int>(service_->calls.vec.size()); in method_count()
139 new FlatBufMethod(service_->calls.vec[i])); in method()
143 const ServiceDef *service_; member in flatbuffers::FlatBufService
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | strand_executor_service.ipp | 78 new_impl->service_ = this;
85 boost::asio::detail::mutex::scoped_lock lock(service_->mutex_);
88 if (service_->impl_list_ == this)
89 service_->impl_list_ = next_;
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | strand_executor_service.ipp | 78 new_impl->service_ = this;
85 boost::asio::detail::mutex::scoped_lock lock(service_->mutex_);
88 if (service_->impl_list_ == this)
89 service_->impl_list_ = next_;
|