Lines Matching +full:1 +full:- +full:cell
1 // SPDX-License-Identifier: GPL-2.0-or-later
35 * cell->fs_lock.
37 static struct afs_server *afs_find_server_by_uuid(struct afs_cell *cell, const uuid_t *uuid) in afs_find_server_by_uuid() argument
45 p = cell->fs_servers.rb_node; in afs_find_server_by_uuid()
49 diff = memcmp(uuid, &server->uuid, sizeof(*uuid)); in afs_find_server_by_uuid()
51 p = p->rb_left; in afs_find_server_by_uuid()
53 p = p->rb_right; in afs_find_server_by_uuid()
55 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) in afs_find_server_by_uuid()
66 * Install a server record in the cell tree. The caller must hold an exclusive
67 * lock on cell->fs_lock.
69 static struct afs_server *afs_install_server(struct afs_cell *cell, in afs_install_server() argument
73 struct afs_net *net = cell->net; in afs_install_server()
80 pp = &cell->fs_servers.rb_node; in afs_install_server()
84 _debug("- consider %p", p); in afs_install_server()
86 diff = memcmp(&(*candidate)->uuid, &server->uuid, sizeof(uuid_t)); in afs_install_server()
88 pp = &(*pp)->rb_left; in afs_install_server()
90 pp = &(*pp)->rb_right; in afs_install_server()
97 rb_link_node(&server->uuid_rb, p, pp); in afs_install_server()
98 rb_insert_color(&server->uuid_rb, &cell->fs_servers); in afs_install_server()
99 write_seqlock(&net->fs_lock); in afs_install_server()
100 hlist_add_head_rcu(&server->proc_link, &net->fs_proc); in afs_install_server()
101 write_sequnlock(&net->fs_lock); in afs_install_server()
103 afs_get_cell(cell, afs_cell_trace_get_server); in afs_install_server()
113 static struct afs_server *afs_alloc_server(struct afs_cell *cell, const uuid_t *uuid) in afs_alloc_server() argument
116 struct afs_net *net = cell->net; in afs_alloc_server()
124 refcount_set(&server->ref, 1); in afs_alloc_server()
125 atomic_set(&server->active, 0); in afs_alloc_server()
126 __set_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_alloc_server()
127 server->debug_id = atomic_inc_return(&afs_server_debug_id); in afs_alloc_server()
128 server->uuid = *uuid; in afs_alloc_server()
129 rwlock_init(&server->fs_lock); in afs_alloc_server()
130 INIT_WORK(&server->destroyer, &afs_server_destroyer); in afs_alloc_server()
131 timer_setup(&server->timer, afs_server_timer, 0); in afs_alloc_server()
132 INIT_LIST_HEAD(&server->volumes); in afs_alloc_server()
133 init_waitqueue_head(&server->probe_wq); in afs_alloc_server()
134 INIT_LIST_HEAD(&server->probe_link); in afs_alloc_server()
135 INIT_HLIST_NODE(&server->proc_link); in afs_alloc_server()
136 spin_lock_init(&server->probe_lock); in afs_alloc_server()
137 server->cell = cell; in afs_alloc_server()
138 server->rtt = UINT_MAX; in afs_alloc_server()
139 server->service_id = FS_SERVICE; in afs_alloc_server()
140 server->probe_counter = 1; in afs_alloc_server()
141 server->probed_at = jiffies - LONG_MAX / 2; in afs_alloc_server()
158 ret = -ERESTARTSYS; in afs_vl_lookup_addrs()
159 if (afs_begin_vlserver_operation(&vc, server->cell, key)) { in afs_vl_lookup_addrs()
161 if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags)) in afs_vl_lookup_addrs()
162 alist = afs_yfsvl_get_endpoints(&vc, &server->uuid); in afs_vl_lookup_addrs()
164 alist = afs_vl_get_addrs_u(&vc, &server->uuid); in afs_vl_lookup_addrs()
174 * Get or create a fileserver record and return it with an active-use count on
177 struct afs_server *afs_lookup_server(struct afs_cell *cell, struct key *key, in afs_lookup_server() argument
185 _enter("%p,%pU", cell->net, uuid); in afs_lookup_server()
187 down_read(&cell->fs_lock); in afs_lookup_server()
188 server = afs_find_server_by_uuid(cell, uuid); in afs_lookup_server()
190 up_read(&cell->fs_lock); in afs_lookup_server()
193 timer_delete_sync(&server->timer); in afs_lookup_server()
194 if (test_bit(AFS_SERVER_FL_CREATING, &server->flags)) in afs_lookup_server()
196 if (server->addr_version != addr_version) in afs_lookup_server()
197 set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_lookup_server()
201 candidate = afs_alloc_server(cell, uuid); in afs_lookup_server()
204 return ERR_PTR(-ENOMEM); in afs_lookup_server()
207 down_write(&cell->fs_lock); in afs_lookup_server()
208 server = afs_install_server(cell, &candidate); in afs_lookup_server()
209 if (test_bit(AFS_SERVER_FL_CREATING, &server->flags)) { in afs_lookup_server()
211 up_write(&cell->fs_lock); in afs_lookup_server()
214 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
215 set_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
216 clear_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
219 up_write(&cell->fs_lock); in afs_lookup_server()
220 timer_delete_sync(&server->timer); in afs_lookup_server()
224 * fileserver. This will make sure the repeat-probing service is in afs_lookup_server()
234 ret = afs_fs_probe_fileserver(cell->net, server, alist, key); in afs_lookup_server()
238 clear_and_wake_up_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
244 kfree(rcu_access_pointer(server->endpoint_state)); in afs_lookup_server()
246 afs_dec_servers_outstanding(cell->net); in afs_lookup_server()
252 wait_on_bit(&server->flags, AFS_SERVER_FL_CREATING, TASK_UNINTERRUPTIBLE); in afs_lookup_server()
253 if (test_bit_acquire(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
255 ret = READ_ONCE(server->create_error); in afs_lookup_server()
256 afs_put_server(cell->net, server, afs_server_trace_unuse_create_fail); in afs_lookup_server()
265 down_write(&cell->fs_lock); in afs_lookup_server()
267 WRITE_ONCE(server->create_error, ret); in afs_lookup_server()
269 set_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
271 clear_and_wake_up_bit(AFS_SERVER_FL_CREATING, &server->flags); in afs_lookup_server()
273 if (test_bit(AFS_SERVER_FL_UNCREATED, &server->flags)) { in afs_lookup_server()
274 clear_bit(AFS_SERVER_FL_UNCREATED, &server->flags); in afs_lookup_server()
277 afs_unuse_server(cell->net, server, afs_server_trace_unuse_create_fail); in afs_lookup_server()
280 up_write(&cell->fs_lock); in afs_lookup_server()
289 mod_timer(&server->timer, jiffies + delay_secs * HZ); in afs_set_server_timer()
301 __refcount_inc(&server->ref, &r); in afs_get_server()
302 a = atomic_read(&server->active); in afs_get_server()
303 trace_afs_server(server->debug_id, r + 1, a, reason); in afs_get_server()
317 __refcount_inc(&server->ref, &r); in afs_use_server()
318 a = atomic_inc_return(&server->active); in afs_use_server()
319 if (a == 1 && activate && in afs_use_server()
320 !test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_use_server()
321 timer_delete(&server->timer); in afs_use_server()
323 trace_afs_server(server->debug_id, r + 1, a, reason); in afs_use_server()
333 unsigned int a, debug_id = server->debug_id; in afs_put_server()
340 a = atomic_read(&server->active); in afs_put_server()
341 zero = __refcount_dec_and_test(&server->ref, &r); in afs_put_server()
342 trace_afs_server(debug_id, r - 1, a, reason); in afs_put_server()
348 * Drop an active count on a server object without updating the last-unused
357 if (atomic_dec_and_test(&server->active)) { in afs_unuse_server_notime()
358 if (test_bit(AFS_SERVER_FL_EXPIRED, &server->flags) || in afs_unuse_server_notime()
359 READ_ONCE(server->cell->state) >= AFS_CELL_REMOVING) in afs_unuse_server_notime()
360 schedule_work(&server->destroyer); in afs_unuse_server_notime()
375 if (atomic_dec_and_test(&server->active)) { in afs_unuse_server()
376 if (!test_bit(AFS_SERVER_FL_EXPIRED, &server->flags) && in afs_unuse_server()
377 READ_ONCE(server->cell->state) < AFS_CELL_REMOVING) { in afs_unuse_server()
380 server->unuse_time = unuse_time; in afs_unuse_server()
383 schedule_work(&server->destroyer); in afs_unuse_server()
394 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_server_rcu()
395 atomic_read(&server->active), afs_server_trace_free); in afs_server_rcu()
396 afs_put_endpoint_state(rcu_access_pointer(server->endpoint_state), in afs_server_rcu()
398 afs_put_cell(server->cell, afs_cell_trace_put_server); in afs_server_rcu()
404 call_rcu(&server->rcu, afs_server_rcu); in __afs_put_server()
410 struct afs_endpoint_state *estate = rcu_access_pointer(server->endpoint_state); in afs_give_up_callbacks()
411 struct afs_addr_list *alist = estate->addresses; in afs_give_up_callbacks()
413 afs_fs_give_up_all_callbacks(net, server, &alist->addrs[alist->preferred], NULL); in afs_give_up_callbacks()
423 if (atomic_read(&server->active)) in afs_has_server_expired()
426 if (server->cell->net->live || in afs_has_server_expired()
427 server->cell->state >= AFS_CELL_REMOVING) { in afs_has_server_expired()
428 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_has_server_expired()
433 expires_at = server->unuse_time; in afs_has_server_expired()
434 if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) && in afs_has_server_expired()
435 !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags)) in afs_has_server_expired()
442 * Remove a server record from it's parent cell's database.
446 struct afs_cell *cell = server->cell; in afs_remove_server_from_cell() local
448 down_write(&cell->fs_lock); in afs_remove_server_from_cell()
451 up_write(&cell->fs_lock); in afs_remove_server_from_cell()
455 set_bit(AFS_SERVER_FL_EXPIRED, &server->flags); in afs_remove_server_from_cell()
456 _debug("expire %pU %u", &server->uuid, atomic_read(&server->active)); in afs_remove_server_from_cell()
458 rb_erase(&server->uuid_rb, &cell->fs_servers); in afs_remove_server_from_cell()
459 up_write(&cell->fs_lock); in afs_remove_server_from_cell()
467 struct afs_net *net = server->cell->net; in afs_server_destroyer()
471 if (test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_server_destroyer()
477 timer_shutdown_sync(&server->timer); in afs_server_destroyer()
478 cancel_work(&server->destroyer); in afs_server_destroyer()
480 if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags)) in afs_server_destroyer()
484 estate = rcu_access_pointer(server->endpoint_state); in afs_server_destroyer()
486 afs_set_peer_appdata(server, estate->addresses, NULL); in afs_server_destroyer()
488 write_seqlock(&net->fs_lock); in afs_server_destroyer()
489 list_del_init(&server->probe_link); in afs_server_destroyer()
490 if (!hlist_unhashed(&server->proc_link)) in afs_server_destroyer()
491 hlist_del_rcu(&server->proc_link); in afs_server_destroyer()
492 write_sequnlock(&net->fs_lock); in afs_server_destroyer()
502 if (!test_bit(AFS_SERVER_FL_EXPIRED, &server->flags)) in afs_server_timer()
503 schedule_work(&server->destroyer); in afs_server_timer()
507 * Wake up all the servers in a cell so that they can purge themselves.
509 void afs_purge_servers(struct afs_cell *cell) in afs_purge_servers() argument
514 down_read(&cell->fs_lock); in afs_purge_servers()
515 for (rb = rb_first(&cell->fs_servers); rb; rb = rb_next(rb)) { in afs_purge_servers()
518 schedule_work(&server->destroyer); in afs_purge_servers()
520 up_read(&cell->fs_lock); in afs_purge_servers()
530 atomic_dec(&net->servers_outstanding); in afs_wait_for_servers()
531 wait_var_event(&net->servers_outstanding, in afs_wait_for_servers()
532 !atomic_read(&net->servers_outstanding)); in afs_wait_for_servers()
549 trace_afs_server(server->debug_id, refcount_read(&server->ref), in afs_update_server_record()
550 atomic_read(&server->active), in afs_update_server_record()
553 alist = afs_vl_lookup_addrs(server, op->key); in afs_update_server_record()
556 estate = rcu_dereference(server->endpoint_state); in afs_update_server_record()
557 has_addrs = estate->addresses; in afs_update_server_record()
560 if ((PTR_ERR(alist) == -ERESTARTSYS || in afs_update_server_record()
561 PTR_ERR(alist) == -EINTR) && in afs_update_server_record()
562 (op->flags & AFS_OPERATION_UNINTR) && in afs_update_server_record()
572 if (server->addr_version != alist->version) in afs_update_server_record()
573 afs_fs_probe_fileserver(op->net, server, alist, key); in afs_update_server_record()
594 if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags)) in afs_check_server_record()
596 if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags)) in afs_check_server_record()
602 if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) { in afs_check_server_record()
603 clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_check_server_record()
605 clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags); in afs_check_server_record()
606 wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING); in afs_check_server_record()
612 ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING, in afs_check_server_record()
613 (op->flags & AFS_OPERATION_UNINTR) ? in afs_check_server_record()
615 if (ret == -ERESTARTSYS) { in afs_check_server_record()
624 ret = -ESTALE; in afs_check_server_record()