volume.c 9.6 KB
Newer Older
D
David Howells 已提交
1
/* AFS volume management
L
Linus Torvalds 已提交
2
 *
3
 * Copyright (C) 2002, 2007 Red Hat, Inc. All Rights Reserved.
L
Linus Torvalds 已提交
4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43
 * Written by David Howells (dhowells@redhat.com)
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version
 * 2 of the License, or (at your option) any later version.
 */

#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/init.h>
#include <linux/slab.h>
#include <linux/fs.h>
#include <linux/pagemap.h>
#include "internal.h"

static const char *afs_voltypes[] = { "R/W", "R/O", "BAK" };

/*
 * lookup a volume by name
 * - this can be one of the following:
 *	"%[cell:]volume[.]"		R/W volume
 *	"#[cell:]volume[.]"		R/O or R/W volume (rwparent=0),
 *					 or R/W (rwparent=1) volume
 *	"%[cell:]volume.readonly"	R/O volume
 *	"#[cell:]volume.readonly"	R/O volume
 *	"%[cell:]volume.backup"		Backup volume
 *	"#[cell:]volume.backup"		Backup volume
 *
 * The cell name is optional, and defaults to the current cell.
 *
 * See "The Rules of Mount Point Traversal" in Chapter 5 of the AFS SysAdmin
 * Guide
 * - Rule 1: Explicit type suffix forces access of that type or nothing
 *           (no suffix, then use Rule 2 & 3)
 * - Rule 2: If parent volume is R/O, then mount R/O volume by preference, R/W
 *           if not available
 * - Rule 3: If parent volume is R/W, then only mount R/W volume unless
 *           explicitly told otherwise
 */
D
David Howells 已提交
44
struct afs_volume *afs_volume_lookup(struct afs_mount_params *params)
L
Linus Torvalds 已提交
45 46 47
{
	struct afs_vlocation *vlocation = NULL;
	struct afs_volume *volume = NULL;
48
	struct afs_server *server = NULL;
L
Linus Torvalds 已提交
49
	char srvtmask;
D
David Howells 已提交
50
	int ret, loop;
L
Linus Torvalds 已提交
51

D
David Howells 已提交
52 53
	_enter("{%*.*s,%d}",
	       params->volnamesz, params->volnamesz, params->volname, params->rwpath);
L
Linus Torvalds 已提交
54 55

	/* lookup the volume location record */
D
David Howells 已提交
56 57
	vlocation = afs_vlocation_lookup(params->cell, params->key,
					 params->volname, params->volnamesz);
58 59 60
	if (IS_ERR(vlocation)) {
		ret = PTR_ERR(vlocation);
		vlocation = NULL;
L
Linus Torvalds 已提交
61
		goto error;
62
	}
L
Linus Torvalds 已提交
63 64 65

	/* make the final decision on the type we want */
	ret = -ENOMEDIUM;
D
David Howells 已提交
66
	if (params->force && !(vlocation->vldb.vidmask & (1 << params->type)))
L
Linus Torvalds 已提交
67 68 69 70 71 72
		goto error;

	srvtmask = 0;
	for (loop = 0; loop < vlocation->vldb.nservers; loop++)
		srvtmask |= vlocation->vldb.srvtmask[loop];

D
David Howells 已提交
73 74
	if (params->force) {
		if (!(srvtmask & (1 << params->type)))
L
Linus Torvalds 已提交
75
			goto error;
D
David Howells 已提交
76
	} else if (srvtmask & AFS_VOL_VTM_RO) {
D
David Howells 已提交
77
		params->type = AFSVL_ROVOL;
D
David Howells 已提交
78
	} else if (srvtmask & AFS_VOL_VTM_RW) {
D
David Howells 已提交
79
		params->type = AFSVL_RWVOL;
D
David Howells 已提交
80
	} else {
L
Linus Torvalds 已提交
81 82 83
		goto error;
	}

D
David Howells 已提交
84
	down_write(&params->cell->vl_sem);
L
Linus Torvalds 已提交
85 86

	/* is the volume already active? */
D
David Howells 已提交
87
	if (vlocation->vols[params->type]) {
L
Linus Torvalds 已提交
88
		/* yes - re-use it */
D
David Howells 已提交
89
		volume = vlocation->vols[params->type];
L
Linus Torvalds 已提交
90 91 92 93 94 95 96 97
		afs_get_volume(volume);
		goto success;
	}

	/* create a new volume record */
	_debug("creating new volume record");

	ret = -ENOMEM;
98
	volume = kzalloc(sizeof(struct afs_volume), GFP_KERNEL);
L
Linus Torvalds 已提交
99 100 101 102
	if (!volume)
		goto error_up;

	atomic_set(&volume->usage, 1);
D
David Howells 已提交
103 104 105 106
	volume->type		= params->type;
	volume->type_force	= params->force;
	volume->cell		= params->cell;
	volume->vid		= vlocation->vldb.vid[params->type];
L
Linus Torvalds 已提交
107 108 109 110 111 112

	init_rwsem(&volume->server_sem);

	/* look up all the applicable server records */
	for (loop = 0; loop < 8; loop++) {
		if (vlocation->vldb.srvtmask[loop] & (1 << volume->type)) {
113 114 115 116
			server = afs_lookup_server(
			       volume->cell, &vlocation->vldb.servers[loop]);
			if (IS_ERR(server)) {
				ret = PTR_ERR(server);
L
Linus Torvalds 已提交
117
				goto error_discard;
118
			}
L
Linus Torvalds 已提交
119

120
			volume->servers[volume->nservers] = server;
L
Linus Torvalds 已提交
121 122 123 124 125 126 127 128 129 130 131 132 133 134 135
			volume->nservers++;
		}
	}

	/* attach the cache and volume location */
#ifdef AFS_CACHING_SUPPORT
	cachefs_acquire_cookie(vlocation->cache,
			       &afs_vnode_cache_index_def,
			       volume,
			       &volume->cache);
#endif

	afs_get_vlocation(vlocation);
	volume->vlocation = vlocation;

D
David Howells 已提交
136
	vlocation->vols[volume->type] = volume;
L
Linus Torvalds 已提交
137

D
David Howells 已提交
138
success:
L
Linus Torvalds 已提交
139 140
	_debug("kAFS selected %s volume %08x",
	       afs_voltypes[volume->type], volume->vid);
D
David Howells 已提交
141
	up_write(&params->cell->vl_sem);
142 143 144
	afs_put_vlocation(vlocation);
	_leave(" = %p", volume);
	return volume;
L
Linus Torvalds 已提交
145 146

	/* clean up */
D
David Howells 已提交
147
error_up:
D
David Howells 已提交
148
	up_write(&params->cell->vl_sem);
D
David Howells 已提交
149
error:
L
Linus Torvalds 已提交
150
	afs_put_vlocation(vlocation);
151 152
	_leave(" = %d", ret);
	return ERR_PTR(ret);
L
Linus Torvalds 已提交
153

D
David Howells 已提交
154
error_discard:
D
David Howells 已提交
155
	up_write(&params->cell->vl_sem);
L
Linus Torvalds 已提交
156 157 158 159 160 161

	for (loop = volume->nservers - 1; loop >= 0; loop--)
		afs_put_server(volume->servers[loop]);

	kfree(volume);
	goto error;
D
David Howells 已提交
162
}
L
Linus Torvalds 已提交
163 164 165 166 167 168 169 170 171 172 173 174 175 176

