| /third_party/mindspore/mindspore/ccsrc/fl/armour/cipher/ |
| D | cipher_reconstruct.cc | 44 const std::string fl_id = iter->first; in CombineMask() local
45 if (find(client_list.begin(), client_list.end(), fl_id) != client_list.end()) { in CombineMask()
49 MS_LOG(INFO) << "fl_id_src : " << fl_id; in CombineMask()
80 …if (GetSuvNoise(clients_share_list, record_public_keys, client_ivs, fl_id, &noise, secret, length)… in CombineMask()
88 (void)client_noise->emplace(std::pair<std::string, std::vector<float>>(fl_id, noise)); in CombineMask()
93 auto it = client_ivs.find(fl_id); in CombineMask()
95 MS_LOG(ERROR) << "cannot get ivs for client: " << fl_id; in CombineMask()
115 (void)client_noise->emplace(std::pair<std::string, std::vector<float>>(fl_id, noise)); in CombineMask()
122 MS_LOG(ERROR) << "reconstruct secret failed: the number of secret shares for fl_id: " << fl_id in CombineMask()
231 std::string fl_id = reconstruct_secret_req->fl_id()->str(); in ReconstructSecrets() local
[all …]
|
| D | cipher_keys.cc | 40 std::string fl_id = get_exchange_keys_req->fl_id()->str(); in GetKeys() local
50 if (client_public_keys.find(fl_id) == client_public_keys.end()) { in GetKeys()
51 MS_LOG(INFO) << "Get keys: the fl_id: " << fl_id << "is not in exchange keys clients."; in GetKeys()
56 … cipher_init_->cipher_meta_storage_.UpdateClientToServer(fl::server::kCtxGetKeysClientList, fl_id); in GetKeys()
84 std::string fl_id = exchange_keys_req->fl_id()->str(); in ExchangeKeys() local
88 MS_LOG(INFO) << "exchange key for fl id " << fl_id; in ExchangeKeys()
89 if (fl_id_to_meta.fl_id_to_meta().count(fl_id) == 0) { in ExchangeKeys()
90 std::string reason = "devices_meta for " + fl_id + " is not set. Please retry later."; in ExchangeKeys()
114 …if (client_public_keys.find(fl_id) != client_public_keys.end()) { // the client already exists, r… in ExchangeKeys()
125 …er_init_->cipher_meta_storage_.UpdateClientToServer(fl::server::kCtxExChangeKeysClientList, fl_id); in ExchangeKeys()
[all …]
|
| D | cipher_meta_storage.cc | 32 std::string fl_id = iter->first; in GetClientSharesFromServer() local
39 new_clientshare.fl_id = client_share_str_pb.fl_id(); in GetClientSharesFromServer()
44 …clients_shares_list->insert(std::pair<std::string, std::vector<clientshare_str>>(fl_id, encrpted_s… in GetClientSharesFromServer()
57 std::string fl_id = client_list_pb.fl_id(SizeToInt(i)); in GetClientListFromServer() local
58 clients_list->push_back(fl_id); in GetClientListFromServer()
73 std::string fl_id = iter->first; in GetClientKeysFromServer() local
80 …nts_keys_list->emplace(std::pair<std::string, std::vector<std::vector<uint8_t>>>(fl_id, cur_keys)); in GetClientKeysFromServer()
95 std::string fl_id = iter->first; in GetClientIVsFromServer() local
105 …(void)clients_ivs_list->emplace(std::pair<std::string, std::vector<std::vector<uint8_t>>>(fl_id, c… in GetClientIVsFromServer()
154 bool CipherMetaStorage::UpdateClientToServer(const char *list_name, const std::string &fl_id) { in UpdateClientToServer() argument
[all …]
|
| D | cipher_shares.cc | 61 std::string fl_id_src = share_secrets_req->fl_id()->str(); in ShareSecrets()
125 std::string fl_id = get_secrets_req->fl_id()->str(); in GetSecrets() local
127 if (encrypted_shares_all.find(fl_id) == encrypted_shares_all.end()) { in GetSecrets()
134 …pher_init_->cipher_meta_storage_.UpdateClientToServer(fl::server::kCtxGetSecretsClientList, fl_id); in GetSecrets()
150 std::string fl_id_des = clientshare_str_now[index_clientshare].fl_id; in GetSecrets()
151 if (fl_id_des == fl_id) { in GetSecrets()
152 client_share_str_new.fl_id = fl_id_src_now; in GetSecrets()
170 auto one_fl_id = fbb->CreateString(ptr->fl_id); in GetSecrets()
|
| D | cipher_meta_storage.h | 57 std::string fl_id; member
95 bool UpdateClientToServer(const char *list_name, const std::string &fl_id);
97 bool UpdateClientKeyToServer(const char *list_name, const std::string &fl_id,
105 const char *list_name, const std::string &fl_id,
|
| D | cipher_reconstruct.h | 67 … const std::map<std::string, std::vector<std::vector<uint8_t>>> &client_ivs, const string &fl_id,
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | distributed_metadata_store.cc | 233 auto &device_meta_fl_id = meta.device_meta().fl_id(); in DoUpdateMetadata()
242 auto &fl_id = meta.fl_id().fl_id(); in DoUpdateMetadata() local
246 if (fl_id == client_list->fl_id(i)) { in DoUpdateMetadata()
252 client_list->add_fl_id(fl_id); in DoUpdateMetadata()
261 auto &fl_id = meta.pair_client_keys().fl_id(); in DoUpdateMetadata() local
266 if (fl_id == iter->first) { in DoUpdateMetadata()
274 client_keys_map[fl_id] = client_keys; in DoUpdateMetadata()
280 auto &fl_id = meta.pair_client_shares().fl_id(); in DoUpdateMetadata() local
286 if (fl_id == iter->first) { in DoUpdateMetadata()
294 client_shares_map[fl_id] = client_shares; in DoUpdateMetadata()
|
| /third_party/mindspore/mindspore/schema/ |
| D | cipher.fbs | 31 fl_id:string;
39 fl_id:string;
45 fl_id:string;
63 fl_id:string;
76 fl_id:string;
90 fl_id:string;
103 fl_id:string;
117 fl_id:string;
|
| D | fl_job.fbs | 55 fl_id:string;
87 fl_id:string;
102 fl_id:string;
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/protos/ |
| D | fl.proto | 70 string fl_id = 1; field
74 repeated string fl_id = 1; field
79 string fl_id = 2; field
96 string fl_id = 1; field
109 string fl_id = 1; field
118 string fl_id = 1; field
147 FLId fl_id = 3; field
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/kernel/round/ |
| D | client_list_kernel.cc | 46 std::string fl_id = get_clients_req->fl_id()->str(); in DealClient() local
58 client_list.push_back(client_list_pb.fl_id(SizeToInt(i))); in DealClient()
68 …if (find(client_list.begin(), client_list.end(), fl_id) == client_list.end()) { // client not in … in DealClient()
69 std::string reason = "fl_id: " + fl_id + " is not in the update_model_clients"; in DealClient()
77 …_init_->cipher_meta_storage_.UpdateClientToServer(fl::server::kCtxGetUpdateModelClientList, fl_id); in DealClient()
85 if (!DistributedCountService::GetInstance().Count(name_, get_clients_req->fl_id()->str())) { in DealClient()
|
| D | reconstruct_secrets_kernel.cc | 77 update_model_clients.push_back(update_model_clients_pb.fl_id(i)); in Launch()
82 std::string fl_id = reconstruct_secret_req->fl_id()->str(); in Launch() local
86 …if (find(update_model_clients.begin(), update_model_clients.end(), fl_id) != update_model_clients.… in Launch()
103 … (void)DistributedCountService::GetInstance().Count(name_, reconstruct_secret_req->fl_id()->str()); in Launch()
|
| D | start_fl_job_kernel.cc | 155 std::string fl_id = start_fl_job_req->fl_id()->str(); in CreateDeviceMetadata() local
157 …MS_LOG(INFO) << "DeviceMeta fl_name:" << fl_name << ", fl_id:" << fl_id << ", data_size:" << data_… in CreateDeviceMetadata()
161 device_meta.set_fl_id(fl_id); in CreateDeviceMetadata()
186 …if (!DistributedCountService::GetInstance().Count(name_, start_fl_job_req->fl_id()->str(), &count_… in CountForStartFLJob()
|
| D | update_model_kernel.cc | 159 std::string update_model_fl_id = update_model_req->fl_id()->str(); in UpdateModel()
209 FLId fl_id; in UpdateModel() local
210 fl_id.set_fl_id(update_model_fl_id); in UpdateModel()
212 *comm_value.mutable_fl_id() = fl_id; in UpdateModel()
251 …if (!DistributedCountService::GetInstance().Count(name_, update_model_req->fl_id()->str(), &count_… in CountForUpdateModel()
|
| D | get_secrets_kernel.cc | 47 if (!DistributedCountService::GetInstance().Count(name_, get_secrets_req->fl_id()->str())) { in CountForGetSecrets()
|
| D | get_keys_kernel.cc | 43 if (!DistributedCountService::GetInstance().Count(name_, get_keys_req->fl_id()->str())) { in CountForGetKeys()
|
| D | share_secrets_kernel.cc | 42 if (!DistributedCountService::GetInstance().Count(name_, share_secrets_req->fl_id()->str())) { in CountForShareSecrets()
|
| D | exchange_keys_kernel.cc | 58 if (!DistributedCountService::GetInstance().Count(name_, exchange_keys_req->fl_id()->str())) { in CountForExchangeKeys()
|
| /third_party/mindspore/tests/st/fl/mobile/ |
| D | simulator.py | 58 fl_id = start_fl_job_builder.CreateString(str_fl_id)
64 RequestFLJob.RequestFLJobAddFlId(start_fl_job_builder, fl_id)
98 fl_id = builder_update_model.CreateString(str_fl_id)
113 RequestUpdateModel.RequestUpdateModelAddFlId(builder_update_model, fl_id)
|
| /third_party/mindspore/tests/st/fl/hybrid_lenet/ |
| D | simulator.py | 58 fl_id = start_fl_job_builder.CreateString(str_fl_id)
64 RequestFLJob.RequestFLJobAddFlId(start_fl_job_builder, fl_id)
98 fl_id = builder_update_model.CreateString(str_fl_id)
113 RequestUpdateModel.RequestUpdateModelAddFlId(builder_update_model, fl_id)
|
| /third_party/mindspore/mindspore/ccsrc/fl/worker/ |
| D | fl_worker.h | 92 std::string fl_id() const;
|
| D | fl_worker.cc | 180 std::string FLWorker::fl_id() const { return std::to_string(rank_id_); } in fl_id() function in mindspore::fl::worker::FLWorker
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/cpu/fl/ |
| D | start_fl_job_kernel.h | 82 fl_id_ = fl::worker::FLWorker::GetInstance().fl_id(); in Init()
|
| D | update_model_kernel.h | 94 fl_id_ = fl::worker::FLWorker::GetInstance().fl_id(); in Init()
|