| /third_party/mindspore/mindspore/ccsrc/fl/server/kernel/round/ |
| D | client_list_kernel.cc | 44 std::vector<string> client_list; in DealClient() local
56 const UpdateModelClientList &client_list_pb = client_list_pb_out.client_list(); in DealClient()
58 client_list.push_back(client_list_pb.fl_id(SizeToInt(i))); in DealClient()
60 if (static_cast<uint64_t>(client_list.size()) < update_model_client_needed) { in DealClient()
68 …if (find(client_list.begin(), client_list.end(), fl_id) == client_list.end()) { // client not in … in DealClient()
94 for (size_t i = 0; i < client_list.size(); ++i) { in DealClient()
95 MS_LOG(INFO) << " fl_id : " << client_list[i]; in DealClient()
98 BuildClientListRsp(fbb, schema::ResponseCode_SUCCEED, "send clients_list succeed!", client_list, in DealClient()
123 std::vector<string> client_list; in Launch() local
129 BuildClientListRsp(fbb, schema::ResponseCode_OutOfTime, "iter num is error.", client_list, in Launch()
|
| D | update_model_kernel.cc | 39 PBMetadata client_list; in InitKernel() local
40 DistributedMetadataStore::GetInstance().RegisterMetadata(kCtxUpdateModelClientList, client_list); in InitKernel()
|
| D | reconstruct_secrets_kernel.cc | 74 const UpdateModelClientList &update_model_clients_pb = update_model_clients_pb_out.client_list(); in Launch()
|
| /third_party/mindspore/mindspore/ccsrc/fl/armour/cipher/ |
| D | cipher_reconstruct.cc | 30 const std::vector<string> &client_list, in CombineMask() argument
45 if (find(client_list.begin(), client_list.end(), fl_id) != client_list.end()) { in CombineMask()
133 bool CipherReconStruct::ReconstructSecretsGenNoise(const std::vector<string> &client_list) { in ReconstructSecretsGenNoise() argument
180 client_list, client_ivs); in ReconstructSecretsGenNoise()
224 const std::vector<std::string> &client_list) { in ReconstructSecrets() argument
240 if (client_list.size() < cipher_init_->reconstruct_secrets_threshold) { in ReconstructSecrets()
241 MS_LOG(ERROR) << "illegal parameters. update model client_list size: " << client_list.size(); in ReconstructSecrets()
257 if (find(client_list.begin(), client_list.end(), fl_id) != client_list.end()) { in ReconstructSecrets()
307 if (ReconstructSecretsGenNoise(client_list)) { in ReconstructSecrets()
|
| D | cipher_reconstruct.h | 51 const std::vector<std::string> &client_list);
77 bool ReconstructSecretsGenNoise(const std::vector<string> &client_list);
86 const std::vector<string> &client_list,
|
| D | cipher_keys.cc | 98 std::vector<std::string> client_list; in ExchangeKeys() local
99 …cipher_meta_storage_.GetClientListFromServer(fl::server::kCtxExChangeKeysClientList, &client_list); in ExchangeKeys()
103 size_t cur_clients_num = client_list.size(); in ExchangeKeys()
|
| D | cipher_meta_storage.cc | 54 const fl::UpdateModelClientList &client_list_pb = client_list_pb_out.client_list(); in GetClientListFromServer()
|
| /third_party/wayland_standard/tests/ |
| D | compositor-introspection-test.c | 64 struct wl_list *client_list; in check_client_list() local
68 client_list = wl_display_get_client_list(compositor->display); in check_client_list()
69 wl_client_for_each(client_it, client_list) { in check_client_list()
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | distributed_metadata_store.cc | 241 auto client_list = metadata_[name].mutable_client_list(); in DoUpdateMetadata() local
245 for (int i = 0; i < client_list->fl_id_size(); i++) { in DoUpdateMetadata()
246 if (fl_id == client_list->fl_id(i)) { in DoUpdateMetadata()
252 client_list->add_fl_id(fl_id); in DoUpdateMetadata()
|
| /third_party/wayland_standard/src/ |
| D | wayland-server.c | 97 struct wl_list client_list; member
550 wl_list_insert(display->client_list.prev, &client->link); in wl_client_create()
1064 wl_list_init(&display->client_list); in wl_display_create()
1361 wl_list_for_each_safe(client, next, &display->client_list, link) { in wl_display_flush_clients()
1393 wl_list_insert_list(&tmp_client_list, &display->client_list); in wl_display_destroy_clients()
1394 wl_list_init(&display->client_list); in wl_display_destroy_clients()
1405 if (!wl_list_empty(&display->client_list)) { in wl_display_destroy_clients()
1937 return &display->client_list; in wl_display_get_client_list()
|
| /third_party/libwebsockets/lib/secure-streams/ |
| D | secure-streams-client.c | 680 lws_dll2_add_head(&h->client_list, &context->pt[tsi].ss_client_owner); in lws_sspc_create()
702 lws_sspc_handle_t *h = lws_container_of(d, lws_sspc_handle_t, client_list); in lws_sspc_destroy_dll()
763 lws_dll2_remove(&h->client_list); in lws_sspc_destroy()
1103 lws_sspc_handle_t *h = lws_container_of(d, lws_sspc_handle_t, client_list); in lws_sspc_cancel_notify_dll()
|
| D | private-lib-secure-streams.h | 314 struct lws_dll2 client_list; member
|
| /third_party/weston/desktop-shell/ |
| D | shell.h | 183 struct wl_list client_list; member
|
| D | shell.c | 5185 wl_list_init(&shell->workspaces.client_list); in wet_shell_init()
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/protos/ |
| D | fl.proto | 148 UpdateModelClientList client_list = 4; field
|
| /third_party/grpc/src/core/tsi/ |
| D | ssl_transport_security.cc | 1665 const unsigned char* client_list, in select_protocol_list() argument
1669 const unsigned char* client_current = client_list; in select_protocol_list()
1670 while (static_cast<unsigned int>(client_current - client_list) < in select_protocol_list()
|