/*
 * destroy a volume record
 */
void afs_put_volume(struct afs_volume *volume)
{
	struct afs_vlocation *vlocation;
	int loop;

	if (!volume)
		return;

	_enter("%p", volume);

177
	ASSERTCMP(atomic_read(&volume->usage), >, 0);
L
Linus Torvalds 已提交
178

179
	vlocation = volume->vlocation;
L
Linus Torvalds 已提交
180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206

	/* to prevent a race, the decrement and the dequeue must be effectively
	 * atomic */
	down_write(&vlocation->cell->vl_sem);

	if (likely(!atomic_dec_and_test(&volume->usage))) {
		up_write(&vlocation->cell->vl_sem);
		_leave("");
		return;
	}

	vlocation->vols[volume->type] = NULL;

	up_write(&vlocation->cell->vl_sem);

	/* finish cleaning up the volume */
#ifdef AFS_CACHING_SUPPORT
	cachefs_relinquish_cookie(volume->cache, 0);
#endif
	afs_put_vlocation(vlocation);

	for (loop = volume->nservers - 1; loop >= 0; loop--)
		afs_put_server(volume->servers[loop]);

	kfree(volume);

	_leave(" [destroyed]");
D
David Howells 已提交
207
}
L
Linus Torvalds 已提交
208 209 210 211 212

/*
 * pick a server to use to try accessing this volume
 * - returns with an elevated usage count on the server chosen
 */
