vfs_inode.c 28.4 KB
Newer Older
1 2 3
/*
 *  linux/fs/9p/vfs_inode.c
 *
4
 * This file contains vfs inode ops for the 9P2000 protocol.
5 6 7 8 9
 *
 *  Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
 *  Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
 *
 *  This program is free software; you can redistribute it and/or modify
10 11
 *  it under the terms of the GNU General Public License version 2
 *  as published by the Free Software Foundation.
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
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to:
 *  Free Software Foundation
 *  51 Franklin Street, Fifth Floor
 *  Boston, MA  02111-1301  USA
 *
 */

#include <linux/module.h>
#include <linux/errno.h>
#include <linux/fs.h>
#include <linux/file.h>
#include <linux/pagemap.h>
#include <linux/stat.h>
#include <linux/string.h>
#include <linux/inet.h>
#include <linux/namei.h>
#include <linux/idr.h>

#include "debug.h"
#include "v9fs.h"
#include "9p.h"
#include "v9fs_vfs.h"
#include "fid.h"

43 44 45 46
static const struct inode_operations v9fs_dir_inode_operations;
static const struct inode_operations v9fs_dir_inode_operations_ext;
static const struct inode_operations v9fs_file_inode_operations;
static const struct inode_operations v9fs_symlink_inode_operations;
47 48 49 50 51 52 53 54

/**
 * unixmode2p9mode - convert unix mode bits to plan 9
 * @v9ses: v9fs session information
 * @mode: mode to convert
 *
 */

55
static int unixmode2p9mode(struct v9fs_session_info *v9ses, int mode)
56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
{
	int res;
	res = mode & 0777;
	if (S_ISDIR(mode))
		res |= V9FS_DMDIR;
	if (v9ses->extended) {
		if (S_ISLNK(mode))
			res |= V9FS_DMSYMLINK;
		if (v9ses->nodev == 0) {
			if (S_ISSOCK(mode))
				res |= V9FS_DMSOCKET;
			if (S_ISFIFO(mode))
				res |= V9FS_DMNAMEDPIPE;
			if (S_ISBLK(mode))
				res |= V9FS_DMDEVICE;
			if (S_ISCHR(mode))
				res |= V9FS_DMDEVICE;
		}

		if ((mode & S_ISUID) == S_ISUID)
			res |= V9FS_DMSETUID;
		if ((mode & S_ISGID) == S_ISGID)
			res |= V9FS_DMSETGID;
		if ((mode & V9FS_DMLINK))
			res |= V9FS_DMLINK;
	}

	return res;
}

/**
 * p9mode2unixmode- convert plan9 mode bits to unix mode bits
 * @v9ses: v9fs session information
 * @mode: mode to convert
 *
 */

93
static int p9mode2unixmode(struct v9fs_session_info *v9ses, int mode)
94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125
{
	int res;

	res = mode & 0777;

	if ((mode & V9FS_DMDIR) == V9FS_DMDIR)
		res |= S_IFDIR;
	else if ((mode & V9FS_DMSYMLINK) && (v9ses->extended))
		res |= S_IFLNK;
	else if ((mode & V9FS_DMSOCKET) && (v9ses->extended)
		 && (v9ses->nodev == 0))
		res |= S_IFSOCK;
	else if ((mode & V9FS_DMNAMEDPIPE) && (v9ses->extended)
		 && (v9ses->nodev == 0))
		res |= S_IFIFO;
	else if ((mode & V9FS_DMDEVICE) && (v9ses->extended)
		 && (v9ses->nodev == 0))
		res |= S_IFBLK;
	else
		res |= S_IFREG;

	if (v9ses->extended) {
		if ((mode & V9FS_DMSETUID) == V9FS_DMSETUID)
			res |= S_ISUID;

		if ((mode & V9FS_DMSETGID) == V9FS_DMSETGID)
			res |= S_ISGID;
	}

	return res;
}

126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157
int v9fs_uflags2omode(int uflags)
{
	int ret;

	ret = 0;
	switch (uflags&3) {
	default:
	case O_RDONLY:
		ret = V9FS_OREAD;
		break;

	case O_WRONLY:
		ret = V9FS_OWRITE;
		break;

	case O_RDWR:
		ret = V9FS_ORDWR;
		break;
	}

	if (uflags & O_EXCL)
		ret |= V9FS_OEXCL;

	if (uflags & O_TRUNC)
		ret |= V9FS_OTRUNC;

	if (uflags & O_APPEND)
		ret |= V9FS_OAPPEND;

	return ret;
}

158
/**
159
 * v9fs_blank_wstat - helper function to setup a 9P stat structure
160
 * @v9ses: 9P session info (for determining extended mode)
161
 * @wstat: structure to initialize
162 163 164
 *
 */

165
static void
166
v9fs_blank_wstat(struct v9fs_wstat *wstat)
167
{
168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184
	wstat->type = ~0;
	wstat->dev = ~0;
	wstat->qid.type = ~0;
	wstat->qid.version = ~0;
	*((long long *)&wstat->qid.path) = ~0;
	wstat->mode = ~0;
	wstat->atime = ~0;
	wstat->mtime = ~0;
	wstat->length = ~0;
	wstat->name = NULL;
	wstat->uid = NULL;
	wstat->gid = NULL;
	wstat->muid = NULL;
	wstat->n_uid = ~0;
	wstat->n_gid = ~0;
	wstat->n_muid = ~0;
	wstat->extension = NULL;
185 186 187 188 189 190 191 192 193 194 195
}

/**
 * v9fs_get_inode - helper function to setup an inode
 * @sb: superblock
 * @mode: mode to setup inode with
 *
 */

struct inode *v9fs_get_inode(struct super_block *sb, int mode)
{
196
	struct inode *inode;
197
	struct v9fs_session_info *v9ses = sb->s_fs_info;
198 199 200 201 202 203 204 205 206 207 208

