74
75
76static d_open_t fdopen;
77#define NUMFDESC 64
78
79#define CDEV_MAJOR 22
80static struct cdevsw fildesc_cdevsw =
81 { fdopen, noclose, noread, nowrite,
82 noioc, nostop, nullreset, nodevtotty,
83 seltrue, nommap, nostrat };
84
85static int finishdup __P((struct filedesc *fdp, int old, int new, register_t *retval));
86/*
87 * Descriptor management.
88 */
89struct filelist filehead; /* head of list of open files */
90int nfiles; /* actual number of open files */
91extern int cmask;
92
93/*
94 * System calls on descriptors.
95 */
96#ifndef _SYS_SYSPROTO_H_
97struct getdtablesize_args {
98 int dummy;
99};
100#endif
101/* ARGSUSED */
102int
103getdtablesize(p, uap)
104 struct proc *p;
105 struct getdtablesize_args *uap;
106{
107
108 p->p_retval[0] =
109 min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
110 return (0);
111}
112
113/*
114 * Duplicate a file descriptor to a particular value.
115 */
116#ifndef _SYS_SYSPROTO_H_
117struct dup2_args {
118 u_int from;
119 u_int to;
120};
121#endif
122/* ARGSUSED */
123int
124dup2(p, uap)
125 struct proc *p;
126 struct dup2_args *uap;
127{
128 register struct filedesc *fdp = p->p_fd;
129 register u_int old = uap->from, new = uap->to;
130 int i, error;
131
132 if (old >= fdp->fd_nfiles ||
133 fdp->fd_ofiles[old] == NULL ||
134 new >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
135 new >= maxfilesperproc)
136 return (EBADF);
137 if (old == new) {
138 p->p_retval[0] = new;
139 return (0);
140 }
141 if (new >= fdp->fd_nfiles) {
142 if ((error = fdalloc(p, new, &i)))
143 return (error);
144 if (new != i)
145 panic("dup2: fdalloc");
146 } else if (fdp->fd_ofiles[new]) {
147 if (fdp->fd_ofileflags[new] & UF_MAPPED)
148 (void) munmapfd(p, new);
149 /*
150 * dup2() must succeed even if the close has an error.
151 */
152 (void) closef(fdp->fd_ofiles[new], p);
153 }
154 return (finishdup(fdp, (int)old, (int)new, p->p_retval));
155}
156
157/*
158 * Duplicate a file descriptor.
159 */
160#ifndef _SYS_SYSPROTO_H_
161struct dup_args {
162 u_int fd;
163};
164#endif
165/* ARGSUSED */
166int
167dup(p, uap)
168 struct proc *p;
169 struct dup_args *uap;
170{
171 register struct filedesc *fdp;
172 u_int old;
173 int new, error;
174
175 old = uap->fd;
176
177#if 0
178 /*
179 * XXX Compatibility
180 */
181 if (old &~ 077) { uap->fd &= 077; return (dup2(p, uap, p->p_retval)); }
182#endif
183
184 fdp = p->p_fd;
185 if (old >= fdp->fd_nfiles || fdp->fd_ofiles[old] == NULL)
186 return (EBADF);
187 if ((error = fdalloc(p, 0, &new)))
188 return (error);
189 return (finishdup(fdp, (int)old, new, p->p_retval));
190}
191
192/*
193 * The file control system call.
194 */
195#ifndef _SYS_SYSPROTO_H_
196struct fcntl_args {
197 int fd;
198 int cmd;
199 long arg;
200};
201#endif
202/* ARGSUSED */
203int
204fcntl(p, uap)
205 struct proc *p;
206 register struct fcntl_args *uap;
207{
208 register struct filedesc *fdp = p->p_fd;
209 register struct file *fp;
210 register char *pop;
211 struct vnode *vp;
212 int i, tmp, error, flg = F_POSIX;
213 struct flock fl;
214 u_int newmin;
215
216 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
217 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
218 return (EBADF);
219 pop = &fdp->fd_ofileflags[uap->fd];
220 switch (uap->cmd) {
221
222 case F_DUPFD:
223 newmin = uap->arg;
224 if (newmin >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
225 newmin >= maxfilesperproc)
226 return (EINVAL);
227 if ((error = fdalloc(p, newmin, &i)))
228 return (error);
229 return (finishdup(fdp, uap->fd, i, p->p_retval));
230
231 case F_GETFD:
232 p->p_retval[0] = *pop & 1;
233 return (0);
234
235 case F_SETFD:
236 *pop = (*pop &~ 1) | (uap->arg & 1);
237 return (0);
238
239 case F_GETFL:
240 p->p_retval[0] = OFLAGS(fp->f_flag);
241 return (0);
242
243 case F_SETFL:
244 fp->f_flag &= ~FCNTLFLAGS;
245 fp->f_flag |= FFLAGS(uap->arg & ~O_ACCMODE) & FCNTLFLAGS;
246 tmp = fp->f_flag & FNONBLOCK;
247 error = (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
248 if (error)
249 return (error);
250 tmp = fp->f_flag & FASYNC;
251 error = (*fp->f_ops->fo_ioctl)(fp, FIOASYNC, (caddr_t)&tmp, p);
252 if (!error)
253 return (0);
254 fp->f_flag &= ~FNONBLOCK;
255 tmp = 0;
256 (void) (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
257 return (error);
258
259 case F_GETOWN:
| 75
76
77static d_open_t fdopen;
78#define NUMFDESC 64
79
80#define CDEV_MAJOR 22
81static struct cdevsw fildesc_cdevsw =
82 { fdopen, noclose, noread, nowrite,
83 noioc, nostop, nullreset, nodevtotty,
84 seltrue, nommap, nostrat };
85
86static int finishdup __P((struct filedesc *fdp, int old, int new, register_t *retval));
87/*
88 * Descriptor management.
89 */
90struct filelist filehead; /* head of list of open files */
91int nfiles; /* actual number of open files */
92extern int cmask;
93
94/*
95 * System calls on descriptors.
96 */
97#ifndef _SYS_SYSPROTO_H_
98struct getdtablesize_args {
99 int dummy;
100};
101#endif
102/* ARGSUSED */
103int
104getdtablesize(p, uap)
105 struct proc *p;
106 struct getdtablesize_args *uap;
107{
108
109 p->p_retval[0] =
110 min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
111 return (0);
112}
113
114/*
115 * Duplicate a file descriptor to a particular value.
116 */
117#ifndef _SYS_SYSPROTO_H_
118struct dup2_args {
119 u_int from;
120 u_int to;
121};
122#endif
123/* ARGSUSED */
124int
125dup2(p, uap)
126 struct proc *p;
127 struct dup2_args *uap;
128{
129 register struct filedesc *fdp = p->p_fd;
130 register u_int old = uap->from, new = uap->to;
131 int i, error;
132
133 if (old >= fdp->fd_nfiles ||
134 fdp->fd_ofiles[old] == NULL ||
135 new >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
136 new >= maxfilesperproc)
137 return (EBADF);
138 if (old == new) {
139 p->p_retval[0] = new;
140 return (0);
141 }
142 if (new >= fdp->fd_nfiles) {
143 if ((error = fdalloc(p, new, &i)))
144 return (error);
145 if (new != i)
146 panic("dup2: fdalloc");
147 } else if (fdp->fd_ofiles[new]) {
148 if (fdp->fd_ofileflags[new] & UF_MAPPED)
149 (void) munmapfd(p, new);
150 /*
151 * dup2() must succeed even if the close has an error.
152 */
153 (void) closef(fdp->fd_ofiles[new], p);
154 }
155 return (finishdup(fdp, (int)old, (int)new, p->p_retval));
156}
157
158/*
159 * Duplicate a file descriptor.
160 */
161#ifndef _SYS_SYSPROTO_H_
162struct dup_args {
163 u_int fd;
164};
165#endif
166/* ARGSUSED */
167int
168dup(p, uap)
169 struct proc *p;
170 struct dup_args *uap;
171{
172 register struct filedesc *fdp;
173 u_int old;
174 int new, error;
175
176 old = uap->fd;
177
178#if 0
179 /*
180 * XXX Compatibility
181 */
182 if (old &~ 077) { uap->fd &= 077; return (dup2(p, uap, p->p_retval)); }
183#endif
184
185 fdp = p->p_fd;
186 if (old >= fdp->fd_nfiles || fdp->fd_ofiles[old] == NULL)
187 return (EBADF);
188 if ((error = fdalloc(p, 0, &new)))
189 return (error);
190 return (finishdup(fdp, (int)old, new, p->p_retval));
191}
192
193/*
194 * The file control system call.
195 */
196#ifndef _SYS_SYSPROTO_H_
197struct fcntl_args {
198 int fd;
199 int cmd;
200 long arg;
201};
202#endif
203/* ARGSUSED */
204int
205fcntl(p, uap)
206 struct proc *p;
207 register struct fcntl_args *uap;
208{
209 register struct filedesc *fdp = p->p_fd;
210 register struct file *fp;
211 register char *pop;
212 struct vnode *vp;
213 int i, tmp, error, flg = F_POSIX;
214 struct flock fl;
215 u_int newmin;
216
217 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
218 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
219 return (EBADF);
220 pop = &fdp->fd_ofileflags[uap->fd];
221 switch (uap->cmd) {
222
223 case F_DUPFD:
224 newmin = uap->arg;
225 if (newmin >= p->p_rlimit[RLIMIT_NOFILE].rlim_cur ||
226 newmin >= maxfilesperproc)
227 return (EINVAL);
228 if ((error = fdalloc(p, newmin, &i)))
229 return (error);
230 return (finishdup(fdp, uap->fd, i, p->p_retval));
231
232 case F_GETFD:
233 p->p_retval[0] = *pop & 1;
234 return (0);
235
236 case F_SETFD:
237 *pop = (*pop &~ 1) | (uap->arg & 1);
238 return (0);
239
240 case F_GETFL:
241 p->p_retval[0] = OFLAGS(fp->f_flag);
242 return (0);
243
244 case F_SETFL:
245 fp->f_flag &= ~FCNTLFLAGS;
246 fp->f_flag |= FFLAGS(uap->arg & ~O_ACCMODE) & FCNTLFLAGS;
247 tmp = fp->f_flag & FNONBLOCK;
248 error = (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
249 if (error)
250 return (error);
251 tmp = fp->f_flag & FASYNC;
252 error = (*fp->f_ops->fo_ioctl)(fp, FIOASYNC, (caddr_t)&tmp, p);
253 if (!error)
254 return (0);
255 fp->f_flag &= ~FNONBLOCK;
256 tmp = 0;
257 (void) (*fp->f_ops->fo_ioctl)(fp, FIONBIO, (caddr_t)&tmp, p);
258 return (error);
259
260 case F_GETOWN:
|
369 * Close a file descriptor.
370 */
371#ifndef _SYS_SYSPROTO_H_
372struct close_args {
373 int fd;
374};
375#endif
376/* ARGSUSED */
377int
378close(p, uap)
379 struct proc *p;
380 struct close_args *uap;
381{
382 register struct filedesc *fdp = p->p_fd;
383 register struct file *fp;
384 register int fd = uap->fd;
385 register u_char *pf;
386
387 if ((unsigned)fd >= fdp->fd_nfiles ||
388 (fp = fdp->fd_ofiles[fd]) == NULL)
389 return (EBADF);
390 pf = (u_char *)&fdp->fd_ofileflags[fd];
391 if (*pf & UF_MAPPED)
392 (void) munmapfd(p, fd);
393 fdp->fd_ofiles[fd] = NULL;
394 while (fdp->fd_lastfile > 0 && fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
395 fdp->fd_lastfile--;
396 if (fd < fdp->fd_freefile)
397 fdp->fd_freefile = fd;
398 *pf = 0;
399 return (closef(fp, p));
400}
401
402#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
403/*
404 * Return status information about a file descriptor.
405 */
406#ifndef _SYS_SYSPROTO_H_
407struct ofstat_args {
408 int fd;
409 struct ostat *sb;
410};
411#endif
412/* ARGSUSED */
413int
414ofstat(p, uap)
415 struct proc *p;
416 register struct ofstat_args *uap;
417{
418 register struct filedesc *fdp = p->p_fd;
419 register struct file *fp;
420 struct stat ub;
421 struct ostat oub;
422 int error;
423
424 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
425 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
426 return (EBADF);
427 switch (fp->f_type) {
428
429 case DTYPE_FIFO:
430 case DTYPE_VNODE:
431 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
432 break;
433
434 case DTYPE_SOCKET:
435 error = soo_stat((struct socket *)fp->f_data, &ub);
436 break;
437
438 case DTYPE_PIPE:
439 error = pipe_stat((struct pipe *)fp->f_data, &ub);
440 break;
441
442 default:
443 panic("ofstat");
444 /*NOTREACHED*/
445 }
446 cvtstat(&ub, &oub);
447 if (error == 0)
448 error = copyout((caddr_t)&oub, (caddr_t)uap->sb, sizeof (oub));
449 return (error);
450}
451#endif /* COMPAT_43 || COMPAT_SUNOS */
452
453/*
454 * Return status information about a file descriptor.
455 */
456#ifndef _SYS_SYSPROTO_H_
457struct fstat_args {
458 int fd;
459 struct stat *sb;
460};
461#endif
462/* ARGSUSED */
463int
464fstat(p, uap)
465 struct proc *p;
466 register struct fstat_args *uap;
467{
468 register struct filedesc *fdp = p->p_fd;
469 register struct file *fp;
470 struct stat ub;
471 int error;
472
473 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
474 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
475 return (EBADF);
476 switch (fp->f_type) {
477
478 case DTYPE_FIFO:
479 case DTYPE_VNODE:
480 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
481 break;
482
483 case DTYPE_SOCKET:
484 error = soo_stat((struct socket *)fp->f_data, &ub);
485 break;
486
487 case DTYPE_PIPE:
488 error = pipe_stat((struct pipe *)fp->f_data, &ub);
489 break;
490
491 default:
492 panic("fstat");
493 /*NOTREACHED*/
494 }
495 if (error == 0)
496 error = copyout((caddr_t)&ub, (caddr_t)uap->sb, sizeof (ub));
497 return (error);
498}
499
500/*
501 * Return status information about a file descriptor.
502 */
503#ifndef _SYS_SYSPROTO_H_
504struct nfstat_args {
505 int fd;
506 struct nstat *sb;
507};
508#endif
509/* ARGSUSED */
510int
511nfstat(p, uap)
512 struct proc *p;
513 register struct nfstat_args *uap;
514{
515 register struct filedesc *fdp = p->p_fd;
516 register struct file *fp;
517 struct stat ub;
518 struct nstat nub;
519 int error;
520
521 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
522 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
523 return (EBADF);
524 switch (fp->f_type) {
525
526 case DTYPE_FIFO:
527 case DTYPE_VNODE:
528 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
529 break;
530
531 case DTYPE_SOCKET:
532 error = soo_stat((struct socket *)fp->f_data, &ub);
533 break;
534
535 case DTYPE_PIPE:
536 error = pipe_stat((struct pipe *)fp->f_data, &ub);
537 break;
538
539 default:
540 panic("fstat");
541 /*NOTREACHED*/
542 }
543 if (error == 0) {
544 cvtnstat(&ub, &nub);
545 error = copyout((caddr_t)&nub, (caddr_t)uap->sb, sizeof (nub));
546 }
547 return (error);
548}
549
550/*
551 * Return pathconf information about a file descriptor.
552 */
553#ifndef _SYS_SYSPROTO_H_
554struct fpathconf_args {
555 int fd;
556 int name;
557};
558#endif
559/* ARGSUSED */
560int
561fpathconf(p, uap)
562 struct proc *p;
563 register struct fpathconf_args *uap;
564{
565 struct filedesc *fdp = p->p_fd;
566 struct file *fp;
567 struct vnode *vp;
568
569 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
570 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
571 return (EBADF);
572 switch (fp->f_type) {
573
574 case DTYPE_PIPE:
575 case DTYPE_SOCKET:
576 if (uap->name != _PC_PIPE_BUF)
577 return (EINVAL);
578 p->p_retval[0] = PIPE_BUF;
579 return (0);
580
581 case DTYPE_FIFO:
582 case DTYPE_VNODE:
583 vp = (struct vnode *)fp->f_data;
584 return (VOP_PATHCONF(vp, uap->name, p->p_retval));
585
586 default:
587 panic("fpathconf");
588 }
589 /*NOTREACHED*/
590}
591
592/*
593 * Allocate a file descriptor for the process.
594 */
595static int fdexpand;
596SYSCTL_INT(_debug, OID_AUTO, fdexpand, CTLFLAG_RD, &fdexpand, 0, "");
597
598int
599fdalloc(p, want, result)
600 struct proc *p;
601 int want;
602 int *result;
603{
604 register struct filedesc *fdp = p->p_fd;
605 register int i;
606 int lim, last, nfiles;
607 struct file **newofile;
608 char *newofileflags;
609
610 /*
611 * Search for a free descriptor starting at the higher
612 * of want or fd_freefile. If that fails, consider
613 * expanding the ofile array.
614 */
615 lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
616 for (;;) {
617 last = min(fdp->fd_nfiles, lim);
618 if ((i = want) < fdp->fd_freefile)
619 i = fdp->fd_freefile;
620 for (; i < last; i++) {
621 if (fdp->fd_ofiles[i] == NULL) {
622 fdp->fd_ofileflags[i] = 0;
623 if (i > fdp->fd_lastfile)
624 fdp->fd_lastfile = i;
625 if (want <= fdp->fd_freefile)
626 fdp->fd_freefile = i;
627 *result = i;
628 return (0);
629 }
630 }
631
632 /*
633 * No space in current array. Expand?
634 */
635 if (fdp->fd_nfiles >= lim)
636 return (EMFILE);
637 if (fdp->fd_nfiles < NDEXTENT)
638 nfiles = NDEXTENT;
639 else
640 nfiles = 2 * fdp->fd_nfiles;
641 MALLOC(newofile, struct file **, nfiles * OFILESIZE,
642 M_FILEDESC, M_WAITOK);
643 newofileflags = (char *) &newofile[nfiles];
644 /*
645 * Copy the existing ofile and ofileflags arrays
646 * and zero the new portion of each array.
647 */
648 bcopy(fdp->fd_ofiles, newofile,
649 (i = sizeof(struct file *) * fdp->fd_nfiles));
650 bzero((char *)newofile + i, nfiles * sizeof(struct file *) - i);
651 bcopy(fdp->fd_ofileflags, newofileflags,
652 (i = sizeof(char) * fdp->fd_nfiles));
653 bzero(newofileflags + i, nfiles * sizeof(char) - i);
654 if (fdp->fd_nfiles > NDFILE)
655 FREE(fdp->fd_ofiles, M_FILEDESC);
656 fdp->fd_ofiles = newofile;
657 fdp->fd_ofileflags = newofileflags;
658 fdp->fd_nfiles = nfiles;
659 fdexpand++;
660 }
661 return (0);
662}
663
664/*
665 * Check to see whether n user file descriptors
666 * are available to the process p.
667 */
668int
669fdavail(p, n)
670 struct proc *p;
671 register int n;
672{
673 register struct filedesc *fdp = p->p_fd;
674 register struct file **fpp;
675 register int i, lim, last;
676
677 lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
678 if ((i = lim - fdp->fd_nfiles) > 0 && (n -= i) <= 0)
679 return (1);
680
681 last = min(fdp->fd_nfiles, lim);
682 fpp = &fdp->fd_ofiles[fdp->fd_freefile];
683 for (i = last - fdp->fd_freefile; --i >= 0; fpp++)
684 if (*fpp == NULL && --n <= 0)
685 return (1);
686 return (0);
687}
688
689/*
690 * Create a new open file structure and allocate
691 * a file decriptor for the process that refers to it.
692 */
693int
694falloc(p, resultfp, resultfd)
695 register struct proc *p;
696 struct file **resultfp;
697 int *resultfd;
698{
699 register struct file *fp, *fq;
700 int error, i;
701
702 if ((error = fdalloc(p, 0, &i)))
703 return (error);
704 if (nfiles >= maxfiles) {
705 tablefull("file");
706 return (ENFILE);
707 }
708 /*
709 * Allocate a new file descriptor.
710 * If the process has file descriptor zero open, add to the list
711 * of open files at that point, otherwise put it at the front of
712 * the list of open files.
713 */
714 nfiles++;
715 MALLOC(fp, struct file *, sizeof(struct file), M_FILE, M_WAITOK);
716 bzero(fp, sizeof(struct file));
717 if ((fq = p->p_fd->fd_ofiles[0])) {
718 LIST_INSERT_AFTER(fq, fp, f_list);
719 } else {
720 LIST_INSERT_HEAD(&filehead, fp, f_list);
721 }
722 p->p_fd->fd_ofiles[i] = fp;
723 fp->f_count = 1;
724 fp->f_cred = p->p_ucred;
725 fp->f_seqcount = 1;
726 crhold(fp->f_cred);
727 if (resultfp)
728 *resultfp = fp;
729 if (resultfd)
730 *resultfd = i;
731 return (0);
732}
733
734/*
735 * Free a file descriptor.
736 */
737void
738ffree(fp)
739 register struct file *fp;
740{
741 LIST_REMOVE(fp, f_list);
742 crfree(fp->f_cred);
743#ifdef DIAGNOSTIC
744 fp->f_count = 0;
745#endif
746 nfiles--;
747 FREE(fp, M_FILE);
748}
749
750/*
751 * Build a new filedesc structure.
752 */
753struct filedesc *
754fdinit(p)
755 struct proc *p;
756{
757 register struct filedesc0 *newfdp;
758 register struct filedesc *fdp = p->p_fd;
759
760 MALLOC(newfdp, struct filedesc0 *, sizeof(struct filedesc0),
761 M_FILEDESC, M_WAITOK);
762 bzero(newfdp, sizeof(struct filedesc0));
763 newfdp->fd_fd.fd_cdir = fdp->fd_cdir;
764 VREF(newfdp->fd_fd.fd_cdir);
765 newfdp->fd_fd.fd_rdir = fdp->fd_rdir;
766 VREF(newfdp->fd_fd.fd_rdir);
767
768 /* Create the file descriptor table. */
769 newfdp->fd_fd.fd_refcnt = 1;
770 newfdp->fd_fd.fd_cmask = cmask;
771 newfdp->fd_fd.fd_ofiles = newfdp->fd_dfiles;
772 newfdp->fd_fd.fd_ofileflags = newfdp->fd_dfileflags;
773 newfdp->fd_fd.fd_nfiles = NDFILE;
774
775 newfdp->fd_fd.fd_freefile = 0;
776 newfdp->fd_fd.fd_lastfile = 0;
777
778 return (&newfdp->fd_fd);
779}
780
781/*
782 * Share a filedesc structure.
783 */
784struct filedesc *
785fdshare(p)
786 struct proc *p;
787{
788 p->p_fd->fd_refcnt++;
789 return (p->p_fd);
790}
791
792/*
793 * Copy a filedesc structure.
794 */
795struct filedesc *
796fdcopy(p)
797 struct proc *p;
798{
799 register struct filedesc *newfdp, *fdp = p->p_fd;
800 register struct file **fpp;
801 register int i;
802
803/*
804 * Certain daemons might not have file descriptors
805 */
806 if (fdp == NULL)
807 return NULL;
808
809 MALLOC(newfdp, struct filedesc *, sizeof(struct filedesc0),
810 M_FILEDESC, M_WAITOK);
811 bcopy(fdp, newfdp, sizeof(struct filedesc));
812 VREF(newfdp->fd_cdir);
813 VREF(newfdp->fd_rdir);
814 newfdp->fd_refcnt = 1;
815
816 /*
817 * If the number of open files fits in the internal arrays
818 * of the open file structure, use them, otherwise allocate
819 * additional memory for the number of descriptors currently
820 * in use.
821 */
822 if (newfdp->fd_lastfile < NDFILE) {
823 newfdp->fd_ofiles = ((struct filedesc0 *) newfdp)->fd_dfiles;
824 newfdp->fd_ofileflags =
825 ((struct filedesc0 *) newfdp)->fd_dfileflags;
826 i = NDFILE;
827 } else {
828 /*
829 * Compute the smallest multiple of NDEXTENT needed
830 * for the file descriptors currently in use,
831 * allowing the table to shrink.
832 */
833 i = newfdp->fd_nfiles;
834 while (i > 2 * NDEXTENT && i > newfdp->fd_lastfile * 2)
835 i /= 2;
836 MALLOC(newfdp->fd_ofiles, struct file **, i * OFILESIZE,
837 M_FILEDESC, M_WAITOK);
838 newfdp->fd_ofileflags = (char *) &newfdp->fd_ofiles[i];
839 }
840 newfdp->fd_nfiles = i;
841 bcopy(fdp->fd_ofiles, newfdp->fd_ofiles, i * sizeof(struct file **));
842 bcopy(fdp->fd_ofileflags, newfdp->fd_ofileflags, i * sizeof(char));
843 fpp = newfdp->fd_ofiles;
844 for (i = newfdp->fd_lastfile; i-- >= 0; fpp++)
845 if (*fpp != NULL)
846 (*fpp)->f_count++;
847 return (newfdp);
848}
849
850/*
851 * Release a filedesc structure.
852 */
853void
854fdfree(p)
855 struct proc *p;
856{
857 register struct filedesc *fdp = p->p_fd;
858 struct file **fpp;
859 register int i;
860
861/*
862 * Certain daemons might not have file descriptors
863 */
864 if (fdp == NULL)
865 return;
866
867 if (--fdp->fd_refcnt > 0)
868 return;
869 fpp = fdp->fd_ofiles;
870 for (i = fdp->fd_lastfile; i-- >= 0; fpp++)
871 if (*fpp)
872 (void) closef(*fpp, p);
873 if (fdp->fd_nfiles > NDFILE)
874 FREE(fdp->fd_ofiles, M_FILEDESC);
875 vrele(fdp->fd_cdir);
876 vrele(fdp->fd_rdir);
877 FREE(fdp, M_FILEDESC);
878}
879
880/*
881 * Close any files on exec?
882 */
883void
884fdcloseexec(p)
885 struct proc *p;
886{
887 struct filedesc *fdp = p->p_fd;
888 struct file **fpp;
889 char *fdfp;
890 register int i;
891
892/*
893 * Certain daemons might not have file descriptors
894 */
895 if (fdp == NULL)
896 return;
897
898 fpp = fdp->fd_ofiles;
899 fdfp = fdp->fd_ofileflags;
900 for (i = 0; i <= fdp->fd_lastfile; i++, fpp++, fdfp++)
901 if (*fpp != NULL && (*fdfp & UF_EXCLOSE)) {
902 if (*fdfp & UF_MAPPED)
903 (void) munmapfd(p, i);
904 (void) closef(*fpp, p);
905 *fpp = NULL;
906 *fdfp = 0;
907 if (i < fdp->fd_freefile)
908 fdp->fd_freefile = i;
909 }
910 while (fdp->fd_lastfile > 0 && fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
911 fdp->fd_lastfile--;
912}
913
914/*
915 * Internal form of close.
916 * Decrement reference count on file structure.
917 * Note: p may be NULL when closing a file
918 * that was being passed in a message.
919 */
920int
921closef(fp, p)
922 register struct file *fp;
923 register struct proc *p;
924{
925 struct vnode *vp;
926 struct flock lf;
927 int error;
928
929 if (fp == NULL)
930 return (0);
931 /*
932 * POSIX record locking dictates that any close releases ALL
933 * locks owned by this process. This is handled by setting
934 * a flag in the unlock to free ONLY locks obeying POSIX
935 * semantics, and not to free BSD-style file locks.
936 * If the descriptor was in a message, POSIX-style locks
937 * aren't passed with the descriptor.
938 */
939 if (p && (p->p_flag & P_ADVLOCK) && fp->f_type == DTYPE_VNODE) {
940 lf.l_whence = SEEK_SET;
941 lf.l_start = 0;
942 lf.l_len = 0;
943 lf.l_type = F_UNLCK;
944 vp = (struct vnode *)fp->f_data;
945 (void) VOP_ADVLOCK(vp, (caddr_t)p, F_UNLCK, &lf, F_POSIX);
946 }
947 if (--fp->f_count > 0)
948 return (0);
949 if (fp->f_count < 0)
950 panic("closef: count < 0");
951 if ((fp->f_flag & FHASLOCK) && fp->f_type == DTYPE_VNODE) {
952 lf.l_whence = SEEK_SET;
953 lf.l_start = 0;
954 lf.l_len = 0;
955 lf.l_type = F_UNLCK;
956 vp = (struct vnode *)fp->f_data;
957 (void) VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK);
958 }
959 if (fp->f_ops)
960 error = (*fp->f_ops->fo_close)(fp, p);
961 else
962 error = 0;
963 ffree(fp);
964 return (error);
965}
966
967/*
968 * Apply an advisory lock on a file descriptor.
969 *
970 * Just attempt to get a record lock of the requested type on
971 * the entire file (l_whence = SEEK_SET, l_start = 0, l_len = 0).
972 */
973#ifndef _SYS_SYSPROTO_H_
974struct flock_args {
975 int fd;
976 int how;
977};
978#endif
979/* ARGSUSED */
980int
981flock(p, uap)
982 struct proc *p;
983 register struct flock_args *uap;
984{
985 register struct filedesc *fdp = p->p_fd;
986 register struct file *fp;
987 struct vnode *vp;
988 struct flock lf;
989
990 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
991 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
992 return (EBADF);
993 if (fp->f_type != DTYPE_VNODE)
994 return (EOPNOTSUPP);
995 vp = (struct vnode *)fp->f_data;
996 lf.l_whence = SEEK_SET;
997 lf.l_start = 0;
998 lf.l_len = 0;
999 if (uap->how & LOCK_UN) {
1000 lf.l_type = F_UNLCK;
1001 fp->f_flag &= ~FHASLOCK;
1002 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK));
1003 }
1004 if (uap->how & LOCK_EX)
1005 lf.l_type = F_WRLCK;
1006 else if (uap->how & LOCK_SH)
1007 lf.l_type = F_RDLCK;
1008 else
1009 return (EBADF);
1010 fp->f_flag |= FHASLOCK;
1011 if (uap->how & LOCK_NB)
1012 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf, F_FLOCK));
1013 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf, F_FLOCK|F_WAIT));
1014}
1015
1016/*
1017 * File Descriptor pseudo-device driver (/dev/fd/).
1018 *
1019 * Opening minor device N dup()s the file (if any) connected to file
1020 * descriptor N belonging to the calling process. Note that this driver
1021 * consists of only the ``open()'' routine, because all subsequent
1022 * references to this file will be direct to the other driver.
1023 */
1024/* ARGSUSED */
1025static int
1026fdopen(dev, mode, type, p)
1027 dev_t dev;
1028 int mode, type;
1029 struct proc *p;
1030{
1031
1032 /*
1033 * XXX Kludge: set curproc->p_dupfd to contain the value of the
1034 * the file descriptor being sought for duplication. The error
1035 * return ensures that the vnode for this device will be released
1036 * by vn_open. Open will detect this special error and take the
1037 * actions in dupfdopen below. Other callers of vn_open or VOP_OPEN
1038 * will simply report the error.
1039 */
1040 p->p_dupfd = minor(dev);
1041 return (ENODEV);
1042}
1043
1044/*
1045 * Duplicate the specified descriptor to a free descriptor.
1046 */
1047int
1048dupfdopen(fdp, indx, dfd, mode, error)
1049 register struct filedesc *fdp;
1050 register int indx, dfd;
1051 int mode;
1052 int error;
1053{
1054 register struct file *wfp;
1055 struct file *fp;
1056
1057 /*
1058 * If the to-be-dup'd fd number is greater than the allowed number
1059 * of file descriptors, or the fd to be dup'd has already been
1060 * closed, reject. Note, check for new == old is necessary as
1061 * falloc could allocate an already closed to-be-dup'd descriptor
1062 * as the new descriptor.
1063 */
1064 fp = fdp->fd_ofiles[indx];
1065 if ((u_int)dfd >= fdp->fd_nfiles ||
1066 (wfp = fdp->fd_ofiles[dfd]) == NULL || fp == wfp)
1067 return (EBADF);
1068
1069 /*
1070 * There are two cases of interest here.
1071 *
1072 * For ENODEV simply dup (dfd) to file descriptor
1073 * (indx) and return.
1074 *
1075 * For ENXIO steal away the file structure from (dfd) and
1076 * store it in (indx). (dfd) is effectively closed by
1077 * this operation.
1078 *
1079 * Any other error code is just returned.
1080 */
1081 switch (error) {
1082 case ENODEV:
1083 /*
1084 * Check that the mode the file is being opened for is a
1085 * subset of the mode of the existing descriptor.
1086 */
1087 if (((mode & (FREAD|FWRITE)) | wfp->f_flag) != wfp->f_flag)
1088 return (EACCES);
1089 fdp->fd_ofiles[indx] = wfp;
1090 fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1091 wfp->f_count++;
1092 if (indx > fdp->fd_lastfile)
1093 fdp->fd_lastfile = indx;
1094 return (0);
1095
1096 case ENXIO:
1097 /*
1098 * Steal away the file pointer from dfd, and stuff it into indx.
1099 */
1100 fdp->fd_ofiles[indx] = fdp->fd_ofiles[dfd];
1101 fdp->fd_ofiles[dfd] = NULL;
1102 fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1103 fdp->fd_ofileflags[dfd] = 0;
1104 /*
1105 * Complete the clean up of the filedesc structure by
1106 * recomputing the various hints.
1107 */
1108 if (indx > fdp->fd_lastfile)
1109 fdp->fd_lastfile = indx;
1110 else
1111 while (fdp->fd_lastfile > 0 &&
1112 fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
1113 fdp->fd_lastfile--;
1114 if (dfd < fdp->fd_freefile)
1115 fdp->fd_freefile = dfd;
1116 return (0);
1117
1118 default:
1119 return (error);
1120 }
1121 /* NOTREACHED */
1122}
1123
1124/*
1125 * Get file structures.
1126 */
1127static int
1128sysctl_kern_file SYSCTL_HANDLER_ARGS
1129{
1130 int error;
1131 struct file *fp;
1132
1133 if (!req->oldptr) {
1134 /*
1135 * overestimate by 10 files
1136 */
1137 return (SYSCTL_OUT(req, 0, sizeof(filehead) +
1138 (nfiles + 10) * sizeof(struct file)));
1139 }
1140
1141 error = SYSCTL_OUT(req, (caddr_t)&filehead, sizeof(filehead));
1142 if (error)
1143 return (error);
1144
1145 /*
1146 * followed by an array of file structures
1147 */
1148 for (fp = filehead.lh_first; fp != NULL; fp = fp->f_list.le_next) {
1149 error = SYSCTL_OUT(req, (caddr_t)fp, sizeof (struct file));
1150 if (error)
1151 return (error);
1152 }
1153 return (0);
1154}
1155
1156SYSCTL_PROC(_kern, KERN_FILE, file, CTLTYPE_OPAQUE|CTLFLAG_RD,
1157 0, 0, sysctl_kern_file, "S,file", "");
1158
1159SYSCTL_INT(_kern, KERN_MAXFILESPERPROC, maxfilesperproc,
1160 CTLFLAG_RW, &maxfilesperproc, 0, "");
1161
1162SYSCTL_INT(_kern, KERN_MAXFILES, maxfiles, CTLFLAG_RW, &maxfiles, 0, "");
1163
1164static fildesc_devsw_installed = 0;
1165#ifdef DEVFS
1166static void *devfs_token_stdin;
1167static void *devfs_token_stdout;
1168static void *devfs_token_stderr;
1169static void *devfs_token_fildesc[NUMFDESC];
1170#endif
1171
1172static void fildesc_drvinit(void *unused)
1173{
1174 dev_t dev;
1175#ifdef DEVFS
1176 int fd;
1177#endif
1178
1179 if( ! fildesc_devsw_installed ) {
1180 dev = makedev(CDEV_MAJOR,0);
1181 cdevsw_add(&dev,&fildesc_cdevsw,NULL);
1182 fildesc_devsw_installed = 1;
1183#ifdef DEVFS
1184 for (fd = 0; fd < NUMFDESC; fd++)
1185 devfs_token_fildesc[fd] =
1186 devfs_add_devswf(&fildesc_cdevsw, fd, DV_CHR,
1187 UID_BIN, GID_BIN, 0666,
1188 "fd/%d", fd);
1189 devfs_token_stdin =
1190 devfs_add_devswf(&fildesc_cdevsw, 0, DV_CHR,
1191 UID_ROOT, GID_WHEEL, 0666,
1192 "stdin");
1193 devfs_token_stdout =
1194 devfs_add_devswf(&fildesc_cdevsw, 1, DV_CHR,
1195 UID_ROOT, GID_WHEEL, 0666,
1196 "stdout");
1197 devfs_token_stderr =
1198 devfs_add_devswf(&fildesc_cdevsw, 2, DV_CHR,
1199 UID_ROOT, GID_WHEEL, 0666,
1200 "stderr");
1201#endif
1202 }
1203}
1204
1205SYSINIT(fildescdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR,
1206 fildesc_drvinit,NULL)
1207
1208
| 471 * Close a file descriptor.
472 */
473#ifndef _SYS_SYSPROTO_H_
474struct close_args {
475 int fd;
476};
477#endif
478/* ARGSUSED */
479int
480close(p, uap)
481 struct proc *p;
482 struct close_args *uap;
483{
484 register struct filedesc *fdp = p->p_fd;
485 register struct file *fp;
486 register int fd = uap->fd;
487 register u_char *pf;
488
489 if ((unsigned)fd >= fdp->fd_nfiles ||
490 (fp = fdp->fd_ofiles[fd]) == NULL)
491 return (EBADF);
492 pf = (u_char *)&fdp->fd_ofileflags[fd];
493 if (*pf & UF_MAPPED)
494 (void) munmapfd(p, fd);
495 fdp->fd_ofiles[fd] = NULL;
496 while (fdp->fd_lastfile > 0 && fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
497 fdp->fd_lastfile--;
498 if (fd < fdp->fd_freefile)
499 fdp->fd_freefile = fd;
500 *pf = 0;
501 return (closef(fp, p));
502}
503
504#if defined(COMPAT_43) || defined(COMPAT_SUNOS)
505/*
506 * Return status information about a file descriptor.
507 */
508#ifndef _SYS_SYSPROTO_H_
509struct ofstat_args {
510 int fd;
511 struct ostat *sb;
512};
513#endif
514/* ARGSUSED */
515int
516ofstat(p, uap)
517 struct proc *p;
518 register struct ofstat_args *uap;
519{
520 register struct filedesc *fdp = p->p_fd;
521 register struct file *fp;
522 struct stat ub;
523 struct ostat oub;
524 int error;
525
526 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
527 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
528 return (EBADF);
529 switch (fp->f_type) {
530
531 case DTYPE_FIFO:
532 case DTYPE_VNODE:
533 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
534 break;
535
536 case DTYPE_SOCKET:
537 error = soo_stat((struct socket *)fp->f_data, &ub);
538 break;
539
540 case DTYPE_PIPE:
541 error = pipe_stat((struct pipe *)fp->f_data, &ub);
542 break;
543
544 default:
545 panic("ofstat");
546 /*NOTREACHED*/
547 }
548 cvtstat(&ub, &oub);
549 if (error == 0)
550 error = copyout((caddr_t)&oub, (caddr_t)uap->sb, sizeof (oub));
551 return (error);
552}
553#endif /* COMPAT_43 || COMPAT_SUNOS */
554
555/*
556 * Return status information about a file descriptor.
557 */
558#ifndef _SYS_SYSPROTO_H_
559struct fstat_args {
560 int fd;
561 struct stat *sb;
562};
563#endif
564/* ARGSUSED */
565int
566fstat(p, uap)
567 struct proc *p;
568 register struct fstat_args *uap;
569{
570 register struct filedesc *fdp = p->p_fd;
571 register struct file *fp;
572 struct stat ub;
573 int error;
574
575 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
576 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
577 return (EBADF);
578 switch (fp->f_type) {
579
580 case DTYPE_FIFO:
581 case DTYPE_VNODE:
582 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
583 break;
584
585 case DTYPE_SOCKET:
586 error = soo_stat((struct socket *)fp->f_data, &ub);
587 break;
588
589 case DTYPE_PIPE:
590 error = pipe_stat((struct pipe *)fp->f_data, &ub);
591 break;
592
593 default:
594 panic("fstat");
595 /*NOTREACHED*/
596 }
597 if (error == 0)
598 error = copyout((caddr_t)&ub, (caddr_t)uap->sb, sizeof (ub));
599 return (error);
600}
601
602/*
603 * Return status information about a file descriptor.
604 */
605#ifndef _SYS_SYSPROTO_H_
606struct nfstat_args {
607 int fd;
608 struct nstat *sb;
609};
610#endif
611/* ARGSUSED */
612int
613nfstat(p, uap)
614 struct proc *p;
615 register struct nfstat_args *uap;
616{
617 register struct filedesc *fdp = p->p_fd;
618 register struct file *fp;
619 struct stat ub;
620 struct nstat nub;
621 int error;
622
623 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
624 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
625 return (EBADF);
626 switch (fp->f_type) {
627
628 case DTYPE_FIFO:
629 case DTYPE_VNODE:
630 error = vn_stat((struct vnode *)fp->f_data, &ub, p);
631 break;
632
633 case DTYPE_SOCKET:
634 error = soo_stat((struct socket *)fp->f_data, &ub);
635 break;
636
637 case DTYPE_PIPE:
638 error = pipe_stat((struct pipe *)fp->f_data, &ub);
639 break;
640
641 default:
642 panic("fstat");
643 /*NOTREACHED*/
644 }
645 if (error == 0) {
646 cvtnstat(&ub, &nub);
647 error = copyout((caddr_t)&nub, (caddr_t)uap->sb, sizeof (nub));
648 }
649 return (error);
650}
651
652/*
653 * Return pathconf information about a file descriptor.
654 */
655#ifndef _SYS_SYSPROTO_H_
656struct fpathconf_args {
657 int fd;
658 int name;
659};
660#endif
661/* ARGSUSED */
662int
663fpathconf(p, uap)
664 struct proc *p;
665 register struct fpathconf_args *uap;
666{
667 struct filedesc *fdp = p->p_fd;
668 struct file *fp;
669 struct vnode *vp;
670
671 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
672 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
673 return (EBADF);
674 switch (fp->f_type) {
675
676 case DTYPE_PIPE:
677 case DTYPE_SOCKET:
678 if (uap->name != _PC_PIPE_BUF)
679 return (EINVAL);
680 p->p_retval[0] = PIPE_BUF;
681 return (0);
682
683 case DTYPE_FIFO:
684 case DTYPE_VNODE:
685 vp = (struct vnode *)fp->f_data;
686 return (VOP_PATHCONF(vp, uap->name, p->p_retval));
687
688 default:
689 panic("fpathconf");
690 }
691 /*NOTREACHED*/
692}
693
694/*
695 * Allocate a file descriptor for the process.
696 */
697static int fdexpand;
698SYSCTL_INT(_debug, OID_AUTO, fdexpand, CTLFLAG_RD, &fdexpand, 0, "");
699
700int
701fdalloc(p, want, result)
702 struct proc *p;
703 int want;
704 int *result;
705{
706 register struct filedesc *fdp = p->p_fd;
707 register int i;
708 int lim, last, nfiles;
709 struct file **newofile;
710 char *newofileflags;
711
712 /*
713 * Search for a free descriptor starting at the higher
714 * of want or fd_freefile. If that fails, consider
715 * expanding the ofile array.
716 */
717 lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
718 for (;;) {
719 last = min(fdp->fd_nfiles, lim);
720 if ((i = want) < fdp->fd_freefile)
721 i = fdp->fd_freefile;
722 for (; i < last; i++) {
723 if (fdp->fd_ofiles[i] == NULL) {
724 fdp->fd_ofileflags[i] = 0;
725 if (i > fdp->fd_lastfile)
726 fdp->fd_lastfile = i;
727 if (want <= fdp->fd_freefile)
728 fdp->fd_freefile = i;
729 *result = i;
730 return (0);
731 }
732 }
733
734 /*
735 * No space in current array. Expand?
736 */
737 if (fdp->fd_nfiles >= lim)
738 return (EMFILE);
739 if (fdp->fd_nfiles < NDEXTENT)
740 nfiles = NDEXTENT;
741 else
742 nfiles = 2 * fdp->fd_nfiles;
743 MALLOC(newofile, struct file **, nfiles * OFILESIZE,
744 M_FILEDESC, M_WAITOK);
745 newofileflags = (char *) &newofile[nfiles];
746 /*
747 * Copy the existing ofile and ofileflags arrays
748 * and zero the new portion of each array.
749 */
750 bcopy(fdp->fd_ofiles, newofile,
751 (i = sizeof(struct file *) * fdp->fd_nfiles));
752 bzero((char *)newofile + i, nfiles * sizeof(struct file *) - i);
753 bcopy(fdp->fd_ofileflags, newofileflags,
754 (i = sizeof(char) * fdp->fd_nfiles));
755 bzero(newofileflags + i, nfiles * sizeof(char) - i);
756 if (fdp->fd_nfiles > NDFILE)
757 FREE(fdp->fd_ofiles, M_FILEDESC);
758 fdp->fd_ofiles = newofile;
759 fdp->fd_ofileflags = newofileflags;
760 fdp->fd_nfiles = nfiles;
761 fdexpand++;
762 }
763 return (0);
764}
765
766/*
767 * Check to see whether n user file descriptors
768 * are available to the process p.
769 */
770int
771fdavail(p, n)
772 struct proc *p;
773 register int n;
774{
775 register struct filedesc *fdp = p->p_fd;
776 register struct file **fpp;
777 register int i, lim, last;
778
779 lim = min((int)p->p_rlimit[RLIMIT_NOFILE].rlim_cur, maxfilesperproc);
780 if ((i = lim - fdp->fd_nfiles) > 0 && (n -= i) <= 0)
781 return (1);
782
783 last = min(fdp->fd_nfiles, lim);
784 fpp = &fdp->fd_ofiles[fdp->fd_freefile];
785 for (i = last - fdp->fd_freefile; --i >= 0; fpp++)
786 if (*fpp == NULL && --n <= 0)
787 return (1);
788 return (0);
789}
790
791/*
792 * Create a new open file structure and allocate
793 * a file decriptor for the process that refers to it.
794 */
795int
796falloc(p, resultfp, resultfd)
797 register struct proc *p;
798 struct file **resultfp;
799 int *resultfd;
800{
801 register struct file *fp, *fq;
802 int error, i;
803
804 if ((error = fdalloc(p, 0, &i)))
805 return (error);
806 if (nfiles >= maxfiles) {
807 tablefull("file");
808 return (ENFILE);
809 }
810 /*
811 * Allocate a new file descriptor.
812 * If the process has file descriptor zero open, add to the list
813 * of open files at that point, otherwise put it at the front of
814 * the list of open files.
815 */
816 nfiles++;
817 MALLOC(fp, struct file *, sizeof(struct file), M_FILE, M_WAITOK);
818 bzero(fp, sizeof(struct file));
819 if ((fq = p->p_fd->fd_ofiles[0])) {
820 LIST_INSERT_AFTER(fq, fp, f_list);
821 } else {
822 LIST_INSERT_HEAD(&filehead, fp, f_list);
823 }
824 p->p_fd->fd_ofiles[i] = fp;
825 fp->f_count = 1;
826 fp->f_cred = p->p_ucred;
827 fp->f_seqcount = 1;
828 crhold(fp->f_cred);
829 if (resultfp)
830 *resultfp = fp;
831 if (resultfd)
832 *resultfd = i;
833 return (0);
834}
835
836/*
837 * Free a file descriptor.
838 */
839void
840ffree(fp)
841 register struct file *fp;
842{
843 LIST_REMOVE(fp, f_list);
844 crfree(fp->f_cred);
845#ifdef DIAGNOSTIC
846 fp->f_count = 0;
847#endif
848 nfiles--;
849 FREE(fp, M_FILE);
850}
851
852/*
853 * Build a new filedesc structure.
854 */
855struct filedesc *
856fdinit(p)
857 struct proc *p;
858{
859 register struct filedesc0 *newfdp;
860 register struct filedesc *fdp = p->p_fd;
861
862 MALLOC(newfdp, struct filedesc0 *, sizeof(struct filedesc0),
863 M_FILEDESC, M_WAITOK);
864 bzero(newfdp, sizeof(struct filedesc0));
865 newfdp->fd_fd.fd_cdir = fdp->fd_cdir;
866 VREF(newfdp->fd_fd.fd_cdir);
867 newfdp->fd_fd.fd_rdir = fdp->fd_rdir;
868 VREF(newfdp->fd_fd.fd_rdir);
869
870 /* Create the file descriptor table. */
871 newfdp->fd_fd.fd_refcnt = 1;
872 newfdp->fd_fd.fd_cmask = cmask;
873 newfdp->fd_fd.fd_ofiles = newfdp->fd_dfiles;
874 newfdp->fd_fd.fd_ofileflags = newfdp->fd_dfileflags;
875 newfdp->fd_fd.fd_nfiles = NDFILE;
876
877 newfdp->fd_fd.fd_freefile = 0;
878 newfdp->fd_fd.fd_lastfile = 0;
879
880 return (&newfdp->fd_fd);
881}
882
883/*
884 * Share a filedesc structure.
885 */
886struct filedesc *
887fdshare(p)
888 struct proc *p;
889{
890 p->p_fd->fd_refcnt++;
891 return (p->p_fd);
892}
893
894/*
895 * Copy a filedesc structure.
896 */
897struct filedesc *
898fdcopy(p)
899 struct proc *p;
900{
901 register struct filedesc *newfdp, *fdp = p->p_fd;
902 register struct file **fpp;
903 register int i;
904
905/*
906 * Certain daemons might not have file descriptors
907 */
908 if (fdp == NULL)
909 return NULL;
910
911 MALLOC(newfdp, struct filedesc *, sizeof(struct filedesc0),
912 M_FILEDESC, M_WAITOK);
913 bcopy(fdp, newfdp, sizeof(struct filedesc));
914 VREF(newfdp->fd_cdir);
915 VREF(newfdp->fd_rdir);
916 newfdp->fd_refcnt = 1;
917
918 /*
919 * If the number of open files fits in the internal arrays
920 * of the open file structure, use them, otherwise allocate
921 * additional memory for the number of descriptors currently
922 * in use.
923 */
924 if (newfdp->fd_lastfile < NDFILE) {
925 newfdp->fd_ofiles = ((struct filedesc0 *) newfdp)->fd_dfiles;
926 newfdp->fd_ofileflags =
927 ((struct filedesc0 *) newfdp)->fd_dfileflags;
928 i = NDFILE;
929 } else {
930 /*
931 * Compute the smallest multiple of NDEXTENT needed
932 * for the file descriptors currently in use,
933 * allowing the table to shrink.
934 */
935 i = newfdp->fd_nfiles;
936 while (i > 2 * NDEXTENT && i > newfdp->fd_lastfile * 2)
937 i /= 2;
938 MALLOC(newfdp->fd_ofiles, struct file **, i * OFILESIZE,
939 M_FILEDESC, M_WAITOK);
940 newfdp->fd_ofileflags = (char *) &newfdp->fd_ofiles[i];
941 }
942 newfdp->fd_nfiles = i;
943 bcopy(fdp->fd_ofiles, newfdp->fd_ofiles, i * sizeof(struct file **));
944 bcopy(fdp->fd_ofileflags, newfdp->fd_ofileflags, i * sizeof(char));
945 fpp = newfdp->fd_ofiles;
946 for (i = newfdp->fd_lastfile; i-- >= 0; fpp++)
947 if (*fpp != NULL)
948 (*fpp)->f_count++;
949 return (newfdp);
950}
951
952/*
953 * Release a filedesc structure.
954 */
955void
956fdfree(p)
957 struct proc *p;
958{
959 register struct filedesc *fdp = p->p_fd;
960 struct file **fpp;
961 register int i;
962
963/*
964 * Certain daemons might not have file descriptors
965 */
966 if (fdp == NULL)
967 return;
968
969 if (--fdp->fd_refcnt > 0)
970 return;
971 fpp = fdp->fd_ofiles;
972 for (i = fdp->fd_lastfile; i-- >= 0; fpp++)
973 if (*fpp)
974 (void) closef(*fpp, p);
975 if (fdp->fd_nfiles > NDFILE)
976 FREE(fdp->fd_ofiles, M_FILEDESC);
977 vrele(fdp->fd_cdir);
978 vrele(fdp->fd_rdir);
979 FREE(fdp, M_FILEDESC);
980}
981
982/*
983 * Close any files on exec?
984 */
985void
986fdcloseexec(p)
987 struct proc *p;
988{
989 struct filedesc *fdp = p->p_fd;
990 struct file **fpp;
991 char *fdfp;
992 register int i;
993
994/*
995 * Certain daemons might not have file descriptors
996 */
997 if (fdp == NULL)
998 return;
999
1000 fpp = fdp->fd_ofiles;
1001 fdfp = fdp->fd_ofileflags;
1002 for (i = 0; i <= fdp->fd_lastfile; i++, fpp++, fdfp++)
1003 if (*fpp != NULL && (*fdfp & UF_EXCLOSE)) {
1004 if (*fdfp & UF_MAPPED)
1005 (void) munmapfd(p, i);
1006 (void) closef(*fpp, p);
1007 *fpp = NULL;
1008 *fdfp = 0;
1009 if (i < fdp->fd_freefile)
1010 fdp->fd_freefile = i;
1011 }
1012 while (fdp->fd_lastfile > 0 && fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
1013 fdp->fd_lastfile--;
1014}
1015
1016/*
1017 * Internal form of close.
1018 * Decrement reference count on file structure.
1019 * Note: p may be NULL when closing a file
1020 * that was being passed in a message.
1021 */
1022int
1023closef(fp, p)
1024 register struct file *fp;
1025 register struct proc *p;
1026{
1027 struct vnode *vp;
1028 struct flock lf;
1029 int error;
1030
1031 if (fp == NULL)
1032 return (0);
1033 /*
1034 * POSIX record locking dictates that any close releases ALL
1035 * locks owned by this process. This is handled by setting
1036 * a flag in the unlock to free ONLY locks obeying POSIX
1037 * semantics, and not to free BSD-style file locks.
1038 * If the descriptor was in a message, POSIX-style locks
1039 * aren't passed with the descriptor.
1040 */
1041 if (p && (p->p_flag & P_ADVLOCK) && fp->f_type == DTYPE_VNODE) {
1042 lf.l_whence = SEEK_SET;
1043 lf.l_start = 0;
1044 lf.l_len = 0;
1045 lf.l_type = F_UNLCK;
1046 vp = (struct vnode *)fp->f_data;
1047 (void) VOP_ADVLOCK(vp, (caddr_t)p, F_UNLCK, &lf, F_POSIX);
1048 }
1049 if (--fp->f_count > 0)
1050 return (0);
1051 if (fp->f_count < 0)
1052 panic("closef: count < 0");
1053 if ((fp->f_flag & FHASLOCK) && fp->f_type == DTYPE_VNODE) {
1054 lf.l_whence = SEEK_SET;
1055 lf.l_start = 0;
1056 lf.l_len = 0;
1057 lf.l_type = F_UNLCK;
1058 vp = (struct vnode *)fp->f_data;
1059 (void) VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK);
1060 }
1061 if (fp->f_ops)
1062 error = (*fp->f_ops->fo_close)(fp, p);
1063 else
1064 error = 0;
1065 ffree(fp);
1066 return (error);
1067}
1068
1069/*
1070 * Apply an advisory lock on a file descriptor.
1071 *
1072 * Just attempt to get a record lock of the requested type on
1073 * the entire file (l_whence = SEEK_SET, l_start = 0, l_len = 0).
1074 */
1075#ifndef _SYS_SYSPROTO_H_
1076struct flock_args {
1077 int fd;
1078 int how;
1079};
1080#endif
1081/* ARGSUSED */
1082int
1083flock(p, uap)
1084 struct proc *p;
1085 register struct flock_args *uap;
1086{
1087 register struct filedesc *fdp = p->p_fd;
1088 register struct file *fp;
1089 struct vnode *vp;
1090 struct flock lf;
1091
1092 if ((unsigned)uap->fd >= fdp->fd_nfiles ||
1093 (fp = fdp->fd_ofiles[uap->fd]) == NULL)
1094 return (EBADF);
1095 if (fp->f_type != DTYPE_VNODE)
1096 return (EOPNOTSUPP);
1097 vp = (struct vnode *)fp->f_data;
1098 lf.l_whence = SEEK_SET;
1099 lf.l_start = 0;
1100 lf.l_len = 0;
1101 if (uap->how & LOCK_UN) {
1102 lf.l_type = F_UNLCK;
1103 fp->f_flag &= ~FHASLOCK;
1104 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_UNLCK, &lf, F_FLOCK));
1105 }
1106 if (uap->how & LOCK_EX)
1107 lf.l_type = F_WRLCK;
1108 else if (uap->how & LOCK_SH)
1109 lf.l_type = F_RDLCK;
1110 else
1111 return (EBADF);
1112 fp->f_flag |= FHASLOCK;
1113 if (uap->how & LOCK_NB)
1114 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf, F_FLOCK));
1115 return (VOP_ADVLOCK(vp, (caddr_t)fp, F_SETLK, &lf, F_FLOCK|F_WAIT));
1116}
1117
1118/*
1119 * File Descriptor pseudo-device driver (/dev/fd/).
1120 *
1121 * Opening minor device N dup()s the file (if any) connected to file
1122 * descriptor N belonging to the calling process. Note that this driver
1123 * consists of only the ``open()'' routine, because all subsequent
1124 * references to this file will be direct to the other driver.
1125 */
1126/* ARGSUSED */
1127static int
1128fdopen(dev, mode, type, p)
1129 dev_t dev;
1130 int mode, type;
1131 struct proc *p;
1132{
1133
1134 /*
1135 * XXX Kludge: set curproc->p_dupfd to contain the value of the
1136 * the file descriptor being sought for duplication. The error
1137 * return ensures that the vnode for this device will be released
1138 * by vn_open. Open will detect this special error and take the
1139 * actions in dupfdopen below. Other callers of vn_open or VOP_OPEN
1140 * will simply report the error.
1141 */
1142 p->p_dupfd = minor(dev);
1143 return (ENODEV);
1144}
1145
1146/*
1147 * Duplicate the specified descriptor to a free descriptor.
1148 */
1149int
1150dupfdopen(fdp, indx, dfd, mode, error)
1151 register struct filedesc *fdp;
1152 register int indx, dfd;
1153 int mode;
1154 int error;
1155{
1156 register struct file *wfp;
1157 struct file *fp;
1158
1159 /*
1160 * If the to-be-dup'd fd number is greater than the allowed number
1161 * of file descriptors, or the fd to be dup'd has already been
1162 * closed, reject. Note, check for new == old is necessary as
1163 * falloc could allocate an already closed to-be-dup'd descriptor
1164 * as the new descriptor.
1165 */
1166 fp = fdp->fd_ofiles[indx];
1167 if ((u_int)dfd >= fdp->fd_nfiles ||
1168 (wfp = fdp->fd_ofiles[dfd]) == NULL || fp == wfp)
1169 return (EBADF);
1170
1171 /*
1172 * There are two cases of interest here.
1173 *
1174 * For ENODEV simply dup (dfd) to file descriptor
1175 * (indx) and return.
1176 *
1177 * For ENXIO steal away the file structure from (dfd) and
1178 * store it in (indx). (dfd) is effectively closed by
1179 * this operation.
1180 *
1181 * Any other error code is just returned.
1182 */
1183 switch (error) {
1184 case ENODEV:
1185 /*
1186 * Check that the mode the file is being opened for is a
1187 * subset of the mode of the existing descriptor.
1188 */
1189 if (((mode & (FREAD|FWRITE)) | wfp->f_flag) != wfp->f_flag)
1190 return (EACCES);
1191 fdp->fd_ofiles[indx] = wfp;
1192 fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1193 wfp->f_count++;
1194 if (indx > fdp->fd_lastfile)
1195 fdp->fd_lastfile = indx;
1196 return (0);
1197
1198 case ENXIO:
1199 /*
1200 * Steal away the file pointer from dfd, and stuff it into indx.
1201 */
1202 fdp->fd_ofiles[indx] = fdp->fd_ofiles[dfd];
1203 fdp->fd_ofiles[dfd] = NULL;
1204 fdp->fd_ofileflags[indx] = fdp->fd_ofileflags[dfd];
1205 fdp->fd_ofileflags[dfd] = 0;
1206 /*
1207 * Complete the clean up of the filedesc structure by
1208 * recomputing the various hints.
1209 */
1210 if (indx > fdp->fd_lastfile)
1211 fdp->fd_lastfile = indx;
1212 else
1213 while (fdp->fd_lastfile > 0 &&
1214 fdp->fd_ofiles[fdp->fd_lastfile] == NULL)
1215 fdp->fd_lastfile--;
1216 if (dfd < fdp->fd_freefile)
1217 fdp->fd_freefile = dfd;
1218 return (0);
1219
1220 default:
1221 return (error);
1222 }
1223 /* NOTREACHED */
1224}
1225
1226/*
1227 * Get file structures.
1228 */
1229static int
1230sysctl_kern_file SYSCTL_HANDLER_ARGS
1231{
1232 int error;
1233 struct file *fp;
1234
1235 if (!req->oldptr) {
1236 /*
1237 * overestimate by 10 files
1238 */
1239 return (SYSCTL_OUT(req, 0, sizeof(filehead) +
1240 (nfiles + 10) * sizeof(struct file)));
1241 }
1242
1243 error = SYSCTL_OUT(req, (caddr_t)&filehead, sizeof(filehead));
1244 if (error)
1245 return (error);
1246
1247 /*
1248 * followed by an array of file structures
1249 */
1250 for (fp = filehead.lh_first; fp != NULL; fp = fp->f_list.le_next) {
1251 error = SYSCTL_OUT(req, (caddr_t)fp, sizeof (struct file));
1252 if (error)
1253 return (error);
1254 }
1255 return (0);
1256}
1257
1258SYSCTL_PROC(_kern, KERN_FILE, file, CTLTYPE_OPAQUE|CTLFLAG_RD,
1259 0, 0, sysctl_kern_file, "S,file", "");
1260
1261SYSCTL_INT(_kern, KERN_MAXFILESPERPROC, maxfilesperproc,
1262 CTLFLAG_RW, &maxfilesperproc, 0, "");
1263
1264SYSCTL_INT(_kern, KERN_MAXFILES, maxfiles, CTLFLAG_RW, &maxfiles, 0, "");
1265
1266static fildesc_devsw_installed = 0;
1267#ifdef DEVFS
1268static void *devfs_token_stdin;
1269static void *devfs_token_stdout;
1270static void *devfs_token_stderr;
1271static void *devfs_token_fildesc[NUMFDESC];
1272#endif
1273
1274static void fildesc_drvinit(void *unused)
1275{
1276 dev_t dev;
1277#ifdef DEVFS
1278 int fd;
1279#endif
1280
1281 if( ! fildesc_devsw_installed ) {
1282 dev = makedev(CDEV_MAJOR,0);
1283 cdevsw_add(&dev,&fildesc_cdevsw,NULL);
1284 fildesc_devsw_installed = 1;
1285#ifdef DEVFS
1286 for (fd = 0; fd < NUMFDESC; fd++)
1287 devfs_token_fildesc[fd] =
1288 devfs_add_devswf(&fildesc_cdevsw, fd, DV_CHR,
1289 UID_BIN, GID_BIN, 0666,
1290 "fd/%d", fd);
1291 devfs_token_stdin =
1292 devfs_add_devswf(&fildesc_cdevsw, 0, DV_CHR,
1293 UID_ROOT, GID_WHEEL, 0666,
1294 "stdin");
1295 devfs_token_stdout =
1296 devfs_add_devswf(&fildesc_cdevsw, 1, DV_CHR,
1297 UID_ROOT, GID_WHEEL, 0666,
1298 "stdout");
1299 devfs_token_stderr =
1300 devfs_add_devswf(&fildesc_cdevsw, 2, DV_CHR,
1301 UID_ROOT, GID_WHEEL, 0666,
1302 "stderr");
1303#endif
1304 }
1305}
1306
1307SYSINIT(fildescdev,SI_SUB_DRIVERS,SI_ORDER_MIDDLE+CDEV_MAJOR,
1308 fildesc_drvinit,NULL)
1309
1310
|