Lines Matching refs:ufp

287 	uf_entry_t *ufp = &fip->fi_list[fd];  in fd_reserve()  local
290 ASSERT((ufp->uf_busy == 0 && incr == 1) || in fd_reserve()
291 (ufp->uf_busy == 1 && incr == -1)); in fd_reserve()
292 ASSERT(MUTEX_HELD(&ufp->uf_lock)); in fd_reserve()
298 ufp->uf_busy += incr; in fd_reserve()
589 uf_entry_t *ufp; in getf_gen() local
601 UF_ENTER(ufp, fip, fd); in getf_gen()
603 if ((fp = ufp->uf_file) == NULL) { in getf_gen()
604 UF_EXIT(ufp); in getf_gen()
611 ufp->uf_refcnt++; in getf_gen()
613 *genp = ufp->uf_gen; in getf_gen()
618 UF_EXIT(ufp); in getf_gen()
642 uf_entry_t *ufp; in closeandsetf() local
668 UF_ENTER(ufp, fip, fd); in closeandsetf()
669 while (ufp->uf_busy && ufp->uf_file == NULL) { in closeandsetf()
671 cv_wait_stop(&ufp->uf_wanted_cv, &ufp->uf_lock, 250); in closeandsetf()
672 UF_EXIT(ufp); in closeandsetf()
674 UF_ENTER(ufp, fip, fd); in closeandsetf()
676 if ((fp = ufp->uf_file) == NULL) { in closeandsetf()
677 ASSERT(ufp->uf_fpollinfo == NULL); in closeandsetf()
678 ASSERT(ufp->uf_flag == 0); in closeandsetf()
680 ufp->uf_file = newfp; in closeandsetf()
681 ufp->uf_gen++; in closeandsetf()
682 UF_EXIT(ufp); in closeandsetf()
688 UF_ENTER(ufp, fip, fd); in closeandsetf()
689 if ((fp = ufp->uf_file) == NULL) { in closeandsetf()
690 UF_EXIT(ufp); in closeandsetf()
695 ASSERT(ufp->uf_busy); in closeandsetf()
696 ufp->uf_file = NULL; in closeandsetf()
697 ufp->uf_flag = 0; in closeandsetf()
711 ASSERT(ufp->uf_refcnt == 0 || p->p_lwpcnt > 1); in closeandsetf()
712 if (ufp->uf_refcnt > 0) { in closeandsetf()
729 UF_EXIT(ufp); in closeandsetf()
736 UF_ENTER(ufp, fip, fd); in closeandsetf()
737 ASSERT(ufp->uf_file == NULL); in closeandsetf()
739 if (ufp->uf_refcnt > 0) { in closeandsetf()
754 UF_EXIT(ufp); in closeandsetf()
759 UF_ENTER(ufp, fip, fd); in closeandsetf()
760 ASSERT(ufp->uf_file == NULL); in closeandsetf()
766 while (ufp->uf_refcnt > 0) { in closeandsetf()
767 cv_wait_stop(&ufp->uf_closing_cv, &ufp->uf_lock, 250); in closeandsetf()
773 UF_EXIT(ufp); in closeandsetf()
774 UF_ENTER(ufp, fip, fd); in closeandsetf()
781 if (ufp->uf_fpollinfo != NULL) in closeandsetf()
782 checkwfdlist(fp->f_vnode, ufp->uf_fpollinfo); in closeandsetf()
794 pfd = ufp->uf_portfd; in closeandsetf()
795 ufp->uf_portfd = NULL; in closeandsetf()
796 fpip = ufp->uf_fpollinfo; in closeandsetf()
797 ufp->uf_fpollinfo = NULL; in closeandsetf()
800 UF_EXIT(ufp); in closeandsetf()
824 uf_entry_t *ufp; in releasef() local
826 UF_ENTER(ufp, fip, fd); in releasef()
827 ASSERT(ufp->uf_refcnt > 0); in releasef()
829 if (--ufp->uf_refcnt == 0) in releasef()
830 cv_broadcast(&ufp->uf_closing_cv); in releasef()
831 UF_EXIT(ufp); in releasef()
840 uf_entry_t *ufp; in areleasef() local
842 UF_ENTER(ufp, fip, fd); in areleasef()
843 ASSERT(ufp->uf_refcnt > 0); in areleasef()
844 if (--ufp->uf_refcnt == 0) in areleasef()
845 cv_broadcast(&ufp->uf_closing_cv); in areleasef()
846 UF_EXIT(ufp); in areleasef()
930 uf_entry_t *ufp; in closeall() local
932 ufp = fip->fi_list; in closeall()
933 for (fd = 0; fd < fip->fi_nfiles; fd++, ufp++) { in closeall()
934 if ((fp = ufp->uf_file) != NULL) { in closeall()
935 ufp->uf_file = NULL; in closeall()
936 if (ufp->uf_portfd != NULL) { in closeall()
939 pfd = ufp->uf_portfd; in closeall()
940 ufp->uf_portfd = NULL; in closeall()
943 ASSERT(ufp->uf_fpollinfo == NULL); in closeall()
1033 uf_entry_t *ufp; in ufalloc_file() local
1068 UF_ENTER(ufp, fip, fd); in ufalloc_file()
1070 ASSERT(ufp->uf_file == NULL); in ufalloc_file()
1071 ufp->uf_file = fp; in ufalloc_file()
1073 ufp->uf_gen++; in ufalloc_file()
1075 UF_EXIT(ufp); in ufalloc_file()
1217 uf_entry_t *ufp; in setf() local
1224 UF_ENTER(ufp, fip, fd); in setf()
1228 UF_ENTER(ufp, fip, fd); in setf()
1229 ASSERT(ufp->uf_busy); in setf()
1230 ufp->uf_gen++; in setf()
1232 ASSERT(ufp->uf_fpollinfo == NULL); in setf()
1233 ASSERT(ufp->uf_flag == 0); in setf()
1234 ufp->uf_file = fp; in setf()
1235 cv_broadcast(&ufp->uf_wanted_cv); in setf()
1236 UF_EXIT(ufp); in setf()
1248 uf_entry_t *ufp; in f_getfl() local
1255 UF_ENTER(ufp, fip, fd); in f_getfl()
1256 if ((fp = ufp->uf_file) == NULL) in f_getfl()
1270 UF_EXIT(ufp); in f_getfl()
1285 uf_entry_t *ufp; in f_getfd_error() local
1293 UF_ENTER(ufp, fip, fd); in f_getfd_error()
1294 if ((fp = ufp->uf_file) == NULL) { in f_getfd_error()
1297 flag = ufp->uf_flag; in f_getfd_error()
1303 UF_EXIT(ufp); in f_getfd_error()
1329 uf_entry_t *ufp; in f_setfd_int() local
1335 UF_ENTER(ufp, fip, fd); in f_setfd_int()
1336 if (ufp->uf_file == NULL) { in f_setfd_int()
1341 ufp->uf_flag |= flags; in f_setfd_int()
1343 ufp->uf_flag = flags; in f_setfd_int()
1347 UF_EXIT(ufp); in f_setfd_int()
1465 uf_entry_t *ufp; in fcnt_add() local
1468 ufp = fip->fi_list; in fcnt_add()
1469 for (i = 0; i < fip->fi_nfiles; i++, ufp++) { in fcnt_add()
1470 if ((fp = ufp->uf_file) != NULL) { in fcnt_add()
1489 uf_entry_t *ufp = fip->fi_list; in close_exec() local
1491 for (int fd = 0; fd < fip->fi_nfiles; fd++, ufp++) { in close_exec()
1498 if ((fp = ufp->uf_file) == NULL) in close_exec()
1501 if ((ufp->uf_flag & FD_CLOEXEC) || in close_exec()
1504 fpollinfo_t *fpip = ufp->uf_fpollinfo; in close_exec()
1507 mutex_enter(&ufp->uf_lock); in close_exec()
1510 ufp->uf_file = NULL; in close_exec()
1511 ufp->uf_fpollinfo = NULL; in close_exec()
1512 ufp->uf_flag = 0; in close_exec()
1524 pfd = ufp->uf_portfd; in close_exec()
1525 ufp->uf_portfd = NULL; in close_exec()
1528 mutex_exit(&ufp->uf_lock); in close_exec()
1534 } else if ((ufp->uf_flag & FD_CLOFORK) != 0) { in close_exec()
1551 mutex_enter(&ufp->uf_lock); in close_exec()
1552 ufp->uf_flag &= ~FD_CLOFORK; in close_exec()
1553 mutex_exit(&ufp->uf_lock); in close_exec()
1681 uf_entry_t *ufp; in fisopen() local
1685 UF_ENTER(ufp, fip, fd); in fisopen()
1686 if ((fp = ufp->uf_file) != NULL && in fisopen()
1688 UF_EXIT(ufp); in fisopen()
1692 UF_EXIT(ufp); in fisopen()
1708 uf_entry_t *ufp; in files_can_change_zones() local
1712 UF_ENTER(ufp, fip, fd); in files_can_change_zones()
1713 if ((fp = ufp->uf_file) != NULL && in files_can_change_zones()
1715 UF_EXIT(ufp); in files_can_change_zones()
1719 UF_EXIT(ufp); in files_can_change_zones()
1737 curthread_in_plist(uf_entry_t *ufp) in curthread_in_plist() argument
1741 ASSERT(MUTEX_HELD(&ufp->uf_lock)); in curthread_in_plist()
1742 for (fpip = ufp->uf_fpollinfo; fpip; fpip = fpip->fp_next) in curthread_in_plist()
1757 uf_entry_t *ufp; in checkfpollinfo() local
1761 UF_ENTER(ufp, fip, fd); in checkfpollinfo()
1762 ASSERT(!curthread_in_plist(ufp)); in checkfpollinfo()
1763 UF_EXIT(ufp); in checkfpollinfo()
1778 uf_entry_t *ufp; in infpollinfo() local
1781 UF_ENTER(ufp, fip, fd); in infpollinfo()
1782 rc = curthread_in_plist(ufp); in infpollinfo()
1783 UF_EXIT(ufp); in infpollinfo()
1797 struct uf_entry *ufp; in addfpollinfo() local
1803 UF_ENTER(ufp, fip, fd); in addfpollinfo()
1808 ASSERT(!curthread_in_plist(ufp)); in addfpollinfo()
1812 ASSERT(ufp->uf_refcnt >= 1); in addfpollinfo()
1813 fpip->fp_next = ufp->uf_fpollinfo; in addfpollinfo()
1814 ufp->uf_fpollinfo = fpip; in addfpollinfo()
1815 UF_EXIT(ufp); in addfpollinfo()
1824 struct uf_entry *ufp; in delfpollinfo() local
1829 UF_ENTER(ufp, fip, fd); in delfpollinfo()
1830 for (fpipp = &ufp->uf_fpollinfo; in delfpollinfo()
1843 ASSERT(!curthread_in_plist(ufp)); in delfpollinfo()
1844 UF_EXIT(ufp); in delfpollinfo()
1855 struct uf_entry *ufp; in addfd_port() local
1858 UF_ENTER(ufp, fip, fd); in addfd_port()
1862 ASSERT(ufp->uf_refcnt >= 1); in addfd_port()
1863 if (ufp->uf_portfd == NULL) { in addfd_port()
1865 ufp->uf_portfd = pfd; in addfd_port()
1868 pfd->pfd_next = ufp->uf_portfd; in addfd_port()
1869 ufp->uf_portfd = pfd; in addfd_port()
1872 UF_EXIT(ufp); in addfd_port()
1878 struct uf_entry *ufp; in delfd_port() local
1881 UF_ENTER(ufp, fip, fd); in delfd_port()
1885 ASSERT(ufp->uf_refcnt >= 1); in delfd_port()
1886 if (ufp->uf_portfd == pfd) { in delfd_port()
1888 ufp->uf_portfd = pfd->pfd_next; in delfd_port()
1894 UF_EXIT(ufp); in delfd_port()