	dprintk(DEBUG_VFS, "super block: %p mode: %o\n", sb, mode);

	inode = new_inode(sb);
	if (inode) {
		inode->i_mode = mode;
		inode->i_uid = current->fsuid;
		inode->i_gid = current->fsgid;
		inode->i_blocks = 0;
		inode->i_rdev = 0;
		inode->i_atime = inode->i_mtime = inode->i_ctime = CURRENT_TIME;
209
		inode->i_mapping->a_ops = &v9fs_addr_operations;
210 211 212 213 214 215

		switch (mode & S_IFMT) {
		case S_IFIFO:
		case S_IFBLK:
		case S_IFCHR:
		case S_IFSOCK:
216 217 218 219
			if(!v9ses->extended) {
				dprintk(DEBUG_ERROR, "special files without extended mode\n");
				return ERR_PTR(-EINVAL);
			}
220 221 222
			init_special_inode(inode, inode->i_mode,
					   inode->i_rdev);
			break;
223 224 225 226
		case S_IFREG:
			inode->i_op = &v9fs_file_inode_operations;
			inode->i_fop = &v9fs_file_operations;
			break;
227 228 229 230 231 232 233
		case S_IFLNK:
			if(!v9ses->extended) {
				dprintk(DEBUG_ERROR, "extended modes used w/o 9P2000.u\n");
				return ERR_PTR(-EINVAL);
			}
			inode->i_op = &v9fs_symlink_inode_operations;
			break;
234
		case S_IFDIR:
235
			inc_nlink(inode);
236 237 238 239
			if(v9ses->extended)
				inode->i_op = &v9fs_dir_inode_operations_ext;
			else
				inode->i_op = &v9fs_dir_inode_operations;
240 241 242 243 244 245 246 247 248 249 250 251 252 253 254
			inode->i_fop = &v9fs_dir_operations;
			break;
		default:
			dprintk(DEBUG_ERROR, "BAD mode 0x%x S_IFMT 0x%x\n",
				mode, mode & S_IFMT);
			return ERR_PTR(-EINVAL);
		}
	} else {
		eprintk(KERN_WARNING, "Problem allocating inode\n");
		return ERR_PTR(-ENOMEM);
	}
	return inode;
}

static int
255 256
v9fs_create(struct v9fs_session_info *v9ses, u32 pfid, char *name, u32 perm,
	u8 mode, char *extension, u32 *fidp, struct v9fs_qid *qid, u32 *iounit)
257
{
258
	int fid;
259
	int err;
260
	struct v9fs_fcall *fcall;
261

262 263
	fid = v9fs_get_idpool(&v9ses->fidpool);
	if (fid < 0) {
264
		eprintk(KERN_WARNING, "no free fids available\n");
265
		return -ENOSPC;
266 267
	}

268 269
	err = v9fs_t_walk(v9ses, pfid, fid, NULL, &fcall);
	if (err < 0) {
270
		PRINT_FCALL_ERROR("clone error", fcall);
271 272 273 274
		if (fcall && fcall->id == RWALK)
			goto clunk_fid;
		else
			goto put_fid;
275 276 277
	}
	kfree(fcall);

278
	err = v9fs_t_create(v9ses, fid, name, perm, mode, extension, &fcall);
279
	if (err < 0) {
280
		PRINT_FCALL_ERROR("create fails", fcall);
281
		goto clunk_fid;
282 283
	}

284 285 286 287 288 289 290 291 292
	if (iounit)
		*iounit = fcall->params.rcreate.iounit;

	if (qid)
		*qid = fcall->params.rcreate.qid;

	if (fidp)
		*fidp = fid;

293
	kfree(fcall);
294
	return 0;
295

296 297 298 299 300
clunk_fid:
	v9fs_t_clunk(v9ses, fid);
	fid = V9FS_NOFID;

put_fid:
301
	if (fid != V9FS_NOFID)
302
		v9fs_put_idpool(fid, &v9ses->fidpool);
303

304 305 306
	kfree(fcall);
	return err;
}
307

308 309 310 311
static struct v9fs_fid*
v9fs_clone_walk(struct v9fs_session_info *v9ses, u32 fid, struct dentry *dentry)
{
	int err;
312
	int nfid;
313 314 315 316 317
	struct v9fs_fid *ret;
	struct v9fs_fcall *fcall;

	nfid = v9fs_get_idpool(&v9ses->fidpool);
	if (nfid < 0) {
318
		eprintk(KERN_WARNING, "no free fids available\n");
319
		return ERR_PTR(-ENOSPC);
320 321
	}

322 323 324 325
	err = v9fs_t_walk(v9ses, fid, nfid, (char *) dentry->d_name.name,
		&fcall);

	if (err < 0) {
326 327 328
		if (fcall && fcall->id == RWALK)
			goto clunk_fid;

329 330 331
		PRINT_FCALL_ERROR("walk error", fcall);
		v9fs_put_idpool(nfid, &v9ses->fidpool);
		goto error;
332
	}
333

334 335
	kfree(fcall);
	fcall = NULL;
336 337 338 339 340
	ret = v9fs_fid_create(v9ses, nfid);
	if (!ret) {
		err = -ENOMEM;
		goto clunk_fid;
	}
341

342 343 344 345
	err = v9fs_fid_insert(ret, dentry);
	if (err < 0) {
		v9fs_fid_destroy(ret);
		goto clunk_fid;
346
	}
347

348
	return ret;
349

350 351
clunk_fid:
	v9fs_t_clunk(v9ses, nfid);
352

353 354 355 356
error:
	kfree(fcall);
	return ERR_PTR(err);
}
357

