55 	struct afs_cell *cell = NULL;  in afs_find_cell_locked()  local
67 		cell = net->ws_cell;  in afs_find_cell_locked()
68 		if (!cell)  in afs_find_cell_locked()
75 		cell = rb_entry(p, struct afs_cell, net_node);  in afs_find_cell_locked()
77 		n = strncasecmp(cell->name, name,  in afs_find_cell_locked()
78 				min_t(size_t, cell->name_len, namesz));  in afs_find_cell_locked()
80 			n = cell->name_len - namesz;  in afs_find_cell_locked()
92 	return afs_use_cell(cell, reason);  in afs_find_cell_locked()
102 	struct afs_cell *cell;  in afs_find_cell()  local
105 	cell = afs_find_cell_locked(net, name, namesz, reason);  in afs_find_cell()
107 	return cell;  in afs_find_cell()
119 	struct afs_cell *cell;  in afs_alloc_cell()  local
143 	cell = kzalloc(sizeof(struct afs_cell), GFP_KERNEL);  in afs_alloc_cell()
144 	if (!cell) {  in afs_alloc_cell()
149 	cell->name = kmalloc(namelen + 1, GFP_KERNEL);  in afs_alloc_cell()
150 	if (!cell->name) {  in afs_alloc_cell()
151 		kfree(cell);  in afs_alloc_cell()
155 	cell->net = net;  in afs_alloc_cell()
156 	cell->name_len = namelen;  in afs_alloc_cell()
158 		cell->name[i] = tolower(name[i]);  in afs_alloc_cell()
159 	cell->name[i] = 0;  in afs_alloc_cell()
161 	refcount_set(&cell->ref, 1);  in afs_alloc_cell()
162 	atomic_set(&cell->active, 0);  in afs_alloc_cell()
163 	INIT_WORK(&cell->manager, afs_manage_cell_work);  in afs_alloc_cell()
164 	cell->volumes = RB_ROOT;  in afs_alloc_cell()
165 	INIT_HLIST_HEAD(&cell->proc_volumes);  in afs_alloc_cell()
166 	seqlock_init(&cell->volume_lock);  in afs_alloc_cell()
167 	cell->fs_servers = RB_ROOT;  in afs_alloc_cell()
168 	seqlock_init(&cell->fs_lock);  in afs_alloc_cell()
169 	INIT_LIST_HEAD(&cell->fs_open_mmaps);  in afs_alloc_cell()
170 	init_rwsem(&cell->fs_open_mmaps_lock);  in afs_alloc_cell()
171 	rwlock_init(&cell->vl_servers_lock);  in afs_alloc_cell()
172 	cell->flags = (1 << AFS_CELL_FL_CHECK_ALIAS);  in afs_alloc_cell()
188 		cell->dns_expiry = TIME64_MAX;  in afs_alloc_cell()
196 		cell->dns_expiry = ktime_get_real_seconds();  in afs_alloc_cell()
199 	rcu_assign_pointer(cell->vl_servers, vllist);  in afs_alloc_cell()
201 	cell->dns_source = vllist->source;  in afs_alloc_cell()
202 	cell->dns_status = vllist->status;  in afs_alloc_cell()
203 	smp_store_release(&cell->dns_lookup_count, 1); /* vs source/status */  in afs_alloc_cell()
205 	cell->debug_id = atomic_inc_return(&cell_debug_id);  in afs_alloc_cell()
206 	trace_afs_cell(cell->debug_id, 1, 0, afs_cell_trace_alloc);  in afs_alloc_cell()
208 	_leave(" = %p", cell);  in afs_alloc_cell()
209 	return cell;  in afs_alloc_cell()
215 	kfree(cell->name);  in afs_alloc_cell()
216 	kfree(cell);  in afs_alloc_cell()
238 	struct afs_cell *cell, *candidate, *cursor;  in afs_lookup_cell()  local
246 		cell = afs_find_cell(net, name, namesz, afs_cell_trace_use_lookup);  in afs_lookup_cell()
247 		if (!IS_ERR(cell))  in afs_lookup_cell()
287 	cell = candidate;  in afs_lookup_cell()
289 	atomic_set(&cell->active, 2);  in afs_lookup_cell()
290 	trace_afs_cell(cell->debug_id, refcount_read(&cell->ref), 2, afs_cell_trace_insert);  in afs_lookup_cell()
291 	rb_link_node_rcu(&cell->net_node, parent, pp);  in afs_lookup_cell()
292 	rb_insert_color(&cell->net_node, &net->cells);  in afs_lookup_cell()
295 	afs_queue_cell(cell, afs_cell_trace_get_queue_new);  in afs_lookup_cell()
298 	trace_afs_cell(cell->debug_id, refcount_read(&cell->ref), atomic_read(&cell->active),  in afs_lookup_cell()
301 	wait_var_event(&cell->state,  in afs_lookup_cell()
303 			       state = smp_load_acquire(&cell->state); /* vs error */  in afs_lookup_cell()
309 		ret = cell->error;  in afs_lookup_cell()
313 	_leave(" = %p [cell]", cell);  in afs_lookup_cell()
314 	return cell;  in afs_lookup_cell()
318 	cell = cursor;  in afs_lookup_cell()
332 	afs_unuse_cell(net, cell, afs_cell_trace_unuse_lookup);  in afs_lookup_cell()
394 static int afs_update_cell(struct afs_cell *cell)  in afs_update_cell()  argument
402 	_enter("%s", cell->name);  in afs_update_cell()
404 	vllist = afs_dns_query(cell, &expiry);  in afs_update_cell()
408 		_debug("%s: fail %d", cell->name, ret);  in afs_update_cell()
434 	_debug("%s: got list %d %d", cell->name, vllist->source, vllist->status);  in afs_update_cell()
435 	cell->dns_status = vllist->status;  in afs_update_cell()
445 	_debug("%s: status %d", cell->name, vllist->status);  in afs_update_cell()
452 			cell->dns_expiry = expiry;  in afs_update_cell()
460 			cell->dns_expiry = now + 10;  in afs_update_cell()
464 		cell->dns_expiry = expiry;  in afs_update_cell()
470 	write_lock(&cell->vl_servers_lock);  in afs_update_cell()
471 	p = rcu_dereference_protected(cell->vl_servers, true);  in afs_update_cell()
473 		rcu_assign_pointer(cell->vl_servers, vllist);  in afs_update_cell()
474 		cell->dns_source = vllist->source;  in afs_update_cell()
477 	write_unlock(&cell->vl_servers_lock);  in afs_update_cell()
478 	afs_put_vlserverlist(cell->net, old);  in afs_update_cell()
481 	smp_store_release(&cell->dns_lookup_count,  in afs_update_cell()
482 			  cell->dns_lookup_count + 1); /* vs source/status */  in afs_update_cell()
483 	wake_up_var(&cell->dns_lookup_count);  in afs_update_cell()
493 	struct afs_cell *cell = container_of(rcu, struct afs_cell, rcu);  in afs_cell_destroy()  local
494 	struct afs_net *net = cell->net;  in afs_cell_destroy()
497 	_enter("%p{%s}", cell, cell->name);  in afs_cell_destroy()
499 	r = refcount_read(&cell->ref);  in afs_cell_destroy()
501 	trace_afs_cell(cell->debug_id, r, atomic_read(&cell->active), afs_cell_trace_free);  in afs_cell_destroy()
503 	afs_put_vlserverlist(net, rcu_access_pointer(cell->vl_servers));  in afs_cell_destroy()
504 	afs_unuse_cell(net, cell->alias_of, afs_cell_trace_unuse_alias);  in afs_cell_destroy()
505 	key_put(cell->anonymous_key);  in afs_cell_destroy()
506 	kfree(cell->name);  in afs_cell_destroy()
507 	kfree(cell);  in afs_cell_destroy()
542 struct afs_cell *afs_get_cell(struct afs_cell *cell, enum afs_cell_trace reason)  in afs_get_cell()  argument
546 	__refcount_inc(&cell->ref, &r);  in afs_get_cell()
547 	trace_afs_cell(cell->debug_id, r + 1, atomic_read(&cell->active), reason);  in afs_get_cell()
548 	return cell;  in afs_get_cell()
554 void afs_put_cell(struct afs_cell *cell, enum afs_cell_trace reason)  in afs_put_cell()  argument
556 	if (cell) {  in afs_put_cell()
557 		unsigned int debug_id = cell->debug_id;  in afs_put_cell()
562 		a = atomic_read(&cell->active);  in afs_put_cell()
563 		zero = __refcount_dec_and_test(&cell->ref, &r);  in afs_put_cell()
566 			a = atomic_read(&cell->active);  in afs_put_cell()
568 			call_rcu(&cell->rcu, afs_cell_destroy);  in afs_put_cell()
576 struct afs_cell *afs_use_cell(struct afs_cell *cell, enum afs_cell_trace reason)  in afs_use_cell()  argument
580 	r = refcount_read(&cell->ref);  in afs_use_cell()
582 	a = atomic_inc_return(&cell->active);  in afs_use_cell()
583 	trace_afs_cell(cell->debug_id, r, a, reason);  in afs_use_cell()
584 	return cell;  in afs_use_cell()
591 void afs_unuse_cell(struct afs_net *net, struct afs_cell *cell, enum afs_cell_trace reason)  in afs_unuse_cell()  argument
597 	if (!cell)  in afs_unuse_cell()
600 	_enter("%s", cell->name);  in afs_unuse_cell()
603 	cell->last_inactive = now;  in afs_unuse_cell()
605 	if (cell->vl_servers->nr_servers)  in afs_unuse_cell()
608 	debug_id = cell->debug_id;  in afs_unuse_cell()
609 	r = refcount_read(&cell->ref);  in afs_unuse_cell()
610 	a = atomic_dec_return(&cell->active);  in afs_unuse_cell()
621 void afs_see_cell(struct afs_cell *cell, enum afs_cell_trace reason)  in afs_see_cell()  argument
625 	r = refcount_read(&cell->ref);  in afs_see_cell()
626 	a = atomic_read(&cell->active);  in afs_see_cell()
627 	trace_afs_cell(cell->debug_id, r, a, reason);  in afs_see_cell()
633 void afs_queue_cell(struct afs_cell *cell, enum afs_cell_trace reason)  in afs_queue_cell()  argument
635 	afs_get_cell(cell, reason);  in afs_queue_cell()
636 	if (!queue_work(afs_wq, &cell->manager))  in afs_queue_cell()
637 		afs_put_cell(cell, afs_cell_trace_put_queue_fail);  in afs_queue_cell()
643 static int afs_alloc_anon_key(struct afs_cell *cell)  in afs_alloc_anon_key()  argument
651 	cp = cell->name;  in afs_alloc_anon_key()
660 	cell->anonymous_key = key;  in afs_alloc_anon_key()
663 	       cell->anonymous_key, key_serial(cell->anonymous_key));  in afs_alloc_anon_key()
670 static int afs_activate_cell(struct afs_net *net, struct afs_cell *cell)  in afs_activate_cell()  argument
676 	if (!cell->anonymous_key) {  in afs_activate_cell()
677 		ret = afs_alloc_anon_key(cell);  in afs_activate_cell()
682 	ret = afs_proc_cell_setup(cell);  in afs_activate_cell()
689 		if (strcmp(cell->name, pcell->name) < 0)  in afs_activate_cell()
693 	cell->proc_link.pprev = p;  in afs_activate_cell()
694 	cell->proc_link.next = *p;  in afs_activate_cell()
695 	rcu_assign_pointer(*p, &cell->proc_link.next);  in afs_activate_cell()
696 	if (cell->proc_link.next)  in afs_activate_cell()
697 		cell->proc_link.next->pprev = &cell->proc_link.next;  in afs_activate_cell()
699 	afs_dynroot_mkdir(net, cell);  in afs_activate_cell()
707 static void afs_deactivate_cell(struct afs_net *net, struct afs_cell *cell)  in afs_deactivate_cell()  argument
709 	_enter("%s", cell->name);  in afs_deactivate_cell()
711 	afs_proc_cell_remove(cell);  in afs_deactivate_cell()
714 	hlist_del_rcu(&cell->proc_link);  in afs_deactivate_cell()
715 	afs_dynroot_rmdir(net, cell);  in afs_deactivate_cell()
725 static void afs_manage_cell(struct afs_cell *cell)  in afs_manage_cell()  argument
727 	struct afs_net *net = cell->net;  in afs_manage_cell()
730 	_enter("%s", cell->name);  in afs_manage_cell()
733 	_debug("state %u", cell->state);  in afs_manage_cell()
734 	switch (cell->state) {  in afs_manage_cell()
739 		if (atomic_try_cmpxchg_relaxed(&cell->active, &active, 0)) {  in afs_manage_cell()
740 			rb_erase(&cell->net_node, &net->cells);  in afs_manage_cell()
741 			trace_afs_cell(cell->debug_id, refcount_read(&cell->ref), 0,  in afs_manage_cell()
743 			smp_store_release(&cell->state, AFS_CELL_REMOVED);  in afs_manage_cell()
746 		if (cell->state == AFS_CELL_REMOVED) {  in afs_manage_cell()
747 			wake_up_var(&cell->state);  in afs_manage_cell()
750 		if (cell->state == AFS_CELL_FAILED)  in afs_manage_cell()
752 		smp_store_release(&cell->state, AFS_CELL_UNSET);  in afs_manage_cell()
753 		wake_up_var(&cell->state);  in afs_manage_cell()
757 		smp_store_release(&cell->state, AFS_CELL_ACTIVATING);  in afs_manage_cell()
758 		wake_up_var(&cell->state);  in afs_manage_cell()
762 		ret = afs_activate_cell(net, cell);  in afs_manage_cell()
766 		smp_store_release(&cell->state, AFS_CELL_ACTIVE);  in afs_manage_cell()
767 		wake_up_var(&cell->state);  in afs_manage_cell()
771 		if (atomic_read(&cell->active) > 1) {  in afs_manage_cell()
772 			if (test_and_clear_bit(AFS_CELL_FL_DO_LOOKUP, &cell->flags)) {  in afs_manage_cell()
773 				ret = afs_update_cell(cell);  in afs_manage_cell()
775 					cell->error = ret;  in afs_manage_cell()
779 		smp_store_release(&cell->state, AFS_CELL_DEACTIVATING);  in afs_manage_cell()
780 		wake_up_var(&cell->state);  in afs_manage_cell()
784 		if (atomic_read(&cell->active) > 1)  in afs_manage_cell()
786 		afs_deactivate_cell(net, cell);  in afs_manage_cell()
787 		smp_store_release(&cell->state, AFS_CELL_INACTIVE);  in afs_manage_cell()
788 		wake_up_var(&cell->state);  in afs_manage_cell()
797 	_debug("bad state %u", cell->state);  in afs_manage_cell()
801 	cell->error = ret;  in afs_manage_cell()
802 	afs_deactivate_cell(net, cell);  in afs_manage_cell()
804 	smp_store_release(&cell->state, AFS_CELL_FAILED); /* vs error */  in afs_manage_cell()
805 	wake_up_var(&cell->state);  in afs_manage_cell()
809 	smp_store_release(&cell->state, AFS_CELL_ACTIVE);  in afs_manage_cell()
810 	wake_up_var(&cell->state);  in afs_manage_cell()
815 	_leave(" [done %u]", cell->state);  in afs_manage_cell()
820 	afs_put_volume(cell->net, cell->root_volume, afs_volume_trace_put_cell_root);  in afs_manage_cell()
821 	cell->root_volume = NULL;  in afs_manage_cell()
822 	afs_put_cell(cell, afs_cell_trace_put_destroy);  in afs_manage_cell()
827 	struct afs_cell *cell = container_of(work, struct afs_cell, manager);  in afs_manage_cell_work()  local
829 	afs_manage_cell(cell);  in afs_manage_cell_work()
830 	afs_put_cell(cell, afs_cell_trace_put_queue_work);  in afs_manage_cell_work()
862 		struct afs_cell *cell =  in afs_manage_cells()  local
867 		active = atomic_read(&cell->active);  in afs_manage_cells()
868 		trace_afs_cell(cell->debug_id, refcount_read(&cell->ref),  in afs_manage_cells()
874 			if (test_and_clear_bit(AFS_CELL_FL_NO_GC, &cell->flags)) {  in afs_manage_cells()
875 				active = atomic_dec_return(&cell->active);  in afs_manage_cells()
876 				trace_afs_cell(cell->debug_id, refcount_read(&cell->ref),  in afs_manage_cells()
883 			time64_t expire_at = cell->last_inactive;  in afs_manage_cells()
885 			read_lock(&cell->vl_servers_lock);  in afs_manage_cells()
887 				cell->vl_servers,  in afs_manage_cells()
888 				lockdep_is_held(&cell->vl_servers_lock));  in afs_manage_cells()
891 			read_unlock(&cell->vl_servers_lock);  in afs_manage_cells()
899 			if (test_bit(AFS_CELL_FL_DO_LOOKUP, &cell->flags))  in afs_manage_cells()
904 			afs_queue_cell(cell, afs_cell_trace_get_queue_manage);  in afs_manage_cells()