Method GetStatusAsyncWithOptions

tensorflow/core/distributed_runtime/worker.cc:44–56

}

void Worker::GetStatusAsyncWithOptions(const GetStatusRequest* request,
                                       GetStatusResponse* response,
                                       StatusCallback done,
                                       CallOptions* call_opts) {
  DeviceMgr* dm = env_->device_mgr;
  std::vector<DeviceAttributes> devices;
  dm->ListDeviceAttributes(&devices);
  response->mutable_device_attributes()->Reserve(devices.size());
  for (auto& d : devices) {
    response->add_device_attributes()->Swap(&d);
  }
  done(Status::OK());
}

void Worker::CreateWorkerSessionAsync(const CreateWorkerSessionRequest* request,
                                      CreateWorkerSessionResponse* response,