358
static struct inode *
359 360 361 362 363 364
v9fs_inode_from_fid(struct v9fs_session_info *v9ses, u32 fid,
	struct super_block *sb)
{
	int err, umode;
	struct inode *ret;
	struct v9fs_fcall *fcall;
365

366 367 368 369 370
	ret = NULL;
	err = v9fs_t_stat(v9ses, fid, &fcall);
	if (err) {
		PRINT_FCALL_ERROR("stat error", fcall);
		goto error;
371 372
	}

373 374 375 376 377 378 379
	umode = p9mode2unixmode(v9ses, fcall->params.rstat.stat.mode);
	ret = v9fs_get_inode(sb, umode);
	if (IS_ERR(ret)) {
		err = PTR_ERR(ret);
		ret = NULL;
		goto error;
	}
380

381 382 383
	v9fs_stat2inode(&fcall->params.rstat.stat, ret, sb);
	kfree(fcall);
	return ret;
384

385
error:
386
	kfree(fcall);
387 388
	if (ret)
		iput(ret);
389

390
	return ERR_PTR(err);
391 392 393 394
}

/**
 * v9fs_remove - helper function to remove files and directories
395 396 397
 * @dir: directory inode that is being deleted
 * @file:  dentry that is being deleted
 * @rmdir: removing a directory
398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416
 *
 */

static int v9fs_remove(struct inode *dir, struct dentry *file, int rmdir)
{
	struct v9fs_fcall *fcall = NULL;
	struct super_block *sb = NULL;
	struct v9fs_session_info *v9ses = NULL;
	struct v9fs_fid *v9fid = NULL;
	struct inode *file_inode = NULL;
	int fid = -1;
	int result = 0;

	dprintk(DEBUG_VFS, "inode: %p dentry: %p rmdir: %d\n", dir, file,
		rmdir);

	file_inode = file->d_inode;
	sb = file_inode->i_sb;
	v9ses = v9fs_inode2v9ses(file_inode);
417
	v9fid = v9fs_fid_clone(file);
418 419
	if(IS_ERR(v9fid))
		return PTR_ERR(v9fid);
420 421 422 423 424 425 426 427 428

	fid = v9fid->fid;
	if (fid < 0) {
		dprintk(DEBUG_ERROR, "inode #%lu, no fid!\n",
			file_inode->i_ino);
		return -EBADF;
	}

	result = v9fs_t_remove(v9ses, fid, &fcall);
429 430
	if (result < 0) {
		PRINT_FCALL_ERROR("remove fails", fcall);
431
		goto Error;
432 433
	}

434 435 436
	v9fs_put_idpool(fid, &v9ses->fidpool);
	v9fs_fid_destroy(v9fid);

437
Error:
438 439 440 441
	kfree(fcall);
	return result;
}

442 443 444 445 446 447
static int
v9fs_open_created(struct inode *inode, struct file *file)
{
	return 0;
}

448 449 450 451
/**
 * v9fs_vfs_create - VFS hook to create files
 * @inode: directory inode that is being deleted
 * @dentry:  dentry that is being deleted
452
 * @mode: create permissions
453 454 455 456 457
 * @nd: path information
 *
 */

static int
458
v9fs_vfs_create(struct inode *dir, struct dentry *dentry, int mode,
459 460
		struct nameidata *nd)
{
461 462 463 464 465 466 467 468 469 470 471 472
	int err;
	u32 fid, perm, iounit;
	int flags;
	struct v9fs_session_info *v9ses;
	struct v9fs_fid *dfid, *vfid, *ffid;
	struct inode *inode;
	struct v9fs_qid qid;
	struct file *filp;

	inode = NULL;
	vfid = NULL;
	v9ses = v9fs_inode2v9ses(dir);
473 474 475 476 477
	dfid = v9fs_fid_clone(dentry->d_parent);
	if(IS_ERR(dfid)) {
		err = PTR_ERR(dfid);
		goto error;
	}
478

479
	perm = unixmode2p9mode(v9ses, mode);
480 481 482 483 484 485
	if (nd && nd->flags & LOOKUP_OPEN)
		flags = nd->intent.open.flags - 1;
	else
		flags = O_RDWR;

	err = v9fs_create(v9ses, dfid->fid, (char *) dentry->d_name.name,
486
		perm, v9fs_uflags2omode(flags), NULL, &fid, &qid, &iounit);
487 488

	if (err)
489
		goto clunk_dfid;
490 491

	vfid = v9fs_clone_walk(v9ses, dfid->fid, dentry);
492
	v9fs_fid_clunk(v9ses, dfid);
493 494 495 496 497 498 499 500 501 502 503 504 505
	if (IS_ERR(vfid)) {
		err = PTR_ERR(vfid);
		vfid = NULL;
		goto error;
	}

	inode = v9fs_inode_from_fid(v9ses, vfid->fid, dir->i_sb);
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
		inode = NULL;
		goto error;
	}

506 507 508 509
	if(v9ses->cache)
		dentry->d_op = &v9fs_cached_dentry_operations;
	else
		dentry->d_op = &v9fs_dentry_operations;
510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532
	d_instantiate(dentry, inode);

	if (nd && nd->flags & LOOKUP_OPEN) {
		ffid = v9fs_fid_create(v9ses, fid);
		if (!ffid)
			return -ENOMEM;

		filp = lookup_instantiate_filp(nd, dentry, v9fs_open_created);
		if (IS_ERR(filp)) {
			v9fs_fid_destroy(ffid);
			return PTR_ERR(filp);
		}

		ffid->rdir_pos = 0;
		ffid->rdir_fcall = NULL;
		ffid->fidopen = 1;
		ffid->iounit = iounit;
		ffid->filp = filp;
		filp->private_data = ffid;
	}

	return 0;

533 534 535
clunk_dfid:
	v9fs_fid_clunk(v9ses, dfid);

