bsd/kern/uipc_usrreq.c

1864 	struct fileglob *fg;
1875 			fg = *rp;
1876 			unp_discard_fdlocked(fg, p);
1898 			fg = *rp;
1900 			unp_discard_fdlocked(fg, p);
1906 		fg = rp[i];
1911 		fp->f_fglob = fg;
1912 		fg_removeuipc(fg);
2035 	struct fileglob *fg, *nextfg;
2055 	for (fg = fmsghead.lh_first; fg != 0; fg = fg->f_msglist.le_next) {
2056 		lck_mtx_lock(&fg->fg_lock);
2057 		fg->fg_flag &= ~(FMARK|FDEFER);
2058 		lck_mtx_unlock(&fg->fg_lock);
2061 		for (fg = fmsghead.lh_first; fg != 0;
2062 		    fg = fg->f_msglist.le_next) {
2063 			lck_mtx_lock(&fg->fg_lock);
2067 			if (fg->fg_count == 0) {
2068 				lck_mtx_unlock(&fg->fg_lock);
2076 			if (fg->fg_flag & FDEFER) {
2077 				fg->fg_flag &= ~FDEFER;
2084 				if (fg->fg_flag & FMARK) {
2085 					lck_mtx_unlock(&fg->fg_lock);
2093 				if (fg->fg_count == fg->fg_msgcount) {
2094 					lck_mtx_unlock(&fg->fg_lock);
2101 				fg->fg_flag |= FMARK;
2108 			if (FILEGLOB_DTYPE(fg) != DTYPE_SOCKET ||
2109 			    (so = (struct socket *)fg->fg_data) == 0) {
2110 				lck_mtx_unlock(&fg->fg_lock);
2115 				lck_mtx_unlock(&fg->fg_lock);
2148 			lck_mtx_unlock(&fg->fg_lock);
2196 	for (nunref = 0, fg = fmsghead.lh_first, fpp = extra_ref; fg != 0;
2197 	    fg = nextfg) {
2198 		lck_mtx_lock(&fg->fg_lock);
2200 		nextfg = fg->f_msglist.le_next;
2204 		if (fg->fg_count == 0) {
2205 			lck_mtx_unlock(&fg->fg_lock);
2214 		if (fg->fg_count == fg->fg_msgcount && !(fg->fg_flag & FMARK)) {
2215 			fg->fg_count++;
2216 			*fpp++ = fg;
2219 		lck_mtx_unlock(&fg->fg_lock);
2311 unp_mark(struct fileglob *fg)
2313 	lck_mtx_lock(&fg->fg_lock);
2315 	if (fg->fg_flag & FMARK) {
2316 		lck_mtx_unlock(&fg->fg_lock);
2319 	fg->fg_flag |= (FMARK|FDEFER);
2321 	lck_mtx_unlock(&fg->fg_lock);
2328 unp_discard(struct fileglob *fg)
2335 	unp_discard_fdlocked(fg, p);
2339 unp_discard_fdlocked(struct fileglob *fg, proc_t p)
2341 	fg_removeuipc(fg);
2344 	(void) closef_locked((struct fileproc *)0, fg, p);