Orange Pi5 kernel

^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   2) /* AFS volume management
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   3)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   4)  * Copyright (C) 2002, 2007 Red Hat, Inc. All Rights Reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   5)  * Written by David Howells (dhowells@redhat.com)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   6)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   7) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   8) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   9) #include <linux/slab.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  10) #include "internal.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  11) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  12) unsigned __read_mostly afs_volume_gc_delay = 10;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  13) unsigned __read_mostly afs_volume_record_life = 60 * 60;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  14) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  15) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  16)  * Insert a volume into a cell.  If there's an existing volume record, that is
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  17)  * returned instead with a ref held.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  18)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  19) static struct afs_volume *afs_insert_volume_into_cell(struct afs_cell *cell,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  20) 						      struct afs_volume *volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  21) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  22) 	struct afs_volume *p;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  23) 	struct rb_node *parent = NULL, **pp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  24) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  25) 	write_seqlock(&cell->volume_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  26) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  27) 	pp = &cell->volumes.rb_node;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  28) 	while (*pp) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  29) 		parent = *pp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  30) 		p = rb_entry(parent, struct afs_volume, cell_node);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  31) 		if (p->vid < volume->vid) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  32) 			pp = &(*pp)->rb_left;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  33) 		} else if (p->vid > volume->vid) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  34) 			pp = &(*pp)->rb_right;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  35) 		} else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  36) 			volume = afs_get_volume(p, afs_volume_trace_get_cell_insert);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  37) 			goto found;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  38) 		}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  39) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  40) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  41) 	rb_link_node_rcu(&volume->cell_node, parent, pp);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  42) 	rb_insert_color(&volume->cell_node, &cell->volumes);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  43) 	hlist_add_head_rcu(&volume->proc_link, &cell->proc_volumes);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  44) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  45) found:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  46) 	write_sequnlock(&cell->volume_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  47) 	return volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  48) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  49) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  50) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  51) static void afs_remove_volume_from_cell(struct afs_volume *volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  52) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  53) 	struct afs_cell *cell = volume->cell;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  54) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  55) 	if (!hlist_unhashed(&volume->proc_link)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  56) 		trace_afs_volume(volume->vid, atomic_read(&volume->usage),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  57) 				 afs_volume_trace_remove);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  58) 		write_seqlock(&cell->volume_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  59) 		hlist_del_rcu(&volume->proc_link);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  60) 		rb_erase(&volume->cell_node, &cell->volumes);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  61) 		write_sequnlock(&cell->volume_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  62) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  63) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  64) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  65) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  66)  * Allocate a volume record and load it up from a vldb record.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  67)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  68) static struct afs_volume *afs_alloc_volume(struct afs_fs_context *params,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  69) 					   struct afs_vldb_entry *vldb,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  70) 					   unsigned long type_mask)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  71) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  72) 	struct afs_server_list *slist;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  73) 	struct afs_volume *volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  74) 	int ret = -ENOMEM, nr_servers = 0, i;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  75) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  76) 	for (i = 0; i < vldb->nr_servers; i++)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  77) 		if (vldb->fs_mask[i] & type_mask)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  78) 			nr_servers++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  79) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  80) 	volume = kzalloc(sizeof(struct afs_volume), GFP_KERNEL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  81) 	if (!volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  82) 		goto error_0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  83) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  84) 	volume->vid		= vldb->vid[params->type];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  85) 	volume->update_at	= ktime_get_real_seconds() + afs_volume_record_life;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  86) 	volume->cell		= afs_get_cell(params->cell, afs_cell_trace_get_vol);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  87) 	volume->type		= params->type;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  88) 	volume->type_force	= params->force;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  89) 	volume->name_len	= vldb->name_len;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  90) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  91) 	atomic_set(&volume->usage, 1);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  92) 	INIT_HLIST_NODE(&volume->proc_link);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  93) 	rwlock_init(&volume->servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  94) 	rwlock_init(&volume->cb_v_break_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  95) 	memcpy(volume->name, vldb->name, vldb->name_len + 1);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  96) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  97) 	slist = afs_alloc_server_list(params->cell, params->key, vldb, type_mask);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  98) 	if (IS_ERR(slist)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  99) 		ret = PTR_ERR(slist);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) 		goto error_1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) 	refcount_set(&slist->usage, 1);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) 	rcu_assign_pointer(volume->servers, slist);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) 	trace_afs_volume(volume->vid, 1, afs_volume_trace_alloc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) 	return volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) error_1:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) 	afs_put_cell(volume->cell, afs_cell_trace_put_vol);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) 	kfree(volume);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) error_0:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) 	return ERR_PTR(ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116)  * Look up or allocate a volume record.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) static struct afs_volume *afs_lookup_volume(struct afs_fs_context *params,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) 					    struct afs_vldb_entry *vldb,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) 					    unsigned long type_mask)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) 	struct afs_volume *candidate, *volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) 	candidate = afs_alloc_volume(params, vldb, type_mask);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) 	if (IS_ERR(candidate))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) 		return candidate;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) 	volume = afs_insert_volume_into_cell(params->cell, candidate);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) 	if (volume != candidate)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) 		afs_put_volume(params->net, candidate, afs_volume_trace_put_cell_dup);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) 	return volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135)  * Look up a VLDB record for a volume.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) static struct afs_vldb_entry *afs_vl_lookup_vldb(struct afs_cell *cell,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) 						 struct key *key,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) 						 const char *volname,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) 						 size_t volnamesz)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) 	struct afs_vldb_entry *vldb = ERR_PTR(-EDESTADDRREQ);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) 	struct afs_vl_cursor vc;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) 	int ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) 	if (!afs_begin_vlserver_operation(&vc, cell, key))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) 		return ERR_PTR(-ERESTARTSYS);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) 	while (afs_select_vlserver(&vc)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) 		vldb = afs_vl_get_entry_by_name_u(&vc, volname, volnamesz);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) 	ret = afs_end_vlserver_operation(&vc);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) 	return ret < 0 ? ERR_PTR(ret) : vldb;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158)  * Look up a volume in the VL server and create a candidate volume record for
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159)  * it.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161)  * The volume name can be one of the following:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162)  *	"%[cell:]volume[.]"		R/W volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163)  *	"#[cell:]volume[.]"		R/O or R/W volume (rwparent=0),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164)  *					 or R/W (rwparent=1) volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165)  *	"%[cell:]volume.readonly"	R/O volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166)  *	"#[cell:]volume.readonly"	R/O volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167)  *	"%[cell:]volume.backup"		Backup volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168)  *	"#[cell:]volume.backup"		Backup volume
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170)  * The cell name is optional, and defaults to the current cell.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172)  * See "The Rules of Mount Point Traversal" in Chapter 5 of the AFS SysAdmin
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173)  * Guide
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174)  * - Rule 1: Explicit type suffix forces access of that type or nothing
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175)  *           (no suffix, then use Rule 2 & 3)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176)  * - Rule 2: If parent volume is R/O, then mount R/O volume by preference, R/W
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177)  *           if not available
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178)  * - Rule 3: If parent volume is R/W, then only mount R/W volume unless
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179)  *           explicitly told otherwise
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) struct afs_volume *afs_create_volume(struct afs_fs_context *params)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) 	struct afs_vldb_entry *vldb;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) 	struct afs_volume *volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) 	unsigned long type_mask = 1UL << params->type;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) 	vldb = afs_vl_lookup_vldb(params->cell, params->key,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) 				  params->volname, params->volnamesz);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) 	if (IS_ERR(vldb))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) 		return ERR_CAST(vldb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) 	if (test_bit(AFS_VLDB_QUERY_ERROR, &vldb->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) 		volume = ERR_PTR(vldb->error);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) 		goto error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) 	/* Make the final decision on the type we want */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) 	volume = ERR_PTR(-ENOMEDIUM);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) 	if (params->force) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) 		if (!(vldb->flags & type_mask))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) 			goto error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) 	} else if (test_bit(AFS_VLDB_HAS_RO, &vldb->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) 		params->type = AFSVL_ROVOL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) 	} else if (test_bit(AFS_VLDB_HAS_RW, &vldb->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) 		params->type = AFSVL_RWVOL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) 	} else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) 		goto error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) 	type_mask = 1UL << params->type;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) 	volume = afs_lookup_volume(params, vldb, type_mask);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) error:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) 	kfree(vldb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) 	return volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219)  * Destroy a volume record
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) static void afs_destroy_volume(struct afs_net *net, struct afs_volume *volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) 	_enter("%p", volume);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) #ifdef CONFIG_AFS_FSCACHE
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) 	ASSERTCMP(volume->cache, ==, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) 	afs_remove_volume_from_cell(volume);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) 	afs_put_serverlist(net, rcu_access_pointer(volume->servers));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) 	afs_put_cell(volume->cell, afs_cell_trace_put_vol);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) 	trace_afs_volume(volume->vid, atomic_read(&volume->usage),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) 			 afs_volume_trace_free);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) 	kfree_rcu(volume, rcu);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) 	_leave(" [destroyed]");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240)  * Get a reference on a volume record.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) struct afs_volume *afs_get_volume(struct afs_volume *volume,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) 				  enum afs_volume_trace reason)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) 	if (volume) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) 		int u = atomic_inc_return(&volume->usage);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) 		trace_afs_volume(volume->vid, u, reason);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) 	return volume;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254)  * Drop a reference on a volume record.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) void afs_put_volume(struct afs_net *net, struct afs_volume *volume,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) 		    enum afs_volume_trace reason)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) 	if (volume) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) 		afs_volid_t vid = volume->vid;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) 		int u = atomic_dec_return(&volume->usage);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) 		trace_afs_volume(vid, u, reason);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) 		if (u == 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) 			afs_destroy_volume(net, volume);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269)  * Activate a volume.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) void afs_activate_volume(struct afs_volume *volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) #ifdef CONFIG_AFS_FSCACHE
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) 	volume->cache = fscache_acquire_cookie(volume->cell->cache,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) 					       &afs_volume_cache_index_def,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) 					       &volume->vid, sizeof(volume->vid),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) 					       NULL, 0,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) 					       volume, 0, true);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283)  * Deactivate a volume.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285) void afs_deactivate_volume(struct afs_volume *volume)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287) 	_enter("%s", volume->name);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) #ifdef CONFIG_AFS_FSCACHE
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) 	fscache_relinquish_cookie(volume->cache, NULL,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) 				  test_bit(AFS_VOLUME_DELETED, &volume->flags));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) 	volume->cache = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) 	_leave("");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299)  * Query the VL service to update the volume status.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) static int afs_update_volume_status(struct afs_volume *volume, struct key *key)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) 	struct afs_server_list *new, *old, *discard;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) 	struct afs_vldb_entry *vldb;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305) 	char idbuf[16];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) 	int ret, idsz;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) 	_enter("");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) 	/* We look up an ID by passing it as a decimal string in the
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311) 	 * operation's name parameter.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) 	idsz = sprintf(idbuf, "%llu", volume->vid);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) 	vldb = afs_vl_lookup_vldb(volume->cell, key, idbuf, idsz);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316) 	if (IS_ERR(vldb)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317) 		ret = PTR_ERR(vldb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) 		goto error;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 320) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 321) 	/* See if the volume got renamed. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 322) 	if (vldb->name_len != volume->name_len ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 323) 	    memcmp(vldb->name, volume->name, vldb->name_len) != 0) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 324) 		/* TODO: Use RCU'd string. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 325) 		memcpy(volume->name, vldb->name, AFS_MAXVOLNAME);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 326) 		volume->name_len = vldb->name_len;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 327) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 328) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 329) 	/* See if the volume's server list got updated. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 330) 	new = afs_alloc_server_list(volume->cell, key,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 331) 				    vldb, (1 << volume->type));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 332) 	if (IS_ERR(new)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 333) 		ret = PTR_ERR(new);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 334) 		goto error_vldb;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 335) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 336) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 337) 	write_lock(&volume->servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 338) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 339) 	discard = new;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 340) 	old = rcu_dereference_protected(volume->servers,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 341) 					lockdep_is_held(&volume->servers_lock));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 342) 	if (afs_annotate_server_list(new, old)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 343) 		new->seq = volume->servers_seq + 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 344) 		rcu_assign_pointer(volume->servers, new);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 345) 		smp_wmb();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 346) 		volume->servers_seq++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 347) 		discard = old;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 348) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 349) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 350) 	volume->update_at = ktime_get_real_seconds() + afs_volume_record_life;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 351) 	write_unlock(&volume->servers_lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 352) 	ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 353) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 354) 	afs_put_serverlist(volume->cell->net, discard);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 355) error_vldb:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 356) 	kfree(vldb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 357) error:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 358) 	_leave(" = %d", ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 359) 	return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 360) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 361) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 362) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 363)  * Make sure the volume record is up to date.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 364)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 365) int afs_check_volume_status(struct afs_volume *volume, struct afs_operation *op)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 366) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 367) 	int ret, retries = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 368) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 369) 	_enter("");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 370) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 371) retry:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 372) 	if (test_bit(AFS_VOLUME_WAIT, &volume->flags))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 373) 		goto wait;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 374) 	if (volume->update_at <= ktime_get_real_seconds() ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 375) 	    test_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 376) 		goto update;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 377) 	_leave(" = 0");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 378) 	return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 379) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 380) update:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 381) 	if (!test_and_set_bit_lock(AFS_VOLUME_UPDATING, &volume->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 382) 		clear_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 383) 		ret = afs_update_volume_status(volume, op->key);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 384) 		if (ret < 0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 385) 			set_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 386) 		clear_bit_unlock(AFS_VOLUME_WAIT, &volume->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 387) 		clear_bit_unlock(AFS_VOLUME_UPDATING, &volume->flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 388) 		wake_up_bit(&volume->flags, AFS_VOLUME_WAIT);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 389) 		_leave(" = %d", ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 390) 		return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 391) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 392) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 393) wait:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 394) 	if (!test_bit(AFS_VOLUME_WAIT, &volume->flags)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 395) 		_leave(" = 0 [no wait]");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 396) 		return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 397) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 398) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 399) 	ret = wait_on_bit(&volume->flags, AFS_VOLUME_WAIT,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 400) 			  (op->flags & AFS_OPERATION_UNINTR) ?
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 401) 			  TASK_UNINTERRUPTIBLE : TASK_INTERRUPTIBLE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 402) 	if (ret == -ERESTARTSYS) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 403) 		_leave(" = %d", ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 404) 		return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 405) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 406) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 407) 	retries++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 408) 	if (retries == 4) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 409) 		_leave(" = -ESTALE");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 410) 		return -ESTALE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 411) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 412) 	goto retry;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 413) }