Lines Matching full:server
2 /* AFS server record management
14 static unsigned afs_server_gc_delay = 10; /* Server record timeout in seconds */
22 * Find a server by one of its addresses.
28 struct afs_server *server = NULL; in afs_find_server() local
35 if (server) in afs_find_server()
36 afs_unuse_server_notime(net, server, afs_server_trace_put_find_rsq); in afs_find_server()
37 server = NULL; in afs_find_server()
42 hlist_for_each_entry_rcu(server, &net->fs_addresses6, addr6_link) { in afs_find_server()
43 alist = rcu_dereference(server->addresses); in afs_find_server()
58 hlist_for_each_entry_rcu(server, &net->fs_addresses4, addr4_link) { in afs_find_server()
59 alist = rcu_dereference(server->addresses); in afs_find_server()
73 server = NULL; in afs_find_server()
76 server = afs_maybe_use_server(server, afs_server_trace_get_by_addr); in afs_find_server()
83 return server; in afs_find_server()
87 * Look up a server by its UUID and mark it active.
91 struct afs_server *server = NULL; in afs_find_server_by_uuid() local
102 if (server) in afs_find_server_by_uuid()
103 afs_unuse_server(net, server, afs_server_trace_put_uuid_rsq); in afs_find_server_by_uuid()
104 server = NULL; in afs_find_server_by_uuid()
110 server = rb_entry(p, struct afs_server, uuid_rb); in afs_find_server_by_uuid()
112 diff = memcmp(uuid, &server->uuid, sizeof(*uuid)); in afs_find_server_by_uuid()
118 afs_use_server(server, afs_server_trace_get_by_uuid); in afs_find_server_by_uuid()
122 server = NULL; in afs_find_server_by_uuid()
128 _leave(" = %p", server); in afs_find_server_by_uuid()
129 return server; in afs_find_server_by_uuid()
133 * Install a server record in the namespace tree. If there's a clash, we stick
141 struct afs_server *server, *next; in afs_install_server() local
150 /* Firstly install the server in the UUID lookup tree */ in afs_install_server()
156 server = rb_entry(p, struct afs_server, uuid_rb); in afs_install_server()
157 diff = memcmp(&candidate->uuid, &server->uuid, sizeof(uuid_t)); in afs_install_server()
163 if (server->cell == cell) in afs_install_server()
167 * different cells. Append the new server to the list. in afs_install_server()
171 server->uuid_next, in afs_install_server()
175 server = next; in afs_install_server()
177 rcu_assign_pointer(server->uuid_next, candidate); in afs_install_server()
178 candidate->uuid_prev = server; in afs_install_server()
179 server = candidate; in afs_install_server()
184 server = candidate; in afs_install_server()
185 rb_link_node(&server->uuid_rb, p, pp); in afs_install_server()
186 rb_insert_color(&server->uuid_rb, &net->fs_servers); in afs_install_server()
187 hlist_add_head_rcu(&server->proc_link, &net->fs_proc); in afs_install_server()
191 alist = rcu_dereference_protected(server->addresses, in afs_install_server()
194 /* Secondly, if the server has any IPv4 and/or IPv6 addresses, install in afs_install_server()
203 hlist_add_head_rcu(&server->addr4_link, &net->fs_addresses4); in afs_install_server()
205 hlist_add_head_rcu(&server->addr6_link, &net->fs_addresses6); in afs_install_server()
210 afs_get_server(server, afs_server_trace_get_install); in afs_install_server()
212 return server; in afs_install_server()
216 * Allocate a new server record and mark it active.
222 struct afs_server *server; in afs_alloc_server() local
227 server = kzalloc(sizeof(struct afs_server), GFP_KERNEL); in afs_alloc_server()
228 if (!server) in afs_alloc_server()
231 atomic_set(&server->ref, 1); in afs_alloc_server()
232 atomic_set(&server->active, 1); in afs_alloc_server()
233 server->debug_id = atomic_inc_return(&afs_server_debug_id); in afs_alloc_server()
234 RCU_INIT_POINTER(server->addresses, alist); in afs_alloc_server()
235 server->addr_version = alist->version; in afs_alloc_server()
236 server->uuid = *uuid; in afs_alloc_server()
237 rwlock_init(&server->fs_lock); in afs_alloc_server()
238 INIT_WORK(&server->initcb_work, afs_server_init_callback_work); in afs_alloc_server()
239 init_waitqueue_head(&server->probe_wq); in afs_alloc_server()
240 INIT_LIST_HEAD(&server->probe_link); in afs_alloc_server()
241 spin_lock_init(&server->probe_lock); in afs_alloc_server()
242 server->cell = cell; in afs_alloc_server()
243 server->rtt = UINT_MAX; in afs_alloc_server()
246 trace_afs_server(server, 1, 1, afs_server_trace_alloc); in afs_alloc_server()
247 _leave(" = %p", server); in afs_alloc_server()
248 return server; in afs_alloc_server()
256 * Look up an address record for a server
268 if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags)) in afs_vl_lookup_addrs()
287 struct afs_server *server, *candidate; in afs_lookup_server() local
291 server = afs_find_server_by_uuid(cell->net, uuid); in afs_lookup_server()
292 if (server) { in afs_lookup_server()
293 if (server->addr_version != addr_version) in afs_lookup_server()
294 set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_lookup_server()
295 return server; in afs_lookup_server()
308 server = afs_install_server(cell, candidate); in afs_lookup_server()
309 if (server != candidate) { in afs_lookup_server()
317 afs_fs_probe_fileserver(cell->net, server, key, true); in afs_lookup_server()
320 return server; in afs_lookup_server()
324 * Set the server timer to fire after a given delay, assuming it's not already
337 * Server management timer. We have an increment on fs_outstanding that we
350 * Get a reference on a server object.
352 struct afs_server *afs_get_server(struct afs_server *server, in afs_get_server() argument
355 unsigned int u = atomic_inc_return(&server->ref); in afs_get_server()
357 trace_afs_server(server, u, atomic_read(&server->active), reason); in afs_get_server()
358 return server; in afs_get_server()
362 * Try to get a reference on a server object.
364 static struct afs_server *afs_maybe_use_server(struct afs_server *server, in afs_maybe_use_server() argument
367 unsigned int r = atomic_fetch_add_unless(&server->ref, 1, 0); in afs_maybe_use_server()
373 a = atomic_inc_return(&server->active); in afs_maybe_use_server()
374 trace_afs_server(server, r, a, reason); in afs_maybe_use_server()
375 return server; in afs_maybe_use_server()
379 * Get an active count on a server object.
381 struct afs_server *afs_use_server(struct afs_server *server, enum afs_server_trace reason) in afs_use_server() argument
383 unsigned int r = atomic_inc_return(&server->ref); in afs_use_server()
384 unsigned int a = atomic_inc_return(&server->active); in afs_use_server()
386 trace_afs_server(server, r, a, reason); in afs_use_server()
387 return server; in afs_use_server()
391 * Release a reference on a server record.
393 void afs_put_server(struct afs_net *net, struct afs_server *server, in afs_put_server() argument
398 if (!server) in afs_put_server()
401 usage = atomic_dec_return(&server->ref); in afs_put_server()
402 trace_afs_server(server, usage, atomic_read(&server->active), reason); in afs_put_server()
404 __afs_put_server(net, server); in afs_put_server()
408 * Drop an active count on a server object without updating the last-unused
411 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server, in afs_unuse_server_notime() argument
414 if (server) { in afs_unuse_server_notime()
415 unsigned int active = atomic_dec_return(&server->active); in afs_unuse_server_notime()
419 afs_put_server(net, server, reason); in afs_unuse_server_notime()
424 * Drop an active count on a server object.
426 void afs_unuse_server(struct afs_net *net, struct afs_server *server, in afs_unuse_server() argument
429 if (server) { in afs_unuse_server()
430 server->unuse_time = ktime_get_real_seconds(); in afs_unuse_server()
431 afs_unuse_server_notime(net, server, reason); in afs_unuse_server()
437 struct afs_server *server = container_of(rcu, struct afs_server, rcu); in afs_server_rcu() local
439 trace_afs_server(server, atomic_read(&server->ref), in afs_server_rcu()
440 atomic_read(&server->active), afs_server_trace_free); in afs_server_rcu()
441 afs_put_addrlist(rcu_access_pointer(server->addresses)); in afs_server_rcu()
442 kfree(server); in afs_server_rcu()
445 static void __afs_put_server(struct afs_net *net, struct afs_server *server) in __afs_put_server() argument
447 call_rcu(&server->rcu, afs_server_rcu); in __afs_put_server()
451 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server) in afs_give_up_callbacks() argument
453 struct afs_addr_list *alist = rcu_access_pointer(server->addresses); in afs_give_up_callbacks()
460 afs_fs_give_up_all_callbacks(net, server, &ac, NULL); in afs_give_up_callbacks()
464 * destroy a dead server
466 static void afs_destroy_server(struct afs_net *net, struct afs_server *server) in afs_destroy_server() argument
468 if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags)) in afs_destroy_server()
469 afs_give_up_callbacks(net, server); in afs_destroy_server()
471 flush_work(&server->initcb_work); in afs_destroy_server()
472 afs_put_server(net, server, afs_server_trace_destroy); in afs_destroy_server()
480 struct afs_server *server, *next, *prev; in afs_gc_servers() local
483 while ((server = gc_list)) { in afs_gc_servers()
484 gc_list = server->gc_next; in afs_gc_servers()
488 active = atomic_read(&server->active); in afs_gc_servers()
490 trace_afs_server(server, atomic_read(&server->ref), in afs_gc_servers()
493 server->uuid_next, lockdep_is_held(&net->fs_lock.lock)); in afs_gc_servers()
494 prev = server->uuid_prev; in afs_gc_servers()
498 rb_erase(&server->uuid_rb, &net->fs_servers); in afs_gc_servers()
500 rb_replace_node_rcu(&server->uuid_rb, in afs_gc_servers()
506 /* This server is not at the front */ in afs_gc_servers()
512 list_del(&server->probe_link); in afs_gc_servers()
513 hlist_del_rcu(&server->proc_link); in afs_gc_servers()
514 if (!hlist_unhashed(&server->addr4_link)) in afs_gc_servers()
515 hlist_del_rcu(&server->addr4_link); in afs_gc_servers()
516 if (!hlist_unhashed(&server->addr6_link)) in afs_gc_servers()
517 hlist_del_rcu(&server->addr6_link); in afs_gc_servers()
522 afs_destroy_server(net, server); in afs_gc_servers()
543 /* Trawl the server list looking for servers that have expired from in afs_manage_servers()
549 struct afs_server *server = in afs_manage_servers() local
551 int active = atomic_read(&server->active); in afs_manage_servers()
553 _debug("manage %pU %u", &server->uuid, active); in afs_manage_servers()
556 trace_afs_server(server, atomic_read(&server->ref), in afs_manage_servers()
559 pr_notice("Can't purge s=%08x\n", server->debug_id); in afs_manage_servers()
563 time64_t expire_at = server->unuse_time; in afs_manage_servers()
565 if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) && in afs_manage_servers()
566 !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags)) in afs_manage_servers()
569 server->gc_next = gc_list; in afs_manage_servers()
570 gc_list = server; in afs_manage_servers()
627 * Get an update for a server's address list.
630 struct afs_server *server) in afs_update_server_record() argument
636 trace_afs_server(server, atomic_read(&server->ref), atomic_read(&server->active), in afs_update_server_record()
639 alist = afs_vl_lookup_addrs(op->volume->cell, op->key, &server->uuid); in afs_update_server_record()
644 server->addresses) { in afs_update_server_record()
654 if (server->addr_version != alist->version) { in afs_update_server_record()
655 write_lock(&server->fs_lock); in afs_update_server_record()
656 discard = rcu_dereference_protected(server->addresses, in afs_update_server_record()
657 lockdep_is_held(&server->fs_lock)); in afs_update_server_record()
658 rcu_assign_pointer(server->addresses, alist); in afs_update_server_record()
659 server->addr_version = alist->version; in afs_update_server_record()
660 write_unlock(&server->fs_lock); in afs_update_server_record()
669 * See if a server's address list needs updating.
671 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server) in afs_check_server_record() argument
678 ASSERT(server); in afs_check_server_record()
681 if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags)) in afs_check_server_record()
683 if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags)) in afs_check_server_record()
689 if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) { in afs_check_server_record()
690 clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags); in afs_check_server_record()
691 success = afs_update_server_record(op, server); in afs_check_server_record()
692 clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags); in afs_check_server_record()
693 wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING); in afs_check_server_record()
699 ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING, in afs_check_server_record()