536 537 538 539 540
error:
	if (vfid)
		v9fs_fid_destroy(vfid);

	return err;
541 542 543 544
}

/**
 * v9fs_vfs_mkdir - VFS mkdir hook to create a directory
545
 * @inode:  inode that is being unlinked
546 547 548 549 550
 * @dentry: dentry that is being unlinked
 * @mode: mode for new directory
 *
 */

551
static int v9fs_vfs_mkdir(struct inode *dir, struct dentry *dentry, int mode)
552
{
553 554 555 556 557 558 559 560 561
	int err;
	u32 fid, perm;
	struct v9fs_session_info *v9ses;
	struct v9fs_fid *dfid, *vfid;
	struct inode *inode;

	inode = NULL;
	vfid = NULL;
	v9ses = v9fs_inode2v9ses(dir);
562 563 564 565 566 567
	dfid = v9fs_fid_clone(dentry->d_parent);
	if(IS_ERR(dfid)) {
		err = PTR_ERR(dfid);
		goto error;
	}

568 569 570
	perm = unixmode2p9mode(v9ses, mode | S_IFDIR);

	err = v9fs_create(v9ses, dfid->fid, (char *) dentry->d_name.name,
571
		perm, V9FS_OREAD, NULL, &fid, NULL, NULL);
572 573 574

	if (err) {
		dprintk(DEBUG_ERROR, "create error %d\n", err);
575
		goto clean_up_dfid;
576 577 578 579 580 581
	}

	vfid = v9fs_clone_walk(v9ses, dfid->fid, dentry);
	if (IS_ERR(vfid)) {
		err = PTR_ERR(vfid);
		vfid = NULL;
582
		goto clean_up_dfid;
583 584
	}

585
	v9fs_fid_clunk(v9ses, dfid);
586 587 588 589
	inode = v9fs_inode_from_fid(v9ses, vfid->fid, dir->i_sb);
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
		inode = NULL;
590 591
		v9fs_fid_destroy(vfid);
		goto error;
592 593
	}

594 595 596 597
	if(v9ses->cache)
		dentry->d_op = &v9fs_cached_dentry_operations;
	else
		dentry->d_op = &v9fs_dentry_operations;
598 599 600
	d_instantiate(dentry, inode);
	return 0;

601 602 603 604
clean_up_dfid:
	v9fs_fid_clunk(v9ses, dfid);

error:
605
	return err;
606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629
}

/**
 * v9fs_vfs_lookup - VFS lookup hook to "walk" to a new inode
 * @dir:  inode that is being walked from
 * @dentry: dentry that is being walked to?
 * @nameidata: path data
 *
 */

static struct dentry *v9fs_vfs_lookup(struct inode *dir, struct dentry *dentry,
				      struct nameidata *nameidata)
{
	struct super_block *sb;
	struct v9fs_session_info *v9ses;
	struct v9fs_fid *dirfid;
	struct v9fs_fid *fid;
	struct inode *inode;
	struct v9fs_fcall *fcall = NULL;
	int dirfidnum = -1;
	int newfid = -1;
	int result = 0;

	dprintk(DEBUG_VFS, "dir: %p dentry: (%s) %p nameidata: %p\n",
630
		dir, dentry->d_name.name, dentry, nameidata);
631 632 633

	sb = dir->i_sb;
	v9ses = v9fs_inode2v9ses(dir);
634
	dirfid = v9fs_fid_lookup(dentry->d_parent);
635

636 637
	if(IS_ERR(dirfid))
		return ERR_PTR(PTR_ERR(dirfid));
638 639 640 641 642 643

	dirfidnum = dirfid->fid;

	newfid = v9fs_get_idpool(&v9ses->fidpool);
	if (newfid < 0) {
		eprintk(KERN_WARNING, "newfid fails!\n");
644 645
		result = -ENOSPC;
		goto Release_Dirfid;
646 647
	}

648
	result = v9fs_t_walk(v9ses, dirfidnum, newfid,
649 650
		(char *)dentry->d_name.name, &fcall);

651 652
	up(&dirfid->lock);

653
	if (result < 0) {
654 655 656 657 658
		if (fcall && fcall->id == RWALK)
			v9fs_t_clunk(v9ses, newfid);
		else
			v9fs_put_idpool(newfid, &v9ses->fidpool);

659 660
		if (result == -ENOENT) {
			d_add(dentry, NULL);
661
			dprintk(DEBUG_VFS,
662 663
				"Return negative dentry %p count %d\n",
				dentry, atomic_read(&dentry->d_count));
664
			kfree(fcall);
665 666 667 668 669
			return NULL;
		}
		dprintk(DEBUG_ERROR, "walk error:%d\n", result);
		goto FreeFcall;
	}
670
	kfree(fcall);
671 672 673 674 675 676 677

	result = v9fs_t_stat(v9ses, newfid, &fcall);
	if (result < 0) {
		dprintk(DEBUG_ERROR, "stat error\n");
		goto FreeFcall;
	}

678 679
	inode = v9fs_get_inode(sb, p9mode2unixmode(v9ses,
		fcall->params.rstat.stat.mode));
680 681 682 683 684 685 686 687 688

	if (IS_ERR(inode) && (PTR_ERR(inode) == -ENOSPC)) {
		eprintk(KERN_WARNING, "inode alloc failes, returns %ld\n",
			PTR_ERR(inode));

		result = -ENOSPC;
		goto FreeFcall;
	}

689
	inode->i_ino = v9fs_qid2ino(&fcall->params.rstat.stat.qid);
690

691
	fid = v9fs_fid_create(v9ses, newfid);
692 693 694 695 696 697
	if (fid == NULL) {
		dprintk(DEBUG_ERROR, "couldn't insert\n");
		result = -ENOMEM;
		goto FreeFcall;
	}

698 699 700 701
	result = v9fs_fid_insert(fid, dentry);
	if (result < 0)
		goto FreeFcall;

702 703
	fid->qid = fcall->params.rstat.stat.qid;
	v9fs_stat2inode(&fcall->params.rstat.stat, inode, inode->i_sb);
704 705 706 707
	if((fid->qid.version)&&(v9ses->cache))
		dentry->d_op = &v9fs_cached_dentry_operations;
	else
		dentry->d_op = &v9fs_dentry_operations;
708 709 710 711 712 713

