= nullptr) { return; } if (env_->local_devices[0]->parsed_name(...).job == job.name() && env_->local_devices[0]->parsed_name().task == task.first) {...DeviceSet); for (auto&& d : *remote_devices) { device_set->AddDevice(d.get()); DeviceNameUtils...::ParsedName name = d->parsed_name(); if (name.job == *worker_cache_factory_options.job_name...DeviceNameUtils::ParseFullName(worker_names[i], &name)) { status = errors::Internal("Could not
::ParsedName src; uint64 src_incarnation = 0; StringPiece dst_device; DeviceNameUtils::ParsedName...parts[4].empty() && // Exactly five parts DeviceNameUtils::ParseFullName(parts[0], &out->src)...&& strings::HexStringToUint64(parts[1], &out->src_incarnation) && DeviceNameUtils::ParseFullName...virtual bool IsSameWorker(DeviceNameUtils::ParsedName src, DeviceNameUtils...RecvFromRemoteAsync(parsed, recv_args, std::move(done)); } } 4.1.3 RpcRemoteRendezvous RpcRemoteRendezvous 检查各项参数
i < num_remote_workers; i++) { const string& remote_worker = remote_workers[i]; tensorflow::DeviceNameUtils...::ParsedName parsed_name; if (!...tensorflow::DeviceNameUtils::ParseFullName(remote_worker,...&parsed_name)) { counter.DecrementCount(); continue; } tensorflow::core::RefCountPtr