Home
last modified time | relevance | path

Searched refs:node_id (Results 1 – 25 of 66) sorted by relevance

123

/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode_manager.cc37 const std::string &node_id = register_message.node_id(); in NextRankId() local
38 if (registered_nodes_info_.find(node_id) != registered_nodes_info_.end()) { in NextRankId()
41 rank_id = registered_nodes_info_[node_id].rank_id_; in NextRankId()
42 registered_nodes_info_[node_id].is_alive = true; in NextRankId()
43 registered_nodes_info_[node_id].ip_ = new_ip; in NextRankId()
44 registered_nodes_info_[node_id].port_ = static_cast<uint16_t>(new_port); in NextRankId()
45 MS_LOG(INFO) << "The node id: " << node_id << " is already assigned!"; in NextRankId()
79 node_info.node_id_ = node_id; in NextRankId()
84 registered_nodes_info_[node_id] = node_info; in NextRankId()
85 …MS_LOG(INFO) << "The server node id:" << node_id << ",node ip: " << node_info.ip_ << ",node port:"… in NextRankId()
[all …]
Dscheduler_node.cc59 node_manager_.UpdateHeartbeat(heartbeat_message.node_id()); in ProcessHeartbeat()
87 if (PSContext::instance()->node_id().empty() && config_->Exists(kNodeId)) { in Initialize()
90 node_info_.node_id_ = PSContext::instance()->node_id(); in Initialize()
149 const std::string &node_id = register_message.node_id(); in ProcessRegister() local
150 node_manager_.UpdateHeartbeat(node_id); in ProcessRegister()
152 MS_LOG(INFO) << "The node id:" << node_id << " is registering to scheduler."; in ProcessRegister()
154 if (node_manager_.IsNodeRegistered(node_id)) { in ProcessRegister()
156 if (connected_nodes_.count(node_id)) { in ProcessRegister()
157 (void)connected_nodes_.erase(node_id); in ProcessRegister()
169 register_resp_message.set_node_id(node_id); in ProcessRegister()
[all …]
Dnode_manager.h61 void UpdateHeartbeat(const std::string &node_id);
71 void AddScaleOutDoneNode(const std::string &node_id);
73 void AddScaleInDoneNode(const std::string &node_id);
113 bool IsNodeRegistered(const std::string &node_id);
/third_party/ltp/testcases/kernel/syscalls/getcpu/
Dgetcpu01.c24 unsigned *node_id LTP_ATTRIBUTE_UNUSED, in get_cpu()
28 return tst_syscall(__NR_getcpu, cpu_id, node_id, cache_struct); in get_cpu()
88 int node_id = 0; in get_nodeid() local
111 node_id = in get_nodeid()
120 return node_id; in get_nodeid()
126 unsigned int cpu_id, node_id = 0; in run() local
137 TEST(get_cpu(&cpu_id, &node_id, NULL)); in run()
144 else if (node_id != node_set) in run()
147 node_set, node_id); in run()
152 node_id); in run()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_numa.cc53 numa_id_t node_id = 0; in NumaMemoryPool() local
55 auto success = CreateMultipleArenas(arena_sz, node_id++ % num_numa_nodes, 1); in NumaMemoryPool()
71 for (auto node_id : nodes_) { in NumaMemoryPool() local
72 numa_map_[node_id].push_back(slot); in NumaMemoryPool()
77 int32_t NumaMemoryPool::CreateMultipleArenas(int64_t segment_sz, numa_id_t node_id, int32_t repeat_… in CreateMultipleArenas() argument
81 void *ptr = numa_alloc_onnode(segment_sz, node_id); in CreateMultipleArenas()
88 nodes_.push_back(node_id); in CreateMultipleArenas()
95 MS_LOG(DEBUG) << "Allocate " << success << " arenas from node " << node_id; in CreateMultipleArenas()
122 numa_id_t node_id = start; in Allocate() local
124 auto it = numa_map_.find(node_id); in Allocate()
[all …]
Dcache_pool.h51 DataLocator() : ptr(nullptr), sz(0), node_id(0), node_hit(false), storage_key(0) {} in DataLocator()
58 node_id = other.node_id; in DataLocator()
69 node_id = other.node_id;
80 numa_id_t node_id; // where the numa node the memory is allocated to variable
Dcache_pool.cc111 auto node_id = cs.GetHWControl()->GetMyNode(); in Insert() local
112 bl.node_id = mp_->FindNode(bl.ptr); in Insert()
113 CHECK_FAIL_RETURN_UNEXPECTED(bl.node_id != -1, "Allocator is not from numa memory pool"); in Insert()
114 bl.node_hit = (bl.node_id == node_id); in Insert()
239 bld.add_node_id(it->node_id); in GetDataLocator()
Dcache_hw.cc202 numa_id_t node_id = -1; in GetMyNode() local
204 numa_id_t node_id = 0; in GetMyNode()
207 node_id = numa_node_of_cpu(cpu); in GetMyNode()
213 node_id = it.first; in GetMyNode()
221 return node_id; in GetMyNode()
/third_party/mindspore/mindspore/ccsrc/profiler/device/ascend/
Dmemory_profiling.h36 void SetNodeId(uint64_t node_id) { node_id_ = node_id; } in SetNodeId() argument
37 void AddInputTensorId(uint64_t node_id) { input_tensor_id_.emplace_back(node_id); } in AddInputTensorId() argument
38 void AddOutputTensorId(uint64_t node_id) { output_tensor_id_.emplace_back(node_id); } in AddOutputTensorId() argument
39 void AddWorkSpaceTensorId(uint64_t node_id) { workspace_tensor_id_.emplace_back(node_id); } in AddWorkSpaceTensorId() argument
/third_party/mindspore/mindspore/ccsrc/backend/optimizer/graph_kernel/
Dgraph_kernel_cluster.cc142 …Cluster(size_t node_id, const AnfNodePtr &node, const std::unordered_map<AnfNodePtr, size_t> &node… in Cluster()
143 : cluster_id_(node_id), max_node_id_(node_id) { in Cluster()
192 size_t Find(size_t node_id) { in Find() argument
193 size_t &pre_id = clusters_[node_id].cluster_id_; in Find()
219 void Dfs(size_t node_id, const VisitFunc &visitor) { in Dfs() argument
221 return DepthFirstSearch(Find(node_id), visitor); in Dfs()
313 auto vis_func = [this, &has_circle, &done, &visited_circle_nodes](size_t node_id) { in CheckCircle() argument
314 … if (done.count(node_id) || acyclic_nodes_.count(node_id) || visited_circle_nodes.count(node_id)) { in CheckCircle()
317 (void)done.insert(node_id); in CheckCircle()
318 if (candidates_.count(node_id)) { in CheckCircle()
[all …]
Dtransform_op_optimizer.cc102 void SetFormat(size_t node_id) { in SetFormat() argument
103 nodes_[node_id].format = kFormatA; in SetFormat()
104 for (size_t i : nodes_[node_id].out_edges) { in SetFormat()
339 for (auto [node_id, trans_type] : min_cut.GetOneNodeOps()) { in RebuildLiteGraph()
340 if (ori_node_[node_id].second != -1) { in RebuildLiteGraph()
341 MS_LOG(EXCEPTION) << "OneNodeOp should be the output edge. node_id:" << node_id in RebuildLiteGraph()
342 << " index:" << ori_node_[node_id].second; in RebuildLiteGraph()
345 ori_node_[node_id].first->ReplaceWith(trans_op); in RebuildLiteGraph()
346 trans_op->SetInputs({ori_node_[node_id].first}); in RebuildLiteGraph()
/third_party/boost/libs/fiber/src/numa/aix/
Dtopology.cpp32 for ( int node_id = 0; node_id < maxnodes; ++node_id) { in explore() local
33 if ( ::rs_getrad( rset, rad, sdl, node_id, 0) ) { in explore()
40 n.id = static_cast< std::uint32_t >( node_id); in explore()
/third_party/mindspore/mindspore/ccsrc/ps/core/protos/
Dcomm.proto69 string node_id = 3; field
75 string node_id = 1; field
80 string node_id = 1; field
108 string node_id = 1; field
121 string node_id = 6; field
138 string node_id = 1; field
166 string node_id = 1; field
171 string node_id = 1; field
177 string node_id = 2; field
/third_party/boost/libs/fiber/src/numa/algo/
Dwork_stealing.cpp30 std::vector< std::uint32_t > get_local_cpus( std::uint32_t node_id, std::vector< boost::fibers::num… in get_local_cpus() argument
32 if ( node_id == node.id) { in get_local_cpus()
40 std::vector< std::uint32_t > get_remote_cpus( std::uint32_t node_id, std::vector< boost::fibers::nu… in get_remote_cpus() argument
43 if ( node_id != node.id) { in get_remote_cpus()
68 std::uint32_t node_id, in work_stealing() argument
72 local_cpus_{ get_local_cpus( node_id, topo) },
73 remote_cpus_{ get_remote_cpus( node_id, topo) },
/third_party/boost/boost/graph/
Dgraphviz.hpp529 const dynamic_properties& dp, const std::string& node_id) in dynamic_vertex_properties_writer() argument
530 : dp(&dp), node_id(&node_id) in dynamic_vertex_properties_writer()
541 if (typeid(key) == i->second->key() && i->first != *node_id) in operator ()()
560 const std::string* node_id; member in boost::dynamic_vertex_properties_writer
608 const dynamic_properties& dp, const std::string& node_id) in node_id_property_map()
609 : dp(&dp), node_id(&node_id) in node_id_property_map()
614 const std::string* node_id; member
621 return get(*pm.node_id, *pm.dp, v); in get()
630 const std::string& node_id in write_graphviz_dp() argument
634 write_graphviz_dp(out, g, dp, node_id, in write_graphviz_dp()
[all …]
/third_party/skia/third_party/externals/spirv-tools/source/opt/
Ddominator_analysis.h73 inline BasicBlock* ImmediateDominator(uint32_t node_id) const { in ImmediateDominator() argument
74 return tree_.ImmediateDominator(node_id); in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable() argument
85 return tree_.ReachableFromRoots(node_id); in IsReachable()
/third_party/spirv-tools/source/opt/
Ddominator_analysis.h73 inline BasicBlock* ImmediateDominator(uint32_t node_id) const { in ImmediateDominator() argument
74 return tree_.ImmediateDominator(node_id); in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable() argument
85 return tree_.ReachableFromRoots(node_id); in IsReachable()
/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() argument
74 return tree_.ImmediateDominator(node_id); in ImmediateDominator()
84 inline bool IsReachable(uint32_t node_id) const { in IsReachable() argument
85 return tree_.ReachableFromRoots(node_id); in IsReachable()
/third_party/boost/libs/fiber/src/numa/hpux/
Dtopology.cpp36 int node_id = ::mpctl( MPC_SPUTOLDOM, cpu_id, 0); in topology() local
37 if ( BOOST_UNLIKELY( -1 == node_id) ) { in topology()
42 map[id].id = static_cast< std::uint32_t >( node_id); in topology()
/third_party/boost/libs/mpl/doc/src/docutils/writers/html4_refdoc/
D__init__.py240 def _make_chunk_id( self, node_id ): argument
241 if self.re_auto_id.match( node_id ):
242 node = self.document.ids[ node_id ]
245 if node_id.startswith( 'boost-mpl-' ):
246 return node_id[ len( 'boost-mpl-' ): ]
248 return node_id
/third_party/boost/libs/graph/doc/
Dread_graphviz.rst22 const std::string& node_id = "node_id");
27 const std::string& node_id = "node_id");
32 const std::string& node_id = "node_id");
54 vertex property map named ``node_id``.
158 dp.property("node_id",name);
177 bool status = read_graphviz(gvgraph,graph,dp,"node_id");
/third_party/e2fsprogs/lib/uuid/
Dgen_uuid.c225 static int get_node_id(unsigned char *node_id) in get_node_id() argument
296 if (node_id) { in get_node_id()
297 memcpy(node_id, a, 6); in get_node_id()
581 static unsigned char node_id[6]; in uuid__generate_time() local
587 if (get_node_id(node_id) <= 0) { in uuid__generate_time()
588 get_random_bytes(node_id, 6); in uuid__generate_time()
594 node_id[0] |= 0x01; in uuid__generate_time()
602 memcpy(uu.node, node_id, 6); in uuid__generate_time()
/third_party/boost/libs/graph/test/
Dgraphviz_test.cpp49 weight_map_t const& weights, std::string const& node_id,
55 std::string const& node_id = "node_id", in test_graph() argument
60 node_id, g_name, get(vertex_name, g), get(vertex_color, g), in test_graph()
68 weight_map_t const& weights, std::string const& node_id, argument
74 dp.property(node_id, name);
84 if (read_graphviz(dotfile, graph, dp, node_id))
91 if (read_graphviz(data.begin(), data.end(), graph, dp, node_id))
/third_party/mindspore/mindspore/core/base/
Dbase.cc25 static const uint32_t node_id = GetTypeId(typeid(Base).name()); in IsFromTypeId() local
26 return tid == node_id; in IsFromTypeId()
/third_party/boost/libs/fiber/src/numa/linux/
Dtopology.cpp166 std::uint32_t node_id = i->first; in topology() local
167 map[node_id].id = node_id; in topology()
168 map[node_id].logical_cpus.insert( cpu_id); in topology()

123