	d_add(dentry, inode);
	kfree(fcall);

	return NULL;

714 715 716 717
Release_Dirfid:
	up(&dirfid->lock);

FreeFcall:
718
	kfree(fcall);
719

720 721 722 723 724 725
	return ERR_PTR(result);
}

/**
 * v9fs_vfs_unlink - VFS unlink hook to delete an inode
 * @i:  inode that is being unlinked
726
 * @d: dentry that is being unlinked
727 728 729 730 731 732 733 734 735 736 737
 *
 */

static int v9fs_vfs_unlink(struct inode *i, struct dentry *d)
{
	return v9fs_remove(i, d, 0);
}

/**
 * v9fs_vfs_rmdir - VFS unlink hook to delete a directory
 * @i:  inode that is being unlinked
738
 * @d: dentry that is being unlinked
739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761
 *
 */

static int v9fs_vfs_rmdir(struct inode *i, struct dentry *d)
{
	return v9fs_remove(i, d, 1);
}

/**
 * v9fs_vfs_rename - VFS hook to rename an inode
 * @old_dir:  old dir inode
 * @old_dentry: old dentry
 * @new_dir: new dir inode
 * @new_dentry: new dentry
 *
 */

static int
v9fs_vfs_rename(struct inode *old_dir, struct dentry *old_dentry,
		struct inode *new_dir, struct dentry *new_dentry)
{
	struct inode *old_inode = old_dentry->d_inode;
	struct v9fs_session_info *v9ses = v9fs_inode2v9ses(old_inode);
762
	struct v9fs_fid *oldfid = v9fs_fid_lookup(old_dentry);
763 764
	struct v9fs_fid *olddirfid;
	struct v9fs_fid *newdirfid;
765
	struct v9fs_wstat wstat;
766 767 768 769 770 771 772 773
	struct v9fs_fcall *fcall = NULL;
	int fid = -1;
	int olddirfidnum = -1;
	int newdirfidnum = -1;
	int retval = 0;

	dprintk(DEBUG_VFS, "\n");

774 775 776 777 778 779 780 781 782 783 784 785 786
	if(IS_ERR(oldfid))
		return PTR_ERR(oldfid);

	olddirfid = v9fs_fid_clone(old_dentry->d_parent);
	if(IS_ERR(olddirfid)) {
		retval = PTR_ERR(olddirfid);
		goto Release_lock;
	}

	newdirfid = v9fs_fid_clone(new_dentry->d_parent);
	if(IS_ERR(newdirfid)) {
		retval = PTR_ERR(newdirfid);
		goto Clunk_olddir;
787 788 789 790 791
	}

	/* 9P can only handle file rename in the same directory */
	if (memcmp(&olddirfid->qid, &newdirfid->qid, sizeof(newdirfid->qid))) {
		dprintk(DEBUG_ERROR, "old dir and new dir are different\n");
792
		retval = -EXDEV;
793
		goto Clunk_newdir;
794 795 796 797 798 799 800 801 802 803
	}

	fid = oldfid->fid;
	olddirfidnum = olddirfid->fid;
	newdirfidnum = newdirfid->fid;

	if (fid < 0) {
		dprintk(DEBUG_ERROR, "no fid for old file #%lu\n",
			old_inode->i_ino);
		retval = -EBADF;
804
		goto Clunk_newdir;
805 806
	}

807 808 809
	v9fs_blank_wstat(&wstat);
	wstat.muid = v9ses->name;
	wstat.name = (char *) new_dentry->d_name.name;
810

811
	retval = v9fs_t_wstat(v9ses, fid, &wstat, &fcall);
812 813

	if (retval < 0)
814
		PRINT_FCALL_ERROR("wstat error", fcall);
815 816

	kfree(fcall);
817 818 819 820 821 822 823 824 825 826

Clunk_newdir:
	v9fs_fid_clunk(v9ses, newdirfid);

Clunk_olddir:
	v9fs_fid_clunk(v9ses, olddirfid);

Release_lock:
	up(&oldfid->lock);

827 828 829 830
	return retval;
}

/**
A
Adrian Bunk 已提交
831
 * v9fs_vfs_getattr - retrieve file metadata
832 833 834 835 836 837 838 839 840 841 842 843
 * @mnt - mount information
 * @dentry - file to get attributes on
 * @stat - metadata structure to populate
 *
 */

static int
v9fs_vfs_getattr(struct vfsmount *mnt, struct dentry *dentry,
		 struct kstat *stat)
{
	struct v9fs_fcall *fcall = NULL;
	struct v9fs_session_info *v9ses = v9fs_inode2v9ses(dentry->d_inode);
844
	struct v9fs_fid *fid = v9fs_fid_clone(dentry);
845 846 847
	int err = -EPERM;

	dprintk(DEBUG_VFS, "dentry: %p\n", dentry);
848 849
	if(IS_ERR(fid))
		return PTR_ERR(fid);
850 851 852 853 854 855

	err = v9fs_t_stat(v9ses, fid->fid, &fcall);

	if (err < 0)
		dprintk(DEBUG_ERROR, "stat error\n");
	else {
856
		v9fs_stat2inode(&fcall->params.rstat.stat, dentry->d_inode,
857 858 859 860 861
				  dentry->d_inode->i_sb);
		generic_fillattr(dentry->d_inode, stat);
	}

