Home | History | Annotate | Line # | Download | only in nilfs
nilfs_vnops.c revision 1.26
      1 /* $NetBSD: nilfs_vnops.c,v 1.26 2014/01/23 10:13:56 hannken Exp $ */
      2 
      3 /*
      4  * Copyright (c) 2008, 2009 Reinoud Zandijk
      5  * All rights reserved.
      6  *
      7  * Redistribution and use in source and binary forms, with or without
      8  * modification, are permitted provided that the following conditions
      9  * are met:
     10  * 1. Redistributions of source code must retain the above copyright
     11  *    notice, this list of conditions and the following disclaimer.
     12  * 2. Redistributions in binary form must reproduce the above copyright
     13  *    notice, this list of conditions and the following disclaimer in the
     14  *    documentation and/or other materials provided with the distribution.
     15  *
     16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     17  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     18  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     19  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     20  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     21  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     22  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     23  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     24  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     25  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     26  *
     27  */
     28 
     29 #include <sys/cdefs.h>
     30 #ifndef lint
     31 __KERNEL_RCSID(0, "$NetBSD: nilfs_vnops.c,v 1.26 2014/01/23 10:13:56 hannken Exp $");
     32 #endif /* not lint */
     33 
     34 
     35 #include <sys/param.h>
     36 #include <sys/systm.h>
     37 #include <sys/namei.h>
     38 #include <sys/resourcevar.h>	/* defines plimit structure in proc struct */
     39 #include <sys/kernel.h>
     40 #include <sys/file.h>		/* define FWRITE ... */
     41 #include <sys/stat.h>
     42 #include <sys/buf.h>
     43 #include <sys/proc.h>
     44 #include <sys/mount.h>
     45 #include <sys/vnode.h>
     46 #include <sys/signalvar.h>
     47 #include <sys/malloc.h>
     48 #include <sys/dirent.h>
     49 #include <sys/lockf.h>
     50 #include <sys/kauth.h>
     51 
     52 #include <miscfs/genfs/genfs.h>
     53 #include <uvm/uvm_extern.h>
     54 
     55 #include <fs/nilfs/nilfs_mount.h>
     56 #include "nilfs.h"
     57 #include "nilfs_subr.h"
     58 #include "nilfs_bswap.h"
     59 
     60 
     61 #define VTOI(vnode) ((struct nilfs_node *) (vnode)->v_data)
     62 
     63 
     64 /* externs */
     65 extern int prtactive;
     66 
     67 /* implementations of vnode functions; table follows at end */
     68 /* --------------------------------------------------------------------- */
     69 
     70 int
     71 nilfs_inactive(void *v)
     72 {
     73 	struct vop_inactive_args /* {
     74 		struct vnode *a_vp;
     75 		bool         *a_recycle;
     76 	} */ *ap = v;
     77 	struct vnode *vp = ap->a_vp;
     78 	struct nilfs_node *nilfs_node = VTOI(vp);
     79 
     80 	DPRINTF(NODE, ("nilfs_inactive called for nilfs_node %p\n", VTOI(vp)));
     81 
     82 	if (nilfs_node == NULL) {
     83 		DPRINTF(NODE, ("nilfs_inactive: inactive NULL NILFS node\n"));
     84 		VOP_UNLOCK(vp);
     85 		return 0;
     86 	}
     87 
     88 	/*
     89 	 * Optionally flush metadata to disc. If the file has not been
     90 	 * referenced anymore in a directory we ought to free up the resources
     91 	 * on disc if applicable.
     92 	 */
     93 	VOP_UNLOCK(vp);
     94 
     95 	return 0;
     96 }
     97 
     98 /* --------------------------------------------------------------------- */
     99 
    100 int
    101 nilfs_reclaim(void *v)
    102 {
    103 	struct vop_reclaim_args /* {
    104 		struct vnode *a_vp;
    105 	} */ *ap = v;
    106 	struct vnode *vp = ap->a_vp;
    107 	struct nilfs_node *nilfs_node = VTOI(vp);
    108 
    109 	DPRINTF(NODE, ("nilfs_reclaim called for node %p\n", nilfs_node));
    110 	if (prtactive && vp->v_usecount > 1)
    111 		vprint("nilfs_reclaim(): pushing active", vp);
    112 
    113 	if (nilfs_node == NULL) {
    114 		DPRINTF(NODE, ("nilfs_reclaim(): null nilfsnode\n"));
    115 		return 0;
    116 	}
    117 
    118 	/* update note for closure */
    119 	nilfs_update(vp, NULL, NULL, NULL, UPDATE_CLOSE);
    120 
    121 	/* dispose all node knowledge */
    122 	nilfs_dispose_node(&nilfs_node);
    123 
    124 	return 0;
    125 }
    126 
    127 /* --------------------------------------------------------------------- */
    128 
    129 int
    130 nilfs_read(void *v)
    131 {
    132 	struct vop_read_args /* {
    133 		struct vnode *a_vp;
    134 		struct uio *a_uio;
    135 		int a_ioflag;
    136 		kauth_cred_t a_cred;
    137 	} */ *ap = v;
    138 	struct vnode *vp     = ap->a_vp;
    139 	struct uio   *uio    = ap->a_uio;
    140 	int           ioflag = ap->a_ioflag;
    141 	int           advice = IO_ADV_DECODE(ap->a_ioflag);
    142 	struct uvm_object    *uobj;
    143 	struct nilfs_node      *nilfs_node = VTOI(vp);
    144 	uint64_t file_size;
    145 	vsize_t len;
    146 	int error;
    147 
    148 	DPRINTF(READ, ("nilfs_read called\n"));
    149 
    150 	/* can this happen? some filingsystems have this check */
    151 	if (uio->uio_offset < 0)
    152 		return EINVAL;
    153 	if (uio->uio_resid == 0)
    154 		return 0;
    155 
    156 	/* protect against rogue programs reading raw directories and links */
    157 	if ((ioflag & IO_ALTSEMANTICS) == 0) {
    158 		if (vp->v_type == VDIR)
    159 			return EISDIR;
    160 		/* all but regular files just give EINVAL */
    161 		if (vp->v_type != VREG)
    162 			return EINVAL;
    163 	}
    164 
    165 	assert(nilfs_node);
    166 	file_size = nilfs_rw64(nilfs_node->inode.i_size);
    167 
    168 	/* read contents using buffercache */
    169 	uobj = &vp->v_uobj;
    170 	error = 0;
    171 	while (uio->uio_resid > 0) {
    172 		/* reached end? */
    173 		if (file_size <= uio->uio_offset)
    174 			break;
    175 
    176 		/* maximise length to file extremity */
    177 		len = MIN(file_size - uio->uio_offset, uio->uio_resid);
    178 		if (len == 0)
    179 			break;
    180 
    181 		/* ubc, here we come, prepare to trap */
    182 		error = ubc_uiomove(uobj, uio, len, advice,
    183 		    UBC_READ | UBC_PARTIALOK | UBC_UNMAP_FLAG(vp));
    184 		if (error)
    185 			break;
    186 	}
    187 
    188 	/* note access time unless not requested */
    189 	if (!(vp->v_mount->mnt_flag & MNT_NOATIME)) {
    190 		nilfs_node->i_flags |= IN_ACCESS;
    191 		if ((ioflag & IO_SYNC) == IO_SYNC)
    192 			error = nilfs_update(vp, NULL, NULL, NULL, UPDATE_WAIT);
    193 	}
    194 
    195 	return error;
    196 }
    197 
    198 /* --------------------------------------------------------------------- */
    199 
    200 int
    201 nilfs_write(void *v)
    202 {
    203 	struct vop_write_args /* {
    204 		struct vnode *a_vp;
    205 		struct uio *a_uio;
    206 		int a_ioflag;
    207 		kauth_cred_t a_cred;
    208 	} */ *ap = v;
    209 	struct vnode *vp     = ap->a_vp;
    210 	struct uio   *uio    = ap->a_uio;
    211 	int           ioflag = ap->a_ioflag;
    212 	int           advice = IO_ADV_DECODE(ap->a_ioflag);
    213 	struct uvm_object    *uobj;
    214 	struct nilfs_node      *nilfs_node = VTOI(vp);
    215 	uint64_t file_size;
    216 	vsize_t len;
    217 	int error, resid, extended;
    218 
    219 	DPRINTF(WRITE, ("nilfs_write called\n"));
    220 
    221 	/* can this happen? some filingsystems have this check */
    222 	if (uio->uio_offset < 0)
    223 		return EINVAL;
    224 	if (uio->uio_resid == 0)
    225 		return 0;
    226 
    227 	/* protect against rogue programs writing raw directories or links */
    228 	if ((ioflag & IO_ALTSEMANTICS) == 0) {
    229 		if (vp->v_type == VDIR)
    230 			return EISDIR;
    231 		/* all but regular files just give EINVAL for now */
    232 		if (vp->v_type != VREG)
    233 			return EINVAL;
    234 	}
    235 
    236 	assert(nilfs_node);
    237 	panic("nilfs_write() called\n");
    238 
    239 	/* remember old file size */
    240 	assert(nilfs_node);
    241 	file_size = nilfs_rw64(nilfs_node->inode.i_size);
    242 
    243 	/* if explicitly asked to append, uio_offset can be wrong? */
    244 	if (ioflag & IO_APPEND)
    245 		uio->uio_offset = file_size;
    246 
    247 #if 0
    248 	extended = (uio->uio_offset + uio->uio_resid > file_size);
    249 	if (extended) {
    250 		DPRINTF(WRITE, ("extending file from %"PRIu64" to %"PRIu64"\n",
    251 			file_size, uio->uio_offset + uio->uio_resid));
    252 		error = nilfs_grow_node(nilfs_node, uio->uio_offset + uio->uio_resid);
    253 		if (error)
    254 			return error;
    255 		file_size = uio->uio_offset + uio->uio_resid;
    256 	}
    257 #endif
    258 
    259 	/* write contents using buffercache */
    260 	uobj = &vp->v_uobj;
    261 	resid = uio->uio_resid;
    262 	error = 0;
    263 
    264 	uvm_vnp_setwritesize(vp, file_size);
    265 	while (uio->uio_resid > 0) {
    266 		/* maximise length to file extremity */
    267 		len = MIN(file_size - uio->uio_offset, uio->uio_resid);
    268 		if (len == 0)
    269 			break;
    270 
    271 		/* ubc, here we come, prepare to trap */
    272 		error = ubc_uiomove(uobj, uio, len, advice,
    273 		    UBC_WRITE | UBC_UNMAP_FLAG(vp));
    274 		if (error)
    275 			break;
    276 	}
    277 	uvm_vnp_setsize(vp, file_size);
    278 
    279 	/* mark node changed and request update */
    280 	nilfs_node->i_flags |= IN_CHANGE | IN_UPDATE;
    281 	if (vp->v_mount->mnt_flag & MNT_RELATIME)
    282 		nilfs_node->i_flags |= IN_ACCESS;
    283 
    284 	/*
    285 	 * XXX TODO FFS has code here to reset setuid & setgid when we're not
    286 	 * the superuser as a precaution against tampering.
    287 	 */
    288 
    289 	/* if we wrote a thing, note write action on vnode */
    290 	if (resid > uio->uio_resid)
    291 		VN_KNOTE(vp, NOTE_WRITE | (extended ? NOTE_EXTEND : 0));
    292 
    293 	if (error) {
    294 		/* bring back file size to its former size */
    295 		/* take notice of its errors? */
    296 //		(void) nilfs_chsize(vp, (u_quad_t) old_size, NOCRED);
    297 
    298 		/* roll back uio */
    299 		uio->uio_offset -= resid - uio->uio_resid;
    300 		uio->uio_resid = resid;
    301 	} else {
    302 		/* if we write and we're synchronous, update node */
    303 		if ((resid > uio->uio_resid) && ((ioflag & IO_SYNC) == IO_SYNC))
    304 			error = nilfs_update(vp, NULL, NULL, NULL, UPDATE_WAIT);
    305 	}
    306 
    307 	return error;
    308 }
    309 
    310 
    311 /* --------------------------------------------------------------------- */
    312 
    313 /*
    314  * bmap functionality that translates logical block numbers to the virtual
    315  * block numbers to be stored on the vnode itself.
    316  *
    317  * Important alert!
    318  *
    319  * If runp is not NULL, the number of contiguous blocks __starting from the
    320  * next block after the queried block__ will be returned in runp.
    321  */
    322 
    323 int
    324 nilfs_trivial_bmap(void *v)
    325 {
    326 	struct vop_bmap_args /* {
    327 		struct vnode *a_vp;
    328 		daddr_t a_bn;
    329 		struct vnode **a_vpp;
    330 		daddr_t *a_bnp;
    331 		int *a_runp;
    332 	} */ *ap = v;
    333 	struct vnode  *vp  = ap->a_vp;	/* our node	*/
    334 	struct vnode **vpp = ap->a_vpp;	/* return node	*/
    335 	daddr_t *bnp  = ap->a_bnp;	/* translated	*/
    336 	daddr_t  bn   = ap->a_bn;	/* origional	*/
    337 	int     *runp = ap->a_runp;
    338 	struct nilfs_node *node = VTOI(vp);
    339 	uint64_t *l2vmap;
    340 	uint32_t blocksize;
    341 	int blks, run, error;
    342 
    343 	DPRINTF(TRANSLATE, ("nilfs_bmap() called\n"));
    344 	/* XXX could return `-1' to indicate holes/zero's */
    345 
    346 	blocksize = node->nilfsdev->blocksize;
    347 	blks = MAXPHYS / blocksize;
    348 
    349 	/* get mapping memory */
    350 	l2vmap = malloc(sizeof(uint64_t) * blks, M_TEMP, M_WAITOK);
    351 
    352 	/* get virtual block numbers for the vnode's buffer span */
    353 	error = nilfs_btree_nlookup(node, bn, blks, l2vmap);
    354 	if (error) {
    355 		free(l2vmap, M_TEMP);
    356 		return error;
    357 	}
    358 
    359 	/* store virtual blocks on our own vp */
    360 	if (vpp)
    361 		*vpp = vp;
    362 
    363 	/* start at virt[0] */
    364 	*bnp = l2vmap[0];
    365 
    366 	/* get runlength */
    367 	run = 1;
    368 	while ((run < blks) && (l2vmap[run] == *bnp + run))
    369 		run++;
    370 	run--;	/* see comment at start of function */
    371 
    372 	/* set runlength */
    373 	if (runp)
    374 		*runp = run;
    375 
    376 	DPRINTF(TRANSLATE, ("\tstart %"PRIu64" -> %"PRIu64" run %d\n",
    377 		bn, *bnp, run));
    378 
    379 	/* mark not translated on virtual block number 0 */
    380 	if (*bnp == 0)
    381 		*bnp = -1;
    382 
    383 	/* return success */
    384 	free(l2vmap, M_TEMP);
    385 	return 0;
    386 }
    387 
    388 /* --------------------------------------------------------------------- */
    389 
    390 static void
    391 nilfs_read_filebuf(struct nilfs_node *node, struct buf *bp)
    392 {
    393 	struct nilfs_device *nilfsdev = node->nilfsdev;
    394 	struct buf *nbp;
    395 	uint64_t *l2vmap, *v2pmap;
    396 	uint64_t from, blks;
    397 	uint32_t blocksize, buf_offset;
    398 	uint8_t  *buf_pos;
    399 	int blk2dev = nilfsdev->blocksize / DEV_BSIZE;
    400 	int i, error;
    401 
    402 	/*
    403 	 * Translate all the block sectors into a series of buffers to read
    404 	 * asynchronously from the nilfs device. Note that this lookup may
    405 	 * induce readin's too.
    406 	 */
    407 
    408 	blocksize = nilfsdev->blocksize;
    409 
    410 	from = bp->b_blkno;
    411 	blks = bp->b_bcount / blocksize;
    412 
    413 	DPRINTF(READ, ("\tread in from inode %"PRIu64" blkno %"PRIu64" "
    414 			"+ %"PRIu64" blocks\n", node->ino, from, blks));
    415 
    416 	DPRINTF(READ, ("\t\tblkno %"PRIu64" "
    417 			"+ %d bytes\n", bp->b_blkno, bp->b_bcount));
    418 
    419 	/* get mapping memory */
    420 	l2vmap = malloc(sizeof(uint64_t) * blks, M_TEMP, M_WAITOK);
    421 	v2pmap = malloc(sizeof(uint64_t) * blks, M_TEMP, M_WAITOK);
    422 
    423 	/* get virtual block numbers for the vnode's buffer span */
    424 	for (i = 0; i < blks; i++)
    425 		l2vmap[i] = from + i;
    426 
    427 	/* translate virtual block numbers to physical block numbers */
    428 	error = nilfs_nvtop(node, blks, l2vmap, v2pmap);
    429 	if (error)
    430 		goto out;
    431 
    432 	/* issue translated blocks */
    433 	bp->b_resid = bp->b_bcount;
    434 	for (i = 0; i < blks; i++) {
    435 		DPRINTF(READ, ("read_filebuf : ino %"PRIu64" blk %d -> "
    436 			"%"PRIu64" -> %"PRIu64"\n",
    437 			node->ino, i, l2vmap[i], v2pmap[i]));
    438 
    439 		buf_offset = i * blocksize;
    440 		buf_pos    = (uint8_t *) bp->b_data + buf_offset;
    441 
    442 		/* note virtual block 0 marks not mapped */
    443 		if (l2vmap[i] == 0) {
    444 			memset(buf_pos, 0, blocksize);
    445 			nestiobuf_done(bp, blocksize, 0);
    446 			continue;
    447 		}
    448 
    449 		/* nest iobuf */
    450 		nbp = getiobuf(NULL, true);
    451 		nestiobuf_setup(bp, nbp, buf_offset, blocksize);
    452 		KASSERT(nbp->b_vp == node->vnode);
    453 		/* nbp is B_ASYNC */
    454 
    455 		nbp->b_lblkno   = i;
    456 		nbp->b_blkno    = v2pmap[i] * blk2dev;	/* in DEV_BSIZE */
    457 		nbp->b_rawblkno = nbp->b_blkno;
    458 
    459 		VOP_STRATEGY(nilfsdev->devvp, nbp);
    460 	}
    461 
    462 	if ((bp->b_flags & B_ASYNC) == 0)
    463 		biowait(bp);
    464 
    465 out:
    466 	free(l2vmap, M_TEMP);
    467 	free(v2pmap, M_TEMP);
    468 	if (error) {
    469 		bp->b_error = EIO;
    470 		biodone(bp);
    471 	}
    472 }
    473 
    474 
    475 static void
    476 nilfs_write_filebuf(struct nilfs_node *node, struct buf *bp)
    477 {
    478 	/* TODO pass on to segment collector */
    479 	panic("nilfs_strategy writing called\n");
    480 }
    481 
    482 
    483 int
    484 nilfs_vfsstrategy(void *v)
    485 {
    486 	struct vop_strategy_args /* {
    487 		struct vnode *a_vp;
    488 		struct buf *a_bp;
    489 	} */ *ap = v;
    490 	struct vnode *vp = ap->a_vp;
    491 	struct buf   *bp = ap->a_bp;
    492 	struct nilfs_node *node = VTOI(vp);
    493 
    494 	DPRINTF(STRATEGY, ("nilfs_strategy called\n"));
    495 
    496 	/* check if we ought to be here */
    497 	if (vp->v_type == VBLK || vp->v_type == VCHR)
    498 		panic("nilfs_strategy: spec");
    499 
    500 	/* translate if needed and pass on */
    501 	if (bp->b_flags & B_READ) {
    502 		nilfs_read_filebuf(node, bp);
    503 		return bp->b_error;
    504 	}
    505 
    506 	/* send to segment collector */
    507 	nilfs_write_filebuf(node, bp);
    508 	return bp->b_error;
    509 }
    510 
    511 /* --------------------------------------------------------------------- */
    512 
    513 int
    514 nilfs_readdir(void *v)
    515 {
    516 	struct vop_readdir_args /* {
    517 		struct vnode *a_vp;
    518 		struct uio *a_uio;
    519 		kauth_cred_t a_cred;
    520 		int *a_eofflag;
    521 		off_t **a_cookies;
    522 		int *a_ncookies;
    523 	} */ *ap = v;
    524 	struct uio *uio = ap->a_uio;
    525 	struct vnode *vp = ap->a_vp;
    526 	struct nilfs_node *node = VTOI(vp);
    527 	struct nilfs_dir_entry *ndirent;
    528 	struct dirent dirent;
    529 	struct buf *bp;
    530 	uint64_t file_size, diroffset, transoffset, blkoff;
    531 	uint64_t blocknr;
    532 	uint32_t blocksize = node->nilfsdev->blocksize;
    533 	uint8_t *pos, name_len;
    534 	int error;
    535 
    536 	DPRINTF(READDIR, ("nilfs_readdir called\n"));
    537 
    538 	if (vp->v_type != VDIR)
    539 		return ENOTDIR;
    540 
    541 	file_size = nilfs_rw64(node->inode.i_size);
    542 
    543 	/* we are called just as long as we keep on pushing data in */
    544 	error = 0;
    545 	if ((uio->uio_offset < file_size) &&
    546 	    (uio->uio_resid >= sizeof(struct dirent))) {
    547 		diroffset   = uio->uio_offset;
    548 		transoffset = diroffset;
    549 
    550 		blocknr = diroffset / blocksize;
    551 		blkoff  = diroffset % blocksize;
    552 		error = nilfs_bread(node, blocknr, NOCRED, 0, &bp);
    553 		if (error)
    554 			return EIO;
    555 		while (diroffset < file_size) {
    556 			DPRINTF(READDIR, ("readdir : offset = %"PRIu64"\n",
    557 				diroffset));
    558 			if (blkoff >= blocksize) {
    559 				blkoff = 0; blocknr++;
    560 				brelse(bp, BC_AGE);
    561 				error = nilfs_bread(node, blocknr, NOCRED, 0,
    562 						&bp);
    563 				if (error)
    564 					return EIO;
    565 			}
    566 
    567 			/* read in one dirent */
    568 			pos = (uint8_t *) bp->b_data + blkoff;
    569 			ndirent = (struct nilfs_dir_entry *) pos;
    570 
    571 			name_len = ndirent->name_len;
    572 			memset(&dirent, 0, sizeof(struct dirent));
    573 			dirent.d_fileno = nilfs_rw64(ndirent->inode);
    574 			dirent.d_type   = ndirent->file_type;	/* 1:1 ? */
    575 			dirent.d_namlen = name_len;
    576 			strncpy(dirent.d_name, ndirent->name, name_len);
    577 			dirent.d_reclen = _DIRENT_SIZE(&dirent);
    578 			DPRINTF(READDIR, ("copying `%*.*s`\n", name_len,
    579 				name_len, dirent.d_name));
    580 
    581 			/*
    582 			 * If there isn't enough space in the uio to return a
    583 			 * whole dirent, break off read
    584 			 */
    585 			if (uio->uio_resid < _DIRENT_SIZE(&dirent))
    586 				break;
    587 
    588 			/* transfer */
    589 			if (name_len)
    590 				uiomove(&dirent, _DIRENT_SIZE(&dirent), uio);
    591 
    592 			/* advance */
    593 			diroffset += nilfs_rw16(ndirent->rec_len);
    594 			blkoff    += nilfs_rw16(ndirent->rec_len);
    595 
    596 			/* remember the last entry we transfered */
    597 			transoffset = diroffset;
    598 		}
    599 		brelse(bp, BC_AGE);
    600 
    601 		/* pass on last transfered offset */
    602 		uio->uio_offset = transoffset;
    603 	}
    604 
    605 	if (ap->a_eofflag)
    606 		*ap->a_eofflag = (uio->uio_offset >= file_size);
    607 
    608 	return error;
    609 }
    610 
    611 /* --------------------------------------------------------------------- */
    612 
    613 int
    614 nilfs_lookup(void *v)
    615 {
    616 	struct vop_lookup_args /* {
    617 		struct vnode *a_dvp;
    618 		struct vnode **a_vpp;
    619 		struct componentname *a_cnp;
    620 	} */ *ap = v;
    621 	struct vnode *dvp = ap->a_dvp;
    622 	struct vnode **vpp = ap->a_vpp;
    623 	struct componentname *cnp = ap->a_cnp;
    624 	struct nilfs_node  *dir_node, *res_node;
    625 	struct nilfs_mount *ump;
    626 	uint64_t ino;
    627 	const char *name;
    628 	int namelen, nameiop, islastcn, mounted_ro;
    629 	int vnodetp;
    630 	int error, found;
    631 
    632 	dir_node = VTOI(dvp);
    633 	ump = dir_node->ump;
    634 	*vpp = NULL;
    635 
    636 	DPRINTF(LOOKUP, ("nilfs_lookup called\n"));
    637 
    638 	/* simplify/clarification flags */
    639 	nameiop     = cnp->cn_nameiop;
    640 	islastcn    = cnp->cn_flags & ISLASTCN;
    641 	mounted_ro  = dvp->v_mount->mnt_flag & MNT_RDONLY;
    642 
    643 	/* check exec/dirread permissions first */
    644 	error = VOP_ACCESS(dvp, VEXEC, cnp->cn_cred);
    645 	if (error)
    646 		return error;
    647 
    648 	DPRINTF(LOOKUP, ("\taccess ok\n"));
    649 
    650 	/*
    651 	 * If requesting a modify on the last path element on a read-only
    652 	 * filingsystem, reject lookup; XXX why is this repeated in every FS ?
    653 	 */
    654 	if (islastcn && mounted_ro && (nameiop == DELETE || nameiop == RENAME))
    655 		return EROFS;
    656 
    657 	DPRINTF(LOOKUP, ("\tlooking up cnp->cn_nameptr '%s'\n",
    658 	    cnp->cn_nameptr));
    659 	/* look in the namecache */
    660 	if (cache_lookup(dvp, cnp->cn_nameptr, cnp->cn_namelen,
    661 			 cnp->cn_nameiop, cnp->cn_flags, NULL, vpp)) {
    662 		return *vpp == NULLVP ? ENOENT : 0;
    663 	}
    664 
    665 	DPRINTF(LOOKUP, ("\tNOT found in cache\n"));
    666 
    667 	/*
    668 	 * Obviously, the file is not (anymore) in the namecache, we have to
    669 	 * search for it. There are three basic cases: '.', '..' and others.
    670 	 *
    671 	 * Following the guidelines of VOP_LOOKUP manpage and tmpfs.
    672 	 */
    673 	error = 0;
    674 	if ((cnp->cn_namelen == 1) && (cnp->cn_nameptr[0] == '.')) {
    675 		DPRINTF(LOOKUP, ("\tlookup '.'\n"));
    676 		/* special case 1 '.' */
    677 		vref(dvp);
    678 		*vpp = dvp;
    679 		/* done */
    680 	} else if (cnp->cn_flags & ISDOTDOT) {
    681 		/* special case 2 '..' */
    682 		DPRINTF(LOOKUP, ("\tlookup '..'\n"));
    683 
    684 		/* get our node */
    685 		name    = "..";
    686 		namelen = 2;
    687 		error = nilfs_lookup_name_in_dir(dvp, name, namelen,
    688 				&ino, &found);
    689 		if (error)
    690 			goto out;
    691 		if (!found)
    692 			error = ENOENT;
    693 
    694 		/* first unlock parent */
    695 		VOP_UNLOCK(dvp);
    696 
    697 		if (error == 0) {
    698 			DPRINTF(LOOKUP, ("\tfound '..'\n"));
    699 			/* try to create/reuse the node */
    700 			error = nilfs_get_node(ump, ino, &res_node);
    701 
    702 			if (!error) {
    703 				DPRINTF(LOOKUP,
    704 					("\tnode retrieved/created OK\n"));
    705 				*vpp = res_node->vnode;
    706 			}
    707 		}
    708 
    709 		/* try to relock parent */
    710 		vn_lock(dvp, LK_EXCLUSIVE | LK_RETRY);
    711 	} else {
    712 		DPRINTF(LOOKUP, ("\tlookup file\n"));
    713 		/* all other files */
    714 		/* lookup filename in the directory returning its inode */
    715 		name    = cnp->cn_nameptr;
    716 		namelen = cnp->cn_namelen;
    717 		error = nilfs_lookup_name_in_dir(dvp, name, namelen,
    718 				&ino, &found);
    719 		if (error)
    720 			goto out;
    721 		if (!found) {
    722 			DPRINTF(LOOKUP, ("\tNOT found\n"));
    723 			/*
    724 			 * UGH, didn't find name. If we're creating or
    725 			 * renaming on the last name this is OK and we ought
    726 			 * to return EJUSTRETURN if its allowed to be created.
    727 			 */
    728 			error = ENOENT;
    729 			if (islastcn &&
    730 				(nameiop == CREATE || nameiop == RENAME))
    731 					error = 0;
    732 			if (!error) {
    733 				error = VOP_ACCESS(dvp, VWRITE, cnp->cn_cred);
    734 				if (!error) {
    735 					error = EJUSTRETURN;
    736 				}
    737 			}
    738 			/* done */
    739 		} else {
    740 			/* try to create/reuse the node */
    741 			error = nilfs_get_node(ump, ino, &res_node);
    742 			if (!error) {
    743 				/*
    744 				 * If we are not at the last path component
    745 				 * and found a non-directory or non-link entry
    746 				 * (which may itself be pointing to a
    747 				 * directory), raise an error.
    748 				 */
    749 				vnodetp = res_node->vnode->v_type;
    750 				if ((vnodetp != VDIR) && (vnodetp != VLNK)) {
    751 					if (!islastcn)
    752 						error = ENOTDIR;
    753 				}
    754 
    755 			}
    756 			if (!error) {
    757 				*vpp = res_node->vnode;
    758 			}
    759 		}
    760 	}
    761 
    762 out:
    763 	/*
    764 	 * Store result in the cache if requested. If we are creating a file,
    765 	 * the file might not be found and thus putting it into the namecache
    766 	 * might be seen as negative caching.
    767 	 */
    768 	if (nameiop != CREATE)
    769 		cache_enter(dvp, *vpp, cnp->cn_nameptr, cnp->cn_namelen,
    770 			    cnp->cn_flags);
    771 
    772 	DPRINTFIF(LOOKUP, error, ("nilfs_lookup returing error %d\n", error));
    773 
    774 	return error;
    775 }
    776 
    777 /* --------------------------------------------------------------------- */
    778 
    779 static void
    780 nilfs_ctime_to_timespec(struct timespec *ts, uint64_t ctime)
    781 {
    782 	ts->tv_sec  = ctime;
    783 	ts->tv_nsec = 0;
    784 }
    785 
    786 
    787 int
    788 nilfs_getattr(void *v)
    789 {
    790 	struct vop_getattr_args /* {
    791 		struct vnode *a_vp;
    792 		struct vattr *a_vap;
    793 		kauth_cred_t a_cred;
    794 		struct lwp   *a_l;
    795 	} */ *ap = v;
    796 	struct vnode       *vp  = ap->a_vp;
    797 	struct vattr       *vap = ap->a_vap;
    798 	struct nilfs_node  *node = VTOI(vp);
    799 	struct nilfs_inode *inode = &node->inode;
    800 
    801 	DPRINTF(VFSCALL, ("nilfs_getattr called\n"));
    802 
    803 	/* basic info */
    804 	vattr_null(vap);
    805 	vap->va_type      = vp->v_type;
    806 	vap->va_mode      = nilfs_rw16(inode->i_mode);	/* XXX same? */
    807 	vap->va_nlink     = nilfs_rw16(inode->i_links_count);
    808 	vap->va_uid       = nilfs_rw32(inode->i_uid);
    809 	vap->va_gid       = nilfs_rw32(inode->i_gid);
    810 	vap->va_fsid      = vp->v_mount->mnt_stat.f_fsidx.__fsid_val[0];
    811 	vap->va_fileid    = node->ino;
    812 	vap->va_size      = nilfs_rw64(inode->i_size);
    813 	vap->va_blocksize = node->nilfsdev->blocksize;
    814 
    815 	/* times */
    816 	nilfs_ctime_to_timespec(&vap->va_atime, nilfs_rw64(inode->i_mtime));
    817 	nilfs_ctime_to_timespec(&vap->va_mtime, nilfs_rw64(inode->i_mtime));
    818 	nilfs_ctime_to_timespec(&vap->va_ctime, nilfs_rw64(inode->i_ctime));
    819 	nilfs_ctime_to_timespec(&vap->va_birthtime, nilfs_rw64(inode->i_ctime));
    820 
    821 	vap->va_gen       = nilfs_rw32(inode->i_generation);
    822 	vap->va_flags     = 0;	/* vattr flags */
    823 	vap->va_bytes     = nilfs_rw64(inode->i_blocks) * vap->va_blocksize;
    824 	vap->va_filerev   = vap->va_gen;  /* XXX file revision? same as gen? */
    825 	vap->va_vaflags   = 0;  /* XXX chflags flags */
    826 
    827 	return 0;
    828 }
    829 
    830 /* --------------------------------------------------------------------- */
    831 
    832 #if 0
    833 static int
    834 nilfs_chown(struct vnode *vp, uid_t new_uid, gid_t new_gid,
    835 	  kauth_cred_t cred)
    836 {
    837 	return EINVAL;
    838 }
    839 
    840 
    841 static int
    842 nilfs_chmod(struct vnode *vp, mode_t mode, kauth_cred_t cred)
    843 {
    844 
    845 	return EINVAL;
    846 }
    847 
    848 
    849 /* exported */
    850 int
    851 nilfs_chsize(struct vnode *vp, u_quad_t newsize, kauth_cred_t cred)
    852 {
    853 	return EINVAL;
    854 }
    855 
    856 
    857 static int
    858 nilfs_chflags(struct vnode *vp, mode_t mode, kauth_cred_t cred)
    859 {
    860 	return EINVAL;
    861 }
    862 
    863 
    864 static int
    865 nilfs_chtimes(struct vnode *vp,
    866 	struct timespec *atime, struct timespec *mtime,
    867 	struct timespec *birthtime, int setattrflags,
    868 	kauth_cred_t cred)
    869 {
    870 	return EINVAL;
    871 }
    872 #endif
    873 
    874 
    875 int
    876 nilfs_setattr(void *v)
    877 {
    878 	struct vop_setattr_args /* {
    879 		struct vnode *a_vp;
    880 		struct vattr *a_vap;
    881 		kauth_cred_t a_cred;
    882 		struct lwp   *a_l;
    883 	} */ *ap = v;
    884 	struct vnode *vp = ap->a_vp;
    885 
    886 	vp = vp;
    887 	DPRINTF(VFSCALL, ("nilfs_setattr called\n"));
    888 	return EINVAL;
    889 }
    890 
    891 /* --------------------------------------------------------------------- */
    892 
    893 /*
    894  * Return POSIX pathconf information for NILFS file systems.
    895  */
    896 int
    897 nilfs_pathconf(void *v)
    898 {
    899 	struct vop_pathconf_args /* {
    900 		struct vnode *a_vp;
    901 		int a_name;
    902 		register_t *a_retval;
    903 	} */ *ap = v;
    904 	uint32_t bits;
    905 
    906 	DPRINTF(VFSCALL, ("nilfs_pathconf called\n"));
    907 
    908 	switch (ap->a_name) {
    909 	case _PC_LINK_MAX:
    910 		*ap->a_retval = (1<<16)-1;	/* 16 bits */
    911 		return 0;
    912 	case _PC_NAME_MAX:
    913 		*ap->a_retval = NILFS_MAXNAMLEN;
    914 		return 0;
    915 	case _PC_PATH_MAX:
    916 		*ap->a_retval = PATH_MAX;
    917 		return 0;
    918 	case _PC_PIPE_BUF:
    919 		*ap->a_retval = PIPE_BUF;
    920 		return 0;
    921 	case _PC_CHOWN_RESTRICTED:
    922 		*ap->a_retval = 1;
    923 		return 0;
    924 	case _PC_NO_TRUNC:
    925 		*ap->a_retval = 1;
    926 		return 0;
    927 	case _PC_SYNC_IO:
    928 		*ap->a_retval = 0;     /* synchronised is off for performance */
    929 		return 0;
    930 	case _PC_FILESIZEBITS:
    931 		/* 64 bit file offsets -> 2+floor(2log(2^64-1)) = 2 + 63 = 65 */
    932 		bits = 64; /* XXX ought to deliver 65 */
    933 #if 0
    934 		if (nilfs_node)
    935 			bits = 64 * vp->v_mount->mnt_dev_bshift;
    936 #endif
    937 		*ap->a_retval = bits;
    938 		return 0;
    939 	}
    940 
    941 	return EINVAL;
    942 }
    943 
    944 
    945 /* --------------------------------------------------------------------- */
    946 
    947 int
    948 nilfs_open(void *v)
    949 {
    950 	struct vop_open_args /* {
    951 		struct vnode *a_vp;
    952 		int a_mode;
    953 		kauth_cred_t a_cred;
    954 		struct proc *a_p;
    955 	} */ *ap = v;
    956 	int flags;
    957 
    958 	DPRINTF(VFSCALL, ("nilfs_open called\n"));
    959 
    960 	/*
    961 	 * Files marked append-only must be opened for appending.
    962 	 */
    963 	flags = 0;
    964 	if ((flags & APPEND) && (ap->a_mode & (FWRITE | O_APPEND)) == FWRITE)
    965 		return (EPERM);
    966 
    967 	return 0;
    968 }
    969 
    970 
    971 /* --------------------------------------------------------------------- */
    972 
    973 int
    974 nilfs_close(void *v)
    975 {
    976 	struct vop_close_args /* {
    977 		struct vnode *a_vp;
    978 		int a_fflag;
    979 		kauth_cred_t a_cred;
    980 		struct proc *a_p;
    981 	} */ *ap = v;
    982 	struct vnode *vp = ap->a_vp;
    983 	struct nilfs_node *nilfs_node = VTOI(vp);
    984 
    985 	DPRINTF(VFSCALL, ("nilfs_close called\n"));
    986 	nilfs_node = nilfs_node;	/* shut up gcc */
    987 
    988 	mutex_enter(vp->v_interlock);
    989 		if (vp->v_usecount > 1)
    990 			nilfs_itimes(nilfs_node, NULL, NULL, NULL);
    991 	mutex_exit(vp->v_interlock);
    992 
    993 	return 0;
    994 }
    995 
    996 
    997 /* --------------------------------------------------------------------- */
    998 
    999 static int
   1000 nilfs_check_possible(struct vnode *vp, struct vattr *vap, mode_t mode)
   1001 {
   1002 	int flags;
   1003 
   1004 	/* check if we are allowed to write */
   1005 	switch (vap->va_type) {
   1006 	case VDIR:
   1007 	case VLNK:
   1008 	case VREG:
   1009 		/*
   1010 		 * normal nodes: check if we're on a read-only mounted
   1011 		 * filingsystem and bomb out if we're trying to write.
   1012 		 */
   1013 		if ((mode & VWRITE) && (vp->v_mount->mnt_flag & MNT_RDONLY))
   1014 			return EROFS;
   1015 		break;
   1016 	case VBLK:
   1017 	case VCHR:
   1018 	case VSOCK:
   1019 	case VFIFO:
   1020 		/*
   1021 		 * special nodes: even on read-only mounted filingsystems
   1022 		 * these are allowed to be written to if permissions allow.
   1023 		 */
   1024 		break;
   1025 	default:
   1026 		/* no idea what this is */
   1027 		return EINVAL;
   1028 	}
   1029 
   1030 	/* noone may write immutable files */
   1031 	/* TODO: get chflags(2) flags */
   1032 	flags = 0;
   1033 	if ((mode & VWRITE) && (flags & IMMUTABLE))
   1034 		return EPERM;
   1035 
   1036 	return 0;
   1037 }
   1038 
   1039 static int
   1040 nilfs_check_permitted(struct vnode *vp, struct vattr *vap, mode_t mode,
   1041     kauth_cred_t cred)
   1042 {
   1043 
   1044 	/* ask the generic genfs_can_access to advice on security */
   1045 	return kauth_authorize_vnode(cred, KAUTH_ACCESS_ACTION(mode,
   1046 	    vp->v_type, vap->va_mode), vp, NULL, genfs_can_access(vp->v_type,
   1047 	    vap->va_mode, vap->va_uid, vap->va_gid, mode, cred));
   1048 }
   1049 
   1050 int
   1051 nilfs_access(void *v)
   1052 {
   1053 	struct vop_access_args /* {
   1054 		struct vnode *a_vp;
   1055 		int a_mode;
   1056 		kauth_cred_t a_cred;
   1057 		struct proc *a_p;
   1058 	} */ *ap = v;
   1059 	struct vnode    *vp   = ap->a_vp;
   1060 	mode_t	         mode = ap->a_mode;
   1061 	kauth_cred_t     cred = ap->a_cred;
   1062 	/* struct nilfs_node *nilfs_node = VTOI(vp); */
   1063 	struct vattr vap;
   1064 	int error;
   1065 
   1066 	DPRINTF(VFSCALL, ("nilfs_access called\n"));
   1067 
   1068 	error = VOP_GETATTR(vp, &vap, NULL);
   1069 	if (error)
   1070 		return error;
   1071 
   1072 	error = nilfs_check_possible(vp, &vap, mode);
   1073 	if (error)
   1074 		return error;
   1075 
   1076 	error = nilfs_check_permitted(vp, &vap, mode, cred);
   1077 
   1078 	return error;
   1079 }
   1080 
   1081 /* --------------------------------------------------------------------- */
   1082 
   1083 int
   1084 nilfs_create(void *v)
   1085 {
   1086 	struct vop_create_v3_args /* {
   1087 		struct vnode *a_dvp;
   1088 		struct vnode **a_vpp;
   1089 		struct componentname *a_cnp;
   1090 		struct vattr *a_vap;
   1091 	} */ *ap = v;
   1092 	struct vnode  *dvp = ap->a_dvp;
   1093 	struct vnode **vpp = ap->a_vpp;
   1094 	struct vattr  *vap  = ap->a_vap;
   1095 	struct componentname *cnp = ap->a_cnp;
   1096 	int error;
   1097 
   1098 	DPRINTF(VFSCALL, ("nilfs_create called\n"));
   1099 	error = nilfs_create_node(dvp, vpp, vap, cnp);
   1100 
   1101 	return error;
   1102 }
   1103 
   1104 /* --------------------------------------------------------------------- */
   1105 
   1106 int
   1107 nilfs_mknod(void *v)
   1108 {
   1109 	struct vop_mknod_v3_args /* {
   1110 		struct vnode *a_dvp;
   1111 		struct vnode **a_vpp;
   1112 		struct componentname *a_cnp;
   1113 		struct vattr *a_vap;
   1114 	} */ *ap = v;
   1115 	struct vnode  *dvp = ap->a_dvp;
   1116 	struct vnode **vpp = ap->a_vpp;
   1117 	struct vattr  *vap  = ap->a_vap;
   1118 	struct componentname *cnp = ap->a_cnp;
   1119 	int error;
   1120 
   1121 	DPRINTF(VFSCALL, ("nilfs_mknod called\n"));
   1122 	error = nilfs_create_node(dvp, vpp, vap, cnp);
   1123 
   1124 	return error;
   1125 }
   1126 
   1127 /* --------------------------------------------------------------------- */
   1128 
   1129 int
   1130 nilfs_mkdir(void *v)
   1131 {
   1132 	struct vop_mkdir_v3_args /* {
   1133 		struct vnode *a_dvp;
   1134 		struct vnode **a_vpp;
   1135 		struct componentname *a_cnp;
   1136 		struct vattr *a_vap;
   1137 	} */ *ap = v;
   1138 	struct vnode  *dvp = ap->a_dvp;
   1139 	struct vnode **vpp = ap->a_vpp;
   1140 	struct vattr  *vap  = ap->a_vap;
   1141 	struct componentname *cnp = ap->a_cnp;
   1142 	int error;
   1143 
   1144 	DPRINTF(VFSCALL, ("nilfs_mkdir called\n"));
   1145 	error = nilfs_create_node(dvp, vpp, vap, cnp);
   1146 
   1147 	return error;
   1148 }
   1149 
   1150 /* --------------------------------------------------------------------- */
   1151 
   1152 static int
   1153 nilfs_do_link(struct vnode *dvp, struct vnode *vp, struct componentname *cnp)
   1154 {
   1155 	struct nilfs_node *nilfs_node, *dir_node;
   1156 	struct vattr vap;
   1157 	int error;
   1158 
   1159 	DPRINTF(VFSCALL, ("nilfs_link called\n"));
   1160 	KASSERT(dvp != vp);
   1161 	KASSERT(vp->v_type != VDIR);
   1162 	KASSERT(dvp->v_mount == vp->v_mount);
   1163 
   1164 	/* lock node */
   1165 	error = vn_lock(vp, LK_EXCLUSIVE);
   1166 	if (error)
   1167 		return error;
   1168 
   1169 	/* get attributes */
   1170 	dir_node = VTOI(dvp);
   1171 	nilfs_node = VTOI(vp);
   1172 
   1173 	error = VOP_GETATTR(vp, &vap, FSCRED);
   1174 	if (error) {
   1175 		VOP_UNLOCK(vp);
   1176 		return error;
   1177 	}
   1178 
   1179 	/* check link count overflow */
   1180 	if (vap.va_nlink >= (1<<16)-1) {	/* uint16_t */
   1181 		VOP_UNLOCK(vp);
   1182 		return EMLINK;
   1183 	}
   1184 
   1185 	error = nilfs_dir_attach(dir_node->ump, dir_node, nilfs_node,
   1186 	    &vap, cnp);
   1187 	if (error)
   1188 		VOP_UNLOCK(vp);
   1189 	return error;
   1190 }
   1191 
   1192 int
   1193 nilfs_link(void *v)
   1194 {
   1195 	struct vop_link_args /* {
   1196 		struct vnode *a_dvp;
   1197 		struct vnode *a_vp;
   1198 		struct componentname *a_cnp;
   1199 	} */ *ap = v;
   1200 	struct vnode *dvp = ap->a_dvp;
   1201 	struct vnode *vp  = ap->a_vp;
   1202 	struct componentname *cnp = ap->a_cnp;
   1203 	int error;
   1204 
   1205 	error = nilfs_do_link(dvp, vp, cnp);
   1206 	if (error)
   1207 		VOP_ABORTOP(dvp, cnp);
   1208 
   1209 	VN_KNOTE(vp, NOTE_LINK);
   1210 	VN_KNOTE(dvp, NOTE_WRITE);
   1211 	vput(dvp);
   1212 
   1213 	return error;
   1214 }
   1215 
   1216 /* --------------------------------------------------------------------- */
   1217 
   1218 static int
   1219 nilfs_do_symlink(struct nilfs_node *nilfs_node, char *target)
   1220 {
   1221 	return EROFS;
   1222 }
   1223 
   1224 
   1225 int
   1226 nilfs_symlink(void *v)
   1227 {
   1228 	struct vop_symlink_v3_args /* {
   1229 		struct vnode *a_dvp;
   1230 		struct vnode **a_vpp;
   1231 		struct componentname *a_cnp;
   1232 		struct vattr *a_vap;
   1233 		char *a_target;
   1234 	} */ *ap = v;
   1235 	struct vnode  *dvp = ap->a_dvp;
   1236 	struct vnode **vpp = ap->a_vpp;
   1237 	struct vattr  *vap  = ap->a_vap;
   1238 	struct componentname *cnp = ap->a_cnp;
   1239 	struct nilfs_node *dir_node;
   1240 	struct nilfs_node *nilfs_node;
   1241 	int error;
   1242 
   1243 	DPRINTF(VFSCALL, ("nilfs_symlink called\n"));
   1244 	DPRINTF(VFSCALL, ("\tlinking to `%s`\n",  ap->a_target));
   1245 	error = nilfs_create_node(dvp, vpp, vap, cnp);
   1246 	KASSERT(((error == 0) && (*vpp != NULL)) || ((error && (*vpp == NULL))));
   1247 	if (!error) {
   1248 		dir_node = VTOI(dvp);
   1249 		nilfs_node = VTOI(*vpp);
   1250 		KASSERT(nilfs_node);
   1251 		error = nilfs_do_symlink(nilfs_node, ap->a_target);
   1252 		if (error) {
   1253 			/* remove node */
   1254 			nilfs_shrink_node(nilfs_node, 0);
   1255 			nilfs_dir_detach(nilfs_node->ump, dir_node, nilfs_node, cnp);
   1256 		}
   1257 	}
   1258 	return error;
   1259 }
   1260 
   1261 /* --------------------------------------------------------------------- */
   1262 
   1263 int
   1264 nilfs_readlink(void *v)
   1265 {
   1266 	struct vop_readlink_args /* {
   1267 		struct vnode *a_vp;
   1268 		struct uio *a_uio;
   1269 		kauth_cred_t a_cred;
   1270 	} */ *ap = v;
   1271 #if 0
   1272 	struct vnode *vp = ap->a_vp;
   1273 	struct uio *uio = ap->a_uio;
   1274 	kauth_cred_t cred = ap->a_cred;
   1275 	struct nilfs_node *nilfs_node;
   1276 	struct pathcomp pathcomp;
   1277 	struct vattr vattr;
   1278 	uint8_t *pathbuf, *targetbuf, *tmpname;
   1279 	uint8_t *pathpos, *targetpos;
   1280 	char *mntonname;
   1281 	int pathlen, targetlen, namelen, mntonnamelen, len, l_ci;
   1282 	int first, error;
   1283 #endif
   1284 	ap = ap;
   1285 
   1286 	DPRINTF(VFSCALL, ("nilfs_readlink called\n"));
   1287 
   1288 	return EROFS;
   1289 }
   1290 
   1291 /* --------------------------------------------------------------------- */
   1292 
   1293 /* note: i tried to follow the logics of the tmpfs rename code */
   1294 int
   1295 nilfs_rename(void *v)
   1296 {
   1297 	struct vop_rename_args /* {
   1298 		struct vnode *a_fdvp;
   1299 		struct vnode *a_fvp;
   1300 		struct componentname *a_fcnp;
   1301 		struct vnode *a_tdvp;
   1302 		struct vnode *a_tvp;
   1303 		struct componentname *a_tcnp;
   1304 	} */ *ap = v;
   1305 	struct vnode *tvp = ap->a_tvp;
   1306 	struct vnode *tdvp = ap->a_tdvp;
   1307 	struct vnode *fvp = ap->a_fvp;
   1308 	struct vnode *fdvp = ap->a_fdvp;
   1309 	struct componentname *tcnp = ap->a_tcnp;
   1310 	struct componentname *fcnp = ap->a_fcnp;
   1311 	struct nilfs_node *fnode, *fdnode, *tnode, *tdnode;
   1312 	struct vattr fvap, tvap;
   1313 	int error;
   1314 
   1315 	DPRINTF(VFSCALL, ("nilfs_rename called\n"));
   1316 
   1317 	/* disallow cross-device renames */
   1318 	if (fvp->v_mount != tdvp->v_mount ||
   1319 	    (tvp != NULL && fvp->v_mount != tvp->v_mount)) {
   1320 		error = EXDEV;
   1321 		goto out_unlocked;
   1322 	}
   1323 
   1324 	fnode  = VTOI(fvp);
   1325 	fdnode = VTOI(fdvp);
   1326 	tnode  = (tvp == NULL) ? NULL : VTOI(tvp);
   1327 	tdnode = VTOI(tdvp);
   1328 
   1329 	/* lock our source dir */
   1330 	if (fdnode != tdnode) {
   1331 		error = vn_lock(fdvp, LK_EXCLUSIVE | LK_RETRY);
   1332 		if (error != 0)
   1333 			goto out_unlocked;
   1334 	}
   1335 
   1336 	/* get info about the node to be moved */
   1337 	vn_lock(fvp, LK_SHARED | LK_RETRY);
   1338 	error = VOP_GETATTR(fvp, &fvap, FSCRED);
   1339 	VOP_UNLOCK(fvp);
   1340 	KASSERT(error == 0);
   1341 
   1342 	/* check when to delete the old already existing entry */
   1343 	if (tvp) {
   1344 		/* get info about the node to be moved to */
   1345 		error = VOP_GETATTR(tvp, &tvap, FSCRED);
   1346 		KASSERT(error == 0);
   1347 
   1348 		/* if both dirs, make sure the destination is empty */
   1349 		if (fvp->v_type == VDIR && tvp->v_type == VDIR) {
   1350 			if (tvap.va_nlink > 2) {
   1351 				error = ENOTEMPTY;
   1352 				goto out;
   1353 			}
   1354 		}
   1355 		/* if moving dir, make sure destination is dir too */
   1356 		if (fvp->v_type == VDIR && tvp->v_type != VDIR) {
   1357 			error = ENOTDIR;
   1358 			goto out;
   1359 		}
   1360 		/* if we're moving a non-directory, make sure dest is no dir */
   1361 		if (fvp->v_type != VDIR && tvp->v_type == VDIR) {
   1362 			error = EISDIR;
   1363 			goto out;
   1364 		}
   1365 	}
   1366 
   1367 	/* dont allow renaming directories acros directory for now */
   1368 	if (fdnode != tdnode) {
   1369 		if (fvp->v_type == VDIR) {
   1370 			error = EINVAL;
   1371 			goto out;
   1372 		}
   1373 	}
   1374 
   1375 	/* remove existing entry if present */
   1376 	if (tvp)
   1377 		nilfs_dir_detach(tdnode->ump, tdnode, tnode, tcnp);
   1378 
   1379 	/* create new directory entry for the node */
   1380 	error = nilfs_dir_attach(tdnode->ump, tdnode, fnode, &fvap, tcnp);
   1381 	if (error)
   1382 		goto out;
   1383 
   1384 	/* unlink old directory entry for the node, if failing, unattach new */
   1385 	error = nilfs_dir_detach(tdnode->ump, fdnode, fnode, fcnp);
   1386 	if (error)
   1387 		nilfs_dir_detach(tdnode->ump, tdnode, fnode, tcnp);
   1388 
   1389 out:
   1390         if (fdnode != tdnode)
   1391                 VOP_UNLOCK(fdvp);
   1392 
   1393 out_unlocked:
   1394 	VOP_ABORTOP(tdvp, tcnp);
   1395 	if (tdvp == tvp)
   1396 		vrele(tdvp);
   1397 	else
   1398 		vput(tdvp);
   1399 	if (tvp)
   1400 		vput(tvp);
   1401 	VOP_ABORTOP(fdvp, fcnp);
   1402 
   1403 	/* release source nodes. */
   1404 	vrele(fdvp);
   1405 	vrele(fvp);
   1406 
   1407 	return error;
   1408 }
   1409 
   1410 /* --------------------------------------------------------------------- */
   1411 
   1412 int
   1413 nilfs_remove(void *v)
   1414 {
   1415 	struct vop_remove_args /* {
   1416 		struct vnode *a_dvp;
   1417 		struct vnode *a_vp;
   1418 		struct componentname *a_cnp;
   1419 	} */ *ap = v;
   1420 	struct vnode *dvp = ap->a_dvp;
   1421 	struct vnode *vp  = ap->a_vp;
   1422 	struct componentname *cnp = ap->a_cnp;
   1423 	struct nilfs_node *dir_node = VTOI(dvp);
   1424 	struct nilfs_node *nilfs_node = VTOI(vp);
   1425 	struct nilfs_mount *ump = dir_node->ump;
   1426 	int error;
   1427 
   1428 	DPRINTF(VFSCALL, ("nilfs_remove called\n"));
   1429 	if (vp->v_type != VDIR) {
   1430 		error = nilfs_dir_detach(ump, dir_node, nilfs_node, cnp);
   1431 		DPRINTFIF(NODE, error, ("\tgot error removing file\n"));
   1432 	} else {
   1433 		DPRINTF(NODE, ("\tis a directory: perm. denied\n"));
   1434 		error = EPERM;
   1435 	}
   1436 
   1437 	if (error == 0) {
   1438 		VN_KNOTE(vp, NOTE_DELETE);
   1439 		VN_KNOTE(dvp, NOTE_WRITE);
   1440 	}
   1441 
   1442 	if (dvp == vp)
   1443 		vrele(vp);
   1444 	else
   1445 		vput(vp);
   1446 	vput(dvp);
   1447 
   1448 	return error;
   1449 }
   1450 
   1451 /* --------------------------------------------------------------------- */
   1452 
   1453 int
   1454 nilfs_rmdir(void *v)
   1455 {
   1456 	struct vop_rmdir_args /* {
   1457 		struct vnode *a_dvp;
   1458 		struct vnode *a_vp;
   1459 		struct componentname *a_cnp;
   1460 	} */ *ap = v;
   1461 	struct vnode *vp = ap->a_vp;
   1462 	struct vnode *dvp = ap->a_dvp;
   1463 	struct componentname *cnp = ap->a_cnp;
   1464 	struct nilfs_node *dir_node = VTOI(dvp);
   1465 	struct nilfs_node *nilfs_node = VTOI(vp);
   1466 	struct nilfs_mount *ump = dir_node->ump;
   1467 	int refcnt, error;
   1468 
   1469 	DPRINTF(NOTIMPL, ("nilfs_rmdir called\n"));
   1470 
   1471 	/* don't allow '.' to be deleted */
   1472 	if (dir_node == nilfs_node) {
   1473 		vrele(dvp);
   1474 		vput(vp);
   1475 		return EINVAL;
   1476 	}
   1477 
   1478 	/* check to see if the directory is empty */
   1479 	error = 0;
   1480 	refcnt = 2; /* XXX */
   1481 	if (refcnt > 1) {
   1482 		/* NOT empty */
   1483 		vput(dvp);
   1484 		vput(vp);
   1485 		return ENOTEMPTY;
   1486 	}
   1487 
   1488 	/* detach the node from the directory */
   1489 	error = nilfs_dir_detach(ump, dir_node, nilfs_node, cnp);
   1490 	if (error == 0) {
   1491 		cache_purge(vp);
   1492 //		cache_purge(dvp);	/* XXX from msdosfs, why? */
   1493 		VN_KNOTE(vp, NOTE_DELETE);
   1494 	}
   1495 	DPRINTFIF(NODE, error, ("\tgot error removing file\n"));
   1496 
   1497 	/* unput the nodes and exit */
   1498 	vput(dvp);
   1499 	vput(vp);
   1500 
   1501 	return error;
   1502 }
   1503 
   1504 /* --------------------------------------------------------------------- */
   1505 
   1506 int
   1507 nilfs_fsync(void *v)
   1508 {
   1509 	struct vop_fsync_args /* {
   1510 		struct vnode *a_vp;
   1511 		kauth_cred_t a_cred;
   1512 		int a_flags;
   1513 		off_t offlo;
   1514 		off_t offhi;
   1515 		struct proc *a_p;
   1516 	} */ *ap = v;
   1517 	struct vnode *vp = ap->a_vp;
   1518 //	struct nilfs_node *nilfs_node = VTOI(vp);
   1519 //	int error, flags, wait;
   1520 
   1521 	DPRINTF(STRATEGY, ("nilfs_fsync called : %s, %s\n",
   1522 		(ap->a_flags & FSYNC_WAIT)     ? "wait":"no wait",
   1523 		(ap->a_flags & FSYNC_DATAONLY) ? "data_only":"complete"));
   1524 
   1525 	vp = vp;
   1526 	return 0;
   1527 }
   1528 
   1529 /* --------------------------------------------------------------------- */
   1530 
   1531 int
   1532 nilfs_advlock(void *v)
   1533 {
   1534 	struct vop_advlock_args /* {
   1535 		struct vnode *a_vp;
   1536 		void *a_id;
   1537 		int a_op;
   1538 		struct flock *a_fl;
   1539 		int a_flags;
   1540 	} */ *ap = v;
   1541 	struct vnode *vp = ap->a_vp;
   1542 	struct nilfs_node *nilfs_node = VTOI(vp);
   1543 	uint64_t file_size;
   1544 
   1545 	DPRINTF(LOCKING, ("nilfs_advlock called\n"));
   1546 
   1547 	assert(nilfs_node);
   1548 	file_size = nilfs_rw64(nilfs_node->inode.i_size);
   1549 
   1550 	return lf_advlock(ap, &nilfs_node->lockf, file_size);
   1551 }
   1552 
   1553 /* --------------------------------------------------------------------- */
   1554 
   1555 
   1556 /* Global vfs vnode data structures for nilfss */
   1557 int (**nilfs_vnodeop_p) __P((void *));
   1558 
   1559 const struct vnodeopv_entry_desc nilfs_vnodeop_entries[] = {
   1560 	{ &vop_default_desc, vn_default_error },
   1561 	{ &vop_lookup_desc, nilfs_lookup },	/* lookup */
   1562 	{ &vop_create_desc, nilfs_create },	/* create */
   1563 	{ &vop_mknod_desc, nilfs_mknod },	/* mknod */	/* TODO */
   1564 	{ &vop_open_desc, nilfs_open },		/* open */
   1565 	{ &vop_close_desc, nilfs_close },	/* close */
   1566 	{ &vop_access_desc, nilfs_access },	/* access */
   1567 	{ &vop_getattr_desc, nilfs_getattr },	/* getattr */
   1568 	{ &vop_setattr_desc, nilfs_setattr },	/* setattr */	/* TODO chflags */
   1569 	{ &vop_read_desc, nilfs_read },		/* read */
   1570 	{ &vop_write_desc, nilfs_write },	/* write */	/* WRITE */
   1571 	{ &vop_fcntl_desc, genfs_fcntl },	/* fcntl */	/* TODO? */
   1572 	{ &vop_ioctl_desc, genfs_enoioctl },	/* ioctl */	/* TODO? */
   1573 	{ &vop_poll_desc, genfs_poll },		/* poll */	/* TODO/OK? */
   1574 	{ &vop_kqfilter_desc, genfs_kqfilter },	/* kqfilter */	/* ? */
   1575 	{ &vop_revoke_desc, genfs_revoke },	/* revoke */	/* TODO? */
   1576 	{ &vop_mmap_desc, genfs_mmap },		/* mmap */	/* OK? */
   1577 	{ &vop_fsync_desc, nilfs_fsync },	/* fsync */
   1578 	{ &vop_seek_desc, genfs_seek },		/* seek */
   1579 	{ &vop_remove_desc, nilfs_remove },	/* remove */
   1580 	{ &vop_link_desc, nilfs_link },		/* link */	/* TODO */
   1581 	{ &vop_rename_desc, nilfs_rename },	/* rename */ 	/* TODO */
   1582 	{ &vop_mkdir_desc, nilfs_mkdir },	/* mkdir */
   1583 	{ &vop_rmdir_desc, nilfs_rmdir },	/* rmdir */
   1584 	{ &vop_symlink_desc, nilfs_symlink },	/* symlink */	/* TODO */
   1585 	{ &vop_readdir_desc, nilfs_readdir },	/* readdir */
   1586 	{ &vop_readlink_desc, nilfs_readlink },	/* readlink */	/* TEST ME */
   1587 	{ &vop_abortop_desc, genfs_abortop },	/* abortop */	/* TODO/OK? */
   1588 	{ &vop_inactive_desc, nilfs_inactive },	/* inactive */
   1589 	{ &vop_reclaim_desc, nilfs_reclaim },	/* reclaim */
   1590 	{ &vop_lock_desc, genfs_lock },		/* lock */
   1591 	{ &vop_unlock_desc, genfs_unlock },	/* unlock */
   1592 	{ &vop_bmap_desc, nilfs_trivial_bmap },	/* bmap */	/* 1:1 bmap */
   1593 	{ &vop_strategy_desc, nilfs_vfsstrategy },/* strategy */
   1594 /*	{ &vop_print_desc, nilfs_print },	*/	/* print */
   1595 	{ &vop_islocked_desc, genfs_islocked },	/* islocked */
   1596 	{ &vop_pathconf_desc, nilfs_pathconf },	/* pathconf */
   1597 	{ &vop_advlock_desc, nilfs_advlock },	/* advlock */	/* TEST ME */
   1598 	{ &vop_bwrite_desc, vn_bwrite },	/* bwrite */	/* ->strategy */
   1599 	{ &vop_getpages_desc, genfs_getpages },	/* getpages */
   1600 	{ &vop_putpages_desc, genfs_putpages },	/* putpages */
   1601 	{ NULL, NULL }
   1602 };
   1603 
   1604 
   1605 const struct vnodeopv_desc nilfs_vnodeop_opv_desc = {
   1606 	&nilfs_vnodeop_p, nilfs_vnodeop_entries
   1607 };
   1608 
   1609