Home
last modified time | relevance | path

Searched refs:set_worker_num (Results 1 – 11 of 11) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode_recovery.cc30 node_->set_worker_num(worker_num); in Recover()
32 node_->set_worker_num(PSContext::instance()->cluster_config().initial_worker_num); in Recover()
Dleader_scaler.cc30 scale_out_message.set_worker_num(manager.worker_num()); in ScaleOutAsync()
50 scale_in_message.set_worker_num(manager.worker_num()); in ScaleInAsync()
Dnode_manager.h96 void set_worker_num(const int32_t &worker_num);
Dscheduler_node.cc348 send_metadata_message.set_worker_num(node_manager_.worker_num()); in SendMetadata()
579 node_manager_.set_worker_num(total_worker_num); in ProcessScaleOut()
662 node_manager_.set_worker_num(total_worker_num); in ProcessScaleIn()
Dabstract_node.h121 void set_worker_num(const int32_t &worker_num);
Dnode_manager.cc304 void NodeManager::set_worker_num(const int32_t &worker_num) { meta_data_->worker_num = IntToUint(wo… in set_worker_num() function in mindspore::ps::core::NodeManager
Dabstract_node.cc434 void AbstractNode::set_worker_num(const int32_t &worker_num) { worker_num_ = worker_num; } in set_worker_num() function in mindspore::ps::core::AbstractNode
/third_party/mindspore/mindspore/parallel/
D_ps_context.py52 "worker_num": ps_context().set_worker_num,
/third_party/mindspore/mindspore/ccsrc/ps/
Dps_context.h98 void set_worker_num(uint32_t worker_num);
Dps_context.cc254 void PSContext::set_worker_num(uint32_t worker_num) { in set_worker_num() function in mindspore::ps::PSContext
/third_party/mindspore/mindspore/ccsrc/pipeline/jit/
Dinit.cc365 .def("set_worker_num", &PSContext::set_worker_num, "Set worker number.") in PYBIND11_MODULE()