	kfree(fcall);
862
	v9fs_fid_clunk(v9ses, fid);
863 864 865 866 867 868 869 870 871 872 873 874 875
	return err;
}

/**
 * v9fs_vfs_setattr - set file metadata
 * @dentry: file whose metadata to set
 * @iattr: metadata assignment structure
 *
 */

static int v9fs_vfs_setattr(struct dentry *dentry, struct iattr *iattr)
{
	struct v9fs_session_info *v9ses = v9fs_inode2v9ses(dentry->d_inode);
876
	struct v9fs_fid *fid = v9fs_fid_clone(dentry);
877
	struct v9fs_fcall *fcall = NULL;
878
	struct v9fs_wstat wstat;
879 880 881
	int res = -EPERM;

	dprintk(DEBUG_VFS, "\n");
882 883
	if(IS_ERR(fid))
		return PTR_ERR(fid);
884

885
	v9fs_blank_wstat(&wstat);
886
	if (iattr->ia_valid & ATTR_MODE)
887
		wstat.mode = unixmode2p9mode(v9ses, iattr->ia_mode);
888 889

	if (iattr->ia_valid & ATTR_MTIME)
890
		wstat.mtime = iattr->ia_mtime.tv_sec;
891 892

	if (iattr->ia_valid & ATTR_ATIME)
893
		wstat.atime = iattr->ia_atime.tv_sec;
894 895

	if (iattr->ia_valid & ATTR_SIZE)
896
		wstat.length = iattr->ia_size;
897 898

	if (v9ses->extended) {
899 900
		if (iattr->ia_valid & ATTR_UID)
			wstat.n_uid = iattr->ia_uid;
901

902 903
		if (iattr->ia_valid & ATTR_GID)
			wstat.n_gid = iattr->ia_gid;
904 905
	}

906
	res = v9fs_t_wstat(v9ses, fid->fid, &wstat, &fcall);
907 908

	if (res < 0)
909
		PRINT_FCALL_ERROR("wstat error", fcall);
910 911 912 913 914

	kfree(fcall);
	if (res >= 0)
		res = inode_setattr(dentry->d_inode, iattr);

915
	v9fs_fid_clunk(v9ses, fid);
916 917 918 919
	return res;
}

/**
920 921
 * v9fs_stat2inode - populate an inode structure with mistat info
 * @stat: Plan 9 metadata (mistat) structure
922 923 924 925 926 927
 * @inode: inode to populate
 * @sb: superblock of filesystem
 *
 */

void
928 929
v9fs_stat2inode(struct v9fs_stat *stat, struct inode *inode,
	struct super_block *sb)
930
{
931
	int n;
932
	char ext[32];
933 934 935 936
	struct v9fs_session_info *v9ses = sb->s_fs_info;

	inode->i_nlink = 1;

937 938 939
	inode->i_atime.tv_sec = stat->atime;
	inode->i_mtime.tv_sec = stat->mtime;
	inode->i_ctime.tv_sec = stat->mtime;
940

941 942
	inode->i_uid = v9ses->uid;
	inode->i_gid = v9ses->gid;
943 944

	if (v9ses->extended) {
945 946
		inode->i_uid = stat->n_uid;
		inode->i_gid = stat->n_gid;
947 948
	}

949
	inode->i_mode = p9mode2unixmode(v9ses, stat->mode);
950 951 952 953
	if ((S_ISBLK(inode->i_mode)) || (S_ISCHR(inode->i_mode))) {
		char type = 0;
		int major = -1;
		int minor = -1;
954

955 956 957 958 959
		n = stat->extension.len;
		if (n > sizeof(ext)-1)
			n = sizeof(ext)-1;
		memmove(ext, stat->extension.str, n);
		ext[n] = 0;
960
		sscanf(ext, "%c %u %u", &type, &major, &minor);
961 962 963 964 965 966 967 968
		switch (type) {
		case 'c':
			inode->i_mode &= ~S_IFBLK;
			inode->i_mode |= S_IFCHR;
			break;
		case 'b':
			break;
		default:
969 970
			dprintk(DEBUG_ERROR, "Unknown special type %c (%.*s)\n",
				type, stat->extension.len, stat->extension.str);
971 972 973 974 975
		};
		inode->i_rdev = MKDEV(major, minor);
	} else
		inode->i_rdev = 0;

976
	inode->i_size = stat->length;
977 978

	inode->i_blocks =
979
	    (inode->i_size + sb->s_blocksize - 1) >> sb->s_blocksize_bits;
980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004
}

/**
 * v9fs_qid2ino - convert qid into inode number
 * @qid: qid to hash
 *
 * BUG: potential for inode number collisions?
 */

ino_t v9fs_qid2ino(struct v9fs_qid *qid)
{
	u64 path = qid->path + 2;
	ino_t i = 0;

	if (sizeof(ino_t) == sizeof(path))
		memcpy(&i, &path, sizeof(ino_t));
	else
		i = (ino_t) (path ^ (path >> 32));

	return i;
}

/**
 * v9fs_readlink - read a symlink's location (internal version)
 * @dentry: dentry for symlink
1005
 * @buffer: buffer to load symlink location into
1006 1007 1008 1009 1010 1011 1012 1013 1014 1015
 * @buflen: length of buffer
 *
 */