213
struct afs_server *afs_volume_pick_fileserver(struct afs_vnode *vnode)
L
Linus Torvalds 已提交
214
{
215
	struct afs_volume *volume = vnode->volume;
L
Linus Torvalds 已提交
216 217 218 219 220
	struct afs_server *server;
	int ret, state, loop;

	_enter("%s", volume->vlocation->vldb.name);

221 222 223 224 225 226 227
	/* stick with the server we're already using if we can */
	if (vnode->server && vnode->server->fs_state == 0) {
		afs_get_server(vnode->server);
		_leave(" = %p [current]", vnode->server);
		return vnode->server;
	}

L
Linus Torvalds 已提交
228 229 230 231 232 233 234
	down_read(&volume->server_sem);

	/* handle the no-server case */
	if (volume->nservers == 0) {
		ret = volume->rjservers ? -ENOMEDIUM : -ESTALE;
		up_read(&volume->server_sem);
		_leave(" = %d [no servers]", ret);
235
		return ERR_PTR(ret);
L
Linus Torvalds 已提交
236 237 238 239 240 241 242 243 244
	}

	/* basically, just search the list for the first live server and use
	 * that */
	ret = 0;
	for (loop = 0; loop < volume->nservers; loop++) {
		server = volume->servers[loop];
		state = server->fs_state;

245 246
		_debug("consider %d [%d]", loop, state);

L
Linus Torvalds 已提交
247 248 249 250 251
		switch (state) {
			/* found an apparently healthy server */
		case 0:
			afs_get_server(server);
			up_read(&volume->server_sem);
252 253 254
			_leave(" = %p (picked %08x)",
			       server, ntohl(server->addr.s_addr));
			return server;
L
Linus Torvalds 已提交
255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289

		case -ENETUNREACH:
			if (ret == 0)
				ret = state;
			break;

		case -EHOSTUNREACH:
			if (ret == 0 ||
			    ret == -ENETUNREACH)
				ret = state;
			break;

		case -ECONNREFUSED:
			if (ret == 0 ||
			    ret == -ENETUNREACH ||
			    ret == -EHOSTUNREACH)
				ret = state;
			break;

		default:
		case -EREMOTEIO:
			if (ret == 0 ||
			    ret == -ENETUNREACH ||
			    ret == -EHOSTUNREACH ||
			    ret == -ECONNREFUSED)
				ret = state;
			break;
		}
	}

	/* no available servers
	 * - TODO: handle the no active servers case better
	 */
	up_read(&volume->server_sem);
	_leave(" = %d", ret);
290
	return ERR_PTR(ret);
D
David Howells 已提交
291
}
L
Linus Torvalds 已提交
292 293 294 295 296 297 298

/*
 * release a server after use
 * - releases the ref on the server struct that was acquired by picking
 * - records result of using a particular server to access a volume
 * - return 0 to try again, 1 if okay or to issue error
 */
299
int afs_volume_release_fileserver(struct afs_vnode *vnode,
L
Linus Torvalds 已提交
300 301 302
				  struct afs_server *server,
				  int result)
{
303
	struct afs_volume *volume = vnode->volume;
L
Linus Torvalds 已提交
304 305 306 307 308 309 310 311 312 313
	unsigned loop;

	_enter("%s,%08x,%d",
	       volume->vlocation->vldb.name, ntohl(server->addr.s_addr),
	       result);

	switch (result) {
		/* success */
	case 0:
		server->fs_act_jif = jiffies;
314
		server->fs_state = 0;
L
Linus Torvalds 已提交
315 316 317 318 319 320 321
		break;

		/* the fileserver denied all knowledge of the volume */
	case -ENOMEDIUM:
		server->fs_act_jif = jiffies;
		down_write(&volume->server_sem);

322
		/* firstly, find where the server is in the active list (if it
L
Linus Torvalds 已提交
323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359
		 * is) */
		for (loop = 0; loop < volume->nservers; loop++)
			if (volume->servers[loop] == server)
				goto present;

		/* no longer there - may have been discarded by another op */
		goto try_next_server_upw;

	present:
		volume->nservers--;
		memmove(&volume->servers[loop],
			&volume->servers[loop + 1],
			sizeof(volume->servers[loop]) *
			(volume->nservers - loop));
		volume->servers[volume->nservers] = NULL;
		afs_put_server(server);
		volume->rjservers++;

		if (volume->nservers > 0)
			/* another server might acknowledge its existence */
			goto try_next_server_upw;

		/* handle the case where all the fileservers have rejected the
		 * volume
		 * - TODO: try asking the fileservers for volume information
		 * - TODO: contact the VL server again to see if the volume is
		 *         no longer registered
		 */
		up_write(&volume->server_sem);
		afs_put_server(server);
		_leave(" [completely rejected]");
		return 1;

		/* problem reaching the server */
	case -ENETUNREACH:
	case -EHOSTUNREACH:
	case -ECONNREFUSED:
360
	case -ETIME:
L
Linus Torvalds 已提交
361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388
	case -ETIMEDOUT:
	case -EREMOTEIO:
		/* mark the server as dead
		 * TODO: vary dead timeout depending on error
		 */
		spin_lock(&server->fs_lock);
		if (!server->fs_state) {
			server->fs_dead_jif = jiffies + HZ * 10;
			server->fs_state = result;
			printk("kAFS: SERVER DEAD state=%d\n", result);
		}
		spin_unlock(&server->fs_lock);
		goto try_next_server;

		/* miscellaneous error */
	default:
		server->fs_act_jif = jiffies;
	case -ENOMEM:
	case -ENONET:
		break;
	}

	/* tell the caller to accept the result */
	afs_put_server(server);
	_leave("");
	return 1;

	/* tell the caller to loop around and try the next server */
D
David Howells 已提交
389
try_next_server_upw:
L
Linus Torvalds 已提交
390
	up_write(&volume->server_sem);
D
David Howells 已提交
391
try_next_server:
L
Linus Torvalds 已提交
392 393 394
	afs_put_server(server);
	_leave(" [try next server]");
	return 0;
D
David Howells 已提交
395
}