| /external/tensorflow/tensorflow/contrib/verbs/ |
| grpc_verbs_service.h | 53 ::grpc::ServerCompletionQueue* cq_; member in class:tensorflow::GrpcVerbsService
|
| rdma.h | 396 ibv_cq* cq_; member in class:tensorflow::RdmaAdapter
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| 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(), \
117 while (cq_->Next(&tag, &ok)) {
125 cq_->Shutdown();
133 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in class:tensorflow::GrpcMasterService
|
| grpc_remote_worker.cc | 47 cq_(completion_queue),
190 new RPCState<protobuf::Message>(&stub_, cq_, method, *request, response,
196 new RPCState<TensorResponse>(&stub_, cq_, method, *request, response,
205 ::grpc::CompletionQueue* cq_; member in class:tensorflow::GrpcRemoteWorker
|
| grpc_worker_service.cc | 86 // `this->cq_`.
102 worker_service_, cq_.get(), \
129 cq_ = builder->AddCompletionQueue();
145 cq_->Shutdown();
178 while (cq_->Next(&tag, &ok)) {
329 worker_service_, cq_.get(),
337 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in class:tensorflow::__anon39543::GrpcWorkerService::GrpcWorkerServiceThread
|