static int v9fs_readlink(struct dentry *dentry, char *buffer, int buflen)
{
	int retval = -EPERM;

	struct v9fs_fcall *fcall = NULL;
	struct v9fs_session_info *v9ses = v9fs_inode2v9ses(dentry->d_inode);
1016
	struct v9fs_fid *fid = v9fs_fid_clone(dentry);
1017

1018 1019
	if(IS_ERR(fid))
		return PTR_ERR(fid);
1020 1021 1022 1023

	if (!v9ses->extended) {
		retval = -EBADF;
		dprintk(DEBUG_ERROR, "not extended\n");
1024
		goto ClunkFid;
1025 1026 1027 1028 1029 1030 1031 1032 1033 1034
	}

	dprintk(DEBUG_VFS, " %s\n", dentry->d_name.name);
	retval = v9fs_t_stat(v9ses, fid->fid, &fcall);

	if (retval < 0) {
		dprintk(DEBUG_ERROR, "stat error\n");
		goto FreeFcall;
	}

1035 1036 1037 1038
	if (!fcall) {
		retval = -EIO;
		goto ClunkFid;
	}
1039

1040
	if (!(fcall->params.rstat.stat.mode & V9FS_DMSYMLINK)) {
1041 1042 1043 1044 1045
		retval = -EINVAL;
		goto FreeFcall;
	}

	/* copy extension buffer into buffer */
1046
	if (fcall->params.rstat.stat.extension.len < buflen)
1047
		buflen = fcall->params.rstat.stat.extension.len + 1;
1048

1049
	memmove(buffer, fcall->params.rstat.stat.extension.str, buflen - 1);
1050
	buffer[buflen-1] = 0;
1051

1052 1053
	dprintk(DEBUG_ERROR, "%s -> %.*s (%s)\n", dentry->d_name.name, fcall->params.rstat.stat.extension.len,
		fcall->params.rstat.stat.extension.str, buffer);
1054 1055
	retval = buflen;

1056
FreeFcall:
1057 1058
	kfree(fcall);

1059 1060 1061
ClunkFid:
	v9fs_fid_clunk(v9ses, fid);

1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079
	return retval;
}

/**
 * v9fs_vfs_readlink - read a symlink's location
 * @dentry: dentry for symlink
 * @buf: buffer to load symlink location into
 * @buflen: length of buffer
 *
 */

static int v9fs_vfs_readlink(struct dentry *dentry, char __user * buffer,
			     int buflen)
{
	int retval;
	int ret;
	char *link = __getname();

1080 1081 1082
	if (unlikely(!link))
		return -ENOMEM;

1083 1084
	if (buflen > PATH_MAX)
		buflen = PATH_MAX;
1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097

	dprintk(DEBUG_VFS, " dentry: %s (%p)\n", dentry->d_iname, dentry);

	retval = v9fs_readlink(dentry, link, buflen);

	if (retval > 0) {
		if ((ret = copy_to_user(buffer, link, retval)) != 0) {
			dprintk(DEBUG_ERROR, "problem copying to user: %d\n",
				ret);
			retval = ret;
		}
	}

1098
	__putname(link);
1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118
	return retval;
}

/**
 * v9fs_vfs_follow_link - follow a symlink path
 * @dentry: dentry for symlink
 * @nd: nameidata
 *
 */

static void *v9fs_vfs_follow_link(struct dentry *dentry, struct nameidata *nd)
{
	int len = 0;
	char *link = __getname();

	dprintk(DEBUG_VFS, "%s n", dentry->d_name.name);

	if (!link)
		link = ERR_PTR(-ENOMEM);
	else {
1119
		len = v9fs_readlink(dentry, link, PATH_MAX);
1120 1121

		if (len < 0) {
1122
			__putname(link);
1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144
			link = ERR_PTR(len);
		} else
			link[len] = 0;
	}
	nd_set_link(nd, link);

	return NULL;
}

/**
 * v9fs_vfs_put_link - release a symlink path
 * @dentry: dentry for symlink
 * @nd: nameidata
 *
 */

static void v9fs_vfs_put_link(struct dentry *dentry, struct nameidata *nd, void *p)
{
	char *s = nd_get_link(nd);

	dprintk(DEBUG_VFS, " %s %s\n", dentry->d_name.name, s);
	if (!IS_ERR(s))
1145
		__putname(s);
1146 1147
}

1148 1149
static int v9fs_vfs_mkspecial(struct inode *dir, struct dentry *dentry,
	int mode, const char *extension)
1150
{
1151 1152
	int err;
	u32 fid, perm;
1153
	struct v9fs_session_info *v9ses;
1154 1155
	struct v9fs_fid *dfid, *vfid = NULL;
	struct inode *inode = NULL;
1156

1157
	v9ses = v9fs_inode2v9ses(dir);
1158 1159
	if (!v9ses->extended) {
		dprintk(DEBUG_ERROR, "not extended\n");
1160
		return -EPERM;
1161 1162
	}

1163 1164 1165 1166 1167 1168 1169 1170
	dfid = v9fs_fid_clone(dentry->d_parent);
	if(IS_ERR(dfid)) {
		err = PTR_ERR(dfid);
		goto error;
	}

	perm = unixmode2p9mode(v9ses, mode);

1171
	err = v9fs_create(v9ses, dfid->fid, (char *) dentry->d_name.name,
1172
		perm, V9FS_OREAD, (char *) extension, &fid, NULL, NULL);
1173

1174
	if (err)
1175
		goto clunk_dfid;
1176 1177 1178

	err = v9fs_t_clunk(v9ses, fid);
	if (err)
1179
		goto clunk_dfid;
1180 1181 1182 1183 1184

	vfid = v9fs_clone_walk(v9ses, dfid->fid, dentry);
	if (IS_ERR(vfid)) {
		err = PTR_ERR(vfid);
		vfid = NULL;
1185
		goto clunk_dfid;
1186 1187 1188 1189 1190 1191
	}

	inode = v9fs_inode_from_fid(v9ses, vfid->fid, dir->i_sb);
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
		inode = NULL;
1192
		goto free_vfid;
1193 1194
	}

