Searched refs:scheduler_port_ (Results 1 – 9 of 9) sorted by relevance
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | ps_context.cc | 57 scheduler_port_ = std::strtol(common::GetEnv(kEnvSchedulerPort).c_str(), nullptr, kBase); in SetPSEnable()
58 if (scheduler_port_ > kMaxPort) { in SetPSEnable()
59 MS_LOG(EXCEPTION) << "The port: " << scheduler_port_ << " is illegal."; in SetPSEnable()
66 … std::make_unique<core::ClusterConfig>(worker_num_, server_num_, scheduler_host_, scheduler_port_); in SetPSEnable()
277 void PSContext::set_scheduler_port(uint16_t sched_port) { scheduler_port_ = sched_port; } in set_scheduler_port()
279 uint16_t PSContext::scheduler_port() const { return scheduler_port_; } in scheduler_port()
|
| D | ps_context.h | 199 scheduler_port_(6667), in PSContext()
238 uint16_t scheduler_port_; variable
|
| /third_party/mindspore/mindspore/ccsrc/fl/worker/ |
| D | fl_worker.h | 100 scheduler_port_(0), in FLWorker()
132 uint16_t scheduler_port_; variable
|
| D | fl_worker.cc | 35 scheduler_port_ = ps::PSContext::instance()->scheduler_port(); in Run()
38 ps::PSContext::instance()->cluster_config().scheduler_port = scheduler_port_; in Run()
43 << ", Scheduler port:" << scheduler_port_ in Run()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
| D | tcp_communicator.h | 71 scheduler_port_(0), in TcpCommunicator()
117 uint16_t scheduler_port_; variable
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | server.h | 78 scheduler_port_(0),
197 uint16_t scheduler_port_; variable
|
| D | server.cc | 138 scheduler_port_ = ps::PSContext::instance()->scheduler_port(); in InitServerContext()
168 …th_server_ = server_node_->GetOrCreateTcpComm(scheduler_ip_, static_cast<int16_t>(scheduler_port_), in InitCommunicatorWithServer()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | abstract_node.h | 55 scheduler_port_(0) {} in AbstractNode()
268 uint16_t scheduler_port_; variable
|
| D | abstract_node.cc | 442 uint16_t AbstractNode::scheduler_port() const { return scheduler_port_; } in scheduler_port()
444 void AbstractNode::set_scheduler_port(const uint16_t &scheduler_port) { scheduler_port_ = scheduler… in set_scheduler_port()
818 client_to_scheduler_ = std::make_shared<TcpClient>(scheduler_ip_, scheduler_port_, config_.get()); in InitClientToScheduler()
1080 scheduler_port_ = PSContext::instance()->cluster_config().scheduler_port; in InitNodeNum()
1082 … << ", the scheduler ip:" << scheduler_ip_ << ", the scheduler port:" << scheduler_port_; in InitNodeNum()
|