23 	struct afs_volume *volume;  in afs_alloc_volume()  local
30 	volume = kzalloc(sizeof(struct afs_volume), GFP_KERNEL);  in afs_alloc_volume()
31 	if (!volume)  in afs_alloc_volume()
34 	volume->vid		= vldb->vid[params->type];  in afs_alloc_volume()
35 	volume->update_at	= ktime_get_real_seconds() + afs_volume_record_life;  in afs_alloc_volume()
36 	volume->cell		= afs_get_cell(params->cell);  in afs_alloc_volume()
37 	volume->type		= params->type;  in afs_alloc_volume()
38 	volume->type_force	= params->force;  in afs_alloc_volume()
39 	volume->name_len	= vldb->name_len;  in afs_alloc_volume()
41 	atomic_set(&volume->usage, 1);  in afs_alloc_volume()
42 	INIT_LIST_HEAD(&volume->proc_link);  in afs_alloc_volume()
43 	rwlock_init(&volume->servers_lock);  in afs_alloc_volume()
44 	rwlock_init(&volume->cb_v_break_lock);  in afs_alloc_volume()
45 	memcpy(volume->name, vldb->name, vldb->name_len + 1);  in afs_alloc_volume()
54 	volume->servers = slist;  in afs_alloc_volume()
55 	return volume;  in afs_alloc_volume()
58 	afs_put_cell(params->net, volume->cell);  in afs_alloc_volume()
59 	kfree(volume);  in afs_alloc_volume()
114 	struct afs_volume *volume;  in afs_create_volume()  local
123 		volume = ERR_PTR(vldb->error);  in afs_create_volume()
128 	volume = ERR_PTR(-ENOMEDIUM);  in afs_create_volume()
141 	volume = afs_alloc_volume(params, vldb, type_mask);  in afs_create_volume()
145 	return volume;  in afs_create_volume()
151 static void afs_destroy_volume(struct afs_net *net, struct afs_volume *volume)  in afs_destroy_volume()  argument
153 	_enter("%p", volume);  in afs_destroy_volume()
156 	ASSERTCMP(volume->cache, ==, NULL);  in afs_destroy_volume()
159 	afs_put_serverlist(net, volume->servers);  in afs_destroy_volume()
160 	afs_put_cell(net, volume->cell);  in afs_destroy_volume()
161 	kfree(volume);  in afs_destroy_volume()
169 void afs_put_volume(struct afs_cell *cell, struct afs_volume *volume)  in afs_put_volume()  argument
171 	if (volume) {  in afs_put_volume()
172 		_enter("%s", volume->name);  in afs_put_volume()
174 		if (atomic_dec_and_test(&volume->usage))  in afs_put_volume()
175 			afs_destroy_volume(cell->net, volume);  in afs_put_volume()
182 void afs_activate_volume(struct afs_volume *volume)  in afs_activate_volume()  argument
185 	volume->cache = fscache_acquire_cookie(volume->cell->cache,  in afs_activate_volume()
187 					       &volume->vid, sizeof(volume->vid),  in afs_activate_volume()
189 					       volume, 0, true);  in afs_activate_volume()
192 	write_lock(&volume->cell->proc_lock);  in afs_activate_volume()
193 	list_add_tail(&volume->proc_link, &volume->cell->proc_volumes);  in afs_activate_volume()
194 	write_unlock(&volume->cell->proc_lock);  in afs_activate_volume()
200 void afs_deactivate_volume(struct afs_volume *volume)  in afs_deactivate_volume()  argument
202 	_enter("%s", volume->name);  in afs_deactivate_volume()
204 	write_lock(&volume->cell->proc_lock);  in afs_deactivate_volume()
205 	list_del_init(&volume->proc_link);  in afs_deactivate_volume()
206 	write_unlock(&volume->cell->proc_lock);  in afs_deactivate_volume()
209 	fscache_relinquish_cookie(volume->cache, NULL,  in afs_deactivate_volume()
210 				  test_bit(AFS_VOLUME_DELETED, &volume->flags));  in afs_deactivate_volume()
211 	volume->cache = NULL;  in afs_deactivate_volume()
220 static int afs_update_volume_status(struct afs_volume *volume, struct key *key)  in afs_update_volume_status()  argument
232 	idsz = sprintf(idbuf, "%llu", volume->vid);  in afs_update_volume_status()
234 	vldb = afs_vl_lookup_vldb(volume->cell, key, idbuf, idsz);  in afs_update_volume_status()
241 	if (vldb->name_len != volume->name_len ||  in afs_update_volume_status()
242 	    memcmp(vldb->name, volume->name, vldb->name_len) != 0) {  in afs_update_volume_status()
244 		memcpy(volume->name, vldb->name, AFS_MAXVOLNAME);  in afs_update_volume_status()
245 		volume->name_len = vldb->name_len;  in afs_update_volume_status()
249 	new = afs_alloc_server_list(volume->cell, key,  in afs_update_volume_status()
250 				    vldb, (1 << volume->type));  in afs_update_volume_status()
256 	write_lock(&volume->servers_lock);  in afs_update_volume_status()
259 	old = volume->servers;  in afs_update_volume_status()
261 		new->seq = volume->servers_seq + 1;  in afs_update_volume_status()
262 		volume->servers = new;  in afs_update_volume_status()
264 		volume->servers_seq++;  in afs_update_volume_status()
268 	volume->update_at = ktime_get_real_seconds() + afs_volume_record_life;  in afs_update_volume_status()
269 	clear_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags);  in afs_update_volume_status()
270 	write_unlock(&volume->servers_lock);  in afs_update_volume_status()
273 	afs_put_serverlist(volume->cell->net, discard);  in afs_update_volume_status()
284 int afs_check_volume_status(struct afs_volume *volume, struct key *key)  in afs_check_volume_status()  argument
291 	if (volume->update_at <= now)  in afs_check_volume_status()
292 		set_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags);  in afs_check_volume_status()
295 	if (!test_bit(AFS_VOLUME_NEEDS_UPDATE, &volume->flags) &&  in afs_check_volume_status()
296 	    !test_bit(AFS_VOLUME_WAIT, &volume->flags)) {  in afs_check_volume_status()
301 	if (!test_and_set_bit_lock(AFS_VOLUME_UPDATING, &volume->flags)) {  in afs_check_volume_status()
302 		ret = afs_update_volume_status(volume, key);  in afs_check_volume_status()
303 		clear_bit_unlock(AFS_VOLUME_WAIT, &volume->flags);  in afs_check_volume_status()
304 		clear_bit_unlock(AFS_VOLUME_UPDATING, &volume->flags);  in afs_check_volume_status()
305 		wake_up_bit(&volume->flags, AFS_VOLUME_WAIT);  in afs_check_volume_status()
310 	if (!test_bit(AFS_VOLUME_WAIT, &volume->flags)) {  in afs_check_volume_status()
315 	ret = wait_on_bit(&volume->flags, AFS_VOLUME_WAIT, TASK_INTERRUPTIBLE);  in afs_check_volume_status()