1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License, Version 1.0 only 6 * (the "License"). You may not use this file except in compliance 7 * with the License. 8 * 9 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 10 * or http://www.opensolaris.org/os/licensing. 11 * See the License for the specific language governing permissions 12 * and limitations under the License. 13 * 14 * When distributing Covered Code, include this CDDL HEADER in each 15 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 16 * If applicable, add the following below this CDDL HEADER, with the 17 * fields enclosed by brackets "[]" replaced with your own identifying 18 * information: Portions Copyright [yyyy] [name of copyright owner] 19 * 20 * CDDL HEADER END 21 */ 22 /* 23 * Copyright 2006 Sun Microsystems, Inc. All rights reserved. 24 * Use is subject to license terms. 25 */ 26 27 /* Copyright (c) 1983, 1984, 1985, 1986, 1987, 1988, 1989 AT&T */ 28 /* All Rights Reserved */ 29 30 /* 31 * University Copyright- Copyright (c) 1982, 1986, 1988 32 * The Regents of the University of California 33 * All Rights Reserved 34 * 35 * University Acknowledgment- Portions of this document are derived from 36 * software developed by the University of California, Berkeley, and its 37 * contributors. 38 */ 39 40 41 #pragma ident "%Z%%M% %I% %E% SMI" 42 43 #include <sys/types.h> 44 #include <sys/thread.h> 45 #include <sys/t_lock.h> 46 #include <sys/param.h> 47 #include <sys/systm.h> 48 #include <sys/bitmap.h> 49 #include <sys/buf.h> 50 #include <sys/cmn_err.h> 51 #include <sys/conf.h> 52 #include <sys/ddi.h> 53 #include <sys/debug.h> 54 #include <sys/errno.h> 55 #include <sys/time.h> 56 #include <sys/fcntl.h> 57 #include <sys/flock.h> 58 #include <sys/file.h> 59 #include <sys/kmem.h> 60 #include <sys/mman.h> 61 #include <sys/open.h> 62 #include <sys/swap.h> 63 #include <sys/sysmacros.h> 64 #include <sys/uio.h> 65 #include <sys/vfs.h> 66 #include <sys/vnode.h> 67 #include <sys/stat.h> 68 #include <sys/poll.h> 69 #include <sys/stream.h> 70 #include <sys/strsubr.h> 71 #include <sys/policy.h> 72 #include <sys/devpolicy.h> 73 74 #include <sys/proc.h> 75 #include <sys/user.h> 76 #include <sys/session.h> 77 #include <sys/vmsystm.h> 78 #include <sys/vtrace.h> 79 #include <sys/pathname.h> 80 81 #include <sys/fs/snode.h> 82 83 #include <vm/seg.h> 84 #include <vm/seg_map.h> 85 #include <vm/page.h> 86 #include <vm/pvn.h> 87 #include <vm/seg_dev.h> 88 #include <vm/seg_vn.h> 89 90 #include <fs/fs_subr.h> 91 92 #include <sys/esunddi.h> 93 #include <sys/autoconf.h> 94 #include <sys/sunndi.h> 95 96 97 static int spec_open(struct vnode **, int, struct cred *); 98 static int spec_close(struct vnode *, int, int, offset_t, struct cred *); 99 static int spec_read(struct vnode *, struct uio *, int, struct cred *, 100 struct caller_context *); 101 static int spec_write(struct vnode *, struct uio *, int, struct cred *, 102 struct caller_context *); 103 static int spec_ioctl(struct vnode *, int, intptr_t, int, struct cred *, int *); 104 static int spec_getattr(struct vnode *, struct vattr *, int, struct cred *); 105 static int spec_setattr(struct vnode *, struct vattr *, int, struct cred *, 106 caller_context_t *); 107 static int spec_access(struct vnode *, int, int, struct cred *); 108 static int spec_create(struct vnode *, char *, vattr_t *, enum vcexcl, 109 int, struct vnode **, struct cred *, int); 110 static int spec_fsync(struct vnode *, int, struct cred *); 111 static void spec_inactive(struct vnode *, struct cred *); 112 static int spec_fid(struct vnode *, struct fid *); 113 static int spec_seek(struct vnode *, offset_t, offset_t *); 114 static int spec_frlock(struct vnode *, int, struct flock64 *, int, offset_t, 115 struct flk_callback *, struct cred *); 116 static int spec_realvp(struct vnode *, struct vnode **); 117 118 static int spec_getpage(struct vnode *, offset_t, size_t, uint_t *, page_t **, 119 size_t, struct seg *, caddr_t, enum seg_rw, struct cred *); 120 static int spec_putapage(struct vnode *, page_t *, u_offset_t *, size_t *, int, 121 struct cred *); 122 static struct buf *spec_startio(struct vnode *, page_t *, u_offset_t, size_t, 123 int); 124 static int spec_getapage(struct vnode *, u_offset_t, size_t, uint_t *, 125 page_t **, size_t, struct seg *, caddr_t, enum seg_rw, struct cred *); 126 static int spec_map(struct vnode *, offset_t, struct as *, caddr_t *, size_t, 127 uchar_t, uchar_t, uint_t, struct cred *); 128 static int spec_addmap(struct vnode *, offset_t, struct as *, caddr_t, size_t, 129 uchar_t, uchar_t, uint_t, struct cred *); 130 static int spec_delmap(struct vnode *, offset_t, struct as *, caddr_t, size_t, 131 uint_t, uint_t, uint_t, struct cred *); 132 133 static int spec_poll(struct vnode *, short, int, short *, struct pollhead **); 134 static int spec_dump(struct vnode *, caddr_t, int, int); 135 static int spec_pageio(struct vnode *, page_t *, u_offset_t, size_t, int, 136 cred_t *); 137 138 static int spec_getsecattr(struct vnode *, vsecattr_t *, int, struct cred *); 139 static int spec_setsecattr(struct vnode *, vsecattr_t *, int, struct cred *); 140 static int spec_pathconf(struct vnode *, int, ulong_t *, struct cred *); 141 142 #define SN_HOLD(csp) { \ 143 mutex_enter(&csp->s_lock); \ 144 csp->s_count++; \ 145 mutex_exit(&csp->s_lock); \ 146 } 147 148 #define SN_RELE(csp) { \ 149 mutex_enter(&csp->s_lock); \ 150 csp->s_count--; \ 151 ASSERT((csp->s_count > 0) || (csp->s_vnode->v_stream == NULL)); \ 152 mutex_exit(&csp->s_lock); \ 153 } 154 155 struct vnodeops *spec_vnodeops; 156 157 const fs_operation_def_t spec_vnodeops_template[] = { 158 VOPNAME_OPEN, spec_open, 159 VOPNAME_CLOSE, spec_close, 160 VOPNAME_READ, spec_read, 161 VOPNAME_WRITE, spec_write, 162 VOPNAME_IOCTL, spec_ioctl, 163 VOPNAME_GETATTR, spec_getattr, 164 VOPNAME_SETATTR, spec_setattr, 165 VOPNAME_ACCESS, spec_access, 166 VOPNAME_CREATE, spec_create, 167 VOPNAME_FSYNC, spec_fsync, 168 VOPNAME_INACTIVE, (fs_generic_func_p) spec_inactive, 169 VOPNAME_FID, spec_fid, 170 VOPNAME_SEEK, spec_seek, 171 VOPNAME_PATHCONF, spec_pathconf, 172 VOPNAME_FRLOCK, spec_frlock, 173 VOPNAME_REALVP, spec_realvp, 174 VOPNAME_GETPAGE, spec_getpage, 175 VOPNAME_PUTPAGE, spec_putpage, 176 VOPNAME_MAP, (fs_generic_func_p) spec_map, 177 VOPNAME_ADDMAP, (fs_generic_func_p) spec_addmap, 178 VOPNAME_DELMAP, spec_delmap, 179 VOPNAME_POLL, (fs_generic_func_p) spec_poll, 180 VOPNAME_DUMP, spec_dump, 181 VOPNAME_PAGEIO, spec_pageio, 182 VOPNAME_SETSECATTR, spec_setsecattr, 183 VOPNAME_GETSECATTR, spec_getsecattr, 184 NULL, NULL 185 }; 186 187 /* 188 * Return address of spec_vnodeops 189 */ 190 struct vnodeops * 191 spec_getvnodeops(void) 192 { 193 return (spec_vnodeops); 194 } 195 196 extern vnode_t *rconsvp; 197 198 /* 199 * Acquire the serial lock on the common snode. 200 */ 201 #define LOCK_CSP(csp) \ 202 mutex_enter(&csp->s_lock); \ 203 while (csp->s_flag & SLOCKED) { \ 204 csp->s_flag |= SWANT; \ 205 cv_wait(&csp->s_cv, &csp->s_lock); \ 206 } \ 207 csp->s_flag |= SLOCKED; \ 208 mutex_exit(&csp->s_lock); 209 210 #define LOCK_CSP_SIG(csp) lock_csp_sig(csp) 211 212 /* 213 * Acquire the serial lock on the common snode checking for a signal. 214 * cv_wait_sig is used to allow signals to pull us out. 215 * Return 1 if locked, 0 if interrupted 216 */ 217 static int 218 lock_csp_sig(struct snode *csp) 219 { 220 mutex_enter(&csp->s_lock); 221 while (csp->s_flag & SLOCKED) { 222 csp->s_flag |= SWANT; 223 if (!cv_wait_sig(&csp->s_cv, &csp->s_lock)) { 224 mutex_exit(&csp->s_lock); 225 /* interrupted */ 226 return (0); 227 } 228 } 229 csp->s_flag |= SLOCKED; 230 mutex_exit(&csp->s_lock); 231 232 return (1); 233 } 234 235 /* 236 * Unlock the serial lock on the common snode 237 */ 238 #define UNLOCK_CSP_LOCK_HELD(csp) \ 239 ASSERT(mutex_owned(&csp->s_lock)); \ 240 if (csp->s_flag & SWANT) \ 241 cv_broadcast(&csp->s_cv); \ 242 csp->s_flag &= ~(SWANT|SLOCKED); 243 244 #define UNLOCK_CSP(csp) \ 245 mutex_enter(&csp->s_lock); \ 246 UNLOCK_CSP_LOCK_HELD(csp); \ 247 mutex_exit(&csp->s_lock); 248 249 /* 250 * compute/return the size of the device 251 */ 252 #define SPEC_SIZE(csp) \ 253 (((csp)->s_flag & SSIZEVALID) ? (csp)->s_size : spec_size(csp)) 254 255 /* 256 * Compute and return the size. If the size in the common snode is valid then 257 * return it. If not valid then get the size from the driver and set size in 258 * the common snode. If the device has not been attached then we don't ask for 259 * an update from the driver- for non-streams SSIZEVALID stays unset until the 260 * device is attached. A stat of a mknod outside /devices (non-devfs) may 261 * report UNKNOWN_SIZE because the device may not be attached yet (SDIPSET not 262 * established in mknod until open time). An stat in /devices will report the 263 * size correctly. Specfs should always call SPEC_SIZE instead of referring 264 * directly to s_size to initialize/retrieve the size of a device. 265 * 266 * XXX There is an inconsistency between block and raw - "unknown" is 267 * UNKNOWN_SIZE for VBLK and 0 for VCHR(raw). 268 */ 269 static u_offset_t 270 spec_size(struct snode *csp) 271 { 272 struct vnode *cvp = STOV(csp); 273 u_offset_t size; 274 int plen; 275 uint32_t size32; 276 dev_t dev; 277 dev_info_t *devi; 278 major_t maj; 279 280 ASSERT((csp)->s_commonvp == cvp); /* must be common node */ 281 282 /* return cached value */ 283 mutex_enter(&csp->s_lock); 284 if (csp->s_flag & SSIZEVALID) { 285 mutex_exit(&csp->s_lock); 286 return (csp->s_size); 287 } 288 289 /* VOP_GETATTR of mknod has not had devcnt restriction applied */ 290 dev = cvp->v_rdev; 291 maj = getmajor(dev); 292 if (maj >= devcnt) { 293 /* return non-cached UNKNOWN_SIZE */ 294 mutex_exit(&csp->s_lock); 295 return ((cvp->v_type == VCHR) ? 0 : UNKNOWN_SIZE); 296 } 297 298 /* establish cached zero size for streams */ 299 if (STREAMSTAB(maj)) { 300 csp->s_size = 0; 301 csp->s_flag |= SSIZEVALID; 302 mutex_exit(&csp->s_lock); 303 return (0); 304 } 305 306 /* 307 * Return non-cached UNKNOWN_SIZE if not open. 308 * 309 * NB: This check is bogus, calling prop_op(9E) should be gated by 310 * attach, not open. Not having this check however opens up a new 311 * context under which a driver's prop_op(9E) could be called. Calling 312 * prop_op(9E) in this new context has been shown to expose latent 313 * driver bugs (insufficient NULL pointer checks that lead to panic). 314 * We are keeping this open check for now to avoid these panics. 315 */ 316 if (csp->s_count == 0) { 317 mutex_exit(&csp->s_lock); 318 return ((cvp->v_type == VCHR) ? 0 : UNKNOWN_SIZE); 319 } 320 321 /* Return non-cached UNKNOWN_SIZE if not attached. */ 322 if (((csp->s_flag & SDIPSET) == 0) || (csp->s_dip == NULL) || 323 !i_ddi_devi_attached(csp->s_dip)) { 324 mutex_exit(&csp->s_lock); 325 return ((cvp->v_type == VCHR) ? 0 : UNKNOWN_SIZE); 326 } 327 328 devi = csp->s_dip; 329 330 /* 331 * Established cached size obtained from the attached driver. Since we 332 * know the devinfo node, for efficiency we use cdev_prop_op directly 333 * instead of [cb]dev_[Ss]size. 334 */ 335 if (cvp->v_type == VCHR) { 336 size = 0; 337 plen = sizeof (size); 338 if (cdev_prop_op(dev, devi, PROP_LEN_AND_VAL_BUF, 339 DDI_PROP_NOTPROM | DDI_PROP_DONTPASS | 340 DDI_PROP_CONSUMER_TYPED, "Size", (caddr_t)&size, 341 &plen) != DDI_PROP_SUCCESS) { 342 plen = sizeof (size32); 343 if (cdev_prop_op(dev, devi, PROP_LEN_AND_VAL_BUF, 344 DDI_PROP_NOTPROM | DDI_PROP_DONTPASS, 345 "size", (caddr_t)&size32, &plen) == 346 DDI_PROP_SUCCESS) 347 size = size32; 348 } 349 } else { 350 size = UNKNOWN_SIZE; 351 plen = sizeof (size); 352 if (cdev_prop_op(dev, devi, PROP_LEN_AND_VAL_BUF, 353 DDI_PROP_NOTPROM | DDI_PROP_DONTPASS | 354 DDI_PROP_CONSUMER_TYPED, "Nblocks", (caddr_t)&size, 355 &plen) != DDI_PROP_SUCCESS) { 356 plen = sizeof (size32); 357 if (cdev_prop_op(dev, devi, PROP_LEN_AND_VAL_BUF, 358 DDI_PROP_NOTPROM | DDI_PROP_DONTPASS, 359 "nblocks", (caddr_t)&size32, &plen) == 360 DDI_PROP_SUCCESS) 361 size = size32; 362 } 363 364 if (size != UNKNOWN_SIZE) { 365 /* convert from block size to byte size */ 366 if (size < (MAXOFFSET_T >> DEV_BSHIFT)) 367 size = size << DEV_BSHIFT; 368 else 369 size = UNKNOWN_SIZE; 370 } 371 } 372 373 csp->s_size = size; 374 csp->s_flag |= SSIZEVALID; 375 376 mutex_exit(&csp->s_lock); 377 return (size); 378 } 379 380 /* 381 * This function deal with vnode substitution in the case of 382 * device cloning. 383 */ 384 static int 385 spec_clone(struct vnode **vpp, dev_t newdev, int vtype, struct stdata *stp) 386 { 387 dev_t dev = (*vpp)->v_rdev; 388 major_t maj = getmajor(dev); 389 major_t newmaj = getmajor(newdev); 390 int sysclone = (maj == clone_major); 391 int qassociate_used = 0; 392 struct snode *oldsp, *oldcsp; 393 struct snode *newsp, *newcsp; 394 struct vnode *newvp, *newcvp; 395 dev_info_t *dip; 396 queue_t *dq; 397 398 ASSERT(dev != newdev); 399 400 /* 401 * Check for cloning across different drivers. 402 * We only support this under the system provided clone driver 403 */ 404 if ((maj != newmaj) && !sysclone) { 405 cmn_err(CE_NOTE, 406 "unsupported clone open maj = %u, newmaj = %u", 407 maj, newmaj); 408 return (ENXIO); 409 } 410 411 /* old */ 412 oldsp = VTOS(*vpp); 413 oldcsp = VTOS(oldsp->s_commonvp); 414 415 /* new */ 416 newvp = makespecvp(newdev, vtype); 417 ASSERT(newvp != NULL); 418 newsp = VTOS(newvp); 419 newcvp = newsp->s_commonvp; 420 newcsp = VTOS(newcvp); 421 422 /* 423 * Clones inherit fsid, realvp, and dip. 424 * XXX realvp inherit is not occurring, does fstat of clone work? 425 */ 426 newsp->s_fsid = oldsp->s_fsid; 427 if (sysclone) { 428 newsp->s_flag |= SCLONE; 429 dip = NULL; 430 } else { 431 newsp->s_flag |= SSELFCLONE; 432 dip = oldcsp->s_dip; 433 } 434 435 /* 436 * If we cloned to an opened newdev that already has called 437 * spec_assoc_vp_with_devi (SDIPSET set) then the association is 438 * already established. 439 */ 440 if (!(newcsp->s_flag & SDIPSET)) { 441 /* 442 * Establish s_dip association for newdev. 443 * 444 * If we trusted the getinfo(9E) DDI_INFO_DEVT2INSTANCE 445 * implementation of all cloning drivers (SCLONE and SELFCLONE) 446 * we would always use e_ddi_hold_devi_by_dev(). We know that 447 * many drivers have had (still have?) problems with 448 * DDI_INFO_DEVT2INSTANCE, so we try to minimize reliance by 449 * detecting drivers that use QASSOCIATE (by looking down the 450 * stream) and setting their s_dip association to NULL. 451 */ 452 qassociate_used = 0; 453 if (stp) { 454 for (dq = stp->sd_wrq; dq; dq = dq->q_next) { 455 if (_RD(dq)->q_flag & _QASSOCIATED) { 456 qassociate_used = 1; 457 dip = NULL; 458 break; 459 } 460 } 461 } 462 463 if (dip || qassociate_used) { 464 spec_assoc_vp_with_devi(newvp, dip); 465 } else { 466 /* derive association from newdev */ 467 dip = e_ddi_hold_devi_by_dev(newdev, 0); 468 spec_assoc_vp_with_devi(newvp, dip); 469 if (dip) 470 ddi_release_devi(dip); 471 } 472 } 473 474 SN_HOLD(newcsp); 475 476 /* deal with stream stuff */ 477 if (stp != NULL) { 478 LOCK_CSP(newcsp); /* synchronize stream open/close */ 479 mutex_enter(&newcsp->s_lock); 480 newcvp->v_stream = newvp->v_stream = stp; 481 stp->sd_vnode = newcvp; 482 stp->sd_strtab = STREAMSTAB(newmaj); 483 mutex_exit(&newcsp->s_lock); 484 UNLOCK_CSP(newcsp); 485 } 486 487 /* substitute the vnode */ 488 SN_RELE(oldcsp); 489 VN_RELE(*vpp); 490 *vpp = newvp; 491 492 return (0); 493 } 494 495 static int 496 spec_open(struct vnode **vpp, int flag, struct cred *cr) 497 { 498 major_t maj; 499 dev_t dev, newdev; 500 struct vnode *vp, *cvp; 501 struct snode *sp, *csp; 502 struct stdata *stp; 503 dev_info_t *dip; 504 int error, type; 505 506 flag &= ~FCREAT; /* paranoia */ 507 508 vp = *vpp; 509 sp = VTOS(vp); 510 ASSERT((vp->v_type == VCHR) || (vp->v_type == VBLK)); 511 if ((vp->v_type != VCHR) && (vp->v_type != VBLK)) 512 return (ENXIO); 513 514 /* 515 * If the VFS_NODEVICES bit was set for the mount, 516 * do not allow opens of special devices. 517 */ 518 if (sp->s_realvp && (sp->s_realvp->v_vfsp->vfs_flag & VFS_NODEVICES)) 519 return (ENXIO); 520 521 newdev = dev = vp->v_rdev; 522 523 /* 524 * If we are opening a node that has not had spec_assoc_vp_with_devi 525 * called against it (mknod outside /devices or a non-dacf makespecvp 526 * node) then SDIPSET will not be set. In this case we call an 527 * interface which will reconstruct the path and lookup (drive attach) 528 * through devfs (e_ddi_hold_devi_by_dev -> e_ddi_hold_devi_by_path -> 529 * devfs_lookupname). For support of broken drivers that don't call 530 * ddi_create_minor_node for all minor nodes in their instance space, 531 * we call interfaces that operates at the directory/devinfo 532 * (major/instance) level instead of to the leaf/minor node level. 533 * After finding and attaching the dip we associate it with the 534 * common specfs vnode (s_dip), which sets SDIPSET. A DL_DETACH_REQ 535 * to style-2 stream driver may set s_dip to NULL with SDIPSET set. 536 * 537 * NOTE: Although e_ddi_hold_devi_by_dev takes a dev_t argument, its 538 * implementation operates at the major/instance level since it only 539 * need to return a dip. 540 */ 541 cvp = sp->s_commonvp; 542 csp = VTOS(cvp); 543 if (!(csp->s_flag & SDIPSET)) { 544 /* try to attach, return error if we fail */ 545 if ((dip = e_ddi_hold_devi_by_dev(dev, 0)) == NULL) 546 return (ENXIO); 547 548 /* associate dip with the common snode s_dip */ 549 spec_assoc_vp_with_devi(vp, dip); 550 ddi_release_devi(dip); /* from e_ddi_hold_devi_by_dev */ 551 } 552 553 #ifdef DEBUG 554 /* verify attach/open exclusion guarantee */ 555 dip = csp->s_dip; 556 ASSERT((dip == NULL) || i_ddi_devi_attached(dip)); 557 #endif /* DEBUG */ 558 559 if ((error = secpolicy_spec_open(cr, cvp, flag)) != 0) 560 return (error); 561 562 maj = getmajor(dev); 563 if (STREAMSTAB(maj)) 564 goto streams_open; 565 566 SN_HOLD(csp); /* increment open count */ 567 568 /* non streams open */ 569 type = (vp->v_type == VBLK ? OTYP_BLK : OTYP_CHR); 570 error = dev_open(&newdev, flag, type, cr); 571 572 /* deal with clone case */ 573 if (error == 0 && dev != newdev) { 574 error = spec_clone(vpp, newdev, vp->v_type, NULL); 575 /* 576 * bail on clone failure, further processing 577 * results in undefined behaviors. 578 */ 579 if (error != 0) 580 return (error); 581 sp = VTOS(*vpp); 582 csp = VTOS(sp->s_commonvp); 583 } 584 585 if (error == 0) { 586 sp->s_size = SPEC_SIZE(csp); 587 588 if ((csp->s_flag & SNEEDCLOSE) == 0) { 589 int nmaj = getmajor(newdev); 590 mutex_enter(&csp->s_lock); 591 /* successful open needs a close later */ 592 csp->s_flag |= SNEEDCLOSE; 593 594 /* 595 * Invalidate possible cached "unknown" size 596 * established by a VOP_GETATTR while open was in 597 * progress, and the driver might fail prop_op(9E). 598 */ 599 if (((cvp->v_type == VCHR) && (csp->s_size == 0)) || 600 ((cvp->v_type == VBLK) && 601 (csp->s_size == UNKNOWN_SIZE))) 602 csp->s_flag &= ~SSIZEVALID; 603 604 if (devopsp[nmaj]->devo_cb_ops->cb_flag & D_64BIT) 605 csp->s_flag |= SLOFFSET; 606 if (devopsp[nmaj]->devo_cb_ops->cb_flag & D_U64BIT) 607 csp->s_flag |= SLOFFSET | SANYOFFSET; 608 mutex_exit(&csp->s_lock); 609 } 610 return (0); 611 } 612 613 /* 614 * Open failed. If we missed a close operation because 615 * we were trying to get the device open and it is the 616 * last in progress open that is failing then call close. 617 * 618 * NOTE: Only non-streams open has this race condition. 619 */ 620 mutex_enter(&csp->s_lock); 621 csp->s_count--; /* decrement open count : SN_RELE */ 622 if ((csp->s_count == 0) && /* no outstanding open */ 623 (csp->s_mapcnt == 0) && /* no mapping */ 624 (csp->s_flag & SNEEDCLOSE)) { /* need a close */ 625 csp->s_flag &= ~(SNEEDCLOSE | SSIZEVALID); 626 627 /* See comment in spec_close() */ 628 if (csp->s_flag & (SCLONE | SSELFCLONE)) 629 csp->s_flag &= ~SDIPSET; 630 631 mutex_exit(&csp->s_lock); 632 ASSERT(*vpp != NULL); 633 (void) device_close(*vpp, flag, cr); 634 } else { 635 mutex_exit(&csp->s_lock); 636 } 637 return (error); 638 639 streams_open: 640 if (vp->v_type != VCHR) 641 return (ENXIO); 642 643 /* 644 * Lock common snode to prevent any new clone opens 645 * on this stream while one is in progress. 646 * This is necessary since the stream currently 647 * associated with the clone device will not be part 648 * of it after the clone open completes. 649 * Unfortunately we don't know in advance if this is 650 * a clone device so we have to lock all opens. 651 * 652 * If we fail, it's because of an interrupt. 653 */ 654 if (LOCK_CSP_SIG(csp) == 0) 655 return (EINTR); 656 657 SN_HOLD(csp); /* increment open count */ 658 659 error = stropen(cvp, &newdev, flag, cr); 660 stp = cvp->v_stream; 661 662 /* deal with the clone case */ 663 if ((error == 0) && (dev != newdev)) { 664 vp->v_stream = cvp->v_stream = NULL; 665 UNLOCK_CSP(csp); 666 error = spec_clone(vpp, newdev, vp->v_type, stp); 667 /* 668 * bail on clone failure, further processing 669 * results in undefined behaviors. 670 */ 671 if (error != 0) 672 return (error); 673 sp = VTOS(*vpp); 674 csp = VTOS(sp->s_commonvp); 675 } else if (error == 0) { 676 vp->v_stream = stp; 677 UNLOCK_CSP(csp); 678 } 679 680 if (error == 0) { 681 /* STREAMS devices don't have a size */ 682 sp->s_size = csp->s_size = 0; 683 684 /* 685 * try to allocate it as a controlling terminal 686 */ 687 if ((stp->sd_flag & STRISTTY) && !(flag & FNOCTTY)) 688 stralloctty(stp); 689 690 return (0); 691 } 692 693 /* 694 * Deal with stropen failure. 695 * 696 * sd_flag in the stream head cannot change since the 697 * common snode is locked before the call to stropen(). 698 */ 699 if ((stp != NULL) && (stp->sd_flag & STREOPENFAIL)) { 700 /* 701 * Open failed part way through. 702 */ 703 mutex_enter(&stp->sd_lock); 704 stp->sd_flag &= ~STREOPENFAIL; 705 mutex_exit(&stp->sd_lock); 706 707 UNLOCK_CSP(csp); 708 (void) spec_close(vp, flag, 1, 0, cr); 709 } else { 710 UNLOCK_CSP(csp); 711 SN_RELE(csp); 712 } 713 714 return (error); 715 } 716 717 /*ARGSUSED2*/ 718 static int 719 spec_close( 720 struct vnode *vp, 721 int flag, 722 int count, 723 offset_t offset, 724 struct cred *cr) 725 { 726 struct vnode *cvp; 727 struct snode *sp, *csp; 728 enum vtype type; 729 dev_t dev; 730 int error = 0; 731 int sysclone; 732 733 if (!(flag & FKLYR)) { 734 /* this only applies to closes of devices from userland */ 735 cleanlocks(vp, ttoproc(curthread)->p_pid, 0); 736 cleanshares(vp, ttoproc(curthread)->p_pid); 737 if (vp->v_stream) 738 strclean(vp); 739 } 740 if (count > 1) 741 return (0); 742 743 sp = VTOS(vp); 744 cvp = sp->s_commonvp; 745 746 dev = sp->s_dev; 747 type = vp->v_type; 748 749 ASSERT(type == VCHR || type == VBLK); 750 751 /* 752 * Prevent close/close and close/open races by serializing closes 753 * on this common snode. Clone opens are held up until after 754 * we have closed this device so the streams linkage is maintained 755 */ 756 csp = VTOS(cvp); 757 758 LOCK_CSP(csp); 759 mutex_enter(&csp->s_lock); 760 761 csp->s_count--; /* one fewer open reference : SN_RELE */ 762 sysclone = sp->s_flag & SCLONE; 763 764 /* 765 * Invalidate size on each close. 766 * 767 * XXX We do this on each close because we don't have interfaces that 768 * allow a driver to invalidate the size. Since clearing this on each 769 * close this causes property overhead we skip /dev/null and 770 * /dev/zero to avoid degrading kenbus performance. 771 */ 772 if (getmajor(dev) != mm_major) 773 csp->s_flag &= ~SSIZEVALID; 774 775 /* 776 * Only call the close routine when the last open reference through 777 * any [s, v]node goes away. This can be checked by looking at 778 * s_count on the common vnode. 779 */ 780 if ((csp->s_count == 0) && (csp->s_mapcnt == 0)) { 781 /* we don't need a close */ 782 csp->s_flag &= ~(SNEEDCLOSE | SSIZEVALID); 783 784 /* 785 * A cloning driver may open-clone to the same dev_t that we 786 * are closing before spec_inactive destroys the common snode. 787 * If this occurs the s_dip association needs to be reevaluated. 788 * We clear SDIPSET to force reevaluation in this case. When 789 * reevaluation occurs (by spec_clone after open), if the 790 * devinfo association has changed then the old association 791 * will be released as the new association is established by 792 * spec_assoc_vp_with_devi(). 793 */ 794 if (csp->s_flag & (SCLONE | SSELFCLONE)) 795 csp->s_flag &= ~SDIPSET; 796 797 mutex_exit(&csp->s_lock); 798 error = device_close(vp, flag, cr); 799 800 /* 801 * Decrement the devops held in clnopen() 802 */ 803 if (sysclone) { 804 ddi_rele_driver(getmajor(dev)); 805 } 806 mutex_enter(&csp->s_lock); 807 } 808 809 UNLOCK_CSP_LOCK_HELD(csp); 810 mutex_exit(&csp->s_lock); 811 812 return (error); 813 } 814 815 /*ARGSUSED2*/ 816 static int 817 spec_read( 818 struct vnode *vp, 819 struct uio *uiop, 820 int ioflag, 821 struct cred *cr, 822 struct caller_context *ct) 823 { 824 int error; 825 struct snode *sp = VTOS(vp); 826 dev_t dev = sp->s_dev; 827 size_t n; 828 ulong_t on; 829 u_offset_t bdevsize; 830 offset_t maxoff; 831 offset_t off; 832 struct vnode *blkvp; 833 834 ASSERT(vp->v_type == VCHR || vp->v_type == VBLK); 835 836 if (STREAMSTAB(getmajor(dev))) { /* stream */ 837 ASSERT(vp->v_type == VCHR); 838 smark(sp, SACC); 839 return (strread(vp, uiop, cr)); 840 } 841 842 if (uiop->uio_resid == 0) 843 return (0); 844 845 /* 846 * Plain old character devices that set D_U64BIT can have 847 * unrestricted offsets. 848 */ 849 maxoff = spec_maxoffset(vp); 850 ASSERT(maxoff != -1 || vp->v_type == VCHR); 851 852 if (maxoff != -1 && (uiop->uio_loffset < 0 || 853 uiop->uio_loffset + uiop->uio_resid > maxoff)) 854 return (EINVAL); 855 856 if (vp->v_type == VCHR) { 857 smark(sp, SACC); 858 ASSERT(STREAMSTAB(getmajor(dev)) == 0); 859 return (cdev_read(dev, uiop, cr)); 860 } 861 862 /* 863 * Block device. 864 */ 865 error = 0; 866 blkvp = sp->s_commonvp; 867 bdevsize = SPEC_SIZE(VTOS(blkvp)); 868 869 do { 870 caddr_t base; 871 offset_t diff; 872 873 off = uiop->uio_loffset & (offset_t)MAXBMASK; 874 on = (size_t)(uiop->uio_loffset & MAXBOFFSET); 875 n = (size_t)MIN(MAXBSIZE - on, uiop->uio_resid); 876 diff = bdevsize - uiop->uio_loffset; 877 878 if (diff <= 0) 879 break; 880 if (diff < n) 881 n = (size_t)diff; 882 883 base = segmap_getmapflt(segkmap, blkvp, 884 (u_offset_t)(off + on), n, 1, S_READ); 885 886 if ((error = uiomove(base + on, n, UIO_READ, uiop)) == 0) { 887 int flags = 0; 888 /* 889 * If we read a whole block, we won't need this 890 * buffer again soon. 891 */ 892 if (n + on == MAXBSIZE) 893 flags = SM_DONTNEED | SM_FREE; 894 error = segmap_release(segkmap, base, flags); 895 } else { 896 (void) segmap_release(segkmap, base, 0); 897 if (bdevsize == UNKNOWN_SIZE) { 898 error = 0; 899 break; 900 } 901 } 902 } while (error == 0 && uiop->uio_resid > 0 && n != 0); 903 904 return (error); 905 } 906 907 /*ARGSUSED*/ 908 static int 909 spec_write( 910 struct vnode *vp, 911 struct uio *uiop, 912 int ioflag, 913 struct cred *cr, 914 struct caller_context *ct) 915 { 916 int error; 917 struct snode *sp = VTOS(vp); 918 dev_t dev = sp->s_dev; 919 size_t n; 920 ulong_t on; 921 u_offset_t bdevsize; 922 offset_t maxoff; 923 offset_t off; 924 struct vnode *blkvp; 925 926 ASSERT(vp->v_type == VCHR || vp->v_type == VBLK); 927 928 if (STREAMSTAB(getmajor(dev))) { 929 ASSERT(vp->v_type == VCHR); 930 smark(sp, SUPD); 931 return (strwrite(vp, uiop, cr)); 932 } 933 934 /* 935 * Plain old character devices that set D_U64BIT can have 936 * unrestricted offsets. 937 */ 938 maxoff = spec_maxoffset(vp); 939 ASSERT(maxoff != -1 || vp->v_type == VCHR); 940 941 if (maxoff != -1 && (uiop->uio_loffset < 0 || 942 uiop->uio_loffset + uiop->uio_resid > maxoff)) 943 return (EINVAL); 944 945 if (vp->v_type == VCHR) { 946 smark(sp, SUPD); 947 ASSERT(STREAMSTAB(getmajor(dev)) == 0); 948 return (cdev_write(dev, uiop, cr)); 949 } 950 951 if (uiop->uio_resid == 0) 952 return (0); 953 954 error = 0; 955 blkvp = sp->s_commonvp; 956 bdevsize = SPEC_SIZE(VTOS(blkvp)); 957 958 do { 959 int pagecreate; 960 int newpage; 961 caddr_t base; 962 offset_t diff; 963 964 off = uiop->uio_loffset & (offset_t)MAXBMASK; 965 on = (ulong_t)(uiop->uio_loffset & MAXBOFFSET); 966 n = (size_t)MIN(MAXBSIZE - on, uiop->uio_resid); 967 pagecreate = 0; 968 969 diff = bdevsize - uiop->uio_loffset; 970 if (diff <= 0) { 971 error = ENXIO; 972 break; 973 } 974 if (diff < n) 975 n = (size_t)diff; 976 977 /* 978 * Check to see if we can skip reading in the page 979 * and just allocate the memory. We can do this 980 * if we are going to rewrite the entire mapping 981 * or if we are going to write to end of the device 982 * from the beginning of the mapping. 983 */ 984 if (n == MAXBSIZE || (on == 0 && (off + n) == bdevsize)) 985 pagecreate = 1; 986 987 base = segmap_getmapflt(segkmap, blkvp, 988 (u_offset_t)(off + on), n, !pagecreate, S_WRITE); 989 990 /* 991 * segmap_pagecreate() returns 1 if it calls 992 * page_create_va() to allocate any pages. 993 */ 994 newpage = 0; 995 996 if (pagecreate) 997 newpage = segmap_pagecreate(segkmap, base + on, 998 n, 0); 999 1000 error = uiomove(base + on, n, UIO_WRITE, uiop); 1001 1002 if (pagecreate && 1003 uiop->uio_loffset < 1004 P2ROUNDUP_TYPED(off + on + n, PAGESIZE, offset_t)) { 1005 /* 1006 * We created pages w/o initializing them completely, 1007 * thus we need to zero the part that wasn't set up. 1008 * This can happen if we write to the end of the device 1009 * or if we had some sort of error during the uiomove. 1010 */ 1011 long nzero; 1012 offset_t nmoved; 1013 1014 nmoved = (uiop->uio_loffset - (off + on)); 1015 if (nmoved < 0 || nmoved > n) { 1016 panic("spec_write: nmoved bogus"); 1017 /*NOTREACHED*/ 1018 } 1019 nzero = (long)P2ROUNDUP(on + n, PAGESIZE) - 1020 (on + nmoved); 1021 if (nzero < 0 || (on + nmoved + nzero > MAXBSIZE)) { 1022 panic("spec_write: nzero bogus"); 1023 /*NOTREACHED*/ 1024 } 1025 (void) kzero(base + on + nmoved, (size_t)nzero); 1026 } 1027 1028 /* 1029 * Unlock the pages which have been allocated by 1030 * page_create_va() in segmap_pagecreate(). 1031 */ 1032 if (newpage) 1033 segmap_pageunlock(segkmap, base + on, 1034 (size_t)n, S_WRITE); 1035 1036 if (error == 0) { 1037 int flags = 0; 1038 1039 /* 1040 * Force write back for synchronous write cases. 1041 */ 1042 if (ioflag & (FSYNC|FDSYNC)) 1043 flags = SM_WRITE; 1044 else if (n + on == MAXBSIZE || IS_SWAPVP(vp)) { 1045 /* 1046 * Have written a whole block. 1047 * Start an asynchronous write and 1048 * mark the buffer to indicate that 1049 * it won't be needed again soon. 1050 * Push swap files here, since it 1051 * won't happen anywhere else. 1052 */ 1053 flags = SM_WRITE | SM_ASYNC | SM_DONTNEED; 1054 } 1055 smark(sp, SUPD|SCHG); 1056 error = segmap_release(segkmap, base, flags); 1057 } else 1058 (void) segmap_release(segkmap, base, SM_INVAL); 1059 1060 } while (error == 0 && uiop->uio_resid > 0 && n != 0); 1061 1062 return (error); 1063 } 1064 1065 static int 1066 spec_ioctl(struct vnode *vp, int cmd, intptr_t arg, int mode, struct cred *cr, 1067 int *rvalp) 1068 { 1069 struct snode *sp; 1070 dev_t dev; 1071 int error; 1072 1073 if (vp->v_type != VCHR) 1074 return (ENOTTY); 1075 sp = VTOS(vp); 1076 dev = sp->s_dev; 1077 if (STREAMSTAB(getmajor(dev))) { 1078 error = strioctl(vp, cmd, arg, mode, U_TO_K, cr, rvalp); 1079 } else { 1080 error = cdev_ioctl(dev, cmd, arg, mode, cr, rvalp); 1081 } 1082 return (error); 1083 } 1084 1085 static int 1086 spec_getattr(struct vnode *vp, struct vattr *vap, int flags, struct cred *cr) 1087 { 1088 int error; 1089 struct snode *sp; 1090 struct vnode *realvp; 1091 1092 /* With ATTR_COMM we will not get attributes from realvp */ 1093 if (flags & ATTR_COMM) { 1094 sp = VTOS(vp); 1095 vp = sp->s_commonvp; 1096 } 1097 sp = VTOS(vp); 1098 realvp = sp->s_realvp; 1099 1100 if (realvp == NULL) { 1101 static int snode_shift = 0; 1102 1103 /* 1104 * Calculate the amount of bitshift to a snode pointer which 1105 * will still keep it unique. See below. 1106 */ 1107 if (snode_shift == 0) 1108 snode_shift = highbit(sizeof (struct snode)); 1109 ASSERT(snode_shift > 0); 1110 1111 /* 1112 * No real vnode behind this one. Fill in the fields 1113 * from the snode. 1114 * 1115 * This code should be refined to return only the 1116 * attributes asked for instead of all of them. 1117 */ 1118 vap->va_type = vp->v_type; 1119 vap->va_mode = 0; 1120 vap->va_uid = vap->va_gid = 0; 1121 vap->va_fsid = sp->s_fsid; 1122 1123 /* 1124 * If the va_nodeid is > MAX_USHORT, then i386 stats might 1125 * fail. So we shift down the snode pointer to try and get 1126 * the most uniqueness into 16-bits. 1127 */ 1128 vap->va_nodeid = ((ino64_t)(uintptr_t)sp >> snode_shift) & 1129 0xFFFF; 1130 vap->va_nlink = 0; 1131 vap->va_rdev = sp->s_dev; 1132 1133 /* 1134 * va_nblocks is the number of 512 byte blocks used to store 1135 * the mknod for the device, not the number of blocks on the 1136 * device itself. This is typically zero since the mknod is 1137 * represented directly in the inode itself. 1138 */ 1139 vap->va_nblocks = 0; 1140 } else { 1141 error = VOP_GETATTR(realvp, vap, flags, cr); 1142 if (error != 0) 1143 return (error); 1144 } 1145 1146 /* set the size from the snode */ 1147 vap->va_size = SPEC_SIZE(VTOS(sp->s_commonvp)); 1148 vap->va_blksize = MAXBSIZE; 1149 1150 mutex_enter(&sp->s_lock); 1151 vap->va_atime.tv_sec = sp->s_atime; 1152 vap->va_mtime.tv_sec = sp->s_mtime; 1153 vap->va_ctime.tv_sec = sp->s_ctime; 1154 mutex_exit(&sp->s_lock); 1155 1156 vap->va_atime.tv_nsec = 0; 1157 vap->va_mtime.tv_nsec = 0; 1158 vap->va_ctime.tv_nsec = 0; 1159 vap->va_seq = 0; 1160 1161 return (0); 1162 } 1163 1164 static int 1165 spec_setattr( 1166 struct vnode *vp, 1167 struct vattr *vap, 1168 int flags, 1169 struct cred *cr, 1170 caller_context_t *ctp) 1171 { 1172 struct snode *sp = VTOS(vp); 1173 struct vnode *realvp; 1174 int error; 1175 1176 if (vp->v_type == VCHR && vp->v_stream && (vap->va_mask & AT_SIZE)) { 1177 /* 1178 * 1135080: O_TRUNC should have no effect on 1179 * named pipes and terminal devices. 1180 */ 1181 ASSERT(vap->va_mask == AT_SIZE); 1182 return (0); 1183 } 1184 1185 if ((realvp = sp->s_realvp) == NULL) 1186 error = 0; /* no real vnode to update */ 1187 else 1188 error = VOP_SETATTR(realvp, vap, flags, cr, ctp); 1189 if (error == 0) { 1190 /* 1191 * If times were changed, update snode. 1192 */ 1193 mutex_enter(&sp->s_lock); 1194 if (vap->va_mask & AT_ATIME) 1195 sp->s_atime = vap->va_atime.tv_sec; 1196 if (vap->va_mask & AT_MTIME) { 1197 sp->s_mtime = vap->va_mtime.tv_sec; 1198 sp->s_ctime = gethrestime_sec(); 1199 } 1200 mutex_exit(&sp->s_lock); 1201 } 1202 return (error); 1203 } 1204 1205 static int 1206 spec_access(struct vnode *vp, int mode, int flags, struct cred *cr) 1207 { 1208 struct vnode *realvp; 1209 struct snode *sp = VTOS(vp); 1210 1211 if ((realvp = sp->s_realvp) != NULL) 1212 return (VOP_ACCESS(realvp, mode, flags, cr)); 1213 else 1214 return (0); /* Allow all access. */ 1215 } 1216 1217 /* 1218 * This can be called if creat or an open with O_CREAT is done on the root 1219 * of a lofs mount where the mounted entity is a special file. 1220 */ 1221 /*ARGSUSED*/ 1222 static int 1223 spec_create(struct vnode *dvp, char *name, vattr_t *vap, enum vcexcl excl, 1224 int mode, struct vnode **vpp, struct cred *cr, int flag) 1225 { 1226 int error; 1227 1228 ASSERT(dvp && (dvp->v_flag & VROOT) && *name == '\0'); 1229 if (excl == NONEXCL) { 1230 if (mode && (error = spec_access(dvp, mode, 0, cr))) 1231 return (error); 1232 VN_HOLD(dvp); 1233 return (0); 1234 } 1235 return (EEXIST); 1236 } 1237 1238 /* 1239 * In order to sync out the snode times without multi-client problems, 1240 * make sure the times written out are never earlier than the times 1241 * already set in the vnode. 1242 */ 1243 static int 1244 spec_fsync(struct vnode *vp, int syncflag, struct cred *cr) 1245 { 1246 struct snode *sp = VTOS(vp); 1247 struct vnode *realvp; 1248 struct vnode *cvp; 1249 struct vattr va, vatmp; 1250 1251 /* If times didn't change, don't flush anything. */ 1252 mutex_enter(&sp->s_lock); 1253 if ((sp->s_flag & (SACC|SUPD|SCHG)) == 0 && vp->v_type != VBLK) { 1254 mutex_exit(&sp->s_lock); 1255 return (0); 1256 } 1257 sp->s_flag &= ~(SACC|SUPD|SCHG); 1258 mutex_exit(&sp->s_lock); 1259 cvp = sp->s_commonvp; 1260 realvp = sp->s_realvp; 1261 1262 if (vp->v_type == VBLK && cvp != vp && vn_has_cached_data(cvp) && 1263 (cvp->v_flag & VISSWAP) == 0) 1264 (void) VOP_PUTPAGE(cvp, (offset_t)0, 0, 0, cr); 1265 1266 /* 1267 * If no real vnode to update, don't flush anything. 1268 */ 1269 if (realvp == NULL) 1270 return (0); 1271 1272 vatmp.va_mask = AT_ATIME|AT_MTIME; 1273 if (VOP_GETATTR(realvp, &vatmp, 0, cr) == 0) { 1274 1275 mutex_enter(&sp->s_lock); 1276 if (vatmp.va_atime.tv_sec > sp->s_atime) 1277 va.va_atime = vatmp.va_atime; 1278 else { 1279 va.va_atime.tv_sec = sp->s_atime; 1280 va.va_atime.tv_nsec = 0; 1281 } 1282 if (vatmp.va_mtime.tv_sec > sp->s_mtime) 1283 va.va_mtime = vatmp.va_mtime; 1284 else { 1285 va.va_mtime.tv_sec = sp->s_mtime; 1286 va.va_mtime.tv_nsec = 0; 1287 } 1288 mutex_exit(&sp->s_lock); 1289 1290 va.va_mask = AT_ATIME|AT_MTIME; 1291 (void) VOP_SETATTR(realvp, &va, 0, cr, NULL); 1292 } 1293 (void) VOP_FSYNC(realvp, syncflag, cr); 1294 return (0); 1295 } 1296 1297 /*ARGSUSED*/ 1298 static void 1299 spec_inactive(struct vnode *vp, struct cred *cr) 1300 { 1301 struct snode *sp = VTOS(vp); 1302 struct vnode *cvp; 1303 struct vnode *rvp; 1304 1305 /* 1306 * If no one has reclaimed the vnode, remove from the 1307 * cache now. 1308 */ 1309 if (vp->v_count < 1) { 1310 panic("spec_inactive: Bad v_count"); 1311 /*NOTREACHED*/ 1312 } 1313 mutex_enter(&stable_lock); 1314 1315 mutex_enter(&vp->v_lock); 1316 /* 1317 * Drop the temporary hold by vn_rele now 1318 */ 1319 if (--vp->v_count != 0) { 1320 mutex_exit(&vp->v_lock); 1321 mutex_exit(&stable_lock); 1322 return; 1323 } 1324 mutex_exit(&vp->v_lock); 1325 1326 sdelete(sp); 1327 mutex_exit(&stable_lock); 1328 1329 /* We are the sole owner of sp now */ 1330 cvp = sp->s_commonvp; 1331 rvp = sp->s_realvp; 1332 1333 if (rvp) { 1334 /* 1335 * If the snode times changed, then update the times 1336 * associated with the "realvp". 1337 */ 1338 if ((sp->s_flag & (SACC|SUPD|SCHG)) != 0) { 1339 1340 struct vattr va, vatmp; 1341 1342 mutex_enter(&sp->s_lock); 1343 sp->s_flag &= ~(SACC|SUPD|SCHG); 1344 mutex_exit(&sp->s_lock); 1345 vatmp.va_mask = AT_ATIME|AT_MTIME; 1346 /* 1347 * The user may not own the device, but we 1348 * want to update the attributes anyway. 1349 */ 1350 if (VOP_GETATTR(rvp, &vatmp, 0, kcred) == 0) { 1351 if (vatmp.va_atime.tv_sec > sp->s_atime) 1352 va.va_atime = vatmp.va_atime; 1353 else { 1354 va.va_atime.tv_sec = sp->s_atime; 1355 va.va_atime.tv_nsec = 0; 1356 } 1357 if (vatmp.va_mtime.tv_sec > sp->s_mtime) 1358 va.va_mtime = vatmp.va_mtime; 1359 else { 1360 va.va_mtime.tv_sec = sp->s_mtime; 1361 va.va_mtime.tv_nsec = 0; 1362 } 1363 1364 va.va_mask = AT_ATIME|AT_MTIME; 1365 (void) VOP_SETATTR(rvp, &va, 0, kcred, NULL); 1366 } 1367 } 1368 } 1369 ASSERT(!vn_has_cached_data(vp)); 1370 vn_invalid(vp); 1371 1372 /* if we are sharing another file systems vfs, release it */ 1373 if (vp->v_vfsp && (vp->v_vfsp != &spec_vfs)) 1374 VFS_RELE(vp->v_vfsp); 1375 1376 /* if we have a realvp, release the realvp */ 1377 if (rvp) 1378 VN_RELE(rvp); 1379 1380 /* if we have a common, release the common */ 1381 if (cvp && (cvp != vp)) { 1382 VN_RELE(cvp); 1383 #ifdef DEBUG 1384 } else if (cvp) { 1385 /* 1386 * if this is the last reference to a common vnode, any 1387 * associated stream had better have been closed 1388 */ 1389 ASSERT(cvp == vp); 1390 ASSERT(cvp->v_stream == NULL); 1391 #endif /* DEBUG */ 1392 } 1393 1394 /* 1395 * if we have a hold on a devinfo node (established by 1396 * spec_assoc_vp_with_devi), release the hold 1397 */ 1398 if (sp->s_dip) 1399 ddi_release_devi(sp->s_dip); 1400 1401 /* 1402 * If we have an associated device policy, release it. 1403 */ 1404 if (sp->s_plcy != NULL) 1405 dpfree(sp->s_plcy); 1406 1407 /* 1408 * If all holds on the devinfo node are through specfs/devfs 1409 * and we just destroyed the last specfs node associated with the 1410 * device, then the devinfo node reference count should now be 1411 * zero. We can't check this because there may be other holds 1412 * on the node from non file system sources: ddi_hold_devi_by_instance 1413 * for example. 1414 */ 1415 kmem_cache_free(snode_cache, sp); 1416 } 1417 1418 static int 1419 spec_fid(struct vnode *vp, struct fid *fidp) 1420 { 1421 struct vnode *realvp; 1422 struct snode *sp = VTOS(vp); 1423 1424 if ((realvp = sp->s_realvp) != NULL) 1425 return (VOP_FID(realvp, fidp)); 1426 else 1427 return (EINVAL); 1428 } 1429 1430 /*ARGSUSED1*/ 1431 static int 1432 spec_seek(struct vnode *vp, offset_t ooff, offset_t *noffp) 1433 { 1434 offset_t maxoff = spec_maxoffset(vp); 1435 1436 if (maxoff == -1 || *noffp <= maxoff) 1437 return (0); 1438 else 1439 return (EINVAL); 1440 } 1441 1442 static int 1443 spec_frlock( 1444 struct vnode *vp, 1445 int cmd, 1446 struct flock64 *bfp, 1447 int flag, 1448 offset_t offset, 1449 struct flk_callback *flk_cbp, 1450 struct cred *cr) 1451 { 1452 struct snode *sp = VTOS(vp); 1453 struct snode *csp; 1454 1455 csp = VTOS(sp->s_commonvp); 1456 /* 1457 * If file is being mapped, disallow frlock. 1458 */ 1459 if (csp->s_mapcnt > 0) 1460 return (EAGAIN); 1461 1462 return (fs_frlock(vp, cmd, bfp, flag, offset, flk_cbp, cr)); 1463 } 1464 1465 static int 1466 spec_realvp(struct vnode *vp, struct vnode **vpp) 1467 { 1468 struct vnode *rvp; 1469 1470 if ((rvp = VTOS(vp)->s_realvp) != NULL) { 1471 vp = rvp; 1472 if (VOP_REALVP(vp, &rvp) == 0) 1473 vp = rvp; 1474 } 1475 1476 *vpp = vp; 1477 return (0); 1478 } 1479 1480 /* 1481 * Return all the pages from [off..off + len] in block 1482 * or character device. 1483 */ 1484 static int 1485 spec_getpage( 1486 struct vnode *vp, 1487 offset_t off, 1488 size_t len, 1489 uint_t *protp, 1490 page_t *pl[], 1491 size_t plsz, 1492 struct seg *seg, 1493 caddr_t addr, 1494 enum seg_rw rw, 1495 struct cred *cr) 1496 { 1497 struct snode *sp = VTOS(vp); 1498 int err; 1499 1500 ASSERT(sp->s_commonvp == vp); 1501 1502 /* 1503 * XXX Given the above assertion, this might not do 1504 * what is wanted here. 1505 */ 1506 if (vp->v_flag & VNOMAP) 1507 return (ENOSYS); 1508 TRACE_4(TR_FAC_SPECFS, TR_SPECFS_GETPAGE, 1509 "specfs getpage:vp %p off %llx len %ld snode %p", 1510 vp, off, len, sp); 1511 1512 switch (vp->v_type) { 1513 case VBLK: 1514 if (protp != NULL) 1515 *protp = PROT_ALL; 1516 1517 if (((u_offset_t)off + len) > (SPEC_SIZE(sp) + PAGEOFFSET)) 1518 return (EFAULT); /* beyond EOF */ 1519 1520 if (len <= PAGESIZE) 1521 err = spec_getapage(vp, (u_offset_t)off, len, protp, pl, 1522 plsz, seg, addr, rw, cr); 1523 else 1524 err = pvn_getpages(spec_getapage, vp, (u_offset_t)off, 1525 len, protp, pl, plsz, seg, addr, rw, cr); 1526 break; 1527 1528 case VCHR: 1529 cmn_err(CE_NOTE, "spec_getpage called for character device. " 1530 "Check any non-ON consolidation drivers"); 1531 err = 0; 1532 pl[0] = (page_t *)0; 1533 break; 1534 1535 default: 1536 panic("spec_getpage: bad v_type 0x%x", vp->v_type); 1537 /*NOTREACHED*/ 1538 } 1539 1540 return (err); 1541 } 1542 1543 extern int klustsize; /* set in machdep.c */ 1544 1545 int spec_ra = 1; 1546 int spec_lostpage; /* number of times we lost original page */ 1547 1548 /*ARGSUSED2*/ 1549 static int 1550 spec_getapage( 1551 struct vnode *vp, 1552 u_offset_t off, 1553 size_t len, 1554 uint_t *protp, 1555 page_t *pl[], 1556 size_t plsz, 1557 struct seg *seg, 1558 caddr_t addr, 1559 enum seg_rw rw, 1560 struct cred *cr) 1561 { 1562 struct snode *sp; 1563 struct buf *bp; 1564 page_t *pp, *pp2; 1565 u_offset_t io_off1, io_off2; 1566 size_t io_len1; 1567 size_t io_len2; 1568 size_t blksz; 1569 u_offset_t blkoff; 1570 int dora, err; 1571 page_t *pagefound; 1572 uint_t xlen; 1573 size_t adj_klustsize; 1574 u_offset_t size; 1575 u_offset_t tmpoff; 1576 1577 sp = VTOS(vp); 1578 TRACE_3(TR_FAC_SPECFS, TR_SPECFS_GETAPAGE, 1579 "specfs getapage:vp %p off %llx snode %p", vp, off, sp); 1580 reread: 1581 1582 err = 0; 1583 bp = NULL; 1584 pp = NULL; 1585 pp2 = NULL; 1586 1587 if (pl != NULL) 1588 pl[0] = NULL; 1589 1590 size = SPEC_SIZE(VTOS(sp->s_commonvp)); 1591 1592 if (spec_ra && sp->s_nextr == off) 1593 dora = 1; 1594 else 1595 dora = 0; 1596 1597 if (size == UNKNOWN_SIZE) { 1598 dora = 0; 1599 adj_klustsize = PAGESIZE; 1600 } else { 1601 adj_klustsize = dora ? klustsize : PAGESIZE; 1602 } 1603 1604 again: 1605 if ((pagefound = page_exists(vp, off)) == NULL) { 1606 if (rw == S_CREATE) { 1607 /* 1608 * We're allocating a swap slot and it's 1609 * associated page was not found, so allocate 1610 * and return it. 1611 */ 1612 if ((pp = page_create_va(vp, off, 1613 PAGESIZE, PG_WAIT, seg, addr)) == NULL) { 1614 panic("spec_getapage: page_create"); 1615 /*NOTREACHED*/ 1616 } 1617 io_len1 = PAGESIZE; 1618 sp->s_nextr = off + PAGESIZE; 1619 } else { 1620 /* 1621 * Need to really do disk I/O to get the page(s). 1622 */ 1623 blkoff = (off / adj_klustsize) * adj_klustsize; 1624 if (size == UNKNOWN_SIZE) { 1625 blksz = PAGESIZE; 1626 } else { 1627 if (blkoff + adj_klustsize <= size) 1628 blksz = adj_klustsize; 1629 else 1630 blksz = 1631 MIN(size - blkoff, adj_klustsize); 1632 } 1633 1634 pp = pvn_read_kluster(vp, off, seg, addr, &tmpoff, 1635 &io_len1, blkoff, blksz, 0); 1636 io_off1 = tmpoff; 1637 /* 1638 * Make sure the page didn't sneek into the 1639 * cache while we blocked in pvn_read_kluster. 1640 */ 1641 if (pp == NULL) 1642 goto again; 1643 1644 /* 1645 * Zero part of page which we are not 1646 * going to be reading from disk now. 1647 */ 1648 xlen = (uint_t)(io_len1 & PAGEOFFSET); 1649 if (xlen != 0) 1650 pagezero(pp->p_prev, xlen, PAGESIZE - xlen); 1651 1652 bp = spec_startio(vp, pp, io_off1, io_len1, 1653 pl == NULL ? (B_ASYNC | B_READ) : B_READ); 1654 sp->s_nextr = io_off1 + io_len1; 1655 } 1656 } 1657 1658 if (dora && rw != S_CREATE) { 1659 u_offset_t off2; 1660 caddr_t addr2; 1661 1662 off2 = ((off / adj_klustsize) + 1) * adj_klustsize; 1663 addr2 = addr + (off2 - off); 1664 1665 pp2 = NULL; 1666 /* 1667 * If we are past EOF then don't bother trying 1668 * with read-ahead. 1669 */ 1670 if (off2 >= size) 1671 pp2 = NULL; 1672 else { 1673 if (off2 + adj_klustsize <= size) 1674 blksz = adj_klustsize; 1675 else 1676 blksz = MIN(size - off2, adj_klustsize); 1677 1678 pp2 = pvn_read_kluster(vp, off2, seg, addr2, &tmpoff, 1679 &io_len2, off2, blksz, 1); 1680 io_off2 = tmpoff; 1681 } 1682 1683 if (pp2 != NULL) { 1684 /* 1685 * Zero part of page which we are not 1686 * going to be reading from disk now. 1687 */ 1688 xlen = (uint_t)(io_len2 & PAGEOFFSET); 1689 if (xlen != 0) 1690 pagezero(pp2->p_prev, xlen, PAGESIZE - xlen); 1691 1692 (void) spec_startio(vp, pp2, io_off2, io_len2, 1693 B_READ | B_ASYNC); 1694 } 1695 } 1696 1697 if (pl == NULL) 1698 return (err); 1699 1700 if (bp != NULL) { 1701 err = biowait(bp); 1702 pageio_done(bp); 1703 1704 if (err) { 1705 if (pp != NULL) 1706 pvn_read_done(pp, B_ERROR); 1707 return (err); 1708 } 1709 } 1710 1711 if (pagefound) { 1712 se_t se = (rw == S_CREATE ? SE_EXCL : SE_SHARED); 1713 /* 1714 * Page exists in the cache, acquire the appropriate 1715 * lock. If this fails, start all over again. 1716 */ 1717 1718 if ((pp = page_lookup(vp, off, se)) == NULL) { 1719 spec_lostpage++; 1720 goto reread; 1721 } 1722 pl[0] = pp; 1723 pl[1] = NULL; 1724 1725 sp->s_nextr = off + PAGESIZE; 1726 return (0); 1727 } 1728 1729 if (pp != NULL) 1730 pvn_plist_init(pp, pl, plsz, off, io_len1, rw); 1731 return (0); 1732 } 1733 1734 /* 1735 * Flags are composed of {B_INVAL, B_DIRTY B_FREE, B_DONTNEED, B_FORCE}. 1736 * If len == 0, do from off to EOF. 1737 * 1738 * The normal cases should be len == 0 & off == 0 (entire vp list), 1739 * len == MAXBSIZE (from segmap_release actions), and len == PAGESIZE 1740 * (from pageout). 1741 */ 1742 int 1743 spec_putpage( 1744 struct vnode *vp, 1745 offset_t off, 1746 size_t len, 1747 int flags, 1748 struct cred *cr) 1749 { 1750 struct snode *sp = VTOS(vp); 1751 struct vnode *cvp; 1752 page_t *pp; 1753 u_offset_t io_off; 1754 size_t io_len = 0; /* for lint */ 1755 int err = 0; 1756 u_offset_t size; 1757 u_offset_t tmpoff; 1758 1759 ASSERT(vp->v_count != 0); 1760 1761 if (vp->v_flag & VNOMAP) 1762 return (ENOSYS); 1763 1764 cvp = sp->s_commonvp; 1765 size = SPEC_SIZE(VTOS(cvp)); 1766 1767 if (!vn_has_cached_data(vp) || off >= size) 1768 return (0); 1769 1770 ASSERT(vp->v_type == VBLK && cvp == vp); 1771 TRACE_4(TR_FAC_SPECFS, TR_SPECFS_PUTPAGE, 1772 "specfs putpage:vp %p off %llx len %ld snode %p", 1773 vp, off, len, sp); 1774 1775 if (len == 0) { 1776 /* 1777 * Search the entire vp list for pages >= off. 1778 */ 1779 err = pvn_vplist_dirty(vp, off, spec_putapage, 1780 flags, cr); 1781 } else { 1782 u_offset_t eoff; 1783 1784 /* 1785 * Loop over all offsets in the range [off...off + len] 1786 * looking for pages to deal with. We set limits so 1787 * that we kluster to klustsize boundaries. 1788 */ 1789 eoff = off + len; 1790 for (io_off = off; io_off < eoff && io_off < size; 1791 io_off += io_len) { 1792 /* 1793 * If we are not invalidating, synchronously 1794 * freeing or writing pages use the routine 1795 * page_lookup_nowait() to prevent reclaiming 1796 * them from the free list. 1797 */ 1798 if ((flags & B_INVAL) || ((flags & B_ASYNC) == 0)) { 1799 pp = page_lookup(vp, io_off, 1800 (flags & (B_INVAL | B_FREE)) ? 1801 SE_EXCL : SE_SHARED); 1802 } else { 1803 pp = page_lookup_nowait(vp, io_off, 1804 (flags & B_FREE) ? SE_EXCL : SE_SHARED); 1805 } 1806 1807 if (pp == NULL || pvn_getdirty(pp, flags) == 0) 1808 io_len = PAGESIZE; 1809 else { 1810 err = spec_putapage(vp, pp, &tmpoff, &io_len, 1811 flags, cr); 1812 io_off = tmpoff; 1813 if (err != 0) 1814 break; 1815 /* 1816 * "io_off" and "io_len" are returned as 1817 * the range of pages we actually wrote. 1818 * This allows us to skip ahead more quickly 1819 * since several pages may've been dealt 1820 * with by this iteration of the loop. 1821 */ 1822 } 1823 } 1824 } 1825 return (err); 1826 } 1827 1828 1829 /* 1830 * Write out a single page, possibly klustering adjacent 1831 * dirty pages. 1832 */ 1833 /*ARGSUSED5*/ 1834 static int 1835 spec_putapage( 1836 struct vnode *vp, 1837 page_t *pp, 1838 u_offset_t *offp, /* return value */ 1839 size_t *lenp, /* return value */ 1840 int flags, 1841 struct cred *cr) 1842 { 1843 struct snode *sp = VTOS(vp); 1844 u_offset_t io_off; 1845 size_t io_len; 1846 size_t blksz; 1847 u_offset_t blkoff; 1848 int err = 0; 1849 struct buf *bp; 1850 u_offset_t size; 1851 size_t adj_klustsize; 1852 u_offset_t tmpoff; 1853 1854 /* 1855 * Destroy read ahead value since we are really going to write. 1856 */ 1857 sp->s_nextr = 0; 1858 size = SPEC_SIZE(VTOS(sp->s_commonvp)); 1859 1860 adj_klustsize = klustsize; 1861 1862 blkoff = (pp->p_offset / adj_klustsize) * adj_klustsize; 1863 1864 if (blkoff + adj_klustsize <= size) 1865 blksz = adj_klustsize; 1866 else 1867 blksz = size - blkoff; 1868 1869 /* 1870 * Find a kluster that fits in one contiguous chunk. 1871 */ 1872 pp = pvn_write_kluster(vp, pp, &tmpoff, &io_len, blkoff, 1873 blksz, flags); 1874 io_off = tmpoff; 1875 1876 /* 1877 * Check for page length rounding problems 1878 * XXX - Is this necessary? 1879 */ 1880 if (io_off + io_len > size) { 1881 ASSERT((io_off + io_len) - size < PAGESIZE); 1882 io_len = size - io_off; 1883 } 1884 1885 bp = spec_startio(vp, pp, io_off, io_len, B_WRITE | flags); 1886 1887 /* 1888 * Wait for i/o to complete if the request is not B_ASYNC. 1889 */ 1890 if ((flags & B_ASYNC) == 0) { 1891 err = biowait(bp); 1892 pageio_done(bp); 1893 pvn_write_done(pp, ((err) ? B_ERROR : 0) | B_WRITE | flags); 1894 } 1895 1896 if (offp) 1897 *offp = io_off; 1898 if (lenp) 1899 *lenp = io_len; 1900 TRACE_4(TR_FAC_SPECFS, TR_SPECFS_PUTAPAGE, 1901 "specfs putapage:vp %p offp %p snode %p err %d", 1902 vp, offp, sp, err); 1903 return (err); 1904 } 1905 1906 /* 1907 * Flags are composed of {B_ASYNC, B_INVAL, B_FREE, B_DONTNEED} 1908 */ 1909 static struct buf * 1910 spec_startio( 1911 struct vnode *vp, 1912 page_t *pp, 1913 u_offset_t io_off, 1914 size_t io_len, 1915 int flags) 1916 { 1917 struct buf *bp; 1918 1919 bp = pageio_setup(pp, io_len, vp, flags); 1920 1921 bp->b_edev = vp->v_rdev; 1922 bp->b_dev = cmpdev(vp->v_rdev); 1923 bp->b_blkno = btodt(io_off); 1924 bp->b_un.b_addr = (caddr_t)0; 1925 1926 (void) bdev_strategy(bp); 1927 1928 if (flags & B_READ) 1929 lwp_stat_update(LWP_STAT_INBLK, 1); 1930 else 1931 lwp_stat_update(LWP_STAT_OUBLK, 1); 1932 1933 return (bp); 1934 } 1935 1936 static int 1937 spec_poll( 1938 struct vnode *vp, 1939 short events, 1940 int anyyet, 1941 short *reventsp, 1942 struct pollhead **phpp) 1943 { 1944 dev_t dev; 1945 int error; 1946 1947 if (vp->v_type == VBLK) 1948 error = fs_poll(vp, events, anyyet, reventsp, phpp); 1949 else { 1950 ASSERT(vp->v_type == VCHR); 1951 dev = vp->v_rdev; 1952 if (STREAMSTAB(getmajor(dev))) { 1953 ASSERT(vp->v_stream != NULL); 1954 error = strpoll(vp->v_stream, events, anyyet, 1955 reventsp, phpp); 1956 } else if (devopsp[getmajor(dev)]->devo_cb_ops->cb_chpoll) { 1957 error = cdev_poll(dev, events, anyyet, reventsp, phpp); 1958 } else { 1959 error = fs_poll(vp, events, anyyet, reventsp, phpp); 1960 } 1961 } 1962 return (error); 1963 } 1964 1965 /* 1966 * This routine is called through the cdevsw[] table to handle 1967 * traditional mmap'able devices that support a d_mmap function. 1968 */ 1969 /*ARGSUSED8*/ 1970 int 1971 spec_segmap( 1972 dev_t dev, 1973 off_t off, 1974 struct as *as, 1975 caddr_t *addrp, 1976 off_t len, 1977 uint_t prot, 1978 uint_t maxprot, 1979 uint_t flags, 1980 struct cred *cred) 1981 { 1982 struct segdev_crargs dev_a; 1983 int (*mapfunc)(dev_t dev, off_t off, int prot); 1984 size_t i; 1985 int error; 1986 1987 if ((mapfunc = devopsp[getmajor(dev)]->devo_cb_ops->cb_mmap) == nodev) 1988 return (ENODEV); 1989 TRACE_4(TR_FAC_SPECFS, TR_SPECFS_SEGMAP, 1990 "specfs segmap:dev %x as %p len %lx prot %x", 1991 dev, as, len, prot); 1992 1993 /* 1994 * Character devices that support the d_mmap 1995 * interface can only be mmap'ed shared. 1996 */ 1997 if ((flags & MAP_TYPE) != MAP_SHARED) 1998 return (EINVAL); 1999 2000 /* 2001 * Check to ensure that the entire range is 2002 * legal and we are not trying to map in 2003 * more than the device will let us. 2004 */ 2005 for (i = 0; i < len; i += PAGESIZE) { 2006 if (cdev_mmap(mapfunc, dev, off + i, maxprot) == -1) 2007 return (ENXIO); 2008 } 2009 2010 as_rangelock(as); 2011 if ((flags & MAP_FIXED) == 0) { 2012 /* 2013 * Pick an address w/o worrying about 2014 * any vac alignment constraints. 2015 */ 2016 map_addr(addrp, len, (offset_t)off, 0, flags); 2017 if (*addrp == NULL) { 2018 as_rangeunlock(as); 2019 return (ENOMEM); 2020 } 2021 } else { 2022 /* 2023 * User-specified address; blow away any previous mappings. 2024 */ 2025 (void) as_unmap(as, *addrp, len); 2026 } 2027 2028 dev_a.mapfunc = mapfunc; 2029 dev_a.dev = dev; 2030 dev_a.offset = off; 2031 dev_a.prot = (uchar_t)prot; 2032 dev_a.maxprot = (uchar_t)maxprot; 2033 dev_a.hat_flags = 0; 2034 dev_a.hat_attr = 0; 2035 dev_a.devmap_data = NULL; 2036 2037 error = as_map(as, *addrp, len, segdev_create, &dev_a); 2038 as_rangeunlock(as); 2039 return (error); 2040 } 2041 2042 int 2043 spec_char_map( 2044 dev_t dev, 2045 offset_t off, 2046 struct as *as, 2047 caddr_t *addrp, 2048 size_t len, 2049 uchar_t prot, 2050 uchar_t maxprot, 2051 uint_t flags, 2052 struct cred *cred) 2053 { 2054 int error = 0; 2055 major_t maj = getmajor(dev); 2056 int map_flag; 2057 int (*segmap)(dev_t, off_t, struct as *, 2058 caddr_t *, off_t, uint_t, uint_t, uint_t, cred_t *); 2059 int (*devmap)(dev_t, devmap_cookie_t, offset_t, 2060 size_t, size_t *, uint_t); 2061 int (*mmap)(dev_t dev, off_t off, int prot); 2062 2063 /* 2064 * Character device: let the device driver 2065 * pick the appropriate segment driver. 2066 * 2067 * 4.x compat.: allow 'NULL' cb_segmap => spec_segmap 2068 * Kindness: allow 'nulldev' cb_segmap => spec_segmap 2069 */ 2070 segmap = devopsp[maj]->devo_cb_ops->cb_segmap; 2071 if (segmap == NULL || segmap == nulldev || segmap == nodev) { 2072 mmap = devopsp[maj]->devo_cb_ops->cb_mmap; 2073 map_flag = devopsp[maj]->devo_cb_ops->cb_flag; 2074 2075 /* 2076 * Use old mmap framework if the driver has both mmap 2077 * and devmap entry points. This is to prevent the 2078 * system from calling invalid devmap entry point 2079 * for some drivers that might have put garbage in the 2080 * devmap entry point. 2081 */ 2082 if ((map_flag & D_DEVMAP) || mmap == NULL || 2083 mmap == nulldev || mmap == nodev) { 2084 devmap = devopsp[maj]->devo_cb_ops->cb_devmap; 2085 2086 /* 2087 * If driver provides devmap entry point in 2088 * cb_ops but not xx_segmap(9E), call 2089 * devmap_setup with default settings 2090 * (NULL) for callback_ops and driver 2091 * callback private data 2092 */ 2093 if (devmap == nodev || devmap == NULL || 2094 devmap == nulldev) 2095 return (ENODEV); 2096 2097 error = devmap_setup(dev, off, as, addrp, 2098 len, prot, maxprot, flags, cred); 2099 2100 return (error); 2101 } else 2102 segmap = spec_segmap; 2103 } else 2104 segmap = cdev_segmap; 2105 2106 return ((*segmap)(dev, (off_t)off, as, addrp, len, prot, 2107 maxprot, flags, cred)); 2108 } 2109 2110 static int 2111 spec_map( 2112 struct vnode *vp, 2113 offset_t off, 2114 struct as *as, 2115 caddr_t *addrp, 2116 size_t len, 2117 uchar_t prot, 2118 uchar_t maxprot, 2119 uint_t flags, 2120 struct cred *cred) 2121 { 2122 int error = 0; 2123 2124 if (vp->v_flag & VNOMAP) 2125 return (ENOSYS); 2126 2127 /* 2128 * If file is locked, fail mapping attempt. 2129 */ 2130 if (vn_has_flocks(vp)) 2131 return (EAGAIN); 2132 2133 if (vp->v_type == VCHR) { 2134 return (spec_char_map(vp->v_rdev, off, as, addrp, len, prot, 2135 maxprot, flags, cred)); 2136 } else if (vp->v_type == VBLK) { 2137 struct segvn_crargs vn_a; 2138 struct vnode *cvp; 2139 struct snode *sp; 2140 2141 /* 2142 * Block device, use segvn mapping to the underlying commonvp 2143 * for pages. 2144 */ 2145 if (off > spec_maxoffset(vp)) 2146 return (ENXIO); 2147 2148 sp = VTOS(vp); 2149 cvp = sp->s_commonvp; 2150 ASSERT(cvp != NULL); 2151 2152 if (off < 0 || (off + len) < 0) 2153 return (ENXIO); 2154 2155 as_rangelock(as); 2156 if ((flags & MAP_FIXED) == 0) { 2157 map_addr(addrp, len, off, 1, flags); 2158 if (*addrp == NULL) { 2159 as_rangeunlock(as); 2160 return (ENOMEM); 2161 } 2162 } else { 2163 /* 2164 * User-specified address; blow away any 2165 * previous mappings. 2166 */ 2167 (void) as_unmap(as, *addrp, len); 2168 } 2169 2170 vn_a.vp = cvp; 2171 vn_a.offset = off; 2172 vn_a.type = flags & MAP_TYPE; 2173 vn_a.prot = (uchar_t)prot; 2174 vn_a.maxprot = (uchar_t)maxprot; 2175 vn_a.flags = flags & ~MAP_TYPE; 2176 vn_a.cred = cred; 2177 vn_a.amp = NULL; 2178 vn_a.szc = 0; 2179 vn_a.lgrp_mem_policy_flags = 0; 2180 2181 error = as_map(as, *addrp, len, segvn_create, &vn_a); 2182 as_rangeunlock(as); 2183 } else 2184 return (ENODEV); 2185 2186 return (error); 2187 } 2188 2189 /*ARGSUSED1*/ 2190 static int 2191 spec_addmap( 2192 struct vnode *vp, /* the common vnode */ 2193 offset_t off, 2194 struct as *as, 2195 caddr_t addr, 2196 size_t len, /* how many bytes to add */ 2197 uchar_t prot, 2198 uchar_t maxprot, 2199 uint_t flags, 2200 struct cred *cred) 2201 { 2202 int error = 0; 2203 struct snode *csp = VTOS(vp); 2204 ulong_t npages; 2205 2206 ASSERT(vp != NULL && VTOS(vp)->s_commonvp == vp); 2207 2208 /* 2209 * XXX Given the above assertion, this might not 2210 * be a particularly sensible thing to test. 2211 */ 2212 if (vp->v_flag & VNOMAP) 2213 return (ENOSYS); 2214 2215 npages = btopr(len); 2216 LOCK_CSP(csp); 2217 csp->s_mapcnt += npages; 2218 2219 UNLOCK_CSP(csp); 2220 return (error); 2221 } 2222 2223 /*ARGSUSED1*/ 2224 static int 2225 spec_delmap( 2226 struct vnode *vp, /* the common vnode */ 2227 offset_t off, 2228 struct as *as, 2229 caddr_t addr, 2230 size_t len, /* how many bytes to take away */ 2231 uint_t prot, 2232 uint_t maxprot, 2233 uint_t flags, 2234 struct cred *cred) 2235 { 2236 struct snode *csp = VTOS(vp); 2237 ulong_t npages; 2238 long mcnt; 2239 2240 /* segdev passes us the common vp */ 2241 2242 ASSERT(vp != NULL && VTOS(vp)->s_commonvp == vp); 2243 2244 /* 2245 * XXX Given the above assertion, this might not 2246 * be a particularly sensible thing to test.. 2247 */ 2248 if (vp->v_flag & VNOMAP) 2249 return (ENOSYS); 2250 2251 npages = btopr(len); 2252 2253 LOCK_CSP(csp); 2254 mutex_enter(&csp->s_lock); 2255 mcnt = (csp->s_mapcnt -= npages); 2256 2257 if (mcnt == 0) { 2258 /* 2259 * Call the close routine when the last reference of any 2260 * kind through any [s, v]node goes away. The s_dip hold 2261 * on the devinfo node is released when the vnode is 2262 * destroyed. 2263 */ 2264 if (csp->s_count == 0) { 2265 csp->s_flag &= ~(SNEEDCLOSE | SSIZEVALID); 2266 2267 /* See comment in spec_close() */ 2268 if (csp->s_flag & (SCLONE | SSELFCLONE)) 2269 csp->s_flag &= ~SDIPSET; 2270 2271 mutex_exit(&csp->s_lock); 2272 2273 (void) device_close(vp, 0, cred); 2274 } else 2275 mutex_exit(&csp->s_lock); 2276 2277 mutex_enter(&csp->s_lock); 2278 } 2279 ASSERT(mcnt >= 0); 2280 2281 UNLOCK_CSP_LOCK_HELD(csp); 2282 mutex_exit(&csp->s_lock); 2283 2284 return (0); 2285 } 2286 2287 static int 2288 spec_dump(struct vnode *vp, caddr_t addr, int bn, int count) 2289 { 2290 ASSERT(vp->v_type == VBLK); 2291 return (bdev_dump(vp->v_rdev, addr, bn, count)); 2292 } 2293 2294 2295 /* 2296 * Do i/o on the given page list from/to vp, io_off for io_len. 2297 * Flags are composed of: 2298 * {B_ASYNC, B_INVAL, B_FREE, B_DONTNEED, B_READ, B_WRITE} 2299 * If B_ASYNC is not set i/o is waited for. 2300 */ 2301 /*ARGSUSED5*/ 2302 static int 2303 spec_pageio( 2304 struct vnode *vp, 2305 page_t *pp, 2306 u_offset_t io_off, 2307 size_t io_len, 2308 int flags, 2309 cred_t *cr) 2310 { 2311 struct buf *bp = NULL; 2312 int err = 0; 2313 2314 if (pp == NULL) 2315 return (EINVAL); 2316 2317 bp = spec_startio(vp, pp, io_off, io_len, flags); 2318 2319 /* 2320 * Wait for i/o to complete if the request is not B_ASYNC. 2321 */ 2322 if ((flags & B_ASYNC) == 0) { 2323 err = biowait(bp); 2324 pageio_done(bp); 2325 } 2326 return (err); 2327 } 2328 2329 /* 2330 * Set ACL on underlying vnode if one exists, or return ENOSYS otherwise. 2331 */ 2332 int 2333 spec_setsecattr(struct vnode *vp, vsecattr_t *vsap, int flag, struct cred *cr) 2334 { 2335 struct vnode *realvp; 2336 struct snode *sp = VTOS(vp); 2337 int error; 2338 2339 /* 2340 * The acl(2) system calls VOP_RWLOCK on the file before setting an 2341 * ACL, but since specfs does not serialize reads and writes, this 2342 * VOP does not do anything. However, some backing file systems may 2343 * expect the lock to be held before setting an ACL, so it is taken 2344 * here privately to avoid serializing specfs reads and writes. 2345 */ 2346 if ((realvp = sp->s_realvp) != NULL) { 2347 (void) VOP_RWLOCK(realvp, V_WRITELOCK_TRUE, NULL); 2348 error = VOP_SETSECATTR(realvp, vsap, flag, cr); 2349 (void) VOP_RWUNLOCK(realvp, V_WRITELOCK_TRUE, NULL); 2350 return (error); 2351 } else 2352 return (fs_nosys()); 2353 } 2354 2355 /* 2356 * Get ACL from underlying vnode if one exists, or fabricate it from 2357 * the permissions returned by spec_getattr() otherwise. 2358 */ 2359 int 2360 spec_getsecattr(struct vnode *vp, vsecattr_t *vsap, int flag, struct cred *cr) 2361 { 2362 struct vnode *realvp; 2363 struct snode *sp = VTOS(vp); 2364 2365 if ((realvp = sp->s_realvp) != NULL) 2366 return (VOP_GETSECATTR(realvp, vsap, flag, cr)); 2367 else 2368 return (fs_fab_acl(vp, vsap, flag, cr)); 2369 } 2370 2371 int 2372 spec_pathconf(vnode_t *vp, int cmd, ulong_t *valp, cred_t *cr) 2373 { 2374 vnode_t *realvp; 2375 struct snode *sp = VTOS(vp); 2376 2377 if ((realvp = sp->s_realvp) != NULL) 2378 return (VOP_PATHCONF(realvp, cmd, valp, cr)); 2379 else 2380 return (fs_pathconf(vp, cmd, valp, cr)); 2381 } 2382