1195 1196 1197 1198
	if(v9ses->cache)
		dentry->d_op = &v9fs_cached_dentry_operations;
	else
		dentry->d_op = &v9fs_dentry_operations;
1199 1200
	d_instantiate(dentry, inode);
	return 0;
1201

1202 1203 1204 1205 1206
free_vfid:
	v9fs_fid_destroy(vfid);

clunk_dfid:
	v9fs_fid_clunk(v9ses, dfid);
1207

1208
error:
1209 1210
	return err;

1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248
}

/**
 * v9fs_vfs_symlink - helper function to create symlinks
 * @dir: directory inode containing symlink
 * @dentry: dentry for symlink
 * @symname: symlink data
 *
 * See 9P2000.u RFC for more information
 *
 */

static int
v9fs_vfs_symlink(struct inode *dir, struct dentry *dentry, const char *symname)
{
	dprintk(DEBUG_VFS, " %lu,%s,%s\n", dir->i_ino, dentry->d_name.name,
		symname);

	return v9fs_vfs_mkspecial(dir, dentry, S_IFLNK, symname);
}

/**
 * v9fs_vfs_link - create a hardlink
 * @old_dentry: dentry for file to link to
 * @dir: inode destination for new link
 * @dentry: dentry for link
 *
 */

/* XXX - lots of code dup'd from symlink and creates,
 * figure out a better reuse strategy
 */

static int
v9fs_vfs_link(struct dentry *old_dentry, struct inode *dir,
	      struct dentry *dentry)
{
	int retval;
1249
	struct v9fs_session_info *v9ses = v9fs_inode2v9ses(dir);
1250 1251 1252 1253 1254 1255
	struct v9fs_fid *oldfid;
	char *name;

	dprintk(DEBUG_VFS, " %lu,%s,%s\n", dir->i_ino, dentry->d_name.name,
		old_dentry->d_name.name);

1256 1257 1258
	oldfid = v9fs_fid_clone(old_dentry);
	if(IS_ERR(oldfid))
		return PTR_ERR(oldfid);
1259 1260

	name = __getname();
1261 1262 1263 1264
	if (unlikely(!name)) {
		retval = -ENOMEM;
		goto clunk_fid;
	}
1265

1266
	sprintf(name, "%d\n", oldfid->fid);
1267 1268
	retval = v9fs_vfs_mkspecial(dir, dentry, V9FS_DMLINK, name);
	__putname(name);
1269

1270 1271
clunk_fid:
	v9fs_fid_clunk(v9ses, oldfid);
1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286
	return retval;
}

/**
 * v9fs_vfs_mknod - create a special file
 * @dir: inode destination for new link
 * @dentry: dentry for file
 * @mode: mode for creation
 * @dev_t: device associated with special file
 *
 */

static int
v9fs_vfs_mknod(struct inode *dir, struct dentry *dentry, int mode, dev_t rdev)
{
1287 1288
	int retval;
	char *name;
1289 1290 1291 1292

	dprintk(DEBUG_VFS, " %lu,%s mode: %x MAJOR: %u MINOR: %u\n", dir->i_ino,
		dentry->d_name.name, mode, MAJOR(rdev), MINOR(rdev));

1293 1294
	if (!new_valid_dev(rdev))
		return -EINVAL;
1295

1296
	name = __getname();
1297 1298
	if (!name)
		return -ENOMEM;
1299 1300
	/* build extension */
	if (S_ISBLK(mode))
1301
		sprintf(name, "b %u %u", MAJOR(rdev), MINOR(rdev));
1302
	else if (S_ISCHR(mode))
1303
		sprintf(name, "c %u %u", MAJOR(rdev), MINOR(rdev));
1304
	else if (S_ISFIFO(mode))
1305
		*name = 0;
1306
	else {
1307 1308
		__putname(name);
		return -EINVAL;
1309 1310
	}

1311 1312
	retval = v9fs_vfs_mkspecial(dir, dentry, mode, name);
	__putname(name);
1313 1314 1315 1316

	return retval;
}

1317
static const struct inode_operations v9fs_dir_inode_operations_ext = {
1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331
	.create = v9fs_vfs_create,
	.lookup = v9fs_vfs_lookup,
	.symlink = v9fs_vfs_symlink,
	.link = v9fs_vfs_link,
	.unlink = v9fs_vfs_unlink,
	.mkdir = v9fs_vfs_mkdir,
	.rmdir = v9fs_vfs_rmdir,
	.mknod = v9fs_vfs_mknod,
	.rename = v9fs_vfs_rename,
	.readlink = v9fs_vfs_readlink,
	.getattr = v9fs_vfs_getattr,
	.setattr = v9fs_vfs_setattr,
};

1332
static const struct inode_operations v9fs_dir_inode_operations = {
1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343
	.create = v9fs_vfs_create,
	.lookup = v9fs_vfs_lookup,
	.unlink = v9fs_vfs_unlink,
	.mkdir = v9fs_vfs_mkdir,
	.rmdir = v9fs_vfs_rmdir,
	.mknod = v9fs_vfs_mknod,
	.rename = v9fs_vfs_rename,
	.getattr = v9fs_vfs_getattr,
	.setattr = v9fs_vfs_setattr,
};

1344
static const struct inode_operations v9fs_file_inode_operations = {
1345 1346 1347 1348
	.getattr = v9fs_vfs_getattr,
	.setattr = v9fs_vfs_setattr,
};

1349
static const struct inode_operations v9fs_symlink_inode_operations = {
1350 1351 1352 1353 1354 1355
	.readlink = v9fs_vfs_readlink,
	.follow_link = v9fs_vfs_follow_link,
	.put_link = v9fs_vfs_put_link,
	.getattr = v9fs_vfs_getattr,
	.setattr = v9fs_vfs_setattr,
};