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()
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()
141 	struct afs_server *server, *next;  in afs_install_server()  local
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()
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()
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()
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 	refcount_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->debug_id, 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()
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()
352 struct afs_server *afs_get_server(struct afs_server *server,  in afs_get_server()  argument
358 	__refcount_inc(&server->ref, &r);  in afs_get_server()
359 	a = atomic_read(&server->active);  in afs_get_server()
360 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_get_server()
361 	return server;  in afs_get_server()
367 static struct afs_server *afs_maybe_use_server(struct afs_server *server,  in afs_maybe_use_server()  argument
373 	if (!__refcount_inc_not_zero(&server->ref, &r))  in afs_maybe_use_server()
376 	a = atomic_inc_return(&server->active);  in afs_maybe_use_server()
377 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_maybe_use_server()
378 	return server;  in afs_maybe_use_server()
384 struct afs_server *afs_use_server(struct afs_server *server, enum afs_server_trace reason)  in afs_use_server()  argument
389 	__refcount_inc(&server->ref, &r);  in afs_use_server()
390 	a = atomic_inc_return(&server->active);  in afs_use_server()
392 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_use_server()
393 	return server;  in afs_use_server()
399 void afs_put_server(struct afs_net *net, struct afs_server *server,  in afs_put_server()  argument
402 	unsigned int a, debug_id = server->debug_id;  in afs_put_server()
406 	if (!server)  in afs_put_server()
409 	a = atomic_read(&server->active);  in afs_put_server()
410 	zero = __refcount_dec_and_test(&server->ref, &r);  in afs_put_server()
413 		__afs_put_server(net, server);  in afs_put_server()
420 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server,  in afs_unuse_server_notime()  argument
423 	if (server) {  in afs_unuse_server_notime()
424 		unsigned int active = atomic_dec_return(&server->active);  in afs_unuse_server_notime()
428 		afs_put_server(net, server, reason);  in afs_unuse_server_notime()
435 void afs_unuse_server(struct afs_net *net, struct afs_server *server,  in afs_unuse_server()  argument
438 	if (server) {  in afs_unuse_server()
439 		server->unuse_time = ktime_get_real_seconds();  in afs_unuse_server()
440 		afs_unuse_server_notime(net, server, reason);  in afs_unuse_server()
446 	struct afs_server *server = container_of(rcu, struct afs_server, rcu);  in afs_server_rcu()  local
448 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_server_rcu()
449 			 atomic_read(&server->active), afs_server_trace_free);  in afs_server_rcu()
450 	afs_put_addrlist(rcu_access_pointer(server->addresses));  in afs_server_rcu()
451 	kfree(server);  in afs_server_rcu()
454 static void __afs_put_server(struct afs_net *net, struct afs_server *server)  in __afs_put_server()  argument
456 	call_rcu(&server->rcu, afs_server_rcu);  in __afs_put_server()
460 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server)  in afs_give_up_callbacks()  argument
462 	struct afs_addr_list *alist = rcu_access_pointer(server->addresses);  in afs_give_up_callbacks()
469 	afs_fs_give_up_all_callbacks(net, server, &ac, NULL);  in afs_give_up_callbacks()
475 static void afs_destroy_server(struct afs_net *net, struct afs_server *server)  in afs_destroy_server()  argument
477 	if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags))  in afs_destroy_server()
478 		afs_give_up_callbacks(net, server);  in afs_destroy_server()
480 	flush_work(&server->initcb_work);  in afs_destroy_server()
481 	afs_put_server(net, server, afs_server_trace_destroy);  in afs_destroy_server()
489 	struct afs_server *server, *next, *prev;  in afs_gc_servers()  local
492 	while ((server = gc_list)) {  in afs_gc_servers()
493 		gc_list = server->gc_next;  in afs_gc_servers()
497 		active = atomic_read(&server->active);  in afs_gc_servers()
499 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_gc_servers()
502 				server->uuid_next, lockdep_is_held(&net->fs_lock.lock));  in afs_gc_servers()
503 			prev = server->uuid_prev;  in afs_gc_servers()
507 					rb_erase(&server->uuid_rb, &net->fs_servers);  in afs_gc_servers()
509 					rb_replace_node_rcu(&server->uuid_rb,  in afs_gc_servers()
521 			list_del(&server->probe_link);  in afs_gc_servers()
522 			hlist_del_rcu(&server->proc_link);  in afs_gc_servers()
523 			if (!hlist_unhashed(&server->addr4_link))  in afs_gc_servers()
524 				hlist_del_rcu(&server->addr4_link);  in afs_gc_servers()
525 			if (!hlist_unhashed(&server->addr6_link))  in afs_gc_servers()
526 				hlist_del_rcu(&server->addr6_link);  in afs_gc_servers()
531 			afs_destroy_server(net, server);  in afs_gc_servers()
558 		struct afs_server *server =  in afs_manage_servers()  local
560 		int active = atomic_read(&server->active);  in afs_manage_servers()
562 		_debug("manage %pU %u", &server->uuid, active);  in afs_manage_servers()
565 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_manage_servers()
568 				pr_notice("Can't purge s=%08x\n", server->debug_id);  in afs_manage_servers()
572 			time64_t expire_at = server->unuse_time;  in afs_manage_servers()
574 			if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) &&  in afs_manage_servers()
575 			    !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags))  in afs_manage_servers()
578 				server->gc_next = gc_list;  in afs_manage_servers()
579 				gc_list = server;  in afs_manage_servers()
639 					      struct afs_server *server)  in afs_update_server_record()  argument
645 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_update_server_record()
646 			 atomic_read(&server->active),  in afs_update_server_record()
649 	alist = afs_vl_lookup_addrs(op->volume->cell, op->key, &server->uuid);  in afs_update_server_record()
654 		    server->addresses) {  in afs_update_server_record()
664 	if (server->addr_version != alist->version) {  in afs_update_server_record()
665 		write_lock(&server->fs_lock);  in afs_update_server_record()
666 		discard = rcu_dereference_protected(server->addresses,  in afs_update_server_record()
667 						    lockdep_is_held(&server->fs_lock));  in afs_update_server_record()
668 		rcu_assign_pointer(server->addresses, alist);  in afs_update_server_record()
669 		server->addr_version = alist->version;  in afs_update_server_record()
670 		write_unlock(&server->fs_lock);  in afs_update_server_record()
681 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server)  in afs_check_server_record()  argument
688 	ASSERT(server);  in afs_check_server_record()
691 	if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags))  in afs_check_server_record()
693 	if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags))  in afs_check_server_record()
699 	if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) {  in afs_check_server_record()
700 		clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags);  in afs_check_server_record()
701 		success = afs_update_server_record(op, server);  in afs_check_server_record()
702 		clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags);  in afs_check_server_record()
703 		wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING);  in afs_check_server_record()
709 	ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING,  in afs_check_server_record()