Home
last modified time | relevance | path

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

/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporting_service_server_builder_plugin.cc44 auto cq = builder->AddCompletionQueue(); in UpdateServerBuilder()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc32 cq_ = server_builder->AddCompletionQueue(); in GrpcEagerServiceImpl()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_fixtures.h82 cq_ = b.AddCompletionQueue(true); in FullstackFixture()
179 cq_ = b.AddCompletionQueue(true); in EndpointPairFixture()
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc59 cq_ = builder.AddCompletionQueue(); in Run()
DREADME.md211 auto cq = builder.AddCompletionQueue();
/external/grpc-grpc/test/cpp/server/
Dserver_request_call_test.cc51 auto cq = builder.AddCompletionQueue(); in TEST()
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service.cc32 cq_ = builder->AddCompletionQueue().release(); in GrpcVerbsService()
/external/grpc-grpc/include/grpcpp/
Dserver_builder.h125 std::unique_ptr<ServerCompletionQueue> AddCompletionQueue(
/external/grpc-grpc/test/cpp/end2end/
Dnonblocking_test.cc104 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
Dserver_builder_plugin_test.cc180 cq_ = builder_->AddCompletionQueue(); in StartServer()
Dhealth_service_end2end_test.cc147 cq_ = builder.AddCompletionQueue(); in SetUpServer()
Dfilter_end2end_test.cc132 srv_cq_ = builder.AddCompletionQueue(); in SetUp()
Dgeneric_end2end_test.cc75 srv_cq_ = builder.AddCompletionQueue(); in SetUp()
Dthread_stress_test.cc179 cq_ = builder.AddCompletionQueue(); in SetUp()
Draw_end2end_test.cc126 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
Dhybrid_end2end_test.cc259 cqs_.push_back(builder.AddCompletionQueue(false)); in SetUpServer()
Dasync_end2end_test.cc282 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc80 cq_ = b.AddCompletionQueue(true); in EndpointPairFixture()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service.cc56 cq_ = builder->AddCompletionQueue(); in GrpcMasterService()
Dgrpc_worker_service.cc109 cq_ = builder->AddCompletionQueue(); in GrpcWorkerServiceThread()
/external/grpc-grpc/src/cpp/server/
Dserver_builder.cc71 std::unique_ptr<ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue() function in grpc::ServerBuilder
/external/grpc-grpc/test/cpp/cocoapods/generic/
Dgeneric.mm137 srv_cq_ = builder.AddCompletionQueue();
/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc101 srv_cqs_.emplace_back(builder->AddCompletionQueue()); in AsyncQpsServerTest()