| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | node_recovery.cc | 53 …uint16_t scheduler_port = std::strtol(recovery_storage_->Get(kRecoverySchedulerPort, "").c_str(), … in Recover() local
54 node_->set_scheduler_port(scheduler_port); in Recover()
56 node_->set_scheduler_port(PSContext::instance()->cluster_config().scheduler_port); in Recover()
59 … the scheduler ip:" << node_->scheduler_ip() << ", the scheduler port:" << node_->scheduler_port(); in Recover()
|
| D | cluster_config.h | 39 scheduler_port(port), in ClusterConfig()
53 uint16_t scheduler_port; member
|
| /third_party/mindspore/tests/st/fl/cross_silo_lenet/ |
| D | finish_cross_silo_lenet.py | 23 scheduler_port = args.scheduler_port variable
25 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_cross_silo_lenet_sched.py | 35 scheduler_port = args.scheduler_port variable
50 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_lenet_worker.py | 40 scheduler_port = args.scheduler_port variable
67 cmd_worker += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_lenet_server.py | 46 scheduler_port = args.scheduler_port variable
78 cmd_server += " --scheduler_port=" + str(scheduler_port)
|
| D | test_cross_silo_lenet.py | 58 scheduler_port = args.scheduler_port variable
81 "scheduler_port": scheduler_port,
|
| /third_party/mindspore/tests/st/fl/hybrid_lenet/ |
| D | finish_hybrid_train.py | 23 scheduler_port = args.scheduler_port variable
25 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_hybrid_train_sched.py | 40 scheduler_port = args.scheduler_port variable
59 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| D | run_hybrid_train_worker.py | 42 scheduler_port = args.scheduler_port variable
69 cmd_worker += " --scheduler_port=" + str(scheduler_port)
|
| D | run_hybrid_train_server.py | 59 scheduler_port = args.scheduler_port variable
101 cmd_server += " --scheduler_port=" + str(scheduler_port)
|
| /third_party/mindspore/tests/st/fl/cross_silo_faster_rcnn/ |
| D | finish_cross_silo_fasterrcnn.py | 24 scheduler_port = args.scheduler_port variable
26 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_cross_silo_fasterrcnn_sched.py | 36 scheduler_port = args.scheduler_port variable
52 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_fasterrcnn_worker.py | 39 scheduler_port = args.scheduler_port variable
64 cmd_worker += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_fasterrcnn_server.py | 48 scheduler_port = args.scheduler_port variable
82 cmd_server += " --scheduler_port=" + str(scheduler_port)
|
| /third_party/mindspore/tests/st/fl/albert/ |
| D | finish_hybrid_train.py | 23 scheduler_port = args.scheduler_port variable
25 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_hybrid_train_sched.py | 39 scheduler_port = args.scheduler_port variable
56 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| D | run_hybrid_train_server.py | 59 scheduler_port = args.scheduler_port variable
100 cmd_server += " --scheduler_port=" + str(scheduler_port)
|
| /third_party/mindspore/tests/st/fl/cross_silo_femnist/ |
| D | finish_cross_silo_femnist.py | 23 scheduler_port = args.scheduler_port variable
25 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_cross_silo_femnist_sched.py | 36 scheduler_port = args.scheduler_port variable
52 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_femnist_worker.py | 41 scheduler_port = args.scheduler_port variable
68 cmd_worker += " --scheduler_port=" + str(scheduler_port)
|
| D | run_cross_silo_femnist_server.py | 47 scheduler_port = args.scheduler_port variable
80 cmd_server += " --scheduler_port=" + str(scheduler_port)
|
| /third_party/mindspore/tests/st/fl/mobile/ |
| D | finish_mobile.py | 24 scheduler_port = args.scheduler_port variable
26 cmd = "pid=`ps -ef|grep \"scheduler_port=" + str(scheduler_port) + "\" "
|
| D | run_mobile_sched.py | 42 scheduler_port = args.scheduler_port variable
61 cmd_sched += " --scheduler_port=" + str(scheduler_port)
|
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | scheduler.cc | 24 PSContext::instance()->cluster_config().scheduler_port = PSContext::instance()->scheduler_port(); in Run()
|