| /external/grpc-grpc/test/cpp/util/ |
| cli_call.h | 90 grpc::CompletionQueue cq_; member in class:grpc::testing::final
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| grpc_verbs_service.h | 47 ::grpc::ServerCompletionQueue* cq_; member in class:tensorflow::GrpcVerbsService
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| grpc_eager_service_impl.h | 55 EnqueueRequest(&service_, cq_.get(), \
73 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in class:tensorflow::eager::GrpcEagerServiceImpl
|
| grpc_eager_client.cc | 34 : stub_(channel), cq_(cq) {}
42 &stub_, cq_, "/tensorflow.eager.EagerService/" #method, *request, \
58 ::grpc::CompletionQueue* cq_; member in class:tensorflow::eager::__anon44924::GrpcEagerClient
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| greeter_async_client2.cc | 57 stub_->PrepareAsyncSayHello(&call->context, request, &cq_);
76 while (cq_.Next(&got_tag, &ok)) {
118 CompletionQueue cq_; member in class:GreeterClient
|
| greeter_async_server.cc | 44 cq_->Shutdown();
59 cq_ = builder.AddCompletionQueue();
76 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) {
91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_,
97 new CallData(service_, cq_);
120 ServerCompletionQueue* cq_; member in class:final::CallData
142 new CallData(&service_, cq_.get());
150 // tells us whether there is any kind of event or cq_ is shutting down.
151 GPR_ASSERT(cq_->Next(&tag, &ok))
157 std::unique_ptr<ServerCompletionQueue> cq_; member in class:final
[all...] |
| /external/grpc-grpc/src/cpp/common/ |
| alarm.cc | 39 AlarmImpl() : cq_(nullptr), tag_(nullptr) {
45 if (cq_ != nullptr) {
46 GRPC_CQ_INTERNAL_UNREF(cq_, "alarm");
57 cq_ = cq->cq();
59 GPR_ASSERT(grpc_cq_begin_op(cq_, this));
66 alarm->cq_, alarm, error,
111 grpc_completion_queue* cq_; member in class:grpc::internal::AlarmImpl
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_state.h | 59 cq_(cq),
93 stub_->PrepareUnaryCall(context_.get(), method_, request_buf_, cq_));
165 ::grpc::CompletionQueue* cq_; member in class:tensorflow::RPCState
|
| grpc_master_service.cc | 56 cq_ = builder->AddCompletionQueue();
76 new ::grpc::Alarm(cq_.get(), gpr_now(GPR_CLOCK_MONOTONIC), nullptr);
82 // `this->cq_`.
97 EnqueueRequest(&master_service_, cq_.get(), \
122 while (cq_->Next(&tag, &ok)) {
130 cq_->Shutdown();
137 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in class:tensorflow::GrpcMasterService
|
| grpc_remote_worker.cc | 52 cq_(completion_queue),
266 new RPCState<protobuf::Message>(&stub_, cq_, method, *request, response,
274 new RPCState<TensorResponse>(&stub_, cq_, method, *request, response,
284 ::grpc::CompletionQueue* cq_; member in class:tensorflow::GrpcRemoteWorker
|
| grpc_worker_service.cc | 65 // `this->cq_`.
81 worker_service_, cq_.get(), \
109 cq_ = builder->AddCompletionQueue();
125 cq_->Shutdown();
163 while (cq_->Next(&tag, &ok)) {
355 worker_service_, cq_.get(),
363 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in class:tensorflow::__anon44938::GrpcWorkerServiceThread
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| completion_queue.h | 111 g_core_codegen_interface->grpc_completion_queue_destroy(cq_);
234 grpc_completion_queue* cq() { return cq_; }
239 cq_ = g_core_codegen_interface->grpc_completion_queue_create(
291 CompletionQueue* cq_; member in class:grpc::CompletionQueue::CompletionQueueTLSCache
303 cq_, tag, deadline, nullptr);
315 /// TODO: sreek - This calls tag->FinalizeResult() even if the cq_ is already
323 cq_, tag, deadline, nullptr);
338 cq_, tag, deadline, nullptr);
363 grpc_completion_queue* cq_; // owned member in class:grpc::CompletionQueue
|
| server_context.h | 294 CompletionQueue* cq_; member in class:grpc::ServerContext
|
| sync_stream.h | 192 cq_.Pluck(&ops); /// status ignored
214 return cq_.Pluck(&ops) && ops.got_message;
227 GPR_CODEGEN_ASSERT(cq_.Pluck(&ops));
234 CompletionQueue cq_; member in class:grpc::final
245 cq_(grpc_completion_queue_attributes{
248 call_(channel->CreateCall(method, context, &cq_)) {
259 cq_.Pluck(&ops);
309 cq_.Pluck(&ops); // status ignored
339 return cq_.Pluck(&ops);
346 return cq_.Pluck(&ops)
401 CompletionQueue cq_; member in class:grpc::ClientWriter
543 CompletionQueue cq_; member in class:grpc::final
[all...] |
| /external/grpc-grpc/src/cpp/client/ |
| channel_cc.cc | 201 void TakeCQ(CompletionQueue* cq) { cq_ = cq; }
207 delete callback->cq_;
212 CompletionQueue* cq_ = nullptr; member in class:grpc::__anon23287::ShutdownCallback
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| load_reporter_async_service_impl.h | 147 ServerCompletionQueue* cq_; member in class:grpc::load_reporter::LoadReporterAsyncServiceImpl::ReportLoadHandler
181 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::load_reporter::LoadReporterAsyncServiceImpl
182 // To synchronize the operations related to shutdown state of cq_, so that we
183 // don't enqueue new tags into cq_ after it is already shut down.
|
| /external/grpc-grpc/test/cpp/end2end/ |
| health_service_end2end_test.cc | 147 cq_ = builder.AddCompletionQueue();
155 if (cq_ != nullptr) {
156 cq_->Shutdown();
224 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::__anon23421::HealthServiceEnd2endTest
260 cq_thread_ = std::thread(LoopCompletionQueue, cq_.get());
|
| nonblocking_test.cc | 78 auto r = cq_->AsyncNext(tag, ok, gpr_time_0(GPR_CLOCK_REALTIME));
91 cq_->Shutdown();
104 cq_ = builder.AddCompletionQueue();
128 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get()));
134 cq_.get(), cq_.get(), tag(2));
165 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::__anon23425::NonblockingTest
|
| raw_end2end_test.cc | 112 cq_->Shutdown();
113 while (cq_->Next(&ignored_tag, &ignored_ok))
126 cq_ = builder.AddCompletionQueue();
138 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::__anon23426::RawEnd2EndTest
177 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get()));
178 service->RequestEcho(&srv_ctx_, &recv_request_, &response_writer, cq_.get(),
179 cq_.get(), tag(2));
181 Verifier().Expect(2, true).Verify(cq_.get());
185 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get());
202 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get()))
[all...] |
| server_builder_plugin_test.cc | 180 cq_ = builder_->AddCompletionQueue();
198 cq_->Shutdown();
213 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::ServerBuilderPluginTest
235 while (cq_->Next(&tag, &ok))
|
| thread_stress_test.cc | 179 cq_ = builder.AddCompletionQueue();
194 cq_->Shutdown();
203 while (cq_->Next(&ignored_tag, &ignored_ok))
212 while (cq_->Next(&tag, &ok)) {
241 contexts_[i].response_writer.get(), cq_.get(),
242 cq_.get(), (void*)static_cast<intptr_t>(i));
254 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::CommonStressTestAsyncServer
338 while (cq_.Next(&ignored_tag, &ignored_ok))
349 cq_.Shutdown();
365 common_.GetStub()->AsyncEcho(&call->context, request, &cq_);
398 CompletionQueue cq_; member in class:grpc::testing::AsyncClientEnd2endTest
[all...] |
| /external/grpc-grpc/test/core/transport/chttp2/ |
| settings_timeout_test.cc | 59 cq_ = grpc_completion_queue_create_for_next(nullptr);
60 grpc_server_register_completion_queue(server_, cq_, nullptr);
75 grpc_completion_queue_destroy(cq_);
83 cq_, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr);
89 grpc_completion_queue* cq_ = nullptr; member in class:grpc_core::test::__anon23389::ServerThread
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| fullstack_fixtures.h | 82 cq_ = b.AddCompletionQueue(true);
100 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(),
102 cq_->Shutdown();
105 while (cq_->Next(&tag, &ok)) {
116 ServerCompletionQueue* cq() { return cq_.get(); }
121 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::FullstackFixture
179 cq_ = b.AddCompletionQueue(true);
229 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(),
231 cq_->Shutdown();
234 while (cq_->Next(&tag, &ok))
255 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::EndpointPairFixture
[all...] |
| /external/grpc-grpc/test/cpp/performance/ |
| writes_per_rpc_test.cc | 80 cq_ = b.AddCompletionQueue(true);
127 cq_->Shutdown();
130 while (cq_->Next(&tag, &ok)) {
134 ServerCompletionQueue* cq() { return cq_.get(); }
139 std::unique_ptr<ServerCompletionQueue> cq_; member in class:grpc::testing::EndpointPairFixture
|
| /external/grpc-grpc/test/cpp/qps/ |
| client_async.cc | 77 cq_(nullptr),
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_);
121 CompletionQueue* cq_; member in class:grpc::testing::ClientRpcContextUnaryImpl
139 cq_ = cq;
144 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));
178 cq_.emplace_back(i % cli_cqs_.size());
247 while (cli_cqs_[cq_[thread_idx]]->Next(&tag, &ok)) {
263 if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) {
273 while (cli_cqs_[cq_[thread_idx]]->DoThenAsyncNext(
278 ctx->StartNewClone(cli_cqs_[cq_[thread_idx]].get())
296 std::vector<int> cq_; member in class:grpc::testing::AsyncClient
436 CompletionQueue* cq_; member in class:grpc::testing::ClientRpcContextStreamingPingPongImpl
591 CompletionQueue* cq_; member in class:grpc::testing::ClientRpcContextStreamingFromClientImpl
711 CompletionQueue* cq_; member in class:grpc::testing::ClientRpcContextStreamingFromServerImpl
856 CompletionQueue* cq_; member in class:grpc::testing::ClientRpcContextGenericStreamingImpl
[all...] |
