Home | History | Annotate | Download | only in fifofs

Lines Matching defs:wso

130 	struct socket	*rso, *wso;
144 		error = socreate(AF_LOCAL, &wso, SOCK_STREAM, 0, l, rso);
150 		fip->fi_writesock = wso;
151 		solock(wso);
152 		if ((error = unp_connect2(wso, rso)) != 0) {
153 			sounlock(wso);
154 			(void)soclose(wso);
171 		if (wso->so_snd.sb_lowat < PIPE_BUF) {
172 			wso->so_snd.sb_hiwat = PIPE_BUF * 2;
174 		wso->so_snd.sb_lowat = PIPE_BUF;
178 		wso->so_state |= SS_CANTRCVMORE;
184 		wso = fip->fi_writesock;
186 		solock(wso);
191 			wso->so_state &= ~SS_CANTSENDMORE;
207 				    wso->so_lock);
208 				sounlock(wso);
212 				solock(wso);
220 				sounlock(wso);
227 				    wso->so_lock);
228 				sounlock(wso);
232 				solock(wso);
236 	sounlock(wso);
300 	struct socket	*wso;
303 	wso = ap->a_vp->v_fifoinfo->fi_writesock;
310 	error = (*wso->so_send)(wso, NULL, ap->a_uio, 0, NULL, sflags, curlwp);
359 	struct socket	*wso = ap->a_vp->v_fifoinfo->fi_writesock;
372 	} else if (wso != NULL) {
373 		lso = wso;
382 	KASSERT(wso == NULL || lso->so_lock == wso->so_lock);
406 	if (wso != NULL && (revents & POLLHUP) == 0) {
408 		if (events != 0 && sowritable(wso)) {
412 			selrecord(curlwp, &wso->so_snd.sb_sel);
413 			wso->so_snd.sb_flags |= SB_NOTIFY;
485 	struct socket *wso, *rso;
491 	wso = fip->fi_writesock;
493 	solock(wso);
497 			socantsendmore(wso);
505 			socantsendmore(wso);
510 		sounlock(wso);
512 		(void) soclose(wso);
518 		sounlock(wso);