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()
43 			hlist_for_each_entry_rcu(server, &net->fs_addresses6, addr6_link) {  in afs_find_server()
44 				alist = rcu_dereference(server->addresses);  in afs_find_server()
59 			hlist_for_each_entry_rcu(server, &net->fs_addresses4, addr4_link) {  in afs_find_server()
60 				alist = rcu_dereference(server->addresses);  in afs_find_server()
74 		server = NULL;  in afs_find_server()
77 		server = afs_maybe_use_server(server, afs_server_trace_get_by_addr);  in afs_find_server()
84 	return server;  in afs_find_server()
92 	struct afs_server *server = NULL;  in afs_find_server_by_uuid()  local
103 		if (server)  in afs_find_server_by_uuid()
104 			afs_unuse_server(net, server, afs_server_trace_put_uuid_rsq);  in afs_find_server_by_uuid()
105 		server = NULL;  in afs_find_server_by_uuid()
111 			server = rb_entry(p, struct afs_server, uuid_rb);  in afs_find_server_by_uuid()
113 			diff = memcmp(uuid, &server->uuid, sizeof(*uuid));  in afs_find_server_by_uuid()
119 				afs_use_server(server, afs_server_trace_get_by_uuid);  in afs_find_server_by_uuid()
123 			server = NULL;  in afs_find_server_by_uuid()
129 	_leave(" = %p", server);  in afs_find_server_by_uuid()
130 	return server;  in afs_find_server_by_uuid()
142 	struct afs_server *server, *next;  in afs_install_server()  local
157 		server = rb_entry(p, struct afs_server, uuid_rb);  in afs_install_server()
158 		diff = memcmp(&candidate->uuid, &server->uuid, sizeof(uuid_t));  in afs_install_server()
164 			if (server->cell == cell)  in afs_install_server()
172 					server->uuid_next,  in afs_install_server()
176 				server = next;  in afs_install_server()
178 			rcu_assign_pointer(server->uuid_next, candidate);  in afs_install_server()
179 			candidate->uuid_prev = server;  in afs_install_server()
180 			server = candidate;  in afs_install_server()
185 	server = candidate;  in afs_install_server()
186 	rb_link_node(&server->uuid_rb, p, pp);  in afs_install_server()
187 	rb_insert_color(&server->uuid_rb, &net->fs_servers);  in afs_install_server()
188 	hlist_add_head_rcu(&server->proc_link, &net->fs_proc);  in afs_install_server()
192 	alist = rcu_dereference_protected(server->addresses,  in afs_install_server()
204 		hlist_add_head_rcu(&server->addr4_link, &net->fs_addresses4);  in afs_install_server()
206 		hlist_add_head_rcu(&server->addr6_link, &net->fs_addresses6);  in afs_install_server()
211 	afs_get_server(server, afs_server_trace_get_install);  in afs_install_server()
213 	return server;  in afs_install_server()
223 	struct afs_server *server;  in afs_alloc_server()  local
228 	server = kzalloc(sizeof(struct afs_server), GFP_KERNEL);  in afs_alloc_server()
229 	if (!server)  in afs_alloc_server()
232 	refcount_set(&server->ref, 1);  in afs_alloc_server()
233 	atomic_set(&server->active, 1);  in afs_alloc_server()
234 	server->debug_id = atomic_inc_return(&afs_server_debug_id);  in afs_alloc_server()
235 	RCU_INIT_POINTER(server->addresses, alist);  in afs_alloc_server()
236 	server->addr_version = alist->version;  in afs_alloc_server()
237 	server->uuid = *uuid;  in afs_alloc_server()
238 	rwlock_init(&server->fs_lock);  in afs_alloc_server()
239 	INIT_WORK(&server->initcb_work, afs_server_init_callback_work);  in afs_alloc_server()
240 	init_waitqueue_head(&server->probe_wq);  in afs_alloc_server()
241 	INIT_LIST_HEAD(&server->probe_link);  in afs_alloc_server()
242 	spin_lock_init(&server->probe_lock);  in afs_alloc_server()
243 	server->cell = cell;  in afs_alloc_server()
244 	server->rtt = UINT_MAX;  in afs_alloc_server()
247 	trace_afs_server(server->debug_id, 1, 1, afs_server_trace_alloc);  in afs_alloc_server()
248 	_leave(" = %p", server);  in afs_alloc_server()
249 	return server;  in afs_alloc_server()
269 			if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags))  in afs_vl_lookup_addrs()
288 	struct afs_server *server, *candidate;  in afs_lookup_server()  local
292 	server = afs_find_server_by_uuid(cell->net, uuid);  in afs_lookup_server()
293 	if (server) {  in afs_lookup_server()
294 		if (server->addr_version != addr_version)  in afs_lookup_server()
295 			set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags);  in afs_lookup_server()
296 		return server;  in afs_lookup_server()
309 	server = afs_install_server(cell, candidate);  in afs_lookup_server()
310 	if (server != candidate) {  in afs_lookup_server()
318 		afs_fs_probe_fileserver(cell->net, server, key, true);  in afs_lookup_server()
321 	return server;  in afs_lookup_server()
353 struct afs_server *afs_get_server(struct afs_server *server,  in afs_get_server()  argument
359 	__refcount_inc(&server->ref, &r);  in afs_get_server()
360 	a = atomic_read(&server->active);  in afs_get_server()
361 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_get_server()
362 	return server;  in afs_get_server()
368 static struct afs_server *afs_maybe_use_server(struct afs_server *server,  in afs_maybe_use_server()  argument
374 	if (!__refcount_inc_not_zero(&server->ref, &r))  in afs_maybe_use_server()
377 	a = atomic_inc_return(&server->active);  in afs_maybe_use_server()
378 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_maybe_use_server()
379 	return server;  in afs_maybe_use_server()
385 struct afs_server *afs_use_server(struct afs_server *server, enum afs_server_trace reason)  in afs_use_server()  argument
390 	__refcount_inc(&server->ref, &r);  in afs_use_server()
391 	a = atomic_inc_return(&server->active);  in afs_use_server()
393 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_use_server()
394 	return server;  in afs_use_server()
400 void afs_put_server(struct afs_net *net, struct afs_server *server,  in afs_put_server()  argument
403 	unsigned int a, debug_id = server->debug_id;  in afs_put_server()
407 	if (!server)  in afs_put_server()
410 	a = atomic_read(&server->active);  in afs_put_server()
411 	zero = __refcount_dec_and_test(&server->ref, &r);  in afs_put_server()
414 		__afs_put_server(net, server);  in afs_put_server()
421 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server,  in afs_unuse_server_notime()  argument
424 	if (server) {  in afs_unuse_server_notime()
425 		unsigned int active = atomic_dec_return(&server->active);  in afs_unuse_server_notime()
429 		afs_put_server(net, server, reason);  in afs_unuse_server_notime()
436 void afs_unuse_server(struct afs_net *net, struct afs_server *server,  in afs_unuse_server()  argument
439 	if (server) {  in afs_unuse_server()
440 		server->unuse_time = ktime_get_real_seconds();  in afs_unuse_server()
441 		afs_unuse_server_notime(net, server, reason);  in afs_unuse_server()
447 	struct afs_server *server = container_of(rcu, struct afs_server, rcu);  in afs_server_rcu()  local
449 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_server_rcu()
450 			 atomic_read(&server->active), afs_server_trace_free);  in afs_server_rcu()
451 	afs_put_addrlist(rcu_access_pointer(server->addresses));  in afs_server_rcu()
452 	kfree(server);  in afs_server_rcu()
455 static void __afs_put_server(struct afs_net *net, struct afs_server *server)  in __afs_put_server()  argument
457 	call_rcu(&server->rcu, afs_server_rcu);  in __afs_put_server()
461 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server)  in afs_give_up_callbacks()  argument
463 	struct afs_addr_list *alist = rcu_access_pointer(server->addresses);  in afs_give_up_callbacks()
470 	afs_fs_give_up_all_callbacks(net, server, &ac, NULL);  in afs_give_up_callbacks()
476 static void afs_destroy_server(struct afs_net *net, struct afs_server *server)  in afs_destroy_server()  argument
478 	if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags))  in afs_destroy_server()
479 		afs_give_up_callbacks(net, server);  in afs_destroy_server()
481 	flush_work(&server->initcb_work);  in afs_destroy_server()
482 	afs_put_server(net, server, afs_server_trace_destroy);  in afs_destroy_server()
490 	struct afs_server *server, *next, *prev;  in afs_gc_servers()  local
493 	while ((server = gc_list)) {  in afs_gc_servers()
494 		gc_list = server->gc_next;  in afs_gc_servers()
498 		active = atomic_read(&server->active);  in afs_gc_servers()
500 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_gc_servers()
503 				server->uuid_next, lockdep_is_held(&net->fs_lock.lock));  in afs_gc_servers()
504 			prev = server->uuid_prev;  in afs_gc_servers()
508 					rb_erase(&server->uuid_rb, &net->fs_servers);  in afs_gc_servers()
510 					rb_replace_node_rcu(&server->uuid_rb,  in afs_gc_servers()
522 			list_del(&server->probe_link);  in afs_gc_servers()
523 			hlist_del_rcu(&server->proc_link);  in afs_gc_servers()
524 			if (!hlist_unhashed(&server->addr4_link))  in afs_gc_servers()
525 				hlist_del_rcu(&server->addr4_link);  in afs_gc_servers()
526 			if (!hlist_unhashed(&server->addr6_link))  in afs_gc_servers()
527 				hlist_del_rcu(&server->addr6_link);  in afs_gc_servers()
532 			afs_destroy_server(net, server);  in afs_gc_servers()
559 		struct afs_server *server =  in afs_manage_servers()  local
561 		int active = atomic_read(&server->active);  in afs_manage_servers()
563 		_debug("manage %pU %u", &server->uuid, active);  in afs_manage_servers()
566 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_manage_servers()
569 				pr_notice("Can't purge s=%08x\n", server->debug_id);  in afs_manage_servers()
573 			time64_t expire_at = server->unuse_time;  in afs_manage_servers()
575 			if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) &&  in afs_manage_servers()
576 			    !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags))  in afs_manage_servers()
579 				server->gc_next = gc_list;  in afs_manage_servers()
580 				gc_list = server;  in afs_manage_servers()
640 					      struct afs_server *server)  in afs_update_server_record()  argument
646 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_update_server_record()
647 			 atomic_read(&server->active),  in afs_update_server_record()
650 	alist = afs_vl_lookup_addrs(op->volume->cell, op->key, &server->uuid);  in afs_update_server_record()
655 		    server->addresses) {  in afs_update_server_record()
665 	if (server->addr_version != alist->version) {  in afs_update_server_record()
666 		write_lock(&server->fs_lock);  in afs_update_server_record()
667 		discard = rcu_dereference_protected(server->addresses,  in afs_update_server_record()
668 						    lockdep_is_held(&server->fs_lock));  in afs_update_server_record()
669 		rcu_assign_pointer(server->addresses, alist);  in afs_update_server_record()
670 		server->addr_version = alist->version;  in afs_update_server_record()
671 		write_unlock(&server->fs_lock);  in afs_update_server_record()
682 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server)  in afs_check_server_record()  argument
689 	ASSERT(server);  in afs_check_server_record()
692 	if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags))  in afs_check_server_record()
694 	if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags))  in afs_check_server_record()
700 	if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) {  in afs_check_server_record()
701 		clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags);  in afs_check_server_record()
702 		success = afs_update_server_record(op, server);  in afs_check_server_record()
703 		clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags);  in afs_check_server_record()
704 		wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING);  in afs_check_server_record()
710 	ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING,  in afs_check_server_record()