Lines Matching +full:one +full:- +full:cell
1 // SPDX-License-Identifier: GPL-2.0-or-later
16 if (slist && refcount_dec_and_test(&slist->usage)) { in afs_put_serverlist()
17 for (i = 0; i < slist->nr_servers; i++) in afs_put_serverlist()
18 afs_unuse_server(net, slist->servers[i].server, in afs_put_serverlist()
33 unsigned int type_mask = 1 << volume->type; in afs_alloc_server_list()
35 int ret = -ENOMEM, nr_servers = 0, newrep = 0, i, j, usable = 0; in afs_alloc_server_list()
37 /* Work out if we're going to restrict to NEWREPSITE-marked servers or in afs_alloc_server_list()
38 * not. If at least one site is marked as NEWREPSITE, then it's likely in afs_alloc_server_list()
39 * that "vos release" is busy updating RO sites. We cut over from one in afs_alloc_server_list()
43 for (i = 0; i < vldb->nr_servers; i++) { in afs_alloc_server_list()
44 if (!(vldb->fs_mask[i] & type_mask)) in afs_alloc_server_list()
47 if (vldb->vlsf_flags[i] & AFS_VLSF_DONTUSE) in afs_alloc_server_list()
50 if (vldb->vlsf_flags[i] & AFS_VLSF_NEWREPSITE) in afs_alloc_server_list()
60 slist->ro_replicating = AFS_RO_REPLICATING_USE_OLD; in afs_alloc_server_list()
62 slist->ro_replicating = AFS_RO_REPLICATING_USE_NEW; in afs_alloc_server_list()
67 refcount_set(&slist->usage, 1); in afs_alloc_server_list()
68 rwlock_init(&slist->lock); in afs_alloc_server_list()
71 for (i = 0; i < vldb->nr_servers; i++) { in afs_alloc_server_list()
73 bool newrepsite = vldb->vlsf_flags[i] & AFS_VLSF_NEWREPSITE; in afs_alloc_server_list()
75 if (!(vldb->fs_mask[i] & type_mask)) in afs_alloc_server_list()
77 if (vldb->vlsf_flags[i] & AFS_VLSF_DONTUSE) in afs_alloc_server_list()
82 server = afs_lookup_server(volume->cell, key, &vldb->fs_server[i], in afs_alloc_server_list()
83 vldb->addr_version[i]); in afs_alloc_server_list()
86 if (ret == -ENOENT || in afs_alloc_server_list()
87 ret == -ENOMEDIUM) in afs_alloc_server_list()
92 /* Insertion-sort by UUID */ in afs_alloc_server_list()
93 for (j = 0; j < slist->nr_servers; j++) in afs_alloc_server_list()
94 if (memcmp(&slist->servers[j].server->uuid, in afs_alloc_server_list()
95 &server->uuid, in afs_alloc_server_list()
96 sizeof(server->uuid)) >= 0) in afs_alloc_server_list()
98 if (j < slist->nr_servers) { in afs_alloc_server_list()
99 if (slist->servers[j].server == server) { in afs_alloc_server_list()
100 afs_unuse_server_notime(volume->cell->net, server, in afs_alloc_server_list()
105 memmove(slist->servers + j + 1, in afs_alloc_server_list()
106 slist->servers + j, in afs_alloc_server_list()
107 (slist->nr_servers - j) * sizeof(struct afs_server_entry)); in afs_alloc_server_list()
110 slist->servers[j].server = server; in afs_alloc_server_list()
111 slist->servers[j].volume = volume; in afs_alloc_server_list()
112 slist->servers[j].flags = se_flags; in afs_alloc_server_list()
113 slist->servers[j].cb_expires_at = AFS_NO_CB_PROMISE; in afs_alloc_server_list()
114 slist->nr_servers++; in afs_alloc_server_list()
117 if (slist->nr_servers == 0) { in afs_alloc_server_list()
118 ret = -EDESTADDRREQ; in afs_alloc_server_list()
125 afs_put_serverlist(volume->cell->net, slist); in afs_alloc_server_list()
139 if (old->nr_servers != new->nr_servers || in afs_annotate_server_list()
140 old->ro_replicating != new->ro_replicating) in afs_annotate_server_list()
143 for (i = 0; i < old->nr_servers; i++) { in afs_annotate_server_list()
144 if (old->servers[i].server != new->servers[i].server) in afs_annotate_server_list()
146 if ((old->servers[i].flags & mask) != (new->servers[i].flags & mask)) in afs_annotate_server_list()
164 down_write(&volume->cell->vs_lock); in afs_attach_volume_to_servers()
166 for (i = 0; i < slist->nr_servers; i++) { in afs_attach_volume_to_servers()
167 se = &slist->servers[i]; in afs_attach_volume_to_servers()
168 server = se->server; in afs_attach_volume_to_servers()
170 list_for_each(p, &server->volumes) { in afs_attach_volume_to_servers()
172 if (volume->vid <= pe->volume->vid) in afs_attach_volume_to_servers()
175 list_add_tail(&se->slink, p); in afs_attach_volume_to_servers()
178 slist->attached = true; in afs_attach_volume_to_servers()
179 up_write(&volume->cell->vs_lock); in afs_attach_volume_to_servers()
192 down_write(&volume->cell->vs_lock); in afs_reattach_volume_to_servers()
194 while (n < new->nr_servers || o < old->nr_servers) { in afs_reattach_volume_to_servers()
195 struct afs_server_entry *pn = n < new->nr_servers ? &new->servers[n] : NULL; in afs_reattach_volume_to_servers()
196 struct afs_server_entry *po = o < old->nr_servers ? &old->servers[o] : NULL; in afs_reattach_volume_to_servers()
201 if (pn && po && pn->server == po->server) { in afs_reattach_volume_to_servers()
202 pn->cb_expires_at = po->cb_expires_at; in afs_reattach_volume_to_servers()
203 list_replace(&po->slink, &pn->slink); in afs_reattach_volume_to_servers()
210 diff = memcmp(&pn->server->uuid, &po->server->uuid, in afs_reattach_volume_to_servers()
211 sizeof(pn->server->uuid)); in afs_reattach_volume_to_servers()
213 diff = pn ? -1 : 1; in afs_reattach_volume_to_servers()
216 list_for_each(p, &pn->server->volumes) { in afs_reattach_volume_to_servers()
218 if (volume->vid <= s->volume->vid) in afs_reattach_volume_to_servers()
221 list_add_tail(&pn->slink, p); in afs_reattach_volume_to_servers()
224 list_del(&po->slink); in afs_reattach_volume_to_servers()
229 up_write(&volume->cell->vs_lock); in afs_reattach_volume_to_servers()
239 if (!slist->attached) in afs_detach_volume_from_servers()
242 down_write(&volume->cell->vs_lock); in afs_detach_volume_from_servers()
244 for (i = 0; i < slist->nr_servers; i++) in afs_detach_volume_from_servers()
245 list_del(&slist->servers[i].slink); in afs_detach_volume_from_servers()
247 slist->attached = false; in afs_detach_volume_from_servers()
248 up_write(&volume->cell->vs_lock); in afs_detach_volume_from_servers()