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()
41 		hlist_for_each_entry_rcu(server, &net->fs_addresses, addr_link) {  in afs_find_server()
42 			estate = rcu_dereference(server->endpoint_state);  in afs_find_server()
49 		server = NULL;  in afs_find_server()
52 		server = afs_maybe_use_server(server, afs_server_trace_get_by_addr);  in afs_find_server()
59 	return server;  in afs_find_server()
67 	struct afs_server *server = NULL;  in afs_find_server_by_uuid()  local
78 		if (server)  in afs_find_server_by_uuid()
79 			afs_unuse_server(net, server, afs_server_trace_put_uuid_rsq);  in afs_find_server_by_uuid()
80 		server = NULL;  in afs_find_server_by_uuid()
86 			server = rb_entry(p, struct afs_server, uuid_rb);  in afs_find_server_by_uuid()
88 			diff = memcmp(uuid, &server->uuid, sizeof(*uuid));  in afs_find_server_by_uuid()
94 				afs_use_server(server, afs_server_trace_get_by_uuid);  in afs_find_server_by_uuid()
98 			server = NULL;  in afs_find_server_by_uuid()
104 	_leave(" = %p", server);  in afs_find_server_by_uuid()
105 	return server;  in afs_find_server_by_uuid()
118 	struct afs_server *server, *next;  in afs_install_server()  local
133 		server = rb_entry(p, struct afs_server, uuid_rb);  in afs_install_server()
134 		diff = memcmp(&candidate->uuid, &server->uuid, sizeof(uuid_t));  in afs_install_server()
140 			if (server->cell == cell)  in afs_install_server()
148 					server->uuid_next,  in afs_install_server()
152 				server = next;  in afs_install_server()
154 			rcu_assign_pointer(server->uuid_next, candidate);  in afs_install_server()
155 			candidate->uuid_prev = server;  in afs_install_server()
156 			server = candidate;  in afs_install_server()
161 	server = candidate;  in afs_install_server()
162 	rb_link_node(&server->uuid_rb, p, pp);  in afs_install_server()
163 	rb_insert_color(&server->uuid_rb, &net->fs_servers);  in afs_install_server()
164 	hlist_add_head_rcu(&server->proc_link, &net->fs_proc);  in afs_install_server()
170 	estate = rcu_dereference_protected(server->endpoint_state,  in afs_install_server()
183 		hlist_add_head_rcu(&server->addr_link, &net->fs_addresses);  in afs_install_server()
188 	afs_get_server(server, afs_server_trace_get_install);  in afs_install_server()
190 	return server;  in afs_install_server()
201 	struct afs_server *server;  in afs_alloc_server()  local
206 	server = kzalloc(sizeof(struct afs_server), GFP_KERNEL);  in afs_alloc_server()
207 	if (!server)  in afs_alloc_server()
214 	refcount_set(&server->ref, 1);  in afs_alloc_server()
215 	atomic_set(&server->active, 1);  in afs_alloc_server()
216 	server->debug_id = atomic_inc_return(&afs_server_debug_id);  in afs_alloc_server()
217 	server->addr_version = alist->version;  in afs_alloc_server()
218 	server->uuid = *uuid;  in afs_alloc_server()
219 	rwlock_init(&server->fs_lock);  in afs_alloc_server()
220 	INIT_LIST_HEAD(&server->volumes);  in afs_alloc_server()
221 	init_waitqueue_head(&server->probe_wq);  in afs_alloc_server()
222 	INIT_LIST_HEAD(&server->probe_link);  in afs_alloc_server()
223 	spin_lock_init(&server->probe_lock);  in afs_alloc_server()
224 	server->cell = cell;  in afs_alloc_server()
225 	server->rtt = UINT_MAX;  in afs_alloc_server()
226 	server->service_id = FS_SERVICE;  in afs_alloc_server()
228 	server->probe_counter = 1;  in afs_alloc_server()
229 	server->probed_at = jiffies - LONG_MAX / 2;  in afs_alloc_server()
232 	estate->server_id = server->debug_id;  in afs_alloc_server()
234 	rcu_assign_pointer(server->endpoint_state, estate);  in afs_alloc_server()
237 	trace_afs_server(server->debug_id, 1, 1, afs_server_trace_alloc);  in afs_alloc_server()
240 	_leave(" = %p", server);  in afs_alloc_server()
241 	return server;  in afs_alloc_server()
244 	kfree(server);  in afs_alloc_server()
263 			if (test_bit(AFS_VLSERVER_FL_IS_YFS, &vc.server->flags))  in afs_vl_lookup_addrs()
282 	struct afs_server *server, *candidate;  in afs_lookup_server()  local
286 	server = afs_find_server_by_uuid(cell->net, uuid);  in afs_lookup_server()
287 	if (server) {  in afs_lookup_server()
288 		if (server->addr_version != addr_version)  in afs_lookup_server()
289 			set_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags);  in afs_lookup_server()
290 		return server;  in afs_lookup_server()
303 	server = afs_install_server(cell, candidate);  in afs_lookup_server()
304 	if (server != candidate) {  in afs_lookup_server()
312 		afs_fs_probe_fileserver(cell->net, server, alist, key);  in afs_lookup_server()
315 	return server;  in afs_lookup_server()
347 struct afs_server *afs_get_server(struct afs_server *server,  in afs_get_server()  argument
353 	__refcount_inc(&server->ref, &r);  in afs_get_server()
354 	a = atomic_read(&server->active);  in afs_get_server()
355 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_get_server()
356 	return server;  in afs_get_server()
362 static struct afs_server *afs_maybe_use_server(struct afs_server *server,  in afs_maybe_use_server()  argument
368 	if (!__refcount_inc_not_zero(&server->ref, &r))  in afs_maybe_use_server()
371 	a = atomic_inc_return(&server->active);  in afs_maybe_use_server()
372 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_maybe_use_server()
373 	return server;  in afs_maybe_use_server()
379 struct afs_server *afs_use_server(struct afs_server *server, enum afs_server_trace reason)  in afs_use_server()  argument
384 	__refcount_inc(&server->ref, &r);  in afs_use_server()
385 	a = atomic_inc_return(&server->active);  in afs_use_server()
387 	trace_afs_server(server->debug_id, r + 1, a, reason);  in afs_use_server()
388 	return server;  in afs_use_server()
394 void afs_put_server(struct afs_net *net, struct afs_server *server,  in afs_put_server()  argument
397 	unsigned int a, debug_id = server->debug_id;  in afs_put_server()
401 	if (!server)  in afs_put_server()
404 	a = atomic_read(&server->active);  in afs_put_server()
405 	zero = __refcount_dec_and_test(&server->ref, &r);  in afs_put_server()
408 		__afs_put_server(net, server);  in afs_put_server()
415 void afs_unuse_server_notime(struct afs_net *net, struct afs_server *server,  in afs_unuse_server_notime()  argument
418 	if (server) {  in afs_unuse_server_notime()
419 		unsigned int active = atomic_dec_return(&server->active);  in afs_unuse_server_notime()
423 		afs_put_server(net, server, reason);  in afs_unuse_server_notime()
430 void afs_unuse_server(struct afs_net *net, struct afs_server *server,  in afs_unuse_server()  argument
433 	if (server) {  in afs_unuse_server()
434 		server->unuse_time = ktime_get_real_seconds();  in afs_unuse_server()
435 		afs_unuse_server_notime(net, server, reason);  in afs_unuse_server()
441 	struct afs_server *server = container_of(rcu, struct afs_server, rcu);  in afs_server_rcu()  local
443 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_server_rcu()
444 			 atomic_read(&server->active), afs_server_trace_free);  in afs_server_rcu()
445 	afs_put_endpoint_state(rcu_access_pointer(server->endpoint_state),  in afs_server_rcu()
447 	afs_put_cell(server->cell, afs_cell_trace_put_server);  in afs_server_rcu()
448 	kfree(server);  in afs_server_rcu()
451 static void __afs_put_server(struct afs_net *net, struct afs_server *server)  in __afs_put_server()  argument
453 	call_rcu(&server->rcu, afs_server_rcu);  in __afs_put_server()
457 static void afs_give_up_callbacks(struct afs_net *net, struct afs_server *server)  in afs_give_up_callbacks()  argument
459 	struct afs_endpoint_state *estate = rcu_access_pointer(server->endpoint_state);  in afs_give_up_callbacks()
462 	afs_fs_give_up_all_callbacks(net, server, &alist->addrs[alist->preferred], NULL);  in afs_give_up_callbacks()
468 static void afs_destroy_server(struct afs_net *net, struct afs_server *server)  in afs_destroy_server()  argument
470 	if (test_bit(AFS_SERVER_FL_MAY_HAVE_CB, &server->flags))  in afs_destroy_server()
471 		afs_give_up_callbacks(net, server);  in afs_destroy_server()
473 	afs_put_server(net, server, afs_server_trace_destroy);  in afs_destroy_server()
481 	struct afs_server *server, *next, *prev;  in afs_gc_servers()  local
484 	while ((server = gc_list)) {  in afs_gc_servers()
485 		gc_list = server->gc_next;  in afs_gc_servers()
489 		active = atomic_read(&server->active);  in afs_gc_servers()
491 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_gc_servers()
494 				server->uuid_next, lockdep_is_held(&net->fs_lock.lock));  in afs_gc_servers()
495 			prev = server->uuid_prev;  in afs_gc_servers()
499 					rb_erase(&server->uuid_rb, &net->fs_servers);  in afs_gc_servers()
501 					rb_replace_node_rcu(&server->uuid_rb,  in afs_gc_servers()
513 			list_del(&server->probe_link);  in afs_gc_servers()
514 			hlist_del_rcu(&server->proc_link);  in afs_gc_servers()
515 			if (!hlist_unhashed(&server->addr_link))  in afs_gc_servers()
516 				hlist_del_rcu(&server->addr_link);  in afs_gc_servers()
521 			afs_destroy_server(net, server);  in afs_gc_servers()
548 		struct afs_server *server =  in afs_manage_servers()  local
550 		int active = atomic_read(&server->active);  in afs_manage_servers()
552 		_debug("manage %pU %u", &server->uuid, active);  in afs_manage_servers()
555 			trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_manage_servers()
558 				pr_notice("Can't purge s=%08x\n", server->debug_id);  in afs_manage_servers()
562 			time64_t expire_at = server->unuse_time;  in afs_manage_servers()
564 			if (!test_bit(AFS_SERVER_FL_VL_FAIL, &server->flags) &&  in afs_manage_servers()
565 			    !test_bit(AFS_SERVER_FL_NOT_FOUND, &server->flags))  in afs_manage_servers()
568 				server->gc_next = gc_list;  in afs_manage_servers()
569 				gc_list = server;  in afs_manage_servers()
629 					      struct afs_server *server,  in afs_update_server_record()  argument
638 	trace_afs_server(server->debug_id, refcount_read(&server->ref),  in afs_update_server_record()
639 			 atomic_read(&server->active),  in afs_update_server_record()
642 	alist = afs_vl_lookup_addrs(op->volume->cell, op->key, &server->uuid);  in afs_update_server_record()
645 		estate = rcu_dereference(server->endpoint_state);  in afs_update_server_record()
661 	if (server->addr_version != alist->version)  in afs_update_server_record()
662 		afs_fs_probe_fileserver(op->net, server, alist, key);  in afs_update_server_record()
672 bool afs_check_server_record(struct afs_operation *op, struct afs_server *server,  in afs_check_server_record()  argument
680 	ASSERT(server);  in afs_check_server_record()
683 	if (test_bit(AFS_SERVER_FL_UPDATING, &server->flags))  in afs_check_server_record()
685 	if (test_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags))  in afs_check_server_record()
691 	if (!test_and_set_bit_lock(AFS_SERVER_FL_UPDATING, &server->flags)) {  in afs_check_server_record()
692 		clear_bit(AFS_SERVER_FL_NEEDS_UPDATE, &server->flags);  in afs_check_server_record()
693 		success = afs_update_server_record(op, server, key);  in afs_check_server_record()
694 		clear_bit_unlock(AFS_SERVER_FL_UPDATING, &server->flags);  in afs_check_server_record()
695 		wake_up_bit(&server->flags, AFS_SERVER_FL_UPDATING);  in afs_check_server_record()
701 	ret = wait_on_bit(&server->flags, AFS_SERVER_FL_UPDATING,  in afs_check_server_record()