| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 573 : type_(type), service_(service) { in ServerThread()
598 builder.RegisterService(service_); in Start()
613 T* service_; member
654 backend_servers_[i].service_->request_count()); in TEST_F()
658 EXPECT_EQ(1U, balancer_servers_[0].service_->request_count()); in TEST_F()
660 EXPECT_EQ(1U, balancer_servers_[0].service_->response_count()); in TEST_F()
683 backend_servers_[i].service_->request_count()); in TEST_F()
687 EXPECT_EQ(1U, balancer_servers_[0].service_->request_count()); in TEST_F()
689 EXPECT_EQ(1U, balancer_servers_[0].service_->response_count()); in TEST_F()
732 EXPECT_EQ(1U, balancer_servers_[0].service_->request_count()); in TEST_F()
[all …]
|
| D | client_lb_end2end_test.cc | 252 MyTestServiceImpl service_; member
279 builder.RegisterService(&service_); in Serve()
293 for (const auto& server : servers_) server->service_.ResetCounters(); in ResetCounters()
306 } while (servers_[server_idx]->service_.request_count() == 0); in WaitForServer()
323 if (server->service_.request_count() == 0) return false; in SeenAllServers()
334 if (servers[i]->service_.request_count() == 1) { in UpdateConnectionOrder()
371 const int request_count = servers_[i]->service_.request_count(); in TEST_F()
499 EXPECT_EQ(servers_[0]->service_.request_count(), 1); in TEST_F()
510 servers_[0]->service_.ResetCounters(); in TEST_F()
518 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
216 TestServiceImpl service_; member in grpc::testing::ServerBuilderPluginTest
|
| D | server_crash_test.cc | 107 builder.RegisterService(&service_); in CreateServerAndClient()
113 bool HadOneBidiStream() { return service_.bidi_stream_count() == 1; } in HadOneBidiStream()
115 bool HadOneResponseStream() { return service_.response_stream_count() == 1; } in HadOneResponseStream()
119 ServiceImpl service_; member in grpc::testing::__anon96d95d380111::CrashTest
|
| D | nonblocking_test.cc | 102 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
103 builder.RegisterService(service_.get()); in BuildAndStartServer()
133 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
168 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_; member in grpc::testing::__anone80365650211::NonblockingTest
|
| D | thread_stress_test.cc | 139 this->SetUpStart(&builder, &service_); in SetUp()
148 TestServiceImpl service_; member in grpc::testing::CommonStressTestSyncServer
157 this->SetUpStart(&builder, &service_); in SetUp()
168 TestServiceImpl service_; member in grpc::testing::CommonStressTestSyncServerLowThreadCount
178 this->SetUpStart(&builder, &service_); in SetUp()
239 service_.RequestEcho(contexts_[i].srv_ctx.get(), in RefreshContext()
253 ::grpc::testing::EchoTestService::AsyncService service_;
|
| D | async_end2end_test.cc | 277 service_.reset(new grpc::testing::EchoTestService::AsyncService()); in BuildAndStartServer()
278 builder.RegisterService(service_.get()); in BuildAndStartServer()
319 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
339 std::unique_ptr<grpc::testing::EchoTestService::AsyncService> service_; member in grpc::testing::__anon60ba754e0111::AsyncEnd2endTest
436 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
479 service_->RequestEcho(&srv_ctx, &recv_request, resp_writer_ptr, cq_.get(), in TEST_P()
515 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
562 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
611 service_->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, in TEST_P()
655 service_->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, in TEST_P()
[all …]
|
| 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
|
| D | exception_test.cc | 68 builder.RegisterService(&service_); in SetUp()
82 ExceptingServiceImpl service_; member in grpc::testing::ExceptionTest
|
| /external/parameter-framework/asio-1.10.6/include/asio/ |
| D | basic_io_object.hpp | 146 return service_->get_io_service(); in get_io_service()
151 : service_(&asio::use_service<IoObjectService>(io_service)) in basic_io_object()
153 service_->construct(implementation); in basic_io_object()
157 : service_(&other.get_service()) in basic_io_object()
159 service_->move_construct(implementation, other.implementation); in basic_io_object()
164 service_->destroy(implementation); in ~basic_io_object()
169 service_->move_assign(implementation, in operator =()
170 *other.service_, other.implementation); in operator =()
171 service_ = other.service_; in operator =()
177 return *service_; in get_service()
[all …]
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/reflection/v1alpha/ |
| D | ListServiceResponse.java | 23 service_ = java.util.Collections.emptyList(); in ListServiceResponse()
59 service_ = new java.util.ArrayList<io.grpc.reflection.v1alpha.ServiceResponse>(); in ListServiceResponse()
62 service_.add( in ListServiceResponse()
75 service_ = java.util.Collections.unmodifiableList(service_); in ListServiceResponse()
94 private java.util.List<io.grpc.reflection.v1alpha.ServiceResponse> service_; field in ListServiceResponse
104 return service_; in getServiceList()
116 return service_; in getServiceOrBuilderList()
127 return service_.size(); in getServiceCount()
138 return service_.get(index); in getService()
150 return service_.get(index); in getServiceOrBuilder()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_service.cc | 25 TF_ASSIGN_OR_RETURN(grpc_service->service_, in NewService()
39 [this, arg, result]() { return service_->Unregister(arg, result); }); in Unregister()
46 return service_->DeconstructTuple(arg, result); in DeconstructTuple()
54 return service_->GetDeviceHandles(arg, result); in GetDeviceHandles()
62 [this, arg, result]() { return service_->Compile(arg, result); }); in Compile()
69 [this, arg, result]() { return service_->Execute(arg, result); }); in Execute()
76 return service_->ExecuteGraphParallel(arg, result); in ExecuteGraphParallel()
84 return service_->WaitForExecution(arg, result); in WaitForExecution()
92 return service_->TransferToClient(arg, result); in TransferToClient()
100 return service_->TransferToServer(arg, result); in TransferToServer()
[all …]
|
| /external/grpc-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 | 142 service_(service), in ReportLoadHandler()
165 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
167 std::unique_lock<std::mutex> lock(service_->cq_shutdown_mu_); in OnRequestDelivered()
168 if (service_->shutdown_) { in OnRequestDelivered()
184 service_, lb_id_.c_str(), this); in OnRequestDelivered()
195 service_, lb_id_.c_str(), this, static_cast<int>(done_notified_), in OnReadDone()
220 service_, load_balanced_hostname_.c_str(), load_report_interval_ms_, in OnReadDone()
225 std::unique_lock<std::mutex> lock(service_->cq_shutdown_mu_); in OnReadDone()
226 if (service_->shutdown_) { in OnReadDone()
242 service_, lb_id_.c_str(), this); in OnReadDone()
[all …]
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/health/v1/ |
| D | HealthCheckRequest.java | 19 service_ = ""; in HealthCheckRequest()
56 service_ = s; in HealthCheckRequest()
84 private volatile java.lang.Object service_; field in HealthCheckRequest
89 java.lang.Object ref = service_; in getService()
96 service_ = s; in getService()
105 java.lang.Object ref = service_; in getServiceBytes()
110 service_ = b; in getServiceBytes()
130 com.google.protobuf.GeneratedMessageV3.writeString(output, 1, service_); in writeTo()
141 size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, service_); in getSerializedSize()
303 service_ = ""; in clear()
[all …]
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 56 builder.RegisterService(&service_); in Run()
76 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) { in CallData()
91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
97 new CallData(service_, cq_); in Proceed()
118 Greeter::AsyncService* service_; member in ServerImpl::CallData
142 new CallData(&service_, cq_.get()); in HandleRpcs()
158 Greeter::AsyncService service_; member in ServerImpl
|
| /external/grpc-grpc/src/compiler/ |
| D | protobuf_plugin.h | 107 : service_(service) {} in ProtoBufService()
109 grpc::string name() const { return service_->name(); } in name()
111 int method_count() const { return service_->method_count(); }; in method_count()
114 new ProtoBufMethod(service_->method(i))); in method()
118 return GetCommentsHelper(service_, true, prefix); in GetLeadingComments()
122 return GetCommentsHelper(service_, false, prefix); in GetTrailingComments()
126 return grpc_python_generator::get_all_comments(service_); in GetAllComments()
130 const grpc::protobuf::ServiceDescriptor* service_;
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | method_handler_impl.h | 59 : func_(func), service_(service) {} in RpcMethodHandler()
68 return func_(service_, param.server_context, &req, &rsp); in RunHandler()
95 ServiceType* service_; variable
107 : func_(func), service_(service) {} in ClientStreamingHandler()
113 return func_(service_, param.server_context, &reader, &rsp); in RunHandler()
138 ServiceType* service_; variable
150 : func_(func), service_(service) {} in ServerStreamingHandler()
160 return func_(service_, param.server_context, &req, &writer); in RunHandler()
184 ServiceType* service_; variable
|
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck/ |
| D | Health.cs | 73 service_ = other.service_; in HealthCheckRequest()
84 private string service_ = ""; field in Grpc.Health.V1.HealthCheckRequest
87 get { return service_; }
89 service_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
|
| /external/flatbuffers/src/ |
| D | idl_gen_grpc.cpp | 102 FlatBufService(const ServiceDef *service) : service_(service) {} in FlatBufService()
109 return service_->doc_comment; in GetAllComments()
112 std::string name() const { return service_->name; } in name()
115 return static_cast<int>(service_->calls.vec.size()); in method_count()
120 new FlatBufMethod(service_->calls.vec[i])); in method()
124 const ServiceDef *service_; member in flatbuffers::FlatBufService
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | bindings_perftest.cc | 56 test::PingServicePtr service_; member in mojo::__anona92d06af0111::PingPongTest
66 : service_(std::move(service)) {} in PingPongTest()
74 service_->Ping(base::Bind(&PingPongTest::OnPingDone, base::Unretained(this))); in Run()
85 service_->Ping(base::Bind(&PingPongTest::OnPingDone, base::Unretained(this))); in OnPingDone()
|
| D | e2e_perftest.cc | 61 test::EchoServicePtr service_; member in mojo::__anonbc74313d0111::PingPongTest
75 : service_(std::move(service)), in PingPongTest()
104 service_->Echo(message_, ping_done_callback_); in DoPing()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.cc | 31 server_builder->RegisterService(&service_); in GrpcEagerServiceImpl()
41 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop()
|
| D | grpc_eager_service_impl.h | 55 EnqueueRequest(&service_, cq_.get(), \
74 tensorflow::eager::grpc::EagerService::AsyncService service_; variable
|
| /external/perfetto/src/tracing/core/ |
| D | tracing_service_impl.cc | 2283 service_(service), in ConsumerEndpointImpl()
2289 service_->DisconnectConsumer(this); in ~ConsumerEndpointImpl()
2306 if (!service_->EnableTracing(this, cfg, std::move(fd))) in EnableTracing()
2318 service_->ChangeTraceConfig(this, cfg); in ChangeTraceConfig()
2327 service_->StartTracing(tracing_session_id_); in StartTracing()
2336 service_->DisableTracing(tracing_session_id_); in DisableTracing()
2345 service_->ReadBuffers(tracing_session_id_, this); in ReadBuffers()
2354 service_->FreeBuffers(tracing_session_id_); in FreeBuffers()
2365 service_->Flush(tracing_session_id_, timeout_ms, callback); in Flush()
2370 bool success = service_->DetachConsumer(this, key); in Detach()
[all …]
|