must have vnode locked before doing ufs_access
[unix-history] / usr / src / sys / ufs / ffs / ufs_vnops.c
CommitLineData
da7c5cc6 1/*
7188ac27
KM
2 * Copyright (c) 1982, 1986, 1989 Regents of the University of California.
3 * All rights reserved.
da7c5cc6 4 *
7188ac27
KM
5 * Redistribution and use in source and binary forms are permitted
6 * provided that the above copyright notice and this paragraph are
7 * duplicated in all such forms and that any documentation,
8 * advertising materials, and other materials related to such
9 * distribution and use acknowledge that the software was developed
10 * by the University of California, Berkeley. The name of the
11 * University may not be used to endorse or promote products derived
12 * from this software without specific prior written permission.
13 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
14 * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
15 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
16 *
48c3b6e8 17 * @(#)ufs_vnops.c 7.38 (Berkeley) %G%
da7c5cc6 18 */
6459ebe0 19
94368568
JB
20#include "param.h"
21#include "systm.h"
94368568
JB
22#include "user.h"
23#include "kernel.h"
24#include "file.h"
25#include "stat.h"
94368568
JB
26#include "buf.h"
27#include "proc.h"
94368568
JB
28#include "socket.h"
29#include "socketvar.h"
7188ac27 30#include "conf.h"
94368568 31#include "mount.h"
7188ac27 32#include "vnode.h"
0f93ba7b 33#include "specdev.h"
4b61628b 34#include "../ufs/quota.h"
7188ac27
KM
35#include "../ufs/inode.h"
36#include "../ufs/fs.h"
3e78e260 37
4f083fd7 38/*
7188ac27 39 * Global vfs data structures for ufs
4f083fd7 40 */
3e78e260 41
7188ac27
KM
42int ufs_lookup(),
43 ufs_create(),
44 ufs_mknod(),
45 ufs_open(),
46 ufs_close(),
47 ufs_access(),
48 ufs_getattr(),
49 ufs_setattr(),
50 ufs_read(),
51 ufs_write(),
52 ufs_ioctl(),
53 ufs_select(),
54 ufs_mmap(),
55 ufs_fsync(),
56 ufs_seek(),
57 ufs_remove(),
58 ufs_link(),
59 ufs_rename(),
60 ufs_mkdir(),
61 ufs_rmdir(),
62 ufs_symlink(),
63 ufs_readdir(),
64 ufs_readlink(),
65 ufs_abortop(),
66 ufs_inactive(),
e8a3816c 67 ufs_reclaim(),
7188ac27
KM
68 ufs_lock(),
69 ufs_unlock(),
70 ufs_bmap(),
e16fa59e 71 ufs_strategy(),
1c3ebc10
KM
72 ufs_print(),
73 ufs_islocked();
7188ac27
KM
74
75struct vnodeops ufs_vnodeops = {
e16fa59e
KM
76 ufs_lookup, /* lookup */
77 ufs_create, /* create */
78 ufs_mknod, /* mknod */
79 ufs_open, /* open */
80 ufs_close, /* close */
81 ufs_access, /* access */
82 ufs_getattr, /* getattr */
83 ufs_setattr, /* setattr */
84 ufs_read, /* read */
85 ufs_write, /* write */
86 ufs_ioctl, /* ioctl */
87 ufs_select, /* select */
88 ufs_mmap, /* mmap */
89 ufs_fsync, /* fsync */
90 ufs_seek, /* seek */
91 ufs_remove, /* remove */
92 ufs_link, /* link */
93 ufs_rename, /* rename */
94 ufs_mkdir, /* mkdir */
95 ufs_rmdir, /* rmdir */
96 ufs_symlink, /* symlink */
97 ufs_readdir, /* readdir */
98 ufs_readlink, /* readlink */
99 ufs_abortop, /* abortop */
100 ufs_inactive, /* inactive */
101 ufs_reclaim, /* reclaim */
102 ufs_lock, /* lock */
103 ufs_unlock, /* unlock */
104 ufs_bmap, /* bmap */
105 ufs_strategy, /* strategy */
106 ufs_print, /* print */
1c3ebc10 107 ufs_islocked, /* islocked */
7188ac27
KM
108};
109
f09fe6d3
KM
110int spec_lookup(),
111 spec_open(),
24a31b70
KM
112 ufsspec_read(),
113 ufsspec_write(),
f09fe6d3 114 spec_strategy(),
e16fa59e 115 spec_bmap(),
f09fe6d3
KM
116 spec_ioctl(),
117 spec_select(),
24a31b70 118 ufsspec_close(),
f09fe6d3
KM
119 spec_badop(),
120 spec_nullop();
121
122struct vnodeops spec_inodeops = {
86cdabf6
KM
123 spec_lookup, /* lookup */
124 spec_badop, /* create */
125 spec_badop, /* mknod */
126 spec_open, /* open */
24a31b70 127 ufsspec_close, /* close */
86cdabf6
KM
128 ufs_access, /* access */
129 ufs_getattr, /* getattr */
130 ufs_setattr, /* setattr */
24a31b70
KM
131 ufsspec_read, /* read */
132 ufsspec_write, /* write */
86cdabf6
KM
133 spec_ioctl, /* ioctl */
134 spec_select, /* select */
135 spec_badop, /* mmap */
136 spec_nullop, /* fsync */
137 spec_badop, /* seek */
138 spec_badop, /* remove */
139 spec_badop, /* link */
140 spec_badop, /* rename */
141 spec_badop, /* mkdir */
142 spec_badop, /* rmdir */
143 spec_badop, /* symlink */
144 spec_badop, /* readdir */
145 spec_badop, /* readlink */
146 spec_badop, /* abortop */
147 ufs_inactive, /* inactive */
148 ufs_reclaim, /* reclaim */
149 ufs_lock, /* lock */
150 ufs_unlock, /* unlock */
e16fa59e 151 spec_bmap, /* bmap */
86cdabf6 152 spec_strategy, /* strategy */
e16fa59e 153 ufs_print, /* print */
1c3ebc10 154 ufs_islocked, /* islocked */
f09fe6d3
KM
155};
156
d1c43d7f
KM
157#ifdef FIFO
158int fifo_lookup(),
159 fifo_open(),
160 ufsfifo_read(),
161 ufsfifo_write(),
162 fifo_bmap(),
163 fifo_ioctl(),
164 fifo_select(),
165 ufsfifo_close(),
166 fifo_print(),
167 fifo_badop(),
168 fifo_nullop();
169
170struct vnodeops fifo_inodeops = {
171 fifo_lookup, /* lookup */
172 fifo_badop, /* create */
173 fifo_badop, /* mknod */
174 fifo_open, /* open */
175 ufsfifo_close, /* close */
176 ufs_access, /* access */
177 ufs_getattr, /* getattr */
178 ufs_setattr, /* setattr */
179 ufsfifo_read, /* read */
180 ufsfifo_write, /* write */
181 fifo_ioctl, /* ioctl */
182 fifo_select, /* select */
183 fifo_badop, /* mmap */
184 fifo_nullop, /* fsync */
185 fifo_badop, /* seek */
186 fifo_badop, /* remove */
187 fifo_badop, /* link */
188 fifo_badop, /* rename */
189 fifo_badop, /* mkdir */
190 fifo_badop, /* rmdir */
191 fifo_badop, /* symlink */
192 fifo_badop, /* readdir */
193 fifo_badop, /* readlink */
194 fifo_badop, /* abortop */
195 ufs_inactive, /* inactive */
196 ufs_reclaim, /* reclaim */
197 ufs_lock, /* lock */
198 ufs_unlock, /* unlock */
199 fifo_bmap, /* bmap */
200 fifo_badop, /* strategy */
201 ufs_print, /* print */
202 ufs_islocked, /* islocked */
203};
204#endif /* FIFO */
205
206enum vtype iftovt_tab[16] = {
207 VNON, VFIFO, VCHR, VNON, VDIR, VNON, VBLK, VNON,
208 VREG, VNON, VLNK, VNON, VSOCK, VNON, VNON, VBAD,
7188ac27 209};
d1c43d7f
KM
210int vttoif_tab[9] = {
211 0, IFREG, IFDIR, IFBLK, IFCHR, IFLNK, IFSOCK, IFIFO, IFMT,
7188ac27 212};
3e78e260 213
4f083fd7 214/*
7188ac27 215 * Create a regular file
4f083fd7 216 */
7188ac27
KM
217ufs_create(ndp, vap)
218 struct nameidata *ndp;
219 struct vattr *vap;
3e78e260 220{
7188ac27
KM
221 struct inode *ip;
222 int error;
3e78e260 223
7188ac27
KM
224 if (error = maknode(MAKEIMODE(vap->va_type, vap->va_mode), ndp, &ip))
225 return (error);
226 ndp->ni_vp = ITOV(ip);
227 return (0);
3e78e260
BJ
228}
229
4f083fd7 230/*
7188ac27 231 * Mknod vnode call
4f083fd7 232 */
7188ac27
KM
233/* ARGSUSED */
234ufs_mknod(ndp, vap, cred)
235 struct nameidata *ndp;
236 struct ucred *cred;
237 struct vattr *vap;
3e78e260 238{
f09fe6d3 239 register struct vnode *vp;
7188ac27
KM
240 struct inode *ip;
241 int error;
3e78e260 242
7188ac27
KM
243 if (error = maknode(MAKEIMODE(vap->va_type, vap->va_mode), ndp, &ip))
244 return (error);
d1c43d7f
KM
245 ip->i_flag |= IACC|IUPD|ICHG;
246 if (vap->va_rdev != VNOVAL) {
7188ac27
KM
247 /*
248 * Want to be able to use this to make badblock
249 * inodes, so don't truncate the dev number.
250 */
b373e060 251 ip->i_rdev = vap->va_rdev;
7188ac27 252 }
7188ac27
KM
253 /*
254 * Remove inode so that it will be reloaded by iget and
255 * checked to see if it is an alias of an existing entry
256 * in the inode cache.
257 */
d1c43d7f
KM
258 vp = ITOV(ip);
259 vput(vp);
f09fe6d3
KM
260 vp->v_type = VNON;
261 vgone(vp);
7188ac27 262 return (0);
3e78e260
BJ
263}
264
265/*
7188ac27
KM
266 * Open called.
267 *
268 * Nothing to do.
3e78e260 269 */
7188ac27
KM
270/* ARGSUSED */
271ufs_open(vp, mode, cred)
272 struct vnode *vp;
273 int mode;
274 struct ucred *cred;
3e78e260 275{
3e78e260 276
7188ac27 277 return (0);
3e78e260
BJ
278}
279
280/*
7188ac27
KM
281 * Close called
282 *
283 * Update the times on the inode.
3e78e260 284 */
7188ac27
KM
285/* ARGSUSED */
286ufs_close(vp, fflag, cred)
287 struct vnode *vp;
288 int fflag;
289 struct ucred *cred;
3e78e260 290{
7188ac27 291 register struct inode *ip = VTOI(vp);
3e78e260 292
de67eefc 293 if (vp->v_usecount > 1 && !(ip->i_flag & ILOCKED))
7188ac27
KM
294 ITIMES(ip, &time, &time);
295 return (0);
3e78e260
BJ
296}
297
4b61628b
KM
298/*
299 * Check mode permission on inode pointer. Mode is READ, WRITE or EXEC.
300 * The mode is shifted to select the owner/group/other fields. The
301 * super user is granted all permissions.
302 */
7188ac27
KM
303ufs_access(vp, mode, cred)
304 struct vnode *vp;
4b61628b 305 register int mode;
7188ac27 306 struct ucred *cred;
3e78e260 307{
4b61628b
KM
308 register struct inode *ip = VTOI(vp);
309 register gid_t *gp;
310 int i, error;
3e78e260 311
4b61628b
KM
312#ifdef DIAGNOSTIC
313 if (!VOP_ISLOCKED(vp)) {
314 vprint("ufs_access: not locked", vp);
315 panic("ufs_access: not locked");
316 }
317#endif
318#ifdef QUOTA
319 if (mode & VWRITE) {
320 switch (vp->v_type) {
321 case VREG: case VDIR: case VLNK:
322 if (error = getinoquota(ip))
323 return (error);
324 }
325 }
326#endif /* QUOTA */
327 /*
328 * If you're the super-user, you always get access.
329 */
330 if (cred->cr_uid == 0)
331 return (0);
332 /*
333 * Access check is based on only one of owner, group, public.
334 * If not owner, then check group. If not a member of the
335 * group, then check public access.
336 */
337 if (cred->cr_uid != ip->i_uid) {
338 mode >>= 3;
339 gp = cred->cr_groups;
340 for (i = 0; i < cred->cr_ngroups; i++, gp++)
341 if (ip->i_gid == *gp)
342 goto found;
343 mode >>= 3;
344found:
345 ;
346 }
347 if ((ip->i_mode & mode) != 0)
348 return (0);
349 return (EACCES);
3e78e260
BJ
350}
351
7188ac27
KM
352/* ARGSUSED */
353ufs_getattr(vp, vap, cred)
354 struct vnode *vp;
355 register struct vattr *vap;
356 struct ucred *cred;
3e78e260 357{
7188ac27 358 register struct inode *ip = VTOI(vp);
3e78e260 359
7188ac27 360 ITIMES(ip, &time, &time);
3e78e260 361 /*
7188ac27 362 * Copy from inode table
3e78e260 363 */
7188ac27
KM
364 vap->va_fsid = ip->i_dev;
365 vap->va_fileid = ip->i_number;
366 vap->va_mode = ip->i_mode & ~IFMT;
367 vap->va_nlink = ip->i_nlink;
368 vap->va_uid = ip->i_uid;
369 vap->va_gid = ip->i_gid;
370 vap->va_rdev = (dev_t)ip->i_rdev;
4b61628b
KM
371#ifdef tahoe
372 vap->va_size = ip->i_size;
373 vap->va_size_rsv = 0;
374#else
8fae943a 375 vap->va_qsize = ip->i_din.di_qsize;
4b61628b 376#endif
7188ac27 377 vap->va_atime.tv_sec = ip->i_atime;
6ef53d70 378 vap->va_atime.tv_usec = 0;
7188ac27 379 vap->va_mtime.tv_sec = ip->i_mtime;
6ef53d70 380 vap->va_mtime.tv_usec = 0;
7188ac27 381 vap->va_ctime.tv_sec = ip->i_ctime;
6ef53d70 382 vap->va_ctime.tv_usec = 0;
d07fc92a
KM
383 vap->va_flags = ip->i_flags;
384 vap->va_gen = ip->i_gen;
7188ac27
KM
385 /* this doesn't belong here */
386 if (vp->v_type == VBLK)
387 vap->va_blocksize = BLKDEV_IOSIZE;
388 else if (vp->v_type == VCHR)
389 vap->va_blocksize = MAXBSIZE;
8eee8525 390 else
7188ac27 391 vap->va_blocksize = ip->i_fs->fs_bsize;
a61a68d6 392 vap->va_bytes = dbtob(ip->i_blocks);
8fae943a 393 vap->va_bytes_rsv = 0;
7188ac27
KM
394 vap->va_type = vp->v_type;
395 return (0);
3e78e260
BJ
396}
397
398/*
7188ac27 399 * Set attribute vnode op. called from several syscalls
3e78e260 400 */
7188ac27
KM
401ufs_setattr(vp, vap, cred)
402 register struct vnode *vp;
403 register struct vattr *vap;
404 register struct ucred *cred;
3e78e260 405{
7188ac27
KM
406 register struct inode *ip = VTOI(vp);
407 int error = 0;
b4d1aee9 408
7188ac27
KM
409 /*
410 * Check for unsetable attributes.
411 */
412 if ((vap->va_type != VNON) || (vap->va_nlink != VNOVAL) ||
413 (vap->va_fsid != VNOVAL) || (vap->va_fileid != VNOVAL) ||
414 (vap->va_blocksize != VNOVAL) || (vap->va_rdev != VNOVAL) ||
d07fc92a 415 ((int)vap->va_bytes != VNOVAL) || (vap->va_gen != VNOVAL)) {
7188ac27 416 return (EINVAL);
b4d1aee9 417 }
7188ac27
KM
418 /*
419 * Go through the fields and update iff not VNOVAL.
420 */
421 if (vap->va_uid != (u_short)VNOVAL || vap->va_gid != (u_short)VNOVAL)
422 if (error = chown1(vp, vap->va_uid, vap->va_gid, cred))
423 return (error);
424 if (vap->va_size != VNOVAL) {
425 if (vp->v_type == VDIR)
426 return (EISDIR);
e16fa59e 427 if (error = itrunc(ip, vap->va_size, 0)) /* XXX IO_SYNC? */
7188ac27 428 return (error);
3e78e260 429 }
7188ac27 430 if (vap->va_atime.tv_sec != VNOVAL || vap->va_mtime.tv_sec != VNOVAL) {
de412887
KM
431 if (cred->cr_uid != ip->i_uid &&
432 (error = suser(cred, &u.u_acflag)))
433 return (error);
7188ac27
KM
434 if (vap->va_atime.tv_sec != VNOVAL)
435 ip->i_flag |= IACC;
436 if (vap->va_mtime.tv_sec != VNOVAL)
437 ip->i_flag |= IUPD;
438 ip->i_flag |= ICHG;
439 if (error = iupdat(ip, &vap->va_atime, &vap->va_mtime, 1))
440 return (error);
5485e062 441 }
7188ac27
KM
442 if (vap->va_mode != (u_short)VNOVAL)
443 error = chmod1(vp, (int)vap->va_mode, cred);
d07fc92a
KM
444 if (vap->va_flags != VNOVAL) {
445 if (cred->cr_uid != ip->i_uid &&
446 (error = suser(cred, &u.u_acflag)))
447 return (error);
448 if (cred->cr_uid == 0) {
449 ip->i_flags = vap->va_flags;
450 } else {
451 ip->i_flags &= 0xffff0000;
452 ip->i_flags |= (vap->va_flags & 0xffff);
453 }
454 ip->i_flag |= ICHG;
455 }
7188ac27 456 return (error);
528f664c
SL
457}
458
4f083fd7
SL
459/*
460 * Change the mode on a file.
461 * Inode must be locked before calling.
462 */
7188ac27
KM
463chmod1(vp, mode, cred)
464 register struct vnode *vp;
528f664c 465 register int mode;
7188ac27 466 struct ucred *cred;
528f664c 467{
7188ac27 468 register struct inode *ip = VTOI(vp);
de412887 469 int error;
197da11b 470
de412887
KM
471 if (cred->cr_uid != ip->i_uid &&
472 (error = suser(cred, &u.u_acflag)))
473 return (error);
3e78e260 474 ip->i_mode &= ~07777;
7188ac27
KM
475 if (cred->cr_uid) {
476 if (vp->v_type != VDIR)
47af7174 477 mode &= ~ISVTX;
7188ac27 478 if (!groupmember(ip->i_gid, cred))
bb1b75f4 479 mode &= ~ISGID;
f94ceb3b 480 }
7188ac27 481 ip->i_mode |= mode & 07777;
3e78e260 482 ip->i_flag |= ICHG;
7188ac27
KM
483 if ((vp->v_flag & VTEXT) && (ip->i_mode & ISVTX) == 0)
484 xrele(vp);
47af7174 485 return (0);
5485e062
BJ
486}
487
528f664c
SL
488/*
489 * Perform chown operation on inode ip;
490 * inode must be locked prior to call.
491 */
7188ac27
KM
492chown1(vp, uid, gid, cred)
493 register struct vnode *vp;
494 uid_t uid;
495 gid_t gid;
496 struct ucred *cred;
528f664c 497{
7188ac27 498 register struct inode *ip = VTOI(vp);
4b61628b
KM
499 uid_t ouid;
500 gid_t ogid;
501 int error = 0;
528f664c 502#ifdef QUOTA
4b61628b
KM
503 register int i;
504 long change;
bb1b75f4 505#endif
528f664c 506
7188ac27 507 if (uid == (u_short)VNOVAL)
bb1b75f4 508 uid = ip->i_uid;
7188ac27 509 if (gid == (u_short)VNOVAL)
bb1b75f4 510 gid = ip->i_gid;
18b0bce6
KB
511 /*
512 * If we don't own the file, are trying to change the owner
513 * of the file, or are not a member of the target group,
514 * the caller must be superuser or the call fails.
515 */
7188ac27
KM
516 if ((cred->cr_uid != ip->i_uid || uid != ip->i_uid ||
517 !groupmember((gid_t)gid, cred)) &&
518 (error = suser(cred, &u.u_acflag)))
519 return (error);
4b61628b
KM
520 ouid = ip->i_uid;
521 ogid = ip->i_gid;
bb1b75f4 522#ifdef QUOTA
4b61628b
KM
523 if (error = getinoquota(ip))
524 return (error);
525 if (ouid == uid) {
526 dqrele(vp, ip->i_dquot[USRQUOTA]);
527 ip->i_dquot[USRQUOTA] = NODQUOT;
528 }
529 if (ogid == gid) {
530 dqrele(vp, ip->i_dquot[GRPQUOTA]);
531 ip->i_dquot[GRPQUOTA] = NODQUOT;
532 }
533 change = ip->i_blocks;
534 (void) chkdq(ip, -change, cred, CHOWN);
535 (void) chkiq(ip, -1, cred, CHOWN);
536 for (i = 0; i < MAXQUOTAS; i++) {
537 dqrele(vp, ip->i_dquot[i]);
538 ip->i_dquot[i] = NODQUOT;
539 }
f94ceb3b 540#endif
bb1b75f4
SL
541 ip->i_uid = uid;
542 ip->i_gid = gid;
528f664c 543#ifdef QUOTA
4b61628b
KM
544 if ((error = getinoquota(ip)) == 0) {
545 if (ouid == uid) {
546 dqrele(vp, ip->i_dquot[USRQUOTA]);
547 ip->i_dquot[USRQUOTA] = NODQUOT;
548 }
549 if (ogid == gid) {
550 dqrele(vp, ip->i_dquot[GRPQUOTA]);
551 ip->i_dquot[GRPQUOTA] = NODQUOT;
552 }
553 if ((error = chkdq(ip, change, cred, CHOWN)) == 0) {
554 if ((error = chkiq(ip, 1, cred, CHOWN)) == 0)
555 return (0);
556 else
557 (void) chkdq(ip, -change, cred, CHOWN|FORCE);
558 }
559 for (i = 0; i < MAXQUOTAS; i++) {
560 dqrele(vp, ip->i_dquot[i]);
561 ip->i_dquot[i] = NODQUOT;
562 }
563 }
564 ip->i_uid = ouid;
565 ip->i_gid = ogid;
566 if (getinoquota(ip) == 0) {
567 if (ouid == uid) {
568 dqrele(vp, ip->i_dquot[USRQUOTA]);
569 ip->i_dquot[USRQUOTA] = NODQUOT;
570 }
571 if (ogid == gid) {
572 dqrele(vp, ip->i_dquot[GRPQUOTA]);
573 ip->i_dquot[GRPQUOTA] = NODQUOT;
574 }
575 (void) chkdq(ip, change, cred, FORCE);
576 (void) chkiq(ip, 1, cred, FORCE);
577 }
578 if (error)
579 return (error);
2e073567 580#endif
4b61628b
KM
581 if (ouid != uid || ogid != gid)
582 ip->i_flag |= ICHG;
583 if (ouid != uid && cred->cr_uid != 0)
584 ip->i_mode &= ~ISUID;
585 if (ogid != gid && cred->cr_uid != 0)
586 ip->i_mode &= ~ISGID;
587 return (0);
d67a03eb
BJ
588}
589
b373e060
KM
590/*
591 * Vnode op for reading.
592 */
593/* ARGSUSED */
594ufs_read(vp, uio, ioflag, cred)
595 struct vnode *vp;
596 register struct uio *uio;
597 int ioflag;
598 struct ucred *cred;
599{
600 register struct inode *ip = VTOI(vp);
601 register struct fs *fs;
602 struct buf *bp;
603 daddr_t lbn, bn, rablock;
20aa076b 604 int size, diff, error = 0;
b373e060
KM
605 long n, on, type;
606
607 if (uio->uio_rw != UIO_READ)
608 panic("ufs_read mode");
609 type = ip->i_mode & IFMT;
610 if (type != IFDIR && type != IFREG && type != IFLNK)
611 panic("ufs_read type");
612 if (uio->uio_resid == 0)
613 return (0);
614 if (uio->uio_offset < 0)
615 return (EINVAL);
616 ip->i_flag |= IACC;
617 fs = ip->i_fs;
618 do {
619 lbn = lblkno(fs, uio->uio_offset);
620 on = blkoff(fs, uio->uio_offset);
621 n = MIN((unsigned)(fs->fs_bsize - on), uio->uio_resid);
622 diff = ip->i_size - uio->uio_offset;
623 if (diff <= 0)
624 return (0);
625 if (diff < n)
626 n = diff;
b373e060 627 size = blksize(fs, ip, lbn);
e16fa59e 628 rablock = lbn + 1;
20aa076b
KM
629 if (vp->v_lastr + 1 == lbn &&
630 lblktosize(fs, rablock) < ip->i_size)
631 error = breada(ITOV(ip), lbn, size, rablock,
632 blksize(fs, ip, rablock), NOCRED, &bp);
b373e060 633 else
e16fa59e 634 error = bread(ITOV(ip), lbn, size, NOCRED, &bp);
de67eefc 635 vp->v_lastr = lbn;
b373e060
KM
636 n = MIN(n, size - bp->b_resid);
637 if (error) {
638 brelse(bp);
639 return (error);
640 }
641 error = uiomove(bp->b_un.b_addr + on, (int)n, uio);
642 if (n + on == fs->fs_bsize || uio->uio_offset == ip->i_size)
643 bp->b_flags |= B_AGE;
644 brelse(bp);
645 } while (error == 0 && uio->uio_resid > 0 && n != 0);
646 return (error);
647}
648
649/*
650 * Vnode op for writing.
651 */
652ufs_write(vp, uio, ioflag, cred)
653 register struct vnode *vp;
654 struct uio *uio;
655 int ioflag;
656 struct ucred *cred;
657{
658 register struct inode *ip = VTOI(vp);
659 register struct fs *fs;
660 struct buf *bp;
661 daddr_t lbn, bn;
662 u_long osize;
663 int i, n, on, flags;
664 int count, size, resid, error = 0;
665
666 if (uio->uio_rw != UIO_WRITE)
667 panic("ufs_write mode");
668 switch (vp->v_type) {
669 case VREG:
670 if (ioflag & IO_APPEND)
671 uio->uio_offset = ip->i_size;
672 /* fall through */
673 case VLNK:
674 break;
675
676 case VDIR:
677 if ((ioflag & IO_SYNC) == 0)
678 panic("ufs_write nonsync dir write");
679 break;
680
681 default:
682 panic("ufs_write type");
683 }
684 if (uio->uio_offset < 0)
685 return (EINVAL);
686 if (uio->uio_resid == 0)
687 return (0);
688 /*
689 * Maybe this should be above the vnode op call, but so long as
690 * file servers have no limits, i don't think it matters
691 */
692 if (vp->v_type == VREG &&
693 uio->uio_offset + uio->uio_resid >
694 u.u_rlimit[RLIMIT_FSIZE].rlim_cur) {
695 psignal(u.u_procp, SIGXFSZ);
696 return (EFBIG);
697 }
698 resid = uio->uio_resid;
699 osize = ip->i_size;
700 fs = ip->i_fs;
e16fa59e
KM
701 flags = 0;
702 if (ioflag & IO_SYNC)
703 flags = B_SYNC;
b373e060
KM
704 do {
705 lbn = lblkno(fs, uio->uio_offset);
706 on = blkoff(fs, uio->uio_offset);
707 n = MIN((unsigned)(fs->fs_bsize - on), uio->uio_resid);
708 if (n < fs->fs_bsize)
e16fa59e 709 flags |= B_CLRBUF;
b373e060 710 else
e16fa59e
KM
711 flags &= ~B_CLRBUF;
712 if (error = balloc(ip, lbn, (int)(on + n), &bp, flags))
b373e060 713 break;
e16fa59e 714 bn = bp->b_blkno;
b373e060
KM
715 if (uio->uio_offset + n > ip->i_size)
716 ip->i_size = uio->uio_offset + n;
717 size = blksize(fs, ip, lbn);
718 count = howmany(size, CLBYTES);
719 for (i = 0; i < count; i++)
720 munhash(ip->i_devvp, bn + i * CLBYTES / DEV_BSIZE);
b373e060 721 n = MIN(n, size - bp->b_resid);
b373e060
KM
722 error = uiomove(bp->b_un.b_addr + on, n, uio);
723 if (ioflag & IO_SYNC)
724 (void) bwrite(bp);
725 else if (n + on == fs->fs_bsize) {
726 bp->b_flags |= B_AGE;
727 bawrite(bp);
728 } else
729 bdwrite(bp);
730 ip->i_flag |= IUPD|ICHG;
731 if (cred->cr_uid != 0)
732 ip->i_mode &= ~(ISUID|ISGID);
733 } while (error == 0 && uio->uio_resid > 0 && n != 0);
734 if (error && (ioflag & IO_UNIT)) {
e16fa59e 735 (void) itrunc(ip, osize, ioflag & IO_SYNC);
b373e060
KM
736 uio->uio_offset -= resid - uio->uio_resid;
737 uio->uio_resid = resid;
738 }
739 return (error);
740}
741
7188ac27
KM
742/* ARGSUSED */
743ufs_ioctl(vp, com, data, fflag, cred)
744 struct vnode *vp;
745 int com;
746 caddr_t data;
747 int fflag;
748 struct ucred *cred;
bb1b75f4 749{
bb1b75f4 750
7188ac27
KM
751 return (ENOTTY);
752}
753
754/* ARGSUSED */
d1c43d7f 755ufs_select(vp, which, fflags, cred)
7188ac27 756 struct vnode *vp;
d1c43d7f 757 int which, fflags;
7188ac27
KM
758 struct ucred *cred;
759{
760
7188ac27 761 return (1); /* XXX */
bb1b75f4 762}
d67a03eb 763
4f083fd7 764/*
7188ac27
KM
765 * Mmap a file
766 *
767 * NB Currently unsupported.
4f083fd7 768 */
7188ac27
KM
769/* ARGSUSED */
770ufs_mmap(vp, fflags, cred)
771 struct vnode *vp;
772 int fflags;
773 struct ucred *cred;
d67a03eb 774{
d67a03eb 775
7188ac27 776 return (EINVAL);
d67a03eb 777}
64d3a787 778
4f083fd7 779/*
7188ac27 780 * Synch an open file.
4f083fd7 781 */
7188ac27 782/* ARGSUSED */
86cdabf6 783ufs_fsync(vp, fflags, cred, waitfor)
7188ac27
KM
784 struct vnode *vp;
785 int fflags;
786 struct ucred *cred;
86cdabf6 787 int waitfor;
528f664c 788{
86cdabf6 789 struct inode *ip = VTOI(vp);
7188ac27 790
7188ac27
KM
791 if (fflags&FWRITE)
792 ip->i_flag |= ICHG;
e16fa59e
KM
793 vflushbuf(vp, waitfor == MNT_WAIT ? B_SYNC : 0);
794 return (iupdat(ip, &time, &time, waitfor == MNT_WAIT));
528f664c
SL
795}
796
4f083fd7 797/*
7188ac27
KM
798 * Seek on a file
799 *
800 * Nothing to do, so just return.
4f083fd7 801 */
7188ac27
KM
802/* ARGSUSED */
803ufs_seek(vp, oldoff, newoff, cred)
804 struct vnode *vp;
805 off_t oldoff, newoff;
806 struct ucred *cred;
528f664c 807{
7188ac27
KM
808
809 return (0);
810}
811
812/*
813 * ufs remove
814 * Hard to avoid races here, especially
815 * in unlinking directories.
816 */
817ufs_remove(ndp)
818 struct nameidata *ndp;
819{
820 register struct inode *ip, *dp;
821 int error;
822
823 ip = VTOI(ndp->ni_vp);
824 dp = VTOI(ndp->ni_dvp);
825 error = dirremove(ndp);
826 if (!error) {
827 ip->i_nlink--;
828 ip->i_flag |= ICHG;
528f664c 829 }
7188ac27
KM
830 if (dp == ip)
831 vrele(ITOV(ip));
832 else
833 iput(ip);
834 iput(dp);
835 return (error);
4f083fd7
SL
836}
837
838/*
7188ac27 839 * link vnode call
4f083fd7 840 */
7188ac27
KM
841ufs_link(vp, ndp)
842 register struct vnode *vp;
843 register struct nameidata *ndp;
4f083fd7 844{
7188ac27
KM
845 register struct inode *ip = VTOI(vp);
846 int error;
4f083fd7 847
7188ac27
KM
848 if (ndp->ni_dvp != vp)
849 ILOCK(ip);
850 if (ip->i_nlink == LINK_MAX - 1) {
851 error = EMLINK;
852 goto out;
853 }
854 ip->i_nlink++;
855 ip->i_flag |= ICHG;
856 error = iupdat(ip, &time, &time, 1);
857 if (!error)
858 error = direnter(ip, ndp);
859out:
860 if (ndp->ni_dvp != vp)
861 IUNLOCK(ip);
862 if (error) {
863 ip->i_nlink--;
82252d2b 864 ip->i_flag |= ICHG;
7188ac27
KM
865 }
866 return (error);
528f664c
SL
867}
868
4f083fd7
SL
869/*
870 * Rename system call.
871 * rename("foo", "bar");
872 * is essentially
873 * unlink("bar");
874 * link("foo", "bar");
875 * unlink("foo");
876 * but ``atomically''. Can't do full commit without saving state in the
877 * inode on disk which isn't feasible at this time. Best we can do is
878 * always guarantee the target exists.
879 *
880 * Basic algorithm is:
881 *
882 * 1) Bump link count on source while we're linking it to the
7188ac27 883 * target. This also ensure the inode won't be deleted out
68f21562
KM
884 * from underneath us while we work (it may be truncated by
885 * a concurrent `trunc' or `open' for creation).
4f083fd7
SL
886 * 2) Link source to destination. If destination already exists,
887 * delete it first.
68f21562
KM
888 * 3) Unlink source reference to inode if still around. If a
889 * directory was moved and the parent of the destination
4f083fd7
SL
890 * is different from the source, patch the ".." entry in the
891 * directory.
4f083fd7 892 */
7188ac27
KM
893ufs_rename(fndp, tndp)
894 register struct nameidata *fndp, *tndp;
528f664c 895{
4f083fd7 896 register struct inode *ip, *xp, *dp;
68f21562
KM
897 struct dirtemplate dirbuf;
898 int doingdirectory = 0, oldparent = 0, newparent = 0;
a5390dce 899 int error = 0;
4f083fd7 900
7188ac27
KM
901 dp = VTOI(fndp->ni_dvp);
902 ip = VTOI(fndp->ni_vp);
903 ILOCK(ip);
4f083fd7 904 if ((ip->i_mode&IFMT) == IFDIR) {
7188ac27 905 register struct direct *d = &fndp->ni_dent;
4f083fd7 906
4f083fd7 907 /*
046f18d1 908 * Avoid ".", "..", and aliases of "." for obvious reasons.
4f083fd7 909 */
7188ac27
KM
910 if ((d->d_namlen == 1 && d->d_name[0] == '.') || dp == ip ||
911 fndp->ni_isdotdot || (ip->i_flag & IRENAME)) {
912 IUNLOCK(ip);
913 ufs_abortop(fndp);
914 ufs_abortop(tndp);
915 return (EINVAL);
4f083fd7 916 }
68f21562 917 ip->i_flag |= IRENAME;
4f083fd7
SL
918 oldparent = dp->i_number;
919 doingdirectory++;
920 }
7188ac27 921 vrele(fndp->ni_dvp);
4f083fd7
SL
922
923 /*
924 * 1) Bump link count while we're moving stuff
925 * around. If we crash somewhere before
926 * completing our work, the link count
927 * may be wrong, but correctable.
928 */
929 ip->i_nlink++;
930 ip->i_flag |= ICHG;
7188ac27 931 error = iupdat(ip, &time, &time, 1);
a388503d 932 IUNLOCK(ip);
4f083fd7
SL
933
934 /*
935 * When the target exists, both the directory
7188ac27 936 * and target vnodes are returned locked.
4f083fd7 937 */
7188ac27
KM
938 dp = VTOI(tndp->ni_dvp);
939 xp = NULL;
940 if (tndp->ni_vp)
941 xp = VTOI(tndp->ni_vp);
046f18d1
SL
942 /*
943 * If ".." must be changed (ie the directory gets a new
81552f0f
KM
944 * parent) then the source directory must not be in the
945 * directory heirarchy above the target, as this would
946 * orphan everything below the source directory. Also
947 * the user must have write permission in the source so
948 * as to be able to change "..". We must repeat the call
949 * to namei, as the parent directory is unlocked by the
950 * call to checkpath().
046f18d1 951 */
68f21562
KM
952 if (oldparent != dp->i_number)
953 newparent = dp->i_number;
954 if (doingdirectory && newparent) {
48c3b6e8
KM
955 VOP_LOCK(fndp->ni_vp);
956 error = ufs_access(fndp->ni_vp, VWRITE, tndp->ni_cred);
957 VOP_UNLOCK(fndp->ni_vp);
958 if (error)
81552f0f 959 goto bad;
7188ac27 960 tndp->ni_nameiop = RENAME | LOCKPARENT | LOCKLEAF | NOCACHE;
81552f0f 961 do {
7188ac27 962 dp = VTOI(tndp->ni_dvp);
81552f0f 963 if (xp != NULL)
79cf21e2 964 iput(xp);
7188ac27 965 if (error = checkpath(ip, dp, tndp->ni_cred))
81552f0f 966 goto out;
7188ac27 967 if (error = namei(tndp))
81552f0f 968 goto out;
7188ac27
KM
969 xp = NULL;
970 if (tndp->ni_vp)
971 xp = VTOI(tndp->ni_vp);
972 } while (dp != VTOI(tndp->ni_dvp));
81552f0f 973 }
4f083fd7
SL
974 /*
975 * 2) If target doesn't exist, link the target
976 * to the source and unlink the source.
977 * Otherwise, rewrite the target directory
978 * entry to reference the source inode and
979 * expunge the original entry's existence.
980 */
4f083fd7 981 if (xp == NULL) {
7188ac27
KM
982 if (dp->i_dev != ip->i_dev)
983 panic("rename: EXDEV");
4f083fd7 984 /*
68f21562
KM
985 * Account for ".." in new directory.
986 * When source and destination have the same
987 * parent we don't fool with the link count.
4f083fd7 988 */
68f21562 989 if (doingdirectory && newparent) {
4f083fd7
SL
990 dp->i_nlink++;
991 dp->i_flag |= ICHG;
7188ac27 992 error = iupdat(dp, &time, &time, 1);
4f083fd7 993 }
7188ac27 994 if (error = direnter(ip, tndp))
4f083fd7
SL
995 goto out;
996 } else {
7188ac27
KM
997 if (xp->i_dev != dp->i_dev || xp->i_dev != ip->i_dev)
998 panic("rename: EXDEV");
e69c3c9c
SL
999 /*
1000 * Short circuit rename(foo, foo).
1001 */
1002 if (xp->i_number == ip->i_number)
7188ac27 1003 panic("rename: same file");
80cee150
JB
1004 /*
1005 * If the parent directory is "sticky", then the user must
1006 * own the parent directory, or the destination of the rename,
1007 * otherwise the destination may not be changed (except by
1008 * root). This implements append-only directories.
1009 */
7188ac27
KM
1010 if ((dp->i_mode & ISVTX) && tndp->ni_cred->cr_uid != 0 &&
1011 tndp->ni_cred->cr_uid != dp->i_uid &&
1012 xp->i_uid != tndp->ni_cred->cr_uid) {
80cee150
JB
1013 error = EPERM;
1014 goto bad;
1015 }
4f083fd7 1016 /*
a5390dce
SL
1017 * Target must be empty if a directory
1018 * and have no links to it.
4f083fd7
SL
1019 * Also, insure source and target are
1020 * compatible (both directories, or both
1021 * not directories).
1022 */
1023 if ((xp->i_mode&IFMT) == IFDIR) {
7188ac27
KM
1024 if (!dirempty(xp, dp->i_number, tndp->ni_cred) ||
1025 xp->i_nlink > 2) {
a5390dce 1026 error = ENOTEMPTY;
4f083fd7
SL
1027 goto bad;
1028 }
1029 if (!doingdirectory) {
a5390dce 1030 error = ENOTDIR;
4f083fd7
SL
1031 goto bad;
1032 }
7188ac27 1033 cache_purge(ITOV(dp));
4f083fd7 1034 } else if (doingdirectory) {
a5390dce 1035 error = EISDIR;
4f083fd7
SL
1036 goto bad;
1037 }
7188ac27
KM
1038 if (error = dirrewrite(dp, ip, tndp))
1039 goto bad;
1040 vput(ITOV(dp));
4f083fd7 1041 /*
a5390dce
SL
1042 * Adjust the link count of the target to
1043 * reflect the dirrewrite above. If this is
1044 * a directory it is empty and there are
1045 * no links to it, so we can squash the inode and
1046 * any space associated with it. We disallowed
1047 * renaming over top of a directory with links to
68f21562
KM
1048 * it above, as the remaining link would point to
1049 * a directory without "." or ".." entries.
4f083fd7 1050 */
a5390dce 1051 xp->i_nlink--;
4f083fd7 1052 if (doingdirectory) {
a5390dce
SL
1053 if (--xp->i_nlink != 0)
1054 panic("rename: linked directory");
e16fa59e 1055 error = itrunc(xp, (u_long)0, IO_SYNC);
a5390dce 1056 }
4f083fd7 1057 xp->i_flag |= ICHG;
88d931ba 1058 iput(xp);
31db12cb 1059 xp = NULL;
4f083fd7
SL
1060 }
1061
1062 /*
1063 * 3) Unlink the source.
1064 */
7188ac27
KM
1065 fndp->ni_nameiop = DELETE | LOCKPARENT | LOCKLEAF;
1066 (void)namei(fndp);
1067 if (fndp->ni_vp != NULL) {
1068 xp = VTOI(fndp->ni_vp);
1069 dp = VTOI(fndp->ni_dvp);
1070 } else {
79cf21e2
KM
1071 if (fndp->ni_dvp != NULL)
1072 vput(fndp->ni_dvp);
7188ac27 1073 xp = NULL;
4f1a9037 1074 dp = NULL;
7188ac27 1075 }
4f083fd7 1076 /*
7188ac27 1077 * Ensure that the directory entry still exists and has not
68f21562
KM
1078 * changed while the new name has been entered. If the source is
1079 * a file then the entry may have been unlinked or renamed. In
1080 * either case there is no further work to be done. If the source
1081 * is a directory then it cannot have been rmdir'ed; its link
1082 * count of three would cause a rmdir to fail with ENOTEMPTY.
7188ac27 1083 * The IRENAME flag ensures that it cannot be moved by another
68f21562 1084 * rename.
4f083fd7 1085 */
4f1a9037 1086 if (xp != ip) {
68f21562 1087 if (doingdirectory)
4f1a9037 1088 panic("rename: lost dir entry");
68f21562 1089 } else {
4f083fd7 1090 /*
68f21562
KM
1091 * If the source is a directory with a
1092 * new parent, the link count of the old
1093 * parent directory must be decremented
1094 * and ".." set to point to the new parent.
4f083fd7 1095 */
68f21562 1096 if (doingdirectory && newparent) {
4f083fd7
SL
1097 dp->i_nlink--;
1098 dp->i_flag |= ICHG;
86cdabf6 1099 error = vn_rdwr(UIO_READ, ITOV(xp), (caddr_t)&dirbuf,
7188ac27 1100 sizeof (struct dirtemplate), (off_t)0,
86cdabf6
KM
1101 UIO_SYSSPACE, IO_NODELOCKED,
1102 tndp->ni_cred, (int *)0);
68f21562
KM
1103 if (error == 0) {
1104 if (dirbuf.dotdot_namlen != 2 ||
1105 dirbuf.dotdot_name[0] != '.' ||
1106 dirbuf.dotdot_name[1] != '.') {
8ad54d9e 1107 dirbad(xp, 12, "rename: mangled dir");
68f21562
KM
1108 } else {
1109 dirbuf.dotdot_ino = newparent;
86cdabf6 1110 (void) vn_rdwr(UIO_WRITE, ITOV(xp),
68f21562
KM
1111 (caddr_t)&dirbuf,
1112 sizeof (struct dirtemplate),
93e273b9 1113 (off_t)0, UIO_SYSSPACE,
86cdabf6 1114 IO_NODELOCKED|IO_SYNC,
7188ac27
KM
1115 tndp->ni_cred, (int *)0);
1116 cache_purge(ITOV(dp));
68f21562
KM
1117 }
1118 }
4f083fd7 1119 }
7188ac27
KM
1120 error = dirremove(fndp);
1121 if (!error) {
68f21562
KM
1122 xp->i_nlink--;
1123 xp->i_flag |= ICHG;
4f083fd7 1124 }
68f21562 1125 xp->i_flag &= ~IRENAME;
4f083fd7 1126 }
4f083fd7 1127 if (dp)
7188ac27 1128 vput(ITOV(dp));
68f21562 1129 if (xp)
7188ac27
KM
1130 vput(ITOV(xp));
1131 vrele(ITOV(ip));
1132 return (error);
a5390dce 1133
4f083fd7 1134bad:
4f083fd7 1135 if (xp)
7188ac27
KM
1136 vput(ITOV(xp));
1137 vput(ITOV(dp));
4f083fd7
SL
1138out:
1139 ip->i_nlink--;
1140 ip->i_flag |= ICHG;
7188ac27
KM
1141 vrele(ITOV(ip));
1142 return (error);
64d3a787 1143}
88a7a62a
SL
1144
1145/*
1146 * A virgin directory (no blushing please).
1147 */
1148struct dirtemplate mastertemplate = {
1149 0, 12, 1, ".",
1150 0, DIRBLKSIZ - 12, 2, ".."
1151};
1152
1153/*
1154 * Mkdir system call
1155 */
7188ac27
KM
1156ufs_mkdir(ndp, vap)
1157 struct nameidata *ndp;
1158 struct vattr *vap;
88a7a62a 1159{
88a7a62a 1160 register struct inode *ip, *dp;
7188ac27
KM
1161 struct inode *tip;
1162 struct vnode *dvp;
88a7a62a 1163 struct dirtemplate dirtemplate;
7188ac27
KM
1164 int error;
1165 int dmode;
1166
1167 dvp = ndp->ni_dvp;
1168 dp = VTOI(dvp);
1169 dmode = vap->va_mode&0777;
1170 dmode |= IFDIR;
88a7a62a
SL
1171 /*
1172 * Must simulate part of maknode here
1173 * in order to acquire the inode, but
1174 * not have it entered in the parent
1175 * directory. The entry is made later
1176 * after writing "." and ".." entries out.
1177 */
4b61628b 1178 if (error = ialloc(dp, dirpref(dp->i_fs), dmode, ndp->ni_cred, &tip)) {
88a7a62a 1179 iput(dp);
7188ac27 1180 return (error);
88a7a62a 1181 }
7188ac27 1182 ip = tip;
4b61628b
KM
1183 ip->i_uid = ndp->ni_cred->cr_uid;
1184 ip->i_gid = dp->i_gid;
88a7a62a 1185#ifdef QUOTA
4b61628b
KM
1186 if ((error = getinoquota(ip)) ||
1187 (error = chkiq(ip, 1, ndp->ni_cred, 0))) {
1188 ifree(ip, ip->i_number, dmode);
1189 iput(ip);
1190 iput(dp);
1191 return (error);
1192 }
88a7a62a
SL
1193#endif
1194 ip->i_flag |= IACC|IUPD|ICHG;
7188ac27
KM
1195 ip->i_mode = dmode;
1196 ITOV(ip)->v_type = VDIR; /* Rest init'd in iget() */
88a7a62a 1197 ip->i_nlink = 2;
7188ac27 1198 error = iupdat(ip, &time, &time, 1);
88a7a62a
SL
1199
1200 /*
1201 * Bump link count in parent directory
1202 * to reflect work done below. Should
1203 * be done before reference is created
1204 * so reparation is possible if we crash.
1205 */
1206 dp->i_nlink++;
1207 dp->i_flag |= ICHG;
7188ac27 1208 error = iupdat(dp, &time, &time, 1);
88a7a62a
SL
1209
1210 /*
1211 * Initialize directory with "."
1212 * and ".." from static template.
1213 */
1214 dirtemplate = mastertemplate;
1215 dirtemplate.dot_ino = ip->i_number;
1216 dirtemplate.dotdot_ino = dp->i_number;
86cdabf6 1217 error = vn_rdwr(UIO_WRITE, ITOV(ip), (caddr_t)&dirtemplate,
7188ac27 1218 sizeof (dirtemplate), (off_t)0, UIO_SYSSPACE,
86cdabf6 1219 IO_NODELOCKED|IO_SYNC, ndp->ni_cred, (int *)0);
7188ac27 1220 if (error) {
88a7a62a
SL
1221 dp->i_nlink--;
1222 dp->i_flag |= ICHG;
1223 goto bad;
1224 }
7188ac27
KM
1225 if (DIRBLKSIZ > dp->i_fs->fs_fsize)
1226 panic("mkdir: blksize"); /* XXX - should grow w/balloc() */
23de9f20
KM
1227 else
1228 ip->i_size = DIRBLKSIZ;
88a7a62a
SL
1229 /*
1230 * Directory all set up, now
1231 * install the entry for it in
1232 * the parent directory.
1233 */
7188ac27 1234 error = direnter(ip, ndp);
88a7a62a 1235 dp = NULL;
7188ac27 1236 if (error) {
715baff1 1237 ndp->ni_nameiop = LOOKUP | NOCACHE;
7188ac27
KM
1238 error = namei(ndp);
1239 if (!error) {
1240 dp = VTOI(ndp->ni_vp);
88a7a62a
SL
1241 dp->i_nlink--;
1242 dp->i_flag |= ICHG;
1243 }
1244 }
1245bad:
1246 /*
1247 * No need to do an explicit itrunc here,
7188ac27 1248 * vrele will do this for us because we set
88a7a62a
SL
1249 * the link count to 0.
1250 */
7188ac27 1251 if (error) {
88a7a62a
SL
1252 ip->i_nlink = 0;
1253 ip->i_flag |= ICHG;
cbcdacd6
KM
1254 iput(ip);
1255 } else
1256 ndp->ni_vp = ITOV(ip);
88a7a62a
SL
1257 if (dp)
1258 iput(dp);
7188ac27 1259 return (error);
88a7a62a
SL
1260}
1261
1262/*
1263 * Rmdir system call.
1264 */
7188ac27
KM
1265ufs_rmdir(ndp)
1266 register struct nameidata *ndp;
88a7a62a 1267{
88a7a62a 1268 register struct inode *ip, *dp;
7188ac27
KM
1269 int error = 0;
1270
1271 ip = VTOI(ndp->ni_vp);
1272 dp = VTOI(ndp->ni_dvp);
88a7a62a
SL
1273 /*
1274 * No rmdir "." please.
1275 */
1276 if (dp == ip) {
7188ac27 1277 vrele(ITOV(dp));
88a7a62a 1278 iput(ip);
7188ac27 1279 return (EINVAL);
88a7a62a
SL
1280 }
1281 /*
1282 * Verify the directory is empty (and valid).
1283 * (Rmdir ".." won't be valid since
1284 * ".." will contain a reference to
1285 * the current directory and thus be
1286 * non-empty.)
1287 */
7188ac27
KM
1288 if (ip->i_nlink != 2 || !dirempty(ip, dp->i_number, ndp->ni_cred)) {
1289 error = ENOTEMPTY;
88a7a62a
SL
1290 goto out;
1291 }
1292 /*
1293 * Delete reference to directory before purging
1294 * inode. If we crash in between, the directory
1295 * will be reattached to lost+found,
1296 */
7188ac27 1297 if (error = dirremove(ndp))
88a7a62a
SL
1298 goto out;
1299 dp->i_nlink--;
1300 dp->i_flag |= ICHG;
7188ac27 1301 cache_purge(ITOV(dp));
88a7a62a 1302 iput(dp);
7188ac27 1303 ndp->ni_dvp = NULL;
88a7a62a
SL
1304 /*
1305 * Truncate inode. The only stuff left
1306 * in the directory is "." and "..". The
1307 * "." reference is inconsequential since
1308 * we're quashing it. The ".." reference
1309 * has already been adjusted above. We've
1310 * removed the "." reference and the reference
1311 * in the parent directory, but there may be
1312 * other hard links so decrement by 2 and
1313 * worry about them later.
1314 */
1315 ip->i_nlink -= 2;
e16fa59e 1316 error = itrunc(ip, (u_long)0, IO_SYNC);
7188ac27 1317 cache_purge(ITOV(ip));
88a7a62a 1318out:
7188ac27 1319 if (ndp->ni_dvp)
88a7a62a
SL
1320 iput(dp);
1321 iput(ip);
7188ac27 1322 return (error);
88a7a62a
SL
1323}
1324
7188ac27
KM
1325/*
1326 * symlink -- make a symbolic link
1327 */
1328ufs_symlink(ndp, vap, target)
1329 struct nameidata *ndp;
1330 struct vattr *vap;
1331 char *target;
1332{
1333 struct inode *ip;
1334 int error;
1335
1336 error = maknode(IFLNK | vap->va_mode, ndp, &ip);
1337 if (error)
1338 return (error);
86cdabf6
KM
1339 error = vn_rdwr(UIO_WRITE, ITOV(ip), target, strlen(target), (off_t)0,
1340 UIO_SYSSPACE, IO_NODELOCKED, ndp->ni_cred, (int *)0);
7188ac27
KM
1341 iput(ip);
1342 return (error);
1343}
1344
1345/*
1346 * Vnode op for read and write
1347 */
930730fd 1348ufs_readdir(vp, uio, cred, eofflagp)
7188ac27
KM
1349 struct vnode *vp;
1350 register struct uio *uio;
7188ac27 1351 struct ucred *cred;
930730fd 1352 int *eofflagp;
88a7a62a 1353{
86cdabf6 1354 int count, lost, error;
88a7a62a 1355
7188ac27
KM
1356 count = uio->uio_resid;
1357 count &= ~(DIRBLKSIZ - 1);
86cdabf6
KM
1358 lost = uio->uio_resid - count;
1359 if (count < DIRBLKSIZ || (uio->uio_offset & (DIRBLKSIZ -1)))
7188ac27 1360 return (EINVAL);
7188ac27
KM
1361 uio->uio_resid = count;
1362 uio->uio_iov->iov_len = count;
86cdabf6
KM
1363 error = ufs_read(vp, uio, 0, cred);
1364 uio->uio_resid += lost;
930730fd
KM
1365 if ((VTOI(vp)->i_size - uio->uio_offset) <= 0)
1366 *eofflagp = 1;
1367 else
1368 *eofflagp = 0;
7188ac27
KM
1369 return (error);
1370}
1371
1372/*
1373 * Return target name of a symbolic link
1374 */
1375ufs_readlink(vp, uiop, cred)
1376 struct vnode *vp;
1377 struct uio *uiop;
1378 struct ucred *cred;
1379{
1380
86cdabf6 1381 return (ufs_read(vp, uiop, 0, cred));
7188ac27
KM
1382}
1383
1384/*
1385 * Ufs abort op, called after namei() when a CREATE/DELETE isn't actually
1386 * done. Iff ni_vp/ni_dvp not null and locked, unlock.
1387 */
1388ufs_abortop(ndp)
1389 register struct nameidata *ndp;
1390{
7188ac27 1391
7188ac27 1392 if (ndp->ni_dvp) {
7359b026
KM
1393 if (VOP_ISLOCKED(ndp->ni_dvp))
1394 VOP_UNLOCK(ndp->ni_dvp);
7188ac27 1395 vrele(ndp->ni_dvp);
88a7a62a 1396 }
7359b026
KM
1397 if (ndp->ni_vp) {
1398 if (VOP_ISLOCKED(ndp->ni_vp))
1399 VOP_UNLOCK(ndp->ni_vp);
1400 vrele(ndp->ni_vp);
1401 }
7188ac27
KM
1402 return;
1403}
1404
1c3ebc10
KM
1405/*
1406 * Lock an inode.
1407 */
7188ac27
KM
1408ufs_lock(vp)
1409 struct vnode *vp;
1410{
1411 register struct inode *ip = VTOI(vp);
1412
1413 ILOCK(ip);
1414 return (0);
1415}
1416
1c3ebc10
KM
1417/*
1418 * Unlock an inode.
1419 */
7188ac27
KM
1420ufs_unlock(vp)
1421 struct vnode *vp;
1422{
1423 register struct inode *ip = VTOI(vp);
1424
1425 if (!(ip->i_flag & ILOCKED))
1426 panic("ufs_unlock NOT LOCKED");
1427 IUNLOCK(ip);
1428 return (0);
1429}
1430
1c3ebc10
KM
1431/*
1432 * Check for a locked inode.
1433 */
1434ufs_islocked(vp)
1435 struct vnode *vp;
1436{
1437
1438 if (VTOI(vp)->i_flag & ILOCKED)
1439 return (1);
1440 return (0);
1441}
1442
7188ac27
KM
1443/*
1444 * Get access to bmap
1445 */
1446ufs_bmap(vp, bn, vpp, bnp)
1447 struct vnode *vp;
1448 daddr_t bn;
1449 struct vnode **vpp;
1450 daddr_t *bnp;
1451{
1452 struct inode *ip = VTOI(vp);
1453
1454 if (vpp != NULL)
1455 *vpp = ip->i_devvp;
1456 if (bnp == NULL)
1457 return (0);
1458 return (bmap(ip, bn, bnp, (daddr_t *)0, (int *)0));
88a7a62a
SL
1459}
1460
1461/*
7188ac27 1462 * Just call the device strategy routine
88a7a62a 1463 */
e16fa59e
KM
1464int checkoverlap = 1;
1465
7188ac27
KM
1466ufs_strategy(bp)
1467 register struct buf *bp;
88a7a62a 1468{
e16fa59e
KM
1469 register struct inode *ip = VTOI(bp->b_vp);
1470 register struct buf *ep;
1471 struct vnode *vp;
1472 struct buf *ebp;
1473 daddr_t start, last;
1474 int error;
1475
1476 if (bp->b_vp->v_type == VBLK || bp->b_vp->v_type == VCHR)
1477 panic("ufs_strategy: spec");
1478 if (bp->b_blkno == bp->b_lblkno) {
1479 if (error = bmap(ip, bp->b_lblkno, &bp->b_blkno))
1480 return (error);
20aa076b 1481 if ((long)bp->b_blkno == -1)
e16fa59e 1482 clrbuf(bp);
e16fa59e 1483 }
20aa076b
KM
1484 if ((long)bp->b_blkno == -1) {
1485 biodone(bp);
e16fa59e 1486 return (0);
20aa076b 1487 }
e16fa59e
KM
1488 if (checkoverlap) {
1489 ebp = &buf[nbuf];
1490 start = bp->b_blkno;
1491 last = start + btodb(bp->b_bcount) - 1;
1492 for (ep = buf; ep < ebp; ep++) {
1493 if (ep == bp || (ep->b_flags & B_INVAL) ||
fcd4f15a 1494 ep->b_vp == NULLVP)
e16fa59e
KM
1495 continue;
1496 if (VOP_BMAP(ep->b_vp, (daddr_t)0, &vp, (daddr_t)0))
1497 continue;
1498 if (vp != ip->i_devvp)
1499 continue;
1500 /* look for overlap */
1501 if (ep->b_bcount == 0 || ep->b_blkno > last ||
1502 ep->b_blkno + btodb(ep->b_bcount) <= start)
1503 continue;
20aa076b
KM
1504 vprint("Disk overlap", vp);
1505 printf("\tstart %d, end %d overlap start %d, end %d\n",
1506 start, last, ep->b_blkno,
1507 ep->b_blkno + btodb(ep->b_bcount) - 1);
e16fa59e
KM
1508 }
1509 }
1510 vp = ip->i_devvp;
1511 bp->b_dev = vp->v_rdev;
1512 (*(vp->v_op->vn_strategy))(bp);
7188ac27
KM
1513 return (0);
1514}
88a7a62a 1515
e16fa59e
KM
1516/*
1517 * Print out the contents of an inode.
1518 */
1519ufs_print(vp)
1520 struct vnode *vp;
1521{
1522 register struct inode *ip = VTOI(vp);
1523
a8f829ed
KM
1524 printf("tag VT_UFS, ino %d, on dev %d, %d", ip->i_number,
1525 major(ip->i_dev), minor(ip->i_dev));
1526#ifdef FIFO
1527 if (vp->v_type == VFIFO)
1528 fifo_printinfo(vp);
1529#endif /* FIFO */
1530 printf("%s\n", (ip->i_flag & ILOCKED) ? " (LOCKED)" : "");
96bae3e0
KM
1531 if (ip->i_spare0 == 0)
1532 return;
1533 printf("\towner pid %d", ip->i_spare0);
1534 if (ip->i_spare1)
1535 printf(" waiting pid %d", ip->i_spare1);
1536 printf("\n");
e16fa59e
KM
1537}
1538
24a31b70
KM
1539/*
1540 * Read wrapper for special devices.
1541 */
1542ufsspec_read(vp, uio, ioflag, cred)
1543 struct vnode *vp;
1544 struct uio *uio;
1545 int ioflag;
1546 struct ucred *cred;
1547{
1548
1549 /*
1550 * Set access flag.
1551 */
1552 VTOI(vp)->i_flag |= IACC;
1553 return (spec_read(vp, uio, ioflag, cred));
1554}
1555
1556/*
1557 * Write wrapper for special devices.
1558 */
1559ufsspec_write(vp, uio, ioflag, cred)
1560 struct vnode *vp;
1561 struct uio *uio;
1562 int ioflag;
1563 struct ucred *cred;
1564{
1565
1566 /*
1567 * Set update and change flags.
1568 */
1569 VTOI(vp)->i_flag |= IUPD|ICHG;
1570 return (spec_write(vp, uio, ioflag, cred));
1571}
1572
1573/*
1574 * Close wrapper for special devices.
1575 *
1576 * Update the times on the inode then do device close.
1577 */
1578ufsspec_close(vp, fflag, cred)
1579 struct vnode *vp;
1580 int fflag;
1581 struct ucred *cred;
1582{
1583 register struct inode *ip = VTOI(vp);
1584
de67eefc 1585 if (vp->v_usecount > 1 && !(ip->i_flag & ILOCKED))
24a31b70
KM
1586 ITIMES(ip, &time, &time);
1587 return (spec_close(vp, fflag, cred));
1588}
1589
d1c43d7f
KM
1590#ifdef FIFO
1591/*
1592 * Read wrapper for fifo's
1593 */
1594ufsfifo_read(vp, uio, ioflag, cred)
1595 struct vnode *vp;
1596 struct uio *uio;
1597 int ioflag;
1598 struct ucred *cred;
1599{
1600
1601 /*
1602 * Set access flag.
1603 */
1604 VTOI(vp)->i_flag |= IACC;
1605 return (fifo_read(vp, uio, ioflag, cred));
1606}
1607
1608/*
1609 * Write wrapper for fifo's.
1610 */
1611ufsfifo_write(vp, uio, ioflag, cred)
1612 struct vnode *vp;
1613 struct uio *uio;
1614 int ioflag;
1615 struct ucred *cred;
1616{
1617
1618 /*
1619 * Set update and change flags.
1620 */
1621 VTOI(vp)->i_flag |= IUPD|ICHG;
1622 return (fifo_write(vp, uio, ioflag, cred));
1623}
1624
1625/*
1626 * Close wrapper for fifo's.
1627 *
1628 * Update the times on the inode then do device close.
1629 */
1630ufsfifo_close(vp, fflag, cred)
1631 struct vnode *vp;
1632 int fflag;
1633 struct ucred *cred;
1634{
1635 register struct inode *ip = VTOI(vp);
1636
1637 if (vp->v_usecount > 1 && !(ip->i_flag & ILOCKED))
1638 ITIMES(ip, &time, &time);
1639 return (fifo_close(vp, fflag, cred));
1640}
1641#endif /* FIFO */
1642
7188ac27
KM
1643/*
1644 * Make a new file.
1645 */
1646maknode(mode, ndp, ipp)
1647 int mode;
1648 register struct nameidata *ndp;
1649 struct inode **ipp;
1650{
1651 register struct inode *ip;
1652 struct inode *tip;
1653 register struct inode *pdir = VTOI(ndp->ni_dvp);
1654 ino_t ipref;
1655 int error;
1656
1657 *ipp = 0;
4b61628b
KM
1658 if ((mode & IFMT) == 0)
1659 mode |= IFREG;
7188ac27
KM
1660 if ((mode & IFMT) == IFDIR)
1661 ipref = dirpref(pdir->i_fs);
1662 else
1663 ipref = pdir->i_number;
4b61628b 1664 if (error = ialloc(pdir, ipref, mode, ndp->ni_cred, &tip)) {
7188ac27
KM
1665 iput(pdir);
1666 return (error);
1667 }
1668 ip = tip;
4b61628b
KM
1669 ip->i_uid = ndp->ni_cred->cr_uid;
1670 ip->i_gid = pdir->i_gid;
7188ac27 1671#ifdef QUOTA
4b61628b
KM
1672 if ((error = getinoquota(ip)) ||
1673 (error = chkiq(ip, 1, ndp->ni_cred, 0))) {
1674 ifree(ip, ip->i_number, mode);
1675 iput(ip);
1676 iput(pdir);
1677 return (error);
1678 }
7188ac27
KM
1679#endif
1680 ip->i_flag |= IACC|IUPD|ICHG;
7188ac27
KM
1681 ip->i_mode = mode;
1682 ITOV(ip)->v_type = IFTOVT(mode); /* Rest init'd in iget() */
1683 ip->i_nlink = 1;
7188ac27
KM
1684 if ((ip->i_mode & ISGID) && !groupmember(ip->i_gid, ndp->ni_cred) &&
1685 suser(ndp->ni_cred, NULL))
1686 ip->i_mode &= ~ISGID;
7188ac27
KM
1687
1688 /*
1689 * Make sure inode goes to disk before directory entry.
1690 */
4b61628b
KM
1691 if (error = iupdat(ip, &time, &time, 1))
1692 goto bad;
1693 if (error = direnter(ip, ndp)) {
1694 pdir = NULL;
1695 goto bad;
7188ac27
KM
1696 }
1697 *ipp = ip;
1698 return (0);
4b61628b
KM
1699
1700bad:
1701 /*
1702 * Write error occurred trying to update the inode
1703 * or the directory so must deallocate the inode.
1704 */
1705 if (pdir)
1706 iput(pdir);
1707 ip->i_nlink = 0;
1708 ip->i_flag |= ICHG;
1709 iput(ip);
1710 return (error);
88a7a62a 1711}