Home
last modified time | relevance | path

Searched defs:node_id (Results 1 – 25 of 69) sorted by relevance

123

/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/protos/
Dcomm.proto124 string node_id = 3; field
134 string node_id = 1; field
140 string node_id = 1; field
183 string node_id = 1; field
196 string node_id = 6; field
214 string node_id = 1; field
242 string node_id = 1; field
247 string node_id = 1; field
253 string node_id = 2; field
278 string node_id = 1; field
[all …]
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/ps/core/
Dnode_manager.cc34 const std::string &node_id = register_message.node_id(); in checkIfRankIdExist() local
54 bool NodeManager::ReAddNodeIfNotExists(const std::string &node_id, const std::string &ip, uint32_t … in ReAddNodeIfNotExists()
88 const std::string &node_id = register_message.node_id(); in NextRankId() local
152 void NodeManager::UpdateHeartbeat(const std::string &node_id) { in UpdateHeartbeat()
243 void NodeManager::AddScaleOutDoneNode(const std::string &node_id) { scale_out_done_nodes_id_.insert… in AddScaleOutDoneNode()
245 void NodeManager::AddScaleInDoneNode(const std::string &node_id) { scale_in_done_nodes_id_.insert(n… in AddScaleInDoneNode()
340 bool NodeManager::IsNodeRegistered(const std::string &node_id) { in IsNodeRegistered()
360 void NodeManager::AddPersistingNode(const std::string &node_id) { (void)nodes_persisting_.insert(no… in AddPersistingNode()
Dps_scheduler_node.cc83 std::string node_id = send_host_name_msg.node_id(); in ProcessSendHostName() local
127 std::string node_id = query_msg.node_id(); in ProcessQueryHostNames() local
174 std::string node_id = send_unique_id_msg.node_id(); in ProcessSendUniqueID() local
209 std::string node_id = query_msg.node_id(); in ProcessQueryUniqueID() local
258 std::string node_id = send_finish_transform_msg.node_id(); in ProcessSendFinishTransform() local
293 std::string node_id = query_msg.node_id(); in ProcessQueryFinishTransform() local
Dscheduler_node.cc128 auto &node_id = kvs.first; in RunRecovery() local
171 std::string node_id = heartbeat_message.node_id(); in ProcessHeartbeat() local
340 const std::string &node_id = register_message.node_id(); in ProcessRegister() local
469 std::string node_id = *finish_message; in ProcessFinish() local
526 std::string node_id = event_message.node_id(); in ProcessSendEvent() local
1003 …::SetRegisterConnectionFd(const std::shared_ptr<TcpConnection> &conn, const std::string &node_id) { in SetRegisterConnectionFd()
/third_party/mindspore/mindspore-src/source/mindspore/lite/src/extendrt/cxx_api/model_pool/
Dpredict_task_queue.cc78 void PredictTaskQueue::WaitUntilPredictActive(PredictTask *task, int node_id) { in WaitUntilPredictActive()
98 void PredictTaskQueue::PushPredictTask(PredictTask *task, int node_id) { in PushPredictTask()
111 PredictTask *PredictTaskQueue::GetPredictTask(int node_id, ModelWorker *worker) { in GetPredictTask()
Dpredict_task_queue.h60 int GetWaitModelNum(int node_id) const { return idle_worker_num_[node_id]; } in GetWaitModelNum()
61 void DecreaseWaitModelNum(int num, int node_id) { idle_worker_num_[node_id] -= num; } in DecreaseWaitModelNum()
62 void IncreaseWaitModelNum(int num, int node_id) { idle_worker_num_[node_id] += num; } in IncreaseWaitModelNum()
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/cluster/topology/protocol/
Dtopology.proto21 string node_id = 1; field
35 string node_id = 1; field
39 string node_id = 1; field
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/cluster/topology/
Dmeta_server_node.cc193 const auto &node_id = registration.node_id(); in ProcessRegister() local
285 const auto &node_id = unregistration.node_id(); in ProcessUnregister() local
322 const auto &node_id = heartbeat.node_id(); in ProcessHeartbeat() local
477 auto node_id = iter->first; in UpdateTopoState() local
535 std::string node_id = n.first; in AssignPortRange() local
545 std::string node_id = n.first; in AssignPortRange() local
591 const auto &node_id = iter.key(); in Recovery() local
620 const auto &node_id = iter->first; in Persist() local
656 bool MetaServerNode::CheckRankIdValidation(const std::string &node_id, const std::string &role, uin… in CheckRankIdValidation()
Dmeta_server_node.h52 std::string node_id; member
113 std::string node_id; member
141 …: NodeBase(node_id, role), total_node_num_(node_num), abnormal_node_num_(0), enable_monitor_(true)… in NodeBase() argument
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_numa.cc53 numa_id_t node_id = 0; in NumaMemoryPool() local
71 for (auto node_id : nodes_) { in NumaMemoryPool() local
77 int32_t NumaMemoryPool::CreateMultipleArenas(int64_t segment_sz, numa_id_t node_id, int32_t repeat_… in CreateMultipleArenas()
122 numa_id_t node_id = start; in Allocate() local
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/backend/common/graph_kernel/core/
Dgraph_kernel_cluster.cc38 Graph::Cluster::Cluster(size_t node_id, const AnfNodePtr &node, in Cluster()
85 size_t Graph::Find(size_t node_id) { in Find()
108 void Graph::Dfs(size_t node_id, const Graph::VisitFunc &visitor) { in Dfs()
190 auto vis_func = [this, &has_circle, &done, &visited_circle_nodes](size_t node_id) { in CheckCircle()
213 auto remove_from_candidates = [this](size_t node_id) { in RemoveCircleNodesFromCandidates()
268 …de_without_getitem = std::count_if(clusters[i].begin(), clusters[i].end(), [this](size_t node_id) { in Process()
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/ascend/hal/profiler/
Dmemory_profiling.h36 void SetNodeId(uint64_t node_id) { node_id_ = node_id; } in SetNodeId()
37 void AddInputTensorId(uint64_t node_id) { input_tensor_id_.emplace_back(node_id); } in AddInputTensorId()
38 void AddOutputTensorId(uint64_t node_id) { output_tensor_id_.emplace_back(node_id); } in AddOutputTensorId()
39 void AddWorkSpaceTensorId(uint64_t node_id) { workspace_tensor_id_.emplace_back(node_id); } in AddWorkSpaceTensorId()
Dmemory_profiling.proto37 uint64 node_id = 2; // node id with respect to the execution order field
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/include/backend/distributed/cluster/topology/
Dnode_base.h36 explicit NodeBase(const std::string &node_id, const std::string &role) in NodeBase()
76 std::string node_id() const { return node_id_; } in node_id() function
Dcompute_graph_node.h37 ComputeGraphNode(const std::string &node_id, const std::string &role) in ComputeGraphNode()
/third_party/mindspore/mindspore-src/source/mindspore/lite/src/extendrt/
Ddynamic_mem_manager.h51 inline void set_node_id(int node_id) { node_id_ = node_id; } in set_node_id()
52 inline int node_id(void) const { return node_id_; } in node_id() function
Dnuma_adapter.cc133 void *NUMAAdapter::Malloc(int node_id, size_t size) const { in Malloc()
161 std::vector<int> NUMAAdapter::GetCPUList(int node_id) { in GetCPUList()
Ddynamic_mem_manager.cc45 void *MemOperator::Allocate(size_t rounded_size, int node_id, size_t *allocate_size) { in Allocate()
229 MemOperator::MemOperator(int node_id) { in MemOperator()
309 std::shared_ptr<MemOperator> DynamicMemManager::GetMemOperator(const int node_id) { in GetMemOperator()
Ddynamic_mem_allocator.cc63 DynamicMemAllocator::DynamicMemAllocator(int node_id) { in DynamicMemAllocator()
/third_party/ltp/testcases/kernel/syscalls/getcpu/
Dgetcpu01.c74 int node_id = 0; in get_nodeid() local
113 unsigned int cpu_id, node_id = 0; in run() local
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/opt/
Ddominator_analysis.h73 inline BasicBlock* ImmediateDominator(uint32_t node_id) const { in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable()
/third_party/spirv-tools/source/opt/
Ddominator_analysis.h73 inline BasicBlock* ImmediateDominator(uint32_t node_id) const { in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable()
/third_party/skia/third_party/externals/spirv-tools/source/opt/
Ddominator_analysis.h73 inline BasicBlock* ImmediateDominator(uint32_t node_id) const { in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable()
/third_party/mindspore/mindspore-src/source/mindspore/lite/src/common/draw/
Dgraphviz_graph_builder.cc75 auto node_id = GetNodeId(*node); in Build() local
216 auto node_id = GetNodeId(node); in CreateComputeNode() local
/third_party/rust/rust/compiler/rustc_borrowck/src/region_infer/
Dgraphviz.rs45 fn node_id(&'this self, n: &RegionVid) -> dot::Id<'this> { in node_id() method
95 fn node_id(&'this self, n: &ConstraintSccIndex) -> dot::Id<'this> { in node_id() method

123